/*
 * 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: 20 }).then(list => {
		var allDone = false;
		for (var i = 0; i < list.length; i++) {
		    var activation = list[i];
		    if (activation.name === waitForThisAction) {

			//
			// great! we found the anticipated activation
			//
			ow.activations.get({ activation: activation.activationId })
			    .then(activationDetails => {

				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);

			    }).catch(errorWhile('fetching activation details', reject));
			
			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);
    });
};