世界
72 lines
1.7 KiB
Go
72 lines
1.7 KiB
Go
//go:build linux
|
|
|
|
package libbox
|
|
|
|
import (
|
|
"context"
|
|
"net/netip"
|
|
"os"
|
|
"time"
|
|
|
|
"github.com/sagernet/sing-box/log"
|
|
"github.com/sagernet/sing-box/protocol/bridge"
|
|
E "github.com/sagernet/sing/common/exceptions"
|
|
)
|
|
|
|
func NewBridgeService(options *BridgeOptions) (BridgeSession, error) {
|
|
if options == nil {
|
|
return nil, E.New("missing bridge options")
|
|
}
|
|
serviceOptions := bridge.ServiceOptions{
|
|
BridgeName: options.BridgeName,
|
|
MTU: int(options.MTU),
|
|
RuleIndex: int(options.RuleIndex),
|
|
RouteTable: int(options.RouteTable),
|
|
}
|
|
if options.Inet4Port != "" {
|
|
inet4Port, err := netip.ParseAddr(options.Inet4Port)
|
|
if err != nil {
|
|
return nil, E.Cause(err, "parse inet4 port address")
|
|
}
|
|
serviceOptions.Inet4Port = inet4Port
|
|
}
|
|
if options.Inet6Port != "" {
|
|
inet6Port, err := netip.ParseAddr(options.Inet6Port)
|
|
if err != nil {
|
|
return nil, E.Cause(err, "parse inet6 port address")
|
|
}
|
|
serviceOptions.Inet6Port = inet6Port
|
|
}
|
|
logFactory := log.NewDefaultFactory(context.Background(), log.Formatter{BaseTime: time.Now()}, os.Stderr, "", nil, false)
|
|
serviceOptions.Logger = logFactory.Logger()
|
|
service, err := bridge.NewService(serviceOptions)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &bridgeServiceSession{service}, nil
|
|
}
|
|
|
|
type bridgeServiceSession struct {
|
|
service *bridge.Service
|
|
}
|
|
|
|
func (s *bridgeServiceSession) FileDescriptor() int32 {
|
|
return int32(s.service.FileDescriptor())
|
|
}
|
|
|
|
func (s *bridgeServiceSession) Name() string {
|
|
return s.service.Name()
|
|
}
|
|
|
|
func (s *bridgeServiceSession) Inet6Active() bool {
|
|
return s.service.Inet6Active()
|
|
}
|
|
|
|
func (s *bridgeServiceSession) SetEgress(interfaceName string) error {
|
|
return s.service.SetEgress(interfaceName)
|
|
}
|
|
|
|
func (s *bridgeServiceSession) Close() error {
|
|
return s.service.Close()
|
|
}
|