@atomist/skill/lib/bundle.js

"use strict";
/*
 * Copyright © 2020 Atomist, Inc.
 *
 * 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.
 */
Object.defineProperty(exports, "__esModule", { value: true });
const function_1 = require("./function");
const log_1 = require("./log");
const payload_1 = require("./payload");
const util_1 = require("./util");
const HandlerRegistry = {
    events: {},
    commands: {},
};
/**
 * Register a command handler with a certain name
 */
function registerCommand(name, loader) {
    HandlerRegistry.commands[name] = loader;
}
exports.registerCommand = registerCommand;
/**
 * Register a event handler with a certain name
 */
function registerEvent(name, loader) {
    HandlerRegistry.events[name] = loader;
}
exports.registerEvent = registerEvent;
exports.bundle = async (pubSubEvent, context) => {
    const attributes = Object.assign(Object.assign({}, (pubSubEvent.attributes || {})), { eventId: context.eventId });
    log_1.debug(`atm:attributes=${JSON.stringify(attributes)}`);
    const payload = JSON.parse(Buffer.from(pubSubEvent.data, "base64").toString());
    log_1.info(`Incoming pub/sub message: ${JSON.stringify(payload, util_1.replacer)}`);
    if (payload_1.isEventIncoming(payload)) {
        return function_1.processEvent(payload, context, async () => {
            const loader = HandlerRegistry.events[payload.extensions.operationName];
            if (loader) {
                return loader();
            }
            else {
                throw new Error(`Event handler with name '${payload.extensions.operationName}' not registered`);
            }
        });
    }
    else if (payload_1.isCommandIncoming(payload)) {
        return function_1.processCommand(payload, context, async () => {
            const loader = HandlerRegistry.commands[payload.command];
            if (loader) {
                return loader();
            }
            else {
                throw new Error(`Command handler with name '${payload.command}' not registered`);
            }
        });
    }
};
//# sourceMappingURL=bundle.js.map