api/federation/http/index.ts

import type { EntityValidator } from "../validator/index";

type MaybePromise<T> = T | Promise<T>;

type ParserCallbacks = {
    note: (note: typeof EntityValidator.$Note) => MaybePromise<void>;
    follow: (follow: typeof EntityValidator.$Follow) => MaybePromise<void>;
    followAccept: (
        followAccept: typeof EntityValidator.$FollowAccept,
    ) => MaybePromise<void>;
    followReject: (
        followReject: typeof EntityValidator.$FollowReject,
    ) => MaybePromise<void>;
    user: (user: typeof EntityValidator.$User) => MaybePromise<void>;
    like: (like: typeof EntityValidator.$Like) => MaybePromise<void>;
    dislike: (dislike: typeof EntityValidator.$Dislike) => MaybePromise<void>;
    undo: (undo: typeof EntityValidator.$Undo) => MaybePromise<void>;
    serverMetadata: (
        serverMetadata: typeof EntityValidator.$ServerMetadata,
    ) => MaybePromise<void>;
    extension: (
        extension: typeof EntityValidator.$Extension,
    ) => MaybePromise<void>;
};

export class RequestParserHandler {
    constructor(
        private readonly body: Record<
            string,
            string | number | object | boolean | null
        >,
        private readonly validator: EntityValidator,
    ) {}

    /**
     * Parse the body of the request and call the appropriate callback.
     * @param callbacks The callbacks to call when a specific entity is found.
     * @returns A promise that resolves when the body has been parsed, and the callbacks have finished executing.
     */
    public async parseBody(callbacks: Partial<ParserCallbacks>): Promise<void> {
        if (!this.body.type) throw new Error("Missing type field in body");

        switch (this.body.type) {
            case "Note": {
                const note = await this.validator.Note(this.body);

                if (callbacks.note) await callbacks.note(note);

                break;
            }
            case "Follow": {
                const follow = await this.validator.Follow(this.body);

                if (callbacks.follow) await callbacks.follow(follow);

                break;
            }
            case "FollowAccept": {
                const followAccept = await this.validator.FollowAccept(
                    this.body,
                );

                if (callbacks.followAccept)
                    await callbacks.followAccept(followAccept);

                break;
            }
            case "FollowReject": {
                const followReject = await this.validator.FollowReject(
                    this.body,
                );

                if (callbacks.followReject)
                    await callbacks.followReject(followReject);

                break;
            }
            case "User": {
                const user = await this.validator.User(this.body);

                if (callbacks.user) await callbacks.user(user);

                break;
            }
            case "Like": {
                const like = await this.validator.Like(this.body);

                if (callbacks.like) await callbacks.like(like);

                break;
            }
            case "Dislike": {
                const dislike = await this.validator.Dislike(this.body);

                if (callbacks.dislike) await callbacks.dislike(dislike);

                break;
            }
            case "Undo": {
                const undo = await this.validator.Undo(this.body);

                if (callbacks.undo) await callbacks.undo(undo);

                break;
            }
            case "ServerMetadata": {
                const serverMetadata = await this.validator.ServerMetadata(
                    this.body,
                );

                if (callbacks.serverMetadata)
                    await callbacks.serverMetadata(serverMetadata);

                break;
            }
            case "Extension": {
                const extension = await this.validator.Extension(this.body);

                if (callbacks.extension) await callbacks.extension(extension);

                break;
            }
            default:
                throw new Error(
                    `Invalid type field in body: ${this.body.type}`,
                );
        }
    }
}