Feature/df rewards (#531)

* bump contracts * oceanjs

* add DFRewards

Author: alexcos20

.github/workflows/tests.yml

@@ -52,7 +52,7 @@ jobs:
         run: |
           bash -x start_ocean.sh --with-thegraph --skip-subgraph-deploy --no-dashboard 2>&1 > start_ocean.log &
         env:
-          CONTRACTS_VERSION: v1.1.3
+          CONTRACTS_VERSION: v1.1.4
 
       - run: npm ci
 

package-lock.json

@@ -28,6 +28,7 @@
     "test-fixed": "TS_NODE_PROJECT='test/integration/tsconfig.json' mocha --config=test/integration/.mocharc.json --node-env=test --exit 'test/integration/FixedRateExchange.test.ts'",
     "test-users": "TS_NODE_PROJECT='test/integration/tsconfig.json' mocha --config=test/integration/.mocharc.json --node-env=test --exit 'test/integration/users.test.ts'",
     "test-ve": "TS_NODE_PROJECT='test/integration/tsconfig.json' mocha --config=test/integration/.mocharc.json --node-env=test --exit 'test/integration/VeOcean.test.ts'",
+    "test-df": "TS_NODE_PROJECT='test/integration/tsconfig.json' mocha --config=test/integration/.mocharc.json --node-env=test --exit 'test/integration/DFRewards.test.ts'",
     "lint": "eslint --ignore-path .gitignore --ext .js --ext .ts --ext .tsx .",
     "lint:fix": "eslint --ignore-path .gitignore --ext .js,.ts,.tsx . --fix",
     "format": "prettier --ignore-path .gitignore './**/*.{css,yml,js,ts,tsx,json,yaml}' --write",
@@ -65,8 +66,8 @@
     "typescript": "^4.8.3"
   },
   "dependencies": {
-    "@oceanprotocol/contracts": "^1.1.3",
-    "@oceanprotocol/lib": "^2.0.0",
+    "@oceanprotocol/contracts": "^1.1.4",
+    "@oceanprotocol/lib": "^2.0.2",
     "cross-fetch": "^3.1.4"
   },
   "repository": {

package.json

@@ -466,4 +466,40 @@ type VeDeposit @entity {
   timestamp: BigInt!
   block: Int!
   tx: String!
+}
+
+
+enum DFHistoryType {
+  Allocated,
+  Claimed
+}
+
+type DFAvailableClaim @entity {
+  "id = {userId}-{tokenId}"
+  id: ID!
+  receiver: DFReward!
+  amount: BigDecimal!
+  token: Token!
+}
+
+
+type DFHistory @entity {
+  "id = {user-id}-{txId}-{eventId}"
+  id: ID!
+  receiver: DFReward!
+  amount: BigDecimal!
+  token: Token!
+  type: DFHistoryType!
+  timestamp: BigInt!
+  block: Int!
+  tx: String!
+}
+
+
+type DFReward @entity {
+  "id = {user address}"
+  id: ID!
+  receiver: User!
+  availableClaims: [DFAvailableClaim!] @derivedFrom(field: "receiver")
+  history: [DFHistory!] @derivedFrom(field: "receiver")
 }

schema.graphql

@@ -22,6 +22,7 @@ async function replaceContractAddresses() {
     let subgraph = fs.readFileSync('./subgraph.template.yaml', 'utf8')
     const subgraphVe = fs.readFileSync('./subgraph_ve.template.yaml', 'utf8')
     if (addresses[network].veOCEAN) {
+      console.log('\t Adding veOCEAN')
       // fix identation , due to vs auto format (subgraph_ve.template is moved to left)
       const lines = subgraphVe.split('\n')
       for (let line = 0; line < lines.length; line++) {

scripts/generatenetworkssubgraphs.js

@@ -0,0 +1,65 @@
+import { BigInt } from '@graphprotocol/graph-ts'
+import { Allocated, Claimed } from '../@types/DFRewards/DFRewards'
+import { DFHistory } from '../@types/schema'
+import { weiToDecimal } from './utils/generic'
+import { getToken } from './utils/tokenUtils'
+import { getDFReward, getDFAvailableClaim } from './utils/dfUtils'
+
+export function handleAllocated(event: Allocated): void {
+  // loop all allocations
+  const token = getToken(event.params.tokenAddress, false)
+  for (let i = 0; i < event.params.tos.length; i++) {
+    const reward = getDFReward(event.params.tos[i])
+    const history = new DFHistory(
+      event.params.tos[i].toHexString() +
+        '-' +
+        event.transaction.hash.toHex() +
+        '-' +
+        event.logIndex.toString()
+    )
+    history.amount = weiToDecimal(
+      event.params.values[i].toBigDecimal(),
+      BigInt.fromI32(token.decimals).toI32()
+    )
+    history.receiver = reward.id
+    history.token = token.id
+    history.type = 'Allocated'
+    history.timestamp = event.block.timestamp
+    history.tx = event.transaction.hash.toHex()
+    history.block = event.block.number.toI32()
+    history.save()
+
+    // update available claims
+    const claim = getDFAvailableClaim(
+      event.params.tos[i],
+      event.params.tokenAddress
+    )
+    claim.amount = claim.amount.plus(history.amount)
+    claim.save()
+  }
+}
+
+export function handleClaimed(event: Claimed): void {
+  // loop all allocations
+  const token = getToken(event.params.tokenAddress, false)
+  const reward = getDFReward(event.params.to)
+  const history = new DFHistory(
+    event.transaction.hash.toHex() + '-' + event.logIndex.toString()
+  )
+  history.amount = weiToDecimal(
+    event.params.value.toBigDecimal(),
+    BigInt.fromI32(token.decimals).toI32()
+  )
+  history.receiver = reward.id
+  history.token = token.id
+  history.type = 'Claimed'
+  history.timestamp = event.block.timestamp
+  history.tx = event.transaction.hash.toHex()
+  history.block = event.block.number.toI32()
+  history.save()
+
+  // update available claims
+  const claim = getDFAvailableClaim(event.params.to, event.params.tokenAddress)
+  claim.amount = claim.amount.minus(history.amount)
+  claim.save()
+}

src/mappings/dfRewards.ts

@@ -0,0 +1,34 @@
+import { Address, BigDecimal } from '@graphprotocol/graph-ts'
+import { DFAvailableClaim, DFReward } from '../../@types/schema'
+import { getUser } from './userUtils'
+
+export function createDFReward(address: Address): DFReward {
+  const dfRewards = new DFReward(address.toHexString())
+  const user = getUser(address.toHexString())
+  dfRewards.receiver = user.id
+  dfRewards.save()
+  return dfRewards
+}
+
+export function getDFReward(address: Address): DFReward {
+  let dfRewards = DFReward.load(address.toHexString())
+  if (dfRewards === null) {
+    dfRewards = createDFReward(address)
+  }
+  return dfRewards
+}
+
+export function getDFAvailableClaim(
+  user: Address,
+  token: Address
+): DFAvailableClaim {
+  const id = user.toHexString() + '-' + token.toHexString()
+  let dfClaim = DFAvailableClaim.load(id)
+  if (dfClaim == null) {
+    dfClaim = new DFAvailableClaim(id)
+    dfClaim.receiver = user.toHexString()
+    dfClaim.amount = BigDecimal.zero()
+    dfClaim.token = token.toHexString()
+  }
+  return dfClaim
+}

src/mappings/utils/dfUtils.ts

@@ -66,3 +66,26 @@
     eventHandlers:
       - event: DelegateBoost(indexed address,indexed address,indexed uint256,uint256,uint256,uint256)
         handler: handleDelegation
+
+- name: DFRewards
+  kind: ethereum/contract
+  network: __NETWORK__
+  source:
+    abi: DFRewards
+    address: __DFREWARDSADDRESS__
+    startBlock: __STARTBLOCK__
+  mapping:
+    kind: ethereum/events
+    apiVersion: 0.0.6
+    language: wasm/assemblyscript
+    file: ./src/mappings/dfRewards.ts
+    entities:
+      - DFRewards
+    abis:
+      - name: DFRewards
+        file: ./node_modules/@oceanprotocol/contracts/artifacts/contracts/df/DFRewards.sol/DFRewards.json
+    eventHandlers:
+      - event: Allocated(address[],uint256[],address)
+        handler: handleAllocated
+      - event: Claimed(address,uint256,address)
+        handler: handleClaimed