forEachVertex-method

lib/graph/file.graph.ts

@@ -1,5 +1,6 @@
 import {
   FileGraphAbstract,
+  ICallbackVertex,
   IFindVertex,
   IPredicate,
   IUpdater,
@@ -13,8 +14,8 @@
 
 class FileGraphIml implements FileGraphAbstract {
   constructor(
     private readonly storageFile: StorageFile,
     private readonly asyncTaskQueue: AsyncTaskQueue,
   ) {}
 
   public async createVertex<T extends object>(data: T): Promise<IVertex<T>> {
@@ -47,7 +48,7 @@
     );
   }
 
-  public async findOne<T extends object>(
+  public findOne<T extends object>(
     predicate: IPredicate<T>,
   ): Promise<IVertex<T> | null> {
     return this.storageFile.searchLine(predicate);
@@ -64,6 +65,12 @@
     return vertices;
   }
 
+  public async forEachVertex<T extends object>(
+    callbackVertex: ICallbackVertex<T>,
+  ): Promise<void> {
+    await this.storageFile.searchLine(callbackVertex);
+  }
+
   public async createEdge(ids: IUuidArray): Promise<boolean> {
     const updater = (vertex: IVertex<object>) => {
       const index = ids.indexOf(vertex.id);

lib/graph/storage.file.ts

@@ -8,6 +8,7 @@
 import readline from 'readline';
 import { mergeVertices, uuid } from '../utils';
 import {
+  ICallbackVertex,
   IFindVertex,
   ILineReturn,
   IPredicate,
@@ -16,7 +17,7 @@
 } from '../interfaces';
 
 export class StorageFile {
   constructor(private readonly path: string) {}
 
   public async appendFile<T extends object>(vertex: T): Promise<void> {
     const vertexSer = Array.isArray(vertex)
@@ -27,7 +28,7 @@
   }
 
   public async searchLine<T extends object>(
-    predicate: IFindVertex<T> | IPredicate<T>,
+    predicate: IFindVertex<T> | IPredicate<T> | ICallbackVertex<T>,
   ): Promise<IVertex<T>> {
     const fileStream = this.createLineStream(true);
     return await fileStream(async line => {

lib/interfaces/graph.interface.ts

@@ -1,4 +1,5 @@
 import {
+  ICallbackVertex,
   IPredicate,
   IUpdater,
   IUuidArray,
@@ -13,7 +14,7 @@
    * @param {T} data - The data vertex for creating the node.
    * @returns {IVertex<T>} - created node.
    */
   public abstract createVertex<T extends object>(data: T): Promise<IVertex<T>>;
 
   /**
    * Creates multiple vertices in the graph.
@@ -24,7 +25,7 @@
    * @returns {Promise<uuidType[]>} A promise that resolves to an array of unique identifiers of the created vertices.
    */
   public abstract createVertices<T extends object>(
     data: T[],
   ): Promise<IVertex<T>[]>;
 
   /**
@@ -39,7 +40,7 @@
    * @returns {Promise<boolean>} A promise that resolves to `true` if the record was successfully updated, and `false` if the record was not found or an error occurred.
    */
   public abstract updateVertex<T extends object>(
     updater: IUpdater<T>,
   ): Promise<boolean>;
 
   /**
@@ -54,7 +55,7 @@
    * @returns {Promise<boolean>} A promise that resolves to `true` if the record was successfully deleted, and `false` if the record was not found or an error occurred.
    */
   public abstract deleteVertex<T extends object>(
     predicate: IPredicate<T>,
   ): Promise<boolean>;
 
   /**
@@ -64,7 +65,7 @@
    * @returns {Promise<T | null>} A promise that resolves to the found vertex if a match is found, or `null` if no match is found.
    */
   public abstract findOne<T extends object>(
     predicate: IPredicate<T>,
   ): Promise<IVertex<T> | null>;
 
   /**
@@ -77,9 +78,21 @@
    * @returns {Promise<T[]>} A promise that resolves to an array of vertices that match the search criteria.
    */
   public abstract findAll<T extends object>(
     predicate: IPredicate<T>,
   ): Promise<IVertex<T>[]>;
 
+  /**
+   * Iterates over each vertex in the graph and applies the provided callback function.
+   *
+   * @template T - The type of the vertex object.
+   * @param {ICallbackVertex<T>} callbackVertex - A callback function that is invoked for each vertex.
+   * If it returns `true`, the iteration stops.
+   * @returns {Promise<void>} - A promise that resolves when the iteration is complete or has been stopped.
+   */
+  public abstract forEachVertex<T extends object>(
+    callbackVertex: ICallbackVertex<T>,
+  ): Promise<void>;
+
   /**
    * Creates edges (links) between the specified vertices.
    *

lib/interfaces/params.interface.ts

@@ -12,6 +12,9 @@ export interface IVertexTree<T extends object> extends IVertex<T> {
 
 export type IUuidArray = [uuidType, ...uuidType[]];
 export type IPredicate<T extends object> = (vertex: IVertex<T>) => boolean;
+export type ICallbackVertex<T extends object> = (
+  vertex: IVertex<T>,
+) => void | boolean;
 export type IUpdater<T extends object> = (
   vertex: IVertex<T>,
 ) => IVertex<T> | object;