Test fastapi

integrations/jira/main.py

@@ -79,6 +79,9 @@ async def handle_webhook_request(data: dict[str, Any]) -> dict[str, Any]:
     return {"ok": True}
 
 
+ocean.app.fast_api_app.include_router(ocean.router, prefix="/integration")
+
+
 # Called once when the integration starts.
 @ocean.on_start()
 async def on_start() -> None:

port_ocean/ocean.py

@@ -39,8 +39,22 @@ def __init__(
         config_override: Dict[str, Any] | None = None,
     ):
         initialize_port_ocean_context(self)
-        self.fast_api_app = app or FastAPI()
-        self.fast_api_app.middleware("http")(request_handler)
+
+        @asynccontextmanager
+        async def lifespan(_: FastAPI) -> AsyncIterator[None]:
+            try:
+                await self.integration.start()
+                await self._setup_scheduled_resync()
+                yield None
+            except Exception:
+                logger.exception("Integration had a fatal error. Shutting down.")
+                logger.complete()
+                sys.exit("Server stopped")
+            finally:
+                signal_handler.exit()
+
+        self.fast_api_app = app or FastAPI(lifespan=lifespan)
+        # self.fast_api_app.middleware("http")(request_handler)
 
         self.config = IntegrationConfiguration(
             # type: ignore
@@ -113,20 +127,4 @@ async def execute_resync_all() -> None:
             await repeated_function()
 
     async def __call__(self, scope: Scope, receive: Receive, send: Send) -> None:
-        self.fast_api_app.include_router(self.integration_router, prefix="/integration")
-
-        @asynccontextmanager
-        async def lifecycle(_: FastAPI) -> AsyncIterator[None]:
-            try:
-                await self.integration.start()
-                await self._setup_scheduled_resync()
-                yield None
-            except Exception:
-                logger.exception("Integration had a fatal error. Shutting down.")
-                logger.complete()
-                sys.exit("Server stopped")
-            finally:
-                signal_handler.exit()
-
-        self.fast_api_app.router.lifespan_context = lifecycle
         await self.fast_api_app(scope, receive, send)

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "port-ocean"
-version = "0.12.9"
+version = "0.12.9-dev01"
 description = "Port Ocean is a CLI tool for managing your Port projects."
 readme = "README.md"
 homepage = "https://app.getport.io"