fratzinger/feathers-utils

import type { HookContext, Params, Query } from "@feathersjs/feathers";
import { checkContext } from "feathers-hooks-common";
import { getItemsIsArray, shouldSkip } from "../utils";

export interface RemoveRelatedOptions<S = Record<string, any>> {
  service: keyof S;
  keyThere: string;
  keyHere: string;
  blocking?: boolean;
}

/**
 * hook to remove related items
 */
export function removeRelated<
  S = Record<string, any>,
  H extends HookContext = HookContext,
>({
  service,
  keyThere,
  keyHere = "id",
  blocking = true,
}: RemoveRelatedOptions<S>) {
  if (!service || !keyThere) {
    throw "initialize hook 'removeRelated' completely!";
  }
  return async (context: H) => {
    if (shouldSkip("removeRelated", context)) {
      return context;
    }

    checkContext(context, "after", "remove", "removeRelated");

    const { items } = getItemsIsArray(context);

    let ids = items.map((x) => x[keyHere]).filter((x) => !!x);
    ids = [...new Set(ids)];

    if (!ids || ids.length <= 0) {
      return context;
    }

    // feathers does not accept `paginate: false` for remove, but some adapters need it to work properly
    const promise: Promise<any> = context.app
      .service(service as string)
      .remove(null, {
        query: {
          [keyThere]: {
            $in: ids,
          },
        },
        paginate: false,
      } as Params<Query>);

    if (blocking) {
      await promise;
    }

    return context;
  };
}