async function pollActivations()

in agent/agent-activationdb.js [57:88]


async function pollActivations(actionName, onActivation, onLoop) {
    const wsk = openwhisk();

    const since = Date.now();

    while (true) {

        let name = actionName;
        if (activationListFilterOnlyBasename) {
            if (actionName.includes("/")) {
                name = actionName.substring(actionName.lastIndexOf("/") + 1);
            }
        }

        const activations = await wsk.activations.list({
            name: name,
            since: since,
            docs: true // include results
        });

        for (const a of activations) {
            const result = onActivation(a);
            if (result) {
                return result;
            }
        }

        await sleep(1000);

        onLoop();
    }
}