package network

import (
	"io"
	"net"

	"github.com/sagernet/sing/common"
	E "github.com/sagernet/sing/common/exceptions"
)

type HandshakeFailure interface {
	HandshakeFailure(err error) error
}

type HandshakeSuccess interface {
	HandshakeSuccess() error
}

type ConnHandshakeSuccess interface {
	ConnHandshakeSuccess(conn net.Conn) error
}

type PacketConnHandshakeSuccess interface {
	PacketConnHandshakeSuccess(conn net.PacketConn) error
}

func ReportHandshakeFailure(reporter any, err error) error {
	if handshakeConn, isHandshakeConn := common.Cast[HandshakeFailure](reporter); isHandshakeConn {
		return E.Append(err, handshakeConn.HandshakeFailure(err), func(err error) error {
			return E.Cause(err, "write handshake failure")
		})
	}
	return nil
}

func CloseOnHandshakeFailure(reporter any, onClose CloseHandlerFunc, err error) error {
	if err != nil {
		if handshakeConn, isHandshakeConn := common.Cast[HandshakeFailure](reporter); isHandshakeConn {
			hErr := handshakeConn.HandshakeFailure(err)
			err = E.Append(err, hErr, func(err error) error {
				if closer, isCloser := reporter.(io.Closer); isCloser {
					err = E.Append(err, closer.Close(), func(err error) error {
						return E.Cause(err, "close")
					})
				}
				return E.Cause(err, "write handshake failure")
			})
		} else {
			if tcpConn, isTCPConn := common.Cast[interface {
				SetLinger(sec int) error
			}](reporter); isTCPConn {
				tcpConn.SetLinger(0)
			}
			if closer, isCloser := reporter.(io.Closer); isCloser {
				err = E.Append(err, closer.Close(), func(err error) error {
					return E.Cause(err, "close")
				})
			}
		}
	}
	if onClose != nil {
		onClose(err)
	}
	return err
}

// Deprecated: use ReportConnHandshakeSuccess/ReportPacketConnHandshakeSuccess instead
func ReportHandshakeSuccess(reporter any) error {
	if handshakeConn, isHandshakeConn := common.Cast[HandshakeSuccess](reporter); isHandshakeConn {
		return handshakeConn.HandshakeSuccess()
	}
	return nil
}

func ReportConnHandshakeSuccess(reporter any, conn net.Conn) error {
	if handshakeConn, isHandshakeConn := common.Cast[ConnHandshakeSuccess](reporter); isHandshakeConn {
		return handshakeConn.ConnHandshakeSuccess(conn)
	}
	if handshakeConn, isHandshakeConn := common.Cast[HandshakeSuccess](reporter); isHandshakeConn {
		return handshakeConn.HandshakeSuccess()
	}
	return nil
}

func ReportPacketConnHandshakeSuccess(reporter any, conn net.PacketConn) error {
	if handshakeConn, isHandshakeConn := common.Cast[PacketConnHandshakeSuccess](reporter); isHandshakeConn {
		return handshakeConn.PacketConnHandshakeSuccess(conn)
	}
	if handshakeConn, isHandshakeConn := common.Cast[HandshakeSuccess](reporter); isHandshakeConn {
		return handshakeConn.HandshakeSuccess()
	}
	return nil
}