import type { IncomingMessage, ServerResponse } from "node:http";
import type { Awareness } from "y-protocols/awareness";
import type Connection from "./Connection.ts";
import type Document from "./Document.ts";
import type { Hocuspocus } from "./Hocuspocus.ts";

export interface ConnectionTransactionOrigin {
	source: "connection";
	connection: Connection;
}

export interface RedisTransactionOrigin {
	source: "redis";
}

export interface LocalTransactionOrigin {
	source: "local";
	skipStoreHooks?: boolean;
	context?: any;
}

export type TransactionOrigin =
	| ConnectionTransactionOrigin
	| RedisTransactionOrigin
	| LocalTransactionOrigin;

export function isTransactionOrigin(
	origin: unknown,
): origin is TransactionOrigin {
	return (
		typeof origin === "object" &&
		origin !== null &&
		"source" in origin &&
		((origin as any).source === "connection" ||
			(origin as any).source === "redis" ||
			(origin as any).source === "local")
	);
}

export function shouldSkipStoreHooks(origin: unknown): boolean {
	if (!isTransactionOrigin(origin)) return false;
	switch (origin.source) {
		case "connection":
			return false;
		case "redis":
			return true;
		case "local":
			return origin.skipStoreHooks ?? false;
	}
}

/**
 * Minimal interface for any WebSocket-like object for WebSocket, Bun's ServerWebSocket, ws, Deno, etc.
 */
export interface WebSocketLike {
	send(data: string | ArrayBufferLike | Blob | ArrayBufferView): void;
	close(code?: number, reason?: string): void;
	readyState: number;
}

export enum MessageType {
	Unknown = -1,
	Sync = 0,
	Awareness = 1,
	Auth = 2,
	QueryAwareness = 3,
	SyncReply = 4, // same as Sync, but won't trigger another 'SyncStep1'
	Stateless = 5,
	BroadcastStateless = 6,
	CLOSE = 7,
	SyncStatus = 8,
	Ping = 9,
	Pong = 10,
}

export interface AwarenessUpdate {
	added: Array<any>;
	updated: Array<any>;
	removed: Array<any>;
}

export interface ConnectionConfiguration {
	readOnly: boolean;
	isAuthenticated: boolean;
}

export interface Extension<Context = any> {
	priority?: number;
	extensionName?: string;
	onConfigure?(data: onConfigurePayload): Promise<any>;
	onListen?(data: onListenPayload): Promise<any>;
	onUpgrade?(data: onUpgradePayload): Promise<any>;
	onConnect?(data: onConnectPayload<Context>): Promise<any>;
	connected?(data: connectedPayload<Context>): Promise<any>;
	onAuthenticate?(data: onAuthenticatePayload<Context>): Promise<any>;
	onTokenSync?(data: onTokenSyncPayload<Context>): Promise<any>;
	onCreateDocument?(data: onCreateDocumentPayload<Context>): Promise<any>;
	onLoadDocument?(data: onLoadDocumentPayload<Context>): Promise<any>;
	afterLoadDocument?(data: afterLoadDocumentPayload<Context>): Promise<any>;
	beforeHandleMessage?(data: beforeHandleMessagePayload<Context>): Promise<any>;
	beforeSync?(data: beforeSyncPayload<Context>): Promise<any>;
	beforeBroadcastStateless?(
		data: beforeBroadcastStatelessPayload,
	): Promise<any>;
	onStateless?(payload: onStatelessPayload): Promise<any>;
	onChange?(data: onChangePayload<Context>): Promise<any>;
	onStoreDocument?(data: onStoreDocumentPayload<Context>): Promise<any>;
	afterStoreDocument?(data: afterStoreDocumentPayload<Context>): Promise<any>;
	onAwarenessUpdate?(data: onAwarenessUpdatePayload<Context>): Promise<any>;
	onRequest?(data: onRequestPayload): Promise<any>;
	onDisconnect?(data: onDisconnectPayload<Context>): Promise<any>;
	beforeUnloadDocument?(data: beforeUnloadDocumentPayload): Promise<any>;
	afterUnloadDocument?(data: afterUnloadDocumentPayload): Promise<any>;
	onDestroy?(data: onDestroyPayload): Promise<any>;
}

export type HookName =
	| "onConfigure"
	| "onListen"
	| "onUpgrade"
	| "onConnect"
	| "connected"
	| "onAuthenticate"
	| "onTokenSync"
	| "onCreateDocument"
	| "onLoadDocument"
	| "afterLoadDocument"
	| "beforeHandleMessage"
	| "beforeBroadcastStateless"
	| "beforeSync"
	| "onStateless"
	| "onChange"
	| "onStoreDocument"
	| "afterStoreDocument"
	| "onAwarenessUpdate"
	| "onRequest"
	| "onDisconnect"
	| "beforeUnloadDocument"
	| "afterUnloadDocument"
	| "onDestroy";

export type HookPayloadByName<Context = any> = {
	onConfigure: onConfigurePayload;
	onListen: onListenPayload;
	onUpgrade: onUpgradePayload;
	onConnect: onConnectPayload<Context>;
	connected: connectedPayload<Context>;
	onAuthenticate: onAuthenticatePayload<Context>;
	onTokenSync: onTokenSyncPayload<Context>;
	onCreateDocument: onCreateDocumentPayload<Context>;
	onLoadDocument: onLoadDocumentPayload<Context>;
	afterLoadDocument: afterLoadDocumentPayload<Context>;
	beforeHandleMessage: beforeHandleMessagePayload<Context>;
	beforeBroadcastStateless: beforeBroadcastStatelessPayload;
	beforeSync: beforeSyncPayload<Context>;
	onStateless: onStatelessPayload;
	onChange: onChangePayload<Context>;
	onStoreDocument: onStoreDocumentPayload<Context>;
	afterStoreDocument: afterStoreDocumentPayload<Context>;
	onAwarenessUpdate: onAwarenessUpdatePayload<Context>;
	onRequest: onRequestPayload;
	onDisconnect: onDisconnectPayload<Context>;
	afterUnloadDocument: afterUnloadDocumentPayload;
	beforeUnloadDocument: beforeUnloadDocumentPayload;
	onDestroy: onDestroyPayload;
};

export interface Configuration<Context = any> extends Extension<Context> {
	/**
	 * A name for the instance, used for logging.
	 */
	name: string | null;
	/**
	 * A list of hocuspocus extensions.
	 */
	extensions: Array<Extension>;
	/**
	 * Defines in which interval the server sends a ping, and closes the connection when no pong is sent back.
	 */
	timeout: number;
	/**
	 * Debounces the call of the `onStoreDocument` hook for the given amount of time in ms.
	 * Otherwise every single update would be persisted.
	 */
	debounce: number;
	/**
	 * Makes sure to call `onStoreDocument` at least in the given amount of time (ms).
	 */
	maxDebounce: number;
	/**
	 * By default, the servers show a start screen. If passed false, the server will start quietly.
	 */
	quiet: boolean;
	/**
	 * If set to false, respects the debounce time of `onStoreDocument` before unloading a document.
	 * Otherwise, the document will be unloaded immediately.
	 *
	 * This prevents a client from DOSing the server by repeatedly connecting and disconnecting when
	 * your onStoreDocument is rate-limited.
	 */
	unloadImmediately: boolean;

	/**
	 * options to pass to the ydoc document
	 */
	yDocOptions: {
		gc: boolean; // enable or disable garbage collection (see https://github.com/yjs/yjs/blob/main/INTERNALS.md#deletions)
		gcFilter: () => boolean; // will be called before garbage collecting ; return false to keep it
	};
}

export interface onStatelessPayload {
	connection: Connection;
	documentName: string;
	document: Document;
	payload: string;
}

export interface onAuthenticatePayload<Context = any> {
	context: Context;
	documentName: string;
	instance: Hocuspocus;
	requestHeaders: Headers;
	requestParameters: URLSearchParams;
	request: Request;
	socketId: string;
	token: string;
	connectionConfig: ConnectionConfiguration;
	providerVersion: string | null;
}

export interface onTokenSyncPayload<Context = any> {
	context: Context;
	document: Document;
	documentName: string;
	instance: Hocuspocus;
	requestHeaders: Headers;
	requestParameters: URLSearchParams;
	socketId: string;
	token: string;
	connectionConfig: ConnectionConfiguration;
	connection: Connection<Context>;
}

export interface onCreateDocumentPayload<Context = any> {
	context: Context;
	documentName: string;
	instance: Hocuspocus;
	requestHeaders: Headers;
	requestParameters: URLSearchParams;
	socketId: string;
	connectionConfig: ConnectionConfiguration;
}

export interface onConnectPayload<Context = any> {
	context: Context;
	documentName: string;
	instance: Hocuspocus;
	request: Request;
	requestHeaders: Headers;
	requestParameters: URLSearchParams;
	socketId: string;
	connectionConfig: ConnectionConfiguration;
	providerVersion: string | null;
}

export interface connectedPayload<Context = any> {
	context: Context;
	documentName: string;
	instance: Hocuspocus;
	request: Request;
	requestHeaders: Headers;
	requestParameters: URLSearchParams;
	socketId: string;
	connectionConfig: ConnectionConfiguration;
	connection: Connection<Context>;
	providerVersion: string | null;
}

export interface onLoadDocumentPayload<Context = any> {
	context: Context;
	document: Document;
	documentName: string;
	instance: Hocuspocus;
	requestHeaders: Headers;
	requestParameters: URLSearchParams;
	socketId: string;
	connectionConfig: ConnectionConfiguration;
}

export interface afterLoadDocumentPayload<Context = any> {
	context: Context;
	document: Document;
	documentName: string;
	instance: Hocuspocus;
	requestHeaders: Headers;
	requestParameters: URLSearchParams;
	socketId: string;
	connectionConfig: ConnectionConfiguration;
}

export interface onChangePayload<Context = any> {
	clientsCount: number;
	context: Context;
	document: Document;
	documentName: string;
	instance: Hocuspocus;
	requestHeaders: Headers;
	requestParameters: URLSearchParams;
	update: Uint8Array;
	socketId: string;
	transactionOrigin: unknown;
	connection?: Connection<Context>;
}

export interface beforeHandleMessagePayload<Context = any> {
	clientsCount: number;
	context: Context;
	document: Document;
	documentName: string;
	instance: Hocuspocus;
	requestHeaders: Headers;
	requestParameters: URLSearchParams;
	update: Uint8Array;
	socketId: string;
	connection: Connection<Context>;
}

export interface beforeSyncPayload<Context = any> {
	clientsCount: number;
	context: Context;
	document: Document;
	documentName: string;
	connection: Connection<Context>;
	/**
	 * The y-protocols/sync message type
	 * @example
	 * 0: SyncStep1
	 * 1: SyncStep2
	 * 2: YjsUpdate
	 *
	 * @see https://github.com/yjs/y-protocols/blob/master/sync.js#L13-L40
	 */
	type: number;
	/**
	 * The payload of the y-sync message.
	 */
	payload: Uint8Array;
}

export interface beforeBroadcastStatelessPayload {
	document: Document;
	documentName: string;
	payload: string;
}

export interface onStoreDocumentPayload<Context = any> {
	clientsCount: number;
	document: Document;
	lastContext: Context;
	lastTransactionOrigin: unknown;
	documentName: string;
	instance: Hocuspocus;
}

// eslint-disable-next-line @typescript-eslint/no-empty-interface, @typescript-eslint/no-empty-object-type
export interface afterStoreDocumentPayload<Context = any>
	extends onStoreDocumentPayload<Context> {}

export interface onAwarenessUpdatePayload<Context = any> {
	document: Document;
	documentName: string;
	instance: Hocuspocus;
	transactionOrigin: unknown;
	connection?: Connection<Context>;
	added: number[];
	updated: number[];
	removed: number[];
	awareness: Awareness;
	states: StatesArray;
}

export type StatesArray = { clientId: number; [key: string | number]: any }[];

export interface fetchPayload<Context = any> {
	context: Context;
	document: Document;
	documentName: string;
	instance: Hocuspocus;
	requestHeaders: Headers;
	requestParameters: URLSearchParams;
	socketId: string;
	connectionConfig: ConnectionConfiguration;
}

export interface storePayload<Context = any>
	extends onStoreDocumentPayload<Context> {
	state: Buffer;
}

export interface onDisconnectPayload<Context = any> {
	clientsCount: number;
	context: Context;
	document: Document;
	documentName: string;
	instance: Hocuspocus;
	requestHeaders: Headers;
	requestParameters: URLSearchParams;
	socketId: string;
}

export interface onRequestPayload {
	request: IncomingMessage;
	response: ServerResponse;
	instance: Hocuspocus;
}

export interface onUpgradePayload {
	request: IncomingMessage;
	socket: any;
	head: any;
	instance: Hocuspocus;
}

export interface onListenPayload {
	instance: Hocuspocus;
	configuration: Configuration;
	port: number;
}

export interface onDestroyPayload {
	instance: Hocuspocus;
}

export interface onConfigurePayload {
	instance: Hocuspocus;
	configuration: Configuration;
	version: string;
}

export interface afterUnloadDocumentPayload {
	instance: Hocuspocus;
	documentName: string;
}

export interface beforeUnloadDocumentPayload {
	instance: Hocuspocus;
	documentName: string;
	document: Document;
}

export interface DirectConnection {
	transact(transaction: (document: Document) => void): Promise<void>;
	disconnect(): void;
}