leverage functions_completeSuccess

slack_bolt/app/app.py

@@ -849,12 +849,9 @@ def function(
             def reverse_string(event, client: WebClient, context: BoltContext):
                 try:
                     string_to_reverse = event["inputs"]["stringToReverse"]
-                    client.api_call(
-                        "functions.completeSuccess",
-                        json={
-                            "function_execution_id": context.function_execution_id,
-                            "outputs": {"reverseString": string_to_reverse[::-1]},
-                        },
+                    client.functions_completeSuccess(
+                        function_execution_id=context.function_execution_id,
+                        outputs={"reverseString": string_to_reverse[::-1]},
                     )
                 except Exception as e:
                     client.api_call(

slack_bolt/app/async_app.py

@@ -882,12 +882,9 @@ def function(
             async def reverse_string(event, client: AsyncWebClient, complete: AsyncComplete):
                 try:
                     string_to_reverse = event["inputs"]["stringToReverse"]
-                    await client.api_call(
-                        "functions.completeSuccess",
-                        json={
-                            "function_execution_id": context.function_execution_id,
-                            "outputs": {"reverseString": string_to_reverse[::-1]},
-                        },
+                    await client.functions_completeSuccess(
+                        function_execution_id=context.function_execution_id,
+                        outputs={"reverseString": string_to_reverse[::-1]},
                     )
                 except Exception as e:
                     await client.functions_completeError(

slack_bolt/logger/messages.py

@@ -280,12 +280,9 @@ def warning_unhandled_request(  # type: ignore
     try:
         # TODO: do something here
         outputs = {{}}
-        {'await ' if is_async else ''}client.api_call(
-            "functions.completeSuccess",
-            json={{
-                "function_execution_id": context.function_execution_id,
-                "outputs": outputs,
-            }},
+        {'await ' if is_async else ''}client.functions_completeSuccess(
+            function_execution_id=context.function_execution_id,
+            outputs=outputs,
         )
     except Exception as e:
         error = f"Failed to handle a function request (error: {{e}})"

tests/scenario_tests/test_function.py

@@ -210,12 +210,9 @@ def reverse(body, event, context, client):
     assert context.function_bot_access_token == "xwfp-valid"
     assert context.client.token == "xwfp-valid"
     assert client.token == "xwfp-valid"
-    client.api_call(
-        "functions.completeSuccess",
-        json={
-            "function_execution_id": event["function_execution_id"],
-            "outputs": {"reverseString": "olleh"},
-        },
+    client.functions_completeSuccess(
+        function_execution_id=event["function_execution_id"],
+        outputs={"reverseString": "olleh"},
     )
 
 
@@ -228,9 +225,4 @@ def reverse_error(body, event, client, context):
 def complete_it(body, event, client):
     assert body == function_body
     assert event == function_body["event"]
-    client.api_call(
-        "functions.completeSuccess",
-        json={
-            "function_execution_id": event["function_execution_id"],
-        },
-    )
+    client.functions_completeSuccess(function_execution_id=event["function_execution_id"], outputs={})

tests/scenario_tests_async/test_function.py

@@ -214,12 +214,9 @@ async def reverse(body, event, client, context):
     assert context.function_bot_access_token == "xwfp-valid"
     assert context.client.token == "xwfp-valid"
     assert client.token == "xwfp-valid"
-    await client.api_call(
-        "functions.completeSuccess",
-        json={
-            "function_execution_id": event["function_execution_id"],
-            "outputs": {"reverseString": "olleh"},
-        },
+    await client.functions_completeSuccess(
+        function_execution_id=event["function_execution_id"],
+        outputs={"reverseString": "olleh"},
     )
 
 
@@ -235,10 +232,7 @@ async def reverse_error(body, event, client, context):
 async def complete_it(body, event, client):
     assert body == function_body
     assert event == function_body["event"]
-    await client.api_call(
-        "functions.completeSuccess",
-        json={
-            "function_execution_id": event["function_execution_id"],
-            "outputs": {},
-        },
+    await client.functions_completeSuccess(
+        function_execution_id=event["function_execution_id"],
+        outputs={},
     )

tests/slack_bolt/logger/test_unmatched_suggestions.py

@@ -98,12 +98,9 @@ def handle_some_function(body, event, client, logger):
     try:
         # TODO: do something here
         outputs = {{}}
-        client.api_call(
-            "functions.completeSuccess",
-            json={{
-                "function_execution_id": context.function_execution_id,
-                "outputs": outputs,
-            }},
+        client.functions_completeSuccess(
+            function_execution_id=context.function_execution_id,
+            outputs=outputs,
         )
     except Exception as e:
         error = f"Failed to handle a function request (error: {{e}})"

tests/slack_bolt_async/logger/test_unmatched_suggestions.py

@@ -98,12 +98,9 @@ async def handle_some_function(body, event, client, logger):
     try:
         # TODO: do something here
         outputs = {{}}
-        await client.api_call(
-            "functions.completeSuccess",
-            json={{
-                "function_execution_id": context.function_execution_id,
-                "outputs": outputs,
-            }},
+        await client.functions_completeSuccess(
+            function_execution_id=context.function_execution_id,
+            outputs=outputs,
         )
     except Exception as e:
         error = f"Failed to handle a function request (error: {{e}})"