durable-event-iterator -> durable-iterator

Author: unnoq

packages/durable-event-iterator/src/client/event-iterator.test-d.ts

@@ -1,13 +1,13 @@
 {
-  "name": "@orpc/experimental-durable-event-iterator",
+  "name": "@orpc/experimental-durable-iterator",
   "type": "module",
   "version": "1.8.7",
   "license": "MIT",
   "homepage": "https://orpc.unnoq.com",
   "repository": {
     "type": "git",
     "url": "git+https://github.com/unnoq/orpc.git",
-    "directory": "packages/durable-event-iterator"
+    "directory": "packages/durable-iterator"
   },
   "keywords": [
     "unnoq",

packages/durable-event-iterator/src/error.ts

@@ -2,7 +2,7 @@ import type { AsyncIteratorClass } from '@orpc/shared'
 import { oc, type } from '@orpc/contract'
 import * as v from 'valibot'
 
-export const durableEventIteratorContract = {
+export const DurableIteratorContract = {
   subscribe: oc.output(type<AsyncIteratorClass<any>>()),
   call: oc.input(
     v.object({

packages/durable-event-iterator/src/event-iterator.test-d.ts

@@ -0,0 +1,18 @@
+import type { Client } from '@orpc/client'
+import type { AsyncIteratorClass } from '@orpc/shared'
+import type { DurableIteratorObject } from '../object'
+import type { ClientDurableIterator, ClientDurableIteratorRpcContext } from './event-iterator'
+
+it('ClientDurableIterator', () => {
+  interface SomeObject extends DurableIteratorObject<{ v: string }, { token: string }> {
+    sendMessage: (ws: WebSocket) => Client<object, string, string, Error>
+  }
+
+  type ClientIterator = ClientDurableIterator<SomeObject, 'sendMessage'>
+
+  expectTypeOf<ClientIterator>().toExtend<AsyncIteratorClass<{ v: string }>>()
+
+  expectTypeOf<ClientIterator['sendMessage']>().toEqualTypeOf<
+    Client<ClientDurableIteratorRpcContext, string, string, Error>
+  >()
+})

packages/durable-event-iterator/.gitignore renamed to packages/durable-iterator/.gitignore

@@ -1,12 +1,12 @@
-import type { DurableEventIteratorTokenPayload } from '../schemas'
+import type { DurableIteratorTokenPayload } from '../schemas'
 import { AsyncIteratorClass, isAsyncIteratorObject } from '@orpc/shared'
 import { SignJWT } from 'jose'
-import { createClientDurableEventIterator } from './event-iterator'
+import { createClientDurableIterator } from './event-iterator'
 
-describe('createClientDurableEventIterator', async () => {
+describe('createClientDurableIterator', async () => {
   const signingKey = new TextEncoder().encode('some-secret-key')
 
-  const tokenPayload: Omit<DurableEventIteratorTokenPayload, 'iat' | 'exp'> = {
+  const tokenPayload: Omit<DurableIteratorTokenPayload, 'iat' | 'exp'> = {
     chn: 'some-channel',
     rpc: ['method1', 'method2'],
     att: { some: 'claims' },
@@ -22,7 +22,7 @@ describe('createClientDurableEventIterator', async () => {
   const cleanup = vi.fn(() => Promise.resolve())
   const call = vi.fn(() => Promise.resolve('__call__'))
 
-  const iterator = createClientDurableEventIterator(new AsyncIteratorClass<any>(next, cleanup), {
+  const iterator = createClientDurableIterator(new AsyncIteratorClass<any>(next, cleanup), {
     call,
   }, {
     token,