contacts: query group members

Author: angelo-v

contacts/src/rdflib/queries/GroupQuery.spec.ts

@@ -1,6 +1,8 @@
 import { graph, lit, sym } from "rdflib";
 import { GroupQuery } from "./GroupQuery";
 import { rdf, vcard } from "../namespaces";
+import { AddressBookQuery } from "./AddressBookQuery";
+import * as querystring from "querystring";
 
 describe(GroupQuery.name, () => {
   describe("query name", () => {
@@ -63,4 +65,100 @@ describe(GroupQuery.name, () => {
       expect(result).toEqual("");
     });
   });
+  describe("query members", () => {
+    it("returns an empty array if nothing found in store", () => {
+      const query = new GroupQuery(
+        graph(),
+        sym("http://pod.test/alice/contacts/1/group/1/index.ttl#this"),
+      );
+      const result = query.queryMembers();
+      expect(result).toEqual([]);
+    });
+    it("returns a single contact with name and URI", () => {
+      const store = graph();
+      const groupNode = sym(
+        "http://pod.test/alice/contacts/1/group/1/index.ttl#this",
+      );
+      store.add(
+        groupNode,
+        vcard("hasMember"),
+        sym("http://pod.test/alice/contacts/Person/1#this"),
+        groupNode.doc(),
+      );
+      store.add(
+        sym("http://pod.test/alice/contacts/Person/1#this"),
+        vcard("fn"),
+        lit("Bob"),
+        groupNode.doc(),
+      );
+      const query = new GroupQuery(store, groupNode);
+      const result = query.queryMembers();
+      expect(result).toEqual([
+        {
+          uri: "http://pod.test/alice/contacts/Person/1#this",
+          name: "Bob",
+        },
+      ]);
+    });
+
+    it("returns all contacts with name and URI", () => {
+      const store = graph();
+      const groupNode = sym(
+        "http://pod.test/alice/contacts/1/group/1/index.ttl#this",
+      );
+
+      store.add(
+        groupNode,
+        vcard("hasMember"),
+        sym("http://pod.test/alice/contacts/Person/1#this"),
+        groupNode.doc(),
+      );
+      store.add(
+        sym("http://pod.test/alice/contacts/Person/1#this"),
+        vcard("fn"),
+        lit("Alice"),
+        groupNode.doc(),
+      );
+      store.add(
+        groupNode,
+        vcard("hasMember"),
+        sym("http://pod.test/alice/contacts/Person/2#this"),
+        groupNode.doc(),
+      );
+      store.add(
+        sym("http://pod.test/alice/contacts/Person/2#this"),
+        vcard("fn"),
+        lit("Bob"),
+        groupNode.doc(),
+      );
+
+      const query = new GroupQuery(
+        store,
+        sym("http://pod.test/alice/contacts/1/group/1/index.ttl#this"),
+      );
+      const result = query.queryMembers();
+      expect(result).toEqual([
+        {
+          uri: "http://pod.test/alice/contacts/Person/1#this",
+          name: "Alice",
+        },
+        {
+          uri: "http://pod.test/alice/contacts/Person/2#this",
+          name: "Bob",
+        },
+      ]);
+    });
+
+    it("ignores members that are not named nodes", () => {
+      const store = graph();
+      const groupNode = sym(
+        "http://pod.test/alice/contacts/1/group/1/index.ttl#this",
+      );
+      store.add(groupNode, vcard("hasMember"), lit("Bob"), groupNode.doc());
+
+      const query = new GroupQuery(store, groupNode);
+      const result = query.queryMembers();
+      expect(result).toEqual([]);
+    });
+  });
 });

contacts/src/rdflib/queries/GroupQuery.ts

@@ -1,4 +1,4 @@
-import { IndexedFormula, NamedNode } from "rdflib";
+import { IndexedFormula, isNamedNode, NamedNode } from "rdflib";
 import { vcard } from "../namespaces";
 
 export class GroupQuery {
@@ -20,4 +20,14 @@ export class GroupQuery {
       ) ?? ""
     );
   }
+
+  queryMembers() {
+    return this.store
+      .each(this.groupNode, vcard("hasMember"))
+      .filter((it): it is NamedNode => isNamedNode(it))
+      .map((node) => ({
+        uri: node.value,
+        name: this.store.anyValue(node, vcard("fn")),
+      }));
+  }
 }