feat: add pusher/ws

example/init.ts

@@ -0,0 +1,15 @@
+import Kient from 'Kient'
+import { Events } from '../src/events'
+
+// const kient = new Kient({
+// 	connectToWebsocket: false,
+// 	pusher: {
+// 		appKey: '32cbd69e4b950bf97679',
+// 	},
+// })
+
+const kient = new Kient()
+
+kient.on(Events.Core.WebSocketConnected, async () => {
+	console.log('connected to ws')
+})

package.json

@@ -3,7 +3,7 @@
   "module": "src/index.ts",
   "type": "module",
   "scripts": {
-    "dev": "bun run --watch example/get-channel.ts"
+    "dev": "bun run --watch example/init.ts"
   },
   "devDependencies": {
     "@biomejs/biome": "1.8.3",
@@ -16,6 +16,9 @@
   },
   "dependencies": {
     "@deepkit/type": "^1.0.1-alpha.153",
-    "ofetch": "^1.3.4"
+    "defu": "^6.1.4",
+    "ofetch": "^1.3.4",
+    "pusher-js": "^8.4.0-rc2",
+    "tseep": "^1.2.2"
   }
 }

src/events.ts

@@ -0,0 +1,15 @@
+const KientEvents = {
+	WebSocketConnected: 'KIENT_WEBSOCKET_CONNECTED',
+	WebSocketDisconnected: 'KIENT_WEBSOCKET_DISCONNECTED',
+} as const
+
+type CoreEvents = {
+	[KientEvents.WebSocketConnected]: () => void
+	[KientEvents.WebSocketDisconnected]: () => void
+}
+
+export const Events = {
+	Core: KientEvents,
+}
+
+export type KientEventEmitters = CoreEvents

src/index.ts

@@ -1,6 +1,49 @@
+import defu from 'defu'
 import { getChannel } from './api/channels/get-channel'
+import { WSClient } from './ws.client'
+import { EventEmitter } from 'tseep'
+import type { KientEventEmitters } from './events'
+
+type DeepRequired<T> = {
+	[P in keyof T]-?: DeepRequired<NonNullable<T[P]>>
+}
+
+export interface KientOptions {
+	connectToWebsocket?: boolean
+	pusher?: {
+		appKey?: string
+		cluster?: string
+	}
+}
+
+const defaultKientOptions: DeepRequired<KientOptions> = {
+	connectToWebsocket: true,
+	pusher: {
+		appKey: '32cbd69e4b950bf97679',
+		cluster: 'us2',
+	},
+}
+
+export default class Kient extends EventEmitter<KientEventEmitters> {
+	private readonly kientOptions!: DeepRequired<KientOptions>
+	private wsClient?: WSClient
+
+	constructor(options?: KientOptions) {
+		super()
+		this.kientOptions = defu(options, defaultKientOptions)
+
+		this.kientOptions.connectToWebsocket ? this.connectWebsocket() : null
+	}
+
+	connectWebsocket() {
+		this.wsClient = new WSClient(this, {
+			pusher: {
+				appKey: this.kientOptions.pusher.appKey,
+				cluster: this.kientOptions.pusher.cluster,
+			},
+		})
+	}
 
-export default class Kient {
 	api = {
 		getChannel: (slugOrId: string) => getChannel(this, slugOrId),
 	}

src/ws.client.ts

@@ -0,0 +1,49 @@
+import type Kient from 'Kient'
+import Pusher, { type Channel, type Options } from 'pusher-js'
+import { Events } from './events'
+
+interface WSClientOptions {
+	pusher: {
+		appKey: string
+		cluster: string
+	}
+}
+
+export class WSClient {
+	private readonly _kientInstance!: Kient
+	private readonly pusher!: Pusher
+
+	constructor(kientInstance: Kient, options: WSClientOptions) {
+		this._kientInstance = kientInstance
+
+		const pusherOptions: Options = {
+			cluster: options.pusher.cluster,
+		}
+		this.pusher = new Pusher(options.pusher.appKey, pusherOptions)
+		this.pusher.connection.bind('connected', () =>
+			this._kientInstance.emit(Events.Core.WebSocketConnected),
+		)
+		this.pusher.connection.bind('disconnected', () =>
+			this._kientInstance.emit(Events.Core.WebSocketDisconnected),
+		)
+	}
+
+	async subscribe(channel: string) {
+		return new Promise<Channel>((resolve, _) => {
+			const subscribedChannel = this.pusher.subscribe(channel)
+			subscribedChannel.bind(
+				'pusher:subscription_error',
+				(error: { type: string; error: string; status: number }) => {
+					throw new Error(`Unable to subscribe to channel, error: ${error}`)
+				},
+			)
+			subscribedChannel.bind('pusher:subscription_succeeded', () => {
+				resolve(subscribedChannel)
+			})
+		})
+	}
+
+	async unsubscribe(channel: string) {
+		await this.pusher.unsubscribe(channel)
+	}
+}

tsconfig.json

@@ -27,7 +27,8 @@
       "Kient": [
         "./src/index.ts"
       ]
-    }
+    },
+    "outDir": "dist"
   },
   "reflection": true
 }