exposure.js

//const debug = require("debug")("mgmt");

const EXPOSURE_API_ENDPOINT_PROD =
  "https://exposure.api.redbee.live/v2";
const EXPOSURE_API_ENDPOINT_STAGE =
  "https://psempexposureapi.ebsd.ericsson.net/v2";
const authService = require("../services/authService");
const entitlementService = require("../services/entitlementService");
const assetService = require("../services/assetService");

const BaseApi = require("../utils/baseApi");

class ExposureAPI extends BaseApi {
  constructor(customerUnit, businessUnit, options) {
    options = {
      environment: "production",
      ...options,
    };
    const url =
      options.environment === "stage"
        ? EXPOSURE_API_ENDPOINT_STAGE
        : EXPOSURE_API_ENDPOINT_PROD;
    super(url);
    this.customerUnit = customerUnit;
    this.businessUnit = businessUnit;
  }

  async authenticate(username, password) {
    if (!this.customerUnit || !this.businessUnit) return;
    const url = `${this.baseUrl}/customer/${this.customerUnit}/businessunit/${this.businessUnit}/auth/login`;
    return await authService.authenticate({
      url,
      username,
      password,
    });
  }

  async play(sessionToken, assetId) {
    if (!this.customerUnit || !this.businessUnit) return;
    const url = `${this.baseUrl}/customer/${this.customerUnit}/businessunit/${this.businessUnit}/entitlement/${assetId}/play`;
    return await entitlementService.play({
      url,
      sessionToken,
    });
  }

  async getAssets({ assetType = undefined, onlyPublished = true }) {
    if (!this.customerUnit || !this.businessUnit) return;
    const url = `${this.baseUrl.replace("v2", "v1")}/customer/${
      this.customerUnit
    }/businessunit/${this.businessUnit}/content/asset`;
    return await assetService.getAllAssets({
      url,
      onlyPublished,
      ...(assetType && { assetType }),
    });
  }

  async getAsset(assetId) {
    if (!this.customerUnit || !this.businessUnit) return;
    const url = `${this.baseUrl.replace("v2", "v1")}/customer/${
      this.customerUnit
    }/businessunit/${this.businessUnit}/content/asset/${assetId}`;
    return await assetService.getAsset(`${url}?onlyPublished=false`);
  }

  async resolveSerie(serieId) {
    if (!this.customerUnit || !this.businessUnit) return;
    const url = `${this.baseUrl.replace("v2", "v1")}/customer/${
      this.customerUnit
    }/businessunit/${this.businessUnit}/content/asset/${serieId}`;
    return await assetService.resolveSerie(url);
  }
}

module.exports = ExposureAPI;