273 lines
8.8 KiB
Swift
273 lines
8.8 KiB
Swift
/**
|
|
* I'll order you a pizza if you can rewrite this in modern idiomatic Swift
|
|
*/
|
|
|
|
import Swift
|
|
import Foundation
|
|
|
|
let printNodeDetails : @convention(c) (UnsafeMutableRawPointer?) -> Void =
|
|
{
|
|
(msgPtr) -> Void in
|
|
let msg = msgPtr?.bindMemory(to: zts_callback_msg.self, capacity: 1)
|
|
let d = msg?.pointee.node;
|
|
print(String(format: "\t- id : %llx", d!.pointee.address));
|
|
print(String(format: "\t- version : %d.%d.%d", d!.pointee.versionMajor, d!.pointee.versionMinor, d!.pointee.versionRev));
|
|
print(String(format: "\t- primaryPort : %d", d!.pointee.primaryPort));
|
|
print(String(format: "\t- secondaryPort : %d", d!.pointee.secondaryPort));
|
|
}
|
|
|
|
/*
|
|
func convertTupleToArray<Tuple, Value>(from tuple: Tuple) -> [Value] {
|
|
let tupleMirror = Mirror(reflecting: tuple)
|
|
func convert(child: Mirror.Child) -> Value? {
|
|
let valueMirror = Mirror(reflecting: child.value)
|
|
return child.value as? Value
|
|
}
|
|
return tupleMirror.children.flatMap(convert)
|
|
}
|
|
*/
|
|
|
|
let printNetworkDetails : @convention(c) (UnsafeMutableRawPointer?) -> Void =
|
|
{
|
|
(msgPtr) -> Void in
|
|
let msg = msgPtr?.bindMemory(to: zts_callback_msg.self, capacity: 1)
|
|
let d = msg?.pointee.network;
|
|
let name = ""; // String(d!.pointee.name);
|
|
|
|
print(String(format: "\t- nwid : %llx", d!.pointee.nwid));
|
|
print(String(format: "\t- mac : %lx", d!.pointee.mac));
|
|
print(String(format: "\t- name : %s", name));
|
|
print(String(format: "\t- type : %d", Int(d!.pointee.type.rawValue)));
|
|
/* MTU for the virtual network can be set via our web API */
|
|
print(String(format: "\t- mtu : %d", d!.pointee.mtu));
|
|
print(String(format: "\t- dhcp : %d", d!.pointee.dhcp));
|
|
print(String(format: "\t- bridge : %d", d!.pointee.bridge));
|
|
print(String(format: "\t- broadcastEnabled : %d", d!.pointee.broadcastEnabled));
|
|
print(String(format: "\t- portError : %d", d!.pointee.portError));
|
|
print(String(format: "\t- netconfRevision : %d", d!.pointee.netconfRevision));
|
|
print(String(format: "\t- routeCount : %d", d!.pointee.routeCount));
|
|
print(String(format: "\t- multicastSubscriptionCount : %d", d!.pointee.multicastSubscriptionCount));
|
|
/*
|
|
var addresses: [zts_sockaddr_storage] = convertTupleToArray(from: d!.pointee.assignedAddresses)
|
|
|
|
print("\t- addresses:\n");
|
|
for i in 0...d!.pointee.assignedAddressCount {
|
|
if (addresses[Int(i)].ss_family == ZTS_AF_INET) {
|
|
// Allocate a byte array that can hold the largest possible IPv4 human-readable string
|
|
var ipCharByteArray = Array<Int8>(repeating: 0, count: Int(ZTS_INET_ADDRSTRLEN))
|
|
// Cast unsafe pointer from zts_sockaddr_storage to zts_sockaddr_in
|
|
var addr:zts_sockaddr_in = withUnsafePointer(to: &(addresses[Int(i)])) {
|
|
$0.withMemoryRebound(to: zts_sockaddr_in.self, capacity: 1) {
|
|
$0.pointee
|
|
}
|
|
}
|
|
// Pass unsafe pointer (addr) to a ntop to convert into human-readable byte array
|
|
zts_inet_ntop(ZTS_AF_INET, &(addr.sin_addr), &ipCharByteArray, UInt32(ZTS_INET_ADDRSTRLEN))
|
|
//print(ipCharByteArray) // [49, 55, 50, 46, 50, 55, 46, 49, 49, 54, 46, 49, 54, 55, 0, 0]
|
|
// Somehow convery Int8 byte array to Swift String ???
|
|
//let ipString = String(bytes: ipStr, encoding: .utf8)
|
|
//print(ipString)
|
|
|
|
// Pass unsafe pointer (addr) to a ntop to convert into human-readable byte array
|
|
// convert to UInt8 byte array
|
|
let uintArray = ipCharByteArray.map { UInt8(bitPattern: $0) }
|
|
if let string = String(bytes: uintArray, encoding: .utf8) {
|
|
print("\t\t-", string)
|
|
}
|
|
}
|
|
if (addresses[Int(i)].ss_family == ZTS_AF_INET6) {
|
|
// ...
|
|
}
|
|
}
|
|
*/
|
|
/*
|
|
print("\t- routes:\n");
|
|
|
|
for i in 0...d!.pointee.routeCount {
|
|
// ...
|
|
}
|
|
*/
|
|
}
|
|
|
|
let printPeerDetails : @convention(c) (UnsafeMutableRawPointer?) -> Void =
|
|
{
|
|
(msgPtr) -> Void in
|
|
let msg = msgPtr?.bindMemory(to: zts_callback_msg.self, capacity: 1)
|
|
let d = msg?.pointee.peer;
|
|
print(String(format: "\t- peer : %llx", d!.pointee.address));
|
|
print(String(format: "\t- role : %d", Int(d!.pointee.role.rawValue)));
|
|
print(String(format: "\t- latency : %llx", d!.pointee.latency));
|
|
print(String(format: "\t- pathCount : %llx", d!.pointee.pathCount));
|
|
print(String(format: "\t- version : %d.%d.%d", d!.pointee.versionMajor, d!.pointee.versionMinor, d!.pointee.versionRev));
|
|
print(String(format: "\t- paths:\n"));
|
|
|
|
/*
|
|
for i in 0...d!.pointee.pathCount {
|
|
// ...
|
|
}
|
|
*/
|
|
}
|
|
|
|
let printNetifDetails : @convention(c) (UnsafeMutableRawPointer?) -> Void =
|
|
{
|
|
(msgPtr) -> Void in
|
|
let msg = msgPtr?.bindMemory(to: zts_callback_msg.self, capacity: 1)
|
|
let d = msg?.pointee.netif;
|
|
print(String(format: "\t- nwid : %llx", d!.pointee.nwid));
|
|
print(String(format: "\t- mac : %llx", d!.pointee.mac));
|
|
print(String(format: "\t- mtu : %d", d!.pointee.mtu));
|
|
}
|
|
|
|
var nodeReady:Bool = false
|
|
var networkReady:Bool = false
|
|
|
|
let on_zts_event : @convention(c) (UnsafeMutableRawPointer?) -> Void =
|
|
{
|
|
(msgPtr) -> Void in
|
|
let msg = msgPtr?.bindMemory(to: zts_callback_msg.self, capacity: 1)
|
|
|
|
let eventCode = msg!.pointee.eventCode
|
|
let network = msg?.pointee.network;
|
|
let peer = msg?.pointee.peer;
|
|
|
|
switch Int32(eventCode)
|
|
{
|
|
case ZTS_EVENT_NODE_UP:
|
|
print("ZTS_EVENT_NODE_UP (you can ignore this)\n")
|
|
|
|
case ZTS_EVENT_NODE_ONLINE:
|
|
print("ZTS_EVENT_NODE_ONLINE\n")
|
|
printNodeDetails(msg)
|
|
nodeReady = true;
|
|
|
|
case ZTS_EVENT_NODE_OFFLINE:
|
|
print("ZTS_EVENT_NODE_OFFLINE\n")
|
|
nodeReady = false;
|
|
|
|
case ZTS_EVENT_NODE_NORMAL_TERMINATION:
|
|
print("ZTS_EVENT_NODE_NORMAL_TERMINATION\n")
|
|
|
|
case ZTS_EVENT_NETWORK_NOT_FOUND:
|
|
let networkId:UInt64 = network!.pointee.nwid
|
|
print(String(format: "ZTS_EVENT_NETWORK_NOT_FOUND (%llx)", networkId))
|
|
|
|
case ZTS_EVENT_NETWORK_REQ_CONFIG:
|
|
let networkId:UInt64 = network!.pointee.nwid
|
|
print(String(format: "ZTS_EVENT_NETWORK_REQ_CONFIG (%llx)", networkId))
|
|
|
|
case ZTS_EVENT_NETWORK_ACCESS_DENIED:
|
|
let networkId:UInt64 = network!.pointee.nwid
|
|
print(String(format: "ZTS_EVENT_NETWORK_ACCESS_DENIED (%llx)", networkId))
|
|
|
|
case ZTS_EVENT_NETWORK_READY_IP4:
|
|
let networkId:UInt64 = network!.pointee.nwid
|
|
print(String(format: "ZTS_EVENT_NETWORK_READY_IP4 (%llx)", networkId))
|
|
networkReady = true;
|
|
|
|
case ZTS_EVENT_NETWORK_READY_IP6:
|
|
let networkId:UInt64 = network!.pointee.nwid
|
|
print(String(format: "ZTS_EVENT_NETWORK_READY_IP6 (%llx)", networkId))
|
|
networkReady = true;
|
|
|
|
case ZTS_EVENT_NETWORK_DOWN:
|
|
let networkId:UInt64 = network!.pointee.nwid
|
|
print(String(format: "ZTS_EVENT_NETWORK_DOWN (%llx)", networkId))
|
|
|
|
case ZTS_EVENT_NETWORK_UPDATE:
|
|
print("ZTS_EVENT_NETWORK_UPDATE\n")
|
|
printNetworkDetails(msg)
|
|
|
|
|
|
case ZTS_EVENT_ADDR_ADDED_IP4:
|
|
print("ZTS_EVENT_ADDR_ADDED_IP4\n")
|
|
|
|
case ZTS_EVENT_ADDR_ADDED_IP6:
|
|
print("ZTS_EVENT_ADDR_ADDED_IP6\n")
|
|
|
|
case ZTS_EVENT_ADDR_REMOVED_IP4:
|
|
print("ZTS_EVENT_ADDR_REMOVED_IP4\n")
|
|
|
|
case ZTS_EVENT_ADDR_REMOVED_IP6:
|
|
print("ZTS_EVENT_ADDR_REMOVED_IP6\n")
|
|
|
|
|
|
case ZTS_EVENT_PEER_DIRECT:
|
|
let peerId:UInt64 = peer!.pointee.address
|
|
print(String(format: "ZTS_EVENT_PEER_DIRECT (%llx)", peerId))
|
|
printPeerDetails(msg)
|
|
|
|
case ZTS_EVENT_PEER_RELAY:
|
|
let peerId:UInt64 = peer!.pointee.address
|
|
print(String(format: "ZTS_EVENT_PEER_RELAY (%llx)", peerId))
|
|
printPeerDetails(msg)
|
|
|
|
case ZTS_EVENT_PEER_PATH_DISCOVERED:
|
|
let peerId:UInt64 = peer!.pointee.address
|
|
print(String(format: "ZTS_EVENT_PEER_PATH_DISCOVERED (%llx)", peerId))
|
|
printPeerDetails(msg)
|
|
|
|
case ZTS_EVENT_PEER_PATH_DEAD:
|
|
let peerId:UInt64 = peer!.pointee.address
|
|
print(String(format: "ZTS_EVENT_PEER_PATH_DEAD (%llx)", peerId))
|
|
printPeerDetails(msg)
|
|
|
|
|
|
case ZTS_EVENT_NETIF_UP:
|
|
print("ZTS_EVENT_NETIF_UP\n")
|
|
|
|
case ZTS_EVENT_NETIF_DOWN:
|
|
print("ZTS_EVENT_NETIF_DOWN\n")
|
|
|
|
case ZTS_EVENT_NETIF_REMOVED:
|
|
print("ZTS_EVENT_NETIF_REMOVED\n")
|
|
|
|
case ZTS_EVENT_NETIF_LINK_UP:
|
|
print("ZTS_EVENT_NETIF_LINK_UP\n")
|
|
|
|
case ZTS_EVENT_NETIF_LINK_DOWN:
|
|
print("ZTS_EVENT_NETIF_LINK_DOWN\n")
|
|
|
|
case ZTS_EVENT_STACK_UP:
|
|
print("ZTS_EVENT_STACK_UP\n")
|
|
|
|
case ZTS_EVENT_STACK_DOWN:
|
|
print("ZTS_EVENT_STACK_DOWN\n")
|
|
|
|
default:
|
|
print("UNKNOWN_EVENT: ", eventCode)
|
|
}
|
|
}
|
|
|
|
func main()
|
|
{
|
|
print("waiting for node to come online...")
|
|
zts_start("config_path", on_zts_event, 0)
|
|
while(!nodeReady) {
|
|
sleep(1)
|
|
}
|
|
print("Joining network")
|
|
|
|
let nwId : UInt64 = 0x0123456789abcdef; // Specify your network ID here
|
|
zts_join(nwId);
|
|
|
|
// create address structure
|
|
let addr_str = "0.0.0.0"
|
|
let port = 8080
|
|
var in4 = zts_sockaddr_in(sin_len: UInt8(MemoryLayout<zts_sockaddr_in>.size),
|
|
sin_family: UInt8(ZTS_AF_INET),
|
|
sin_port: UInt16(port).bigEndian,
|
|
sin_addr: zts_in_addr(s_addr: 0),
|
|
sin_zero: (0,0,0,0,0,0,0,0))
|
|
zts_inet_pton(ZTS_AF_INET, addr_str, &(in4.sin_addr));
|
|
|
|
print("fd=", zts_bsd_socket(ZTS_AF_INET, ZTS_SOCK_STREAM, 0));
|
|
|
|
// ...
|
|
|
|
while(true) {
|
|
sleep(1);
|
|
}
|
|
}
|
|
|
|
main()
|