#!/usr/bin/python

import string
import gobject
import avahi

import dbus
from dbus.mainloop.glib import DBusGMainLoop

## setup some globals 
serviceName = "WFUT Server"
serviceType = "_wfut._tcp"
servicePort = 0;
serviceTXT = ""

domain = "local"
host = ""

group = None
rename_count = 12

## Root of http server
serverRoot="./"

def add_service():
    global group, serviceName, serviceType, servicePort, serviceTXT, domain, host
    if group is None:
        group = dbus.Interface(
                bus.get_object( avahi.DBUS_NAME, server.EntryGroupNew()),
                avahi.DBUS_INTERFACE_ENTRY_GROUP)
        group.connect_to_signal('StateChanged', entry_group_state_changed)

    print "Adding service '%s' of type '%s' ..." % (serviceName, serviceType)

    group.AddService(
            avahi.IF_UNSPEC,    #interface
            avahi.PROTO_UNSPEC, #protocol
            0,                  #flags
            serviceName, serviceType,
            domain, host,
            dbus.UInt16(servicePort),
            avahi.string_array_to_txt_array(serviceTXT))
    group.Commit()

def remove_service():
    global group

    if not group is None:
        group.Reset()

def server_state_changed(state):
    if state == avahi.SERVER_COLLISION:
        print "WARNING: Server name collision"
        remove_service()
    elif state == avahi.SERVER_RUNNING:
        add_service()

def entry_group_state_changed(state, error):
    global serviceName, server, rename_count

    print "state change: %i" % state

    if state == avahi.ENTRY_GROUP_ESTABLISHED:
        print "Service established."
    elif state == avahi.ENTRY_GROUP_COLLISION:

        rename_count = rename_count - 1
        if rename_count > 0:
            name = server.GetAlternativeServiceName(name)
            print "WARNING: Service name collision, changing name to '%s' ..." % name
            remove_service()
            add_service()

        else:
            print "ERROR: No suitable service name found after %i retries, exiting." % n_rename
            main_loop.quit()
    elif state == avahi.ENTRY_GROUP_FAILURE:
        print "Error in group state changed", error
        main_loop.quit()
        return

from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer
class WFUTHandler(BaseHTTPRequestHandler):

  def do_GET(self):

    ## If no path is specified, then stick up a little message
    if self.path == "/":
      self.wfile.write("WFUT Server")
      return

    try:
      ## log file access
      print(string.join(["Accessing:", self.path]))

      ## open file and transmit content
      f = open(serverRoot + "/" + self.path)
      self.send_response(200)
      self.send_header('Content-type', 'application/octet-stream');
      self.end_headers();
      self.wfile.write(f.read());
      f.close();

    except IOError:
      self.send_error(404, 'File Not Found: %s' % self.path)


if __name__ == '__main__':
    DBusGMainLoop( set_as_default=True )

    main_loop = gobject.MainLoop()
    bus = dbus.SystemBus()

    ## TODO; Read config file

    import sys,getopt
    optlist, args = getopt.getopt(sys.argv[1:], "p:")

    for (arg, opt) in optlist:
        ## Extract port number
        if arg == '-p': servicePort = int(opt);

    ## TODO: Bind to particular address?
    ws = HTTPServer(('', servicePort), WFUTHandler)

    ## Generate server url
    url = string.join(["http://", ws.server_name, ":", str(ws.server_port), "/"], "");

    print "Server URL is: " + url

    ## Extract port number
    servicePort = ws.server_port;

    server = dbus.Interface(
            bus.get_object( avahi.DBUS_NAME, avahi.DBUS_PATH_SERVER ),
            avahi.DBUS_INTERFACE_SERVER )

    server.connect_to_signal( "StateChanged", server_state_changed )
    server_state_changed( server.GetState() )

    try:

      context = main_loop.get_context()

      while True:
        # Handle commands here
        ws.handle_request();

        # Allow gobject/dbus/avahi to do something
        context.iteration(True)

        # main_loop.run()

    except KeyboardInterrupt:
      pass

    if not group is None:
      group.Free()