Pusher

import { appEnvironment, defineConfig, PUSHER_DEFAULTS, pusherService } from "@danwo/sdk"

const { app } = PUSHER_DEFAULTS

export default defineConfig({
  testDir: "tests",
  readiness: { mode: "page+backend", settle: true },
  environment: () =>
    appEnvironment({
      app: {
        command: "npm run dev",
        url: "http://localhost:3000",
        env: {
          PUSHER_APP_ID: app.id,
          PUSHER_KEY: app.key,
          PUSHER_SECRET: app.secret,
          PUSHER_CLUSTER: app.cluster,
          NEXT_PUBLIC_PUSHER_KEY: app.key,
          NEXT_PUBLIC_PUSHER_CLUSTER: app.cluster,
        },
      },
      services: [pusherService()],
    }),
})

pusherService({
  seed: {
    apps: [
      {
        id: "1000001",
        key: "my-key",
        secret: "my-secret",
        cluster: "eu",
        subscriptionCounting: true,
        webhooks: [
          { url: "http://localhost:3000/api/pusher", events: ["channel_occupied", "member_added"] },
        ],
      },
    ],
    beams: [{ instanceId: "my-instance", secretKey: "my-beams-secret" }],
  },
})

import { type PusherFixtures, pusherChannels, test as base } from "@danwo/sdk"

const test = base.extend<PusherFixtures>()

test("shows a new order without a reload", async ({ app, screen, expect, pusher }) => {
  await app.open("/orders")
  await screen.getByRole("button", { name: "Place order" }).click()

  await expect(screen.getByRole("status")).toHaveText("Order o_1 placed")

  const event = await pusherChannels(pusher).waitFor("orders", "order.placed")

  expect(event.delivered_to).toHaveLength(1)
  expect(pusherChannels(pusher).events({ channel: "orders" })).toHaveLength(1)
})