[feat] Add Essentials /api/dkg/create endpoint and remove leaked sqlite file

Expose sync publish over HTTP with the same create logic as dkg-create MCP (including blob id support).

Remove accidentally committed apps/agent/original_dkg_node file and add API coverage tests.

Author: Jurij Skornik

apps/agent/original_dkg_node

@@ -35,6 +35,25 @@ export default defineDkgPlugin((ctx, mcp, api) => {
     }
   }
 
+  async function resolveJsonLdInput(jsonld: string): Promise<string> {
+    if (!jsonld) {
+      console.error("No JSON-LD content provided after file read.");
+      throw new Error("No JSON-LD content provided.");
+    }
+
+    if (jsonld.startsWith("{") || jsonld.startsWith("[")) {
+      return jsonld;
+    }
+
+    const blob = await ctx.blob.get(jsonld);
+    if (!blob) {
+      console.error(`File with id "${jsonld}" not found`);
+      throw new Error(`File with id "${jsonld}" not found`);
+    }
+
+    return consumers.text(blob.data);
+  }
+
   function validateSparqlInput(query: string): SparqlValidationResult {
     const validation = validateSparqlQuery(query);
     if (!validation.valid) {
@@ -191,21 +210,8 @@ export default defineDkgPlugin((ctx, mcp, api) => {
       },
     },
     async (input) => {
-      if (!input.jsonld) {
-        console.error("No JSON-LD content provided after file read.");
-        throw new Error("No JSON-LD content provided.");
-      }
       const privacy = input.privacy || "private";
-      const content =
-        input.jsonld.startsWith("{") || input.jsonld.startsWith("[")
-          ? input.jsonld
-          : await ctx.blob.get(input.jsonld).then((r) => {
-              if (!r) {
-                console.error(`File with id "${input.jsonld}" not found`);
-                throw new Error(`File with id "${input.jsonld}" not found`);
-              }
-              return consumers.text(r.data);
-            });
+      const content = await resolveJsonLdInput(input.jsonld);
 
       const { ual, error } = await publishJsonLdAsset(content, privacy);
       if (error) {
@@ -306,6 +312,82 @@ export default defineDkgPlugin((ctx, mcp, api) => {
     },
   );
 
+  api.post(
+    "/api/dkg/create",
+    openAPIRoute(
+      {
+        tag: "DKG Publishing",
+        summary: "Create and Publish DKG Asset",
+        description:
+          "Synchronously create and publish a Knowledge Asset on DKG from JSON-LD content or uploaded blob id.",
+        body: z.object({
+          jsonld: z
+            .string()
+            .describe("JSON-LD content or ID of an uploaded file"),
+          privacy: z.enum(["private", "public"]).optional().default("private"),
+        }),
+        response: {
+          schema: z.object({
+            success: z.boolean(),
+            data: z
+              .object({
+                ual: z.string(),
+                explorerLink: z.string(),
+                message: z.string(),
+              })
+              .optional(),
+            error: z.string().optional(),
+          }),
+        },
+        finalizeRouteConfig: (config) => ({
+          ...config,
+          security: [],
+        }),
+      },
+      async (req, res) => {
+        try {
+          const privacy = req.body.privacy || "private";
+          const content = await resolveJsonLdInput(req.body.jsonld);
+
+          const { ual, error } = await publishJsonLdAsset(content, privacy);
+          if (error) {
+            console.error("Error creating asset:", error);
+            return res.status(500).json({
+              success: false,
+              error: "Failed to create asset: " + error,
+            });
+          }
+
+          if (!ual) {
+            return res.status(500).json({
+              success: false,
+              error: "Failed to create asset: missing UAL in response",
+            });
+          }
+
+          const explorerLink = getExplorerUrl(ual);
+          const message = `Knowledge Asset collection successfully created.\n\nUAL: ${ual}\nDKG Explorer link: ${explorerLink}`;
+
+          return res.json({
+            success: true,
+            data: {
+              ual,
+              explorerLink,
+              message,
+            },
+          });
+        } catch (error) {
+          const errorMessage =
+            error instanceof Error ? error.message : String(error);
+          return res.status(500).json({
+            success: false,
+            error: errorMessage,
+          });
+        }
+      },
+    ),
+  );
+
   api.post(
     "/api/dkg/query",
     openAPIRoute(

packages/plugin-dkg-essentials/src/plugins/dkg-tools.ts

@@ -451,6 +451,35 @@ describe("@dkg/plugin-dkg-essentials checks", () => {
   });
 
   describe("HTTP API Routes", () => {
+    it("should expose POST /api/dkg/create from Essentials", async () => {
+      const response = await request(app)
+        .post("/api/dkg/create")
+        .send({
+          jsonld: JSON.stringify({
+            "@context": "https://schema.org",
+            "@type": "Organization",
+            name: "HTTP Create Test Organization",
+          }),
+          privacy: "private",
+        })
+        .expect(200);
+
+      expect(response.body.success).to.equal(true);
+      expect(response.body.data.ual).to.equal("did:dkg:otp:20430/0x123456/12345");
+      expect(response.body.data.explorerLink).to.include(
+        "https://dkg-testnet.origintrail.io/explore?ual=",
+      );
+    });
+
+    it("should return 400 for invalid POST /api/dkg/create input", async () => {
+      await request(app)
+        .post("/api/dkg/create")
+        .send({
+          privacy: "private",
+        })
+        .expect(400);
+    });
+
     it("should expose POST /api/dkg/query from Essentials", async () => {
       const response = await request(app)
         .post("/api/dkg/query")