client/lib/activations.js

/*
 * Copyright 2015-2016 IBM Corporation
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

var pollIntervalMillis = 200,
    openwhisk = require('openwhisk'),
    ok_ = require('./repl-messages').ok_,
    errorWhile = require('./repl-messages').errorWhile,
    api = {
	host: 'https://openwhisk.ng.bluemix.net',
	path: '/api/v1'
    };

/**
 * Wait for activation completion
 *
 */
exports.waitForActivationCompletion = function waitForActivationCompletion(wskprops, eventBus, waitForThisAction, options) {
    var key = wskprops.AUTH;
    var ow = openwhisk({
	api: api.host + api.path,
	api_key: key,
	namespace: '_' // special here, as activations are currently stored in the user's default namespace
    });

    return new Promise((resolve, reject) => {
	//
	// this is the poll function
	//
	var pollOnce = function() {
	    //
	    // scan the recent activations, looking for the
	    // anticipated activation by invoked-entity name
	    //
	    ow.activations.list({ limit: 5, name: waitForThisAction, since: options.since, docs: true }).then(list => {
		var allDone = false;
		for (var i = 0; i < list.length; i++) {
		    var activationDetails = list[i];

		    if (options && options.result) {
			activationDetails = activationDetails.response.result;
		    }
				
		    // print out the activation record
		    console.log(JSON.stringify(activationDetails, undefined, 4));

		    // let other async listeners know about it
		    eventBus.emit('invocation-done', activationDetails);

		    // and let the promise know about it
		    resolve(activationDetails);

		    allDone = true;
		    break;
		}
		
		if (!allDone) {
		    //
		    // not yet, try again in a little bit
		    //
		    setTimeout(pollOnce, pollIntervalMillis);
		}
		    
	    }).catch(errorWhile('listing activations', reject));
	};

	//
	// start up the poller
	//
	setTimeout(pollOnce, pollIntervalMillis);
    });
};