//

//  TCPListener.m

//  MYNetwork

//

//  Created by Jens Alfke on 5/10/08.

//  Copyright 2008 Jens Alfke. All rights reserved.

//  Portions based on TCPServer class from Apple's "CocoaEcho" sample code.

#import "TCPListener.h"

#import "TCPConnection.h"

#import "Logging.h"

#import "Test.h"

#import "ExceptionUtils.h"

#import "IPAddress.h"

#include <sys/socket.h>

#include <netinet/in.h>

#include <unistd.h>

static void TCPListenerAcceptCallBack(CFSocketRef socket, CFSocketCallBackType type, 

                                      CFDataRef address, const void *data, void *info);

@interface TCPListener()

@property BOOL bonjourPublished;

@property NSInteger bonjourError;

- (void) _updateTXTRecord;

@end

@implementation TCPListener

- (id) initWithPort: (UInt16)port

{

    self = [super init];

    if (self != nil) {

        _port = port;

    }

    return self;

}

- (void) dealloc 

{

    [self close];

    LogTo(TCP,@"DEALLOC %@",self);

    [super dealloc];

}

@synthesize delegate=_delegate, port=_port, useIPv6=_useIPv6,

            bonjourServiceType=_bonjourServiceType, bonjourServiceName=_bonjourServiceName,

            bonjourPublished=_bonjourPublished, bonjourError=_bonjourError,

            pickAvailablePort=_pickAvailablePort;

- (NSString*) description

{

    return $sprintf(@"%@[port %hu]",self.class,_port);

}

// Stores the last error from CFSocketCreate or CFSocketSetAddress into *ouError.

static void* getLastCFSocketError( NSError **outError ) {

    if( outError )

        *outError = [NSError errorWithDomain: NSPOSIXErrorDomain code: errno userInfo: nil];

    return NULL;

}

// Closes a socket (if it's not already NULL), and returns NULL to assign to it.

static CFSocketRef closeSocket( CFSocketRef socket ) {

    if( socket ) {

        CFSocketInvalidate(socket);

        CFRelease(socket);

    }

    return NULL;

}

// opens a socket of a given protocol, either ipv4 or ipv6.

- (CFSocketRef) _openProtocol: (SInt32) protocolFamily 

                      address: (struct sockaddr*)address

                        error: (NSError**)error

{

    CFSocketContext socketCtxt = {0, self, NULL, NULL, NULL};

    CFSocketRef socket = CFSocketCreate(kCFAllocatorDefault, PF_INET, SOCK_STREAM, IPPROTO_TCP,

                                        kCFSocketAcceptCallBack, &TCPListenerAcceptCallBack, &socketCtxt);

    if( ! socket ) 

        return getLastCFSocketError(error);   // CFSocketCreate leaves error code in errno

    int yes = 1;

    setsockopt(CFSocketGetNative(socket), SOL_SOCKET, SO_REUSEADDR, (void *)&yes, sizeof(yes));

    NSData *addressData = [NSData dataWithBytes:address length:address->sa_len];

    if (kCFSocketSuccess != CFSocketSetAddress(socket, (CFDataRef)addressData)) {

        getLastCFSocketError(error);

        return closeSocket(socket);

    }

    // set up the run loop source for the socket

    CFRunLoopRef cfrl = CFRunLoopGetCurrent();

    CFRunLoopSourceRef source = CFSocketCreateRunLoopSource(kCFAllocatorDefault, socket, 0);

    CFRunLoopAddSource(cfrl, source, kCFRunLoopCommonModes);

    CFRelease(source);

    return socket;

}

- (BOOL) _failedToOpen: (NSError*)error

{

    LogTo(TCP,@"%@ failed to open: %@",self,error);

    [self tellDelegate: @selector(listener:failedToOpen:) withObject: error];

    return NO;

}

- (BOOL) open: (NSError**)outError 

{

    // set up the IPv4 endpoint; if port is 0, this will cause the kernel to choose a port for us

    do{

        struct sockaddr_in addr4;

        memset(&addr4, 0, sizeof(addr4));

        addr4.sin_len = sizeof(addr4);

        addr4.sin_family = AF_INET;

        addr4.sin_port = htons(_port);

        addr4.sin_addr.s_addr = htonl(INADDR_ANY);

        NSError *error;

        _ipv4socket = [self _openProtocol: PF_INET address: (struct sockaddr*)&addr4 error: &error];

        if( ! _ipv4socket ) {

            if( error.code==EADDRINUSE && _pickAvailablePort && _port<0xFFFF ) {

                LogTo(BLIPVerbose,@"%@: port busy, trying %hu...",self,_port+1);

                self.port++;        // try the next port

            } else {

                if( outError ) *outError = error;

                return [self _failedToOpen: error];

            }

        }

    }while( ! _ipv4socket );

    if (0 == _port) {

        // now that the binding was successful, we get the port number 

        NSData *addr = [(NSData *)CFSocketCopyAddress(_ipv4socket) autorelease];

        const struct sockaddr_in *addr4 = addr.bytes;

        self.port = ntohs(addr4->sin_port);

    }

    if( _useIPv6 ) {

        // set up the IPv6 endpoint

        struct sockaddr_in6 addr6;

        memset(&addr6, 0, sizeof(addr6));

        addr6.sin6_len = sizeof(addr6);

        addr6.sin6_family = AF_INET6;

        addr6.sin6_port = htons(_port);

        memcpy(&(addr6.sin6_addr), &in6addr_any, sizeof(addr6.sin6_addr));

        _ipv6socket = [self _openProtocol: PF_INET6 address: (struct sockaddr*)&addr6 error: outError];

        if( ! _ipv6socket ) {

            _ipv4socket = closeSocket(_ipv4socket);

            return [self _failedToOpen: *outError];

        }

    }

    // Open Bonjour:

    if( _bonjourServiceType && !_netService) {

        // instantiate the NSNetService object that will advertise on our behalf.

        _netService = [[NSNetService alloc] initWithDomain: @"local." 

                                                      type: _bonjourServiceType

                                                      name: _bonjourServiceName ?:@""

                                                      port: _port];

        if( _netService ) {

            [_netService setDelegate:self];

            if( _bonjourTXTRecord )

                [self _updateTXTRecord];

            [_netService publish];

        } else {

            self.bonjourError = -1;

            Warn(@"%@: Failed to create NSNetService",self);

        }

    }

    LogTo(TCP,@"%@ is open",self);

    [self tellDelegate: @selector(listenerDidOpen:) withObject: nil];

    return YES;

}

- (BOOL) open

{

    return [self open: nil];

}

- (void) close 

{

    if( _ipv4socket ) {

        if( _netService ) {

            [_netService stop];

            [_netService release];

            _netService = nil;

            self.bonjourPublished = NO;

        }

        self.bonjourError = 0;

        _ipv4socket = closeSocket(_ipv4socket);

        _ipv6socket = closeSocket(_ipv6socket);

        LogTo(BLIP,@"%@ is closed",self);

        [self tellDelegate: @selector(listenerDidClose:) withObject: nil];

    }

}

- (BOOL) isOpen

{

    return _ipv4socket != NULL;

}

#pragma mark -

#pragma mark ACCEPTING CONNECTIONS:

@synthesize connectionClass = _connectionClass;

- (BOOL) acceptConnection: (CFSocketNativeHandle)socket

{

    IPAddress *addr = [IPAddress addressOfSocket: socket];

    if( ! addr )

        return NO;

    if( [_delegate respondsToSelector: @selector(listener:shouldAcceptConnectionFrom:)]

       && ! [_delegate listener: self shouldAcceptConnectionFrom: addr] )

        return NO;

    Assert(_connectionClass);

    TCPConnection *conn = [[self.connectionClass alloc] initIncomingFromSocket: socket

                                                                      listener: self];

    if( ! conn )

        return NO;

    if( _sslProperties ) {

        conn.SSLProperties = _sslProperties;

        [conn setSSLProperty: $true forKey: (id)kCFStreamSSLIsServer];

    }

    [conn open];

    [self tellDelegate: @selector(listener:didAcceptConnection:) withObject: conn];

    return YES;

}

static void TCPListenerAcceptCallBack(CFSocketRef socket, CFSocketCallBackType type, CFDataRef address, const void *data, void *info) 

{

    TCPListener *server = (TCPListener *)info;

    if (kCFSocketAcceptCallBack == type) { 

        CFSocketNativeHandle nativeSocketHandle = *(CFSocketNativeHandle *)data;

        BOOL accepted = NO;

        @try{

            accepted = [server acceptConnection: nativeSocketHandle];

        }catchAndReport(@"TCPListenerAcceptCallBack");

        if( ! accepted )

            close(nativeSocketHandle);

    }

}

#pragma mark -

#pragma mark BONJOUR:

- (NSDictionary*) bonjourTXTRecord

{

    return _bonjourTXTRecord;

}

- (void) setBonjourTXTRecord: (NSDictionary*)txt

{

    if( ifSetObj(&_bonjourTXTRecord,txt) )

        [self _updateTXTRecord];

}

- (void) _updateTXTRecord

{

    if( _netService ) {

        NSData *data;

        if( _bonjourTXTRecord ) {

            data = [NSNetService dataFromTXTRecordDictionary: _bonjourTXTRecord];

            if( data )

                LogTo(BLIP,@"%@: Set %u-byte TXT record", self,data.length);

            else

                Warn(@"TCPListener: Couldn't convert txt dict to data: %@",_bonjourTXTRecord);

        } else

            data = nil;

        [_netService setTXTRecordData: data];

    }

}

- (void)netServiceWillPublish:(NSNetService *)sender

{

    LogTo(BLIP,@"%@: Advertising %@",self,sender);

    self.bonjourPublished = YES;

}

- (void)netService:(NSNetService *)sender didNotPublish:(NSDictionary *)errorDict

{

    self.bonjourError = [[errorDict objectForKey:NSNetServicesErrorCode] intValue];

    LogTo(BLIP,@"%@: Failed to advertise %@: error %i",self,sender,self.bonjourError);

    [_netService release];

    _netService = nil;

}

- (void)netServiceDidStop:(NSNetService *)sender

{

    LogTo(BLIP,@"%@: Stopped advertising %@",self,sender);

    self.bonjourPublished = NO;

    [_netService release];

    _netService = nil;

}

@end

/*

 Copyright (c) 2008, 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.

 */