Function handleAsyncTransaction

packages/graph/src/AsyncGraph.ts:203–257

(
  graph: Graph<TSchema>,
  command: AsyncTransaction,
)

}

function* handleAsyncTransaction<TSchema extends GraphSchema>(
  graph: Graph<TSchema>,
  command: AsyncTransaction,
): Iterable<AsyncTransactionOperationResult> {
  for (const operation of command.operations) {
    try {
      switch (operation["@type"]) {
        case "AddVertexOperation": {
          graph.storage.addVertex(operation.vertex);
          yield {
            "@type": "AsyncOperationSuccess",
          };
          break;
        }
        case "AddEdgeOperation": {
          graph.storage.addEdge(operation.edge);
          yield {
            "@type": "AsyncOperationSuccess",
          };
          break;
        }
        case "DeleteVertexOperation": {
          graph.storage.deleteVertex(operation.id);
          yield {
            "@type": "AsyncOperationSuccess",
          };
          break;
        }
        case "DeleteEdgeOperation": {
          graph.storage.deleteEdge(operation.id);
          yield {
            "@type": "AsyncOperationSuccess",
          };
          break;
        }
        case "UpdatePropertyOperation": {
          graph.storage.updateProperty(operation.id, operation.key, operation.value);
          yield {
            "@type": "AsyncOperationSuccess",
          };
          break;
        }
        default: {
          throw new Error(`Unknown operation type: ${operation["@type"]}`);
        }
      }
    } catch (error) {
      yield {
        "@type": "AsyncOperationFailure",
        operation: operation,
        error: error instanceof Error ? error.message : String(error),
      };
    }
  }
}