hash calc optimize

XYOracleNetwork · Jan 29, 2024 · b4d1e9a · b4d1e9a
1 parent a879b4e
commit b4d1e9a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...odules/packages/diviner/packages/forecasting/packages/abstract/src/AbstractForecasting.ts b/...odules/packages/diviner/packages/forecasting/packages/abstract/src/AbstractForecasting.ts
@@ -33,7 +33,7 @@ export abstract class AbstractForecastingDiviner<
     const stopTimestamp = query.timestamp || Date.now()
     const startTimestamp = windowSettings.windowSize ? stopTimestamp - windowSettings.windowSize : 0
     const data = await this.getPayloadsInWindow(startTimestamp, stopTimestamp)
-    const sources = (await PayloadBuilder.dataHashes(data)) ?? []
+    const sources = await PayloadBuilder.dataHashes(data)
     const values = await this.forecastingMethod(data, this.transformer)
     const response: ForecastPayload = { schema: ForecastPayloadSchema, sources, values }
     return [response]

diff --git a/...es/indexing/packages/temporal/packages/memory/src/IndexCandidateToIndexDiviner/Diviner.ts b/...es/indexing/packages/temporal/packages/memory/src/IndexCandidateToIndexDiviner/Diviner.ts
@@ -93,7 +93,7 @@ export class TemporalIndexingDivinerIndexCandidateToIndexDiviner<
             return transformers ? transformers.map((transform) => transform(payload)) : []
           })
           // Include all the sources for reference
-          const sources = Object.keys(await PayloadBuilder.toDataHashMap([bw, ...sourcePayloads]))
+          const sources = await PayloadBuilder.dataHashes([bw, ...sourcePayloads])
           // Build and return the index
           return await new PayloadBuilder<TemporalIndexingDivinerResultIndex>({ schema: TemporalIndexingDivinerResultIndexSchema })
             .fields(Object.assign({ sources }, ...indexFields))

diff --git a/packages/modules/packages/diviner/packages/jsonpath/packages/memory/src/Diviner.ts b/packages/modules/packages/diviner/packages/jsonpath/packages/memory/src/Diviner.ts
@@ -43,7 +43,7 @@ export class JsonPathDiviner<
         // Use the payload transformers to convert the fields from the source payloads to the destination fields
         const fields: PayloadFields[] = this.transforms.map((transform) => transform(payload))
         // Include all the sources for reference
-        const sources = Object.keys(await PayloadBuilder.toDataHashMap([payload]))
+        const sources = await PayloadBuilder.dataHashes([payload])
         // Build and return the index
         return await new PayloadBuilder<TOut>({ schema: this.destinationSchema }).fields(Object.assign({ sources }, ...fields)).build()
       }),