fix

Signed-off-by: laminar <[email protected]>

Author: tpiperatgod

src/functions_framework/context/function_context.py

@@ -36,8 +36,8 @@ def __init__(self, name="", version="", dapr_triggers=None, http_trigger=None,
     def from_json(json_dct):
         name = json_dct.get('name')
         version = json_dct.get('version')
-        inputs_list = json_dct.get('inputs')
-        outputs_list = json_dct.get('outputs')
+        inputs_map = json_dct.get('inputs')
+        outputs_map = json_dct.get('outputs')
         _dapr_triggers = json_dct.get('triggers', {}).get('dapr', [])
         http_trigger = json_dct.get('triggers', {}).get('http', None)
         states = json_dct.get('states', {})
@@ -47,16 +47,16 @@ def from_json(json_dct):
         port = json_dct.get('port', 0)
 
         inputs = None
-        if inputs_list:
+        if inputs_map:
             inputs = {}
-            for k, v in inputs_list.items():
-                input = Component.from_json(v)
-                inputs[k] = input
+            for k, v in inputs_map.items():
+                _input = Component.from_json(v)
+                inputs[k] = _input
 
         outputs = None
-        if outputs_list:
+        if outputs_map:
             outputs = {}
-            for k, v in outputs_list.items():
+            for k, v in outputs_map.items():
                 output = Component.from_json(v)
                 outputs[k] = output
 
@@ -112,24 +112,18 @@ def from_json(json_dct):
 class HTTPRoute(object):
     """HTTP route."""
 
-    def __init__(self, port="", hostname="", rules=None):
+    def __init__(self, port=""):
         self.port = port
-        self.hostname = hostname
-        self.rules = rules
 
     def __str__(self):
-        return "{port: %s, hostname: %s, rules: %s}" % (
-            self.port,
-            self.hostname,
-            self.rules
+        return "{port: %s}" % (
+            self.port
         )
 
     @staticmethod
     def from_json(json_dct):
         port = json_dct.get('port', '')
-        hostnames = json_dct.get('route', {}).get('hostnames', '')
-        rules = json_dct.get('route', {}).get('rules', [])
-        return HTTPRoute(port, hostnames, rules)
+        return HTTPRoute(port)
 
 
 class DaprTrigger(object):

src/functions_framework/context/user_context.py

@@ -26,7 +26,7 @@ class UserContext(object):
     """Context for user."""
 
     def __init__(self, runtime_context: RuntimeContext = None,
-                binding_request=None, topic_event=None, http_request=None, logger=None):
+                 binding_request=None, topic_event=None, http_request=None, logger=None):
         self.runtime_context = runtime_context
         self.logger = logger
         self.out = FunctionOut(0, None, "", {})

src/functions_framework/triggers/dapr_trigger/dapr.py

@@ -11,8 +11,6 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-import logging
-
 from copy import deepcopy
 
 from cloudevents.sdk.event import v1
@@ -45,17 +43,13 @@ def start(self, context: RuntimeContext, logger=None):
                 def binding_handler(request: BindingRequest):
                     rt_ctx = deepcopy(context)
                     user_ctx = UserContext(runtime_context=rt_ctx, binding_request=request, logger=logger)
-                    logging.basicConfig(level=logging.DEBUG)
-                    logging.info('Received Message : ' + request.text())
                     self.user_function(user_ctx)
 
             if trigger.component_type.startswith("pubsub"):
                 @self.app.subscribe(pubsub_name=trigger.name, topic=trigger.topic)
                 def topic_handler(event: v1.Event):
                     rt_ctx = deepcopy(context)
                     user_ctx = UserContext(runtime_context=rt_ctx, topic_event=event, logger=logger)
-                    logging.basicConfig(level=logging.DEBUG)
-                    logging.info('Received Message : ' + event.data.__str__())
                     self.user_function(user_ctx)
 
         self.app.run(self.port)