litlyx/dashboard/server/api/timeline/events.ts

import { EventModel } from "@schema/metrics/EventSchema";
import { Redis } from "~/server/services/CacheService";
import { executeTimelineAggregation, fillAndMergeTimelineAggregationV2 } from "~/server/services/TimelineService";

export default defineEventHandler(async event => {

    const data = await getRequestData(event, { requireSchema: false, requireSlice: true });
    if (!data) return;

    const { pid, from, to, slice, project_id } = data;

    const cacheKey = `timeline:events:${pid}:${slice}:${from}:${to}`;
    const cacheExp = 60;

    return await Redis.useCacheV2(cacheKey, cacheExp, async () => {

        const timelineData = await executeTimelineAggregation({
            projectId: project_id,
            model: EventModel,
            from, to, slice,
        });

        const timelineFilledMerged = fillAndMergeTimelineAggregationV2(timelineData, slice, from, to);

        return timelineFilledMerged;

    });




});