import { addressFamilyMismatch } from './utils.js'
import type { NetworkAddress, SSDP } from './index.js'

export function sendSsdpMessage (ssdp: SSDP, status: string, headers: Record<string, string>, remote: NetworkAddress): void {
  Promise.all(
    ssdp.sockets.map(async socket => {
      await new Promise<void>((resolve, reject) => {
        if (socket.closed) {
          resolve(); return
        }

        const recipient = remote ?? socket.options.broadcast

        // don't send messages over udp6 sockets and expect them to reach upd4 recipients
        if (recipient != null && addressFamilyMismatch(recipient, socket)) {
          resolve(); return
        }

        if (headers.LOCATION != null) {
          // @ts-expect-error wat
          headers.LOCATION = headers.LOCATION[socket.type]
        }

        const message = [status]

        if (!status.startsWith('HTTP/1.1')) {
          // not a response so insert the host header
          let host = socket.options.broadcast.address

          if (socket.type === 'udp6') {
            // need to wrap IPv6 addrs in `[...]` because they can contain `:`
            host = `[${socket.options.broadcast.address}]`
          }

          message.push(`HOST: ${host}:${socket.options.broadcast.port}`)
        }

        Object.keys(headers).forEach(function (header) {
          message.push(`${header}: ${headers[header]}`)
        })

        message.push('\r\n')

        const buffer = Buffer.from(message.join('\r\n'))

        ssdp.emit('transport:outgoing-message', socket, buffer, recipient)

        socket.send(buffer, 0, buffer.length, recipient.port, recipient.address, error => {
          if (error != null) {
            reject(error); return
          }

          resolve()
        })
      })
    })
  ).catch(err => {
    ssdp.emit('error', err)
  })
}