feat: ActivityPub first implementation

.devcontainer/devcontainer.json

@@ -33,7 +33,7 @@
         "version": "21",
         "jdkDistro": "open"
     },
-    "./solr": {}
+    // "./solr": {}
 	},
 	"overrideFeatureInstallOrder": [
 		"ghcr.io/devcontainers-extra/features/poetry",

bases/renku_data_services/data_api/app.py

@@ -4,6 +4,10 @@
 from ulid import ULID
 
 from renku_data_services import errors
+from renku_data_services.activitypub.blueprints import ActivityPubBP
+from renku_data_services.activitypub.core import ActivityPubService
+from renku_data_services.activitypub.db import ActivityPubRepository
+from renku_data_services.activitypub.models import ActivityPubConfig
 from renku_data_services.app_config import Config
 from renku_data_services.base_api.error_handler import CustomErrorHandler
 from renku_data_services.base_api.misc import MiscBP
@@ -225,6 +229,36 @@ def register_all_handlers(app: Sanic, config: Config) -> Sanic:
         data_connector_secret_repo=config.data_connector_secret_repo,
         authenticator=config.authenticator,
     )
+
+    # ActivityPub configuration
+    # Use the base_url and domain from the config
+    activitypub_config = ActivityPubConfig(
+        domain=config.domain,
+        base_url=f"{config.base_url}{url_prefix}",  # Include the URL prefix
+        admin_email=config.admin_email,
+    )
+
+    # ActivityPub repository and service
+    activitypub_repo = ActivityPubRepository(
+        session_maker=config.db.async_session_maker,
+        project_repo=config.project_repo,
+        config=activitypub_config,
+    )
+
+    activitypub_service = ActivityPubService(
+        activitypub_repo=activitypub_repo,
+        project_repo=config.project_repo,
+        config=activitypub_config,
+    )
+
+    # ActivityPub blueprint
+    activitypub = ActivityPubBP(
+        name="activitypub",
+        url_prefix=url_prefix,
+        activitypub_service=activitypub_service,
+        authenticator=config.authenticator,
+        config=activitypub_config,
+    )
     app.blueprint(
         [
             resource_pools.blueprint(),
@@ -252,6 +286,7 @@ def register_all_handlers(app: Sanic, config: Config) -> Sanic:
             message_queue.blueprint(),
             search.blueprint(),
             data_connectors.blueprint(),
+            activitypub.blueprint(),
         ]
     )
     if builds is not None:

components/renku_data_services/activitypub/__init__.py

@@ -0,0 +1 @@
+"""ActivityPub component for Renku."""