Function handle

apps/app-server/src/utils/websocket-endpoints.ts:64–104

(message: Buffer)

    redlockSignals,

    async handle(message: Buffer) {
      try {
        moduleLogger.info('Received message %d', step);

        const input_ = (
          input.procedures[step - 1][0]._def.inputs[0] as any
        ).parse(unpack(message));

        if (step === 1) {
          await input.acquireLocks(input_);
        }

        const output = await input.procedures[step - 1][1]({
          ctx: input.ctx,
          input: input_,
        });

        checkRedlockSignalAborted(redlockSignals);

        moduleLogger.info('Sending message %d', step);

        input.connection.socket.send(
          pack({
            success: true,

            output,
          }),
        );

        if (step === input.procedures.length) {
          input.connection.end();
          finishPromise.resolve();

          moduleLogger.info('Finished websocket request');
        }

        step++;
      } catch (error: any) {
        finishPromise.reject(String(error?.message ?? error));
      }
    },
  };
}