Merge branch 'dev' into hallvictoria/abstract-timer

Author: gavin-aguiar

.flake8

@@ -3,3 +3,6 @@ ignore = W503,E402,E731
 exclude =
     .git, __pycache__, build, dist, .eggs, .github, .local,
     Samples, azure/functions/_thirdparty, docs/, .venv*/, .env*/, .vscode/, venv*, pyvenv*
+max-line-length = 100
+extend-ignore = D401, D101, D105, D400, D205, D102, D100, D107, DAR401, DAR101, DAR201
+strictness = short

azure/functions/__init__.py

@@ -104,4 +104,4 @@
     'BlobSource'
 )
 
-__version__ = '1.24.0b2'
+__version__ = '1.24.0b3'

azure/functions/_cosmosdb.py

@@ -2,9 +2,9 @@
 # Licensed under the MIT License.
 
 import collections
-import json
 
 from . import _abc
+from ._jsonutils import json
 
 
 class Document(_abc.Document, collections.UserDict):

azure/functions/_http.py

@@ -4,10 +4,10 @@
 import collections.abc
 import http
 import io
-import json
 import types
 import typing
 
+from ._jsonutils import json
 from werkzeug import formparser as _wk_parser
 from werkzeug import http as _wk_http
 from werkzeug.datastructures import (Headers, FileStorage, MultiDict,

azure/functions/_jsonutils.py

@@ -0,0 +1,78 @@
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License.
+
+from abc import ABC, abstractmethod
+from typing import Any, Union
+from types import SimpleNamespace
+
+
+"""
+Azure Functions JSON utilities.
+This module provides a JSON interface that can be used to serialize and
+deserialize objects to and from JSON format. It supports both the `orjson`
+and the standard `json` libraries, falling back to the standard library
+if `orjson` is not available (installed).
+"""
+
+
+try:
+    import orjson as _orjson
+except ImportError:
+    _orjson = None
+
+# Standard library is always present
+import json as _std_json
+
+
+class JsonInterface(ABC):
+    @abstractmethod
+    def dumps(self, obj: Any) -> str:
+        pass
+
+    @abstractmethod
+    def loads(self, s: Union[str, bytes, bytearray]) -> Any:
+        pass
+
+
+class OrJsonAdapter(JsonInterface):
+    def __init__(self):
+        assert _orjson is not None
+        self.orjson = _orjson
+
+    def dumps(self, obj: Any) -> str:
+        # orjson.dumps returns bytes, decode to str
+        return self.orjson.dumps(obj).decode("utf-8")
+
+    def loads(self, s: Union[str, bytes, bytearray]) -> Any:
+        return self.orjson.loads(s)
+
+
+class StdJsonAdapter(JsonInterface):
+    def __init__(self):
+        self.json = _std_json
+
+    def dumps(self, obj: Any) -> str:
+        return self.json.dumps(obj)
+
+    def loads(self, s: Union[str, bytes, bytearray]) -> Any:
+        return self.json.loads(s)
+
+
+if _orjson is not None:
+    json_impl = OrJsonAdapter()
+else:
+    json_impl = StdJsonAdapter()
+
+
+def dumps(obj: Any) -> str:
+    return json_impl.dumps(obj)
+
+
+def loads(s: Union[str, bytes, bytearray]) -> Any:
+    return json_impl.loads(s)
+
+
+json = SimpleNamespace(
+    dumps=dumps,
+    loads=loads
+)

azure/functions/_mysql.py

@@ -2,7 +2,8 @@
 # Licensed under the MIT License.
 import abc
 import collections
-import json
+
+from ._jsonutils import json
 
 
 class BaseMySqlRow(abc.ABC):

azure/functions/_queue.py

@@ -2,10 +2,10 @@
 # Licensed under the MIT License.
 
 import datetime
-import json
 import typing
 
 from . import _abc
+from ._jsonutils import json
 
 
 class QueueMessage(_abc.QueueMessage):

azure/functions/_sql.py

@@ -2,7 +2,8 @@
 # Licensed under the MIT License.
 import abc
 import collections
-import json
+
+from ._jsonutils import json
 
 
 class BaseSqlRow(abc.ABC):

azure/functions/cosmosdb.py

@@ -2,10 +2,10 @@
 # Licensed under the MIT License.
 
 import collections.abc
-import json
 import typing
 
 from azure.functions import _cosmosdb as cdb
+from ._jsonutils import json
 
 from . import meta