Add a configuration loader

build.gradle.kts

@@ -48,6 +48,7 @@ allprojects {
 }
 
 dependencies {
+  implementation(project(":yggdrasil-utils"))
   implementation(project(":yggdrasil-core"))
   implementation(project(":yggdrasil-cartago"))
   implementation(project(":yggdrasil-websub"))
@@ -68,7 +69,6 @@ dependencies {
   testImplementation(libs.wot.td.java)
   testImplementation(libs.rdf4j.model)
   testImplementation(files("libs/cartago-3.1.jar"))
-  testImplementation(project(":yggdrasil-utils"))
 
   testCompileOnly(libs.spotbugs.annotations)
 }

conf/cartago_config.json

@@ -0,0 +1,46 @@
+{
+  "http-config" : {
+    "host" : "localhost",
+    "port" : 8080,
+    "base-uri" : "http://localhost:8080/"
+  },
+  "notification-config" : {
+    "enabled" : true
+  },
+  "environment-config" : {
+    "known-artifacts" : [
+      {
+        "class" : "http://example.org/Counter",
+        "template" : "org.hyperagents.yggdrasil.cartago.artifacts.Counter"
+      }
+    ],
+    "workspaces" : [
+      {
+        "name" : "w1"
+      },
+      {
+        "name" : "w0",
+        "parent-name" : "w1",
+        "artifacts" : [
+          {
+            "name" : "c0",
+            "class" : "http://example.org/Counter",
+            "init-params" : [
+              5
+            ],
+            "focused-by" : [
+              {
+                "agent-uri" : "http://localhost:8080/agents/test",
+                "callback-uri" : "http://localhost:8081/"
+              }
+            ]
+          }
+        ],
+        "agents" : [
+          "http://localhost:8080/agents/test"
+        ]
+      }
+    ],
+    "enabled" : true
+  }
+}

conf/docker_disk_config.json

@@ -2,11 +2,17 @@
   "http-config" : {
     "host" : "0.0.0.0",
     "port" : 8080,
-    "base-uri" : "http://localhost:8899/",
-    "websub-hub-uri" : "https://yggdrasil.interactions.ics.unisg.ch/hub/"
+    "base-uri" : "http://localhost:8899/"
   },
   "rdf-store" : {
     "in-memory" : false,
     "store-path" : "data/"
+  },
+  "notification-config" : {
+    "websub-hub-base-uri" : "https://yggdrasil.interactions.ics.unisg.ch/",
+    "enabled" : true
+  },
+  "environment-config" : {
+    "enabled" : true
   }
 }

conf/localhost_memory_config.json

@@ -2,7 +2,12 @@
   "http-config" : {
     "host" : "localhost",
     "port" : 8080,
-    "base-uri" : "http://localhost:8080/",
-    "websub-hub-uri" : "http://localhost:8080/hub/"
+    "base-uri" : "http://localhost:8080/"
+  },
+  "notification-config" : {
+    "enabled" : true
+  },
+  "environment-config" : {
+    "enabled" : true
   }
 }

conf/static_config.json

@@ -0,0 +1,26 @@
+{
+  "http-config" : {
+    "host" : "localhost",
+    "port" : 8080,
+    "base-uri" : "http://localhost:8080/"
+  },
+  "environment-config" : {
+    "workspaces" : [
+      {
+        "name" : "test",
+        "representation" : "test_workspace_td.ttl"
+      },
+      {
+        "name" : "sub",
+        "parent-name" : "test",
+        "artifacts" : [
+          {
+            "name" : "c0",
+            "representation" : "c0_counter_artifact.ttl"
+          }
+        ],
+        "representation" : "sub_workspace_td.ttl"
+      }
+    ]
+  }
+}

src/main/java/org/hyperagents/yggdrasil/MainVerticle.java

@@ -3,35 +3,63 @@
 import io.vertx.config.ConfigRetriever;
 import io.vertx.core.AbstractVerticle;
 import io.vertx.core.DeploymentOptions;
+import io.vertx.core.Future;
 import io.vertx.core.Promise;
-import org.hyperagents.yggdrasil.cartago.CartagoVerticle;
 import org.hyperagents.yggdrasil.http.HttpServerVerticle;
+import org.hyperagents.yggdrasil.model.Environment;
+import org.hyperagents.yggdrasil.model.impl.EnvironmentParser;
 import org.hyperagents.yggdrasil.store.RdfStoreVerticle;
-import org.hyperagents.yggdrasil.websub.HttpNotificationVerticle;
+import org.hyperagents.yggdrasil.utils.EnvironmentConfig;
+import org.hyperagents.yggdrasil.utils.HttpInterfaceConfig;
+import org.hyperagents.yggdrasil.utils.WebSubConfig;
+import org.hyperagents.yggdrasil.utils.impl.EnvironmentConfigImpl;
+import org.hyperagents.yggdrasil.utils.impl.HttpInterfaceConfigImpl;
+import org.hyperagents.yggdrasil.utils.impl.WebSubConfigImpl;
 
 public class MainVerticle extends AbstractVerticle {
+  private static final String DEFAULT_CONF_VALUE = "default";
+
   @Override
   public void start(final Promise<Void> startPromise) {
     ConfigRetriever.create(this.vertx)
                    .getConfig()
-                   .compose(c ->
-                     this.vertx.deployVerticle(
-                       new HttpServerVerticle(),
-                       new DeploymentOptions().setConfig(c)
-                     )
-                     .compose(v -> this.vertx.deployVerticle(
-                       new RdfStoreVerticle(),
-                       new DeploymentOptions().setConfig(c)
-                     ))
-                     .compose(v -> this.vertx.deployVerticle(
-                       new HttpNotificationVerticle(),
-                       new DeploymentOptions().setConfig(c)
-                     ))
-                     .compose(v -> this.vertx.deployVerticle(
-                       new CartagoVerticle(),
-                       new DeploymentOptions().setConfig(c)
-                     ))
-                   )
+                   .compose(c -> {
+                     final var httpConfig = new HttpInterfaceConfigImpl(c);
+                     this.vertx.sharedData()
+                               .<String, HttpInterfaceConfig>getLocalMap("http-config")
+                               .put(DEFAULT_CONF_VALUE, httpConfig);
+                     final var environmentConfig = new EnvironmentConfigImpl(c);
+                     this.vertx.sharedData()
+                               .<String, EnvironmentConfig>getLocalMap("environment-config")
+                               .put(DEFAULT_CONF_VALUE, environmentConfig);
+                     final var notificationConfig = new WebSubConfigImpl(c, httpConfig);
+                     this.vertx.sharedData()
+                               .<String, WebSubConfig>getLocalMap("notification-config")
+                               .put(DEFAULT_CONF_VALUE, notificationConfig);
+                     this.vertx.sharedData()
+                               .<String, Environment>getLocalMap("environment")
+                               .put(DEFAULT_CONF_VALUE, EnvironmentParser.parse(c));
+                     return this.vertx
+                                .deployVerticle(new HttpServerVerticle())
+                                .compose(v -> this.vertx.deployVerticle(
+                                  new RdfStoreVerticle(),
+                                  new DeploymentOptions().setConfig(c)
+                                ))
+                                .compose(v ->
+                                  notificationConfig.isEnabled()
+                                  ? this.vertx.deployVerticle(
+                                      "org.hyperagents.yggdrasil.websub.HttpNotificationVerticle"
+                                    )
+                                  : Future.succeededFuture()
+                                )
+                                .compose(v ->
+                                  new EnvironmentConfigImpl(c).isEnabled()
+                                  ? this.vertx.deployVerticle(
+                                      "org.hyperagents.yggdrasil.cartago.CartagoVerticle"
+                                  )
+                                  : Future.succeededFuture()
+                                );
+                   })
                    .<Void>mapEmpty()
                    .onComplete(startPromise);
   }

src/test/java/org/hyperagents/yggdrasil/BodyNotificationTest.java

@@ -33,12 +33,10 @@ public class BodyNotificationTest {
   private static final String TEST_AGENT_NAME = "test_agent";
   private static final String TEST_AGENT_ID = "http://localhost:8080/agents/" + TEST_AGENT_NAME;
   private static final String AGENT_ID_HEADER = "X-Agent-WebID";
-  private static final String HINT_HEADER = "Slug";
   private static final String MAIN_WORKSPACE_NAME = "test";
   private static final String COUNTER_ARTIFACT_NAME = "c0";
   private static final String COUNTER_ARTIFACT_CLASS = "http://example.org/Counter";
   private static final int TEST_PORT = 8080;
-  private static final int CALLBACK_PORT = 8081;
   private static final String TEST_HOST = "localhost";
   private static final String OK_STATUS_MESSAGE = "Status code should be OK";
   private static final String CREATED_STATUS_MESSAGE = "Status code should be CREATED";
@@ -53,7 +51,7 @@ public class BodyNotificationTest {
   private static final String WORKSPACES_PATH = "/workspaces/";
   private static final String ARTIFACTS_PATH = "/artifacts/";
   private static final String BODIES_PATH = "/agents/";
-  private static final String CALLBACK_URL = "http://" + TEST_HOST + ":" + CALLBACK_PORT + "/";
+  private static final String CALLBACK_URL = "http://" + TEST_HOST + ":" + 8081 + "/";
 
   private final List<Promise<Map.Entry<String, String>>> callbackMessages;
   private WebClient client;
@@ -89,16 +87,26 @@ public void setUp(final Vertx vertx, final VertxTestContext ctx) {
               "host",
               TEST_HOST,
               "port",
-              TEST_PORT,
-              "websub-hub-uri",
-              this.getUrl(HUB_PATH),
-              "cartago-port",
-              8088
+              TEST_PORT
             ),
-            "known-artifacts",
+            "notification-config",
             JsonObject.of(
-              COUNTER_ARTIFACT_CLASS,
-              "org.hyperagents.yggdrasil.artifacts.Counter"
+              "enabled",
+              true
+            ),
+            "environment-config",
+            JsonObject.of(
+              "enabled",
+              true,
+              "known-artifacts",
+              JsonArray.of(
+                JsonObject.of(
+                  "class",
+                  COUNTER_ARTIFACT_CLASS,
+                  "template",
+                  "org.hyperagents.yggdrasil.artifacts.Counter"
+                )
+              )
             )
           ))
         )
@@ -136,7 +144,7 @@ public void testRun(final VertxTestContext ctx) throws URISyntaxException, IOExc
     this.client
         .post(TEST_PORT, TEST_HOST, WORKSPACES_PATH)
         .putHeader(AGENT_ID_HEADER, TEST_AGENT_ID)
-        .putHeader(HINT_HEADER, MAIN_WORKSPACE_NAME)
+        .putHeader("Slug", MAIN_WORKSPACE_NAME)
         .send()
         .onSuccess(r -> {
           Assertions.assertEquals(