chore: update prettier

sroussey · Jan 31, 2025 · 015bd97 · 015bd97
1 parent 1e645d5
commit 015bd97
Show file tree

Hide file tree

Showing 20 changed files with 61 additions and 30 deletions.
diff --git a/.prettierrc b/.prettierrc
@@ -0,0 +1,10 @@
+{
+  "printWidth": 100,
+  "tabWidth": 2,
+  "useTabs": false,
+  "semi": true,
+  "singleQuote": false,
+  "trailingComma": "es5",
+  "bracketSpacing": true,
+  "arrowParens": "always"
+}
diff --git a/.vscode/settings.json b/.vscode/settings.json
@@ -16,7 +16,7 @@
   },
   "search.exclude": {
     "**/dist": true,
-    "**/package-lock.json": true,
+    "**/bun.lock": true,
     "**/*.tsbuildinfo": true
   },
   "editor.codeActionsOnSave": {

diff --git a/bun.lock b/bun.lock
@@ -34,6 +34,7 @@
         "eslint-plugin-react-hooks": "^5.1.0",
         "eslint-plugin-regexp": "^2.7.0",
         "globals": "^15.14.0",
+        "prettier": "^3.4.2",
         "typescript": "^5.7.3",
       },
     },
@@ -1115,6 +1116,8 @@
 
     "prelude-ls": ["[email protected]", "", {}, "sha512-vkcDPrRZo1QZLbn5RLGPpg/WmIQ65qoWWhcGKf/b5eplkkarX0m9z8ppCat4mlOqUsWpyNuYgO3VRyrYHSzX5g=="],
 
+    "prettier": ["[email protected]", "", { "bin": { "prettier": "bin/prettier.cjs" } }, "sha512-e9MewbtFo+Fevyuxn/4rrcDAaq0IYxPGLvObpQjiZBMAzB9IGmzlnG9RZy3FFas+eBMu2vA0CszMeduow5dIuQ=="],
+
     "process": ["[email protected]", "", {}, "sha512-cdGef/drWFoydD1JsMzuFf8100nZl+GT+yacc2bEced5f9Rjk4z+WtFUTBu9PhOi9j/jfmBPu0mMEY4wIdAF8A=="],
 
     "prop-types": ["[email protected]", "", { "dependencies": { "loose-envify": "^1.4.0", "object-assign": "^4.1.1", "react-is": "^16.13.1" } }, "sha512-oj87CgZICdulUohogVAR7AjlC0327U4el4L6eAvOqCeudMDVU0NThNaV+b9Df4dXgSP1gXMTnPdhfe/2qDH5cg=="],

diff --git a/examples/web/src/RunGraphFlow.tsx b/examples/web/src/RunGraphFlow.tsx
@@ -190,7 +190,7 @@ function listenToTask(
               extent: "parent",
               selectable: false,
               connectable: false,
-            } as Node<TurboNodeData>)
+            }) as Node<TurboNodeData>
         );
         listenToGraphTasks(task.subGraph, setNodes, setEdges);
         let returnNodes = nodes.filter((n) => n.parentId !== task.config.id); // remove old children

diff --git a/package.json b/package.json
@@ -22,7 +22,7 @@
     "clean": "rm -rf node_modules packages/*/node_modules packages/*/dist packages/*/src/**/*\\.d\\.ts packages/*/src/**/*\\.map examples/*/node_modules examples/*/dist examples/*/src/**/*\\.d\\.ts examples/*/src/**/*\\.map",
     "watch:packages": "concurrently --kill-others -c 'auto' -n core,task,storage,ai,provider,test 'cd packages/core && bun run watch' 'sleep 3 && cd packages/task && bun run watch' 'sleep 3 && cd packages/storage && bun run watch' 'sleep 3 && cd packages/ai && bun run watch' 'sleep 6 && cd packages/ai-provider && bun run watch' 'sleep 10 && cd packages/test && bun run watch'",
     "docs": "typedoc",
-    "format": "eslint --fix && prettier \"{packages|examples}/*/src/**/*.{js,ts,tsx,json}\" --check --write",
+    "format": "eslint --fix && prettier \"{packages,examples}/*/src/**/*.{js,ts,tsx,json}\" --check --write",
     "release": "bun run build && bun publish",
     "test": "jest"
   },
@@ -57,6 +57,7 @@
     "eslint-plugin-react-hooks": "^5.1.0",
     "eslint-plugin-regexp": "^2.7.0",
     "globals": "^15.14.0",
+    "prettier": "^3.4.2",
     "typescript": "^5.7.3"
   },
   "engines": {

diff --git a/packages/core/src/job/base/JobQueue.ts b/packages/core/src/job/base/JobQueue.ts
@@ -10,7 +10,10 @@ import { ILimiter } from "./ILimiter";
 import { Job, JobStatus } from "./Job";
 
 export class RetryError extends Error {
-  constructor(public retryDate: Date, message: string) {
+  constructor(
+    public retryDate: Date,
+    message: string
+  ) {
     super(message);
     this.name = "RetryError";
   }

diff --git a/packages/core/src/source/Document.ts b/packages/core/src/source/Document.ts
@@ -84,7 +84,11 @@ export class Document {
 }
 
 export class DocumentSection extends Document {
-  constructor(public parent: Document, content?: ContentType, metadata?: DocumentSectionMetadata) {
+  constructor(
+    public parent: Document,
+    content?: ContentType,
+    metadata?: DocumentSectionMetadata
+  ) {
     super(content, metadata);
     this.parent = parent;
   }

diff --git a/packages/core/src/storage/base/KVRepository.ts b/packages/core/src/storage/base/KVRepository.ts
@@ -47,7 +47,7 @@ export abstract class KVRepository<
   Value extends Record<string, any> = DefaultValueType,
   PrimaryKeySchema extends BasePrimaryKeySchema = typeof DefaultPrimaryKeySchema,
   ValueSchema extends BaseValueSchema = typeof DefaultValueSchema,
-  Combined extends Record<string, any> = Key & Value
+  Combined extends Record<string, any> = Key & Value,
 > {
   // KV repository event emitter
   private events = new EventEmitter<KVEvents>();

diff --git a/packages/core/src/task/base/ArrayTask.ts b/packages/core/src/task/base/ArrayTask.ts
@@ -133,7 +133,8 @@ function generateCombinations<T extends TaskInput>(input: T, inputMakeArray: (ke
     // Move to the next combination of indices
     for (let i = indices.length - 1; i >= 0; i--) {
       if (++indices[i] < arraysToCombine[i].length) break; // Increment current index if possible
-      if (i === 0) done = true; // All combinations have been generated
+      if (i === 0)
+        done = true; // All combinations have been generated
       else indices[i] = 0; // Reset current index and move to the next position
     }
   }
@@ -162,7 +163,7 @@ function generateCombinations<T extends TaskInput>(input: T, inputMakeArray: (ke
  */
 export function arrayTaskFactory<
   PluralInputType extends TaskInput = TaskInput,
-  PluralOutputType extends TaskOutput = TaskOutput
+  PluralOutputType extends TaskOutput = TaskOutput,
 >(
   taskClass: typeof SingleTask | typeof CompoundTask,
   inputMakeArray: Array<keyof PluralInputType>,

diff --git a/packages/core/src/task/base/TaskGraphRunner.ts b/packages/core/src/task/base/TaskGraphRunner.ts
@@ -31,7 +31,10 @@ export class TaskGraphRunner {
    * @param dag The task graph to run
    * @param repository The task output repository to use for caching task outputs
    */
-  constructor(public dag: TaskGraph, public repository?: TaskOutputRepository) {
+  constructor(
+    public dag: TaskGraph,
+    public repository?: TaskOutputRepository
+  ) {
     this.layers = new Map();
     this.provenanceInput = new Map();
   }

diff --git a/packages/core/src/util/Misc.ts b/packages/core/src/util/Misc.ts
@@ -60,10 +60,13 @@ export function deepEqual(a: any, b: any): boolean {
 export function sortObject(obj: Record<string, any>): Record<string, any> {
   return Object.keys(obj)
     .sort()
-    .reduce((result, key) => {
-      result[key] = obj[key];
-      return result;
-    }, {} as Record<string, any>);
+    .reduce(
+      (result, key) => {
+        result[key] = obj[key];
+        return result;
+      },
+      {} as Record<string, any>
+    );
 }
 
 export function serialize(obj: Record<string, any>): string {

diff --git a/packages/storage/src/browser/indexeddb/base/IndexedDbKVRepository.ts b/packages/storage/src/browser/indexeddb/base/IndexedDbKVRepository.ts
@@ -34,7 +34,7 @@ export class IndexedDbKVRepository<
   Value extends Record<string, any> = DefaultValueType,
   PrimaryKeySchema extends BasePrimaryKeySchema = typeof DefaultPrimaryKeySchema,
   ValueSchema extends BaseValueSchema = typeof DefaultValueSchema,
-  Combined extends Record<string, any> = Key & Value
+  Combined extends Record<string, any> = Key & Value,
 > extends KVRepository<Key, Value, PrimaryKeySchema, ValueSchema, Combined> {
   /** Promise that resolves to the IndexedDB database instance */
   private dbPromise: Promise<IDBDatabase>;

diff --git a/packages/storage/src/browser/inmemory/base/InMemoryKVRepository.ts b/packages/storage/src/browser/inmemory/base/InMemoryKVRepository.ts
@@ -32,7 +32,7 @@ export class InMemoryKVRepository<
   Value extends Record<string, any> = DefaultValueType,
   PrimaryKeySchema extends BasePrimaryKeySchema = typeof DefaultPrimaryKeySchema,
   ValueSchema extends BaseValueSchema = typeof DefaultValueSchema,
-  Combined extends Record<string, any> = Key & Value
+  Combined extends Record<string, any> = Key & Value,
 > extends KVRepository<Key, Value, PrimaryKeySchema, ValueSchema, Combined> {
   /** Internal storage using a Map with fingerprint strings as keys */
   values = new Map<string, Combined>();

diff --git a/packages/storage/src/bun/sqlite/SqliteJobQueue.ts b/packages/storage/src/bun/sqlite/SqliteJobQueue.ts
@@ -92,7 +92,7 @@ export class SqliteJobQueue<Input, Output> extends JobQueue<Input, Output> {
         input: string,
         runAfter: string | null,
         deadlineAt: string | null,
-        maxRetries: number
+        maxRetries: number,
       ]
     >(AddQuery);
 
@@ -225,8 +225,8 @@ export class SqliteJobQueue<Input, Output> extends JobQueue<Input, Output> {
     const status = output
       ? JobStatus.COMPLETED
       : error && job.retries >= job.maxRetries
-      ? JobStatus.FAILED
-      : JobStatus.PENDING;
+        ? JobStatus.FAILED
+        : JobStatus.PENDING;
 
     const UpdateQuery = `
         UPDATE job_queue 

diff --git a/packages/storage/src/bun/sqlite/base/SqliteKVRepository.ts b/packages/storage/src/bun/sqlite/base/SqliteKVRepository.ts
@@ -33,7 +33,7 @@ export class SqliteKVRepository<
   Value extends Record<string, any> = DefaultValueType,
   PrimaryKeySchema extends BasePrimaryKeySchema = typeof DefaultPrimaryKeySchema,
   ValueSchema extends BaseValueSchema = typeof DefaultValueSchema,
-  Combined extends Record<string, any> = Key & Value
+  Combined extends Record<string, any> = Key & Value,
 > extends BaseSqlKVRepository<Key, Value, PrimaryKeySchema, ValueSchema, Combined> {
   /** The SQLite database instance */
   private db: Database;

diff --git a/packages/storage/src/node/filesystem/base/FileKVRepository.ts b/packages/storage/src/node/filesystem/base/FileKVRepository.ts
@@ -35,7 +35,7 @@ export class FileKVRepository<
   Value extends Record<string, any> = DefaultValueType,
   PrimaryKeySchema extends BasePrimaryKeySchema = typeof DefaultPrimaryKeySchema,
   ValueSchema extends BaseValueSchema = typeof DefaultValueSchema,
-  Combined extends Key & Value = Key & Value
+  Combined extends Key & Value = Key & Value,
 > extends KVRepository<Key, Value, PrimaryKeySchema, ValueSchema, Combined> {
   private folderPath: string;
 

diff --git a/packages/storage/src/node/postgres/PostgresJobQueue.ts b/packages/storage/src/node/postgres/PostgresJobQueue.ts
@@ -82,8 +82,8 @@ export class PostgresJobQueue<Input, Output> extends JobQueue<Input, Output> {
       return await sql`
         INSERT INTO job_queue(queue, fingerprint, input, runAfter, maxRetries)
           VALUES (${this.queue!}, ${fingerprint}, ${
-        job.input as any
-      }::jsonb, ${job.createdAt.toISOString()}, ${job.maxRetries})
+            job.input as any
+          }::jsonb, ${job.createdAt.toISOString()}, ${job.maxRetries})
           RETURNING id`;
     });
   }
@@ -202,8 +202,8 @@ export class PostgresJobQueue<Input, Output> extends JobQueue<Input, Output> {
     const status = output
       ? JobStatus.COMPLETED
       : error && job.retries >= job.maxRetries
-      ? JobStatus.FAILED
-      : JobStatus.PENDING;
+        ? JobStatus.FAILED
+        : JobStatus.PENDING;
     if (!output || error) job.retries += 1;
     await this.sql.begin(async (sql) => {
       const result = await sql`    

diff --git a/packages/storage/src/node/postgres/base/PostgresKVRepository.ts b/packages/storage/src/node/postgres/base/PostgresKVRepository.ts
@@ -43,7 +43,7 @@ export class PostgresKVRepository<
   Value extends Record<string, any> = DefaultValueType,
   PrimaryKeySchema extends BasePrimaryKeySchema = typeof DefaultPrimaryKeySchema,
   ValueSchema extends BaseValueSchema = typeof DefaultValueSchema,
-  Combined extends Record<string, any> = Key & Value
+  Combined extends Record<string, any> = Key & Value,
 > extends BaseSqlKVRepository<Key, Value, PrimaryKeySchema, ValueSchema, Combined> {
   private pool: Pool;
 

diff --git a/packages/storage/src/util/Misc.ts b/packages/storage/src/util/Misc.ts
@@ -60,10 +60,13 @@ export function deepEqual(a: any, b: any): boolean {
 export function sortObject(obj: Record<string, any>): Record<string, any> {
   return Object.keys(obj)
     .sort()
-    .reduce((result, key) => {
-      result[key] = obj[key];
-      return result;
-    }, {} as Record<string, any>);
+    .reduce(
+      (result, key) => {
+        result[key] = obj[key];
+        return result;
+      },
+      {} as Record<string, any>
+    );
 }
 
 export function serialize(obj: Record<string, any>): string {

diff --git a/packages/storage/src/util/base/BaseSqlKVRepository.ts b/packages/storage/src/util/base/BaseSqlKVRepository.ts
@@ -34,7 +34,7 @@ export abstract class BaseSqlKVRepository<
   Value extends Record<string, any> = DefaultValueType,
   PrimaryKeySchema extends BasePrimaryKeySchema = typeof DefaultPrimaryKeySchema,
   ValueSchema extends BaseValueSchema = typeof DefaultValueSchema,
-  Combined extends Record<string, any> = Key & Value
+  Combined extends Record<string, any> = Key & Value,
 > extends KVRepository<Key, Value, PrimaryKeySchema, ValueSchema, Combined> {
   /**
    * Creates a new instance of BaseSqlKVRepository