commerce/lib/shopify/payload.ts

import { ajax } from 'lib/shopify/ajax';
import { Config } from 'lib/shopify/payload-types';
import qs from 'qs';

type Collection = keyof Config['collections'];

const OPERATORS = [
  'equals',
  'contains',
  'not_equals',
  'in',
  'all',
  'not_in',
  'exists',
  'greater_than',
  'greater_than_equal',
  'less_than',
  'less_than_equal',
  'like',
  'within',
  'intersects',
  'near'
] as const;

type Operator = (typeof OPERATORS)[number];
type WhereField = {
  // eslint-disable-next-line no-unused-vars
  [key in Operator]?: unknown;
};
export type Where = {
  [key: string]: Where[] | WhereField | undefined;
  and?: Where[];
  or?: Where[];
};

export type PaginatedDocs<T> = {
  docs: T[];
  hasNextPage: boolean;
  hasPrevPage: boolean;
  limit: number;
  nextPage?: null | number;
  page?: number;
  pagingCounter: number;
  prevPage?: null | number;
  totalDocs: number;
  totalPages: number;
};

type Doc<T> = {
  message: string;
  doc: T;
};

type FindParams = {
  where?: Where;
  depth?: number;
  sort?: string;
  page?: number;
  limit?: number;
};

export const find = <T>(collection: Collection, params: FindParams) => {
  const query = qs.stringify(params, { addQueryPrefix: true });

  const url = `${process.env.CMS_URL}/api/${collection}${query}`;
  return ajax<PaginatedDocs<T>>('GET', url);
};

export const findByID = <T>(collection: Collection, id: string) => {
  const url = `${process.env.CMS_URL}/api/${collection}/${id}`;
  return ajax<T>('GET', url);
};

export const create = <T extends object>(collection: Collection, body: Partial<T>) => {
  const url = `${process.env.CMS_URL}/api/${collection}`;
  return ajax<Doc<T>>('POST', url, body);
};

export const update = <T extends object>(collection: Collection, id: string, body: Partial<T>) => {
  const url = `${process.env.CMS_URL}/api/${collection}/${id}`;
  return ajax<Doc<T>>('PATCH', url, body);
};