sing-box/inbound/shadowsocks.go

100 lines
3.6 KiB
Go
Raw Permalink Normal View History

2022-07-01 11:34:02 +00:00
package inbound
import (
"context"
"net"
2022-08-29 11:43:13 +00:00
"os"
"time"
2022-07-01 11:34:02 +00:00
2022-07-06 07:01:09 +00:00
"github.com/sagernet/sing-box/adapter"
"github.com/sagernet/sing-box/common/mux"
"github.com/sagernet/sing-box/common/uot"
2022-07-06 07:01:09 +00:00
C "github.com/sagernet/sing-box/constant"
"github.com/sagernet/sing-box/log"
"github.com/sagernet/sing-box/option"
2022-07-08 15:03:57 +00:00
"github.com/sagernet/sing-shadowsocks"
"github.com/sagernet/sing-shadowsocks/shadowaead"
"github.com/sagernet/sing-shadowsocks/shadowaead_2022"
"github.com/sagernet/sing/common"
"github.com/sagernet/sing/common/buf"
E "github.com/sagernet/sing/common/exceptions"
N "github.com/sagernet/sing/common/network"
2023-08-31 06:00:47 +00:00
"github.com/sagernet/sing/common/ntp"
2022-07-01 11:34:02 +00:00
)
2022-07-12 07:17:29 +00:00
func NewShadowsocks(ctx context.Context, router adapter.Router, logger log.ContextLogger, tag string, options option.ShadowsocksInboundOptions) (adapter.Inbound, error) {
2022-07-04 07:34:43 +00:00
if len(options.Users) > 0 && len(options.Destinations) > 0 {
return nil, E.New("users and destinations options must not be combined")
}
if len(options.Users) > 0 {
return newShadowsocksMulti(ctx, router, logger, tag, options)
} else if len(options.Destinations) > 0 {
return newShadowsocksRelay(ctx, router, logger, tag, options)
} else {
return newShadowsocks(ctx, router, logger, tag, options)
}
}
2022-08-29 11:43:13 +00:00
var (
_ adapter.Inbound = (*Shadowsocks)(nil)
_ adapter.InjectableInbound = (*Shadowsocks)(nil)
)
2022-07-01 11:34:02 +00:00
type Shadowsocks struct {
myInboundAdapter
service shadowsocks.Service
}
2022-07-12 07:17:29 +00:00
func newShadowsocks(ctx context.Context, router adapter.Router, logger log.ContextLogger, tag string, options option.ShadowsocksInboundOptions) (*Shadowsocks, error) {
2022-07-01 11:34:02 +00:00
inbound := &Shadowsocks{
myInboundAdapter: myInboundAdapter{
protocol: C.TypeShadowsocks,
network: options.Network.Build(),
ctx: ctx,
router: uot.NewRouter(router, logger),
2022-07-01 11:34:02 +00:00
logger: logger,
tag: tag,
listenOptions: options.ListenOptions,
},
}
2022-07-01 11:34:02 +00:00
inbound.connHandler = inbound
inbound.packetHandler = inbound
var err error
inbound.router, err = mux.NewRouterWithOptions(inbound.router, logger, common.PtrValueOrDefault(options.Multiplex))
if err != nil {
return nil, err
}
var udpTimeout time.Duration
2022-07-01 11:34:02 +00:00
if options.UDPTimeout != 0 {
udpTimeout = time.Duration(options.UDPTimeout)
2022-07-01 11:34:02 +00:00
} else {
udpTimeout = C.UDPTimeout
2022-07-01 11:34:02 +00:00
}
switch {
case options.Method == shadowsocks.MethodNone:
inbound.service = shadowsocks.NewNoneService(int64(udpTimeout.Seconds()), inbound.upstreamContextHandler())
2022-07-01 11:34:02 +00:00
case common.Contains(shadowaead.List, options.Method):
inbound.service, err = shadowaead.NewService(options.Method, nil, options.Password, int64(udpTimeout.Seconds()), inbound.upstreamContextHandler())
2022-07-01 11:34:02 +00:00
case common.Contains(shadowaead_2022.List, options.Method):
inbound.service, err = shadowaead_2022.NewServiceWithPassword(options.Method, options.Password, int64(udpTimeout.Seconds()), inbound.upstreamContextHandler(), ntp.TimeFuncFromContext(ctx))
2022-07-01 11:34:02 +00:00
default:
err = E.New("unsupported method: ", options.Method)
2022-07-01 11:34:02 +00:00
}
2022-07-02 06:07:50 +00:00
inbound.packetUpstream = inbound.service
2022-07-01 11:34:02 +00:00
return inbound, err
}
func (h *Shadowsocks) NewConnection(ctx context.Context, conn net.Conn, metadata adapter.InboundContext) error {
2022-07-12 07:17:29 +00:00
return h.service.NewConnection(adapter.WithContext(log.ContextWithNewID(ctx), &metadata), conn, adapter.UpstreamMetadata(metadata))
2022-07-01 11:34:02 +00:00
}
func (h *Shadowsocks) NewPacket(ctx context.Context, conn N.PacketConn, buffer *buf.Buffer, metadata adapter.InboundContext) error {
2022-07-17 07:11:26 +00:00
return h.service.NewPacket(adapter.WithContext(ctx, &metadata), conn, buffer, adapter.UpstreamMetadata(metadata))
}
2022-08-29 11:43:13 +00:00
func (h *Shadowsocks) NewPacketConnection(ctx context.Context, conn N.PacketConn, metadata adapter.InboundContext) error {
return os.ErrInvalid
}