Function api_handle_message

src/shared/socket/SocketAPI.ts:93–151

(
  api: SocketAPIData<T, U, EVENT>,
  data: SocketRequestData | SocketResponseData<unknown>,
  event: EVENT,
)

}

export async function api_handle_message<
  T extends T_BASE,
  U extends U_BASE<T>,
  EVENT extends EVENT_BASE
>(
  api: SocketAPIData<T, U, EVENT>,
  data: SocketRequestData | SocketResponseData<unknown>,
  event: EVENT,
): Promise<[
    SocketResponseData<unknown> | undefined, // Incoming response (resolve/reject promise)
    SocketResponseData<unknown> | undefined, // Outgoing response (send this)
  ]> {

  if ('type' in data) { // Request
    // Handle message
    for (let i = 0; i < api.registered_any.length; i++) {
      const callback_any = api.registered_any[i];
      callback_any(event, data.type as T, data.args);
    }

    const callback = api.registered[data.type];
    let result: any;
    let error: any;
    if (callback) {
      try {
        result = await callback(event, ...data.args as any);
      } catch (e) {
        // console.error(`An error was thrown from inside a callback (type: ${data.type}).`, e);
        error = (e as Error).toString();
      }
    }

    // Respond
    if (data.id !== undefined) {
      if (typeof data.id === 'number') {
        let response: SocketResponseData<T>;
        if (result !== undefined) {
          response  = {
            id: data.id,
            result: result
          };
        } else {
          response  = {
            id: data.id,
            error: error
          };
        }

        return [undefined, response];
      } else {
        console.error(`Socket Client - Failed to respond to request, request ID is not of type "number" (type: "${typeof data.id}").`);
      }
    }
  } else { // Response
    return [data, undefined];
  }

  return [undefined, undefined];