refactor debug logging unit tests

Author: Victoria Hall

tests/unittests/log_filtering_functions/debug_logging/function.json renamed to tests/endtoend/debug_logging_functions/debug_logging/function.json

@@ -0,0 +1,17 @@
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License.
+
+import logging
+
+import azure.functions as func
+
+app = func.FunctionApp(http_auth_level=func.AuthLevel.ANONYMOUS)
+
+
+@app.route(route="debug_logging")
+def default_template(req: func.HttpRequest):
+    logging.info('logging info', exc_info=True)
+    logging.warning('logging warning', exc_info=True)
+    logging.debug('logging debug', exc_info=True)
+    logging.error('logging error', exc_info=True)
+    return 'OK-debug'

tests/unittests/log_filtering_functions/debug_logging/main.py renamed to tests/endtoend/debug_logging_functions/debug_logging/main.py

@@ -38,7 +38,7 @@ def tearDownClass(cls):
 
     @classmethod
     def get_script_dir(cls):
-        return testutils.UNIT_TESTS_FOLDER / 'log_filtering_functions'
+        return testutils.E2E_TESTS_FOLDER / 'debug_logging_functions'
 
     def test_debug_logging_enabled(self):
         """
@@ -72,7 +72,7 @@ def tearDownClass(cls):
 
     @classmethod
     def get_script_dir(cls):
-        return testutils.UNIT_TESTS_FOLDER / 'log_filtering_functions'
+        return testutils.E2E_TESTS_FOLDER / 'debug_logging_functions'
 
     def test_debug_logging_disabled(self):
         """
@@ -115,7 +115,7 @@ def tearDownClass(cls):
 
     @classmethod
     def get_script_dir(cls):
-        return testutils.UNIT_TESTS_FOLDER / 'log_filtering_functions'
+        return testutils.E2E_TESTS_FOLDER / 'debug_logging_functions'
 
     def test_debug_logging_filtered(self):
         """
@@ -131,3 +131,24 @@ def check_log_debug_logging_filtered(self, host_out: typing.List[str]):
         self.assertIn('logging warning', host_out)
         self.assertNotIn('logging debug', host_out)
         self.assertIn('logging error', host_out)
+
+
+class TestDebugLoggingEnabledFunctionsStein(TestDebugLoggingEnabledFunctions):
+
+    @classmethod
+    def get_script_dir(cls):
+        return testutils.E2E_TESTS_FOLDER / 'debug_logging_functions_stein'
+
+
+class TestDebugLoggingDisabledFunctionsStein(TestDebugLoggingDisabledFunctions):
+
+    @classmethod
+    def get_script_dir(cls):
+        return testutils.E2E_TESTS_FOLDER / 'debug_logging_functions_stein'
+
+
+class TestDebugLogEnabledHostFilteringFunctionsStein(TestDebugLogEnabledHostFilteringFunctions):  # noqa
+
+    @classmethod
+    def get_script_dir(cls):
+        return testutils.E2E_TESTS_FOLDER / 'debug_logging_functions_stein'

tests/endtoend/debug_logging_functions/debug_logging_functions_stein/function_app.py

@@ -267,3 +267,12 @@ def blob_cache(req: func.HttpRequest,
 def invalid_connection_info(req: func.HttpRequest,
                             client: blob.BlobClient) -> str:
     return client.download_blob(encoding='utf-8').readall()
+
+
+@app.function_name(name="nonexistent_blob")
+@app.route(route="nonexistent_blob")
+@app.blob_input(arg_name="client",
+                path="python-worker-tests/nonexistent-file.txt",
+                connection="AzureWebJobsStorage")
+def nonexistent_blob(req: func.HttpRequest, client: blob.BlobClient) -> str:
+    return client.download_blob(encoding='utf-8').readall()

tests/unittests/test_enable_debug_logging_functions.py renamed to tests/endtoend/test_debug_logging_functions.py

@@ -157,6 +157,27 @@ def test_deferred_bindings_enabled_decode(self):
 
         self.assertIsNotNone(obj)
 
+    def test_deferred_bindings_enabled_decode_failed(self):
+        binding = BlobClientConverter
+        pb = protos.ParameterBinding(name='test',
+                                     data=protos.TypedData(
+                                         string='test'))
+        sample_mbd = MockMBD(version="1.0",
+                             source="AzureStorageBlobs",
+                             content_type="application/json",
+                             content="{\"Connection\":\"NotARealConnectionString\","
+                                     "\"ContainerName\":"
+                                     "\"python-worker-tests\","
+                                     "\"BlobName\":"
+                                     "\"nonexistent-blob.txt\"}")
+        datum = datumdef.Datum(value=sample_mbd, type='model_binding_data')
+
+        with self.assertRaises(AttributeError):
+            # Decode will fail here because the connection string does not exist
+            meta.deferred_bindings_decode(binding=binding, pb=pb,
+                                          pytype=BlobClient, datum=datum,
+                                          metadata={})
+
     async def test_check_deferred_bindings_enabled(self):
         """
         check_deferred_bindings_enabled checks if deferred bindings is enabled at fx

tests/extension_tests/deferred_bindings_tests/deferred_bindings_blob_functions/function_app.py

@@ -190,3 +190,7 @@ def test_failed_client_creation(self):
         # Without the http_v2_enabled default definition, this request would time out.
         # Instead, it fails immediately
         self.assertEqual(r.status_code, 500)
+
+    def test_nonexistent_blob(self):
+        r = self.webhost.request('GET', 'nonexistent_blob')
+        self.assertEqual(r.status_code, 500)