Sidebar 160426

__tests__/components/brain/my-stream/MyStreamWave.register.test.tsx

@@ -0,0 +1,157 @@
+import { render, waitFor } from "@testing-library/react";
+import MyStreamWave from "@/components/brain/my-stream/MyStreamWave";
+
+const mockRegisterWave = jest.fn();
+const mockSetQueryData = jest.fn();
+const mockSetWaveData = jest.fn();
+const mockSetViewMode = jest.fn();
+const mockToggleViewMode = jest.fn();
+const mockPush = jest.fn();
+const mockReplace = jest.fn();
+const mockSearchParams = {
+  get: jest.fn(),
+  toString: jest.fn(),
+};
+const mockWave = {
+  id: "wave-1",
+  name: "Wave 1",
+  participation: {},
+  metrics: {},
+} as any;
+
+jest.mock("@tanstack/react-query", () => ({
+  useQueryClient: () => ({
+    setQueryData: mockSetQueryData,
+  }),
+}));
+
+jest.mock("next/navigation", () => ({
+  usePathname: () => "/waves/wave-1",
+  useRouter: () => ({
+    push: mockPush,
+    replace: mockReplace,
+  }),
+  useSearchParams: () => mockSearchParams,
+}));
+
+jest.mock("react-use", () => ({
+  createBreakpoint: () => () => "LG",
+}));
+
+jest.mock("@/contexts/TitleContext", () => ({
+  useSetWaveData: (waveData: unknown) => mockSetWaveData(waveData),
+}));
+
+jest.mock("@/components/react-query-wrapper/ReactQueryWrapper", () => ({
+  QueryKey: {
+    DROP: "DROP",
+  },
+}));
+
+jest.mock("@/components/brain/ContentTabContext", () => ({
+  useContentTab: () => ({
+    activeContentTab: "CHAT",
+  }),
+}));
+
+jest.mock("@/hooks/useWaveData", () => ({
+  useWaveData: () => ({
+    data: mockWave,
+  }),
+}));
+
+jest.mock("@/contexts/wave/MyStreamContext", () => ({
+  useMyStream: () => ({
+    waves: { list: [] },
+    directMessages: { list: [] },
+    registerWave: mockRegisterWave,
+  }),
+}));
+
+jest.mock("@/hooks/useWaveViewMode", () => ({
+  useWaveViewMode: () => ({
+    viewMode: "chat",
+    setViewMode: mockSetViewMode,
+    toggleViewMode: mockToggleViewMode,
+  }),
+}));
+
+jest.mock("@/hooks/useWave", () => ({
+  useWave: () => ({
+    isRankWave: false,
+    isMemesWave: false,
+    isDm: false,
+  }),
+}));
+
+jest.mock("@/hooks/useDeviceInfo", () => ({
+  __esModule: true,
+  default: () => ({ isApp: false }),
+}));
+
+jest.mock("@/components/brain/my-stream/MyStreamWaveChat", () => ({
+  __esModule: true,
+  default: () => <div data-testid="chat" />,
+}));
+
+jest.mock(
+  "@/components/brain/my-stream/curations/MyStreamWaveCurationContent",
+  () => ({
+    __esModule: true,
+    default: () => <div data-testid="curation" />,
+  })
+);
+
+jest.mock("@/components/brain/my-stream/MyStreamWaveLeaderboard", () => ({
+  __esModule: true,
+  default: () => <div data-testid="leaderboard" />,
+}));
+
+jest.mock("@/components/brain/my-stream/MyStreamWaveSubmissions", () => ({
+  __esModule: true,
+  default: () => <div data-testid="submissions" />,
+}));
+
+jest.mock("@/components/brain/my-stream/MyStreamWaveOutcome", () => ({
+  __esModule: true,
+  default: () => <div data-testid="outcome" />,
+}));
+
+jest.mock("@/components/waves/winners/WaveWinners", () => ({
+  WaveWinners: () => <div data-testid="winners" />,
+}));
+
+jest.mock("@/components/brain/my-stream/tabs/MyStreamWaveTabs", () => ({
+  MyStreamWaveTabs: () => <div data-testid="tabs" />,
+}));
+
+jest.mock("@/components/brain/my-stream/votes/MyStreamWaveMyVotes", () => ({
+  __esModule: true,
+  default: () => <div data-testid="my-votes" />,
+}));
+
+jest.mock("@/components/brain/my-stream/MyStreamWaveFAQ", () => ({
+  __esModule: true,
+  default: () => <div data-testid="faq" />,
+}));
+
+jest.mock("@/components/brain/my-stream/MyStreamWaveSales", () => ({
+  __esModule: true,
+  default: () => <div data-testid="sales" />,
+}));
+
+describe("MyStreamWave registration", () => {
+  beforeEach(() => {
+    jest.clearAllMocks();
+    mockSearchParams.get.mockReturnValue(null);
+    mockSearchParams.toString.mockReturnValue("");
+  });
+
+  it("registers the mounted wave for direct URL loads", async () => {
+    render(<MyStreamWave waveId="wave-1" />);
+
+    await waitFor(() => {
+      expect(mockRegisterWave).toHaveBeenCalledWith("wave-1", true);
+    });
+  });
+});

__tests__/components/react-query-wrapper/utils/increaseWavesOverviewDropsCount.test.ts

@@ -1,30 +1,122 @@
-import { QueryClient } from '@tanstack/react-query';
-import { increaseWavesOverviewDropsCount } from '@/components/react-query-wrapper/utils/increaseWavesOverviewDropsCount';
-import { ApiWavesOverviewType } from '@/generated/models/ApiWavesOverviewType';
-import { QueryKey } from '@/components/react-query-wrapper/ReactQueryWrapper';
+import { QueryClient } from "@tanstack/react-query";
+import { increaseWavesOverviewDropsCount } from "@/components/react-query-wrapper/utils/increaseWavesOverviewDropsCount";
+import { ApiWavesOverviewType } from "@/generated/models/ApiWavesOverviewType";
+import { ApiWavesPinFilter } from "@/generated/models/ApiWavesPinFilter";
+import { QueryKey } from "@/components/react-query-wrapper/ReactQueryWrapper";
 
 function createWave(id: string) {
-  return { id, metrics: { drops_count: 0, your_drops_count: 0 } } as any;
+  return {
+    id,
+    last_drop_time: 0,
+    metrics: {
+      drops_count: 0,
+      your_drops_count: 0,
+      latest_drop_timestamp: 0,
+      your_latest_drop_timestamp: 0,
+    },
+  } as any;
 }
 
-describe('increaseWavesOverviewDropsCount', () => {
-  it('increments drops count for all overview types', async () => {
+describe("increaseWavesOverviewDropsCount", () => {
+  afterEach(() => {
+    jest.restoreAllMocks();
+  });
+
+  it("increments drops count for all overview types", async () => {
     const client = new QueryClient();
-    const wave = createWave('w1');
+    const wave = createWave("w1");
     const data = { pages: [[wave]] };
 
     for (const type of Object.values(ApiWavesOverviewType)) {
-      const key = [QueryKey.WAVES_OVERVIEW, { limit: 20, type, only_waves_followed_by_authenticated_user: true }];
+      const key = [
+        QueryKey.WAVES_OVERVIEW,
+        { limit: 20, type, only_waves_followed_by_authenticated_user: true },
+      ];
       client.setQueryData(key, data);
     }
 
-    await increaseWavesOverviewDropsCount(client, 'w1');
+    await increaseWavesOverviewDropsCount(client, "w1");
 
     for (const type of Object.values(ApiWavesOverviewType)) {
-      const key = [QueryKey.WAVES_OVERVIEW, { limit: 20, type, only_waves_followed_by_authenticated_user: true }];
+      const key = [
+        QueryKey.WAVES_OVERVIEW,
+        { limit: 20, type, only_waves_followed_by_authenticated_user: true },
+      ];
       const result: any = client.getQueryData(key);
       expect(result?.pages?.[0][0].metrics.drops_count).toBe(1);
       expect(result?.pages?.[0][0].metrics.your_drops_count).toBe(1);
     }
   });
+
+  it("updates pinned overview array caches", async () => {
+    jest.spyOn(Date, "now").mockReturnValue(1234);
+    const client = new QueryClient();
+    const wave = createWave("w1");
+    const other = createWave("w2");
+    const key = [
+      QueryKey.WAVES_OVERVIEW,
+      { pinned: ApiWavesPinFilter.Pinned, viewer_identity: "0xabc" },
+    ];
+    client.setQueryData(key, [wave, other]);
+
+    await increaseWavesOverviewDropsCount(client, "w1");
+
+    const result: any = client.getQueryData(key);
+    expect(result[0].metrics.drops_count).toBe(1);
+    expect(result[0].metrics.your_drops_count).toBe(1);
+    expect(result[0].metrics.latest_drop_timestamp).toBe(1234);
+    expect(result[0].metrics.your_latest_drop_timestamp).toBe(1234);
+    expect(result[0].last_drop_time).toBe(1234);
+    expect(result[1]).toEqual(other);
+  });
+
+  it("preserves infinite overview page structure", async () => {
+    const client = new QueryClient();
+    const waveOne = createWave("w1");
+    const waveTwo = createWave("w2");
+    const key = [
+      QueryKey.WAVES_OVERVIEW,
+      {
+        limit: 20,
+        type: ApiWavesOverviewType.RecentlyDroppedTo,
+        only_waves_followed_by_authenticated_user: true,
+      },
+    ];
+    client.setQueryData(key, {
+      pages: [[waveOne], [waveTwo]],
+      pageParams: [undefined, 1],
+    });
+
+    await increaseWavesOverviewDropsCount(client, "w2");
+
+    const result: any = client.getQueryData(key);
+    expect(result.pages).toHaveLength(2);
+    expect(result.pages[0]).toEqual([waveOne]);
+    expect(result.pages[1]).toHaveLength(1);
+    expect(result.pages[1][0].id).toBe("w2");
+    expect(result.pages[1][0].metrics.drops_count).toBe(1);
+    expect(result.pageParams).toEqual([undefined, 1]);
+  });
+
+  it("leaves unrelated overview caches untouched", async () => {
+    const client = new QueryClient();
+    const key = [
+      QueryKey.WAVES_OVERVIEW,
+      {
+        limit: 20,
+        type: ApiWavesOverviewType.RecentlyDroppedTo,
+        only_waves_followed_by_authenticated_user: true,
+      },
+    ];
+    const data = { pages: [[createWave("other")]], pageParams: [undefined] };
+    client.setQueryData(key, data);
+    const cancelSpy = jest.spyOn(client, "cancelQueries");
+    const setQueryDataSpy = jest.spyOn(client, "setQueryData");
+
+    await increaseWavesOverviewDropsCount(client, "missing");
+
+    expect(cancelSpy).not.toHaveBeenCalled();
+    expect(setQueryDataSpy).not.toHaveBeenCalled();
+    expect(client.getQueryData(key)).toBe(data);
+  });
 });