Merged renvm-volumes and renvm subgraphs

Author: 0x31

abis/DarknodeRegistry.json

@@ -4,13 +4,13 @@
   "scripts": {
     "codegen": "graph codegen",
     "build": "graph build",
-    "deploy": "graph deploy --node https://api.thegraph.com/deploy/ --ipfs https://api.thegraph.com/ipfs/ amcassetti/renvm",
-    "create-local": "graph create --node http://localhost:8020/ amcassetti/renvm",
-    "remove-local": "graph remove --node http://localhost:8020/ amcassetti/renvm",
-    "deploy-local": "graph deploy --node http://localhost:8020/ --ipfs http://localhost:5001 amcassetti/renvm"
+    "deploy": "graph deploy --node https://api.thegraph.com/deploy/ --ipfs https://api.thegraph.com/ipfs/ noiach/renvm-volume",
+    "create-local": "graph create --node http://localhost:8020/ noiach/renvm-volume",
+    "remove-local": "graph remove --node http://localhost:8020/ noiach/renvm-volume",
+    "deploy-local": "graph deploy --node http://localhost:8020/ --ipfs http://localhost:5001 noiach/renvm-volume"
   },
   "dependencies": {
-    "@graphprotocol/graph-cli": "0.17.1",
-    "@graphprotocol/graph-ts": "0.17.0"
+    "@graphprotocol/graph-cli": "0.18.0",
+    "@graphprotocol/graph-ts": "0.18.1"
   }
-}
+}

abis/Contract.json abis/Gateway.json

@@ -1,27 +1,113 @@
+enum TransactionType {
+  mint
+  burn
+}
+
 type Transaction @entity {
   id: ID!
-  _createdTimestamp: BigInt
-  _asset: String!
-  _type: String!
-  _amount: BigInt!
-  _feeRate: BigInt!
-  _adapterAddress: Bytes
-  _destination: Bytes
+  createdTimestamp: BigInt
+  asset: String!
+  type: TransactionType!
+  amount: BigInt!
+  feeRate: BigInt!
+  adapterAddress: Bytes
+  destination: Bytes
+  integrator: Bytes
 }
 
 type Darknode @entity {
   id: ID!
-  _operator: Bytes!
-  _isRegistered: Boolean!
-  _registeredTimestamp: BigInt
-  _deregisteredTimestamp: BigInt
-  _startBlock: BigInt
-  _endBlock: BigInt
+  operator: Bytes!
+  isRegistered: Boolean!
+  registeredTimestamp: BigInt
+  deregisteredTimestamp: BigInt
+  startBlock: BigInt
+  endBlock: BigInt
 }
 
 type Epoch @entity {
   id: ID!
-  _createdTimestamp: BigInt
-  _blockNumber: BigInt!
-  _nextEpochBlockNumber: BigInt!
+  createdTimestamp: BigInt
+  blockNumber: BigInt!
+  nextEpochBlockNumber: BigInt!
+}
+
+# Data accumulated and condensed into day stats
+type Integrator @entity {
+    id: ID!
+
+    contractAddress: Bytes!
+
+    totalTxCountBTC: BigInt!
+    totalLockedBTC: BigInt!
+    totalVolumeBTC: BigInt!
+
+    totalTxCountZEC: BigInt!
+    totalLockedZEC: BigInt!
+    totalVolumeZEC: BigInt!
+
+    totalTxCountBCH: BigInt!
+    totalLockedBCH: BigInt!
+    totalVolumeBCH: BigInt!
+}
+
+# Data accumulated and condensed into day stats
+type RenVM @entity {
+    id: ID! # fixed to '1'
+
+    totalTxCountBTC: BigInt!
+    totalLockedBTC: BigInt!
+    totalVolumeBTC: BigInt!
+
+    totalTxCountZEC: BigInt!
+    totalLockedZEC: BigInt!
+    totalVolumeZEC: BigInt!
+
+    totalTxCountBCH: BigInt!
+    totalLockedBCH: BigInt!
+    totalVolumeBCH: BigInt!
+}
+
+enum PeriodType {
+    HOUR
+    DAY
+    WEEK
+    MONTH
+    YEAR
+}
+
+# Data accumulated and condensed into day stats
+type PeriodData @entity {
+    id: ID! # timestamp rounded to current day by dividing by 86400 - should only be one per day
+    date: Int!
+
+    type: PeriodType!
+
+    # total
+
+    totalTxCountBTC: BigInt!
+    totalLockedBTC: BigInt!
+    totalVolumeBTC: BigInt!
+
+    totalTxCountZEC: BigInt!
+    totalLockedZEC: BigInt!
+    totalVolumeZEC: BigInt!
+
+    totalTxCountBCH: BigInt!
+    totalLockedBCH: BigInt!
+    totalVolumeBCH: BigInt!
+
+    # period
+
+    periodTxCountBTC: BigInt!
+    periodLockedBTC: BigInt!
+    periodVolumeBTC: BigInt!
+
+    periodTxCountZEC: BigInt!
+    periodLockedZEC: BigInt!
+    periodVolumeZEC: BigInt!
+
+    periodTxCountBCH: BigInt!
+    periodLockedBCH: BigInt!
+    periodVolumeBCH: BigInt!
 }

package.json

@@ -0,0 +1,101 @@
+// tslint:disable: only-arrow-functions prefer-for-of
+
+import { BigInt } from "@graphprotocol/graph-ts";
+
+import { Gateway, LogBurn, LogMint } from "../generated/BCHGateway/Gateway";
+import { Transaction } from "../generated/schema";
+import { getDayData, getIntegrator, getRenVM, I32, oneBigInt } from "./common";
+
+const periods: string[] = ["HOUR", "DAY", "WEEK", "MONTH", "YEAR"];
+
+export function handleLogMint(event: LogMint): void {
+
+    const txid = event.transaction.hash.toHex() + "-" + event.logIndex.toString();
+    const tx = new Transaction(txid);
+
+    const contract = Gateway.bind(event.address);
+    const to = event.transaction.to;
+
+    tx.createdTimestamp = event.block.timestamp;
+    tx.asset = "BCH";
+    tx.amount = event.params._amount;
+    tx.feeRate = BigInt.fromI32(contract.mintFee());
+    tx.type = "mint";
+    tx.adapterAddress = to;
+    tx.save();
+
+    // Nov 2 2018 is 1541116800 for dayStartTimestamp and 17837 for dayID
+    // Nov 3 2018 would be 1541116800 + 86400 and 17838. And so on, for each exchange
+    const timestamp: I32 = event.block.timestamp.toI32();
+
+    // Update Global Values
+    const renVM = getRenVM();
+    renVM.totalTxCountBCH = renVM.totalTxCountBCH.plus(oneBigInt());
+    renVM.totalVolumeBCH = renVM.totalVolumeBCH.plus(tx.amount);
+    renVM.totalLockedBCH = renVM.totalLockedBCH.plus(tx.amount);
+    renVM.save();
+
+    const integrator = getIntegrator(tx.adapterAddress);
+    integrator.totalTxCountBCH = integrator.totalTxCountBCH.plus(oneBigInt());
+    integrator.totalVolumeBCH = integrator.totalVolumeBCH.plus(tx.amount);
+    integrator.totalLockedBCH = integrator.totalLockedBCH.plus(tx.amount);
+    integrator.save();
+
+    for (let i = 0; i < periods.length; i++) {
+        const dayData = getDayData(timestamp, periods[i]);
+
+        // save info
+        dayData.periodTxCountBCH = dayData.periodTxCountBCH.plus(oneBigInt());
+        dayData.periodVolumeBCH = dayData.periodVolumeBCH.plus(tx.amount);
+        dayData.periodLockedBCH = dayData.periodLockedBCH.plus(tx.amount);
+
+        dayData.totalTxCountBCH = renVM.totalTxCountBCH;
+        dayData.totalVolumeBCH = renVM.totalVolumeBCH;
+        dayData.totalLockedBCH = renVM.totalLockedBCH;
+
+        dayData.save();
+    }
+}
+
+export function handleLogBurn(event: LogBurn): void {
+    const txid = event.transaction.hash.toHex() + "-" + event.logIndex.toString();
+    const tx = new Transaction(txid);
+
+    const contract = Gateway.bind(event.address);
+    const to = event.transaction.to;
+
+    tx.createdTimestamp = event.block.timestamp;
+    tx.asset = "RenBCH";
+    tx.amount = event.params._amount;
+    tx.feeRate = BigInt.fromI32(contract.burnFee());
+    tx.type = "burn";
+    tx.adapterAddress = to;
+    tx.save();
+
+    // Nov 2 2018 is 1541116800 for dayStartTimestamp and 17837 for dayID
+    // Nov 3 2018 would be 1541116800 + 86400 and 17838. And so on, for each exchange
+    const timestamp: I32 = event.block.timestamp.toI32();
+
+    // Update Global Values
+    const renVM = getRenVM();
+    renVM.totalTxCountBCH = renVM.totalTxCountBCH.plus(oneBigInt());
+    renVM.totalVolumeBCH = renVM.totalVolumeBCH.plus(tx.amount);
+    renVM.totalLockedBCH = renVM.totalLockedBCH.minus(tx.amount);
+    renVM.save();
+
+    for (let i = 0; i < periods.length; i++) {
+        const dayData = getDayData(timestamp, periods[i]);
+
+        // save info
+        dayData.periodTxCountBCH = dayData.periodTxCountBCH.plus(oneBigInt());
+        dayData.periodVolumeBCH = dayData.periodVolumeBCH.plus(tx.amount);
+        dayData.periodLockedBCH = dayData.periodLockedBCH.minus(tx.amount);
+
+        dayData.totalTxCountBCH = renVM.totalTxCountBCH;
+        dayData.totalVolumeBCH = renVM.totalVolumeBCH;
+        dayData.totalLockedBCH = renVM.totalLockedBCH;
+
+        dayData.save();
+    }
+
+}