This repository has no description
Something went wrong. Try again.
2.0 kB · 65 lines
TypeScript
at main
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566// SPDX-License-Identifier: AGPL-3.0-or-later
import { ReadStateAckBulkRequest, ReadStateAckRequest, ReadStateAckResponse,} from '@fluxer/schema/src/domains/channel/ChannelRequestSchemas';import type {Hono} from 'hono';import {DefaultUserOnly, LoginRequired} from '../middleware/AuthMiddleware';import {RateLimitMiddleware} from '../middleware/RateLimitMiddleware';import {OpenAPI} from '../middleware/ResponseTypeMiddleware';import {RateLimitConfigs} from '../RateLimitConfig';import type {HonoEnv} from '../types/HonoEnv';import {Validator} from '../Validator';
export function ReadStateController(app: Hono<HonoEnv>): void { app.post( '/read-states/ack', RateLimitMiddleware(RateLimitConfigs.READ_STATE_ACK_BULK), LoginRequired, DefaultUserOnly, OpenAPI({ operationId: 'ack_read_states', summary: 'Acknowledge read states', description: 'Applies one or more read-state acknowledgements and returns the authoritative read states after the write.', responseSchema: ReadStateAckResponse, statusCode: 200, security: ['bearerToken', 'sessionToken'], tags: ['Read States'], }), Validator('json', ReadStateAckRequest), async (ctx) => { return ctx.json( await ctx.get('readStateRequestService').ackReadStates({ userId: ctx.get('user').id, data: ctx.req.valid('json'), }), ); }, ); app.post( '/read-states/ack-bulk', RateLimitMiddleware(RateLimitConfigs.READ_STATE_ACK_BULK), LoginRequired, DefaultUserOnly, OpenAPI({ operationId: 'ack_bulk_messages', summary: 'Mark channels as read', description: 'Marks multiple channels as read for the authenticated user in bulk.', responseSchema: null, statusCode: 204, security: ['bearerToken', 'sessionToken'], tags: ['Read States'], }), Validator('json', ReadStateAckBulkRequest), async (ctx) => { await ctx.get('readStateRequestService').bulkAckMessages({ userId: ctx.get('user').id, data: ctx.req.valid('json'), }); return ctx.body(null, 204); }, );}