f06d9bbf420feb41886adbcfbc6207c4fbb6edb0,dino/endpoint/queue.py,QueueHandler,handle_server_activity,#QueueHandler#Any#Any#,141

Before Change

        logger.debug("got internally published event with verb %s id %s" % (activity.verb, activity.id))

        if activity.verb in ["ban", "kick", "remove"]:
            self.handle_local_node_events(data, activity)
        else:
            // otherwise it"s external events for possible analysis

After Change

            self.handle_server_activity(data, activity)
        except Exception as e:
            logger.error("could not handle server activity: %s" % str(e))
            logger.exception(traceback.format_exc())

    def _handle_server_activity(self, data: dict, activity: Activity) -> None:
        if activity.id in self.recently_delegated_events:

Instances