sing/common/bufio/addr_conn.go

package bufio

import (
	"io"
	"net"

	M "github.com/sagernet/sing/common/metadata"
)

type AddrConn struct {
	net.Conn
	Source      M.Socksaddr
	Destination M.Socksaddr
}

func (c *AddrConn) LocalAddr() net.Addr {
	if c.Destination.IsValid() {
		return c.Destination.TCPAddr()
	}
	return c.Conn.LocalAddr()
}

func (c *AddrConn) RemoteAddr() net.Addr {
	if c.Source.IsValid() {
		return c.Source.TCPAddr()
	}
	return c.Conn.RemoteAddr()
}

func (c *AddrConn) ReadFrom(r io.Reader) (n int64, err error) {
	return Copy(c.Conn, r)
}

func (c *AddrConn) WriteTo(w io.Writer) (n int64, err error) {
	return Copy(w, c.Conn)
}

func (c *AddrConn) ReaderReplaceable() bool {
	return true
}

func (c *AddrConn) WriterReplaceable() bool {
	return true
}

func (c *AddrConn) Upstream() any {
	return c.Conn
}