pankod/refine

import { CrudSorting, MetaQuery, Pagination } from "@refinedev/core";
import * as gql from "gql-query-builder";

import { HasuraCrudFilters, generateFilters } from "./generateFilters";
import { generateSorting } from "./generateSorting";
import { getOperationFields } from "./graphql";

type GenerateUseListSubscriptionParams = {
  resource: string;
  meta: MetaQuery;
  pagination?: Pagination;
  sorters?: CrudSorting;
  filters?: HasuraCrudFilters;
};

type GenerateUseListSubscriptionReturnValues = {
  variables: any;
  query: string;
  operation: string;
};

export const generateUseListSubscription = ({
  resource,
  meta,
  pagination,
  sorters,
  filters,
}: GenerateUseListSubscriptionParams): GenerateUseListSubscriptionReturnValues => {
  const {
    current = 1,
    pageSize: limit = 10,
    mode = "server",
  } = pagination ?? {};

  const hasuraSorting = generateSorting(sorters);
  const hasuraFilters = generateFilters(filters, "hasura-default");

  const operation = meta.operation ?? resource;

  const hasuraSortingType = `[${operation}_order_by!]`;
  const hasuraFiltersType = `${operation}_bool_exp`;

  const gqlOperation = meta?.gqlQuery ?? meta?.gqlMutation;
  if (gqlOperation) {
    const query = `
            subscription ${operation}($limit: Int, $offset: Int, $order_by: ${hasuraSortingType}, $where: ${hasuraFiltersType} ) {
                ${operation}( limit: $limit, offset: $offset, order_by: $order_by, where: $where ) {
                    ${getOperationFields(gqlOperation)}
                }
            }
        `;

    const variables = {
      ...(mode === "server"
        ? {
            limit,
            offset: (current - 1) * limit,
          }
        : {}),
      ...(hasuraSorting && {
        order_by: hasuraSorting,
      }),
      ...(hasuraFilters && {
        where: hasuraFilters,
      }),
    };

    return { query, variables, operation };
  }

  const { query, variables } = gql.subscription([
    {
      operation,
      fields: meta.fields,
      variables: {
        ...(mode === "server"
          ? {
              limit,
              offset: (current - 1) * limit,
            }
          : {}),
        ...(hasuraSorting && {
          order_by: {
            value: hasuraSorting,
            type: hasuraSortingType,
          },
        }),
        ...(hasuraFilters && {
          where: {
            value: hasuraFilters,
            type: hasuraFiltersType,
          },
        }),
      },
    },
  ]);

  return { query, variables, operation };
};

/**
 * @deprecated Please use `generateUseListSubscription` instead.
 */
export const genereteUseListSubscription = generateUseListSubscription;