Method addEdge

packages/y-graph-storage/src/YGraphStorage.ts:319–359

(edge: StoredEdge)

  }

  public addEdge(edge: StoredEdge): void {
    const [label, uuid] = parseElementId(edge.id);
    const schema = this.#config.schema.edges[label];
    if (schema == null) {
      throw new LabelNotFoundError(label);
    }
    // inV is the target vertex, outV is the source vertex
    const inVMap = this.getVertexMap(edge.inV);
    const outVMap = this.getVertexMap(edge.outV);
    const collection = this.getEdgeCollectionMap(label);
    this.transact(() => {
      const map = new Y.Map<unknown>();
      map.set($InVKey, edge.inV);
      map.set($OutVKey, edge.outV);
      collection.set(uuid, map);
      for (const key of Object.keys(schema.properties)) {
        const value = edge.properties[key as keyof typeof edge.properties];
        if (value === undefined) {
          continue;
        }
        map.set(key, value);
      }

      // inV (target) receives incoming edges
      let incomingEdges = inVMap.get($InEKey) as undefined | Y.Map<unknown>;
      if (incomingEdges == null) {
        incomingEdges = new Y.Map<unknown>([[edge.id, true]]);
        inVMap.set($InEKey, incomingEdges);
      } else {
        incomingEdges.set(edge.id, true);
      }
      // outV (source) has outgoing edges
      let outgoingEdges = outVMap.get($OutEKey) as undefined | Y.Map<unknown>;
      if (outgoingEdges == null) {
        outgoingEdges = new Y.Map<unknown>([[edge.id, true]]);
        outVMap.set($OutEKey, outgoingEdges);
      } else {
        outgoingEdges.set(edge.id, true);
      }
    });
  }

  public deleteEdge(id: ElementId): void {
    const [label, uuid] = parseElementId(id);