chats: insert message into message document for today

Author: angelo-v

chats/rdflib/src/module/ChatsModuleRdfLib.ts

@@ -18,7 +18,8 @@ import { createChat } from "./update-operations/index.js";
 import { ChatQuery } from "./queries/index.js";
 import { MessagesDocumentQuery } from "./queries/MessagesDocumentQuery.js";
 import { DateContainerQuery } from "./queries/DateContainerQuery.js";
-import { mintMessageUri } from './uris/index.js';
+import { mintMessageUri } from "./uris/index.js";
+import { postMessage } from './update-operations/post-message.js';
 
 interface ModuleConfig {
   store: IndexedFormula;
@@ -103,6 +104,10 @@ export class ChatsModuleRdfLib implements ChatsModule {
 
   // eslint-disable-next-line @typescript-eslint/no-unused-vars
   async postMessage({ chatUri }: PostMessageCommand): Promise<string> {
-    return mintMessageUri(sym(chatUri));
+    const chatNode = sym(chatUri);
+    const messageUri = mintMessageUri(chatNode);
+    const operation = postMessage(messageUri, chatNode);
+    await executeUpdate(this.fetcher, this.updater, operation);
+    return messageUri;
   }
 }

chats/rdflib/src/module/_integration-tests/post-message.integration.spec.ts

@@ -1,7 +1,11 @@
 import { setupModule } from "../../test-support/setupModule";
 import { generateId } from "@solid-data-modules/rdflib-utils/identifier";
 import { when } from "jest-when";
-import { mockTurtleDocument } from "@solid-data-modules/rdflib-utils/test-support";
+import {
+  expectPatchRequest,
+  mockNotFound,
+  mockTurtleDocument,
+} from "@solid-data-modules/rdflib-utils/test-support";
 
 jest.mock("@solid-data-modules/rdflib-utils/identifier");
 
@@ -29,6 +33,12 @@ describe("post message", () => {
         `,
     );
 
+    // but without message document for today
+    mockNotFound(
+      authenticatedFetch,
+      "https://pod.test/alice/chats/abc123/2024/07/30/chat.ttl",
+    );
+
     // when a message is posted to the chat
     const uri = await chats.postMessage({
       chatUri: "https://pod.test/alice/chats/abc123/index.ttl#this",
@@ -42,5 +52,19 @@ describe("post message", () => {
         "https://pod.test/alice/chats/abc123/2024/07/30/chat.ttl#8c615b",
       ),
     );
+
+    // and the message is inserted to the message document for today
+    expectPatchRequest(
+      authenticatedFetch,
+      "https://pod.test/alice/chats/abc123/2024/07/30/chat.ttl",
+      `@prefix solid: <http://www.w3.org/ns/solid/terms#>.
+@prefix ex: <http://www.example.org/terms#>.
+
+_:patch
+
+      solid:inserts {
+        <https://pod.test/alice/chats/abc123/index.ttl#this> <http://www.w3.org/2005/01/wf/flow#message> <https://pod.test/alice/chats/abc123/2024/07/30/chat.ttl#8c615b> .
+      };   a solid:InsertDeletePatch .`,
+    );
   });
 });

chats/rdflib/src/module/update-operations/post-message.spec.ts

@@ -0,0 +1,20 @@
+import { postMessage } from "./post-message";
+import { st, sym } from "rdflib";
+import { wf } from "../namespaces";
+
+describe("post message", () => {
+  it("inserts a link from chat to message", () => {
+    const result = postMessage(
+      "https://pod.test/chat/42/chat.ttl#1",
+      sym("https://pod.test/chat/42/index.ttl#this"),
+    );
+    expect(result.insertions).toContainEqual(
+      st(
+        sym("https://pod.test/chat/42/index.ttl#this"),
+        wf("message"),
+        sym("https://pod.test/chat/42/chat.ttl#1"),
+        sym("https://pod.test/chat/42/chat.ttl"),
+      ),
+    );
+  });
+});

chats/rdflib/src/module/update-operations/post-message.ts

@@ -0,0 +1,15 @@
+import { NamedNode, st, sym } from "rdflib";
+import { UpdateOperation } from "@solid-data-modules/rdflib-utils";
+import { wf } from '../namespaces.js';
+
+export function postMessage(
+  messageUri: string,
+  chatNode: NamedNode,
+): UpdateOperation {
+  const messageNode = sym(messageUri);
+  return {
+    insertions: [st(chatNode, wf("message"), messageNode, messageNode.doc())],
+    deletions: [],
+    filesToCreate: [],
+  };
+}