Replace 'alphavantage-sdr' with 'alphachain' adapter

Author: krebernisak

.github/workflows/release.yml

@@ -74,9 +74,9 @@ jobs:
             marketstack,
             nikkei,
             binance-dex,
-            alphavantage-sdr,
             nomics,
             1forge,
+            alphachain,
             alphavantage,
             amberdata,
             bravenewcoin,

CHANGELOG.md

@@ -6,6 +6,10 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 
 ## [Unreleased]
 
+### Changed
+
+- Replaced `alphavantage-sdr` with `alphachain` adapter
+
 ## [0.1.1] - 2020-09-18
 
 ### Added

alphachain/README.md

@@ -0,0 +1,28 @@
+# Chainlink External Adapter for AlphaChain (SDR)
+
+## Input Params
+
+- `base`, `from`, or `coin`: The symbol of the currency to query
+- `quote`, `to`, or `market`: The symbol of the currency to convert to
+
+## Output
+
+```json
+{
+  "jobRunID": "1",
+  "data": {
+    "data": {
+      "from_symbol": "ETH",
+      "last_refreshed": "2020-05-29 08:45:03 +0000 UTC",
+      "rate": 301.3654364,
+      "time_zone": "UTC",
+      "to_symbol": "SDR"
+    },
+    "jobRunID": "",
+    "result": 301.3654364,
+    "status": "200"
+  },
+  "result": 301.3654364,
+  "statusCode": 200
+}
+```

alphavantage-sdr/adapter.js alphachain/adapter.js

@@ -13,7 +13,14 @@ const customParams = {
 const createRequest = (input, callback) => {
   const validator = new Validator(callback, input, customParams)
   const jobRunID = validator.validated.id
-  const url = 'https://us-central1-alpha-chain-api.cloudfunctions.net/test-api'
+  const url = 'https://alpha-chain2.p.rapidapi.com/data-query'
+  const host = 'alpha-chain2.p.rapidapi.com'
+  const headers = {
+    'content-type': 'application/octet-stream',
+    'x-rapidapi-host': host,
+    'x-rapidapi-key': process.env.API_KEY,
+    useQueryString: true
+  }
   const base = validator.validated.data.base.toUpperCase()
   const quote = validator.validated.data.quote.toUpperCase()
 
@@ -25,17 +32,18 @@ const createRequest = (input, callback) => {
 
   const config = {
     url,
-    params
+    params,
+    headers
   }
 
   Requester.request(config, customError)
-    .then(response => {
-      response.data.result = Requester.validateResultNumber(response.data, ['result'])
+    .then((response) => {
+      response.data.result = Requester.validateResultNumber(response.data, [
+        'result'
+      ])
       callback(response.status, Requester.success(jobRunID, response))
     })
-    .catch(error => {
-      callback(500, Requester.errored(jobRunID, error))
-    })
+    .catch((error) => callback(500, Requester.errored(jobRunID, error)))
 }
 
 module.exports.createRequest = createRequest

alphavantage-sdr/index.js alphachain/index.js

@@ -1,5 +1,5 @@
 {
-  "name": "alphavantage-sdr",
+  "name": "alphachain",
   "version": "0.1.0",
   "license": "MIT",
   "main": "index.js",

alphavantage-sdr/package.json alphachain/package.json

@@ -0,0 +1,75 @@
+const { assert } = require('chai')
+const { createRequest } = require('../adapter')
+
+describe('createRequest', () => {
+  const jobID = '1'
+
+  context('successful calls', () => {
+    const requests = [
+      {
+        name: 'id not supplied',
+        testData: { data: { base: 'ETH', quote: 'XDR' } }
+      },
+      {
+        name: 'base/quote',
+        testData: { id: jobID, data: { base: 'ETH', quote: 'XDR' } }
+      },
+      {
+        name: 'from/to',
+        testData: { id: jobID, data: { from: 'ETH', to: 'XDR' } }
+      },
+      {
+        name: 'coin/market',
+        testData: { id: jobID, data: { coin: 'ETH', market: 'XDR' } }
+      }
+    ]
+
+    requests.forEach((req) => {
+      it(`${req.name}`, (done) => {
+        createRequest(req.testData, (statusCode, data) => {
+          assert.equal(statusCode, 200)
+          assert.equal(data.jobRunID, jobID)
+          assert.isNotEmpty(data.data)
+          assert.isAbove(data.result, 0)
+          assert.isAbove(data.data.result, 0)
+          done()
+        })
+      })
+    })
+  })
+
+  context('error calls', () => {
+    const requests = [
+      { name: 'empty body', testData: {} },
+      { name: 'empty data', testData: { data: {} } },
+      {
+        name: 'base not supplied',
+        testData: { id: jobID, data: { quote: 'XDR' } }
+      },
+      {
+        name: 'quote not supplied',
+        testData: { id: jobID, data: { base: 'ETH' } }
+      },
+      {
+        name: 'unknown base',
+        testData: { id: jobID, data: { base: 'not_real', quote: 'XDR' } }
+      },
+      {
+        name: 'unknown quote',
+        testData: { id: jobID, data: { base: 'ETH', quote: 'not_real' } }
+      }
+    ]
+
+    requests.forEach((req) => {
+      it(`${req.name}`, (done) => {
+        createRequest(req.testData, (statusCode, data) => {
+          assert.equal(statusCode, 500)
+          assert.equal(data.jobRunID, jobID)
+          assert.equal(data.status, 'errored')
+          assert.isNotEmpty(data.error)
+          done()
+        })
+      })
+    })
+  })
+})

alphachain/test/adapter_test.js

@@ -35,12 +35,16 @@ const createRequest = (input, callback) => {
     params
   }
   Requester.request(config, customError)
-    .then(response => {
-      response.data.result = JSON.parse(Requester.validateResultNumber(
-        response.data, ['Realtime Currency Exchange Rate', '5. Exchange Rate']))
+    .then((response) => {
+      response.data.result = JSON.parse(
+        Requester.validateResultNumber(response.data, [
+          'Realtime Currency Exchange Rate',
+          '5. Exchange Rate'
+        ])
+      )
       callback(response.status, Requester.success(jobRunID, response))
     })
-    .catch(error => {
+    .catch((error) => {
       callback(500, Requester.errored(jobRunID, error))
     })
 }

alphavantage-sdr/README.md

@@ -12,11 +12,11 @@
     "marketstack",
     "nikkei",
     "binance-dex",
-    "alphavantage-sdr",
     "nomics",
     "external-adapter",
     "example",
     "1forge",
+    "alphachain",
     "alphavantage",
     "amberdata",
     "bravenewcoin",