feat: v5: remove player cache

package.json

@@ -41,7 +41,8 @@
     "url": "https://github.com/shipgirlproject/Shoukaku.git"
   },
   "dependencies": {
-    "ws": "^8.18.0"
+    "ws": "^8.18.0",
+    "zod": "^3.23.8"
   },
   "devDependencies": {
     "@shipgirl/eslint-config": "^0.4.0",

src/Constants.ts

@@ -1,3 +1,4 @@
+import * as z from 'zod';
 import Info from '../package.json';
 // eslint-disable-next-line import-x/no-cycle
 import { NodeOption, ShoukakuOptions } from './Shoukaku';
@@ -18,19 +19,28 @@ export enum VoiceState {
 	SESSION_FAILED_UPDATE
 }
 
-export enum OpCodes {
+// export to allow compiler to determine shape
+/**
+ * Websocket operation codes
+ * @see https://lavalink.dev/api/websocket#op-types
+ */
+export enum OpCodesEnum {
 	PLAYER_UPDATE = 'playerUpdate',
 	STATS = 'stats',
 	EVENT = 'event',
 	READY = 'ready'
 }
 
+export const OpCodes = z.nativeEnum(OpCodesEnum);
+export type OpCode = z.TypeOf<typeof OpCodes>;
+
 export const Versions = {
 	REST_VERSION: 4,
 	WEBSOCKET_VERSION: 4
 };
 
 export const ShoukakuDefaults: Required<ShoukakuOptions> = {
+	validate: false,
 	resume: false,
 	resumeTimeout: 30,
 	resumeByLibrary: false,

src/Shoukaku.ts

@@ -46,6 +46,10 @@ export interface NodeOption {
 }
 
 export interface ShoukakuOptions {
+	/**
+	 * Whether to validate Lavalink responses (worse performance)
+	 */
+	validate?: boolean;
 	/**
 	 * Whether to resume a connection on disconnect to Lavalink (Server Side) (Note: DOES NOT RESUME WHEN THE LAVALINK SERVER DIES)
 	 */
@@ -173,6 +177,7 @@ export class Shoukaku extends TypedEventEmitter<ShoukakuEvents> {
 	 * @param connector A Discord library connector
 	 * @param nodes An array that conforms to the NodeOption type that specifies nodes to connect to
 	 * @param options Options to pass to create this Shoukaku instance
+	 * @param options.validate Whether to validate Lavalink responses (worse performance)
 	 * @param options.resume Whether to resume a connection on disconnect to Lavalink (Server Side) (Note: DOES NOT RESUME WHEN THE LAVALINK SERVER DIES)
 	 * @param options.resumeTimeout Time to wait before lavalink starts to destroy the players of the disconnected client
 	 * @param options.resumeByLibrary Whether to resume the players by doing it in the library side (Client Side) (Note: TRIES TO RESUME REGARDLESS OF WHAT HAPPENED ON A LAVALINK SERVER)

src/connectors/Connector.ts

@@ -5,9 +5,11 @@ import { ServerUpdate, StateUpdatePartial } from '../guild/Connection';
 import { NodeOption, Shoukaku } from '../Shoukaku';
 import { mergeDefault } from '../Utils';
 
+export type AnyFunction = (...args: any[]) => any;
+
 export interface ConnectorMethods {
-	sendPacket: any;
-	getId: any;
+	sendPacket: AnyFunction;
+	getId: AnyFunction;
 }
 
 export const AllowedPackets = [ 'VOICE_STATE_UPDATE', 'VOICE_SERVER_UPDATE' ];

src/guild/Connection.ts

@@ -1,26 +1,54 @@
 import { EventEmitter, once } from 'node:events';
+import * as z from 'zod';
 // eslint-disable-next-line import-x/no-cycle
 import { State, VoiceState } from '../Constants';
 import { Shoukaku, VoiceChannelOptions } from '../Shoukaku';
 
 /**
  * Represents the partial payload from a stateUpdate event
+ * @see https://discord.com/developers/docs/resources/voice#voice-state-object
  */
-export interface StateUpdatePartial {
-	channel_id?: string;
-	session_id?: string;
-	self_deaf: boolean;
-	self_mute: boolean;
-}
+export const StateUpdatePartial = z.object({
+	/**
+	 * Channel ID the state update is for
+	 */
+	channel_id: z.optional(z.string()),
+	/**
+	 * Session ID the state update is for
+	 */
+	session_id: z.optional(z.string()),
+	/**
+	 * Whether this user is locally deafened
+	 */
+	self_deaf: z.boolean(),
+	/**
+	 * Whether this user is locally muted
+	 */
+	self_mute: z.boolean()
+});
+
+export type StateUpdatePartial = z.TypeOf<typeof StateUpdatePartial>;
 
 /**
  * Represents the payload from a serverUpdate event
+ * @see https://discord.com/developers/docs/topics/gateway-events#voice-server-update
  */
-export interface ServerUpdate {
-	token: string;
-	guild_id: string;
-	endpoint: string;
-}
+export const ServerUpdate = z.object({
+	/**
+	 * Voice connection token
+	 */
+	token: z.string(),
+	/**
+	 * Guild this voice server update is for
+	 */
+	guild_id: z.string(),
+	/**
+	 * Voice server hostname
+	 */
+	endpoint: z.string()
+});
+
+export type ServerUpdate = z.TypeOf<typeof ServerUpdate>;
 
 /**
  * Represents a connection to a Discord voice channel