feathersjs · daffl · Mar 19, 2026 · Mar 19, 2026 · Mar 19, 2026
diff --git a/package-lock.json b/package-lock.json
diff --git a/packages/feathers/src/client/sse.test.ts b/packages/feathers/src/client/sse.test.ts
@@ -9,8 +9,6 @@ describe('SSE client', function () {
 
   let server: any
   let app: Application<TestServiceTypes>
-  let client1: Application<TestServiceTypes>
-  let client2: Application<TestServiceTypes>
 
   beforeAll(async () => {
     app = getApp()
@@ -32,19 +30,6 @@ describe('SSE client', function () {
     })
 
     server = await createTestServer(port, app)
-
-    client1 = feathers<TestServiceTypes>().configure(
-      fetchClient(fetch, {
-        baseUrl: url,
-        sse: 'sse'
-      })
-    )
-    client2 = feathers<TestServiceTypes>().configure(
-      fetchClient(fetch, {
-        baseUrl: url,
-        sse: 'sse'
-      })
-    )
   })
 
   afterAll(async () => {
@@ -53,17 +38,32 @@ describe('SSE client', function () {
 
   it('should stream basic SSE between clients, can abort sse', async () => {
     const events: Todo[] = []
+    const client1 = feathers<TestServiceTypes>().configure(
+      fetchClient(fetch, {
+        baseUrl: url,
+        sse: 'sse'
+      })
+    )
 
-    client1.service('sse').emit('start')
-
-    const controller = await new Promise<AbortController>((resolve) => {
+    const connectedPromise = new Promise<AbortController>((resolve) => {
       client1.service('sse').once('connected', (data: AbortController) => resolve(data))
     })
 
+    await client1.setup()
+
+    const controller = await connectedPromise
+
     client1.service('todos').on('created', (data: Todo) => {
       events.push(data)
     })
 
+    const client2 = feathers<TestServiceTypes>().configure(
+      fetchClient(fetch, {
+        baseUrl: url,
+        sse: 'sse'
+      })
+    )
+
     await client2.service('todos').create({ text: 'todo 1', complete: true })
     await Promise.all([
       client2.service('todos').create({ text: 'todo 2', complete: false }),
@@ -82,31 +82,57 @@ describe('SSE client', function () {
   })
 
   it('emits AbortController on successful connection', async () => {
-    const params = {
-      query: { message: 'testing' }
-    }
-
-    client1.service('sse').emit('start', params)
+    const client = feathers<TestServiceTypes>().configure(
+      fetchClient(fetch, {
+        baseUrl: url,
+        sse: {
+          path: 'sse',
+          params: { query: { message: 'testing' } }
+        }
+      })
+    )
 
-    const controller = await new Promise<AbortController>((resolve) => {
-      client1.service('sse').once('connected', (data: AbortController) => resolve(data))
+    const connectedPromise = new Promise<AbortController>((resolve) => {
+      client.service('sse').once('connected', (data: AbortController) => resolve(data))
     })
 
+    await client.setup()
+
+    const controller = await connectedPromise
+
     controller.abort()
     expect(controller.signal.aborted).toBe(true)
   })
 
   it('only receive events for their channels', async () => {
     const events: Todo[] = []
+    const client1 = feathers<TestServiceTypes>().configure(
+      fetchClient(fetch, {
+        baseUrl: url,
+        sse: {
+          path: 'sse',
+          params: { query: { channel: 'client' } }
+        }
+      })
+    )
+    const client2 = feathers<TestServiceTypes>().configure(
+      fetchClient(fetch, {
+        baseUrl: url,
+        sse: {
+          path: 'sse',
+          params: { query: { channel: 'client' } }
+        }
+      })
+    )
 
-    client1.service('sse').emit('start', { query: { channel: 'client' } })
-    client2.service('sse').emit('start', { query: { channel: 'client' } })
-
-    await Promise.all([
+    const connected = Promise.all([
       new Promise((resolve) => client1.service('sse').once('connected', resolve)),
       new Promise((resolve) => client2.service('sse').once('connected', resolve))
     ])
 
+    await Promise.all([client1.setup(), client2.setup()])
+    await connected
+
     client1.service('todos').on('created', (todo: Todo) => events.push(todo))
     client2.service('todos').on('created', (todo: Todo) => events.push(todo))
 
@@ -144,12 +170,14 @@ describe('SSE client', function () {
         }
       })
     )
-    reconnectClient.service('sse').emit('start')
 
-    await new Promise<AbortController>((resolve) => {
+    const connectedPromise = new Promise<AbortController>((resolve) => {
       reconnectClient.service('sse').once('connected', (data: AbortController) => resolve(data))
     })
 
+    await reconnectClient.setup()
+    await connectedPromise
+
     const disconnectEvent = new Promise<Error>((resolve) => {
       reconnectClient.service('sse').once('disconnected', (error: Error) => resolve(error))
     })

diff --git a/packages/feathers/src/client/sse.ts b/packages/feathers/src/client/sse.ts
@@ -1,9 +1,10 @@
-import { Application, Params } from '../declarations.js'
+import { Application, HookContext, NextFunction, Params } from '../declarations.js'
 
 export interface SseClientOptions {
   path: string
   reconnectionDelay?: number
   reconnectionDelayMax?: number
+  params?: Params
 }
 
 export interface ReconnectingEvent {
@@ -21,7 +22,12 @@ function getDelay(attempt: number, reconnectionDelay: number, reconnectionDelayM
 
 export function sseClient(options: SseClientOptions) {
   return (client: Application) => {
-    const { path, reconnectionDelay = 1000, reconnectionDelayMax = 5000 } = options
+    const {
+      path,
+      reconnectionDelay = 1000,
+      reconnectionDelayMax = 5000,
+      params: defaultParams = {}
+    } = options
     const sseService = client.service(path)
 
     let attempt = 0
@@ -94,8 +100,13 @@ export function sseClient(options: SseClientOptions) {
         })
     }
 
-    sseService.on('start', (params: Params = {}) => {
-      connect(params)
+    client.hooks({
+      setup: [
+        async (_context: HookContext, next: NextFunction) => {
+          await next()
+          connect(defaultParams)
+        }
+      ]
     })
   }
 }
diff --git a/website/.nuxtrc b/website/.nuxtrc
@@ -1 +1 @@
-setups.@nuxt/test-utils="3.23.0"
+setups.@nuxt/test-utils="4.0.0"
diff --git a/website/app/app.vue b/website/app/app.vue
@@ -66,8 +66,8 @@ useSeoMeta({
   <!-- Global Search Modal -->
   <DocsSearchModal
     v-model="isSearchOpen"
-    :collections="['guides', 'api', 'cookbook', 'help', 'ecosystem']"
+    :collections="['guides', 'api', 'help']"
     search-label="Feathers Docs"
-    :popular-paths="['/guides', '/api', '/cookbook', '/help']"
+    :popular-paths="['/guides', '/api', '/help']"
   />
 </template>
diff --git a/website/app/components/DocsSidebar.vue b/website/app/components/DocsSidebar.vue
@@ -7,7 +7,6 @@ const sidebarRef = ref<HTMLElement | null>(null)
 function getMenuName(path: string) {
   if (path.startsWith('/guides')) return 'guides'
   if (path.startsWith('/api')) return 'api'
-  if (path.startsWith('/cookbook')) return 'cookbook'
   if (path.startsWith('/help')) return 'help'
   return 'guides' // default
 }
@@ -21,9 +20,6 @@ const { data: guidesMenu } = await useAsyncData('menu-guides', () =>
 const { data: apiMenu } = await useAsyncData('menu-api', () =>
   queryCollection('menus').where('stem', '==', 'menus/api').first()
 )
-const { data: cookbookMenu } = await useAsyncData('menu-cookbook', () =>
-  queryCollection('menus').where('stem', '==', 'menus/cookbook').first()
-)
 const { data: helpMenu } = await useAsyncData('menu-help', () =>
   queryCollection('menus').where('stem', '==', 'menus/help').first()
 )
@@ -32,8 +28,6 @@ const currentMenu = computed(() => {
   switch (menuName.value) {
     case 'api':
       return apiMenu.value
-    case 'cookbook':
-      return cookbookMenu.value
     case 'help':
       return helpMenu.value
     default:

diff --git a/website/app/components/Features.vue b/website/app/components/Features.vue
@@ -43,7 +43,7 @@
             <Text class="opacity-70">
               Built for TypeScript, Feathers provides the structure to create complex applications but is
               flexible enough to not be in the way. With
-              <Link is="NuxtLink" to="/ecosystem/">a large ecosystem of plugins</Link> you can include exactly
+              a large ecosystem of plugins you can include exactly
               what you need. No more, no less.
             </Text>
           </CardBody>

diff --git a/website/app/components/TopNav.vue b/website/app/components/TopNav.vue
@@ -15,7 +15,6 @@ const { openSearch } = useGlobalSearch()
         <Flex row items-center class="gap-6 rounded-box bg-base-100/10 p-3 sm:px-12">
           <NuxtLink to="/guides">Guides</NuxtLink>
           <NuxtLink to="/api">API</NuxtLink>
-          <NuxtLink to="/cookbook">Cookbook</NuxtLink>
           <NuxtLink to="/help">Help</NuxtLink>
         </Flex>
       </NavbarCenter>

diff --git a/website/app/pages/cookbook/[...slug].vue b/website/app/pages/cookbook/[...slug].vue
diff --git a/website/content.config.ts b/website/content.config.ts
@@ -23,17 +23,9 @@ export default defineContentConfig({
       type: 'page',
       source: 'api/**/*.md'
     }),
-    cookbook: defineCollection({
-      type: 'page',
-      source: 'cookbook/**/*.md'
-    }),
     help: defineCollection({
       type: 'page',
       source: 'help/**/*.md'
     }),
-    ecosystem: defineCollection({
-      type: 'page',
-      source: 'ecosystem/**/*.md'
-    })
   }
 })
diff --git a/website/content/api/application.md b/website/content/api/application.md
@@ -171,7 +171,7 @@ app.configure(setupService)
 ## .setup([server])
 
 `app.setup([server]) -> Promise<app>` is used to initialize all services by calling each [services .setup(app, path)](services#setupapp-path) method (if available).
-It will also use the `server` instance passed (e.g. through `http.createServer`) to set up SocketIO (if enabled) and any other provider that might require the server instance. You can register [application setup hooks](./hooks#setup-and-teardown) to e.g. set up database connections and other things required to be initialized on startup in a certain order.
+It will also use the `server` instance passed (e.g. through `http.createServer`) to set up any provider that might require the server instance. You can register [application setup hooks](./hooks#setup-and-teardown) to e.g. set up database connections and other things required to be initialized on startup in a certain order.
 
 Normally `app.setup` will be called automatically when starting the application via [app.listen([port])](#listen-port) but there are cases (like in tests) when it can be called explicitly.
 
@@ -183,7 +183,7 @@ Normally `app.setup` will be called automatically when starting the application
 
 `app.listen([port]) -> Promise<HTTPServer>` starts the application on the given port. It will set up all configured transports (if any) and then run [app.setup(server)](#setup-server) with the server object and then return the server object.
 
-`listen` will only be available if a server side transport (REST or websocket) has been configured.
+`listen` will only be available if a server side transport (HTTP) has been configured.
 
 ## .set(name, value)
 

diff --git a/website/content/api/bun.md b/website/content/api/bun.md
@@ -28,15 +28,14 @@ Bun.serve({
 
 The `createHandler` returns a function with the signature `(request: Request) => Promise<Response>` which is the Web Standard used natively by Bun.
 
-## With Socket.io
+## With SSE
 
-To use real-time functionality with Socket.io in Bun:
+To use real-time functionality with Server-Sent Events in Bun, register the [SSE service](./http#sse-service) and set up [channels](./channels):
 
 ```ts
 import { feathers } from 'feathers'
 import { createHandler } from 'feathers/http'
-import { Server } from 'socket.io'
-import { socketio } from 'feathers/socketio'
+import { SseService } from 'feathers/sse'
 
 const app = feathers()
 
@@ -46,14 +45,15 @@ app.use('messages', {
   }
 })
 
-app.configure(socketio())
+// Register the SSE service for real-time events
+app.use('sse', new SseService())
 
 const handler = createHandler(app)
 
-const server = Bun.serve({
+Bun.serve({
   port: 3030,
   fetch: handler
 })
 
-await app.setup(server)
+await app.setup()
 ```
diff --git a/website/content/api/channels.md b/website/content/api/channels.md
@@ -2,7 +2,7 @@
 
 # Channels
 
-On a Feathers server with a real-time transport (like [Socket.io](./socketio)) configured, event channels determine which connected clients to send [real-time events](./events) to and how the sent data should look.
+On a Feathers server with a real-time transport (like [SSE](./client/sse)) configured, event channels determine which connected clients to send [real-time events](./events) to and how the sent data should look.
 
 This chapter describes:
 
@@ -86,7 +86,7 @@ export default function (app: any) {
 
 ## Connections
 
-A connection is an object that represents a real-time connection. It is the same object as `socket.feathers` in a [Socket.io](./socketio#params) middleware. You can add any kind of information to it but most notably, when using [authentication](./authentication/service), it will contain the authenticated user. By default it is located in `connection.user` once the client has authenticated on the socket (usually by calling `app.authenticate()` on the [client](./client)).
+A connection is an object that represents a real-time connection. You can add any kind of information to it but most notably, when using [authentication](./authentication/service), it will contain the authenticated user. By default it is located in `connection.user` once the client has authenticated (usually by calling `app.authenticate()` on the [client](./client)).
 
 We can get access to the `connection` object by listening to `app.on('connection', connection => {})` or `app.on('login', (payload, { connection }) => {})`.
Original file line number	Diff line number	Diff line change
		@@ -1 +1 @@
		setups.@nuxt/test-utils="3.23.0"
		setups.@nuxt/test-utils="4.0.0"