lbry-desktop/ui/js/lbryio.js

import { getSession, setSession, setLocal } from "./utils.js";
import lbry from "./lbry.js";

const querystring = require("querystring");

const lbryio = {
  _accessToken: getSession("accessToken"),
  _authenticationPromise: null,
  _user: null,
  enabled: true,
};

const CONNECTION_STRING = process.env.LBRY_APP_API_URL
  ? process.env.LBRY_APP_API_URL.replace(/\/*$/, "/") // exactly one slash at the end
  : "https://api.lbry.io/";
const EXCHANGE_RATE_TIMEOUT = 20 * 60 * 1000;

lbryio._exchangePromise = null;
lbryio._exchangeLastFetched = null;
lbryio.getExchangeRates = function() {
  if (
    !lbryio._exchangeLastFetched ||
    Date.now() - lbryio._exchangeLastFetched > EXCHANGE_RATE_TIMEOUT
  ) {
    lbryio._exchangePromise = new Promise((resolve, reject) => {
      lbryio
        .call("lbc", "exchange_rate", {}, "get", true)
        .then(({ lbc_usd, lbc_btc, btc_usd }) => {
          const rates = { lbc_usd, lbc_btc, btc_usd };
          resolve(rates);
        })
        .catch(reject);
    });
    lbryio._exchangeLastFetched = Date.now();
  }
  return lbryio._exchangePromise;
};

lbryio.call = function(
  resource,
  action,
  params = {},
  method = "get",
  evenIfDisabled = false
) {
  // evenIfDisabled is just for development, when we may have some calls working and some not
  return new Promise((resolve, reject) => {
    if (
      !lbryio.enabled &&
      !evenIfDisabled &&
      (resource != "discover" || action != "list")
    ) {
      console.log(__("Internal API disabled"));
      reject(new Error(__("LBRY internal API is disabled")));
      return;
    }

    const xhr = new XMLHttpRequest();

    xhr.addEventListener("error", function(event) {
      reject(
        new Error(__("Something went wrong making an internal API call."))
      );
    });

    xhr.addEventListener("timeout", function() {
      reject(new Error(__("XMLHttpRequest connection timed out")));
    });

    xhr.addEventListener("load", function() {
      const response = JSON.parse(xhr.responseText);

      if (!response.success) {
        if (reject) {
          let error = new Error(response.error);
          error.xhr = xhr;
          reject(error);
        } else {
          document.dispatchEvent(
            new CustomEvent("unhandledError", {
              detail: {
                connectionString: connectionString,
                method: action,
                params: params,
                message: response.error.message,
                ...(response.error.data ? { data: response.error.data } : {}),
              },
            })
          );
        }
      } else {
        resolve(response.data);
      }
    });

    // For social media auth:
    //const accessToken = localStorage.getItem('accessToken');
    //const fullParams = {...params, ... accessToken ? {access_token: accessToken} : {}};

    // Temp app ID based auth:
    const fullParams = { app_id: lbryio.getAccessToken(), ...params };

    if (method == "get") {
      xhr.open(
        "get",
        CONNECTION_STRING +
          resource +
          "/" +
          action +
          "?" +
          querystring.stringify(fullParams),
        true
      );
      xhr.send();
    } else if (method == "post") {
      xhr.open("post", CONNECTION_STRING + resource + "/" + action, true);
      xhr.setRequestHeader("Content-type", "application/x-www-form-urlencoded");
      xhr.send(querystring.stringify(fullParams));
    } else {
      reject(new Error(__("Invalid method")));
    }
  });
};

lbryio.getAccessToken = () => {
  const token = getSession("accessToken");
  return token ? token.toString().trim() : token;
};

lbryio.setAccessToken = token => {
  setSession("accessToken", token ? token.toString().trim() : token);
};

lbryio.setCurrentUser = (resolve, reject) => {
  lbryio
    .call("user", "me")
    .then(data => {
      lbryio.user = data;
      resolve(data);
    })
    .catch(function(err) {
      lbryio.setAccessToken(null);
      reject(err);
    });
};

lbryio.authenticate = function() {
  if (!lbryio.enabled) {
    return new Promise((resolve, reject) => {
      resolve({
        id: 1,
        language: "en",
        has_email: true,
        has_verified_email: true,
        is_reward_approved: false,
        is_reward_eligible: false,
      });
    });
  }
  if (lbryio._authenticationPromise === null) {
    lbryio._authenticationPromise = new Promise((resolve, reject) => {
      lbry
        .status()
        .then(response => {
          let installation_id = response.installation_id;

          if (!lbryio.getAccessToken()) {
            lbryio
              .call(
                "user",
                "new",
                {
                  language: "en",
                  app_id: installation_id,
                },
                "post"
              )
              .then(function(responseData) {
                if (!responseData.id) {
                  reject(
                    new Error("Received invalid authentication response.")
                  );
                }
                lbryio.setAccessToken(installation_id);
                lbryio.setCurrentUser(resolve, reject);
              })
              .catch(function(error) {
                /*
						 until we have better error code format, assume all errors are duplicate application id
						 if we're wrong, this will be caught by later attempts to make a valid call
						*/
                lbryio.setAccessToken(installation_id);
                lbryio.setCurrentUser(resolve, reject);
              });
          } else {
            lbryio.setCurrentUser(resolve, reject);
          }
        })
        .catch(reject);
    });
  }
  return lbryio._authenticationPromise;
};

export default lbryio;