TyleoDvDelaware3217/GoDoxy
1
0
Fork 0
mirror of https://github.com/yusing/godoxy.git synced 2025-05-19 20:32:35 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

refactor: code cleanup

Browse source
This commit is contained in:
yusing 2025-04-16 12:12:46 +08:00
parent 47fb07fe4d
commit 82f48d1248
4 changed files with 9 additions and 36 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
internal/api/v1/dockerapi/containers.go
View file

@ -18,7 +18,7 @@ type Container struct {
}
func Containers(w http.ResponseWriter, r *http.Request) {
serveHTTP[Container, []Container](w, r, GetContainers)
serveHTTP[Container](w, r, GetContainers)
}
func GetContainers(ctx context.Context, dockerClients DockerClients) ([]Container, gperr.Error) {

10
internal/route/stream_impl.go
View file

@ -7,7 +7,7 @@ import (
"net"
"time"
"github.com/yusing/go-proxy/internal/net/types"
gpnet "github.com/yusing/go-proxy/internal/net/types"
U "github.com/yusing/go-proxy/internal/utils"
)
@ -15,7 +15,7 @@ type (
Stream struct {
*StreamRoute
listener types.StreamListener
listener gpnet.StreamListener
targetAddr net.Addr
}
)
@ -56,7 +56,7 @@ func (stream *Stream) Setup() error {
}
// in case ListeningPort was zero, get the actual port
stream.Port.Listening = tcpListener.Addr().(*net.TCPAddr).Port
stream.listener = types.NetListener(tcpListener)
stream.listener = gpnet.NetListener(tcpListener)
case "udp":
stream.targetAddr, err = net.ResolveUDPAddr("udp", stream.ProxyURL.Host)
if err != nil {
@ -80,7 +80,7 @@ func (stream *Stream) Setup() error {
return nil
}
func (stream *Stream) Accept() (conn types.StreamConn, err error) {
func (stream *Stream) Accept() (conn gpnet.StreamConn, err error) {
if stream.listener == nil {
return nil, errors.New("listener is nil")
}
@ -100,7 +100,7 @@ func (stream *Stream) Accept() (conn types.StreamConn, err error) {
}
}
func (stream *Stream) Handle(conn types.StreamConn) error {
func (stream *Stream) Handle(conn gpnet.StreamConn) error {
switch conn := conn.(type) {
case *UDPConn:
switch stream := stream.listener.(type) {

6
internal/route/udp_forwarder.go
View file

@ -8,7 +8,7 @@ import (
"github.com/yusing/go-proxy/internal/gperr"
"github.com/yusing/go-proxy/internal/logging"
"github.com/yusing/go-proxy/internal/net/types"
gpnet "github.com/yusing/go-proxy/internal/net/types"
F "github.com/yusing/go-proxy/internal/utils/functional"
)
@ -57,7 +57,7 @@ func (w *UDPForwarder) Addr() net.Addr {
return w.forwarder.LocalAddr()
}
func (w *UDPForwarder) Accept() (types.StreamConn, error) {
func (w *UDPForwarder) Accept() (gpnet.StreamConn, error) {
buf := newUDPBuf()
addr, err := w.readFromListener(buf)
if err != nil {
@ -161,7 +161,7 @@ func (w *UDPForwarder) getInitConn(conn *UDPConn, key string) (*UDPConn, error)
return dst, nil
}
func (w *UDPForwarder) Handle(streamConn types.StreamConn) error {
func (w *UDPForwarder) Handle(streamConn gpnet.StreamConn) error {
conn, ok := streamConn.(*UDPConn)
if !ok {
panic("unexpected conn type")

27
internal/utils/functional/map.go
View file

@ -85,33 +85,6 @@ func (m Map[KT, VT]) CollectErrors(do func(k KT, v VT) error) []error {
return errs
}
// CollectErrors calls the given function for each key-value pair in the map,
// then returns a slice of errors collected.
func (m Map[KT, VT]) CollectErrorsParallel(do func(k KT, v VT) error) []error {
if m.Size() < minParallelSize {
return m.CollectErrors(do)
}
var errs []error
var mu sync.Mutex
var wg sync.WaitGroup
m.Range(func(k KT, v VT) bool {
wg.Add(1)
go func() {
if err := do(k, v); err != nil {
mu.Lock()
errs = append(errs, err)
mu.Unlock()
}
wg.Done()
}()
return true
})
wg.Wait()
return errs
}
func (m Map[KT, VT]) Has(k KT) bool {
_, ok := m.Load(k)
return ok