Support RetryError in other functions

[mariusandra]

PR PostHog/plugin-server#408 introduced RetryError, which you use like this:

import { RetryError } from '@posthog/plugin-scaffold' // also a global

export async function exportEvents (events, { global, config }) {
    try {
        await fetch(`https://${config.host}/e`, {
            method: 'POST',
            body: JSON.stringify(events),
            headers: { 'Content-Type': 'application/json' },
        })
    } catch (error) {
         throw new RetryError() // ask to retry
    }
}

This exportEvents function will now be automatically retried.

We should add the same functionality to onEvent, onSnapshot, and in the future perhaps also processEvent, though that's a bit trickier due to the ordering requirements.

Retries should also be something that's easy to add or automatic in other new functions like onAction, onRequest (incoming webhooks), etc.

[mariusandra]

One complication introduced by PostHog/plugin-server#408 is that the buffer.add call to enqueue events that eventually reach exportEvents is done in a patched onEvent. Basically:

const oldOnEvent = exports.oldOnEvent
exports.onEvent = (event, meta) => { buffer.add(event); oldOnEvent?.(event, meta) }

This messes up the retry logic a bit and should be split up nicely (as in don't retry the export when retrying the regular onEvent... it has its own retry handling).

[posthog-bot]

This issue hasn't seen activity in two years! If you want to keep it open, post a comment or remove the stale label – otherwise this will be closed in two weeks.

[posthog-bot]

This issue was closed due to lack of activity. Feel free to reopen if it's still relevant.