add publish unit tests for mutation hooks

packages/core/src/hooks/data/useCreate.spec.tsx

@@ -29,4 +29,43 @@ describe("useCreate Hook", () => {
  expect(status).toBe("success");
  expect(data?.data.slug).toBe("ut-ad-et");
  });
+
+ describe("usePublish", () => {
+ it("publish live event on success", async () => {
+ const onPublishMock = jest.fn();
+
+ const { result, waitForNextUpdate, waitFor } = renderHook(
+ () => useCreate(),
+ {
+ wrapper: TestWrapper({
+ dataProvider: MockJSONServer,
+ resources: [{ name: "posts" }],
+ liveProvider: {
+ unsubscribe: jest.fn(),
+ subscribe: jest.fn(),
+ publish: onPublishMock,
+ },
+ }),
+ },
+ );
+
+ result.current.mutate({ resource: "posts", values: { id: 1 } });
+
+ await waitForNextUpdate();
+
+ await waitFor(() => {
+ return result.current.isSuccess;
+ });
+
+ expect(onPublishMock).toBeCalled();
+ expect(onPublishMock).toHaveBeenCalledWith({
+ channel: "resources/posts",
+ date: expect.any(Date),
+ type: "created",
+ payload: {
+ ids: ["1"],
+ },
+ });
+ });
+ });
 });

packages/core/src/hooks/data/useCreateMany.spec.tsx

@@ -30,4 +30,46 @@ describe("useCreateMany Hook", () => {
  expect(data?.data[0].slug).toBe("ut-ad-et");
  expect(data?.data[1].slug).toBe("consequatur-molestiae-rerum");
  });
+
+ describe("usePublish", () => {
+ it("publish live event on success", async () => {
+ const onPublishMock = jest.fn();
+
+ const { result, waitForNextUpdate, waitFor } = renderHook(
+ () => useCreateMany(),
+ {
+ wrapper: TestWrapper({
+ dataProvider: MockJSONServer,
+ resources: [{ name: "posts" }],
+ liveProvider: {
+ unsubscribe: jest.fn(),
+ subscribe: jest.fn(),
+ publish: onPublishMock,
+ },
+ }),
+ },
+ );
+
+ result.current.mutate({
+ resource: "posts",
+ values: [{ id: 1 }, { id: 2 }],
+ });
+
+ await waitForNextUpdate();
+
+ await waitFor(() => {
+ return result.current.isSuccess;
+ });
+
+ expect(onPublishMock).toBeCalled();
+ expect(onPublishMock).toHaveBeenCalledWith({
+ channel: "resources/posts",
+ date: expect.any(Date),
+ type: "created",
+ payload: {
+ ids: ["1", "2"],
+ },
+ });
+ });
+ });
 });

packages/core/src/hooks/data/useDelete.spec.tsx

@@ -86,4 +86,46 @@ describe("useDelete Hook", () => {
 
  expect(isSuccess).toBeTruthy();
  });
+
+ describe("usePublish", () => {
+ it("publish live event on success", async () => {
+ const onPublishMock = jest.fn();
+
+ const { result, waitForNextUpdate, waitFor } = renderHook(
+ () => useDelete(),
+ {
+ wrapper: TestWrapper({
+ dataProvider: MockJSONServer,
+ resources: [{ name: "posts" }],
+ liveProvider: {
+ unsubscribe: jest.fn(),
+ subscribe: jest.fn(),
+ publish: onPublishMock,
+ },
+ }),
+ },
+ );
+
+ result.current.mutate({
+ id: "1",
+ resource: "posts",
+ mutationMode: "pessimistic",
+ });
+ await waitForNextUpdate();
+
+ await waitFor(() => {
+ return result.current.isSuccess;
+ });
+
+ expect(onPublishMock).toBeCalled();
+ expect(onPublishMock).toHaveBeenCalledWith({
+ channel: "resources/posts",
+ date: expect.any(Date),
+ type: "deleted",
+ payload: {
+ ids: ["1"],
+ },
+ });
+ });
+ });
 });

packages/core/src/hooks/data/useDeleteMany.spec.tsx

@@ -85,4 +85,45 @@ describe("useDeleteMany Hook", () => {
 
  expect(isSuccess).toBeTruthy();
  });
+
+ describe("usePublish", () => {
+ it("publish live event on success", async () => {
+ const onPublishMock = jest.fn();
+
+ const { result, waitForNextUpdate, waitFor } = renderHook(
+ () => useDeleteMany(),
+ {
+ wrapper: TestWrapper({
+ dataProvider: MockJSONServer,
+ resources: [{ name: "posts" }],
+ liveProvider: {
+ unsubscribe: jest.fn(),
+ subscribe: jest.fn(),
+ publish: onPublishMock,
+ },
+ }),
+ },
+ );
+
+ result.current.mutate({
+ resource: "posts",
+ ids: ["1", "2"],
+ });
+ await waitForNextUpdate();
+
+ await waitFor(() => {
+ return result.current.isSuccess;
+ });
+
+ expect(onPublishMock).toBeCalled();
+ expect(onPublishMock).toHaveBeenCalledWith({
+ channel: "resources/posts",
+ date: expect.any(Date),
+ type: "deleted",
+ payload: {
+ ids: ["1", "2"],
+ },
+ });
+ });
+ });
 });

packages/core/src/hooks/data/useDeleteMany.ts

@@ -221,7 +221,7 @@ export const useDeleteMany = <
  publish?.({
  channel: `resources/${resource}`,
  type: "deleted",
- payload: ids.map(String),
+ payload: { ids: ids.map(String) },
  date: new Date(),
  });
  },

packages/core/src/hooks/data/useUpdate.spec.tsx

@@ -89,4 +89,48 @@ describe("useUpdate Hook", () => {
 
  expect(isSuccess).toBeTruthy();
  });
+
+ describe("usePublish", () => {
+ it("publish live event on success", async () => {
+ const onPublishMock = jest.fn();
+
+ const { result, waitForNextUpdate, waitFor } = renderHook(
+ () => useUpdate(),
+ {
+ wrapper: TestWrapper({
+ dataProvider: MockJSONServer,
+ resources: [{ name: "posts" }],
+ liveProvider: {
+ unsubscribe: jest.fn(),
+ subscribe: jest.fn(),
+ publish: onPublishMock,
+ },
+ }),
+ },
+ );
+
+ result.current.mutate({
+ resource: "posts",
+ mutationMode: "undoable",
+ undoableTimeout: 0,
+ id: "1",
+ values: { id: "1", title: "undoable test" },
+ });
+ await waitForNextUpdate();
+
+ await waitFor(() => {
+ return result.current.isSuccess;
+ });
+
+ expect(onPublishMock).toBeCalled();
+ expect(onPublishMock).toHaveBeenCalledWith({
+ channel: "resources/posts",
+ date: expect.any(Date),
+ type: "updated",
+ payload: {
+ ids: ["1"],
+ },
+ });
+ });
+ });
 });

packages/core/src/hooks/data/useUpdateMany.spec.tsx

@@ -116,4 +116,48 @@ describe("useUpdateMany Hook", () => {
 
  expect(isSuccess).toBeTruthy();
  });
+
+ describe("usePublish", () => {
+ it("publish live event on success", async () => {
+ const onPublishMock = jest.fn();
+
+ const { result, waitForNextUpdate, waitFor } = renderHook(
+ () => useUpdateMany(),
+ {
+ wrapper: TestWrapper({
+ dataProvider: MockJSONServer,
+ resources: [{ name: "posts" }],
+ liveProvider: {
+ unsubscribe: jest.fn(),
+ subscribe: jest.fn(),
+ publish: onPublishMock,
+ },
+ }),
+ },
+ );
+
+ result.current.mutate({
+ resource: "posts",
+ mutationMode: "undoable",
+ undoableTimeout: 0,
+ ids: ["1", "2"],
+ values: { id: "1", title: "undoable test" },
+ });
+ await waitForNextUpdate();
+
+ await waitFor(() => {
+ return result.current.isSuccess;
+ });
+
+ expect(onPublishMock).toBeCalled();
+ expect(onPublishMock).toHaveBeenCalledWith({
+ channel: "resources/posts",
+ date: expect.any(Date),
+ type: "updated",
+ payload: {
+ ids: ["1", "2"],
+ },
+ });
+ });
+ });
 });

packages/core/src/hooks/data/useUpdateMany.ts

@@ -272,7 +272,9 @@ export const useUpdateMany = <
  publish?.({
  channel: `resources/${resource}`,
  type: "updated",
- payload: ids.map(String),
+ payload: {
+ ids: ids.map(String),
+ },
  date: new Date(),
  });
  },