Add SDR adapter for AlphaVantage

alphavantage-sdr/README.md

@@ -0,0 +1,28 @@
+# Chainlink External Adapter for AlphaVantage (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

@@ -0,0 +1,41 @@
+const { Requester, Validator } = require('@chainlink/external-adapter')
+
+const customError = (data) => {
+  if (data.status !== '200') return true
+  return false
+}
+
+const customParams = {
+  base: ['base', 'from', 'coin'],
+  quote: ['quote', 'to', 'market']
+}
+
+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 base = validator.validated.data.base.toUpperCase()
+  const quote = validator.validated.data.quote.toUpperCase()
+
+  const params = {
+    from_symbol: base,
+    to_symbol: quote,
+    chainlink_node: true
+  }
+
+  const config = {
+    url,
+    params
+  }
+
+  Requester.request(config, customError)
+    .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))
+    })
+}
+
+module.exports.createRequest = createRequest

alphavantage-sdr/index.js

@@ -0,0 +1,10 @@
+const bootstrap = require('@chainlink/ea-bootstrap')
+const { createRequest } = require('./adapter')
+
+module.exports = {
+  server: bootstrap.server.init(createRequest),
+
+  gcpservice: bootstrap.serverless.initGcpService(createRequest),
+  handler: bootstrap.serverless.initHandler(createRequest),
+  handlerv2: bootstrap.serverless.initHandlerV2(createRequest)
+}

alphavantage-sdr/package.json

@@ -0,0 +1,14 @@
+{
+  "name": "alphavantage-sdr",
+  "version": "0.1.0",
+  "license": "MIT",
+  "main": "index.js",
+  "scripts": {
+    "server": "node -e 'require(\"./index.js\").server()'",
+    "test": "yarn _mocha --timeout 0"
+  },
+  "dependencies": {
+    "@chainlink/ea-bootstrap": "0.0.1",
+    "@chainlink/external-adapter": "^0.2.3"
+  }
+}

alphavantage-sdr/test/adapter_test.js

@@ -0,0 +1,51 @@
+const assert = require('chai').assert
+const createRequest = require('../adapter').createRequest
+
+describe('createRequest', () => {
+  const jobID = '1'
+
+  context('successful calls', () => {
+    const requests = [
+      { name: 'id not supplied', testData: { data: { base: 'ETH', quote: 'SDR' } } },
+      { name: 'base/quote', testData: { id: jobID, data: { base: 'ETH', quote: 'SDR' } } },
+      { name: 'from/to', testData: { id: jobID, data: { from: 'ETH', to: 'SDR' } } },
+      { name: 'coin/market', testData: { id: jobID, data: { coin: 'ETH', market: 'SDR' } } }
+    ]
+
+    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: 'SDR' } } },
+      { name: 'quote not supplied', testData: { id: jobID, data: { base: 'ETH' } } },
+      { name: 'unknown base', testData: { id: jobID, data: { base: 'not_real', quote: 'SDR' } } },
+      { 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()
+        })
+      })
+    })
+  })
+})

package.json

@@ -4,6 +4,7 @@
   "license": "MIT",
   "private": true,
   "workspaces": [
+    "alphavantage-sdr",
     "nomics",
     "external-adapter",
     "example",