split up entity.ts

Author: nikgraf

apps/events/src/components/todos.tsx

@@ -15,8 +15,8 @@ export const Todos = () => {
   const [assignees, setAssignees] = useState<{ value: string; label: string }[]>([]);
 
   useEffect(() => {
-    // filter out assignees that are not in the users array
     setAssignees((prevFilteredAssignees) => {
+      // filter out assignees that are not in the users array whenever users change
       return prevFilteredAssignees.filter((assignee) => users.some((user) => user.id === assignee.value));
     });
   }, [users]);

packages/hypergraph/src/entity/create.ts

@@ -0,0 +1,26 @@
+import type { DocHandle } from '@automerge/automerge-repo';
+import * as Schema from 'effect/Schema';
+import { generateId } from '../utils/generateId.js';
+import type { AnyNoContext, DocumentContent, Entity, Insert } from './types.js';
+
+/**
+ * Creates an entity model of given type and stores it in the repo.
+ */
+export const create = <const S extends AnyNoContext>(handle: DocHandle<DocumentContent>, type: S) => {
+  // TODO: what's the right way to get the name of the type?
+  // @ts-expect-error name is defined
+  const typeName = type.name;
+  const entityId = generateId();
+  const encode = Schema.encodeSync(type.insert);
+
+  return (data: Readonly<Schema.Schema.Type<Insert<S>>>): Entity<S> => {
+    const encoded = encode(data);
+    // apply changes to the repo -> adds the entity to the repo entities document
+    handle.change((doc) => {
+      doc.entities ??= {};
+      doc.entities[entityId] = { ...encoded, '@@types@@': [typeName] };
+    });
+
+    return { id: entityId, ...encoded, type: typeName };
+  };
+};

packages/hypergraph/src/entity/decodedEntitiesCache.ts

@@ -33,8 +33,3 @@ type DecodedEntitiesCache = Map<
 >;
 
 export const decodedEntitiesCache: DecodedEntitiesCache = new Map();
-
-export const relationParentQueries: Map<
-  string, // entity ID
-  Array<QueryEntry>
-> = new Map();

packages/hypergraph/src/entity/delete.ts

@@ -0,0 +1,23 @@
+import type { DocHandle } from '@automerge/automerge-repo';
+import type { DocumentContent } from './types.js';
+
+/**
+ * Deletes the exiting entity from the repo.
+ */
+export const delete$ = (handle: DocHandle<DocumentContent>) => {
+  return (id: string): boolean => {
+    let result = false;
+
+    // apply changes to the repo -> removes the existing entity by its id
+    handle.change((doc) => {
+      if (doc.entities?.[id] !== undefined) {
+        delete doc.entities[id];
+        result = true;
+      }
+    });
+
+    return result;
+  };
+};
+
+export { delete$ as delete };