import { isObject, doRequest, getRequestOptions } from './utils'; export default class { constructor (host, auth, headers) { this.host = host; this.auth = auth; this.headers = headers; } getRetiring (options) { const operationSettings = { "requiresBody": false, "queryParams": [ { "name": "block_number_from", "nameCamelCase": "blockNumberFrom" }, { "name": "limit", "nameCamelCase": "limit" } ], "isApplicationJson": false, "isFormUrlEncoded": false, "method": "GET" }; return getRequestOptions(operationSettings, options) .then((opts) => { const uri = `${this.host}/pool_updates/retiring`; const auth = opts.auth || this.auth; const headers = this.headers || {}; // Layer in some options local to this class const requestOpts = Object.assign({ headers }, opts, { auth, uri }); return doRequest(requestOpts).then(function (serverResponse) { switch (serverResponse.statusCode) { case 200: if (requestOpts.json) { return Promise.resolve(serverResponse.body); } else { return Promise.resolve(JSON.parse(serverResponse.body)); } case 404: return Promise.reject({ status: serverResponse.statusCode, data: serverResponse.body }); default: return Promise.reject(new Error('Unknown response code: ' + serverResponse.statusCode)); } }); }); } getByPoolId (poolId, options) { const operationSettings = { "requiresBody": false, "queryParams": [ { "name": "block_number_from", "nameCamelCase": "blockNumberFrom" }, { "name": "limit", "nameCamelCase": "limit" } ], "isApplicationJson": false, "isFormUrlEncoded": false, "method": "GET" }; return getRequestOptions(operationSettings, options) .then((opts) => { const uri = `${this.host}/pool_updates/${poolId}`; const auth = opts.auth || this.auth; const headers = this.headers || {}; // Layer in some options local to this class const requestOpts = Object.assign({ headers }, opts, { auth, uri }); return doRequest(requestOpts).then(function (serverResponse) { switch (serverResponse.statusCode) { case 200: if (requestOpts.json) { return Promise.resolve(serverResponse.body); } else { return Promise.resolve(JSON.parse(serverResponse.body)); } case 404: return Promise.reject({ status: serverResponse.statusCode, data: serverResponse.body }); default: return Promise.reject(new Error('Unknown response code: ' + serverResponse.statusCode)); } }); }); } get (options) { const operationSettings = { "requiresBody": false, "queryParams": [ { "name": "block_number_from", "nameCamelCase": "blockNumberFrom" }, { "name": "limit", "nameCamelCase": "limit" } ], "isApplicationJson": false, "isFormUrlEncoded": false, "method": "GET" }; return getRequestOptions(operationSettings, options) .then((opts) => { const uri = `${this.host}/pool_updates`; const auth = opts.auth || this.auth; const headers = this.headers || {}; // Layer in some options local to this class const requestOpts = Object.assign({ headers }, opts, { auth, uri }); return doRequest(requestOpts).then(function (serverResponse) { switch (serverResponse.statusCode) { case 200: if (requestOpts.json) { return Promise.resolve(serverResponse.body); } else { return Promise.resolve(JSON.parse(serverResponse.body)); } case 404: return Promise.reject({ status: serverResponse.statusCode, data: serverResponse.body }); default: return Promise.reject(new Error('Unknown response code: ' + serverResponse.statusCode)); } }); }); } }