libs/internal-sdk/src/react-query/activityChartsRetrieve.core.ts - next - githubmirror/novu

libs/internal-sdk/src/react-query/activityChartsRetrieve.core.ts

95 строк3 KB

George Djabarov

refactor(api-service): standardize subscription identifier usage across endpoints fixes NV-6982 (#9694)

26 дек 2025, 00:03

26 дек 2025, 00:033dca011

/*
 * Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.
 */

import {
  QueryClient,
  QueryFunctionContext,
  QueryKey,
} from "@tanstack/react-query";
import { NovuCore } from "../core.js";
import { activityChartsRetrieve } from "../funcs/activityChartsRetrieve.js";
import { combineSignals } from "../lib/primitives.js";
import { RequestOptions } from "../lib/sdks.js";
import * as components from "../models/components/index.js";
import * as operations from "../models/operations/index.js";
import { unwrapAsync } from "../types/fp.js";
export type ActivityChartsRetrieveQueryData = components.GetChartsResponseDto;

export function prefetchActivityChartsRetrieve(
  queryClient: QueryClient,
  client$: NovuCore,
  request: operations.ActivityControllerGetChartsRequest,
  options?: RequestOptions,
): Promise<void> {
  return queryClient.prefetchQuery({
    ...buildActivityChartsRetrieveQuery(
      client$,
      request,
      options,
    ),
  });
}

export function buildActivityChartsRetrieveQuery(
  client$: NovuCore,
  request: operations.ActivityControllerGetChartsRequest,
  options?: RequestOptions,
): {
  queryKey: QueryKey;
  queryFn: (
    context: QueryFunctionContext,
  ) => Promise<ActivityChartsRetrieveQueryData>;
} {
  return {
    queryKey: queryKeyActivityChartsRetrieve({
      createdAtGte: request.createdAtGte,
      createdAtLte: request.createdAtLte,
      reportType: request.reportType,
      workflowIds: request.workflowIds,
      subscriberIds: request.subscriberIds,
      transactionIds: request.transactionIds,
      statuses: request.statuses,
      channels: request.channels,
      topicKey: request.topicKey,
      idempotencyKey: request.idempotencyKey,
    }),
    queryFn: async function activityChartsRetrieveQueryFn(
      ctx,
    ): Promise<ActivityChartsRetrieveQueryData> {
      const sig = combineSignals(
        ctx.signal,
        options?.signal,
        options?.fetchOptions?.signal,
      );
      const mergedOptions = {
        ...options?.fetchOptions,
        ...options,
        signal: sig,
      };

      return unwrapAsync(activityChartsRetrieve(
        client$,
        request,
        mergedOptions,
      ));
    },
  };
}

export function queryKeyActivityChartsRetrieve(
  parameters: {
    createdAtGte?: string | undefined;
    createdAtLte?: string | undefined;
    reportType: Array<operations.ReportType>;
    workflowIds?: Array<string> | undefined;
    subscriberIds?: Array<string> | undefined;
    transactionIds?: Array<string> | undefined;
    statuses?: Array<operations.Statuses> | undefined;
    channels?: Array<string> | undefined;
    topicKey?: string | undefined;
    idempotencyKey?: string | undefined;
  },
): QueryKey {
  return ["@novu/api", "Charts", "retrieve", parameters];
}