import {Sub} from "@e280/stz"
import {AgentInfo} from "../signaller/types.js"
import {SignallerApi} from "../signaller/api.js"

export const generalTimeout = 60_000

export type Prospect = {
	id: string
	reputation: string
	peer: RTCPeerConnection
	onFailed: Sub
}

export type Connection<Cable = StdCable> = {
	id: string
	reputation: string
	peer: RTCPeerConnection
	cable: Cable
	disconnect: () => void
}

export type RtcConfigurator = (options: {signaller: SignallerApi["v1"]}) => Promise<RTCConfiguration>

export type BrowserApiOptions<Cable> = {
	rtcConfigurator: RtcConfigurator
	cableConfig: CableConfig<Cable>
	signallerApi: SignallerApi
	allow: AllowFn
	welcome: WelcomeFn<Cable>
}

export type SendIceCandidateFn = (candidate: RTCIceCandidate) => Promise<void>

export type CableConfig<Cable> = {
	offering: (peer: RTCPeerConnection) => Promise<Cable>
	answering: (peer: RTCPeerConnection) => Promise<Cable>
}

export type StdCable = {
	reliable: RTCDataChannel
	unreliable: RTCDataChannel
}

export function asCableConfig<Cable>(config: CableConfig<Cable>) {
	return config
}

///////////////////////////////////////////

export type CommonOptions<Cable> = {
	url: string
	timeout: number
	rtcConfigurator: RtcConfigurator
	cableConfig: CableConfig<Cable>
}

export type ConnectOptions<Cable> = {
	welcome: WelcomeFn<Cable>
	closed: () => void
	allow?: AllowFn
} & Partial<CommonOptions<Cable>>

export type JoinOptions<Cable> = {
	invite: string
	disconnected: () => void
	allow?: AllowFn
	welcome?: WelcomeFn<Cable>
} & Partial<CommonOptions<Cable>>

export type AllowFn = (agent: AgentInfo) => Promise<boolean>
export type WelcomeFn<Cable = StdCable> = (prospect: Prospect) => (connection: Connection<Cable>) => () => void