Logo Search packages:      
Sourcecode: tahoe-lafs version File versions  Download package

macapp.py

import operator
import os
import stat
from subprocess import Popen, PIPE
import sys
import thread
import threading
import traceback
import urllib
import webbrowser

import wx
from twisted.internet import reactor
from twisted.python import log, logfile

import allmydata
from allmydata import client
from allmydata.gui.confwiz import ConfWizApp, ACCOUNT_PAGE, DEFAULT_SERVER_URL
from allmydata.scripts.common import get_aliases
import amdicon
import amdlogo

DEFAULT_FUSE_TIMEOUT = 300

TRY_TO_INSTALL_TAHOE_SCRIPT = True
TAHOE_SCRIPT = '''#!/bin/bash
if [ "x${*}x" == "xx" ]
then
    %(exe)s --help
else
    %(exe)s "${@}"
fi
'''

def run_macapp():
    nodedir = os.path.expanduser('~/.tahoe')
    if not os.path.isdir(nodedir):
        app_supp = os.path.expanduser('~/Library/Application Support/Allmydata Tahoe/')
        if not os.path.isdir(app_supp):
            os.makedirs(app_supp)
        os.symlink(app_supp, nodedir)

    app_cont = AppContainer(nodedir)
    return app_cont.run()

00047 class MacGuiClient(client.Client):
    """
    This is a subclass of the tahoe 'client' node, which hooks into the
    client's 'notice something went wrong' mechanism, to display the fact
    in a manner sensible for a wx gui app
    """
    def __init__(self, nodedir, app_cont):
        self.app_cont = app_cont
        client.Client.__init__(self, nodedir)

    def _service_startup_failed(self, failure):
        wx.CallAfter(self.wx_abort, failure)
        log.msg('node service startup failed')
        log.err(failure)

    def wx_abort(self, failure):
        wx.MessageBox(failure.getTraceback(), 'Fatal Error in Node startup')
        self.app_cont.guiapp.ExitMainLoop()

00066 class AppContainer(object):
    """
    This is the 'container' for the mac app, which takes care of initial
    configuration concerns - e.g. running the confwiz before going any further -
    of launching the reactor, and within it the tahoe node, on a separate thread,
    and then lastly of launching the actual wx gui app and waiting for it to exit.
    """
    def __init__(self, nodedir):
        self.nodedir = nodedir

    def files_exist(self, file_list):
        extant_conf = [ os.path.exists(os.path.join(self.nodedir, f)) for f in file_list ]
        return reduce(operator.__and__, extant_conf)

    def is_config_incomplete(self):
        necessary_conf_files = ['introducer.furl', 'private/root_dir.cap']
        need_config = not self.files_exist(necessary_conf_files)
        if need_config:
            print 'some config is missing from nodedir (%s): %s' % (self.nodedir, necessary_conf_files)
        return need_config

    def run(self):
        # handle initial config
        if not os.path.exists(os.path.join(self.nodedir, 'webport')):
            f = file(os.path.join(self.nodedir, 'webport'), 'wb')
            f.write('3456')
            f.close()

        if self.is_config_incomplete():
            confwiz = ConfWizApp(DEFAULT_SERVER_URL, open_welcome_page=True)
            confwiz.MainLoop()

        if self.is_config_incomplete():
            print 'config still incomplete; confwiz cancelled, exiting'
            return 1

        # set up twisted logging. this will become part of the node rsn.
        logdir = os.path.join(self.nodedir, 'logs')
        if not os.path.exists(logdir):
            os.makedirs(logdir)
        lf = logfile.LogFile('tahoesvc.log', logdir)
        log.startLogging(lf)

        if TRY_TO_INSTALL_TAHOE_SCRIPT:
            self.maybe_install_tahoe_script()

        # actually start up the node and the ui
        os.chdir(self.nodedir)

        # start the reactor thread up, launch the tahoe node therein
        self.start_reactor()

        try:
            # launch the actual gui on the wx event loop, wait for it to quit
            self.guiapp = MacGuiApp(app_cont=self)
            self.guiapp.MainLoop()
            log.msg('gui mainloop exited')
        except:
            log.err()

        # shutdown the reactor, hence tahoe node, before exiting
        self.stop_reactor()

        return 0

    def start_reactor(self):
        self.reactor_shutdown = threading.Event()
        thread.start_new_thread(self.launch_reactor, ())

    def launch_reactor(self):
        # run the node itself
        #c = client.Client(self.nodedir)
        c = MacGuiClient(self.nodedir, app_cont=self)
        reactor.callLater(0, c.startService) # after reactor startup
        reactor.run(installSignalHandlers=False)
        self.reactor_shutdown.set()

    def stop_reactor(self):
        # trigger reactor shutdown, and block waiting on it
        reactor.callFromThread(reactor.stop)
        log.msg('waiting for reactor shutdown')
        self.reactor_shutdown.wait()
        log.msg('reactor shut down')

    def maybe_install_tahoe_script(self):
        path_candidates = ['/usr/local/bin', '~/bin', '~/Library/bin']
        env_path = map(os.path.expanduser, os.environ['PATH'].split(':'))
        if not sys.executable.endswith('/python'):
            print 'not installing tahoe script: unexpected sys.exe "%s"' % (sys.executable,)
            return
        for path_candidate in map(os.path.expanduser, env_path):
            tahoe_path = path_candidate + '/tahoe'
            if os.path.exists(tahoe_path):
                print 'not installing "tahoe": it already exists at "%s"' % (tahoe_path,)
                return
        for path_candidate in map(os.path.expanduser, path_candidates):
            if path_candidate not in env_path:
                print path_candidate, 'not in', env_path
                continue
            tahoe_path = path_candidate + '/tahoe'
            try:
                print 'trying to install "%s"' % (tahoe_path,)
                bin_path = (sys.executable[:-6] + 'Allmydata')
                script = TAHOE_SCRIPT % { 'exe': bin_path }
                f = file(tahoe_path, 'wb')
                f.write(script)
                f.close()
                mode = stat.S_IRUSR|stat.S_IXUSR|stat.S_IRGRP|stat.S_IXGRP|stat.S_IROTH|stat.S_IXOTH
                os.chmod(tahoe_path, mode)
                print 'installed "%s"' % (tahoe_path,)
                return
            except:
                print 'unable to write %s' % (tahoe_path,)
                traceback.print_exc()
        else:
            print 'no remaining candidate paths for installation of tahoe script'


def DisplayTraceback(message):
    xc = traceback.format_exception(*sys.exc_info())
    wx.MessageBox(u"%s\n (%s)"%(message,''.join(xc)), 'Error')

WEBOPEN_ID = wx.NewId()
ACCOUNT_PAGE_ID = wx.NewId()
MOUNT_ID = wx.NewId()

class SplashFrame(wx.Frame):
    def __init__(self):
        no_resz = wx.DEFAULT_FRAME_STYLE & ~ (wx.MINIMIZE_BOX|wx.RESIZE_BORDER|wx.MAXIMIZE_BOX)
        wx.Frame.__init__(self, None, -1, 'Allmydata', style=no_resz)

        self.SetSizeHints(100, 100, 600, 800)
        self.SetIcon(amdicon.getIcon())
        self.Bind(wx.EVT_CLOSE, self.on_close)

        background = wx.Panel(self, -1)
        background.parent = self
        self.login_panel = SplashPanel(background, self.on_close)
        sizer = wx.BoxSizer(wx.VERTICAL)
        background_sizer = wx.BoxSizer(wx.VERTICAL)
        background_sizer.Add(self.login_panel, 1, wx.ALIGN_CENTER_HORIZONTAL | wx.ALL, 26)
        background.SetSizer(background_sizer)
        sizer.Add(background, 0, wx.EXPAND | wx.ALL, 0)
        self.SetSizer(sizer)
        self.SetAutoLayout(True)
        self.Fit()
        self.Layout()

    def on_close(self, event):
        self.Show(False)

class SplashPanel(wx.Panel):
    def __init__(self, parent, on_close):
        wx.Panel.__init__(self, parent, -1)
        self.parent = parent

        hbox = wx.BoxSizer(wx.HORIZONTAL)
        vbox = wx.BoxSizer(wx.VERTICAL)
        self.sizer = wx.BoxSizer(wx.VERTICAL)

        self.icon = wx.StaticBitmap(self, -1, amdlogo.getBitmap())
        self.label = wx.StaticText(self, -1, 'Allmydata')
        bigfont = self.label.GetFont()
        bigfont.SetPointSize(26)
        smlfont = self.label.GetFont()
        smlfont.SetPointSize(10)
        self.label.SetFont(bigfont)
        ver = "Version 3.0 (%s)" % (allmydata.__version__,)
        self.ver_label = wx.StaticText(self, -1, ver)
        self.ver_label.SetFont(smlfont)
        copy = u"Copyright \N{COPYRIGHT SIGN} 2004-2008 Allmydata Inc.,"
        self.copy_label = wx.StaticText(self, -1, copy)
        self.copy_label.SetFont(smlfont)
        self.res_label = wx.StaticText(self, -1, "All Rights Reserved.")
        self.res_label.SetFont(smlfont)
        ##self.ok = wx.Button(self, -1, 'Ok')
        ##self.Bind(wx.EVT_BUTTON, on_close, self.ok)
        hbox.Add(self.icon, 0, wx.CENTER | wx.ALL, 2)
        vbox.Add(self.label, 0, wx.CENTER | wx.ALL, 2)
        vbox.Add(self.ver_label, 0, wx.CENTER | wx.ALL, 2)
        hbox.Add(vbox)
        self.sizer.Add(hbox)
        self.sizer.Add(wx.Size(8,8), 1, wx.EXPAND | wx.ALL, 2)
        self.sizer.Add(self.copy_label, 0, wx.CENTER | wx.ALL, 2)
        self.sizer.Add(self.res_label, 0, wx.CENTER | wx.ALL, 2)
        #self.sizer.Add(wx.Size(42,42), 1, wx.EXPAND | wx.ALL, 2)
        ##self.sizer.Add(self.ok, 0, wx.CENTER | wx.ALL, 2)
        self.SetSizer(self.sizer)
        self.SetAutoLayout(True)


class MountFrame(wx.Frame):
    def __init__(self, guiapp):
        wx.Frame.__init__(self, None, -1, 'Allmydata Mount Filesystem')

        self.SetSizeHints(100, 100, 600, 800)
        self.SetIcon(amdicon.getIcon())
        self.Bind(wx.EVT_CLOSE, self.on_close)

        background = wx.Panel(self, -1)
        background.parent = self
        self.mount_panel = MountPanel(background, self.on_close, guiapp)
        sizer = wx.BoxSizer(wx.VERTICAL)
        background_sizer = wx.BoxSizer(wx.VERTICAL)
        background_sizer.Add(self.mount_panel, 1, wx.ALIGN_CENTER_HORIZONTAL | wx.ALL, 26)
        background.SetSizer(background_sizer)
        sizer.Add(background, 0, wx.EXPAND | wx.ALL, 0)
        self.SetSizer(sizer)
        self.SetAutoLayout(True)
        self.Fit()
        self.Layout()

    def on_close(self, event):
        self.Show(False)

class MountPanel(wx.Panel):
    def __init__(self, parent, on_close, guiapp):
        wx.Panel.__init__(self, parent, -1)
        self.parent = parent
        self.guiapp = guiapp

        self.sizer = wx.BoxSizer(wx.VERTICAL)

        self.label = wx.StaticText(self, -1, 'Allmydata Mount Filesystem')
        self.mnt_label = wx.StaticText(self, -1, 'Mount')
        self.alias_choice = wx.Choice(self, -1, (120, 64), choices=self.guiapp.aliases.keys())
        root_dir = self.alias_choice.FindString('tahoe')
        if root_dir != -1:
            self.alias_choice.SetSelection(root_dir)
        self.at_label = wx.StaticText(self, -1, 'at')
        self.mountpoint = wx.TextCtrl(self, -1, 'choose a mount dir', size=(256,22))
        self.mnt_browse = wx.Button(self, -1, 'Browse')
        mount_sizer = wx.BoxSizer(wx.HORIZONTAL)
        mount_sizer.Add(self.mnt_label, 0, wx.ALL, 4)
        mount_sizer.Add(self.alias_choice, 0, wx.ALL, 4)
        mount_sizer.Add(self.at_label, 0, wx.ALL, 4)
        mount_sizer.Add(self.mountpoint, 0, wx.ALL, 4)
        mount_sizer.Add(self.mnt_browse, 0, wx.ALL, 4)
        self.mount = wx.Button(self, -1, 'Mount')
        self.Bind(wx.EVT_BUTTON, self.on_mount, self.mount)
        #self.Bind(wx.EVT_CHOICE, self.on_choice, self.alias_choice)
        self.Bind(wx.EVT_BUTTON, self.on_mnt_browse, self.mnt_browse)
        self.sizer.Add(self.label, 0, wx.CENTER | wx.ALL, 2)
        self.sizer.Add(wx.Size(28,28), 1, wx.EXPAND | wx.ALL, 2)
        self.sizer.Add(mount_sizer, 0, wx.EXPAND | wx.ALL, 0)
        self.sizer.Add(wx.Size(28,28), 1, wx.EXPAND | wx.ALL, 2)
        self.sizer.Add(self.mount, 0, wx.CENTER | wx.ALL, 2)
        self.SetSizer(self.sizer)
        self.SetAutoLayout(True)

    def on_mount(self, event):
        mountpoint = str(self.mountpoint.GetValue())
        if not os.path.isdir(mountpoint):
            wx.MessageBox(u'"%s" is not a directory' % (mountpoint,))
        else:
            alias_name = self.alias_choice.GetStringSelection()
            self.do_mount(alias_name, mountpoint)

    def on_mnt_browse(self, event):
        dlg = wx.DirDialog(self, "Choose a Mountpoint Directory:",
                           style=wx.DD_DEFAULT_STYLE|wx.DD_NEW_DIR_BUTTON)
        if dlg.ShowModal() == wx.ID_OK:
            mountpoint = dlg.GetPath()
            self.mountpoint.SetValue(mountpoint)
        dlg.Destroy()

    def do_mount(self, alias_name, mountpoint):
        log.msg('do_mount(%r, %r)' % (alias_name, mountpoint))
        self.guiapp.mount_filesystem(alias_name, mountpoint)
        self.parent.parent.Show(False)

class MacGuiApp(wx.App):
    config = {
        'auto-mount': True,
        'auto-open': True,
        'show-webopen': False,
        'daemon-timeout': DEFAULT_FUSE_TIMEOUT,
        }

    def __init__(self, app_cont):
        self.app_cont = app_cont
        self.nodedir = app_cont.nodedir
        self.load_config()
        self.mounted_filesystems = {}
        self.aliases = get_aliases(self.nodedir)
        wx.App.__init__(self)

    ## load up setting from gui.conf dir
    def load_config(self):
        log.msg('load_config')
        confdir = os.path.join(self.nodedir, 'gui.conf')
        config = {}
        config.update(self.config)
        for k in self.config:
            f = os.path.join(confdir, k)
            if os.path.exists(f):
                val = file(f, 'rb').read().strip()
                if type(self.config[k]) == bool:
                    if val.lower() in ['y', 'yes', 'true', 'on', '1']:
                        val = True
                    else:
                        val = False
                elif type(self.config[k]) == int:
                    val = int(val)
                config[k] = val
        self.config = config

    ## GUI wx init
    def OnInit(self):
        log.msg('OnInit')
        try:
            self.frame = SplashFrame()
            self.frame.CenterOnScreen()
            self.frame.Show(True)
            self.SetTopWindow(self.frame)

            # self.load_config()

            wx.FutureCall(4096, self.on_timer, None)

            self.mount_frame = MountFrame(guiapp=self)

            self.setup_dock_icon()
            menubar = self.setup_app_menu(self.frame)
            self.frame.SetMenuBar(menubar)

            return True
        except:
            DisplayTraceback('exception on startup')
            sys.exit()

    ## WX menu and event handling

    def on_timer(self, event):
        self.frame.Show(False)
        self.perhaps_automount()

    def setup_dock_icon(self):
        self.tbicon = wx.TaskBarIcon()
        #self.tbicon.SetIcon(amdicon.getIcon(), "Allmydata")
        wx.EVT_TASKBAR_RIGHT_UP(self.tbicon, self.on_dock_menu)

    def setup_app_menu(self, frame):
        menubar = wx.MenuBar()
        file_menu = wx.Menu()
        if self.config['show-webopen']:
            webopen_menu = wx.Menu()
            self.webopen_menu_ids = {}
            for alias in self.aliases:
                mid = wx.NewId()
                self.webopen_menu_ids[mid] = alias
                item = webopen_menu.Append(mid, alias)
                frame.Bind(wx.EVT_MENU, self.on_webopen, item)
            file_menu.AppendMenu(WEBOPEN_ID, 'Open Web UI', webopen_menu)
        item = file_menu.Append(ACCOUNT_PAGE_ID, text='Open Account Page')
        frame.Bind(wx.EVT_MENU, self.on_account_page, item)
        item = file_menu.Append(MOUNT_ID, text='Mount Filesystem')
        frame.Bind(wx.EVT_MENU, self.on_mount, item)
        item = file_menu.Append(wx.ID_ABOUT, text='About')
        frame.Bind(wx.EVT_MENU, self.on_about, item)
        item = file_menu.Append(wx.ID_EXIT, text='Quit')
        frame.Bind(wx.EVT_MENU, self.on_quit, item)
        menubar.Append(file_menu, 'File')
        return menubar

    def on_dock_menu(self, event):
        dock_menu = wx.Menu()
        item = dock_menu.Append(wx.NewId(), text='About')
        self.tbicon.Bind(wx.EVT_MENU, self.on_about, item)
        if self.config['show-webopen']:
            item = dock_menu.Append(WEBOPEN_ID, text='Open Web Root')
            self.tbicon.Bind(wx.EVT_MENU, self.on_webopen, item)
        item = dock_menu.Append(ACCOUNT_PAGE_ID, text='Open Account Page')
        self.tbicon.Bind(wx.EVT_MENU, self.on_account_page, item)
        item = dock_menu.Append(MOUNT_ID, text='Mount Filesystem')
        self.tbicon.Bind(wx.EVT_MENU, self.on_mount, item)
        self.tbicon.PopupMenu(dock_menu)

    def on_about(self, event):
        self.frame.Show(True)

    def on_quit(self, event):
        self.unmount_filesystems()
        self.ExitMainLoop()

    def on_webopen(self, event):
        alias = self.webopen_menu_ids.get(event.GetId())
        #log.msg('on_webopen() alias=%r' % (alias,))
        self.webopen(alias)

    def on_account_page(self, event):
        webbrowser.open(DEFAULT_SERVER_URL + ACCOUNT_PAGE)

    def on_mount(self, event):
        self.mount_frame.Show(True)

    ## Gui App methods

    def perhaps_automount(self):
        if self.config['auto-mount']:
            mountpoint = os.path.join(self.nodedir, 'mnt/__auto__')
            if not os.path.isdir(mountpoint):
                os.makedirs(mountpoint)
            self.mount_filesystem('tahoe', mountpoint, 'Allmydata')

    def webopen(self, alias=None):
        log.msg('webopen: %r' % (alias,))
        if alias is None:
            alias = 'tahoe'
        root_uri = self.aliases.get(alias)
        if root_uri:
            nodeurl = file(os.path.join(self.nodedir, 'node.url'), 'rb').read().strip()
            if nodeurl[-1] != "/":
                nodeurl += "/"
            url = nodeurl + "uri/%s/" % urllib.quote(root_uri)
            webbrowser.open(url)

    def mount_filesystem(self, alias_name, mountpoint, display_name=None):
        log.msg('mount_filesystem(%r,%r,%r)' % (alias_name, mountpoint, display_name))
        log.msg('sys.exec = %r' % (sys.executable,))

        # first determine if we can find the 'tahoe' binary (i.e. contents of .app)
        if not sys.executable.endswith('Allmydata.app/Contents/MacOS/python'):
            log.msg("can't find allmydata.app: sys.executable = %r" % (sys.executable,))
            wx.MessageBox("Can't determine location of Allmydata.app")
            return False
        bin_path = sys.executable[:-6] + 'Allmydata'
        log.msg('%r exists: %r' % (bin_path, os.path.exists(bin_path),))

        # check mountpoint exists
        if not os.path.exists(mountpoint):
            log.msg('mountpoint %r does not exist' % (mountpoint,))
            return False

        # figure out options for fuse_main
        foptions = []
        foptions.append('-olocal') # required to display in Finder on leopard
        #foptions.append('-ofstypename=allmydata') # shown in 'get info'
        if display_name is None:
            display_name = alias_name
        foptions.append('-ovolname=%s' % (display_name,))
        timeout = self.config['daemon-timeout']
        foptions.append('-odaemon_timeout=%d' % (timeout,))
        icns_path = os.path.join(self.nodedir, 'private/icons', alias_name+'.icns')
        log.msg('icns_path %r exists: %s' % (icns_path, os.path.exists(icns_path)))
        if not os.path.exists(icns_path):
            icns_path = os.path.normpath(os.path.join(os.path.dirname(sys.executable),
                                                      '../Resources/allmydata.icns'))
            log.msg('set icns_path=%s' % (icns_path,))
        if os.path.exists(icns_path):
            foptions.append('-ovolicon=%s' % (icns_path,))


        # actually launch tahoe fuse
        command = [bin_path, 'fuse', '--alias', alias_name] + foptions + [mountpoint]
        #log.msg('spawning command %r' % (command,))
        #proc = Popen(command, cwd=self.nodedir, stdout=PIPE, stderr=PIPE)
        #log.msg('spawned process, pid %s' % (proc.pid,))
        self.async_run_cmd(command)

        # log the outcome, record the fact that we mounted this fs
        #wx.FutureCall(4096, self.check_proc, proc, 'fuse')
        self.mounted_filesystems[display_name] = mountpoint

        # open finder, if configured to do so
        if self.config['auto-open']:
            wx.FutureCall(4096, self.sync_run_cmd, ['/usr/bin/open', mountpoint])
        return True

    def unmount_filesystems(self):
        # the user may've already unmounted some, but we should ensure that
        # anything the gui mounted gets shut down, since they all depend on
        # the tahoe node, which is going away
        for name, mountpoint in self.mounted_filesystems.items():
            log.msg('unmounting %r (%s)' % (name, mountpoint))
            self.sync_run_cmd(['/sbin/umount', mountpoint])

    def sync_run_cmd(self, argv):
        log.msg('synchronously running command: %r' % (argv,))
        proc = Popen(argv, cwd=self.nodedir, stdout=PIPE, stderr=PIPE)
        proc.wait()
        self.check_proc(proc)

    def async_run_cmd(self, argv):
        log.msg('asynchronously running command: %r' % (argv,))
        proc = Popen(argv, cwd=self.nodedir, stdout=PIPE, stderr=PIPE)
        log.msg('spawned process, pid: %s' % (proc.pid,))
        wx.FutureCall(4096, self.check_proc, proc, 'async fuse process:')

    def check_proc(self, proc, description=None):
        message = []
        if description is not None:
            message.append(description)
        message.append('pid: %s  retcode: %s' % (proc.pid, proc.returncode,))
        stdout = proc.stdout.read()
        if stdout:
            message.append('\nstdout:\n%s' % (stdout,))
        stderr = proc.stderr.read()
        if stderr:
            message.append('\nstdout:\n%s' % (stderr,))
        log.msg(' '.join(message))


Generated by  Doxygen 1.6.0   Back to index