oauth-utils.js

import { OAuth } from "oauth";
import { promisify } from "util";
import dotenv from "dotenv";
dotenv.config();

const TWITTER_CONSUMER_API_KEY = process.env.TWITTER_CONSUMER_KEY;
const TWITTER_CONSUMER_API_SECRET_KEY = process.env.TWITTER_CONSUMER_SECRET;
const TWITTER_CALLBACK_URL = process.env.TWITTER_CALLBACK_URL;
const oauthConsumer = new OAuth(
  "https://twitter.com/oauth/request_token",
  "https://twitter.com/oauth/access_token",
  TWITTER_CONSUMER_API_KEY,
  TWITTER_CONSUMER_API_SECRET_KEY,
  "1.0A",
  TWITTER_CALLBACK_URL,
  "HMAC-SHA1"
);

export const oauthGetUserById = (
  userId,
  { oauthAccessToken, oauthAccessTokenSecret } = {}
) => {
  return promisify(oauthConsumer.get.bind(oauthConsumer))(
    `https://api.twitter.com/1.1/users/show.json?user_id=${userId}`,
    oauthAccessToken,
    oauthAccessTokenSecret
  ).then((body) => JSON.parse(body));
};
export const getOAuthAccessTokenWith = async ({
  oauthRequestToken,
  oauthRequestTokenSecret,
  oauthVerifier,
} = {}) =>
  new Promise((resolve, reject) => {
    oauthConsumer.getOAuthAccessToken(
      oauthRequestToken,
      oauthRequestTokenSecret,
      oauthVerifier,
      (error, oauthAccessToken, oauthAccessTokenSecret, results) =>
        error
          ? reject(new Error("Error getting OAuth access token"))
          : resolve({ oauthAccessToken, oauthAccessTokenSecret, results })
    );
  });

export const getOAuthRequestToken = async () =>
  new Promise((resolve, reject) => {
    oauthConsumer.getOAuthRequestToken(
      (error, oauthRequestToken, oauthRequestTokenSecret, results) =>
        error
          ? reject(new Error("Error getting OAuth request token"))
          : resolve({ oauthRequestToken, oauthRequestTokenSecret, results })
    );
  });