git.maemo.org Git - theonering/blob - src/theonering.py

   1 #!/usr/bin/env python
   2
   3 """
   4 Telepathy-TheOneRing - Telepathy plugin for GoogleVoice
   5 Copyright (C) 2009  Ed Page eopage AT byu DOT net
   6
   7 This library is free software; you can redistribute it and/or
   8 modify it under the terms of the GNU Lesser General Public
   9 License as published by the Free Software Foundation; either
  10 version 2.1 of the License, or (at your option) any later version.
  11
  12 This library is distributed in the hope that it will be useful,
  13 but WITHOUT ANY WARRANTY; without even the implied warranty of
  14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  15 Lesser General Public License for more details.
  16
  17 You should have received a copy of the GNU Lesser General Public
  18 License along with this library; if not, write to the Free Software
  19 Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
  20 """
  21
  22 import os
  23 import sys
  24 import signal
  25 import logging
  26 import gobject
  27
  28 import dbus.glib
  29 import telepathy.utils as telepathy_utils
  30
  31 import util.linux as linux_utils
  32 import util.go_utils as gobject_utils
  33 import constants
  34 import connection_manager
  35
  36
  37 def run_theonering(persist):
  38         linux_utils.set_process_name(constants.__app_name__)
  39
  40         try:
  41                 os.makedirs(constants._data_path_)
  42         except OSError, e:
  43                 if e.errno != 17:
  44                         raise
  45
  46         @gobject_utils.async
  47         def on_quit():
  48                 manager.quit()
  49                 mainloop.quit()
  50
  51         def timeout_cb():
  52                 if len(manager._connections) == 0:
  53                         logging.info('No connection received - quitting')
  54                         on_quit()
  55                 return False
  56
  57         if persist:
  58                 shutdown_callback = None
  59         else:
  60                 gobject_utils.timeout_add_seconds(
  61                         connection_manager.TheOneRingConnectionManager.IDLE_TIMEOUT,
  62                         timeout_cb
  63                 )
  64                 shutdown_callback = on_quit
  65
  66         signal.signal(signal.SIGTERM, lambda: on_quit)
  67
  68         try:
  69                 manager = connection_manager.TheOneRingConnectionManager(shutdown_func=shutdown_callback)
  70         except dbus.exceptions.NameExistsException:
  71                 logging.warning('Failed to acquire bus name, connection manager already running?')
  72                 sys.exit(1)
  73
  74         mainloop = gobject.MainLoop(is_running=True)
  75
  76         gobject.threads_init()
  77         dbus.glib.init_threads()
  78         while mainloop.is_running():
  79                 try:
  80                         mainloop.run()
  81                 except KeyboardInterrupt:
  82                         quit()
  83
  84
  85 def main(logToFile):
  86         try:
  87                 os.makedirs(constants._data_path_)
  88         except OSError, e:
  89                 if e.errno != 17:
  90                         raise
  91
  92         telepathy_utils.debug_divert_messages(os.getenv('THEONERING_LOGFILE'))
  93         logFormat = '(%(asctime)s) %(levelname)-5s %(threadName)s.%(name)s: %(message)s'
  94         logging.raiseExceptions = True # Getting funky shutdown behavior, checking it out
  95         if logToFile:
  96                 logging.basicConfig(
  97                         level=logging.DEBUG,
  98                         filename=constants._user_logpath_,
  99                         format=logFormat,
 100                         datefmt='%H:%M:%S',
 101                 )
 102         else:
 103                 logging.basicConfig(
 104                         level=logging.DEBUG,
 105                         format=logFormat,
 106                         datefmt='%H:%M:%S',
 107                 )
 108         logging.info("telepathy-theonering %s-%s" % (constants.__version__, constants.__build__))
 109         logging.debug("OS: %s" % (os.uname()[0], ))
 110         logging.debug("Kernel: %s (%s) for %s" % os.uname()[2:])
 111         logging.debug("Hostname: %s" % os.uname()[1])
 112
 113         persist = 'THEONERING_PERSIST' in os.environ
 114
 115         try:
 116                 run_theonering(persist)
 117         finally:
 118                 logging.shutdown()
 119
 120
 121 if __name__ == "__main__":
 122         main(False)