-
-
Notifications
You must be signed in to change notification settings - Fork 1.8k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
netplay discovery through bonjour/mdns
- Loading branch information
1 parent
a33ec20
commit b1fdbb9
Showing
8 changed files
with
353 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,307 @@ | ||
| #import <Foundation/Foundation.h> | ||
| #import <Foundation/NSNetServices.h> | ||
|
|
||
| #import "netplay_private.h" | ||
|
|
||
| #import "content.h" | ||
| #import "../../frontend/frontend_driver.h" | ||
| #import "paths.h" | ||
| #import "version.h" | ||
|
|
||
| #define NETPLAY_MDNS_TYPE "_ra_netplay._tcp" | ||
|
|
||
| @interface NetplayBonjourMan : NSObject<NSNetServiceDelegate, NSNetServiceBrowserDelegate> | ||
|
|
||
| @property (strong, nonatomic) NSNetService *service; | ||
| @property (strong, nonatomic) NSNetServiceBrowser *browser; | ||
| @property (strong, atomic) NSMutableArray<NSNetService*> *services; | ||
|
|
||
| + (NetplayBonjourMan*)shared; | ||
| - (void)publish:(netplay_t *)netplay; | ||
| - (void)unpublish; | ||
| - (void)browse; | ||
| - (void)finishBrowsing:(net_driver_state_t *)net_st; | ||
|
|
||
| @end | ||
|
|
||
| static NetplayBonjourMan *nbm_instance; | ||
|
|
||
| @implementation NetplayBonjourMan | ||
|
|
||
| #pragma mark - (Semi-)Public API | ||
|
|
||
| + (NetplayBonjourMan*)shared | ||
| { | ||
| if (!nbm_instance) | ||
| nbm_instance = [[NetplayBonjourMan alloc] init]; | ||
| return nbm_instance; | ||
| } | ||
|
|
||
| - (void)publish:(netplay_t *)netplay | ||
| { | ||
| self.service = [[NSNetService alloc] initWithDomain:@"" type:@NETPLAY_MDNS_TYPE name:@"" port:netplay->tcp_port]; | ||
| [self.service setTXTRecordData:[self TXTdataFromNetplay:netplay]]; | ||
| [self.service setDelegate:self]; | ||
| [self.service publish]; | ||
| } | ||
|
|
||
| - (void)unpublish | ||
| { | ||
| [self.service stop]; | ||
| self.service = nil; | ||
| } | ||
|
|
||
| - (void)browse | ||
| { | ||
| self.services = [NSMutableArray arrayWithCapacity: 0]; | ||
| dispatch_async(dispatch_get_main_queue(), ^{ | ||
| self.browser = [[NSNetServiceBrowser alloc] init]; | ||
| [self.browser setDelegate:self]; | ||
| [self.browser searchForServicesOfType:@NETPLAY_MDNS_TYPE inDomain:@""]; | ||
| }); | ||
| } | ||
|
|
||
| - (void)finishBrowsing:(net_driver_state_t *)net_st | ||
| { | ||
| [self.browser stop]; | ||
| for (NSNetService *srv in self.services) | ||
| { | ||
| if (![srv.addresses count] || [srv port] <= 0 || ![srv TXTRecordData]) | ||
| continue; | ||
|
|
||
| NSDictionary<NSString*,NSData*> *txt = [NSNetService dictionaryFromTXTRecordData:[srv TXTRecordData]]; | ||
| if (!txt) | ||
| continue; | ||
|
|
||
| char address[16] = {0}; | ||
| for (NSData *addr_data in [srv addresses]) | ||
| { | ||
| struct sockaddr_storage *their_addr = (struct sockaddr_storage *)[addr_data bytes]; | ||
| if (!addr_6to4(their_addr)) | ||
| continue; | ||
| if (!getnameinfo_retro((struct sockaddr*)their_addr, sizeof(struct sockaddr_storage), | ||
| address, sizeof(address), NULL, 0, NI_NUMERICHOST)) | ||
| break; | ||
| } | ||
| if (!address[0]) | ||
| continue; | ||
|
|
||
| /* Make sure we don't already know about it */ | ||
| long port = [srv port]; | ||
| size_t iter; | ||
| for (iter = 0; iter < net_st->discovered_hosts.size; iter++) | ||
| if (port != net_st->discovered_hosts.hosts[iter].port || | ||
| !string_is_equal(address, net_st->discovered_hosts.hosts[iter].address)) | ||
| continue; | ||
|
|
||
| /* Allocate space for it */ | ||
| if (net_st->discovered_hosts.size >= net_st->discovered_hosts.allocated) | ||
| { | ||
| if (!net_st->discovered_hosts.size) | ||
| { | ||
| net_st->discovered_hosts.hosts = (struct netplay_host*) | ||
| malloc(sizeof(*net_st->discovered_hosts.hosts)); | ||
| if (!net_st->discovered_hosts.hosts) | ||
| return; | ||
| net_st->discovered_hosts.allocated = 1; | ||
| } | ||
| else | ||
| { | ||
| size_t new_allocated = net_st->discovered_hosts.allocated + 4; | ||
| struct netplay_host *new_hosts = (struct netplay_host*)realloc( | ||
| net_st->discovered_hosts.hosts, | ||
| new_allocated * sizeof(*new_hosts)); | ||
|
|
||
| if (!new_hosts) | ||
| { | ||
| free(net_st->discovered_hosts.hosts); | ||
| memset(&net_st->discovered_hosts, 0, | ||
| sizeof(net_st->discovered_hosts)); | ||
|
|
||
| return; | ||
| } | ||
|
|
||
| net_st->discovered_hosts.allocated = new_allocated; | ||
| net_st->discovered_hosts.hosts = new_hosts; | ||
| } | ||
| } | ||
|
|
||
| struct netplay_host *host = &net_st->discovered_hosts.hosts[net_st->discovered_hosts.size++]; | ||
|
|
||
| NSString *crc = [[NSString alloc] initWithData:txt[@"content_crc"] encoding:NSUTF8StringEncoding]; | ||
| NSScanner *scanner = [NSScanner scannerWithString:crc]; | ||
| unsigned int content_crc; | ||
| [scanner scanHexInt:&content_crc]; | ||
| host->content_crc = (int)ntohl(content_crc); | ||
| host->port = (int)port; | ||
|
|
||
| strlcpy(host->address, address, sizeof(host->address)); | ||
| strlcpy(host->nick, [txt[@"nick"] bytes], [txt[@"nick"] length] + 1); | ||
| strlcpy(host->frontend, [txt[@"frontend"] bytes], [txt[@"frontend"] length] + 1); | ||
| strlcpy(host->core, [txt[@"core"] bytes], [txt[@"core"] length] + 1); | ||
| strlcpy(host->core_version, [txt[@"core_version"] bytes], [txt[@"core_version"] length] + 1); | ||
| strlcpy(host->retroarch_version, [txt[@"retroarch_version"] bytes], [txt[@"retroarch_version"] length] + 1); | ||
| strlcpy(host->content, [txt[@"content"] bytes], [txt[@"content"] length] + 1); | ||
| strlcpy(host->subsystem_name, [txt[@"subsystem_name"] bytes], [txt[@"subsystem_name"] length] + 1); | ||
|
|
||
| host->has_password = [[[NSString alloc] initWithData:txt[@"has_password"] encoding:NSUTF8StringEncoding] isEqualToString:@"true"]; | ||
| host->has_spectate_password = [[[NSString alloc] initWithData:txt[@"has_spectate_password"] encoding:NSUTF8StringEncoding] isEqualToString:@"true"]; | ||
| } | ||
| } | ||
|
|
||
| #pragma mark - Browse helper functions | ||
|
|
||
| - (void)netServiceBrowser:(NSNetServiceBrowser *)browser | ||
| didFindService:(NSNetService *)service | ||
| moreComing:(BOOL)moreComing | ||
| { | ||
| [service resolveWithTimeout:0.9f]; | ||
| [self.services addObject:service]; | ||
| } | ||
|
|
||
| - (void)netServiceBrowser:(NSNetServiceBrowser *)browser | ||
| didRemoveService:(NSNetService *)service | ||
| moreComing:(BOOL)moreComing | ||
| { | ||
| [self.services removeObject:service]; | ||
| } | ||
|
|
||
| #pragma mark - Publish helper functions | ||
|
|
||
| - (NSData *)TXTdataFromNetplay:(netplay_t *)netplay | ||
| { | ||
| return [NSNetService dataFromTXTRecordDictionary:@{ | ||
| @"content_crc": [self content_crc], | ||
| @"nick": [self nick:netplay], | ||
| @"frontend": [self frontend], | ||
| @"core": [self core], | ||
| @"core_version": [self core_version], | ||
| @"retroarch_version": [self retroarch_version], | ||
| @"content": [self content], | ||
| @"subsystem_name": [self subsystem_name], | ||
| @"has_password": [self has_password], | ||
| @"has_spectate_password": [self has_spectate_password] | ||
| }]; | ||
| } | ||
|
|
||
| - (NSData *)content_crc | ||
| { | ||
| uint32_t crc = 0; | ||
| struct string_list *subsystem = path_get_subsystem_list(); | ||
| if (!subsystem || subsystem->size <= 0) | ||
| crc = content_get_crc(); | ||
| return [[NSString stringWithFormat:@"%08x", (uint32_t)htonl(crc)] dataUsingEncoding:NSUTF8StringEncoding]; | ||
| } | ||
|
|
||
| - (NSData *)nick:(netplay_t *)netplay | ||
| { | ||
| return [[NSData alloc] initWithBytes:netplay->nick length:strlen(netplay->nick)]; | ||
| } | ||
|
|
||
| - (NSData *)frontend | ||
| { | ||
| char frontend_architecture_tmp[24]; | ||
| const frontend_ctx_driver_t *frontend_drv; | ||
|
|
||
| frontend_drv = (const frontend_ctx_driver_t*) | ||
| frontend_driver_get_cpu_architecture_str(frontend_architecture_tmp, | ||
| sizeof(frontend_architecture_tmp)); | ||
| NSString *frontend; | ||
| if (frontend_drv) | ||
| frontend = [NSString stringWithFormat:@"%s %s", frontend_drv->ident, frontend_architecture_tmp]; | ||
| else | ||
| frontend = @"N/A"; | ||
| return [frontend dataUsingEncoding:NSUTF8StringEncoding]; | ||
| } | ||
|
|
||
| - (NSData *)core | ||
| { | ||
| struct retro_system_info *system = &runloop_state_get_ptr()->system.info; | ||
| return [[NSData alloc] initWithBytes:system->library_name length:strlen(system->library_name)]; | ||
| } | ||
|
|
||
| - (NSData *)core_version | ||
| { | ||
| struct retro_system_info *system = &runloop_state_get_ptr()->system.info; | ||
| return [[NSData alloc] initWithBytes:system->library_version length:strlen(system->library_version)]; | ||
| } | ||
|
|
||
| - (NSData *)retroarch_version | ||
| { | ||
| return [[NSData alloc] initWithBytes:PACKAGE_VERSION length:strlen(PACKAGE_VERSION)]; | ||
| } | ||
|
|
||
| - (NSData *)content | ||
| { | ||
| struct string_list *subsystem = path_get_subsystem_list(); | ||
| if (subsystem && subsystem->size > 0) | ||
| { | ||
| unsigned i; | ||
| NSMutableData *data = [[NSMutableData alloc] init]; | ||
|
|
||
| for (i = 0;;) | ||
| { | ||
| const char *pb = path_basename(subsystem->elems[i].data); | ||
| [data appendBytes:pb length:strlen(pb)]; | ||
| if (++i >= subsystem->size) | ||
| break; | ||
| [data appendBytes:"|" length:strlen("|")]; | ||
| } | ||
| return data; | ||
| } | ||
| else | ||
| { | ||
| const char *basename = path_basename(path_get(RARCH_PATH_BASENAME)); | ||
| if (string_is_empty(basename)) | ||
| basename = "N/A"; | ||
| return [[NSData alloc] initWithBytes:basename length:strlen(basename)]; | ||
| } | ||
| } | ||
|
|
||
| - (NSData *)subsystem_name | ||
| { | ||
| struct string_list *subsystem = path_get_subsystem_list(); | ||
| if (subsystem && subsystem->size > 0) | ||
| { | ||
| const char *path = path_get(RARCH_PATH_SUBSYSTEM); | ||
| return [[NSData alloc] initWithBytes:path length:strlen(path)]; | ||
| } | ||
| else | ||
| return [[NSData alloc] initWithBytes:"N/A" length:3]; | ||
| } | ||
|
|
||
| - (NSData *)has_password | ||
| { | ||
| settings_t *settings = config_get_ptr(); | ||
| const char *has_password = string_is_empty(settings->paths.netplay_password) ? "false" : "true"; | ||
| return [[NSData alloc] initWithBytes:has_password length:strlen(has_password)]; | ||
| } | ||
|
|
||
| - (NSData *)has_spectate_password | ||
| { | ||
| settings_t *settings = config_get_ptr(); | ||
| const char *has_password = string_is_empty(settings->paths.netplay_spectate_password) ? "false" : "true"; | ||
| return [[NSData alloc] initWithBytes:has_password length:strlen(has_password)]; | ||
| } | ||
|
|
||
| @end | ||
|
|
||
| void netplay_mdns_publish(netplay_t *netplay) | ||
| { | ||
| [[NetplayBonjourMan shared] publish:netplay]; | ||
| } | ||
|
|
||
| void netplay_mdns_unpublish(void) | ||
| { | ||
| [[NetplayBonjourMan shared] unpublish]; | ||
| } | ||
|
|
||
| void netplay_mdns_start_discovery(void) | ||
| { | ||
| [[NetplayBonjourMan shared] browse]; | ||
| } | ||
|
|
||
| void netplay_mdns_finish_discovery(net_driver_state_t *net_st) | ||
| { | ||
| [[NetplayBonjourMan shared] finishBrowsing:net_st]; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.