//

//  MYBonjourBrowser.m

//  MYNetwork

//

//  Created by Jens Alfke on 1/22/08.

//  Copyright 2008 Jens Alfke. All rights reserved.

//

#import "MYBonjourBrowser.h"

#import "MYBonjourService.h"

#import "MYBonjourRegistration.h"

#import "ExceptionUtils.h"

#import "Test.h"

#import "Logging.h"

#import <dns_sd.h>

static void browseCallback (DNSServiceRef                       sdRef,

                            DNSServiceFlags                     flags,

                            uint32_t                            interfaceIndex,

                            DNSServiceErrorType                 errorCode,

                            const char                          *serviceName,

                            const char                          *regtype,

                            const char                          *replyDomain,

                            void                                *context);

@interface MYBonjourBrowser ()

@property BOOL browsing;

- (void) _updateServiceList;

@end

@implementation MYBonjourBrowser

- (id) initWithServiceType: (NSString*)serviceType

{

    Assert(serviceType);

    self = [super init];

    if (self != nil) {

        self.continuous = YES;

        _serviceType = [serviceType copy];

        _services = [[NSMutableSet alloc] init];

        _addServices = [[NSMutableSet alloc] init];

        _rmvServices = [[NSMutableSet alloc] init];

        _serviceClass = [MYBonjourService class];

    }

    return self;

}

- (void) dealloc

{

    LogTo(Bonjour,@"DEALLOC BonjourBrowser");

    [_myRegistration cancel];

    [_myRegistration release];

    [_serviceType release];

    [_services release];

    [_addServices release];

    [_rmvServices release];

    [super dealloc];

}

@synthesize browsing=_browsing, services=_services, serviceClass=_serviceClass;

- (NSString*) description

{

    return $sprintf(@"%@[%@]", self.class,_serviceType);

}

- (DNSServiceErrorType) createServiceRef: (DNSServiceRef*)sdRefPtr {

    return DNSServiceBrowse(sdRefPtr,

                            kDNSServiceFlagsShareConnection, 

                            0,

                            _serviceType.UTF8String, NULL,

                            &browseCallback, self);

}

- (void) priv_gotError: (DNSServiceErrorType)errorCode {

    LogTo(Bonjour,@"%@ got error %i", self,errorCode);

    self.error = errorCode;

}

- (void) priv_gotServiceName: (NSString*)serviceName

                        type: (NSString*)regtype

                      domain: (NSString*)domain

                   interface: (uint32_t)interfaceIndex

                       flags: (DNSServiceFlags)flags

{

    // Create (or reuse existing) MYBonjourService object:

    MYBonjourService *service = [[_serviceClass alloc] initWithName: serviceName

                                                               type: regtype

                                                             domain: domain

                                                          interface: interfaceIndex];

    if ([_myRegistration isSameAsService: service]) {

        // This is an echo of my own registration, so ignore it

        LogTo(Bonjour,@"%@ ignoring echo %@", self,service);

        [service release];

        return;

    }

    MYBonjourService *existingService = [_services member: service];

    if( existingService ) {

        // Use existing service object instead of creating a new one

        [service release];

        service = [existingService retain];

    }

    // Add it to the add/remove sets:

    NSMutableSet *addTo, *removeFrom;

    if (flags & kDNSServiceFlagsAdd) {

        addTo = _addServices;

        removeFrom = _rmvServices;

    } else {

        addTo = _rmvServices;

        removeFrom = _addServices;

    }

    if( [removeFrom containsObject: service] )

        [removeFrom removeObject: service];

    else

        [addTo addObject: service];

    [service release];

    // Schedule a (single) call to _updateServiceList:

    if (!_pendingUpdate) {

        [self performSelector: @selector(_updateServiceList) withObject: nil afterDelay: 0];

        _pendingUpdate = YES;

    }

}

- (void) _updateServiceList

{

    _pendingUpdate = NO;

    if( _rmvServices.count ) {

        [self willChangeValueForKey: @"services" 

                    withSetMutation: NSKeyValueMinusSetMutation

                       usingObjects: _rmvServices];

        [_services minusSet: _rmvServices];

        [self didChangeValueForKey: @"services" 

                   withSetMutation: NSKeyValueMinusSetMutation

                      usingObjects: _rmvServices];

        [_rmvServices makeObjectsPerformSelector: @selector(removed)];

        [_rmvServices removeAllObjects];

    }

    if( _addServices.count ) {

        [_addServices makeObjectsPerformSelector: @selector(added)];

        [self willChangeValueForKey: @"services" 

                    withSetMutation: NSKeyValueUnionSetMutation

                       usingObjects: _addServices];

        [_services unionSet: _addServices];

        [self didChangeValueForKey: @"services" 

                   withSetMutation: NSKeyValueUnionSetMutation

                      usingObjects: _addServices];

        [_addServices removeAllObjects];

    }

}

static void browseCallback (DNSServiceRef                       sdRef,

                            DNSServiceFlags                     flags,

                            uint32_t                            interfaceIndex,

                            DNSServiceErrorType                 errorCode,

                            const char                          *serviceName,

                            const char                          *regtype,

                            const char                          *replyDomain,

                            void                                *context)

{

    MYBonjourBrowser *browser = context;

    @try{

        //LogTo(Bonjour,@"browseCallback (error=%i, name='%s')", errorCode,serviceName);

        if (!errorCode)

            [browser priv_gotServiceName: [NSString stringWithUTF8String: serviceName]

                                    type: [NSString stringWithUTF8String: regtype]

                                  domain: [NSString stringWithUTF8String: replyDomain]

                               interface: interfaceIndex

                                   flags: flags];

    }catchAndReport(@"Bonjour");

    [browser gotResponse: errorCode];

}

- (void) cancel {

    [_myRegistration stop];

    [super cancel];

}

- (MYBonjourRegistration *) myRegistration {

    if (!_myRegistration)

        _myRegistration = [[MYBonjourRegistration alloc] initWithServiceType: _serviceType port: 0];

    return _myRegistration;

}

@end

#pragma mark -

#pragma mark TESTING:

#if DEBUG

#import "MYBonjourQuery.h"

#import "MYAddressLookup.h"

@interface BonjourTester : NSObject

{

    MYBonjourBrowser *_browser;

}

@end

@implementation BonjourTester

- (id) init

{

    self = [super init];

    if (self != nil) {

        _browser = [[MYBonjourBrowser alloc] initWithServiceType: @"_presence._tcp"];

        [_browser addObserver: self forKeyPath: @"services" 

                      options: NSKeyValueObservingOptionOld | NSKeyValueObservingOptionNew 

                      context: NULL];

        [_browser addObserver: self forKeyPath: @"browsing" 

                      options: NSKeyValueObservingOptionNew

                      context: NULL];

        [_browser start];

        MYBonjourRegistration *myReg = _browser.myRegistration;

        myReg.port = 12346;

        Assert([myReg start]);

    }

    return self;

}

- (void) dealloc

{

    [_browser stop];

    [_browser removeObserver: self forKeyPath: @"services"];

    [_browser removeObserver: self forKeyPath: @"browsing"];

    [_browser release];

    [super dealloc];

}

- (void)observeValueForKeyPath:(NSString *)keyPath ofObject:(id)object change:(NSDictionary *)change context:(void *)context

{

    Log(@"Observed change in %@: %@",keyPath,change);

    if( $equal(keyPath,@"services") ) {

        if( [[change objectForKey: NSKeyValueChangeKindKey] intValue]==NSKeyValueChangeInsertion ) {

            NSSet *newServices = [change objectForKey: NSKeyValueChangeNewKey];

            for( MYBonjourService *service in newServices ) {

                NSString *hostname = service.hostname;  // block till it's resolved

                Log(@"##### %@ : at %@:%hu, TXT=%@", 

                      service, hostname, service.port, service.txtRecord);

                service.addressLookup.continuous = YES;

                [service.addressLookup addObserver: self

                                        forKeyPath: @"addresses"

                                           options: NSKeyValueObservingOptionOld | NSKeyValueObservingOptionNew

                                           context: NULL];

                [service queryForRecord: kDNSServiceType_NULL];

            }

        } else if( [[change objectForKey: NSKeyValueChangeKindKey] intValue]==NSKeyValueChangeRemoval ) {

            NSSet *oldServices = [change objectForKey: NSKeyValueChangeOldKey];

            for( MYBonjourService *service in oldServices ) {

                Log(@"##### REMOVED: %@", service);

                [service.addressLookup removeObserver: self forKeyPath: @"addresses"];

            }

        }

    }

}

@end

TestCase(Bonjour) {

    EnableLogTo(Bonjour,YES);

    EnableLogTo(DNS,YES);

    [NSRunLoop currentRunLoop]; // create runloop

    BonjourTester *tester = [[BonjourTester alloc] init];

    [[NSRunLoop currentRunLoop] runUntilDate: [NSDate dateWithTimeIntervalSinceNow: 1500]];

    [tester release];

}

#endif

/*

 Copyright (c) 2008-2009, Jens Alfke <jens@mooseyard.com>. All rights reserved.

 Redistribution and use in source and binary forms, with or without modification, are permitted

 provided that the following conditions are met:

 * Redistributions of source code must retain the above copyright notice, this list of conditions

 and the following disclaimer.

 * Redistributions in binary form must reproduce the above copyright notice, this list of conditions

 and the following disclaimer in the documentation and/or other materials provided with the

 distribution.

 THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR

 IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND 

 FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRI-

 BUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES

 (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 

  PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 

 CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF 

 THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

 */