index.js

const { extname } = require('path');
const createDebug = require('debug');
const { parse, format } = require('url');
const { parse: parseIni } = require('ini');

const fetch = require('./fetch');

const debug = createDebug('iheart');

// go through a CORS reverse proxy so that these APIs work in the web browser
const corsDefaultProxy = process.browser ? 'https://cors.now.sh/' : '';

const searchBase = 'https://api.iheart.com/api/v1/catalog/searchAll';
const streamsBase = 'https://api.iheart.com/api/v2/content/liveStations/';

function getProxyURL(options) {
  return options && 'string' === typeof options.proxy
    ? options.proxy
    : options && null === options.proxy
    ? ''
    : corsDefaultProxy;
}

/**
 * Searches for radio streams matching `keyword`.
 */
async function search(keyword, options) {
  if ('string' !== typeof keyword) {
    throw new TypeError('a string "keyword" is required');
  }

  const corsProxy = getProxyURL(options);
  const formatted = parse(searchBase, true);
  formatted.query.keywords = keyword;
  const url = format(formatted);

  const res = await fetch(`${corsProxy}${url}`);

  const body = await res.json();
  if (body.errors) {
    // body.firstError
  }
  return body;
}

/**
 * Searches for a station by Id
 */
async function getById(_station, options) {
  const id = _station.id || _station;
  if ('number' !== typeof id) {
    throw new TypeError('a number station "id" is required');
  }

  const corsProxy = getProxyURL(options);
  let url = streamsBase + id;
  const res = await fetch(`${corsProxy}${url}`);

  const body = await res.json();
  if (body.errors) {
    // body.firstError
  }

  return body.hits[0];
}

/**
 * Gets the raw stream URL of the given Station or Station ID.
 */
async function streamURL(_station, options) {
  const { streams } = await getById(_station, options);
  if (!streams) {
    throw new Error('No `streams` given');
  }

  url =
    streams.secure_pls_stream ||
    streams.pls_stream ||
    streams.stw_stream ||
    streams.secure_shoutcast_stream ||
    streams.shoutcast_stream ||
    streams[Object.keys(streams)[0]];

  if ('.pls' === extname(url).toLowerCase()) {
    debug('attempting to resolve "pls" file %o', url);
    const corsProxy = getProxyURL(options);
    const res = await fetch(`${corsProxy}${url}`);
    const body = parseIni(await res.text());
    debug('pls file: %O', body);
    url = body.playlist.File1;
  }

  debug('stream URL: %o', url);
  return url;
}

module.exports = {
  search,
  getById,
  streamURL
};