feat: add subscription id to event and add unsub func

Author: zSoulweaver

src/structures/base-event.ts

@@ -3,6 +3,7 @@ import { Base } from './base'
 
 export interface WebhookEvent {
 	messageId: string
+	subscriptionId: string
 	timestamp: string
 	type: string
 	version: string
@@ -19,6 +20,11 @@ export class EventBase extends Base<WebhookEvent> {
 		 */
 		messageId: string
 
+		/**
+		 * The subscription ID associated with the event
+		 */
+		subscriptionId: string
+
 		/**
 		 * The event's timestamp
 		 */
@@ -32,6 +38,14 @@ export class EventBase extends Base<WebhookEvent> {
 		this.webhookEvent = {
 			messageId: data.messageId,
 			timestamp: new Date(data.timestamp),
+			subscriptionId: data.subscriptionId,
 		}
 	}
+
+	/**
+	 * The unsubscribes the client from this subscription type using the associated subscription ID in the event
+	 */
+	unsubscribe() {
+		this.kient.api.webhook.unsubscribe([this.webhookEvent.subscriptionId])
+	}
 }

src/webhook.server.ts

@@ -17,6 +17,7 @@ export class WebhookServer {
 		this.instance.post('/webhook', async (c) => {
 			if (this.kient._kickPublicKey) {
 				const messageId = c.req.header('Kick-Event-Message-Id')
+				const subscriptionId = c.req.header('Kick-Event-Subscription-Id')
 				const signature = c.req.header('Kick-Event-Signature')
 				const timestamp = c.req.header('Kick-Event-Message-Timestamp')
 				const body = await c.req.text()
@@ -40,13 +41,14 @@ export class WebhookServer {
 				const eventType = c.req.header('Kick-Event-Type')
 				const eventVersion = c.req.header('Kick-Event-Version')
 
-				if (!eventType || !eventVersion) {
+				if (!eventType || !eventVersion || !subscriptionId) {
 					console.error('Missing required event type or version')
 					return c.body(null, 400)
 				}
 
 				this.kient.handleWebhookEvent({
 					messageId,
+					subscriptionId,
 					timestamp,
 					type: eventType,
 					version: eventVersion,