index.js

'use strict';

const Promise = require('bluebird');
const Client = require('./lib/client');
const defaultVideoTransform = require('./lib/default-video-transform');
const defaultCollectionTransform = require('./lib/default-collection-transform');
const createChannelCache = require('./lib/create-channel-cache');
const fetchJWPlayerVideo = require('./lib/fetch-jwplayer-video');
const fetchJWPlayerCollection = require('./lib/fetch-jwplayer-playlist');
const utils = require('./lib/utils');

const DEFAULTS = {
	baseUrl: 'https://api.jwplatform.com',
	// baseUrl: 'https://api.jwplayer.com',
	collectionTransform: defaultCollectionTransform,
	videoTransform: defaultVideoTransform
};

// options.bus
// options.baseUrl
// options.secretKey
// options.apiKey
// options.collectionTransform
// options.assetTransform
exports.initialize = options => {
	options = Object.assign({}, DEFAULTS, options || {});

	const bus = options.bus;
	const baseUrl = options.baseUrl;
	const apiKey = options.apiKey;
	const secretKey = options.secretKey;
	const role = 'provider';
	const cmd = 'get';

	if (!bus || typeof bus !== 'object') {
		throw new Error('oddworks-jwplayer-provider requires an Oddcast Bus');
	}

	const collectionTransform = options.collectionTransform;
	const videoTransform = options.videoTransform;

	const client = new Client({bus, baseUrl, secretKey, apiKey});

	const getChannel = createChannelCache(bus);

	bus.queryHandler(
		{role, cmd, source: 'jwplayer-playlist-provider'},
		exports.createPlaylistHandler(bus, getChannel, client, collectionTransform)
	);

	bus.queryHandler(
		{role, cmd, source: 'jwplayer-video-provider'},
		exports.createVideoHandler(bus, getChannel, client, videoTransform)
	);

	return Promise.resolve({
		name: 'jwplayer-provider',
		client
	});
};

exports.createPlaylistHandler = (bus, getChannel, client, transform) => {
	const getCollection = fetchJWPlayerCollection(bus, client, transform);

	// Called from Oddworks core via bus.query
	// Expects:
	//   args.spec.playlist.id
	return args => {
		const spec = args.spec;
		const playlistId = (spec.playlist || {}).key || (spec.playlist || {}).id;
		const channelId = spec.channel;

		if (!playlistId || typeof playlistId !== 'string') {
			throw new Error(
				'jwplayer-playlist-provider spec.playlist.key or spec.playlist.id String is required'
			);
		}

		return getChannel(channelId).then(channel => {
			return getCollection({spec, channel});
		});
	};
};

exports.createVideoHandler = (bus, getChannel, client, transform) => {
	const getJWPlayerVideo = fetchJWPlayerVideo(bus, client, transform);

	// Called from Oddworks core via bus.query
	// Expects:
	//   args.spec.video
	return args => {
		const spec = args.spec;
		const channelId = spec.channel;
		const videoId = (spec.video || {}).mediaid || (spec.video || {}).id;

		if (!videoId || typeof videoId !== 'string') {
			throw new Error(
				'jwplayer-video-provider spec.video.mediaid or spec.video.id String is not available'
			);
		}

		return getChannel(channelId).then(channel => {
			return getJWPlayerVideo({spec, channel});
		});
	};
};

// options.secretKey *required
// options.apiKey *required
// options.bus *optional
// options.baseUrl *optional
exports.createClient = options => {
	options = Object.assign({}, DEFAULTS, options || {});

	const bus = options.bus;
	const baseUrl = options.baseUrl;
	const secretKey = options.secretKey;
	const apiKey = options.apiKey;

	if (!apiKey || typeof apiKey !== 'string') {
		throw new Error('oddworks-jwplayer-provider requires an jwplayer apiKey key');
	}
	if (!secretKey || typeof secretKey !== 'string') {
		throw new Error('oddworks-jwplayer-provider requires an jwplayer secretKey key');
	}

	return new Client({bus, baseUrl, secretKey, apiKey});
};

exports.utils = utils;