integrate service with coingecko

Author: facuspagnuolo

.gitignore

@@ -1,3 +1,3 @@
 node_modules
-dist
+build
 .env

package.json

@@ -19,13 +19,15 @@
     "start:worker:dev": "nodemon ./src/worker.ts"
   },
   "dependencies": {
+    "axios": "^0.21.1",
     "body-parser": "^1.19.0",
     "cors": "^2.8.5",
     "chalk": "^4.1.0",
     "decimal.js": "^10.2.1",
     "dotenv": "^8.2.0",
     "express": "^4.17.1",
     "knex": "^0.21.1",
+    "moment": "^2.29.1",
     "objection": "^2.1.3",
     "pg": "^8.0.3"
   },

src/controllers/OrganizationController.ts

@@ -26,11 +26,12 @@ export default {
     const organization = await Organization.findByAddress(request.params.address)
     if (!organization) throw HttpError.NOT_FOUND('Organization not found')
 
+    const balances = []
     const orgBalances = await OrganizationBalance.findByOrganization(organization)
-    const balances = Promise.all(orgBalances.map(async ({ assetId, price, amount, value }) => {
+    for (const { assetId, price, amount, value } of orgBalances) {
       const asset = await Asset.findById(assetId)
-      return { asset: { address: asset?.address, symbol: asset?.symbol, decimals: asset?.decimals }, price, amount, value }
-    }));
+      balances.push({ asset: { address: asset?.address, symbol: asset?.symbol, decimals: asset?.decimals }, price, amount, value })
+    }
 
     const { createdAt, address, executor, value, syncedAt } = organization
     response.status(200).send({ createdAt, address, executor, value, syncedAt, balances })

src/database/migrations/20210414202011_create_organizations_table.ts

@@ -7,7 +7,7 @@ export async function up(knex: Knex): Promise<void> {
     table.string('address').notNullable()
     table.string('executor').notNullable()
     table.dateTime('createdAt').notNullable()
-    table.string('value').notNullable()
+    table.double('value', 10).notNullable()
     table.dateTime('syncedAt')
     table.unique(['address'])
   })

src/database/migrations/20210414202254_create_assets_table.ts

@@ -6,7 +6,6 @@ export async function up(knex: Knex): Promise<void> {
     table.increments('id')
     table.string('address').notNullable()
     table.string('symbol').notNullable()
-    table.string('name').notNullable()
     table.string('decimals').notNullable()
     table.dateTime('createdAt').defaultTo(knex.fn.now()).notNullable()
     table.unique(['address'])

src/database/migrations/20210414204239_create_organization_balance_table.ts

@@ -11,8 +11,8 @@ export async function up(knex: Knex): Promise<void> {
     table.integer('organizationId').index()
     table.foreign('organizationId').references(`${Organization.tableName}.id`).onDelete('CASCADE')
     table.string('amount').notNullable()
-    table.string('price')
-    table.string('value')
+    table.double('price', 10).notNullable()
+    table.double('value', 10).notNullable()
     table.dateTime('createdAt').defaultTo(knex.fn.now()).notNullable()
     table.unique(['assetId', 'organizationId'])
   })

src/helpers/numbers.ts

@@ -1,3 +1,5 @@
 import { Decimal } from 'decimal.js'
 
 export const decimal = (x: string | number): Decimal => new Decimal(x)
+
+export const fixed = (x: Decimal): number => Number(x.toFixed(10, Decimal.ROUND_DOWN))

src/models/Coingecko.ts

@@ -0,0 +1,50 @@
+import axios from 'axios'
+import moment from 'moment'
+import { Decimal } from 'decimal.js'
+
+import { decimal } from '../helpers/numbers'
+
+const BASE_URL = 'https://api.coingecko.com/api/v3'
+
+type Coins = { [key: string]: Coin }
+
+type Coin = {
+  id: string
+  name: string
+  symbol: string
+  address: string
+}
+
+class Coingecko {
+  coins?: Coins
+
+  async getPrice(address: string, at: string): Promise<Decimal> {
+    const coins = await this.all()
+    const date = moment(at).format('DD-MM-YYYY')
+    const coinId = coins[address.toLowerCase()].id
+    const data = await this._get(`/coins/${coinId}/history?date=${date}&localization=false`)
+    const price = data?.market_data?.current_price?.usd || 0
+    return decimal(price)
+  }
+
+  async all(): Promise<Coins> {
+    if (this.coins == undefined) {
+      this.coins = {}
+      const coinsData: any[] = await this._get('coins/list?include_platform=true')
+      coinsData
+        .filter((coinData: any) => coinData?.platforms?.ethereum !== undefined)
+        .forEach(({ id, name, symbol, platforms }: any) => {
+          let address = platforms.ethereum;
+          this.coins![address.toLowerCase()] = ({ id, name, symbol, address: address.toLowerCase() })
+        })
+    }
+    return this.coins
+  }
+
+  private async _get(path: string): Promise<any> {
+    const response = await axios.get(`${BASE_URL}/${path}`);
+    return response.data
+  }
+}
+
+export default new Coingecko()

src/models/Organization.ts

@@ -20,20 +20,20 @@ export default class Organization extends BaseModel {
   id!: number
   address!: string
   executor!: string
-  value!: string
+  value!: number
   createdAt!: string
   syncedAt?: string
 
   static create({ address, executor, createdAt }: { address: string, executor: string, createdAt: string }): Promise<Organization> {
-    return this.query().insert({ address, executor, createdAt, value: '0' })
+    return this.query().insert({ address, executor, createdAt, value: 0 })
   }
 
   static async count(): Promise<number> {
     return this.query().resultSize()
   }
 
   static async totalValue(): Promise<number> {
-    const results = await this.query().select(raw('coalesce(sum(??), 0)', 'value').as('sum'))
+    const results = await this.query().sum('value')
     // @ts-ignore
     return results[0].sum
   }
@@ -46,8 +46,8 @@ export default class Organization extends BaseModel {
     return this.query().findOne({ address })
   }
 
-  async update({ value }: { value: string }): Promise<void> {
-    const syncedAt = new Date().getTime().toString()
+  async update({ value }: { value: number }): Promise<void> {
+    const syncedAt = new Date().toISOString()
     await this.$query().update({ value, syncedAt })
   }
 }

src/models/OrganizationBalance.ts

@@ -28,11 +28,11 @@ export default class OrganizationBalance extends BaseModel {
   assetId!: number
   organizationId!: number
   amount!: string
-  price!: string
-  value!: string
+  price!: number
+  value!: number
   createdAt!: string
 
-  static create({ assetId, organizationId, amount, price, value }: { assetId: number, organizationId: number, amount: string, price: string, value: string }): Promise<OrganizationBalance> {
+  static create({ assetId, organizationId, amount, price, value }: { assetId: number, organizationId: number, amount: string, price: number, value: number }): Promise<OrganizationBalance> {
     return this.query().insert({ assetId, organizationId, amount, price, value })
   }