1 files changed, 191 insertions, 0 deletions
diff --git a/wireguard-go-bridge/api-ios.go b/wireguard-go-bridge/api-ios.go
new file mode 100644
index 0000000..dd66648
--- /dev/null
+++ b/wireguard-go-bridge/api-ios.go
@@ -0,0 +1,191 @@
+/* SPDX-License-Identifier: MIT
+ *
+ * Copyright (C) 2018-2019 Jason A. Donenfeld <Jason@zx2c4.com>. All Rights Reserved.
+ */
+
+package main
+
+// #include <stdlib.h>
+// #include <sys/types.h>
+// static void callLogger(void *func, int level, const char *msg)
+// {
+// 	((void(*)(int, const char *))func)(level, msg);
+// }
+import "C"
+
+import (
+	"bufio"
+	"bytes"
+	"errors"
+	"golang.org/x/sys/unix"
+	"golang.zx2c4.com/wireguard/device"
+	"golang.zx2c4.com/wireguard/tun"
+	"log"
+	"math"
+	"os"
+	"os/signal"
+	"runtime"
+	"strings"
+	"unsafe"
+)
+
+var loggerFunc unsafe.Pointer
+var versionString *C.char
+
+type CLogger struct {
+	level C.int
+}
+
+func (l *CLogger) Write(p []byte) (int, error) {
+	if uintptr(loggerFunc) == 0 {
+		return 0, errors.New("No logger initialized")
+	}
+	message := C.CString(string(p))
+	C.callLogger(loggerFunc, l.level, message)
+	C.free(unsafe.Pointer(message))
+	return len(p), nil
+}
+
+type tunnelHandle struct {
+	*device.Device
+	*device.Logger
+}
+
+var tunnelHandles = make(map[int32]tunnelHandle)
+
+func init() {
+	versionString = C.CString(device.WireGuardGoVersion)
+	device.RoamingDisabled = true
+	signals := make(chan os.Signal)
+	signal.Notify(signals, unix.SIGUSR2)
+	go func() {
+		buf := make([]byte, os.Getpagesize())
+		for {
+			select {
+			case <-signals:
+				n := runtime.Stack(buf, true)
+				buf[n] = 0
+				if uintptr(loggerFunc) != 0 {
+					C.callLogger(loggerFunc, 0, (*C.char)(unsafe.Pointer(&buf[0])))
+				}
+			}
+		}
+	}()
+}
+
+//export wgEnableRoaming
+func wgEnableRoaming(enabled bool) {
+	device.RoamingDisabled = !enabled
+}
+
+//export wgSetLogger
+func wgSetLogger(loggerFn uintptr) {
+	loggerFunc = unsafe.Pointer(loggerFn)
+}
+
+//export wgTurnOn
+func wgTurnOn(settings string, tunFd int32) int32 {
+	logger := &device.Logger{
+		Debug: log.New(&CLogger{level: 0}, "", 0),
+		Info:  log.New(&CLogger{level: 1}, "", 0),
+		Error: log.New(&CLogger{level: 2}, "", 0),
+	}
+
+	err := unix.SetNonblock(int(tunFd), true)
+	if err != nil {
+		logger.Error.Println(err)
+		return -1
+	}
+	tun, err := tun.CreateTUNFromFile(os.NewFile(uintptr(tunFd), "/dev/tun"), 0)
+	if err != nil {
+		logger.Error.Println(err)
+		return -1
+	}
+	logger.Info.Println("Attaching to interface")
+	device := device.NewDevice(tun, logger)
+
+	setError := device.IpcSetOperation(bufio.NewReader(strings.NewReader(settings)))
+	if setError != nil {
+		logger.Error.Println(setError)
+		return -1
+	}
+
+	device.Up()
+	logger.Info.Println("Device started")
+
+	var i int32
+	for i = 0; i < math.MaxInt32; i++ {
+		if _, exists := tunnelHandles[i]; !exists {
+			break
+		}
+	}
+	if i == math.MaxInt32 {
+		return -1
+	}
+	tunnelHandles[i] = tunnelHandle{device, logger}
+	return i
+}
+
+//export wgTurnOff
+func wgTurnOff(tunnelHandle int32) {
+	device, ok := tunnelHandles[tunnelHandle]
+	if !ok {
+		return
+	}
+	delete(tunnelHandles, tunnelHandle)
+	device.Close()
+}
+
+//export wgSetConfig
+func wgSetConfig(tunnelHandle int32, settings string) int64 {
+	device, ok := tunnelHandles[tunnelHandle]
+	if !ok {
+		return 0
+	}
+	err := device.IpcSetOperation(bufio.NewReader(strings.NewReader(settings)))
+	if err != nil {
+		device.Error.Println(err)
+		return err.ErrorCode()
+	}
+	return 0
+}
+
+//export wgGetConfig
+func wgGetConfig(tunnelHandle int32) *C.char {
+	device, ok := tunnelHandles[tunnelHandle]
+	if !ok {
+		return nil
+	}
+	settings := new(bytes.Buffer)
+	writer := bufio.NewWriter(settings)
+	err := device.IpcGetOperation(writer)
+	if err != nil {
+		return nil
+	}
+	writer.Flush()
+	return C.CString(settings.String())
+}
+
+//export wgBindInterfaceScope
+func wgBindInterfaceScope(tunnelHandle int32, ifscope int32) {
+	device, ok := tunnelHandles[tunnelHandle]
+	if !ok {
+		return
+	}
+	device.Info.Printf("Binding sockets to interface %d\n", ifscope)
+	err := device.BindSocketToInterface4(uint32(ifscope))
+	if err != nil {
+		device.Error.Printf("Unable to bind v4 socket to interface:", err)
+	}
+	err = device.BindSocketToInterface6(uint32(ifscope))
+	if err != nil {
+		device.Error.Printf("Unable to bind v6 socket to interface:", err)
+	}
+}
+
+//export wgVersion
+func wgVersion() *C.char {
+	return versionString
+}
+
+func main() {}