ext-modular/infrastructure.js

"use stict";

const cl = global.botanLoader;

const EventEmitter = require( "events" ).EventEmitter;
const util = require( "util" );

class Infrastructure extends EventEmitter
{
	constructor()
	{
		super();
		var _self = this;

		var __readyList = [];
		this.readyList = new Proxy( __readyList, {

			get: ( target, prop ) => Reflect.get( target, prop )

			, set: ( target, prop, value ) => {

				// Have to emit the event at next tick
				// due to error thrown from the handlers
				// hangs the process
				process.nextTick( () => {
					if( __readyList.every( ( v ) => v === true ) )
					{
						_self.isReady = true;
						_self.emit( "apis_ready", _self )
					}
				} );

				return Reflect.set( target, prop, value );
			}

		} );

		this.APIs = {};
		this.isReady = true;
	}

	callAPI( name )
	{
		var propName = name.split( "." );
		propName = name[ name.length - 1 ];

		if( this.APIs[ propName ] ) return this.APIs[ propName ];

		var path = name.replace( ".", "/" );

		var API = cl.load( name );

		if( !API.create )
		{
			throw new Error( "API does not have support calling" );
		}

		var aclass = API.create( Array.prototype.slice.call( arguments, 1 ) );

		this.APIs[ propName ] = aclass;

		if( aclass.ready !== undefined )
		{
			this.isReady = false;

			var rList =  this.readyList;
			rList.push( aclass.ready || aclass );

			aclass.once( "ready", ( e ) => rList[ rList.indexOf( e ) ] = true );
		}

		return aclass;
	}

	Ready( callback )
	{
		if( this.isReady ) callback();
		else this.once( "apis_ready", () => callback() );
	}
}

module.exports = Infrastructure;