#
#    Copyright (C) 2007, One Laptop Per Child
#
#    This program is free software; you can redistribute it and/or modify
#    it under the terms of the GNU General Public License as published by
#    the Free Software Foundation; either version 2 of the License, or
#    (at your option) any later version.
#
#    This program 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 General Public License for more details.
#
#    You should have received a copy of the GNU General Public License
#    along with this program; if not, write to the Free Software
#    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
#

import logging
import dbus
from dbus.gobject_service import ExportedGObject
import base64


SERVICE = "org.laptop.WebActivity"
IFACE = SERVICE
PATH = "/org/laptop/WebActivity"

_logger = logging.getLogger('messenger')


class Messenger(ExportedGObject):
    def __init__(self, tube, is_initiator, model):
        ExportedGObject.__init__(self, tube, PATH)
        self.tube = tube
        self.is_initiator = is_initiator
        self.members = []
        self.entered = False
        self.model = model
        self.bus_name = None
        self.tube.watch_participants(self.participant_change_cb)

    def participant_change_cb(self, added, removed):
        _logger.debug('Participants change add=%s    rem=%s',
                      added, removed)
        for handle, bus_name in added:
            _logger.debug('Add member handle=%s  bus_name=%s',
                          handle, bus_name)
            self.members.append(bus_name)

        for handle in removed:
            _logger.debug('Remove member %r', handle)
            try:
                self.members.remove(self.tube.participants[handle])
            except ValueError:
                _logger.debug('Remove member %r - already absent', handle)

        if not self.entered:
            self.tube.add_signal_receiver(self._add_link_receiver, '_add_link',
                                          IFACE, path=PATH,
                                          sender_keyword='sender',
                                          byte_arrays=True)
            self.bus_name = self.tube.get_unique_name()
            if self.is_initiator:
                _logger.debug('Initialising a new shared browser, I am %s .',
                              self.tube.get_unique_name())
            else:
                # sync with other members
                _logger.debug('Joined I am %s .', self.bus_name)
                for member in self.members:
                    if member != self.bus_name:
                        _logger.debug('Get info from %s', member)
                        self.tube.get_object(member, PATH).sync_with_members(
                            self.model.get_links_ids(), dbus_interface=IFACE,
                            reply_handler=self.reply_sync, error_handler=lambda
                            e: self.error_sync(e, 'transfering file'))

        self.entered = True

    def reply_sync(self, a_ids, sender):
        a_ids.pop()
        for link in self.model.data['shared_links']:
            if link['hash'] not in a_ids:
                self.tube.get_object(sender, PATH).send_link(
                    link['hash'], link['url'], link['title'], link['color'],
                    link['owner'], link['thumb'], link['timestamp'])

    def error_sync(self, e, when):
        _logger.error('Error %s: %s', when, e)

    @dbus.service.method(dbus_interface=IFACE, in_signature='as',
                         out_signature='ass', sender_keyword='sender')
    def sync_with_members(self, b_ids, sender=None):
        '''Sync with members '''
        b_ids.pop()
        # links the caller wants from me
        for link in self.model.data['shared_links']:
            if link['hash'] not in b_ids:
                self.tube.get_object(sender, PATH).send_link(
                    link['hash'], link['url'], link['title'], link['color'],
                    link['owner'], link['thumb'], link['timestamp'])
        a_ids = self.model.get_links_ids()
        a_ids.append('')
        # links I want from the caller
        return (a_ids, self.bus_name)

    @dbus.service.method(dbus_interface=IFACE, in_signature='ssssssd',
                         out_signature='')
    def send_link(self, identifier, url, title, color, owner, buf, timestamp):
        '''Send link'''
        a_ids = self.model.get_links_ids()
        if identifier not in a_ids:
            thumb = base64.b64decode(buf)
            self.model.add_link(url, title, thumb, owner, color, timestamp)

    @dbus.service.signal(IFACE, signature='sssssd')
    def _add_link(self, url, title, color, owner, thumb, timestamp):
        '''Signal to send the link information (add)'''
        _logger.debug('Add Link: %s ', url)

    def _add_link_receiver(self, url, title, color, owner, buf, timestamp,
                           sender=None):
        '''Member sent a link'''
        handle = self.tube.bus_name_to_handle[sender]
        if self.tube.self_handle != handle:
            thumb = base64.b64decode(buf)
            self.model.add_link(url, title, thumb, owner, color, timestamp)
            _logger.debug('Added link: %s to linkbar.', url)