Files
umbrix-libcore/custom/custom.go
problematicconsumer 9a8b25076f Add config builder
2023-09-01 14:52:30 +03:30

159 lines
3.1 KiB
Go

package main
/*
#include "stdint.h"
*/
import "C"
import (
"encoding/json"
"os"
"unsafe"
"github.com/hiddify/libcore/bridge"
"github.com/hiddify/libcore/shared"
"github.com/sagernet/sing-box/experimental/libbox"
)
var box *libbox.BoxService
var configOptions *shared.ConfigOptions
//export setupOnce
func setupOnce(api unsafe.Pointer) {
bridge.InitializeDartApi(api)
}
//export setup
func setup(baseDir *C.char, workingDir *C.char, tempDir *C.char) {
Setup(C.GoString(baseDir), C.GoString(workingDir), C.GoString(tempDir))
}
//export parse
func parse(path *C.char) *C.char {
err := shared.ParseConfig(C.GoString(path))
if err != nil {
return C.CString(err.Error())
}
return C.CString("")
}
//export changeConfigOptions
func changeConfigOptions(configOptionsJson *C.char) *C.char {
configOptions = &shared.ConfigOptions{}
err := json.Unmarshal([]byte(C.GoString(configOptionsJson)), configOptions)
if err != nil {
return C.CString(err.Error())
}
return C.CString("")
}
//export create
func create(configPath *C.char) *C.char {
path := C.GoString(configPath)
content, err := os.ReadFile(path)
if err != nil {
return C.CString(err.Error())
}
options, err := parseConfig(string(content))
if err != nil {
return C.CString(err.Error())
}
options = shared.BuildConfig(*configOptions, options)
shared.SaveCurrentConfig(sWorkingPath, options)
err = startCommandServer()
if err != nil {
return C.CString(err.Error())
}
instance, err := NewService(options)
if err != nil {
return C.CString(err.Error())
}
box = instance
commandServer.SetService(box)
if err != nil {
instance.Close()
box = nil
return C.CString(err.Error())
}
return C.CString("")
}
//export start
func start() *C.char {
if box == nil {
return C.CString("instance not found")
}
err := box.Start()
if err != nil {
return C.CString(err.Error())
}
return C.CString("")
}
//export stop
func stop() *C.char {
if box == nil {
return C.CString("instance not found")
}
commandServer.SetService(nil)
err := box.Close()
if err != nil {
return C.CString(err.Error())
}
box = nil
err = commandServer.Close()
if err != nil {
return C.CString(err.Error())
}
commandServer = nil
return C.CString("")
}
//export startCommandClient
func startCommandClient(command C.int, port C.longlong) *C.char {
err := StartCommand(int32(command), int64(port))
if err != nil {
return C.CString(err.Error())
}
return C.CString("")
}
//export stopCommandClient
func stopCommandClient(command C.int) *C.char {
err := StopCommand(int32(command))
if err != nil {
return C.CString(err.Error())
}
return C.CString("")
}
//export selectOutbound
func selectOutbound(groupTag *C.char, outboundTag *C.char) *C.char {
err := libbox.NewStandaloneCommandClient().SelectOutbound(C.GoString(groupTag), C.GoString(outboundTag))
if err != nil {
return C.CString(err.Error())
}
return C.CString("")
}
//export urlTest
func urlTest(groupTag *C.char) *C.char {
err := libbox.NewStandaloneCommandClient().URLTest(C.GoString(groupTag))
if err != nil {
return C.CString(err.Error())
}
return C.CString("")
}
func main() {}