export function registerFunction()

in src/coreApi/registerFunction.ts [12:49]
29 lines of code
6 McCabe index (conditional complexity)

export function registerFunction(metadata: FunctionMetadata, callback: FunctionCallback): Disposable {
    if (worker.app.workerIndexingLocked) {
        throw new AzFuncSystemError('A function can only be registered during app startup.');
    }
    worker.app.isUsingWorkerIndexing = true;

    const functionId = metadata.functionId || metadata.name;
    if (functionId in worker.app.functions) {
        throw new AzFuncSystemError(`A function with id "${functionId}" has already been registered.`);
    }

    const rpcMetadata: rpc.IRpcFunctionMetadata = fromCoreFunctionMetadata(metadata);
    rpcMetadata.functionId = functionId;
    // `rawBindings` is what's actually used by the host
    // `bindings` is used by the js library in both the old host indexing and the new worker indexing
    rpcMetadata.rawBindings = Object.entries(metadata.bindings).map(([name, binding]) => {
        return JSON.stringify({ ...binding, name });
    });

    // The host validates that the `scriptFile` property is defined. Neither the host nor the worker needs it, but tooling like the portal may use it so we'll make a best guess
    // (The real script file may be a separate file referenced from the entry point, or it may be coming from a different entry point entirely if there are some async shenanigans)
    if (worker.app.currentEntryPoint) {
        rpcMetadata.scriptFile = path.basename(worker.app.currentEntryPoint);
        rpcMetadata.directory = path.dirname(worker.app.currentEntryPoint);
    } else {
        rpcMetadata.scriptFile = 'unknown';
    }

    worker.app.functions[functionId] = { metadata: rpcMetadata, callback };

    return new Disposable(() => {
        if (worker.app.workerIndexingLocked) {
            throw new AzFuncSystemError('A function can only be disposed during app startup.');
        } else {
            delete worker.app.functions[functionId];
        }
    });
}