Additional Data

.dockerignore

@@ -6,3 +6,6 @@ npm-debug.log
 
 # OS Files
 .DS_Store
+
+.env
+/.idea

schema-base.graphql

@@ -1,3 +1,9 @@
+type ProcessingStatus @entity {
+  id: ID!
+  timestamp: DateTime!
+  blockNumber: Int!
+}
+
 """
 Any entity which has a price associated with it should have that price go in here.
 Prices can change very frequently and we don't want those changes on the same track
@@ -72,6 +78,17 @@ type StrategyDailyYield @entity {
   apy: Float!
 }
 
+type NativeBalance @entity {
+  """
+  Format: 'account:blockNumber'
+  """
+  id: ID!
+  timestamp: DateTime! @index
+  blockNumber: Int! @index
+  account: String!
+  balance: BigInt!
+}
+
 type ERC20 @entity {
   """
   Format: 'address'
@@ -211,3 +228,12 @@ type LiquiditySource @entity {
   token: String!
 }
 
+type LiquidityDailyBalance @entity {
+  id: ID!
+  timestamp: DateTime! @index
+  blockNumber: Int! @index
+  address: String!
+  token: String!
+  balance: BigInt!
+}
+

schema.graphql

@@ -1,5 +1,11 @@
 # GENERATED, DO NOT MODIFY
 
+type ProcessingStatus @entity {
+  id: ID!
+  timestamp: DateTime!
+  blockNumber: Int!
+}
+
 """
 Any entity which has a price associated with it should have that price go in here.
 Prices can change very frequently and we don't want those changes on the same track
@@ -74,6 +80,17 @@ type StrategyDailyYield @entity {
   apy: Float!
 }
 
+type NativeBalance @entity {
+  """
+  Format: 'account:blockNumber'
+  """
+  id: ID!
+  timestamp: DateTime! @index
+  blockNumber: Int! @index
+  account: String!
+  balance: BigInt!
+}
+
 type ERC20 @entity {
   """
   Format: 'address'
@@ -213,6 +230,15 @@ type LiquiditySource @entity {
   token: String!
 }
 
+type LiquidityDailyBalance @entity {
+  id: ID!
+  timestamp: DateTime! @index
+  blockNumber: Int! @index
+  address: String!
+  token: String!
+  balance: BigInt!
+}
+
 """
 The OETH entity tracks the change in total supply of OETH over time.
 """

src/main-oeth.ts

@@ -11,6 +11,7 @@ import * as vault from './oeth/processors/vault'
 import * as validateOeth from './oeth/validators/validate-oeth'
 import { run } from './processor'
 import * as exchangeRatesPostProcessor from './shared/post-processors/exchange-rates'
+import { processStatus } from './shared/processor-templates/processor-status'
 
 export const processor = {
   stateSchema: 'oeth-processor',
@@ -25,7 +26,11 @@ export const processor = {
     strategies,
     exchangeRates,
   ],
-  postProcessors: [exchangeRatesPostProcessor, dailyStats],
+  postProcessors: [
+    exchangeRatesPostProcessor,
+    dailyStats,
+    processStatus('oeth'),
+  ],
   validators: [validateOeth],
 }
 export default processor

src/main-ogv.ts

@@ -3,11 +3,12 @@ import * as governance from './ogv/post-processors/governance'
 import * as ogv from './ogv/processors/ogv'
 import * as ogvSupply from './ogv/processors/ogv-supply'
 import { run } from './processor'
+import { processStatus } from './shared/processor-templates/processor-status'
 
 export const processor = {
   stateSchema: 'ogv-processor',
   processors: [ogvSupply, ogv],
-  postProcessors: [governance, dailyStats],
+  postProcessors: [governance, dailyStats, processStatus('ogv')],
   validators: [],
 }
 export default processor

src/main-other.ts

@@ -1,16 +1,32 @@
 import { run } from './processor'
 import * as exchangeRates from './shared/post-processors/exchange-rates'
+import * as liquidity from './shared/post-processors/liquidity'
+import { processStatus } from './shared/processor-templates/processor-status'
 import * as balancer from './shared/processors/balancer'
 import * as curve from './shared/processors/curve'
 import { erc20s } from './shared/processors/erc20s'
 import * as liquiditySources from './shared/processors/liquidity-sources'
 import * as maverick from './shared/processors/maverick'
+import * as native from './shared/processors/native'
+import * as sushiswap from './shared/processors/sushiswap'
+import * as uniswap from './shared/processors/uniswap'
+import * as validate from './shared/validators/validate-shared'
+
+sushiswap.initialize()
+uniswap.initialize()
 
 export const processor = {
   stateSchema: 'other-processor',
-  processors: [balancer, curve, maverick, ...erc20s, liquiditySources],
-  postProcessors: [exchangeRates],
-  validators: [],
+  processors: [
+    balancer,
+    curve,
+    maverick,
+    native,
+    ...erc20s(),
+    liquiditySources,
+  ],
+  postProcessors: [exchangeRates, liquidity, processStatus('other')],
+  validators: [validate],
 }
 export default processor
 

src/main-ousd.ts

@@ -4,11 +4,12 @@ import * as strategies from './ousd/processors/strategies/strategies'
 import * as validateOusd from './ousd/validators/validate-ousd'
 import { run } from './processor'
 import * as exchangeRates from './shared/post-processors/exchange-rates'
+import { processStatus } from './shared/processor-templates/processor-status'
 
 export const processor = {
   stateSchema: 'ousd-processor',
   processors: [ousd, strategies],
-  postProcessors: [exchangeRates, dailyStats],
+  postProcessors: [exchangeRates, dailyStats, processStatus('ousd')],
   validators: [validateOusd],
 }
 export default processor

src/model/generated/index.ts

@@ -1,7 +1,9 @@
+export * from "./processingStatus.model"
 export * from "./exchangeRate.model"
 export * from "./strategyBalance.model"
 export * from "./strategyYield.model"
 export * from "./strategyDailyYield.model"
+export * from "./nativeBalance.model"
 export * from "./erc20.model"
 export * from "./erc20Holder.model"
 export * from "./erc20State.model"
@@ -16,6 +18,7 @@ export * from "./maverickPool.model"
 export * from "./maverickPoolBalance.model"
 export * from "./liquiditySource.model"
 export * from "./_liquiditySourceType"
+export * from "./liquidityDailyBalance.model"
 export * from "./oeth.model"
 export * from "./oethAsset.model"
 export * from "./oethAddress.model"

src/model/generated/liquidityDailyBalance.model.ts

@@ -0,0 +1,29 @@
+import {Entity as Entity_, Column as Column_, PrimaryColumn as PrimaryColumn_, Index as Index_} from "typeorm"
+import * as marshal from "./marshal"
+
+@Entity_()
+export class LiquidityDailyBalance {
+    constructor(props?: Partial<LiquidityDailyBalance>) {
+        Object.assign(this, props)
+    }
+
+    @PrimaryColumn_()
+    id!: string
+
+    @Index_()
+    @Column_("timestamp with time zone", {nullable: false})
+    timestamp!: Date
+
+    @Index_()
+    @Column_("int4", {nullable: false})
+    blockNumber!: number
+
+    @Column_("text", {nullable: false})
+    address!: string
+
+    @Column_("text", {nullable: false})
+    token!: string
+
+    @Column_("numeric", {transformer: marshal.bigintTransformer, nullable: false})
+    balance!: bigint
+}

src/model/generated/nativeBalance.model.ts

@@ -0,0 +1,29 @@
+import {Entity as Entity_, Column as Column_, PrimaryColumn as PrimaryColumn_, Index as Index_} from "typeorm"
+import * as marshal from "./marshal"
+
+@Entity_()
+export class NativeBalance {
+    constructor(props?: Partial<NativeBalance>) {
+        Object.assign(this, props)
+    }
+
+    /**
+     * Format: 'account:blockNumber'
+     */
+    @PrimaryColumn_()
+    id!: string
+
+    @Index_()
+    @Column_("timestamp with time zone", {nullable: false})
+    timestamp!: Date
+
+    @Index_()
+    @Column_("int4", {nullable: false})
+    blockNumber!: number
+
+    @Column_("text", {nullable: false})
+    account!: string
+
+    @Column_("numeric", {transformer: marshal.bigintTransformer, nullable: false})
+    balance!: bigint
+}

src/model/generated/processingStatus.model.ts

@@ -0,0 +1,17 @@
+import {Entity as Entity_, Column as Column_, PrimaryColumn as PrimaryColumn_} from "typeorm"
+
+@Entity_()
+export class ProcessingStatus {
+    constructor(props?: Partial<ProcessingStatus>) {
+        Object.assign(this, props)
+    }
+
+    @PrimaryColumn_()
+    id!: string
+
+    @Column_("timestamp with time zone", {nullable: false})
+    timestamp!: Date
+
+    @Column_("int4", {nullable: false})
+    blockNumber!: number
+}

src/oeth/processors/strategies/strategies.ts

@@ -20,14 +20,15 @@ import {
   RETH_ADDRESS,
   STETH_ADDRESS,
   WETH_ADDRESS,
+  addresses,
 } from '../../../utils/addresses'
 
 export const oethStrategies: readonly IStrategyData[] = [
   {
     from: 17249899,
     name: 'OETH Convex ETH+OETH (AMO)',
     contractName: 'ConvexEthMetaStrategy',
-    address: '0x1827f9ea98e0bf96550b2fc20f7233277fcd7e63',
+    address: addresses.strategies.oeth.ConvexEthMetaStrategy,
     oTokenAddress: OETH_ADDRESS,
     kind: 'CurveAMO',
     curvePoolInfo: {
@@ -45,7 +46,7 @@ export const oethStrategies: readonly IStrategyData[] = [
     from: 17067232,
     name: 'OETH Frax Staking',
     contractName: 'FraxETHStrategy',
-    address: '0x3ff8654d633d4ea0fae24c52aec73b4a20d0d0e5',
+    address: addresses.strategies.oeth.FraxETHStrategy,
     oTokenAddress: OETH_ADDRESS,
     kind: 'Generic',
     base: { address: currencies.ETH, decimals: 18 },
@@ -67,7 +68,7 @@ export const oethStrategies: readonly IStrategyData[] = [
     from: 18156225,
     name: 'OETH Aura rETH/WETH',
     contractName: 'BalancerMetaPoolStrategy',
-    address: '0x49109629ac1deb03f2e9b2fe2ac4a623e0e7dfdc',
+    address: addresses.strategies.oeth.BalancerMetaPoolStrategy,
     oTokenAddress: OETH_ADDRESS,
     kind: 'BalancerMetaStablePool',
     base: { address: currencies.ETH, decimals: 18 },