mediawiki-extensions-Echo/modules/api/mw.echo.api.EchoApi.js

( function ( mw ) {
	/**
	 * A class defining Echo API instructions and network operations
	 *
	 * @constructor
	 */
	mw.echo.api.EchoApi = function MwEchoApiEchoApi() {
		this.network = new mw.echo.api.NetworkHandler();

		this.fetchingPromise = null;
	};

	OO.initClass( mw.echo.api.EchoApi );

	/**
	 * Fetch notifications from the server based on type
	 *
	 * @param {string} types An array of notification types to fetch: 'alert', 'message', 'all'
	 * @param {string} [source="local"] The source from which to fetch the notifications
	 * @param {boolean} [isForced] Force a refresh on the fetch notifications promise
	 * @return {[type]} Promise that is resolved with all notifications for the
	 *  requested types.
	 */
	mw.echo.api.EchoApi.prototype.fetchNotifications = function ( type, source, isForced ) {
		var api = this;

		source = source || 'local';

		return this.network.getApiHandler( source ).fetchNotifications( type, isForced )
			.then( function ( result ) {
				var id, s,
					sources = {},
					rawData = OO.getProp( result.query, 'notifications' ),
					sourceDefinitions = rawData.sources;

				for ( source in sourceDefinitions ) {
					api.network.addApiHandler( source, sourceDefinitions[ source ], true );
				}

				for ( id in rawData.list ) {
					if ( rawData.list[ id ].type === 'external' ) {
						// Define sources
						sources = {};
						for ( s = 0; s < rawData.list[ id ].sources.length; s++ ) {
							sources[ rawData.list[ id ].sources[ s ] ] = sourceDefinitions[ rawData.list[ id ].sources[ s ] ].title;
						}
						rawData.list[ id ].sources = sources;
					}

				}

				return rawData;
			} );
	};

	/**
	 * Fetch notifications from several sources
	 *
	 * @param {string[]} sourceArray An array of sources to fetch from the group
	 * @param {string} type Notification type
	 * @return {jQuery.Promise} A promise that resolves with an array of promises for
	 *  fetchNotifications per each given source in the source array.
	 */
	mw.echo.api.EchoApi.prototype.fetchNotificationGroups = function ( sourceArray, type ) {
		var i, promise,
			promises = [];

		for ( i = 0; i < sourceArray.length; i++ ) {
			promise = this.network.getApiHandler( sourceArray[ i ] ).fetchNotifications( type );
			promises.push( promise );
		}

		return mw.echo.api.NetworkHandler.static.waitForAllPromises( promises );
	};

	/**
	 * Mark items as read in the API.
	 *
	 * @param {string[]} itemIds An array of item IDs to mark as read
	 * @param {string} source The source that these items belong to
	 * @param {string} type Notification type
	 * @return {jQuery.Promise} A promise that is resolved when the operation
	 *  is complete, with the number of unread notifications still remaining
	 *  for that type in the given source
	 */
	mw.echo.api.EchoApi.prototype.markItemsRead = function ( itemIds, source, type ) {
		return this.network.getApiHandler( source ).markItemsRead( itemIds, type );
	};

	/**
	 * Mark all notifications for a given type as read in the given source.
	 *
	 * @param {[type]} source Notifications source
	 * @param {[type]} type Notifications type
	 * @return {jQuery.Promise} A promise that is resolved when the operation
	 *  is complete, with the number of unread notifications still remaining
	 *  for that type in the given source
	 */
	mw.echo.api.EchoApi.prototype.markAllRead = function ( source, type ) {
		// FIXME: This specific method sends an operation
		// to the API that marks all notifications of the given type as read regardless
		// of whether they were actually seen by the user.
		// We should consider removing the use of this method and, instead,
		// using strictly the 'markItemsRead' by giving the API only the
		// notifications that are available to the user.
		return this.network.getApiHandler( source ).markAllRead( type );
	};

	/**
	 * Fetch the number of unread notifications for the given type in the given
	 * source.
	 *
	 * @param {string} source Notifications source
	 * @param {string} type Notification type
	 * @return {jQuery.Promise} A promise that is resolved with the number of
	 *  unread notifications for the given type and source.
	 */
	mw.echo.api.EchoApi.prototype.fetchUnreadCount = function ( source, type ) {
		return this.network.getApiHandler( source ).fetchUnreadCount( type );
	};

	/**
	 * Update the seenTime property for the given type and source.
	 *
	 * @param {string} source Notification source
	 * @param {string} type Notification type
	 * @return {jQuery.Promise} A promise that is resolved when the operation is complete.
	 */
	mw.echo.api.EchoApi.prototype.updateSeenTime = function ( source, type ) {
		return this.network.getApiHandler( source ).updateSeenTime( type );
	};

	/**
	 * Check whether the API promise for fetch notification is in an error
	 * state for the given source and notification type.
	 *
	 * @param {string} source Notification source.
	 * @param {string} type Notification type
	 * @return {Boolean} The API response for fetching notification has
	 *  resolved in an error state, or is rejected.
	 */
	mw.echo.api.EchoApi.prototype.isFetchingErrorState = function ( source, type ) {
		return this.network.getApiHandler( source ).isFetchingErrorState( type );
	};

	/**
	 * Get the fetch notifications promise active for the current source and type.
	 *
	 * @param {string} source Notification source.
	 * @param {string} type Notification type
	 * @return {jQuery.Promise} Promise that is resolved when notifications are
	 *  fetched from the API.
	 */
	mw.echo.api.EchoApi.prototype.getFetchNotificationPromise = function ( source, type ) {
		return this.network.getApiHandler( source ).getFetchNotificationPromise( type );
	};

} )( mediaWiki );