use WebsocketRequest for type

This commit is contained in:
ITOH
2021-05-11 20:08:57 +02:00
parent 508970ce49
commit 59fbb976cb
2 changed files with 14 additions and 14 deletions

View File

@@ -1,48 +1,48 @@
import type { DiscordGatewayPayload } from "../types/gateway/gateway_payload.ts";
import { DiscordenoShard } from "./ws.ts";
import { DiscordenoShard, WebSocketRequest } from "./ws.ts";
/** The handler for logging different actions happening inside the ws. User can override and put custom handling per event. */
export function log(
type: "CLOSED",
data: { shardId: number; payload: CloseEvent },
data: { shardId: number; payload: CloseEvent }
): unknown;
export function log(
type: "CLOSED_RECONNECT",
data: { shardId: number; payload: CloseEvent },
data: { shardId: number; payload: CloseEvent }
): unknown;
export function log(
type: "ERROR",
data: Record<string, unknown> & { shardId: number },
data: Record<string, unknown> & { shardId: number }
): unknown;
export function log(
type: "HEARTBEATING",
data: { shardId: number; shard: DiscordenoShard },
data: { shardId: number; shard: DiscordenoShard }
): unknown;
export function log(
type: "HEARTBEATING_CLOSED",
data: { shardId: number; shard: DiscordenoShard },
data: { shardId: number; shard: DiscordenoShard }
): unknown;
export function log(
type: "HEARTBEATING_DETAILS",
data: { shardId: number; interval: number; shard: DiscordenoShard },
data: { shardId: number; interval: number; shard: DiscordenoShard }
): unknown;
export function log(
type: "HEARTBEATING_STARTED",
data: { shardId: number; interval: number },
data: { shardId: number; interval: number }
): unknown;
export function log(
type: "IDENTIFYING",
data: { shardId: number; maxShards: number },
data: { shardId: number; maxShards: number }
): unknown;
export function log(
type: "INVALID_SESSION",
data: { shardId: number; payload: DiscordGatewayPayload },
data: { shardId: number; payload: DiscordGatewayPayload }
): unknown;
export function log(type: "RAW", data: Record<string, unknown>): unknown;
export function log(
type: "RAW_SEND",
shardId: number,
data: Record<string, unknown>,
data: WebSocketRequest
): unknown;
export function log(type: "RECONNECT", data: { shardId: number }): unknown;
export function log(type: "RESUMED", data: { shardId: number }): unknown;
@@ -65,7 +65,7 @@ export function log(
| "RESUMED"
| "RESUMING"
| "DEBUG",
data: unknown,
data: unknown
) {
// This is just a placeholder for the dev to override
if (!type && !data) console.log(type, data);

View File

@@ -34,11 +34,11 @@ export async function processQueue(id: number) {
: Array.isArray(value)
? value.map((v) => (typeof v === "bigint" ? v.toString() : v))
: value,
`Running forEach loop in ws.processQueue function for changing bigints to strings.`,
`Running forEach loop in ws.processQueue function for changing bigints to strings.`
);
}
ws.log("RAW_SEND", shard.id, { ...request });
ws.log("RAW_SEND", shard.id, request);
shard.ws.send(JSON.stringify(request));