index.js

/* eslint-env node */
'use strict';

var axios = require('axios');

const BASE_URLS = {
  NA: 'https://api.amazonalexa.com',
  EU: 'https://api.eu.amazonalexa.com',
  FE: 'https://api.fe.amazonalexa.com'
};
const DEFAULT_GEO_REGION = 'NA';

const VERSION_0 = 'v0';
const VERSION_1 = 'v1';
const SUPPORTED_VERSIONS = [VERSION_0, VERSION_1];
const DEFAULT_VERSION = SUPPORTED_VERSIONS[SUPPORTED_VERSIONS.length - 1];

function alexaSMAPI(params) {
  params = params !== undefined ? params : {};
  const version = SUPPORTED_VERSIONS.includes(params.version) ? params.version : DEFAULT_VERSION;
  var smapi = { BASE_URLS, version };

  smapi.rest = {
    client: axios.create({
      baseURL: BASE_URLS[params.region in BASE_URLS ? params.region : DEFAULT_GEO_REGION],
      headers: {
        'Content-Type': 'application/json',
        'Accept': 'application/json'
      }
    }),
    head: function(url) {
      return this.client.head(url)
        .then(response => ({status: response.status, location: response.headers.location, etag: response.headers.etag}))
        .catch(response => Promise.reject(response.response));
    },
    get: function(url, parameters) {
      return this.client.get(url, { params: parameters !== undefined ? parameters : {} })
        .then(response => Object.assign({}, {status: response.status}, response.data))
        .catch(response => Promise.reject(response.response));
    },
    post: function(url, parameters) {
      return this.client.post(url, parameters !== undefined ? parameters : {})
        .then(response => Object.assign({}, {status: response.status, location: response.headers.location, etag: response.headers.etag}, response.data))
        .catch(response => Promise.reject(response.response));
    },
    put: function(url, parameters) {
      return this.client.put(url, parameters !== undefined ? parameters : {})
        .then(response => ({status: response.status, location: response.headers.location, etag: response.headers.etag}))
        .catch(response => Promise.reject(response.response));
    },
    delete: function(url) {
      return this.client.delete(url)
        .then(response => Object.assign({}, {status: response.status}, response.data))
        .catch(response => Promise.reject(response.response));
    }
  };

  smapi.refreshToken = (token) => {
    if (typeof token !== 'string' || token.length === 0)
      throw new Error('Invalid token specified!');
    else
      smapi.rest.client.defaults.headers.common['Authorization'] = token;
  };

  smapi.setBaseUrl = (url) => {
    if (typeof url !== 'string' || url.length === 0)
      throw new Error('Invalid base url specified!');
    else
      smapi.rest.client.defaults.baseURL = url;
  };

  smapi.tokens = {
    refresh: (params) => {
      return axios({
        baseURL: 'https://api.amazon.com',
        url: '/auth/o2/token',
        method: 'post',
        headers: {
          'Content-Type': 'application/json',
          'Accept': 'application/json'
        },
        data: {
          grant_type: 'refresh_token',
          refresh_token: params.refreshToken,
          client_id: params.clientId,
          client_secret: params.clientSecret,
        }
      })
        .then(response => {
          smapi.refreshToken(response.data.access_token);
          return response.data; // could do some fancy work to "auto-refresh" token based on timestamp
        })
        .catch(response => Promise.reject(response.response));
    }
  };

  smapi.skills = {
    getManifest: (skillId, stage) => {
      const url = {
        v0: `/v0/skills/${skillId}`,
        v1: `/v1/skills/${skillId}/stages/${stage}/manifest`
      };
      return smapi.rest.get(url[smapi.version]);
    },
    create: (vendorId, skillManifest) => {
      if (smapi.version === VERSION_0) {
        return smapi.rest.post('/v0/skills', { vendorId, skillManifest });
      } else if (smapi.version === VERSION_1) {
        return smapi.rest.post('/v1/skills', { vendorId, manifest: skillManifest });
      }
    },
    update: (skillId, stage, skillManifest) => {
      if (smapi.version === VERSION_0) {
        skillManifest = stage;
        return smapi.rest.put(`/v0/skills/${skillId}`, { skillManifest });
      } else if (smapi.version === VERSION_1) {
        return smapi.rest.put(`/v1/skills/${skillId}/stages/${stage}/manifest`, { manifest: skillManifest });
      }
    },
    status: skillId => smapi.rest.get(`/${smapi.version}/skills/${skillId}/status`),
    list: (vendorId, maxResults, nextToken) => smapi.rest.get(`/${smapi.version}/skills`, { vendorId, maxResults, nextToken }),
    delete: skillId => smapi.rest.delete(`/${smapi.version}/skills/${skillId}`)
  };

  smapi.interactionModel = {
    get: (skillId, stage, locale) => {
      if (smapi.version === VERSION_0) locale = stage;
      const url = {
        v0: `/v0/skills/${skillId}/interactionModel/locales/${locale}`,
        v1: `/v1/skills/${skillId}/stages/${stage}/interactionModel/locales/${locale}`
      };
      return smapi.rest.get(url[smapi.version]);
    },
    getEtag: (skillId, stage, locale) => {
      if (smapi.version === VERSION_0) locale = stage;
      const url = {
        v0: `/v0/skills/${skillId}/interactionModel/locales/${locale}`,
        v1: `/v1/skills/${skillId}/stages/${stage}/interactionModel/locales/${locale}`
      };
      return smapi.rest.head(url[smapi.version]);
    },
    update: (skillId, stage, locale, interactionModel) => {
      if (smapi.version === VERSION_0) {
        interactionModel = locale;
        locale = stage;
        return smapi.rest.post(`/v0/skills/${skillId}/interactionModel/locales/${locale}`, { interactionModel });
      } else if (smapi.version === VERSION_1)
        return smapi.rest.put(`/v1/skills/${skillId}/stages/${stage}/interactionModel/locales/${locale}`, { interactionModel });
    },
    getStatus: (skillId, locale) => {
      const url = {
        v0: `/v0/skills/${skillId}/interactionModel/locales/${locale}/status`,
        v1: `/v1/skills/${skillId}/status?resource=interactionModel`
      };
      return smapi.rest.get(url[smapi.version]);
    }
  };

  smapi.accountLinking = {
    update: (skillId, stage, accountLinkingRequest) => {
      if (smapi.version === VERSION_0) accountLinkingRequest = stage;
      const url = {
        v0: `/v0/skills/${skillId}/accountLinkingClient`,
        v1: `/v1/skills/${skillId}/stages/${stage}/accountLinkingClient`
      };
      return smapi.rest.put(url[smapi.version], { accountLinkingRequest });
    },
    readInfo: (skillId, stage) => {
      const url = {
        v0: `/v0/skills/${skillId}/accountLinkingClient`,
        v1: `/v1/skills/${skillId}/stages/${stage}/accountLinkingClient`
      };
      return smapi.rest.get(url[smapi.version]);
    },
    delete: (skillId, stage) => smapi.rest.delete(`/v1/skills/${skillId}/stages/${stage}/accountLinkingClient`),
  };

  smapi.vendors = {
    list: () => smapi.rest.get(`/${smapi.version}/vendors`)
  };

  smapi.skillEnablement = {
    enable: (skillId, stage) => smapi.rest.put(`/v1/skills/${skillId}/stages/${stage}/enablement`),
    status: (skillId, stage) => smapi.rest.get(`/v1/skills/${skillId}/stages/${stage}/enablement`),
    disable: (skillId, stage) => smapi.rest.delete(`/v1/skills/${skillId}/stages/${stage}/enablement`)
  };

  smapi.skillCertification = {
    submit: skillId => smapi.rest.post(`/${smapi.version}/skills/${skillId}/submit`),
    status: (vendorId, skillId) => smapi.rest.get('/v1/skills', { vendorId, skillId }), // Trial and error as it is not properly documented at https://developer.amazon.com/docs/smapi/skill-certification-operations.html
    withdraw: (skillId, reason, message) => smapi.rest.post(`/${smapi.version}/skills/${skillId}/withdraw`, { reason, message })
  };

  smapi.skillTesting = {
    validate: (skillId, stage, locales) => smapi.rest.post(`/v1/skills/${skillId}/stages/${stage}/validations`, { locales }),
    validationStatus: (skillId, stage, validationId) => smapi.rest.get(`/v1/skills/${skillId}/stages/${stage}/validations/${validationId}`),
    invoke: (skillId, endpointRegion, skillRequest) => smapi.rest.post(`/${smapi.version}/skills/${skillId}/invocations`, { endpointRegion, skillRequest }),
    simulate: (skillId, content, locale) => smapi.rest.post(`/${smapi.version}/skills/${skillId}/simulations`, { input: { content }, device: { locale } }),
    simulationStatus: (skillId, requestId) => smapi.rest.get(`/${smapi.version}/skills/${skillId}/simulations/${requestId}`)
  };

  smapi.intentRequests = {
    list: (params) => {
      const skillId = params.skillId;
      delete params.skillId;
      return smapi.rest.get(`/v1/skills/${skillId}/history/intentRequests`, params);
    }
  };

  smapi.custom = {
    head: url => smapi.rest.head(url),
    get: (url, parameters) => smapi.rest.get(url, parameters),
    post: (url, parameters) => smapi.rest.post(url, parameters),
    put: (url, parameters) => smapi.rest.put(url, parameters),
    delete: url => smapi.rest.delete(url)
  };

  return smapi;
}

module.exports = alexaSMAPI;