Detect more changes by actually comparing previous state and current state

src/hooks/afterOperationSendChangesWebhook.ts

@@ -13,47 +13,64 @@ import {
   Relationship,
   Video,
 } from "../types/collections";
-import { isPayloadType } from "../utils/asserts";
+import { isDefined, isPayloadType } from "../utils/asserts";
 import {
   AfterChangeHook,
   AfterDeleteHook,
+  BeforeChangeHook,
   BeforeDeleteHook,
 } from "payload/dist/collections/config/types";
 import { GeneratedTypes } from "payload";
 import { uniqueBy } from "../utils/array";
 import { GlobalAfterChangeHook } from "payload/types";
 import { findRelationByID } from "payloadcms-relationships/dist/utils";
-import { RelationshipRemoved } from "payloadcms-relationships";
 
-export const afterOutgoingRelationRemovedSendChangesWebhook = async ({
-  removedOutgoingRelations,
-}: RelationshipRemoved) => {
-  const changes: EndpointChange[] = [];
+export const beforeChangePrepareChanges: BeforeChangeHook = async ({
+  collection,
+  originalDoc,
+  context,
+  data,
+}) => {
+  if ("_status" in data && data._status === "draft") return data;
+  if (!originalDoc) return data;
 
-  removedOutgoingRelations?.forEach((relation) =>
-    changes.push(...getEndpointChangesFromOutgoingRelation(relation))
+  context.beforeChangeChanges = await getChanges(
+    collection.slug as keyof GeneratedTypes["collections"],
+    originalDoc
   );
 
-  await sendWebhookMessage(uniqueBy(changes, ({ url }) => url));
+  return data;
 };
 
-export const afterChangeSendChangesWebhook: AfterChangeHook = async ({ doc, collection }) => {
+export const afterChangeSendChangesWebhook: AfterChangeHook = async ({
+  doc,
+  collection,
+  context,
+}) => {
   if ("_status" in doc && doc._status === "draft") return doc;
 
   const changes = await getChanges(collection.slug as keyof GeneratedTypes["collections"], doc);
-  await sendWebhookMessage(changes);
+  const previousChanges = context.beforeChangeChanges as EndpointChange[] | undefined;
 
+  if (isDefined(previousChanges)) {
+    await sendWebhookMessage(uniqueBy([...previousChanges, ...changes], ({ url }) => url));
+  } else {
+    await sendWebhookMessage(changes);
+  }
+ 
   return doc;
 };
 
 export const beforeDeletePrepareChanges: BeforeDeleteHook = async ({ id, collection, context }) => {
-  const changes = await getChanges(collection.slug as keyof GeneratedTypes["collections"], { id });
-  context.beforeDeleteChanges = changes;
+  context.beforeDeleteChanges = await getChanges(
+    collection.slug as keyof GeneratedTypes["collections"],
+    { id }
+  );
 };
 
 export const afterDeleteSendChangesWebhook: AfterDeleteHook = async ({ doc, context }) => {
   const changes = context.beforeDeleteChanges as EndpointChange[] | undefined;
-  if (changes) {
+  if (isDefined(changes)) {
     await sendWebhookMessage(changes);
   }
   return doc;

src/payload.config.ts

@@ -33,7 +33,6 @@ import { Collections } from "./shared/payload/constants";
 import { relationshipsPlugin } from "payloadcms-relationships";
 import { shownOnlyToAdmin } from "./accesses/collections/shownOnlyToAdmin";
 import { mustBeAdmin } from "./accesses/fields/mustBeAdmin";
-import { afterOutgoingRelationRemovedSendChangesWebhook } from "./hooks/afterOperationSendChangesWebhook";
 
 const configuredSftpAdapter = sftpAdapter({
   connectOptions: {
@@ -111,7 +110,6 @@ export default buildConfig({
           delete: mustBeAdmin,
         },
       },
-      onOutgoingRelationRemoved: afterOutgoingRelationRemovedSendChangesWebhook,
     }),
 
     cloudStorage({

src/utils/collectionConfig.ts

@@ -4,6 +4,7 @@ import { formatToPascalCase } from "./string";
 import {
   afterChangeSendChangesWebhook,
   afterDeleteSendChangesWebhook,
+  beforeChangePrepareChanges,
   beforeDeletePrepareChanges,
 } from "../hooks/afterOperationSendChangesWebhook";
 
@@ -22,6 +23,7 @@ export const buildCollectionConfig = (config: BuildCollectionConfig): Collection
   typescript: { interface: formatToPascalCase(config.labels.singular) },
   hooks: {
     ...config.hooks,
+    beforeChange: [...(config.hooks?.beforeChange ?? []), beforeChangePrepareChanges],
     afterChange: [...(config.hooks?.afterChange ?? []), afterChangeSendChangesWebhook],
     beforeDelete: [...(config.hooks?.beforeDelete ?? []), beforeDeletePrepareChanges],
     afterDelete: [...(config.hooks?.afterDelete ?? []), afterDeleteSendChangesWebhook],