export const guidelistSentWorkflow = workflow('guidelist_sent', async ({ payload, step, subscriber }) => {
    await step.inApp('notify-in-app', () => ({
        subject: translationService.translate('guidelist.sent.in_app.subject', subscriber.locale),
        body: translationService.translate('guidelist.sent.in_app.body', subscriber.locale, {
            userUsername: payload.sender.username,
            movieTitle: payload.movie.title,
            movieSlug: payload.movie.slug
        }),
        avatar: payload.sender.avatar || undefined,
        redirect: {
            url: `/collection/guidelist#${payload.id}`
        }
    }));

    await step.push('notify-push', () => ({
        subject: translationService.translate('guidelist.sent.push.subject', subscriber.locale),
        body: translationService.translate('guidelist.sent.push.body', subscriber.locale, {
            userUsername: payload.sender.username,
            movieTitle: payload.movie.title
        }),
    }));
}, {
    tags: ['guidelist'],
    payloadSchema: z.object({
        id: z.number().int().describe('The ID of the guidelist'),
        sender: z.object({
            username: z.string().describe('The user who sent the guidelist'),
            avatar: z
                .string()
                .nullable()
                .optional()
                .describe('The avatar of the user who sent the guidelist')
        }),
        movie: z.object({
            title: z.string().describe('The movie that was recommended'),
            slug: z.string().describe('The slug of the movie that was recommended')
        }),
    })
});

export const guidelistSentWorkflow = workflow('guidelist_sent', async ({ payload, step, subscriber }) => {
    await step.inApp('notify-in-app', () => ({
        subject: translationService.translate('guidelist.sent.in_app.subject', subscriber.locale),
        body: translationService.translate('guidelist.sent.in_app.body', subscriber.locale, {
            userUsername: payload.sender.username,
            movieTitle: payload.movie.title,
            movieSlug: payload.movie.slug
        }),
        avatar: payload.sender.avatar || undefined,
        redirect: {
            url: `/collection/guidelist#${payload.id}`
        }
    }));

    await step.push('notify-push', () => ({
        subject: translationService.translate('guidelist.sent.push.subject', subscriber.locale),
        body: translationService.translate('guidelist.sent.push.body', subscriber.locale, {
            userUsername: payload.sender.username,
            movieTitle: payload.movie.title
        }),
    }));
}, {
    tags: ['guidelist'],
    payloadSchema: z.object({
        id: z.number().int().describe('The ID of the guidelist'),
        sender: z.object({
            username: z.string().describe('The user who sent the guidelist'),
            avatar: z
                .string()
                .nullable()
                .optional()
                .describe('The avatar of the user who sent the guidelist')
        }),
        movie: z.object({
            title: z.string().describe('The movie that was recommended'),
            slug: z.string().describe('The slug of the movie that was recommended')
        }),
    })
});

{
    "statusCode": 400,
    "timestamp": "2024-11-13T10:22:17.860Z",
    "path": "/v1/bridge/sync?source=studio",
    "message": "Signature does not match the expected signature. Please ensure the signature provided in the `novu-signature` header is correct and try again.",
    "error": "Bad Request"
}

{
    "statusCode": 400,
    "timestamp": "2024-11-13T10:22:17.860Z",
    "path": "/v1/bridge/sync?source=studio",
    "message": "Signature does not match the expected signature. Please ensure the signature provided in the `novu-signature` header is correct and try again.",
    "error": "Bad Request"
}

The Novu-Signature header included in each signed event contains a timestamp and one or more signatures that we verify. The timestamp is prefixed by t=, and each signature is prefixed by a scheme. Schemes start with v, followed by an integer. Currently, the only valid live signature scheme is v1.

Handling the signature verification is done by the Novu Framework, so you don’t need to perform any action.

The Novu-Signature header included in each signed event contains a timestamp and one or more signatures that we verify. The timestamp is prefixed by t=, and each signature is prefixed by a scheme. Schemes start with v, followed by an integer. Currently, the only valid live signature scheme is v1.

Handling the signature verification is done by the Novu Framework, so you don’t need to perform any action.

{
  message: "{{user}} send you a friend request",
  user: "myidea"
  avatar: "user.avatar_url"
}

{
  message: "{{user}} send you a friend request",
  user: "myidea"
  avatar: "user.avatar_url"
}

{
  action: "FriendRequest"
}

{
  action: "FriendRequest"
}