0.5.0

Author: PaulZhemanov

package.json

@@ -1,7 +1,7 @@
 {
   "private": true,
   "name": "spark-processor",
-  "version": "1.0.0",
+  "version": "0.5.0",
   "type": "module",
   "scripts": {
     "build": "sentio build",

src/config.ts

@@ -1,5 +1,6 @@
 {
  "BTC-USDC": {
+  "name": "BTC-USDC",
   "market": "0xb1ed073b4dccbff48e2ac1b52a49454e6a2921aa54effee89eb958dc5ddbffbe",
   "baseToken": "0x38e4ca985b22625fff93205e997bfc5cc8453a953da638ad297ca60a9f2600bc",
   "baseTokenSymbol": "BTC",
@@ -11,6 +12,7 @@
   "defaultQuotePrice": 1
  },
  "ETH-USDC": {
+  "name": "ETH-USDC",
   "market": "0x2dd759eb0671e293b5e386f9b4f1cc8a1cb2c4ed1cf839e5de4f06f822d3790f",
   "baseToken": "0xf8f8b6283d7fa5b672b530cbb84fcccb4ff8dc40f8176ef4544ddb1f1952ad07",
   "baseTokenSymbol": "ETH",

src/marketsConfig.json

@@ -1,7 +1,7 @@
 import { SparkMarketProcessorTemplate } from "./types/fuel/SparkMarketProcessor.js";
 import { FuelNetwork } from "@sentio/sdk/fuel";
 import { SparkRegistryProcessor } from './types/fuel/SparkRegistryProcessor.js';
-import { MARKET_REGISTRY_ADDRESS } from './config.js';
+import { REGISTRY_ADDRESS } from './registry.js';
 import { BigDecimal, LogLevel } from "@sentio/sdk";
 import crypto from "crypto";
 import marketsConfig from './marketsConfig.json';
@@ -183,7 +183,7 @@ marketTemplate.onTimeInterval(async (block, ctx) => {
     const filteredBalances = balances.filter(balance => balance.market === ctx.contractAddress);
 
     for (const balance of filteredBalances) {
-        const marketConfig = Object.values(marketsConfig).find(market => market.market.toLowerCase() === balance.market.toLowerCase());
+        const marketConfig = Object.values(marketsConfig).find(market => market.market === balance.market);
 
         if (!marketConfig) {
             ctx.eventLogger.emit('MarketConfigNotFound', {
@@ -241,18 +241,23 @@ marketTemplate.onTimeInterval(async (block, ctx) => {
 
         await ctx.store.upsert(snapshot);
 
-        ctx.eventLogger.emit('SnapshotCreation', {
+        ctx.eventLogger.emit('Snapshot', {
             severity: LogLevel.INFO,
-            message: `Creating snapshot at ${new Date().toISOString()}`,
-            block_number: ctx.block?.id,
+            message: `Snapshot for user ${balance.user}: ${new Date().toISOString()}`,
+            timestamp: new Date().toISOString(),
+            block_date: ctx.timestamp.toString(),
+            chain_id: ctx.chainId,
+            block_number: block.height.toString(),
             user_address: balance.user,
+            pool_address: ctx.contractAddress,
+            total_value_locked_score: tvl
         });
 
     }
 }, 60 * 60);
 
 SparkRegistryProcessor.bind({
-    address: MARKET_REGISTRY_ADDRESS,
+    address: REGISTRY_ADDRESS,
     chainId: FuelNetwork.TEST_NET
 })
     .onLogMarketRegisterEvent(async (log, ctx) => {

src/processor.ts

@@ -0,0 +1 @@
+export const REGISTRY_ADDRESS = "0x0f5232e0d927f7a477baa7e6f0380c50f8b3de5c0d6ae42bb29ba8a767e5ff1a";

src/registry.ts

@@ -54,11 +54,11 @@ export class UserScoreSnapshot extends AbstractEntity  {
 
 	@Required
 	@Column("String")
-	block_date: String
+	timestamp: String
 
 	@Required
 	@Column("String")
-	timestamp: String
+	block_date: String
 
 	@Required
 	@Column("String")
@@ -95,9 +95,8 @@ const source = `type Balance @entity {
 
 type UserScoreSnapshot @entity {
   id: ID!
-  block_date: String!
   timestamp: String!
-  # timestamp_block: String!
+  block_date: String!
   chain_id: String!
   block_number: String!
   user_address: String!