Rocket.Chat/packages/apps-engine/deno-runtime/handlers/outboundcomms-handler.ts

import { JsonRpcError, Defined } from 'jsonrpc-lite';
import type { IOutboundMessageProviders } from '@rocket.chat/apps-engine/definition/outboundCommunication/IOutboundCommsProvider.ts';

import { AppObjectRegistry } from '../AppObjectRegistry.ts';
import { AppAccessorsInstance } from '../lib/accessors/mod.ts';
import { Logger } from '../lib/logger.ts';

export default async function outboundMessageHandler(call: string, params: unknown): Promise<JsonRpcError | Defined> {
	const [, providerName, methodName] = call.split(':');
	const provider = AppObjectRegistry.get<IOutboundMessageProviders>(`outboundCommunication:${providerName}`);
	if (!provider) {
		return new JsonRpcError('error-invalid-provider', -32000);
	}
	const method = provider[methodName as keyof IOutboundMessageProviders];
	const logger = AppObjectRegistry.get<Logger>('logger');
	const args = (params as Array<unknown>) ?? [];

	try {
		logger?.debug(`Executing ${methodName} on outbound communication provider...`);

		// deno-lint-ignore ban-types
		return await (method as Function).apply(provider, [
			...args,
			AppAccessorsInstance.getReader(),
			AppAccessorsInstance.getModifier(),
			AppAccessorsInstance.getHttp(),
			AppAccessorsInstance.getPersistence(),
		]);
	} catch (e) {
		return new JsonRpcError(e.message, -32000);
	}
}