Alireza Ahmadi
148 lines
3.1 KiB
Go
148 lines
3.1 KiB
Go
package core
|
|
|
|
import (
|
|
"s-ui/logger"
|
|
"s-ui/util/common"
|
|
|
|
"github.com/sagernet/sing-box/adapter"
|
|
"github.com/sagernet/sing-box/option"
|
|
)
|
|
|
|
func (c *Core) AddInbound(config []byte) error {
|
|
if !c.isRunning {
|
|
return common.NewError("sing-box is not running")
|
|
}
|
|
var err error
|
|
var inbound_config option.Inbound
|
|
err = inbound_config.UnmarshalJSONContext(c.GetCtx(), config)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
err = inbound_manager.Create(
|
|
c.GetCtx(),
|
|
router,
|
|
factory.NewLogger("inbound/"+inbound_config.Type+"["+inbound_config.Tag+"]"),
|
|
inbound_config.Tag,
|
|
inbound_config.Type,
|
|
inbound_config.Options)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (c *Core) RemoveInbound(tag string) error {
|
|
if !c.isRunning {
|
|
return common.NewError("sing-box is not running")
|
|
}
|
|
logger.Info("remove inbound: ", tag)
|
|
return inbound_manager.Remove(tag)
|
|
}
|
|
|
|
func (c *Core) AddOutbound(config []byte) error {
|
|
if !c.isRunning {
|
|
return common.NewError("sing-box is not running")
|
|
}
|
|
var err error
|
|
var outbound_config option.Outbound
|
|
|
|
err = outbound_config.UnmarshalJSONContext(c.GetCtx(), config)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
outboundCtx := adapter.WithContext(c.GetCtx(), &adapter.InboundContext{
|
|
Outbound: outbound_config.Tag,
|
|
})
|
|
|
|
err = outbound_manager.Create(
|
|
outboundCtx,
|
|
router,
|
|
factory.NewLogger("outbound/"+outbound_config.Type+"["+outbound_config.Tag+"]"),
|
|
outbound_config.Tag,
|
|
outbound_config.Type,
|
|
outbound_config.Options)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (c *Core) RemoveOutbound(tag string) error {
|
|
if !c.isRunning {
|
|
return common.NewError("sing-box is not running")
|
|
}
|
|
logger.Info("remove outbound: ", tag)
|
|
return outbound_manager.Remove(tag)
|
|
}
|
|
|
|
func (c *Core) AddEndpoint(config []byte) error {
|
|
if !c.isRunning {
|
|
return common.NewError("sing-box is not running")
|
|
}
|
|
var err error
|
|
var endpoint_config option.Endpoint
|
|
|
|
err = endpoint_config.UnmarshalJSONContext(c.GetCtx(), config)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
err = endpoint_manager.Create(
|
|
c.GetCtx(),
|
|
router,
|
|
factory.NewLogger("endpoint/"+endpoint_config.Type+"["+endpoint_config.Tag+"]"),
|
|
endpoint_config.Tag,
|
|
endpoint_config.Type,
|
|
endpoint_config.Options)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (c *Core) RemoveEndpoint(tag string) error {
|
|
if !c.isRunning {
|
|
return common.NewError("sing-box is not running")
|
|
}
|
|
logger.Info("remove endpoint: ", tag)
|
|
return endpoint_manager.Remove(tag)
|
|
}
|
|
|
|
func (c *Core) AddService(config []byte) error {
|
|
if !c.isRunning {
|
|
return common.NewError("sing-box is not running")
|
|
}
|
|
var err error
|
|
var srv_config option.Service
|
|
|
|
err = srv_config.UnmarshalJSONContext(c.GetCtx(), config)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
err = service_manager.Create(
|
|
c.GetCtx(),
|
|
factory.NewLogger("service/"+srv_config.Type+"["+srv_config.Tag+"]"),
|
|
srv_config.Tag,
|
|
srv_config.Type,
|
|
srv_config.Options)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (c *Core) RemoveService(tag string) error {
|
|
if !c.isRunning {
|
|
return common.NewError("sing-box is not running")
|
|
}
|
|
logger.Info("remove service: ", tag)
|
|
return service_manager.Remove(tag)
|
|
}
|