feat(durable-iterator): rewrite + enchance (#965)

- [x] feat: rewrite
- [x] feat: refresh token without re-estimate websocket connection
- [x] feat: tags with publish events filter support
- [x] feat: support `targets` and `exclude` as callback for filter
- [x] fix: should run before retry-plugin to avoid conflict
- [x] fix: server-side client, retry-plugin not preserve extra
iterator's fields (rpc methods in this case)
- [x] test
- [x] docs

Closes: https://github.com/unnoq/orpc/issues/993

<!-- This is an auto-generated comment: release notes by coderabbit.ai
-->
## Summary by CodeRabbit

* **New Features**
* Introduced Durable Iterator: end-to-end durable streaming with
token-based auth, auto-reconnect, resume/replay, publishEvent,
tagging/target/exclude filters, client & handler plugins, and token
refresh.
* Streaming cancellation via AbortController; added getSignedValue
helper and new utilities overlayProxy and fallback.

* **Documentation**
* Renamed docs/sidebar to “Durable Iterator” and updated streaming
examples to show AbortController usage.

* **Chores**
* Package rename and CI/playground updates for
@orpc/experimental-durable-iterator.
<!-- end of auto-generated comment: release notes by coderabbit.ai -->

Author: dinwwwh

.github/workflows/ci.yaml

@@ -14,6 +14,11 @@ jobs:
 
       - uses: pnpm/action-setup@v4
 
+      - uses: actions/setup-node@v5
+        with:
+          node-version: 22
+          cache: pnpm
+
       - run: pnpm i
 
       - run: pnpm run lint
@@ -27,6 +32,11 @@ jobs:
 
       - uses: pnpm/action-setup@v4
 
+      - uses: actions/setup-node@v5
+        with:
+          node-version: 22
+          cache: pnpm
+
       - run: pnpm i
 
       - run: pnpm run test:coverage
@@ -42,6 +52,11 @@ jobs:
 
       - uses: pnpm/action-setup@v4
 
+      - uses: actions/setup-node@v5
+        with:
+          node-version: 22
+          cache: pnpm
+
       - run: pnpm i
 
       - run: pnpm run packages:publish:commit

.github/workflows/release-next.yaml

@@ -15,6 +15,11 @@ jobs:
 
       - uses: pnpm/action-setup@v4
 
+      - uses: actions/setup-node@v5
+        with:
+          node-version: 22
+          cache: pnpm
+
       - run: pnpm i
 
       - run: |

.github/workflows/release.yaml

@@ -45,6 +45,11 @@ jobs:
 
       - uses: pnpm/action-setup@v4
 
+      - uses: actions/setup-node@v5
+        with:
+          node-version: 22
+          cache: pnpm
+
       - run: pnpm i
 
       - run: |

apps/content/.vitepress/config.ts

@@ -180,7 +180,7 @@ export default withMermaid(defineConfig({
           collapsed: true,
           items: [
             { text: 'AI SDK', link: '/docs/integrations/ai-sdk' },
-            { text: 'Durable Event Iterator', link: '/docs/integrations/durable-event-iterator' },
+            { text: 'Durable Iterator', link: '/docs/integrations/durable-iterator' },
             { text: 'Hey API', link: '/docs/integrations/hey-api' },
             { text: 'OpenTelemetry', link: '/docs/integrations/opentelemetry' },
             { text: 'Pinia Colada', link: '/docs/integrations/pinia-colada' },

apps/content/docs/client/event-iterator.md

@@ -29,13 +29,16 @@ for await (const event of iterator) {
 
 ## Stopping the Stream Manually
 
-Call `.return()` on the iterator to gracefully end the stream.
+You can rely on `signal` or `.return` to stop the iterator.
 
 ```ts
-const iterator = await client.streaming()
+const controller = new AbortController()
+const iterator = await client.streaming(undefined, { signal: controller.signal })
 
+// Stop the stream after 1 second
 setTimeout(async () => {
-  // Stop the stream after 1 second
+  controller.abort()
+  // or
   await iterator.return()
 }, 1000)
 

apps/content/docs/helpers/signing.md

@@ -12,7 +12,7 @@ Signing is faster than [encryption](/docs/helpers/encryption) but users can view
 :::
 
 ```ts twoslash
-import { sign, unsign } from '@orpc/server/helpers'
+import { getSignedValue, sign, unsign } from '@orpc/server/helpers'
 
 const secret = 'your-secret-key'
 const userData = 'user123'
@@ -22,8 +22,11 @@ const signedValue = await sign(userData, secret)
 // ↑ Original data is visible to users
 
 const verifiedValue = await unsign(signedValue, secret) // 'user123'
+
+// Extract value without verification
+const extractedValue = getSignedValue(signedValue) // 'user123'
 ```
 
 ::: info
-The `unsign` helper accepts `undefined` or `null` as signed value and returns `undefined` for invalid inputs, enabling seamless handling of optional data.
+The `unsign` and `getSignedValue` helpers accept `undefined` or `null` as signed value and return `undefined` for invalid inputs, enabling seamless handling of optional data.
 :::