/** Implementation of the DKProxy class representing D-Bus objects on the
    GNUstep side.
   Copyright (C) 2010 Free Software Foundation, Inc.

   Written by:  Niels Grewe <niels.grewe@halbordnung.de>
   Created: May 2010

   This library is free software; you can redistribute it and/or
   modify it under the terms of the GNU Lesser General Public
   License as published by the Free Software Foundation; either
   version 2 of the License, or (at your option) any later version.

   This library is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
   Library General Public License for more details.

   You should have received a copy of the GNU Lesser General Public
   License along with this library; if not, write to the Free
   Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
   Boston, MA 02111 USA.
   */

#import "DKArgument.h"
#import "DKEndpoint.h"
#import "DKEndpointManager.h"
#import "DKInterface.h"
#import "DKIntrospectionParserDelegate.h"
#import "DKMethod.h"
#import "DKMethodCall.h"
#import "DKProxy+Private.h"

#import "DBusKit/DKNotificationCenter.h"

#define INCLUDE_RUNTIME_H
#include "config.h"
#undef INCLUDE_RUNTIME_H

#import <Foundation/NSCoder.h>
#import <Foundation/NSData.h>
#import <Foundation/NSException.h>
#import <Foundation/NSDictionary.h>
#import <Foundation/NSInvocation.h>
#import <Foundation/NSLock.h>
#import <Foundation/NSMapTable.h>
#import <Foundation/NSMethodSignature.h>
#import <Foundation/NSNotification.h>
#import <Foundation/NSRunLoop.h>
#import <Foundation/NSString.h>
#import <Foundation/NSThread.h>
#import <Foundation/NSValue.h>
#import <Foundation/NSXMLParser.h>
#import <GNUstepBase/GSObjCRuntime.h>
#import <GNUstepBase/NSDebug+GNUstepBase.h>

#include <string.h>

/*
 * Definitions of the strings used for selector mangling.
 */
#define SEL_MANGLE_IFSTART_STRING @"_DKIf_"
#define SEL_MANGLE_IFEND_STRING @"_DKIfEnd_"


static SEL getEndpointSelector;
static SEL getServiceNameSelector;
static IMP getEndpoint;
static IMP getServiceName;

#define DK_PORT_ENDPOINT getEndpoint(port, getEndpointSelector)
#define DK_PORT_SERVICE getServiceName(port, getServiceNameSelector)

enum
{
  NO_TABLES,
  HAVE_TABLES,
  HAVE_INTROSPECT,
  WILL_BUILD_CACHE,
  BUILDING_CACHE,
  CACHE_BUILT,
  CACHE_READY
};

@interface DKProxy (DKProxyInternal)

- (void)_setupTables;
- (DKMethod*)_methodForSelector: (SEL)aSelector
                   waitForCache: (BOOL)doWait;
- (BOOL)_buildMethodCache: (id)ignored;
- (void)_installIntrospectionMethod;

/* Define introspect on ourselves. */
- (NSString*)Introspect;
@end

@interface DKPort (DKPortPrivate)
- (id)initWithRemote: (NSString*)remote
          atEndpoint: (DKEndpoint*)ep;
@end

@interface NSXMLParser (GSSloppyParserMode)
- (void) _setAcceptHTML: (BOOL)yesno;
@end

@interface DKNotificationCenter (DKNotificationCenterStateSync)
- (void)_syncStateWithEndpoint: (DKEndpoint*)ep;
@end

DKInterface *_DKInterfaceIntrospectable;

@implementation DKProxy

+ (void)initialize
{
  if ([DKProxy class] == self)
  {
    // Trigger generation of static introspection method:
    DKArgument *xmlOutArg = nil;
    DKMethod *introspect = nil;
    _DKInterfaceIntrospectable = [[DKInterface alloc] initWithName: [NSString stringWithUTF8String: DBUS_INTERFACE_INTROSPECTABLE]
                                                            parent: nil];
    introspect = [[DKMethod alloc] initWithName: @"Introspect"
                                         parent: _DKInterfaceIntrospectable];
    xmlOutArg = [[DKArgument alloc] initWithDBusSignature: "s"
                                                     name: @"data"
                                                   parent: introspect];
    [introspect addArgument: xmlOutArg
                  direction: kDKArgumentDirectionOut];
    [_DKInterfaceIntrospectable addMethod: introspect];
    [_DKInterfaceIntrospectable installMethod: introspect
                                  forSelector: @selector(Introspect)];
    [introspect release];
    [xmlOutArg release];
    getEndpointSelector = @selector(endpoint);
    getEndpoint = class_getMethodImplementation([DKPort class],
      getEndpointSelector);
    getServiceNameSelector = @selector(serviceName);
    getServiceName = class_getMethodImplementation([DKPort class],
      getServiceNameSelector);
  }
}

+ (id)proxyWithService: (NSString*)aService
                  path: (NSString*)aPath
                   bus: (DKDBusBusType)type
{
  return [[[self alloc] initWithService: aService
                                   path: aPath
				    bus: type] autorelease];
}

+ (id)proxyWithPort: (DKPort*)aPort
               path: (NSString*)aPath
{
  return [[[self alloc] initWithPort: aPort
                                path: aPath] autorelease];
}

- (id)initWithService: (NSString*)aService
                 path: (NSString*)aPath
                  bus: (DKDBusBusType)type
{
  DKPort *aPort = [[DKPort alloc] initWithRemote: aService
                                           onBus: type];

  id ret = [self initWithPort: aPort
                         path: aPath];
  [aPort release];
  return ret;
}

/**
 * Legacy initializer:
 */
- (id)initWithEndpoint: (DKEndpoint*)ep
            andService: (NSString*)aService
               andPath: (NSString*)aPath
{
  DKPort *aPort = [[DKPort alloc] initWithRemote: aService
                                      atEndpoint: ep];
  id ret = [self initWithPort: aPort
                         path: aPath];
  [aPort release];
  return ret;
}

- (id)initWithPort: (DKPort*)aPort
              path: (NSString*)aPath
{
  // This class derives from NSProxy, hence no call to -[super init].
  if (((nil == aPort)) || (nil == aPath))
  {
    [self release];
    return nil;
  }
  ASSIGNCOPY(path, aPath);
  ASSIGN(port, aPort);
  tableLock = [[NSLock alloc] init];
  condition = [[NSCondition alloc] init];
  state = NO_TABLES;
  [self _setupTables];
  [self _installIntrospectionMethod];
  return self;
}

- (id)initWithCoder: (NSCoder*)coder
{
  DKEndpoint *endpoint = nil;
  NSString *service = nil;
  if ([coder allowsKeyedCoding])
  {
    endpoint = [coder decodeObjectForKey: @"DKProxyEndpoint"];
    service = [coder decodeObjectForKey: @"DKProxyService"];
    path = [coder decodeObjectForKey: @"DKProxyPath"];
  }
  else
  {
    [coder decodeValueOfObjCType: @encode(id) at: &endpoint];
    [coder decodeValueOfObjCType: @encode(id) at: &service];
    [coder decodeValueOfObjCType: @encode(id) at: &path];
  }
  port = [[DKPort alloc] initWithRemote: service
                             atEndpoint: endpoint];
  tableLock = [[NSLock alloc] init];
  condition = [[NSCondition alloc] init];
  state = NO_TABLES;
  [self _setupTables];
  [self _installIntrospectionMethod];
  return self;
}

- (void) encodeWithCoder: (NSCoder*)coder
{
  if ([coder allowsKeyedCoding])
  {
    [coder encodeObject: DK_PORT_ENDPOINT forKey: @"DKProxyEndpoint"];
    [coder encodeObject: DK_PORT_SERVICE forKey: @"DKProxyService"];
    [coder encodeObject: path forKey: @"DKProxyPath"];
  }
  else
  {
    [coder encodeObject: DK_PORT_ENDPOINT];
    [coder encodeObject: DK_PORT_SERVICE];
    [coder encodeObject: path];
  }
}

/**
 * Overrides the implementation in NSProxy, which would wrap this proxy in an
 * NSDistantObject
 */
- (id)replacementObjectForPortCoder: (NSPortCoder*)coder
{
  return self;
}

/**
 * Overrides NSProxy.
 */
- (Class)classForPortCoder
{
  return [DKProxy class];
}

- (BOOL)conformsToProtocol: (Protocol*)aProto
{
  NSEnumerator *ifEnum = [interfaces objectEnumerator];
  DKInterface *anIf = nil;
  if (protocol_isEqual(@protocol(DKObjectPathNode), aProto))
  {
    return YES;
  }
  while (nil != (anIf = [ifEnum nextObject]))
  {
    if (protocol_isEqual([anIf protocol], aProto))
    {
      return YES;
    }
  }
  return [super conformsToProtocol: aProto];
}

/**
 * Triggers generation of the method cache. This will schedule generation of the
 * cache on the worker thread or execute it locally if this code is already
 * being executed on the worker thread.
 *
 * This is not that much useful if cache generation is requested directly by
 * -methodSignatureForSelector (it will go on and block right away because it
 * needs the cache), but it is quite handy if we want to update the cache
 * periodically.
 */
- (void)DBusBuildMethodCache
{
  // Make sure we don't try to build the cache multiple times:
  [condition lock];
  if (WILL_BUILD_CACHE == state)
  {
    [condition unlock];

    [[DKEndpointManager sharedEndpointManager] boolReturnForPerformingSelector: @selector(_buildMethodCache:)
                                                                        target: self
                                                                          data: NULL
                                                                 waitForReturn: YES];
  }
  else
  {
    [condition unlock];
  }
}

/**
 * Returns the DKMethod that handles the selector.
 */
- (DKMethod*)DBusMethodForSelector: (SEL)selector
{
  DKMethod *m = nil;
  const char* selName;

  if (0 == selector)
  {
    return nil;
  }


  /*
   * We need the "Introspect" selector to build the method cache and gurantee
   * that there is a method available for it. Hence, we won't wait for the cache
   * to be build when looking it up.
   */
  if (sel_isEqual(@selector(Introspect), selector))
  {
    m = [self _methodForSelector: @selector(Introspect)
                    waitForCache: NO];
  }

  /*
   * For "Introspect", we now will have a method. We need to look one up for
   * everything else now:
   */
  if (nil == m)
  {
    /* If we don't have a cache yet, we trigger it's generation */
    [condition lock];
    if (HAVE_INTROSPECT >= state)
    {
      state = WILL_BUILD_CACHE;
      [condition unlock];
      [self DBusBuildMethodCache];
    }
    else
    {
      [condition unlock];
    }

    // Normalize the selector to its untyped version:
    selName = sel_getName(selector);
    selector = sel_getUid(selName);

    /* Retry, but this time, block until the introspection data is resolved. */
    m = [self _methodForSelector: selector
                    waitForCache: YES];
  }

  return m;
}

- (void)setPrimaryDBusInterface: (NSString*)anInterface
{
  if (interfaces == nil)
  {
    // The interfaces have not yet been resolved, so we temporarily store the
    // string until the method resolution has run.
    ASSIGNCOPY(activeInterface, anInterface);
  }
  else
  {
    DKInterface *theIf = [interfaces objectForKey: anInterface];
    ASSIGN(activeInterface, theIf);
  }
}

/**
 * Returns the interface corresponding to the mangled version in which all dots
 * have been replaced with underscores.
 */
- (NSString*)DBusInterfaceForMangledString: (NSString*)string
{
  DKInterface *anIf = nil;
  NSEnumerator *enumerator = nil;
  if (nil == string)
  {
    return nil;
  }
  [tableLock lock];
  enumerator =[interfaces objectEnumerator];

  while (nil != (anIf = [enumerator nextObject]))
  {
    if ([string isEqualToString: [anIf mangledName]])
    {
      [tableLock unlock];
      return [anIf name];
    }
  }
  [tableLock unlock];
  return nil;
}

/**
 * This method strips the metadata mangled into the selector string and
 * returns it at shallBox and interface.
 */

- (SEL)_unmangledSelector: (SEL)selector
                interface: (NSString**)interface
{
  NSMutableString *selectorString = [NSStringFromSelector(selector) mutableCopy];
  SEL unmangledSelector = 0;

  NSRange ifStartRange = [selectorString rangeOfString: SEL_MANGLE_IFSTART_STRING];
  NSRange ifEndRange = [selectorString rangeOfString: SEL_MANGLE_IFEND_STRING];

  if (0 == selector)
  {
    [selectorString release];
    return 0;
  }

  // Sanity check for presence and order of both the starting and the ending
  // string.
  if ((NSNotFound != ifStartRange.location)
    && (NSNotFound != ifEndRange.location)
    && (NSMaxRange(ifStartRange) < ifEndRange.location))
  {
    // Do not dereference NULL
    if (interface != NULL)
    {
      // Calculate the range of the interface string between the two:
      NSUInteger ifIndex = NSMaxRange(ifStartRange);
      NSUInteger ifLength = (ifEndRange.location - ifIndex);
      NSRange ifRange = NSMakeRange(ifIndex, ifLength);

      // Extract and unmangle the information
      NSString *mangledIf = [selectorString substringWithRange: ifRange];
      *interface = [self DBusInterfaceForMangledString: mangledIf];
    }

    // Throw away the whole _DKIf_*_DKEndIf_ portion.
    [selectorString deleteCharactersInRange: NSUnionRange(ifStartRange, ifEndRange)];
  }

  unmangledSelector = NSSelectorFromString(selectorString);
  [selectorString release];
  return unmangledSelector;
}

/**
 * Overrides the implementation in NSProxy.
 */
- (BOOL)respondsToSelector: (SEL)aSelector
{
  if (class_respondsToSelector([DKProxy class], aSelector))
  {
    return YES;
  }
  if ([self DBusMethodForSelector: aSelector])
  {
    return YES;
  }
  return NO;
}

- (NSMethodSignature*)methodSignatureForSelector: (SEL)aSelector
{
  /*
   * For simple cases we can simply look up the selector in the table and return
   * the signature from the associated method.
   */
  DKMethod *method = [self DBusMethodForSelector: aSelector];
  const char *types = NULL;
  NSMethodSignature *theSig = nil;
  types = GSTypesFromSelector(aSelector);

  // Build a signature with the types:
  theSig = [NSMethodSignature signatureWithObjCTypes: types];

  /*
   * Second chance to find the method: Remove mangling constructs from the
   * selector string.
   */
  if (nil == method)
  {
    NSString *interface = nil;
    SEL unmangledSel = [self _unmangledSelector: aSelector
                                      interface: &interface];
    if (0 == unmangledSel)
    {
      // We can't do anything then.
      return nil;
    }

    if (nil != interface)
    {
      // The interface was specified. Retrieve the corresponding method;
      [tableLock lock];
      method = [(DKInterface*)[interfaces objectForKey: interface] DBusMethodForSelector: unmangledSel];
      [tableLock unlock];
    }
    else
    {
      // No interface, so we try the standard dispatch table:
      method = [self DBusMethodForSelector: unmangledSel];
    }
  }


  // Finally check whether we have a sensible method and signature:
  if (nil == method)
  {
    // Bad luck, the method is not there:
    return nil;
  }
  else if ([method isValidForMethodSignature: theSig])
  {
    // Good, the method can handle the signature for which we are being called:
    return theSig;
  }
  else
  {
    // Bad luck, we got a method, but it is not compatible with this method
    // signature:
    [NSException raise: @"DKInvalidArgumentException"
                format: @"D-Bus object %@ for service %@: Mismatched method signature.",
      path,
      DK_PORT_SERVICE];
  }

  return nil;
}

/**
 * Retrieves the D-Bus method for the selector. The <var>doWait</var> flag is
 * used to determine whether the method should wait for the cache to be built.
 * This is, however, not expedient if we are looking up the introspection
 * selector that is used to build the cache.
 */
- (DKMethod*) _methodForSelector: (SEL)aSel
                    waitForCache: (BOOL)doWait
{
  DKMethod *m = nil;
  // Cache the implementation pointer for method retrieval.
  SEL retrievalSelector = @selector(DBusMethodForSelector:);
  IMP retrieveDBusMethod = class_getMethodImplementation([DKInterface class],
    retrievalSelector);
  NSRunLoop *rl = nil;
  BOOL inWorkerThread = DKInWorkerThread;
  NSAssert(retrieveDBusMethod, @"No method retrieval implementation in DKInterface.");
  if (inWorkerThread)
  {
    rl = [NSRunLoop currentRunLoop];
  }
  [condition lock];
  if (doWait)
  {
    // Wait until it is signaled that the cache has been built:
    while (CACHE_READY != state)
    {
      if (inWorkerThread)
      {
	[condition unlock];
	[rl runUntilDate: [NSDate dateWithTimeIntervalSinceNow: 0.01]];
        [condition lock];
      }
      else
      {
	[condition wait];
      }
    }
  }

  [tableLock lock];
  if ([activeInterface isKindOfClass: [DKInterface class]])
  {
    // If an interface was marked active, try to find the selector there first
    // (the interface will perform its own locking).
    m = retrieveDBusMethod(activeInterface, retrievalSelector, aSel);
  }
  if (nil == m)
  {
    NSEnumerator *ifEnum = [interfaces objectEnumerator];
    DKInterface *thisIf = nil;
    while ((nil == m) && (nil != (thisIf = [ifEnum nextObject])))
    {
      m = retrieveDBusMethod(thisIf, retrievalSelector, aSel);
    }
  }

  [tableLock unlock];
  [condition unlock];
  return m;
}

- (void)forwardInvocation: (NSInvocation*)inv
{
  SEL selector = [inv selector];
  NSMethodSignature *signature = [inv methodSignature];
  NSString *interface = nil;
  DKMethod *method = [self DBusMethodForSelector: selector];
  DKMethodCall *call = nil;

  if (nil == method)
  {
    SEL newSel = 0;
    newSel = [self _unmangledSelector: selector
                            interface: &interface];
    if (0 != newSel)
    {
      [inv setSelector: newSel];
      if (nil != interface)
      {
	[tableLock lock];
	method = [(DKInterface*)[interfaces objectForKey: interface] DBusMethodForSelector: newSel];
        [tableLock unlock];
      }
      else
      {
	method = [self DBusMethodForSelector: newSel];
      }
    }
  }
  if (nil == method)
  {
    // If so, we cannot do anything more:
    [NSException raise: @"DKInvalidArgumentException"
                format: @"D-Bus object %@ for service %@ does not recognize %@",
      path,
      DK_PORT_SERVICE,
     NSStringFromSelector(selector)];
  }

  if (NO == [method isValidForMethodSignature: signature])
  {
    [NSException raise: @"DKInvalidArgumentException"
                format: @"D-Bus object %@ for service %@: Mismatched method signature.",
      path,
      DK_PORT_SERVICE];
  }

  call = [[DKMethodCall alloc] initWithProxy: self
                                      method: method
                                  invocation: inv
				     timeout: 5000];

  //TODO: Implement asynchronous method calls using futures
  [call sendSynchronously];
  [call release];
}

- (BOOL)isKindOfClass: (Class)aClass
{
  if (aClass == [DKProxy class])
  {
    return YES;
  }
  return NO;
}

- (DKPort*)_port
{
  return port;
}

- (void)_setPort: (DKPort*)aPort
{
  ASSIGN(port, aPort);
}

- (DKEndpoint*)_endpoint
{
  return DK_PORT_ENDPOINT;
}

- (NSString*)_service
{
  return DK_PORT_SERVICE;
}

- (NSString*)_path
{
  return path;
}

- (NSString*)_uniqueName
{
  DKDBusBusType type = [DK_PORT_ENDPOINT DBusBusType];
  DKDBus *bus = [DKDBus busWithBusType: type];
  NSString *uniqueName = nil;

  NS_DURING
  {
    uniqueName = [(id<DKDBusStub>)bus GetNameOwner: DK_PORT_SERVICE];
  }
  NS_HANDLER
  {
    if (NO == [[localException name] isEqualToString: @"DKDBusRemoteErrorException"])
    {
      // This is not simply the D-Bus error we'd might expect, we need to
      // re-raise it.
      [localException raise];
    }
    // Otherwise, continue, the name was simply not available. We return nil;
  }
  NS_ENDHANDLER
  return uniqueName;
}


- (BOOL)_isLocal
{
  // True only for outgoing proxies representing local objects.
  return NO;
}

- (NSDictionary*)_interfaces
{
  NSDictionary *theDict = nil;
  [tableLock lock];
  theDict = [NSDictionary dictionaryWithDictionary: interfaces];
  [tableLock unlock];
  return theDict;
}

- (id) proxyParent
{
  return self;
}

- (BOOL) hasSameScopeAs: (DKProxy*)aProxy
{
  return [port isEqual: [aProxy _port]];
}

- (void) _installIntrospectionMethod
{
  [condition lock];
  while (HAVE_TABLES != state)
  {
    [condition wait];
  }
  [self _addInterface: _DKInterfaceIntrospectable];

  state = HAVE_INTROSPECT;
  [condition broadcast];
  [condition unlock];
}

- (void) _registerSignalsFromInterface: (DKInterface*)theIf
{
  [theIf registerSignals];
}

- (void)_registerSignalsWithNotificationCenter: (DKNotificationCenter*)center
{

  NSEnumerator *ifEnum = nil;
  DKInterface *theIf = nil;
  [tableLock lock];
  NS_DURING
  {
    ifEnum = [interfaces objectEnumerator];
    while (nil != (theIf = [ifEnum nextObject]))
    {
      [theIf registerSignalsWithNotificationCenter: center];
    }
  }
  NS_HANDLER
  {
    [tableLock unlock];
    [localException raise];
  }
  NS_ENDHANDLER
  [tableLock unlock];
}

/**
 * Causes all interfaces to generate their dispatch tables.
 */
- (void) _installAllInterfaces
{
  NSEnumerator *ifEnum = nil;
  DKInterface *theIf = nil;
  [condition lock];
  while (CACHE_BUILT != state)
  {
    [condition wait];
  }
  [tableLock lock];
  ifEnum = [interfaces objectEnumerator];
  while (nil != (theIf = [ifEnum nextObject]))
  {
    [theIf installMethods];
    [theIf installProperties];
    [self _registerSignalsFromInterface: theIf];
  }
  [tableLock unlock];

  state = CACHE_READY;
  [condition broadcast];
  [condition unlock];

}

- (void)_setupTables
{
  if ((nil == interfaces) || (nil == children))
  {
    if (NO_TABLES == state)
    {
      [condition lock];
      if (NO_TABLES != state)
      {
	[condition unlock];
        return;
      }
      else
      {
	[tableLock lock];
      }
      if (nil == interfaces)
      {
	interfaces = [NSMutableDictionary new];
      }
      if (nil == children)
      {
	children = [NSMutableArray new];
      }
      [tableLock unlock];
      state = HAVE_TABLES;
      [condition broadcast];
      [condition unlock];
    }
  }
}

- (void)_addInterface: (DKInterface*)interface
{
  NSString *ifName = [interface name];
  if (nil != ifName)
  {
    // Only add named interfaces:
    [tableLock lock];
    [interfaces setObject: interface
                   forKey: ifName];
    // Check whether this is the interface we need to activate:
    if ([activeInterface isKindOfClass: [NSString class]])
    {
      if ([ifName isEqualToString: (NSString*)activeInterface])
      {
	ASSIGN(activeInterface, interface);
      }
    }
    [tableLock unlock];
  }
}

- (void)_addChildNode: (DKObjectPathNode*)node
{
  if (nil != node)
  {
    [tableLock lock];
    [children addObject: node];
    [tableLock unlock];
  }
}

- (BOOL)_buildMethodCache: (id)ignored
{
  DKIntrospectionParserDelegate *delegate = [[DKIntrospectionParserDelegate alloc] initWithParentForNodes: self];
  NSXMLParser *parser = nil;
  NSData *introspectionData = nil;


  [condition lock];
  while (WILL_BUILD_CACHE != state)
  {
    [condition wait];
  }
  state = BUILDING_CACHE;
  [condition unlock];

  // Get the introspection data, reset ourselves
  NS_DURING
  {
    introspectionData = [[self Introspect] dataUsingEncoding: NSUTF8StringEncoding];
  }
  NS_HANDLER
  {
    [condition lock];
    if (CACHE_READY != state)
    {
      state = HAVE_INTROSPECT;
    }
    [delegate release];
    [condition broadcast];
    [condition unlock];
    [localException raise];
  }
  NS_ENDHANDLER

  [condition lock];

  if (BUILDING_CACHE == state)
  {
    // Set up parser and delegate:
    parser = [[NSXMLParser alloc] initWithData: introspectionData];
    [parser setDelegate: delegate];

    // Workaround for situations where gnustep-base is using its sloppy parser:
    if ([parser respondsToSelector: @selector( _setAcceptHTML:)])
    {
      //[parser  _setAcceptHTML: YES];
    }

    // Generate the introspection tree:
    [parser parse];

    state = CACHE_BUILT;
    [condition broadcast];
  }

  if (CACHE_BUILT == state)
  {
    [condition unlock];
    [self _installAllInterfaces];
  }
  else
  {
    [condition unlock];
  }

  // Cleanup
  [parser release];
  [delegate release];
  return YES;
}

- (void) dealloc
{
  [port release];
  [path release];
  [interfaces release];
  [children release];
  [activeInterface release];
  [tableLock release];
  [condition release];
  [super dealloc];
}

@end

static NSRecursiveLock *busLock;
static DKProxy *systemBus;
static DKProxy *sessionBus;

NSString* DKBusDisconnectedNotification = @"DKDBusDisconnectedNotification";
NSString* DKBusReconnectedNotification = @"DKBusReconnectedNotification";
@implementation DKDBus
+ (void)initialize
{
  if (self == [DKDBus class])
  {
    busLock = [[NSRecursiveLock alloc] init];
  }
}

+ (id)sessionBus
{
  if (sessionBus == nil)
  {
    [busLock lock];
    if (sessionBus == nil)
    {
      DKEndpoint *ep = [[DKEndpointManager sharedEndpointManager] endpointForWellKnownBus: DBUS_BUS_SESSION];
      sessionBus = [[DKDBus alloc] initWithEndpoint: ep
                                         andService: @"org.freedesktop.DBus"
                                            andPath: @"/org/freedesktop/DBus"];
    }
    [busLock unlock];
  }
  return sessionBus;
}

+ (id)systemBus
{
  if (systemBus == nil)
  {
    [busLock lock];
    if (systemBus == nil)
    {
      DKEndpoint *ep = [[DKEndpointManager sharedEndpointManager] endpointForWellKnownBus: DBUS_BUS_SYSTEM];
      systemBus = [[DKDBus alloc] initWithEndpoint: ep
                                        andService: @"org.freedesktop.DBus"
                                           andPath: @"/"];
    }
    [busLock unlock];
  }
  return systemBus;
}

+ (id)busWithBusType: (DKDBusBusType)type
{
  switch (type)
  {
    case DKDBusSessionBus:
      return [self sessionBus];
    case DKDBusSystemBus:
      return [self systemBus];
    default:
      return nil;
  }
  return nil;
}

- (id)initWithEndpoint: (DKEndpoint*)anEndpoint
            andService: (NSString*)aService
               andPath: (NSString*)aPath
{
  BOOL willBeSessionBus = NO;
  BOOL willBeSystemBus = NO;
  DBusConnection *testConnection = NULL;
  DBusConnection *endpointConnection = NULL;
  DKNonAutoInvalidatingPort *aPort = nil;
  [busLock lock];
  if (NO == [aService isEqualToString: @"org.freedesktop.DBus"])
  {
    [self release];
    return nil;
  }
  if (NO == [aPath isEqualToString: @"/org/freedesktop/DBus"])
  {
    if (NO == [aPath isEqualToString: @"/"])
    {
      [self release];
      return nil;
    }
  }
  if (anEndpoint == nil)
  {
    [self release];
    return nil;
  }
  /*
   * We determine for which bus we are being created by taking advantage of the
   * fact that D-Bus will cache connections: If we already got a connection to
   * the session bus, we will get the same one back.
   */
  endpointConnection = [anEndpoint DBusConnection];
  testConnection = dbus_bus_get(DBUS_BUS_SESSION, NULL);
  willBeSessionBus = (endpointConnection == testConnection);
  if (willBeSessionBus && (nil != sessionBus))
  {
    dbus_connection_unref(testConnection);
    [self release];
    return (DKDBus*)sessionBus;
  }
  dbus_connection_unref(testConnection);

  testConnection = dbus_bus_get(DBUS_BUS_SYSTEM, NULL);

  if (NO == willBeSessionBus)
  {
    willBeSystemBus = (endpointConnection == testConnection);
    if (willBeSystemBus && (systemBus != nil))
    {
      dbus_connection_unref(testConnection);
      [self release];
      return (DKDBus*)systemBus;
    }
    dbus_connection_unref(testConnection);
  }

  /*
   * We should now be sure that we are being initialized for either the system
   * or the session bus. To do that, we create an instance of a special DKPort
   * subclass that does not perform auto-invalidation. The reason for this is
   * that auto-invalidation needs to go via the DKNotificationCenter, which in
   * turn has a dependency on the corresponding bus object (which we are just
   * initializing). Using an DKNonAutoInvalidatingPort avoids this circular
   * dependency.
   */
  aPort = [[[DKNonAutoInvalidatingPort alloc] initWithRemote: aService
                                                  atEndpoint: anEndpoint] autorelease];

  if (nil == (self = [super initWithPort: aPort
                                    path: aPath]))
  {
    return nil;
  }

  /*
   * If we got an object, we are legitimately creating a DKBus object. Thus, we
   * assign the object to the appropriate global variable.
   */
  if (willBeSystemBus)
  {
    systemBus = self;
  }
  else if (willBeSessionBus)
  {
    sessionBus = self;
  }

  [self DBusBuildMethodCache];
  [busLock unlock];
  return self;
}

- (void)release
{
  // No-Op.
}

- (id)autorelease
{
  return self;
}

- (id)retain
{
  return self;
}

- (NSUInteger)retainCount
{
  return UINT_MAX;
}

- (void)setPrimaryDBusInterface: (NSString*)interface
{
  /*
   * No-Op. This is a shared object, we cannot let one caller change stuff the
   * other callers won't know about.
   */
   NSWarnMLog(@"'%@' called for a shared DKDBus object.", NSStringFromSelector(_cmd));
}

- (NSString*)_uniqueName
{
  /*
   * Overriding this is a significiant optimisation. We already know that only
   * one bus object exists per bus and that it is named org.freedesktop.DBus. We
   * do not need to do any roundtrips to D-Bus to find out about this. Since
   * many things (e.g. the notification center) need to find out about the
   * unique name, we save quite a lot by overriding the method.
   */
  return @"org.freedesktop.DBus";
}


- (void) _registerSignalsFromInterface: (DKInterface*)theIf
{
  // We override this to avoid triggering reentrancy from the notification
  // center.
}

- (void)_disconnected: (NSNotification*)n
{
  /*
   * Make sure that we only schedule our reconnection once:
   */
  if (__sync_bool_compare_and_swap(&isDisconnected, 0, 1))
  {
    DKEndpoint *ep = [self _endpoint];
    DKDBusBusType type = [ep DBusBusType];
    [[DKEndpointManager sharedEndpointManager] attemptRecoveryForEndpoint: ep
                                                                    proxy: self];

    [[NSNotificationCenter defaultCenter] postNotificationName: DKBusDisconnectedNotification
                                                        object: self
                                                      userInfo:
      [NSDictionary dictionaryWithObjectsAndKeys: [NSNumber numberWithInt: type],
      @"busType", nil]];
    [self _setPort: nil];
    NSDebugMLog(@"Disconnected from D-Bus");
  }
}

- (void)_reconnectedWithEndpoint: (DKEndpoint*)anEndpoint
{
  if (nil == anEndpoint)
  {
    return;
  }
  if (__sync_bool_compare_and_swap(&isDisconnected, 1, 0))
  {
    DKPort *aPort = [[DKPort alloc] initWithRemote: @"org.freedesktop.DBus"
                                        atEndpoint: anEndpoint];
    DKDBusBusType type = [anEndpoint DBusBusType];
    [self _setPort: aPort];
    [aPort release];
    NSDebugMLog(@"Reconnected to D-Bus");
    [[NSNotificationCenter defaultCenter] postNotificationName: DKBusReconnectedNotification
                                                        object: self
                                                      userInfo:
      [NSDictionary dictionaryWithObjectsAndKeys: [NSNumber numberWithInt: type],
      @"busType", nil]];
    [[DKNotificationCenter centerForBusType: type] _syncStateWithEndpoint: anEndpoint];
  }

}

- (NSMethodSignature*)methodSignatureForSelector: (SEL)aSel
{
  if (sel_isEqual(@selector(_disconnected:), aSel))
  {
    return [NSMethodSignature signatureWithObjCTypes: "v@:@"];
  }
  return [super methodSignatureForSelector: aSel];
}
@end