export type QoS = 0 | 1 | 2;

interface IMqttClientOptions {
	clientId: string;
	uri: string;
	host?: string;
	port?: number;
	protocol?: 'mqtt' | 'tcp' | 'wss' | 'mqtts' | 'ws';
	tls?: boolean;
	keepalive?: number; // seconds
	protocolLevel?: number;
	clean?: boolean;
	auth?: boolean;
	user?: string; // only used when auth is true
	pass?: string; // only used when auth is true
	will?: boolean;
	willMsg?: string; // only used when will is true
	willtopic?: string; // only used when will is true
	willQos?: QoS; // only used when will is true
	willRetainFlag?: boolean; // only used when will is true
	automaticReconnect?: boolean; // android only
}

export class IMqttClient {
	constructor(options: IMqttClientOptions);

	on(event: 'closed', cb: (msg: string) => void): void;

	on(event: 'error', cb: (msg: string) => void): void;

	on(
		event: 'message',
		cb: (msg: { data: string; qos: QoS; retain: boolean; topic: string }) => void,
	): void;

	on(event: 'connect', cb: (msg: { reconnect: boolean }) => void): void;

	connect(): void;

	disconnect(): void;

	subscribe(topic: string, qos: QoS): void;

	unsubscribe(topic: string): void;

	publish(topic: string, payload: string, qos: QoS, retain: boolean): void;

	reconnect(): void;

	isConnected(): Promise<boolean>;
}

declare namespace mqtt {
	function createClient(options: IMqttClientOptions): Promise<IMqttClient>;
	function removeClient(client: IMqttClient): void;
	function disconnectAll(): void;
}

export default mqtt;