# -*- coding: utf-8 -*-

# copyright 2012 LOGILAB S.A. (Paris, FRANCE), all rights reserved.

# contact http://www.logilab.fr/ -- mailto:contact@logilab.fr

#

# This file is part of CubicWeb.

#

# CubicWeb 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.1 of the License, or (at your option)

# any later version.

#

# CubicWeb 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 Lesser General Public License for more

# details.

#

# You should have received a copy of the GNU Lesser General Public License along

# with CubicWeb.  If not, see <http://www.gnu.org/licenses/>.

from cubicweb.server import hook

class ZMQStopHook(hook.Hook):

    __regid__ = 'zmqstop'

    events = ('server_shutdown',)

    def __call__(self):

        self.repo.app_instances_bus.stop()

class ZMQStartHook(hook.Hook):

    __regid__ = 'zmqstart'

    events = ('server_startup',)

    order = -1

    def __call__(self):

        config = self.repo.config

        address_pub = config.get('zmq-address-pub')

        address_sub = config.get('zmq-address-sub')

        if not address_pub and not address_sub:

            return

        from cubicweb.server import cwzmq

        self.repo.app_instances_bus = cwzmq.ZMQComm()

        if address_pub:

            self.repo.app_instances_bus.add_publisher(address_pub)

        def clear_cache_callback(msg):

            self.debug('clear_caches: %s', ' '.join(msg))

            self.repo.clear_caches(msg[1:])

        self.repo.app_instances_bus.add_subscription('delete', clear_cache_callback)

        for address in address_sub:

            self.repo.app_instances_bus.add_subscriber(address)

        self.repo.app_instances_bus.start()

class ZMQRepositoryServerStopHook(hook.Hook):

    __regid__ = 'zmqrepositoryserverstop'

    events = ('server_shutdown',)

    def __call__(self):

        server = getattr(self.repo, 'zmq_repo_server', None)

        if server:

            self.repo.zmq_repo_server.quit()

class ZMQRepositoryServerStartHook(hook.Hook):

    __regid__ = 'zmqrepositoryserverstart'

    events = ('server_startup',)

    def __call__(self):

        config = self.repo.config

        if config.name == 'repository':

            # start-repository command already starts a zmq repo

            return

        address = config.get('zmq-repository-address')

        if not address:

            return

        self.repo.warning('remote access to the repository via zmq/pickle is deprecated')

        from cubicweb.server import cwzmq

        self.repo.zmq_repo_server = server = cwzmq.ZMQRepositoryServer(self.repo)

        server.connect(address)

        self.repo.threaded_task(server.run)