Function pluginHandler

packages/server/src/adapter/fastify/plugin.ts:28–56

(fastify, options, done)

 * Fastify plugin for handling CRUD requests.
 */
const pluginHandler: FastifyPluginCallback<FastifyPluginOptions<SchemaDef>> = (fastify, options, done) => {
    const prefix = options.prefix ?? '';

    fastify.all(`${prefix}/*`, async (request, reply) => {
        const client = await options.getClient(request, reply);
        if (!client) {
            reply.status(500).send({ message: 'unable to get ZenStackClient from request context' });
            return reply;
        }

        try {
            const response = await options.apiHandler.handleRequest({
                method: request.method,
                path: (request.params as any)['*'],
                query: request.query as Record<string, string | string[]>,
                requestBody: request.body,
                client,
            });
            reply.status(response.status).send(response.body);
        } catch (err) {
            logInternalError(options.apiHandler.log, err);
            reply.status(500).send({ message: `An internal server error occurred` });
        }

        return reply;
    });

    done();
};

const plugin = fp(pluginHandler);