server/api/messaging/index.ts

import { apiRoute, applyConfig } from "@/api";
import { createRoute } from "@hono/zod-openapi";
import { getLogger } from "@logtape/logtape";
import chalk from "chalk";
import { z } from "zod";

export const meta = applyConfig({
    auth: {
        required: false,
    },
    ratelimits: {
        duration: 60,
        max: 500,
    },
    route: "/messaging",
});

const route = createRoute({
    method: "post",
    path: "/messaging",
    summary: "Endpoint for the Instance Messaging Versia Extension.",
    description: "https://versia.pub/extensions/instance-messaging.",
    request: {
        body: {
            content: {
                "text/plain": {
                    schema: z.string(),
                },
            },
        },
    },
    responses: {
        200: {
            description: "Message saved",
        },
    },
});

export default apiRoute((app) =>
    app.openapi(route, async (context) => {
        const content = await context.req.text();

        getLogger(["federation", "messaging"])
            .info`Received message via ${chalk.bold("Instance Messaging")}:\n${content}`;

        return context.body(null, 200);
    }),
);