feat(deployment): add launch for all deployments

src/pixel_battle/deployment/chunk_reading_service/__main__.py

@@ -0,0 +1,11 @@
+import uvicorn
+
+from pixel_battle.deployment.chunk_reading_service.asgi import app
+
+
+def main() -> None:
+    uvicorn.run(app)
+
+
+if __name__ == "__main__":
+    main()

src/pixel_battle/deployment/chunk_reading_service/asgi.py

@@ -0,0 +1,12 @@
+from pixel_battle.deployment.chunk_reading_service.di import (
+    chunk_reading_service_container,
+)
+from pixel_battle.deployment.common.asgi import ASGIApp, LazyASGIApp
+from pixel_battle.presentation.web.app import app_from
+
+
+async def app_factory() -> ASGIApp:
+    return await app_from(chunk_reading_service_container)
+
+
+app = LazyASGIApp(factory=app_factory)

src/pixel_battle/deployment/chunk_stream_compression_coordination_service/__main__.py

@@ -0,0 +1,23 @@
+import asyncio
+
+from pixel_battle.deployment.chunk_stream_compression_coordination_service.di import (  # noqa: E501
+    chunk_stream_compression_coordination_service_container,
+)
+from pixel_battle.presentation.distributed_tasks.update_chunk_view import (
+    UpdateChunkViewTask,
+)
+
+
+async def main() -> None:
+    task = await chunk_stream_compression_coordination_service_container.get(
+        UpdateChunkViewTask
+    )
+
+    try:
+        await task.start_pushing()
+    finally:
+        await chunk_stream_compression_coordination_service_container.close()
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

src/pixel_battle/deployment/chunk_stream_compression_service/__main__.py

@@ -0,0 +1,23 @@
+import asyncio
+
+from pixel_battle.deployment.chunk_stream_compression_service.di import (
+    chunk_stream_compression_service_container,
+)
+from pixel_battle.presentation.distributed_tasks.update_chunk_view import (
+    UpdateChunkViewTask,
+)
+
+
+async def main() -> None:
+    task = await chunk_stream_compression_service_container.get(
+        UpdateChunkViewTask
+    )
+
+    try:
+        await task.start_pulling()
+    finally:
+        await chunk_stream_compression_service_container.close()
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

src/pixel_battle/deployment/chunk_streaming_service/__main__.py

@@ -0,0 +1,11 @@
+import uvicorn
+
+from pixel_battle.deployment.chunk_streaming_service.asgi import app
+
+
+def main() -> None:
+    uvicorn.run(app)
+
+
+if __name__ == "__main__":
+    main()

src/pixel_battle/deployment/chunk_streaming_service/asgi.py

@@ -0,0 +1,12 @@
+from pixel_battle.deployment.chunk_streaming_service.di import (
+    chunk_streaming_service_container,
+)
+from pixel_battle.deployment.common.asgi import ASGIApp, LazyASGIApp
+from pixel_battle.presentation.web.app import app_from
+
+
+async def app_factory() -> ASGIApp:
+    return await app_from(chunk_streaming_service_container)
+
+
+app = LazyASGIApp(factory=app_factory)

src/pixel_battle/deployment/chunk_writing_service/__main__.py

@@ -0,0 +1,11 @@
+import uvicorn
+
+from pixel_battle.deployment.chunk_writing_service.asgi import app
+
+
+def main() -> None:
+    uvicorn.run(app)
+
+
+if __name__ == "__main__":
+    main()

src/pixel_battle/deployment/chunk_writing_service/asgi.py

@@ -0,0 +1,12 @@
+from pixel_battle.deployment.chunk_writing_service.di import (
+    chunk_writing_service_container,
+)
+from pixel_battle.deployment.common.asgi import ASGIApp, LazyASGIApp
+from pixel_battle.presentation.web.app import app_from
+
+
+async def app_factory() -> ASGIApp:
+    return await app_from(chunk_writing_service_container)
+
+
+app = LazyASGIApp(factory=app_factory)