feat: Update ajv-threads package to version with worker pool

ceramicnetwork · Mar 5, 2024 · c6fe092 · c6fe092
1 parent f2b50c6
commit c6fe092
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/packages/core/package.json b/packages/core/package.json
@@ -71,7 +71,7 @@
     "@stablelib/random": "^1.0.1",
     "@stablelib/sha256": "^1.0.1",
     "@stablelib/uuid": "^1.0.1",
-    "ajv-threads": "^1.0.3",
+    "ajv-threads": "^1.0.4",
     "await-semaphore": "^0.1.3",
     "cartonne": "^3.0.1",
     "codeco": "^1.1.0",

diff --git a/packages/core/src/ceramic.ts b/packages/core/src/ceramic.ts
@@ -244,7 +244,10 @@ export class Ceramic implements StreamReaderWriter, StreamStateLoader {
 
     this._ipfs = modules.ipfs
 
-    this._schemaValidator = new SchemaValidation()
+    const numCores = os.cpus().length
+    // Use number of threads equal to half the available cores for schema validation. Leave the
+    // other half for signature validation.
+    this._schemaValidator = new SchemaValidation(Math.floor(numCores / 2))
     this._streamHandlers = HandlersMap.makeWithDefaultHandlers(this._logger, this._schemaValidator)
 
     // This initialization block below has to be redone.

diff --git a/packages/stream-model-instance-handler/package.json b/packages/stream-model-instance-handler/package.json
@@ -42,7 +42,7 @@
     "@ceramicnetwork/stream-handler-common": "^4.1.0",
     "@ceramicnetwork/stream-model-instance": "^4.2.0",
     "@ceramicnetwork/streamid": "^5.0.0",
-    "ajv-threads": "^1.0.3",
+    "ajv-threads": "^1.0.4",
     "fast-json-patch": "^3.1.0",
     "least-recent": "^1.0.3",
     "lodash.clonedeep": "^4.5.0",