insomnia/app/network/o-auth-1/get-token.js
2017-11-06 21:44:55 +01:00

59 lines
1.7 KiB
JavaScript

// @flow
/**
* Get an OAuth1Token object and also handle storing/saving/refreshing
* @returns {Promise.<void>}
*/
import crypto from 'crypto';
import OAuth1 from 'oauth-1.0a';
import {SIGNATURE_METHOD_HMAC_SHA1, SIGNATURE_METHOD_PLAINTEXT} from './constants';
import type {OAuth1SignatureMethod} from './constants';
import type {RequestAuthentication} from '../../models/request';
function hashFunction (signatureMethod: OAuth1SignatureMethod) {
if (signatureMethod === SIGNATURE_METHOD_HMAC_SHA1) {
return function (baseString: string, key: string): string {
return crypto.createHmac('sha1', key).update(baseString).digest('base64');
};
}
if (signatureMethod === SIGNATURE_METHOD_PLAINTEXT) {
return function (baseString: string): string {
return baseString;
};
}
throw new Error(`Invalid signature method ${signatureMethod}`);
}
export default async function (
url: string,
method: string,
authentication: RequestAuthentication
): {[string]: string} {
console.log('OAUTHING', url, method, authentication);
const oauth = new OAuth1({
consumer: {
key: authentication.consumerKey,
secret: authentication.consumerSecret
},
signature_method: authentication.signatureMethod,
version: authentication.version,
hash_function: hashFunction(authentication.signatureMethod)
});
const requestData = {
url: url,
method: method
};
let token = null;
if (authentication.tokenKey && authentication.tokenSecret) {
token = {key: authentication.tokenKey, secret: authentication.tokenSecret};
} else if (authentication.tokenKey) {
token = {key: authentication.tokenKey};
}
const data = oauth.authorize(requestData, token);
return oauth.toHeader(data);
}