Changelog

All notable changes to PubSubJS packages are documented here. This project uses Changesets for versioning.

Core WebSocket Redis SSE React

@pubsubjs/core

0.4.0

Minor Changes

61f520c: Add dynamic handler registration with per-handler unsubscribe

on() now returns an UnsubscribeFn to remove a specific handler (breaking: was this)

off() now returns void and tears down the transport subscription (breaking: was this)

onMany() now returns an UnsubscribeFn to remove all registered handlers (breaking: was this)

Multiple handlers can be registered for the same event — each receives messages independently

Per-handler error isolation: one handler throwing does not affect other handlers on the same event

Per-handler filter support: each handler can have its own filter policy via on() options

Late-binding: handlers registered after subscribe() auto-subscribe to the transport

Reference counting: transport subscription is removed when the last handler for an event is unsubscribed

0.3.0

Minor Changes

7c2d65d: Improve TypeScript types for transport events and WebSocket options

Breaking change for TypeScript users: Transport event handlers now receive typed event data objects instead of unknown.

onUpgrade type fix

The onUpgrade callback in WebSocketServerTransport now correctly accepts Record instead of requiring the full WebSocketData type. This matches the actual runtime behavior where connectionId and subscriptions are generated internally.

  // Before (required type assertion)
  const transport = new WebSocketServerTransport({
    onUpgrade: (req) => ({ userId: "123" } as WebSocketData),
  });

  // After (no assertion needed)
  const transport = new WebSocketServerTransport({
    onUpgrade: (req) => ({ userId: "123" }),
  });
  

Typed transport events

Transport events now have properly typed handlers via TransportEventMap:

  // Event data is now typed
  transport.on("connect", ({ connectionId }) => {
    console.log(connectionId); // string | undefined
  });

  transport.on("error", ({ error }) => {
    console.error(error); // Error | undefined
  });
  

0.2.1

Patch Changes

5893d56: Fix npm publishing to use proper semver ranges instead of workspace:\* protocol

0.2.0

Minor Changes

e32a69b: Add attribute-based event filtering at the transport level

Add FilterPolicy type with operators: $in, $exists, $prefix, $ne, $gt, $gte, $lt, $lte, $between

Add EventAttributes type for attaching filterable attributes to events

Add matchesFilter() function for evaluating filter policies

Add toSNSFilterPolicy() for AWS SNS compatibility

Update PublishOptions to accept attributes

Update Subscriber.on() to accept filter option

Implement client-side filtering in WebSocket, Redis, and SSE transports

Support nested attributes via dot notation (e.g., "user.role")

Filter semantics:

Multiple conditions on same key = OR (at least one must match)

Multiple keys = AND (all must match)

0.1.2

Patch Changes

10c33d0: Fix release workflow - remove prepublishOnly, mark examples as private

0.1.1

Patch Changes

00be192: Improve README with documentation and quick start guide

@pubsubjs/transport-websocket

0.4.0

Patch Changes

Updated dependencies [61f520c]

@pubsubjs/core@0.4.0

0.3.0

Patch Changes

7c2d65d: Improve TypeScript types for transport events and WebSocket options

Breaking change for TypeScript users: Transport event handlers now receive typed event data objects instead of unknown.

onUpgrade type fix

The onUpgrade callback in WebSocketServerTransport now correctly accepts Record instead of requiring the full WebSocketData type. This matches the actual runtime behavior where connectionId and subscriptions are generated internally.

  // Before (required type assertion)
  const transport = new WebSocketServerTransport({
    onUpgrade: (req) => ({ userId: "123" } as WebSocketData),
  });

  // After (no assertion needed)
  const transport = new WebSocketServerTransport({
    onUpgrade: (req) => ({ userId: "123" }),
  });
  

Typed transport events

Transport events now have properly typed handlers via TransportEventMap:

  // Event data is now typed
  transport.on("connect", ({ connectionId }) => {
    console.log(connectionId); // string | undefined
  });

  transport.on("error", ({ error }) => {
    console.error(error); // Error | undefined
  });
  

Updated dependencies [7c2d65d]

@pubsubjs/core@0.3.0

0.2.1

Patch Changes

5893d56: Fix npm publishing to use proper semver ranges instead of workspace:\* protocol

Updated dependencies [5893d56]

@pubsubjs/core@0.2.1

0.2.0

Minor Changes

e32a69b: Add attribute-based event filtering at the transport level

Add FilterPolicy type with operators: $in, $exists, $prefix, $ne, $gt, $gte, $lt, $lte, $between

Add EventAttributes type for attaching filterable attributes to events

Add matchesFilter() function for evaluating filter policies

Add toSNSFilterPolicy() for AWS SNS compatibility

Update PublishOptions to accept attributes

Update Subscriber.on() to accept filter option

Implement client-side filtering in WebSocket, Redis, and SSE transports

Support nested attributes via dot notation (e.g., "user.role")

Filter semantics:

Multiple conditions on same key = OR (at least one must match)

Multiple keys = AND (all must match)

5b6a4d6: Add composable mode for integrating WebSocket transport with external Bun.serve()

Standalone mode (existing behavior)

creates its own server:

  const transport = new WebSocketServerTransport({ port: 3000 });
  await transport.connect();
  

Composable mode (new)

integrates with external server:

  const transport = new WebSocketServerTransport(); // no port
  await transport.connect();

  Bun.serve({
    fetch(req, server) {
      if (req.headers.get("upgrade") === "websocket") {
        return transport.handleUpgrade(req, server);
      }
      return new Response("Hello");
    },
    websocket: transport.websocketHandler,
  });
  

New APIs:

websocketHandler - WebSocket handler for use with external Bun.serve()

handleUpgrade(req, server) - Handle WebSocket upgrade requests

Patch Changes

Updated dependencies [e32a69b]

@pubsubjs/core@0.2.0

0.1.2

Patch Changes

10c33d0: Fix release workflow - remove prepublishOnly, mark examples as private

Updated dependencies [10c33d0]

@pubsubjs/core@0.1.2

0.1.1

Patch Changes

Updated dependencies [00be192]

@pubsubjs/core@0.1.1

@pubsubjs/transport-redis

0.4.0

Patch Changes

Updated dependencies [61f520c]

@pubsubjs/core@0.4.0

0.3.0

Patch Changes

Updated dependencies [7c2d65d]

@pubsubjs/core@0.3.0

0.2.1

Patch Changes

5893d56: Fix npm publishing to use proper semver ranges instead of workspace:\* protocol

Updated dependencies [5893d56]

@pubsubjs/core@0.2.1

0.2.0

Minor Changes

e32a69b: Add attribute-based event filtering at the transport level

Add FilterPolicy type with operators: $in, $exists, $prefix, $ne, $gt, $gte, $lt, $lte, $between

Add EventAttributes type for attaching filterable attributes to events

Add matchesFilter() function for evaluating filter policies

Add toSNSFilterPolicy() for AWS SNS compatibility

Update PublishOptions to accept attributes

Update Subscriber.on() to accept filter option

Implement client-side filtering in WebSocket, Redis, and SSE transports

Support nested attributes via dot notation (e.g., "user.role")

Filter semantics:

Multiple conditions on same key = OR (at least one must match)

Multiple keys = AND (all must match)

Patch Changes

Updated dependencies [e32a69b]

@pubsubjs/core@0.2.0

0.1.2

Patch Changes

10c33d0: Fix release workflow - remove prepublishOnly, mark examples as private

Updated dependencies [10c33d0]

@pubsubjs/core@0.1.2

0.1.1

Patch Changes

Updated dependencies [00be192]

@pubsubjs/core@0.1.1

@pubsubjs/transport-sse

0.4.0

Patch Changes

Updated dependencies [61f520c]

@pubsubjs/core@0.4.0

0.3.0

Patch Changes

7c2d65d: Improve TypeScript types for transport events and WebSocket options

Breaking change for TypeScript users: Transport event handlers now receive typed event data objects instead of unknown.

onUpgrade type fix

The onUpgrade callback in WebSocketServerTransport now correctly accepts Record instead of requiring the full WebSocketData type. This matches the actual runtime behavior where connectionId and subscriptions are generated internally.

  // Before (required type assertion)
  const transport = new WebSocketServerTransport({
    onUpgrade: (req) => ({ userId: "123" } as WebSocketData),
  });

  // After (no assertion needed)
  const transport = new WebSocketServerTransport({
    onUpgrade: (req) => ({ userId: "123" }),
  });
  

Typed transport events

Transport events now have properly typed handlers via TransportEventMap:

  // Event data is now typed
  transport.on("connect", ({ connectionId }) => {
    console.log(connectionId); // string | undefined
  });

  transport.on("error", ({ error }) => {
    console.error(error); // Error | undefined
  });
  

Updated dependencies [7c2d65d]

@pubsubjs/core@0.3.0

0.2.1

Patch Changes

5893d56: Fix npm publishing to use proper semver ranges instead of workspace:\* protocol

Updated dependencies [5893d56]

@pubsubjs/core@0.2.1

0.2.0

Minor Changes

e32a69b: Add attribute-based event filtering at the transport level

Add FilterPolicy type with operators: $in, $exists, $prefix, $ne, $gt, $gte, $lt, $lte, $between

Add EventAttributes type for attaching filterable attributes to events

Add matchesFilter() function for evaluating filter policies

Add toSNSFilterPolicy() for AWS SNS compatibility

Update PublishOptions to accept attributes

Update Subscriber.on() to accept filter option

Implement client-side filtering in WebSocket, Redis, and SSE transports

Support nested attributes via dot notation (e.g., "user.role")

Filter semantics:

Multiple conditions on same key = OR (at least one must match)

Multiple keys = AND (all must match)

Patch Changes

Updated dependencies [e32a69b]

@pubsubjs/core@0.2.0

0.1.2

Patch Changes

10c33d0: Fix release workflow - remove prepublishOnly, mark examples as private

Updated dependencies [10c33d0]

@pubsubjs/core@0.1.2

0.1.1

Patch Changes

Updated dependencies [00be192]

@pubsubjs/core@0.1.1

@pubsubjs/react

0.4.0

Patch Changes

Updated dependencies [61f520c]

@pubsubjs/core@0.4.0

0.3.0

Patch Changes

Updated dependencies [7c2d65d]

@pubsubjs/core@0.3.0

0.2.1

Patch Changes

5893d56: Fix npm publishing to use proper semver ranges instead of workspace:\* protocol

Updated dependencies [5893d56]

@pubsubjs/core@0.2.1

0.2.0

Patch Changes

Updated dependencies [e32a69b]

@pubsubjs/core@0.2.0

0.1.2

Patch Changes

10c33d0: Fix release workflow - remove prepublishOnly, mark examples as private

Updated dependencies [10c33d0]

@pubsubjs/core@0.1.2

0.1.1

Patch Changes

Updated dependencies [00be192]

@pubsubjs/core@0.1.1