# The MIT License (MIT)
#
# Copyright (c) 2014-2015 WUSTL ZPLAB
#
# Permission is hereby granted, free of charge, to any person obtaining a copy
# of this software and associated documentation files (the "Software"), to deal
# in the Software without restriction, including without limitation the rights
# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
# copies of the Software, and to permit persons to whom the Software is
# furnished to do so, subject to the following conditions:
#
# The above copyright notice and this permission notice shall be included in all
# copies or substantial portions of the Software.
#
# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
# SOFTWARE.
#
# Authors: Zach Pincus, Erik Hvatum <ice.rikh@gmail.com>

import collections
import threading
import traceback
import zmq
from . import trie

class PropertyClient(threading.Thread):
    """A client for receiving property updates in a background thread.

    The background thread is automatically started when this object is constructed.
    To stop the thread, set the 'running' attribute to False.
    """
    def __init__(self, daemon=True):
        # properties is a local copy of tracked properties, in case that's useful
        self.properties = {}
        # callbacks is a dict mapping property names to lists of callbacks
        self.callbacks = collections.defaultdict(set)
        # prefix_callbacks is a trie used to match property names to prefixes
        # which were registered for "wildcard" callbacks.
        self.prefix_callbacks = trie.trie()
        super().__init__(name='PropertyClient', daemon=daemon)
        self.start()

    def run(self):
        """Thread target: do not call directly."""
        self.running = True
        while self.running:
            property_name, value = self._receive_update()
            self.properties[property_name] = value
            for callbacks in [self.callbacks[property_name]] + list(self.prefix_callbacks.values(property_name)):
                for callback, valueonly in callbacks:
                    try:
                        if valueonly:
                            callback(value)
                        else:
                            callback(property_name, value)
                    except Exception as e:
                        print('Caught exception in PropertyClient callback:')
                        traceback.print_exception(type(e), e, e.__traceback__)

    def subscribe(self, property_name, callback, valueonly=False):
        """Register a callback to be called any time the named property is updated.
        If valueonly is True, the callback will be called as: callback(new_value);
        if valueonly is False, it will be called as callback(property_name, new_value).

        Multiple callbacks can be registered for a single property_name.
        """
        self.callbacks[property_name].add((callback, valueonly))

    def unsubscribe(self, property_name, callback, valueonly=False):
        """Unregister an exactly matching, previously registered callback.  If
        the same callback function is registered multiple times with identical
        property_name and valueonly parameters, only one registration is removed."""
        if property_name is None:
            raise ValueError('property_name parameter must not be None.')
        try:
            callbacks = self.callbacks[property_name]
            callbacks.remove((callback, valueonly))
        except KeyError:
            raise KeyError('No matching subscription found for property name "{}".'.format(property_name))
        if not callbacks:
            del self.callbacks[property_name]

    def subscribe_prefix(self, property_prefix, callback):
        """Register a callback to be called any time a named property which is
        prefixed by the property_prefix parameter is updated. The callback is
        called as callback(property_name, new_value).

        Example: if property_prefix is 'camera.', then the callback will be called
        when 'camera.foo' or 'camera.bar' or any such property name is updated.
        An empty prefix ('') will match everything.

        Multiple callbacks can be registered for a single property_prefix.
        """
        if property_prefix not in self.prefix_callbacks:
            self.prefix_callbacks[property_prefix] = set()
        self.prefix_callbacks[property_prefix].add((callback, False))

    def unsubscribe_prefix(self, property_prefix, callback):
        """Unregister an exactly matching, previously registered callback.  If
        the same callback function is registered multiple times with identical
        property_prefix parameters, only one registration is removed."""
        if property_prefix is None:
            raise ValueError('property_prefix parameter must not be None.')
        try:
            callbacks = self.callbacks[property_name]
            callbacks.remove((callback, False))
        except KeyError:
            raise KeyError('No matching subscription found for property name "{}".'.format(property_name))
        if not callbacks:
            del self.callbacks[property_name]

    def _receive_update(self):
        """Receive an update from the server"""
        raise NotImplementedError()

class ZMQClient(PropertyClient):
    def __init__(self, port, context=None, daemon=True):
        """PropertyClient subclass that uses ZeroMQ PUB/SUB to receive out updates.
        Parameters:
            port: a string ZeroMQ port identifier, like ''tcp://127.0.0.1:5555''.
            context: a ZeroMQ context to share, if one already exists.
            daemon: exit the client when the foreground thread exits.
        """
        self.context = context if context is not None else zmq.Context()
        self.socket = self.context.socket(zmq.SUB)
        self.socket.connect(port)
        super().__init__(daemon)

    def subscribe(self, property_name, callback, valueonly=False):
        self.socket.setsockopt_string(zmq.SUBSCRIBE, property_name)
        super().subscribe(property_name, callback, valueonly)
    subscribe.__doc__ = PropertyClient.subscribe.__doc__

    def unsubscribe(self, property_name, callback, valueonly=False):
        super().unsubscribe(property_name, callback, valueonly)
        self.socket.setsockopt_string(zmq.UNSUBSCRIBE, property_name)
    unsubscribe.__doc__ = PropertyClient.unsubscribe.__doc__

    def subscribe_prefix(self, property_prefix, callback):
        self.socket.setsockopt_string(zmq.SUBSCRIBE, property_prefix)
        super().subscribe_prefix(property_prefix, callback)
    subscribe_prefix.__doc__ = PropertyClient.subscribe_prefix.__doc__

    def unsubscribe_prefix(self, property_prefix, callback):
        super().unsubscribe_prefix(property_prefix, callback)
        self.socket.setsockopt_string(zmq.UNSUBSCRIBE, property_prefix)
    unsubscribe_prefix.__doc__ = PropertyClient.unsubscribe_prefix.__doc__

    def _receive_update(self):
        property_name = self.socket.recv_string()
        assert(self.socket.getsockopt(zmq.RCVMORE))
        value = self.socket.recv_json()
        return property_name, value

@@ -5283,32 +5283,39 @@
 allbacks = self.
+prefix_
 callbacks%5Bproper
@@ -5309,36 +5309,38 @@
 lbacks%5Bproperty_
-name
+prefix
 %5D%0A            ca
@@ -5490,36 +5490,38 @@
 format(property_
-name
+prefix
 ))%0A        if no
@@ -5546,32 +5546,39 @@
        del self.
+prefix_
 callbacks%5Bproper
@@ -5572,36 +5572,38 @@
 lbacks%5Bproperty_
-name
+prefix
 %5D%0A%0A    def _rece

Fix scope.simple_rpc.property_client.PropertyClient.unsubscribe_prefix which either never worked or broke at some point.