Forward parsed json body to function handler

zhulik · Feb 8, 2023 · 952ad70 · 952ad70
1 parent fc633b5
commit 952ad70
Show file tree

Hide file tree

Showing 5 changed files with 16 additions and 7 deletions.
diff --git a/backup-stats-collector/function/lib/function/handler.rb b/backup-stats-collector/function/lib/function/handler.rb
@@ -3,8 +3,9 @@
 class Function::Handler
   METRICS_PREFIX = ENV.fetch("METRICS_PREFIX")
 
-  def initialize(env)
+  def initialize(env, body: nil)
     @env = env
+    @body = body
   end
 
   def call

diff --git a/base/config.ru b/base/config.ru
@@ -24,7 +24,13 @@ handler = lambda do
 
   raise Function::Unauthorized if token != AUTH_TOKEN
 
-  [200, {}, Function::Handler.new(request.env).call]
+  body = begin
+    JSON.parse(request.body.read, symbolize_names: true)
+  rescue StandardError
+    nil
+  end
+
+  [200, {}, Function::Handler.new(request.env, body:).call]
 end
 
 get "/*", &handler

diff --git a/hass-listener/function/lib/function/handler.rb b/hass-listener/function/lib/function/handler.rb
@@ -1,8 +1,9 @@
 # frozen_string_literal: true
 
 class Function::Handler
-  def initialize(env)
+  def initialize(env, body: nil)
     @env = env
+    @body = body
   end
 
   def call

diff --git a/notifier/function/lib/function/handler.rb b/notifier/function/lib/function/handler.rb
@@ -9,12 +9,12 @@ class Function::Handler
 
   TELEGRAM = Function::Telegram.new(TELEGRAM_TOKEN, TELEGRAM_CHATS)
 
-  def initialize(env)
+  def initialize(env, body: nil)
     @env = env
+    @body = body
   end
 
   def call
-    pp(@env.to_json)
-    @env.to_json
+    @body
   end
 end
diff --git a/time-passed/function/lib/function/handler.rb b/time-passed/function/lib/function/handler.rb
@@ -9,8 +9,9 @@ class Function::Handler
 
   METRICS_PREFIX = ENV.fetch("METRICS_PREFIX")
 
-  def initialize(env)
+  def initialize(env, body: nil)
     @env = env
+    @body = body
   end
 
   def call