Function contentController

packages/api/src/controllers/contentController.ts:62–654

(fastify: FastifyInstance)

// eslint-disable-next-line @typescript-eslint/require-await
export default async function contentController(fastify: FastifyInstance) {
  fastify.withTypeProvider<TypeBoxTypeProvider>().post(
    "/templates/render",
    {
      schema: {
        description: "Render message template.",
        tags: ["Content"],
        body: RenderMessageTemplateRequest,
        response: {
          200: RenderMessageTemplateResponse,
          500: BaseMessageResponse,
        },
      },
    },
    async (request, reply) => {
      const {
        contents,
        workspaceId,
        subscriptionGroupId,
        channel,
        userProperties,
        tags,
      } = request.body;
      const tagsWithMessageId: MessageTags = {
        ...(tags ?? {}),
        messageId: tags?.messageId ?? randomUUID(),
      };

      const secretNames = [SecretNames.Subscription];
      if (channel === ChannelType.Webhook) {
        secretNames.push(SecretNames.Webhook);
      }

      const secrets = (
        await db().query.secret.findMany({
          where: and(
            eq(schema.secret.workspaceId, workspaceId),
            inArray(schema.secret.name, secretNames),
          ),
        })
      ).reduce((acc, secret) => {
        acc.set(secret.name, secret);
        return acc;
      }, new Map<string, Secret>());

      const templateSecrets: Record<string, string> = {};
      const subscriptionSecret = secrets.get(SecretNames.Subscription)?.value;
      if (subscriptionSecret) {
        templateSecrets[SecretNames.Subscription] = subscriptionSecret;
      }
      const webhookSecret = secrets.get(SecretNames.Webhook)?.configValue;
      if (webhookSecret) {
        const validated = schemaValidateWithErr(webhookSecret, WebhookSecret);
        if (validated.isErr()) {
          return reply.status(500).send({
            message: "Invalid webhook secret configuration",
          });
        }