Skip to content

Commit

Permalink
fix: fix all imports missing
Browse files Browse the repository at this point in the history
  • Loading branch information
Fab1o0107 committed Dec 21, 2023
1 parent 2314785 commit 4895344
Show file tree
Hide file tree
Showing 6 changed files with 211 additions and 206 deletions.
194 changes: 194 additions & 0 deletions src/Icelink.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,194 @@
/* eslint-disable @typescript-eslint/no-unsafe-declaration-merging */
import { EventEmitter } from "node:events";
import { Redis } from "ioredis";
import { Node } from "./node/index";
import { Player } from "./guild/Player";
import { VoiceConnection } from "./guild/VoiceConnection";
import { State } from "./Constants";
import { Rest } from "./node/Rest";
import { name as packageName, version as packageVersion } from "../package.json";

export interface VoiceChannelOptions {
/** A id of Guild in which the ChannelId of the voice channel is located. */
guildId: string;
/** A id of shard to track where this should send on sharded websockets, put 0 if you are unsharded. */
shardId: number;
/** A id of the voice channel you want to connect to. */
channelId: string;
/** Whether to deafen or undeafen the current bot user. */
mute?: boolean;
/** Whether to mute or unmute the current bot user. */
deaf?: boolean;
}

export interface NodeOption {
/** Name of this node. */
name: string;
/** A credentials to access the Lavalink. */
authorization: string;
/** A URL of the Lavalink. */
url: string;
/** Whether to use secure protocols or not. */
secure?: boolean;
}

export interface IcelinkOptions {
/** Whether to move players to a different Lavalink node when a node disconnect. */
moveOnDisconnect?: boolean;
/** The Node options, for all the nodes. */
nodes: NodeOption[];
/** Timeout before trying to reconnect. */
reconnectInterval?: number;
/** Number of times to try and reconnect to Lavalink before giving up. */
reconnectTries?: number;
/** Whether to use redis cache system to save the node session and channel id from players, or not. */
redis?: Redis;
/** Whether to resume a connection on disconnect from the Lavalink. (Server Side) */
resume?: boolean;
/** Whether to resume the players by doing it in the library side. (Client Side) */
resumeByLibrary?: boolean;
/** Time to wait before lavalink starts to destroy the players of the disconnected client. */
resumeTimeout?: number;
/** Time to wait for a response from the Lavalink REST API before giving up. */
restTimeout?: number;
/** Custom or extend the structures for icelink to use. */
structures?: Structures;
/** User Agent to use when making requests to Lavalink. */
userAgent?: string;
/** Timeout before abort the voice connection. */
voiceConnectionTimeout?: number;
}

type Constructor<T> = new (...args: any[]) => T;

export interface Structures {
/** A custom structure that extends the Rest class. */
rest?: Constructor<Rest>;
/** A custom structure that extends the Player class. */
player?: Constructor<Player>;
}

export interface Icelink extends EventEmitter {
on: ((
event: "reconnecting",
listener: (name: string, reconnectsLeft: number, reconnectInterval: number) => void
) => this) &
((event: "close", listener: (name: string, code: number, reason: string) => void) => this) &
((event: "debug", listener: (debug: string) => void) => this) &
((event: "disconnect", listener: (name: string, count: number) => void) => this) &
((event: "error", listener: (name: string, error: Error) => void) => this) &
((event: "raw", listener: (name: string, data: unknown) => void) => this) &
((event: "ready", listener: (name: string, reconnected: boolean) => void) => this);
}

/** Main Icelink class. */
export abstract class Icelink extends EventEmitter {
/**
* A Icelink options.
* @readonly
*/
public readonly options: Required<Omit<IcelinkOptions, "redis">>;
/**
* Connected Lavalink nodes.
* @readonly
*/
public readonly nodes = new Map<string, Node>();
/**
* Voice connections being handled.
* @readonly
*/
public readonly connections = new Map<string, VoiceConnection>();
/**
* Players being handled.
* @readonly
*/
public readonly players = new Map<string, Player>();
/**
* redis cache being handle for save node session and players.
* @readonly
*/
public readonly redis: Redis | null = null;
/** Icelink instance identifier. */
public id: string | null = null;

/**
* Creates a new Icelink.
* @param options An options to pass to create this Icelink instance.
*/
public constructor(options: IcelinkOptions) {
super();

this.options = {
moveOnDisconnect: options.moveOnDisconnect ?? false,
nodes: options.nodes,
reconnectInterval: options.reconnectInterval ?? 5,
reconnectTries: options.reconnectTries ?? 3,
resume: options.resume ?? false,
resumeByLibrary: options.resumeByLibrary ?? false,
resumeTimeout: options.resumeTimeout ?? 30,
restTimeout: options.restTimeout ?? 60,
structures: options.structures ?? {},
userAgent: options.userAgent ?? `${packageName}/${packageVersion}`,
voiceConnectionTimeout: options.voiceConnectionTimeout ?? 15
};
this.redis = options.redis ?? null;

Object.defineProperties(this, {
options: { enumerable: false, writable: false },
nodes: { enumerable: true, writable: false },
connections: { enumerable: true, writable: false },
players: { enumerable: true, writable: false },
id: { enumerable: false, writable: true }
});

this.listen();
}

/**
* A ideal Lavalink node if available connected.
* @readonly
*/
public get idealNode(): Node | undefined {
return [...this.nodes.values()]
.filter(node => node.state === State.Connected)
.sort((a, b) => a.penalties - b.penalties)
.shift();
}

/**
* Add a Lavalink node to the pool of available nodes.
* @param options A node options for instance.
*/
public async addNode(options: NodeOption): Promise<void> {
const node = new Node(this, options);

await node.connect();

this.nodes.set(node.name, node);
}

/**
* Remove a Lavalink node from the pool of available nodes.
* @param name Name of the node.
* @param reason Reason of removing the node.
*/
public removeNode(name: string, reason = "Remove node executed"): void {
const node = this.nodes.get(name);

if (!node) throw new Error("The node name you specified doesn't exist");

node.disconnect(1000, reason);
}

/**
* Listen attaches the event listener to the library you are using.
* @abstract
*/
public abstract listen(): void;

/**
* sendPacket is where your library send packets to Discord Gateway.
* @abstract
*/
public abstract sendPacket(shardId: number, payload: any, important: boolean): void;
}
6 changes: 3 additions & 3 deletions src/guild/Player.ts
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
/* eslint-disable @typescript-eslint/no-unsafe-declaration-merging, max-lines */
import { EventEmitter } from "node:events";
import { Node } from "../node";
import { Node } from "../node/index";
import { VoiceConnection } from "./VoiceConnection";
import { OpCodes, State } from "../Constants.js";
import { Exception, Track } from "../node/Rest.js";
import { OpCodes, State } from "../Constants";
import { Exception, Track } from "../node/Rest";

export type TrackEndReason = "cleanup" | "finished" | "loadFailed" | "replaced" | "stopped";
export type PlayerEventType =
Expand Down
4 changes: 2 additions & 2 deletions src/guild/VoiceConnection.ts
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
import { EventEmitter, once } from "events";
import { State, VoiceState } from "../Constants.js";
import { Icelink, VoiceChannelOptions } from "..";
import { State, VoiceState } from "../Constants";
import { Icelink, VoiceChannelOptions } from "../Icelink";

export interface StateUpdatePartial {
channel_id?: string;
Expand Down
Loading

0 comments on commit 4895344

Please sign in to comment.