Fix

Author: habara-k

examples/flask-echo/app.py

@@ -70,7 +70,7 @@ def callback():
             continue
         if not isinstance(event.message, TextMessageContent):
             continue
-        line_bot_api.reply_message_with_http_info(
+        line_bot_api.reply_message(
             ReplyMessageRequest(
                 reply_token=event.reply_token,
                 messages=[TextMessage(text=event.message.text)]

examples/flask-echo/app_with_handler.py

@@ -69,7 +69,7 @@ def callback():
 
 @handler.add(MessageEvent, message=TextMessageContent)
 def message_text(event):
-    line_bot_api.reply_message_with_http_info(
+    line_bot_api.reply_message(
         ReplyMessageRequest(
             reply_token=event.reply_token,
             messages=[TextMessage(text=event.message.text)]

linebot/v3/async_line_bot_client.py

@@ -371,6 +371,134 @@ def test_mission_sticker_v3(self):
             self.assertEqual(body["sendPresentMessage"], False)
 
 
+class TestLineBotClientAuthorizationHeader(unittest.TestCase):
+    """Test that the Authorization header is correctly propagated to all domains."""
+
+    def _assert_bearer_token(self, httpserver, uri, method, token):
+        """Helper: call an endpoint and verify the Authorization header."""
+        request, _ = httpserver.log[-1]
+        self.assertEqual(request.headers.get("Authorization"), f"Bearer {token}")
+
+    def test_messaging_api_sends_bearer_token(self):
+        with HTTPServer() as httpserver:
+            httpserver.expect_request(
+                uri="/v2/bot/profile/U123",
+                method="GET",
+            ).respond_with_json(
+                {"displayName": "T", "userId": "U123"}, status=200
+            )
+
+            with LineBotClient(
+                channel_access_token="my-secret-token",
+                host=httpserver.url_for("/")
+            ) as client:
+                client.get_profile(user_id="U123")
+
+            request, _ = httpserver.log[0]
+            self.assertEqual(
+                request.headers.get("Authorization"), "Bearer my-secret-token"
+            )
+
+    def test_insight_api_sends_bearer_token(self):
+        with HTTPServer() as httpserver:
+            httpserver.expect_request(
+                uri="/v2/bot/insight/followers",
+                method="GET",
+            ).respond_with_json(
+                {"status": "ready", "followers": 0, "targetedReaches": 0, "blocks": 0},
+                status=200
+            )
+
+            with LineBotClient(
+                channel_access_token="insight-token",
+                host=httpserver.url_for("/")
+            ) as client:
+                client.get_number_of_followers(var_date="20240101")
+
+            request, _ = httpserver.log[0]
+            self.assertEqual(
+                request.headers.get("Authorization"), "Bearer insight-token"
+            )
+
+    def test_audience_api_sends_bearer_token(self):
+        with HTTPServer() as httpserver:
+            httpserver.expect_request(
+                uri="/v2/bot/audienceGroup/99999",
+                method="DELETE",
+            ).respond_with_json({}, status=200)
+
+            with LineBotClient(
+                channel_access_token="audience-token",
+                host=httpserver.url_for("/")
+            ) as client:
+                client.delete_audience_group(audience_group_id=99999)
+
+            request, _ = httpserver.log[0]
+            self.assertEqual(
+                request.headers.get("Authorization"), "Bearer audience-token"
+            )
+
+    def test_liff_api_sends_bearer_token(self):
+        with HTTPServer() as httpserver:
+            httpserver.expect_request(
+                uri="/liff/v1/apps",
+                method="GET",
+            ).respond_with_json({"apps": []}, status=200)
+
+            with LineBotClient(
+                channel_access_token="liff-token",
+                host=httpserver.url_for("/")
+            ) as client:
+                client.get_all_liff_apps()
+
+            request, _ = httpserver.log[0]
+            self.assertEqual(
+                request.headers.get("Authorization"), "Bearer liff-token"
+            )
+
+    def test_module_api_sends_bearer_token(self):
+        with HTTPServer() as httpserver:
+            httpserver.expect_request(
+                uri="/v2/bot/list",
+                method="GET",
+            ).respond_with_json({"bots": []}, status=200)
+
+            with LineBotClient(
+                channel_access_token="module-token",
+                host=httpserver.url_for("/")
+            ) as client:
+                client.get_modules()
+
+            request, _ = httpserver.log[0]
+            self.assertEqual(
+                request.headers.get("Authorization"), "Bearer module-token"
+            )
+
+    def test_shop_api_sends_bearer_token(self):
+        with HTTPServer() as httpserver:
+            httpserver.expect_request(
+                uri="/shop/v3/mission",
+                method="POST",
+            ).respond_with_json({}, status=200)
+
+            with LineBotClient(
+                channel_access_token="shop-token",
+                host=httpserver.url_for("/")
+            ) as client:
+                req = MissionStickerRequest(
+                    to="U123",
+                    productId="p",
+                    productType="t",
+                    sendPresentMessage=False
+                )
+                client.mission_sticker_v3(mission_sticker_request=req)
+
+            request, _ = httpserver.log[0]
+            self.assertEqual(
+                request.headers.get("Authorization"), "Bearer shop-token"
+            )
+
+
 class TestLineBotClientErrors(unittest.TestCase):
     """Test error handling through LineBotClient."""
 

linebot/v3/line_bot_client.py

@@ -176,7 +176,7 @@ def _extract_params_source(func: ast.FunctionDef) -> str:
     for i, arg in enumerate(all_args):
         part = arg.arg
         if arg.annotation:
-            part += " : " + ast.unparse(arg.annotation)
+            part += ": " + ast.unparse(arg.annotation)
         default_index = i - (num_args - num_defaults)
         if default_index >= 0:
             part += " = " + ast.unparse(args.defaults[default_index])
@@ -496,8 +496,14 @@ def generate_sync_client(
     lines.append('')
     lines.append('    def close(self) -> None:')
     lines.append('        """Close all underlying API clients."""')
+    lines.append('        errors: list[BaseException] = []')
     for mod in unique_modules:
-        lines.append(f'        self._{mod}_api_client.close()')
+        lines.append(f'        try:')
+        lines.append(f'            self._{mod}_api_client.close()')
+        lines.append(f'        except Exception as e:')
+        lines.append(f'            errors.append(e)')
+    lines.append('        if errors:')
+    lines.append('            raise errors[0]')
     lines.append('')
 
     # Delegating methods
@@ -516,7 +522,7 @@ def generate_sync_client(
 
     output_path = os.path.join(repo_root, "linebot/v3/line_bot_client.py")
     with open(output_path, "w") as f:
-        f.write("\n".join(lines))
+        f.write("\n".join(lines) + "\n")
     print(f"Generated {output_path} ({len(all_methods)} methods)")
 
 
@@ -639,8 +645,14 @@ def generate_async_client(
 
     lines.append('    async def close(self) -> None:')
     lines.append('        """Close all underlying async API clients."""')
+    lines.append('        errors: list[BaseException] = []')
     for mod in unique_modules:
-        lines.append(f'        await self._{mod}_api_client.close()')
+        lines.append(f'        try:')
+        lines.append(f'            await self._{mod}_api_client.close()')
+        lines.append(f'        except Exception as e:')
+        lines.append(f'            errors.append(e)')
+    lines.append('        if errors:')
+    lines.append('            raise errors[0]')
     lines.append('')
 
     # Delegating methods — async client methods are actually ``def`` (not ``async def``).
@@ -660,7 +672,7 @@ def generate_async_client(
 
     output_path = os.path.join(repo_root, "linebot/v3/async_line_bot_client.py")
     with open(output_path, "w") as f:
-        f.write("\n".join(lines))
+        f.write("\n".join(lines) + "\n")
     print(f"Generated {output_path} ({len(all_methods)} methods)")