Apply black formatter to examples and tests

seratch · seratch · commit 60c69fc85b6b · 2022-07-12T09:10:21.000+09:00
diff --git a/examples/aws_chalice/app.py b/examples/aws_chalice/app.py
@@ -25,9 +25,7 @@ def say_it(say):
     say("Done!")
 
 
-bolt_app.command("/hello-bolt-python-chalice")(
-    ack=respond_to_slack_within_3_seconds, lazy=[say_it]
-)
+bolt_app.command("/hello-bolt-python-chalice")(ack=respond_to_slack_within_3_seconds, lazy=[say_it])
 
 ChaliceSlackRequestHandler.clear_all_log_handlers()
 logging.basicConfig(format="%(asctime)s %(message)s", level=logging.DEBUG)
diff --git a/examples/django/myslackapp/settings.py b/examples/django/myslackapp/settings.py
@@ -20,9 +20,7 @@
 # See https://docs.djangoproject.com/en/3.2/howto/deployment/checklist/
 
 # TODO: CHANGE THIS IF YOU REUSE THIS APP
-SECRET_KEY = (
-    "This is just a example. You should not expose your secret key in real apps"
-)
+SECRET_KEY = "This is just a example. You should not expose your secret key in real apps"
 
 # SECURITY WARNING: don't run with debug turned on in production!
 DEBUG = True
diff --git a/examples/django/oauth_app/migrations/0002_token_rotation.py b/examples/django/oauth_app/migrations/0002_token_rotation.py
@@ -11,21 +11,11 @@ class Migration(migrations.Migration):
     ]
 
     operations = [
-        migrations.AddField(
-            "SlackBot", "bot_refresh_token", models.TextField(null=True)
-        ),
-        migrations.AddField(
-            "SlackBot", "bot_token_expires_at", models.DateTimeField(null=True)
-        ),
-        migrations.AddField(
-            "SlackInstallation", "bot_refresh_token", models.TextField(null=True)
-        ),
-        migrations.AddField(
-            "SlackInstallation", "bot_token_expires_at", models.DateTimeField(null=True)
-        ),
-        migrations.AddField(
-            "SlackInstallation", "user_refresh_token", models.TextField(null=True)
-        ),
+        migrations.AddField("SlackBot", "bot_refresh_token", models.TextField(null=True)),
+        migrations.AddField("SlackBot", "bot_token_expires_at", models.DateTimeField(null=True)),
+        migrations.AddField("SlackInstallation", "bot_refresh_token", models.TextField(null=True)),
+        migrations.AddField("SlackInstallation", "bot_token_expires_at", models.DateTimeField(null=True)),
+        migrations.AddField("SlackInstallation", "user_refresh_token", models.TextField(null=True)),
         migrations.AddField(
             "SlackInstallation",
             "user_token_expires_at",
diff --git a/examples/django/oauth_app/models.py b/examples/django/oauth_app/models.py
@@ -23,9 +23,7 @@ class SlackBot(models.Model):
 
     class Meta:
         indexes = [
-            models.Index(
-                fields=["client_id", "enterprise_id", "team_id", "installed_at"]
-            ),
+            models.Index(fields=["client_id", "enterprise_id", "team_id", "installed_at"]),
         ]
 
 
diff --git a/examples/falcon/async_app.py b/examples/falcon/async_app.py
@@ -9,9 +9,7 @@
 
 
 # @app.command("/bolt-py-proto", [lambda body: body["team_id"] == "T03E94MJU"])
-async def test_command(
-    logger: logging.Logger, body: dict, ack: AsyncAck, respond: AsyncRespond
-):
+async def test_command(logger: logging.Logger, body: dict, ack: AsyncAck, respond: AsyncRespond):
     logger.info(body)
     await ack("thanks!")
     await respond(
diff --git a/examples/falcon/async_oauth_app.py b/examples/falcon/async_oauth_app.py
@@ -9,9 +9,7 @@
 
 
 # @app.command("/bolt-py-proto", [lambda body: body["team_id"] == "T03E94MJU"])
-async def test_command(
-    logger: logging.Logger, body: dict, ack: AsyncAck, respond: AsyncRespond
-):
+async def test_command(logger: logging.Logger, body: dict, ack: AsyncAck, respond: AsyncRespond):
     logger.info(body)
     await ack("thanks!")
     await respond(
diff --git a/examples/google_cloud_functions/datastore.py b/examples/google_cloud_functions/datastore.py
@@ -48,11 +48,7 @@ def installation_key(
     ):
         enterprise_id = enterprise_id or "none"
         team_id = "none" if is_enterprise_install else team_id or "none"
-        name = (
-            f"{enterprise_id}-{team_id}-{user_id}"
-            if user_id
-            else f"{enterprise_id}-{team_id}"
-        )
+        name = f"{enterprise_id}-{team_id}-{user_id}" if user_id else f"{enterprise_id}-{team_id}"
         if suffix is not None:
             name += "-" + suffix
         return self.datastore_client.key("installations", name)
@@ -208,9 +204,7 @@ def delete_all(
         team_id: Optional[str],
     ):
         self.delete_bot(enterprise_id=enterprise_id, team_id=team_id)
-        self.delete_installation(
-            enterprise_id=enterprise_id, team_id=team_id, user_id=None
-        )
+        self.delete_installation(enterprise_id=enterprise_id, team_id=team_id, user_id=None)
 
 
 class GoogleDatastoreOAuthStateStore(OAuthStateStore):
@@ -244,9 +238,7 @@ def consume(self, state: str) -> bool:
 
     def issue(self, *args, **kwargs) -> str:
         state_value = str(uuid4())
-        entity: Entity = datastore.Entity(
-            key=self.datastore_client.key(self.collection_id, state_value)
-        )
+        entity: Entity = datastore.Entity(key=self.datastore_client.key(self.collection_id, state_value))
         entity.update(value=state_value)
         self.datastore_client.put(entity)
         return state_value
diff --git a/examples/lazy_async_modals_app.py b/examples/lazy_async_modals_app.py
@@ -102,9 +102,7 @@ async def open_modal(body, client, logger):
 
 @app.options("es_a")
 async def show_options(ack):
-    await ack(
-        {"options": [{"text": {"type": "plain_text", "text": "Maru"}, "value": "maru"}]}
-    )
+    await ack({"options": [{"text": {"type": "plain_text", "text": "Maru"}, "value": "maru"}]})
 
 
 @app.options("mes_a")
diff --git a/examples/lazy_modals_app.py b/examples/lazy_modals_app.py
@@ -103,9 +103,7 @@ def open_modal(body, client, logger):
 
 @app.options("es_a")
 def show_options(ack):
-    ack(
-        {"options": [{"text": {"type": "plain_text", "text": "Maru"}, "value": "maru"}]}
-    )
+    ack({"options": [{"text": {"type": "plain_text", "text": "Maru"}, "value": "maru"}]})
 
 
 @app.options("mes_a")
diff --git a/examples/message_events.py b/examples/message_events.py
@@ -61,9 +61,7 @@ def detect_deletion(say: Say, body: dict):
     event={"type": "message", "subtype": re.compile("(me_message)|(file_share)")},
     middleware=[extract_subtype],
 )
-def add_reaction(
-    body: dict, client: WebClient, context: BoltContext, logger: logging.Logger
-):
+def add_reaction(body: dict, client: WebClient, context: BoltContext, logger: logging.Logger):
     subtype = context["subtype"]  # by extract_subtype
     logger.info(f"subtype: {subtype}")
     message_ts = body["event"]["ts"]
diff --git a/examples/modals_app.py b/examples/modals_app.py
@@ -105,9 +105,7 @@ def handle_command(body, ack, respond, client, logger):
 
 @app.options("es_a")
 def show_options(ack):
-    ack(
-        {"options": [{"text": {"type": "plain_text", "text": "Maru"}, "value": "maru"}]}
-    )
+    ack({"options": [{"text": {"type": "plain_text", "text": "Maru"}, "value": "maru"}]})
 
 
 @app.options("mes_a")
diff --git a/examples/modals_app_typed.py b/examples/modals_app_typed.py
@@ -23,17 +23,13 @@
 
 
 @app.middleware  # or app.use(log_request)
-def log_request(
-    logger: Logger, body: dict, next: Callable[[], BoltResponse]
-) -> BoltResponse:
+def log_request(logger: Logger, body: dict, next: Callable[[], BoltResponse]) -> BoltResponse:
     logger.debug(body)
     return next()
 
 
 @app.command("/hello-bolt-python")
-def handle_command(
-    body: dict, ack: Ack, respond: Respond, client: WebClient, logger: Logger
-) -> None:
+def handle_command(body: dict, ack: Ack, respond: Respond, client: WebClient, logger: Logger) -> None:
     logger.info(body)
     ack(
         text="Accepted!",
@@ -49,9 +45,7 @@ def handle_command(
         blocks=[
             SectionBlock(
                 block_id="b",
-                text=MarkdownTextObject(
-                    text="You can add a button alongside text in your message. "
-                ),
+                text=MarkdownTextObject(text="You can add a button alongside text in your message. "),
                 accessory=ButtonElement(
                     action_id="a",
                     text=PlainTextObject(text="Button"),
diff --git a/examples/pyramid/app.py b/examples/pyramid/app.py
@@ -20,9 +20,7 @@ def event_test(body, say, logger):
 
     with Configurator() as config:
         config.add_route("slack_events", "/slack/events")
-        config.add_view(
-            handler.handle, route_name="slack_events", request_method="POST"
-        )
+        config.add_view(handler.handle, route_name="slack_events", request_method="POST")
         pyramid_app = config.make_wsgi_app()
     server = make_server("0.0.0.0", 3000, pyramid_app)
     server.serve_forever()
diff --git a/examples/pyramid/oauth_app.py b/examples/pyramid/oauth_app.py
@@ -20,18 +20,12 @@ def event_test(body, say, logger):
 
     with Configurator() as config:
         config.add_route("slack_events", "/slack/events")
-        config.add_view(
-            handler.handle, route_name="slack_events", request_method="POST"
-        )
+        config.add_view(handler.handle, route_name="slack_events", request_method="POST")
 
         config.add_route("slack_install", "/slack/install")
         config.add_route("slack_oauth_redirect", "/slack/oauth_redirect")
-        config.add_view(
-            handler.handle, route_name="slack_install", request_method="GET"
-        )
-        config.add_view(
-            handler.handle, route_name="slack_oauth_redirect", request_method="GET"
-        )
+        config.add_view(handler.handle, route_name="slack_install", request_method="GET")
+        config.add_view(handler.handle, route_name="slack_oauth_redirect", request_method="GET")
 
         pyramid_app = config.make_wsgi_app()
     server = make_server("0.0.0.0", 3000, pyramid_app)
diff --git a/examples/socket_mode_healthcheck.py b/examples/socket_mode_healthcheck.py
@@ -31,10 +31,7 @@ def event_test(event, say):
 
 @flask_app.route("/health", methods=["GET"])
 def slack_events():
-    if (
-        socket_mode_handler.client is not None
-        and socket_mode_handler.client.is_connected()
-    ):
+    if socket_mode_handler.client is not None and socket_mode_handler.client.is_connected():
         return make_response("OK", 200)
     return make_response("The Socket Mode client is inactive", 503)
 
diff --git a/examples/sqlalchemy/async_oauth_app.py b/examples/sqlalchemy/async_oauth_app.py
@@ -63,9 +63,7 @@ async def async_save(self, installation: Installation):
                 b["client_id"] = self.client_id
                 await database.execute(self.bots.insert(), b)
 
-    async def async_find_bot(
-        self, *, enterprise_id: Optional[str], team_id: Optional[str]
-    ) -> Optional[Bot]:
+    async def async_find_bot(self, *, enterprise_id: Optional[str], team_id: Optional[str]) -> Optional[Bot]:
         c = self.bots.c
         query = (
             self.bots.select()
@@ -120,24 +118,18 @@ async def async_issue(self) -> str:
         state: str = str(uuid4())
         now = datetime.utcfromtimestamp(time.time() + self.expiration_seconds)
         async with Database(self.database_url) as database:
-            await database.execute(
-                self.oauth_states.insert(), {"state": state, "expire_at": now}
-            )
+            await database.execute(self.oauth_states.insert(), {"state": state, "expire_at": now})
             return state
 
     async def async_consume(self, state: str) -> bool:
         try:
             async with Database(self.database_url) as database:
                 async with database.transaction():
                     c = self.oauth_states.c
-                    query = self.oauth_states.select().where(
-                        and_(c.state == state, c.expire_at > datetime.utcnow())
-                    )
+                    query = self.oauth_states.select().where(and_(c.state == state, c.expire_at > datetime.utcnow()))
                     row = await database.fetch_one(query)
                     self.logger.debug(f"consume's query result: {row}")
-                    await database.execute(
-                        self.oauth_states.delete().where(c.id == row["id"])
-                    )
+                    await database.execute(self.oauth_states.delete().where(c.id == row["id"]))
                     return True
             return False
         except Exception as e:
diff --git a/examples/starlette/app.py b/examples/starlette/app.py
@@ -21,9 +21,7 @@ async def endpoint(req: Request):
     return await app_handler.handle(req)
 
 
-api = Starlette(
-    debug=True, routes=[Route("/slack/events", endpoint=endpoint, methods=["POST"])]
-)
+api = Starlette(debug=True, routes=[Route("/slack/events", endpoint=endpoint, methods=["POST"])])
 
 # pip install -r requirements.txt
 # export SLACK_SIGNING_SECRET=***
diff --git a/examples/starlette/async_app.py b/examples/starlette/async_app.py
@@ -21,9 +21,7 @@ async def endpoint(req: Request):
     return await app_handler.handle(req)
 
 
-api = Starlette(
-    debug=True, routes=[Route("/slack/events", endpoint=endpoint, methods=["POST"])]
-)
+api = Starlette(debug=True, routes=[Route("/slack/events", endpoint=endpoint, methods=["POST"])])
 
 # pip install -r requirements.txt
 # export SLACK_SIGNING_SECRET=***
diff --git a/examples/workflow_steps/async_steps_from_apps.py b/examples/workflow_steps/async_steps_from_apps.py
@@ -82,9 +82,7 @@ async def save(ack: AsyncAck, view: dict, update: AsyncUpdate):
                 "value": state_values["task_name_input"]["task_name"]["value"],
             },
             "taskDescription": {
-                "value": state_values["task_description_input"]["task_description"][
-                    "value"
-                ],
+                "value": state_values["task_description_input"]["task_description"]["value"],
             },
             "taskAuthorEmail": {
                 "value": state_values["task_author_input"]["task_author"]["value"],
@@ -114,9 +112,7 @@ async def save(ack: AsyncAck, view: dict, update: AsyncUpdate):
 pseudo_database = {}
 
 
-async def execute(
-    step: dict, client: AsyncWebClient, complete: AsyncComplete, fail: AsyncFail
-):
+async def execute(step: dict, client: AsyncWebClient, complete: AsyncComplete, fail: AsyncFail):
     try:
         await complete(
             outputs={
@@ -125,9 +121,7 @@ async def execute(
                 "taskAuthorEmail": step["inputs"]["taskAuthorEmail"]["value"],
             }
         )
-        user: AsyncSlackResponse = await client.users_lookupByEmail(
-            email=step["inputs"]["taskAuthorEmail"]["value"]
-        )
+        user: AsyncSlackResponse = await client.users_lookupByEmail(email=step["inputs"]["taskAuthorEmail"]["value"])
         user_id = user["user"]["id"]
         new_task = {
             "task_name": step["inputs"]["taskName"]["value"],
diff --git a/examples/workflow_steps/async_steps_from_apps_decorator.py b/examples/workflow_steps/async_steps_from_apps_decorator.py
@@ -88,9 +88,7 @@ async def save(ack: AsyncAck, view: dict, update: AsyncUpdate):
                 "value": state_values["task_name_input"]["task_name"]["value"],
             },
             "taskDescription": {
-                "value": state_values["task_description_input"]["task_description"][
-                    "value"
-                ],
+                "value": state_values["task_description_input"]["task_description"]["value"],
             },
             "taskAuthorEmail": {
                 "value": state_values["task_author_input"]["task_author"]["value"],
@@ -133,19 +131,15 @@ async def noop_middleware(next):
 
 async def notify_execution(client: AsyncWebClient, step: dict):
     await asyncio.sleep(5)
-    await client.chat_postMessage(
-        channel="#random", text=f"Step execution: ```{step}```"
-    )
+    await client.chat_postMessage(channel="#random", text=f"Step execution: ```{step}```")
 
 
 @copy_review_step.execute(
     matchers=[additional_matcher],
     middleware=[noop_middleware],
     lazy=[notify_execution],
 )
-async def execute(
-    step: dict, client: AsyncWebClient, complete: AsyncComplete, fail: AsyncFail
-):
+async def execute(step: dict, client: AsyncWebClient, complete: AsyncComplete, fail: AsyncFail):
     try:
         await complete(
             outputs={
@@ -154,9 +148,7 @@ async def execute(
                 "taskAuthorEmail": step["inputs"]["taskAuthorEmail"]["value"],
             }
         )
-        user_lookup: AsyncSlackResponse = await client.users_lookupByEmail(
-            email=step["inputs"]["taskAuthorEmail"]["value"]
-        )
+        user_lookup: AsyncSlackResponse = await client.users_lookupByEmail(email=step["inputs"]["taskAuthorEmail"]["value"])
         user_id = user_lookup["user"]["id"]
         new_task = {
             "task_name": step["inputs"]["taskName"]["value"],
diff --git a/examples/workflow_steps/async_steps_from_apps_primitive.py b/examples/workflow_steps/async_steps_from_apps_primitive.py
@@ -86,9 +86,7 @@ async def save(ack: AsyncAck, client: AsyncWebClient, body: dict):
                     "value": state_values["task_name_input"]["task_name"]["value"],
                 },
                 "taskDescription": {
-                    "value": state_values["task_description_input"]["task_description"][
-                        "value"
-                    ],
+                    "value": state_values["task_description_input"]["task_description"]["value"],
                 },
                 "taskAuthorEmail": {
                     "value": state_values["task_author_input"]["task_author"]["value"],
@@ -133,9 +131,7 @@ async def execute(body: dict, client: AsyncWebClient):
             },
         },
     )
-    user: AsyncSlackResponse = await client.users_lookupByEmail(
-        email=step["inputs"]["taskAuthorEmail"]["value"]
-    )
+    user: AsyncSlackResponse = await client.users_lookupByEmail(email=step["inputs"]["taskAuthorEmail"]["value"])
     user_id = user["user"]["id"]
     new_task = {
         "task_name": step["inputs"]["taskName"]["value"],
diff --git a/examples/workflow_steps/steps_from_apps.py b/examples/workflow_steps/steps_from_apps.py
diff --git a/examples/workflow_steps/steps_from_apps_decorator.py b/examples/workflow_steps/steps_from_apps_decorator.py
diff --git a/examples/workflow_steps/steps_from_apps_primitive.py b/examples/workflow_steps/steps_from_apps_primitive.py
diff --git a/tests/adapter_tests/aws/test_aws_lambda.py b/tests/adapter_tests/aws/test_aws_lambda.py

Original file line number	Diff line number	Diff line change
`@@ -23,9 +23,7 @@ class SlackBot(models.Model):`
`23`	`23`
`24`	`24`	`class Meta:`
`25`	`25`	`indexes = [`
`26`		`- models.Index(`
`27`		`- fields=["client_id", "enterprise_id", "team_id", "installed_at"]`
`28`		`- ),`
	`26`	`+ models.Index(fields=["client_id", "enterprise_id", "team_id", "installed_at"]),`
`29`	`27`	`]`
`30`	`28`
`31`	`29`