allow js processor to be async

jolly-roger-eth · Apr 13, 2024 · 98d3831 · 98d3831
1 parent 7e6291c
commit 98d3831
Show file tree

Hide file tree

Showing 19 changed files with 73 additions and 14 deletions.
diff --git a/examples/basic/CHANGELOG.md b/examples/basic/CHANGELOG.md
@@ -1,5 +1,12 @@
 # basic
 
+## 0.0.4
+
+### Patch Changes
+
+- Updated dependencies
+  - [email protected]
+
 ## 0.0.3
 
 ### Patch Changes

diff --git a/examples/basic/package.json b/examples/basic/package.json
@@ -1,7 +1,7 @@
 {
   "name": "basic",
   "private": true,
-  "version": "0.0.3",
+  "version": "0.0.4",
   "type": "module",
   "scripts": {
     "dev": "vite",
@@ -10,7 +10,7 @@
   },
   "dependencies": {
     "ethereum-indexer-browser": "workspace:^0.7.0",
-    "ethereum-indexer-js-processor": "workspace:^0.6.16",
+    "ethereum-indexer-js-processor": "workspace:^0.7.0",
     "react": "^18.2.0",
     "react-dom": "^18.2.0"
   },

diff --git a/examples/event-processor-bleeps/CHANGELOG.md b/examples/event-processor-bleeps/CHANGELOG.md
@@ -1,5 +1,12 @@
 # event-processor-bleeps
 
+## 0.0.57
+
+### Patch Changes
+
+- Updated dependencies
+  - [email protected]
+
 ## 0.0.56
 
 ### Patch Changes

diff --git a/examples/event-processor-bleeps/package.json b/examples/event-processor-bleeps/package.json
@@ -1,7 +1,7 @@
 {
 	"name": "event-processor-bleeps",
 	"private": true,
-	"version": "0.0.56",
+	"version": "0.0.57",
 	"description": "",
 	"type": "module",
 	"main": "dist/index.cjs",

diff --git a/examples/event-processor-conquest-eth/CHANGELOG.md b/examples/event-processor-conquest-eth/CHANGELOG.md
@@ -1,5 +1,12 @@
 # event-processor-conquest-eth
 
+## 0.0.57
+
+### Patch Changes
+
+- Updated dependencies
+  - [email protected]
+
 ## 0.0.56
 
 ### Patch Changes

diff --git a/examples/event-processor-conquest-eth/package.json b/examples/event-processor-conquest-eth/package.json
@@ -1,7 +1,7 @@
 {
   "name": "event-processor-conquest-eth",
   "private": true,
-  "version": "0.0.56",
+  "version": "0.0.57",
   "description": "",
   "type": "module",
   "main": "dist/index.cjs",

diff --git a/examples/event-processor-conquest-fplay/CHANGELOG.md b/examples/event-processor-conquest-fplay/CHANGELOG.md
@@ -1,5 +1,12 @@
 # event-processor-conquest-fplay
 
+## 0.0.57
+
+### Patch Changes
+
+- Updated dependencies
+  - [email protected]
+
 ## 0.0.56
 
 ### Patch Changes

diff --git a/examples/event-processor-conquest-fplay/package.json b/examples/event-processor-conquest-fplay/package.json
@@ -1,7 +1,7 @@
 {
 	"name": "event-processor-conquest-fplay",
 	"private": true,
-	"version": "0.0.56",
+	"version": "0.0.57",
 	"description": "",
 	"type": "module",
 	"main": "dist/index.cjs",

diff --git a/examples/event-processor-nfts/CHANGELOG.md b/examples/event-processor-nfts/CHANGELOG.md
@@ -1,5 +1,12 @@
 # event-processor-nfts
 
+## 0.0.57
+
+### Patch Changes
+
+- Updated dependencies
+  - [email protected]
+
 ## 0.0.56
 
 ### Patch Changes

diff --git a/examples/event-processor-nfts/package.json b/examples/event-processor-nfts/package.json
@@ -1,7 +1,7 @@
 {
   "name": "event-processor-nfts",
   "private": true,
-  "version": "0.0.56",
+  "version": "0.0.57",
   "description": "",
   "type": "module",
   "main": "dist/index.cjs",

diff --git a/examples/mud/CHANGELOG.md b/examples/mud/CHANGELOG.md
@@ -1,5 +1,15 @@
 # web-demo
 
+## 0.1.69
+
+### Patch Changes
+
+- Updated dependencies
+  - [email protected]
+  - [email protected]
+  - [email protected]
+  - [email protected]
+
 ## 0.1.68
 
 ### Patch Changes

diff --git a/examples/mud/package.json b/examples/mud/package.json
@@ -1,7 +1,7 @@
 {
 	"name": "mud-demo",
 	"private": true,
-	"version": "0.1.68",
+	"version": "0.1.69",
 	"type": "module",
 	"scripts": {
 		"dev": "vite",

diff --git a/examples/web-demo/CHANGELOG.md b/examples/web-demo/CHANGELOG.md
@@ -1,5 +1,13 @@
 # web-demo
 
+## 0.1.69
+
+### Patch Changes
+
+- [email protected]
+- [email protected]
+- [email protected]
+
 ## 0.1.68
 
 ### Patch Changes

diff --git a/examples/web-demo/package.json b/examples/web-demo/package.json
@@ -1,7 +1,7 @@
 {
 	"name": "web-demo",
 	"private": true,
-	"version": "0.1.68",
+	"version": "0.1.69",
 	"type": "module",
 	"scripts": {
 		"dev": "vite",

diff --git a/packages/ethereum-indexer-js-processor/CHANGELOG.md b/packages/ethereum-indexer-js-processor/CHANGELOG.md
@@ -1,5 +1,11 @@
 # ethereum-indexer-js-processor
 
+## 0.7.0
+
+### Minor Changes
+
+- allow js processor to be async
+
 ## 0.6.30
 
 ### Patch Changes

diff --git a/packages/ethereum-indexer-js-processor/package.json b/packages/ethereum-indexer-js-processor/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "ethereum-indexer-js-processor",
-	"version": "0.6.30",
+	"version": "0.7.0",
 	"description": "",
 	"keywords": [],
 	"author": "",

diff --git a/packages/ethereum-indexer-js-processor/src/processor/JSObjectEventProcessor.ts b/packages/ethereum-indexer-js-processor/src/processor/JSObjectEventProcessor.ts
@@ -28,7 +28,7 @@ export type SingleEventJSONProcessor<
 	version?: string;
 	createInitialState(): ProcessResultType;
 	configure(config: ProcessorConfig): void;
-	processEvent(json: ProcessResultType, event: LogEvent<ABI>): void;
+	processEvent(json: ProcessResultType, event: LogEvent<ABI>): void | Promise<void>;
 };
 
 export class JSObjectEventProcessor<ABI extends Abi, ProcessResultType extends JSObject, ProcessorConfig = undefined>
@@ -181,7 +181,7 @@ export class JSObjectEventProcessor<ABI extends Abi, ProcessResultType extends J
 					}
 				} else {
 					if (willNotChange) {
-						this.singleEventProcessor.processEvent(this._json.state, event);
+						await this.singleEventProcessor.processEvent(this._json.state, event);
 					} else {
 						if (!lastBlockHash || event.blockHash != lastBlockHash) {
 							if (draft as any) {

diff --git a/packages/ethereum-indexer-js-processor/src/processor/types.ts b/packages/ethereum-indexer-js-processor/src/processor/types.ts
@@ -28,7 +28,7 @@ export type EventFunctions<ABI extends Abi, ProcessResultType extends JSObject,
 				json: ProcessResultType,
 				event: LogEvent<ABI> & {args: InputValues<ExtractAbiEvent<ABI, Property>>},
 				config: ProcessorConfig
-		  ) => void;
+		  ) => Promise<void> | void;
 };
 
 export type MergedEventFunctions<

diff --git a/packages/ethereum-indexer-js-processor/src/processor/utils.ts b/packages/ethereum-indexer-js-processor/src/processor/utils.ts
@@ -13,7 +13,7 @@ export type JSProcessor<
 > = EventFunctions<ABI, ProcessResultType, ProcessorConfig> & {
 	version?: string;
 	construct(): ProcessResultType;
-	handleUnparsedEvent?(json: ProcessResultType, event: LogEventWithParsingFailure): Promise<void>;
+	handleUnparsedEvent?(json: ProcessResultType, event: LogEventWithParsingFailure): void | Promise<void>;
 };
 
 class SingleJSONEventProcessorWrapper<ABI extends Abi, ProcessResultType extends JSObject, ProcessorConfig> {
@@ -31,7 +31,7 @@ class SingleJSONEventProcessorWrapper<ABI extends Abi, ProcessResultType extends
 		this.config = config;
 	}
 
-	processEvent(json: ProcessResultType, event: LogEvent<ABI>) {
+	processEvent(json: ProcessResultType, event: LogEvent<ABI>): Promise<void> | void {
 		if ('decodeError' in event) {
 			if (this.obj.handleUnparsedEvent) {
 				return this.obj.handleUnparsedEvent(json, event);