(2022-11-29, 10:12)kambala Wrote: I'd also like to try to test / reproduce in my environment first. Could you summarise (or link to a post) with reproduction steps? I haven't read all messages here too attentively tbh.
mDnsTest.swift:
import Foundation
@objc
public class mDNS : NSObject {
class func inet(addr: sockaddr_in) -> String {
let ipv4addr = (0...3).map { UInt8(truncatingIfNeeded: addr.sin_addr.s_addr >> ($0 * 8)) }
let addrString = ipv4addr.map(String.init).joined(separator: ".")
print(addrString)
return addrString
}
class func inet6(addr: sockaddr_in6) -> String {
let ipv6addr = [
addr.sin6_addr.__u6_addr.__u6_addr32.0,
addr.sin6_addr.__u6_addr.__u6_addr32.1,
addr.sin6_addr.__u6_addr.__u6_addr32.2,
addr.sin6_addr.__u6_addr.__u6_addr32.3
]
.flatMap { uint32 in
(0...3).map { UInt8(truncatingIfNeeded: uint32 >> ($0 * 8)) }
}
var byteStrings = ipv6addr.map { String(format: "%02X", $0) }
stride(from: 14, through: 2, by: -2).forEach { byteStrings.insert(":", at: $0) }
var addrString = byteStrings.joined()
print(addrString)
return addrString
}
@objc
class func lookup(_ hostname: String) -> String? {
print("resolving: \(hostname)")
let name = hostname as CFString
let host = CFHostCreateWithName(kCFAllocatorDefault, name).takeUnretainedValue()
let error: UnsafeMutablePointer<CFStreamError>? = nil
let resolutionStatus = CFHostStartInfoResolution(host, CFHostInfoType.addresses, error)
print("Resolution returned: \(resolutionStatus)")
//typealias LayoutA = MemoryLayout<sockaddr>
//typealias Layout4 = MemoryLayout<sockaddr_in>
//typealias Layout6 = MemoryLayout<sockaddr_in6>
//
//assert(LayoutA.size == Layout4.size)
//assert(LayoutA.size == Layout6.size) // nope
//assert(LayoutA.stride == Layout4.stride)
//assert(LayoutA.stride == Layout6.stride) // nope
guard error == nil else { fatalError("\(error!.pointee)") }
let addresses = CFHostGetAddressing(host, nil)?.takeRetainedValue() as? [Data] ?? []
print(addresses)
var addressStrings = [String]()
for data in addresses {
let umbp = UnsafeMutableBufferPointer<sockaddr>.allocate(capacity: 1)
data.copyBytes(to: umbp)
guard let sock = umbp.first else { continue }
print("length: \(sock.sa_len), family: \(sock.sa_family)")
switch(Int32(sock.sa_family)) {
case AF_INET: // IPv4
print("inet")
let umbp = UnsafeMutableBufferPointer<sockaddr_in>.allocate(capacity: 1)
data.copyBytes(to: umbp)
guard let addr = umbp.first else { continue }
addressStrings.append(inet(addr: addr))
case AF_INET6: // IPv6
print("inet6")
let umbp = UnsafeMutableBufferPointer<sockaddr_in6>.allocate(capacity: 1)
data.copyBytes(to: umbp)
guard let addr = umbp.first else { continue }
addressStrings.append(inet6(addr: addr))
default:
print("unhandled family: \(sock.sa_family)")
}
}
let result = addressStrings.sorted(by: { $0.count < $1.count }).first
print("address \(hostname) resolved to \(result)")
return result
}
}
HostManagementeViewController:
- (void)selectServerAtIndexPathNSIndexPath*)indexPath {
NSDictionary *item = AppDelegate.instance.arrayServerList[indexPath.row];
AppDelegate.instance.obj.serverDescription = IsEmpty(item[@"serverDescription"]) ? @"" : item[@"serverDescription"];
AppDelegate.instance.obj.serverUser = IsEmpty(item[@"serverUser"]) ? @"" : item[@"serverUser"];
AppDelegate.instance.obj.serverPass = IsEmpty(item[@"serverPass"]) ? @"" : item[@"serverPass"];
BOOL useMdnsTest = YES;
if (!useMdnsTest) {
AppDelegate.instance.obj.serverIP = IsEmpty(item[@"serverIP"]) ? @"" : item[@"serverIP"];
} else {
NSString *resolvedIp = [mDNS lookup: item[@"serverIP"]];
AppDelegate.instance.obj.serverIP = IsEmpty(resolvedIp) ? @"" : [NSString stringWithFormat:@"[%@]", resolvedIp];
}
AppDelegate.instance.obj.serverPort = IsEmpty(item[@"serverPort"]) ? @"" : item[@"serverPort"];
AppDelegate.instance.obj.serverHWAddr = IsEmpty(item[@"serverMacAddress"]) ? @"" : item[@"serverMacAddress"];
AppDelegate.instance.obj.tcpPort = [item[@"tcpPort"] intValue];
}
- (void)netServiceDidResolveAddress: (NSNetService*)service {
for (NSData *data in [service addresses]) {
char addressBuffer[MAX(INET_ADDRSTRLEN, INET6_ADDRSTRLEN)];
struct sockaddr_in *socketAddress = (struct sockaddr_in*)[data bytes];
int sockFamily = socketAddress->sin_family;
if (sockFamily == AF_INET) {
const char *addressStr = inet_ntop(sockFamily,
&(socketAddress->sin_addr),
addressBuffer,
INET_ADDRSTRLEN);
int port = ntohs(socketAddress->sin_port);
if (addressStr && port) {
descriptionUI.text = service.name;
ipUI.text = [NSString stringWithFormat:@"%s", addressStr];
portUI.text = [NSString stringWithFormat:@"%d", port];
descriptionUI.textColor = [Utilities getSystemBlue];
ipUI.textColor = [Utilities getSystemBlue];
portUI.textColor = [Utilities getSystemBlue];
NSString *serverJSON = [NSString stringWithFormat:@"http://%@:%@/jsonrpc", ipUI.text, portUI.text];
NSURL *url = [[NSURL alloc] initWithString: serverJSON];
NSURLSession *pingSession = [NSURLSession sharedSession];
NSURLSessionDataTask *pingConnection = [pingSession dataTaskWithURL:url
completionHandler:^(NSData *data, NSURLResponse *response, NSError *error) {
dispatch_async(dispatch_get_main_queue(), ^{
[self fillMacAddressInfo];
});
}];
[pingConnection resume];
[Utilities AnimView:discoveredInstancesView AnimDuration:0.3 Alpha:1.0 XPos: self.view.frame.size.width];
}
}
else if (sockFamily == AF_INET6) {
const struct sockaddr_in6 *addr6 = (const struct sockaddr_in6*)[data bytes];
const char *addressStr = inet_ntop(AF_INET6,
&addr6->sin6_addr,
addressBuffer,
INET6_ADDRSTRLEN);
int port = ntohs(socketAddress->sin_port);
if (addressStr && port) {
descriptionUI.text = service.name;
ipUI.text = [NSString stringWithFormat:@"[%s]", addressStr];
portUI.text = [NSString stringWithFormat:@"%d", port];
descriptionUI.textColor = [Utilities getSystemBlue];
ipUI.textColor = [Utilities getSystemBlue];
portUI.textColor = [Utilities getSystemBlue];
NSString *serverJSON = [NSString stringWithFormat:@"http://%@:%@/jsonrpc", ipUI.text, portUI.text];
NSURL *url = [[NSURL alloc] initWithString: serverJSON];
NSURLSession *pingSession = [NSURLSession sharedSession];
NSURLSessionDataTask *pingConnection = [pingSession dataTaskWithURL:url
completionHandler:^(NSData *data, NSURLResponse *response, NSError *error) {
dispatch_async(dispatch_get_main_queue(), ^{
[self fillMacAddressInfo];
});
}];
[pingConnection resume];
[Utilities AnimView:discoveredInstancesView AnimDuration:0.3 Alpha:1.0 XPos: self.view.frame.size.width];
}
}
}
}
- (void)startNetworkCommunicationWithServer: (NSString*)server serverPort: (int)port {
if (port == 0) {
port = 9090;
}
if ([server isEqualToString:@""]) {
return;
}
// remove brackets for ipv6
server = [server stringByReplacingOccurrencesOfString:@"[" withString:@""];
server = [server stringByReplacingOccurrencesOfString:@"]" withString:@""];
CFReadStreamRef readStream;
CFStreamCreatePairWithSocketToHost(NULL, (CFStringRef)CFBridgingRetain(server), port, &readStream, NULL);
inStream = (__bridge NSInputStream*)readStream;
// outStream = (__bridge NSOutputStream*)writeStream;
inStream.delegate = self;
// outStream.delegate = self;
[inStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
// [outStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[inStream open];
// [outStream open];
CFRelease((__bridge CFTypeRef)server);
}
