move getValuesInEntityChange to zod

index.ts

@@ -1,4 +1,3 @@
-export * from "./src/extract-values.js";
 export * as typebox from "./src/typebox.js";
 export * as zod from "./src/zod.js";
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@substreams/sink-entity-changes",
-  "version": "0.3.7",
+  "version": "0.3.8",
   "description": "Substreams Sink Entity Changes",
   "type": "module",
   "license": "MIT",

src/extract-values.test.ts → src/zod.test.ts

@@ -1,6 +1,5 @@
 import { expect, test } from "vitest";
-import { getValuesInEntityChange } from "./extract-values.js";
-import { EntityChange } from "./zod.js";
+import { EntityChange, getValuesInEntityChange } from "./zod.js";
 
 test("getValuesInEntityChange", () => {
   const change: Partial<EntityChange> = {

src/zod.ts

@@ -42,3 +42,24 @@ export type Value = z.infer<typeof Value>;
 export type Field = z.infer<typeof Field>;
 export type EntityChange = z.infer<typeof EntityChange>;
 export type EntityChanges = z.infer<typeof EntityChanges>;
+
+export function getValuesInEntityChange(change: EntityChange) {
+  const values: Record<string, unknown> = {};
+
+  for (const field of change.fields) {
+    for (const [key, value] of Object.entries(field.newValue ?? {})) {
+      if (!value) {
+        continue;
+      }
+
+      if (key === "array") {
+        const { value: array } = value as { value: Record<string, unknown>[] };
+        values[field.name] = array.flatMap(Object.values);
+      } else {
+        values[field.name] = value;
+      }
+    }
+  }
+
+  return values;
+}