annot-server/websockets.py
changeset 76 029cdbeebf03
parent 66 658561ea9e65
child 93 79ae42ad97d4
equal deleted inserted replaced
75:129281e4bc2a 76:029cdbeebf03
    60         if client in self.filters:
    60         if client in self.filters:
    61             self.filters.pop(client, None)
    61             self.filters.pop(client, None)
    62 
    62 
    63     def broadcast(self, msg, filter):
    63     def broadcast(self, msg, filter):
    64         print("broadcasting prepared message '{}' ..".format(msg))
    64         print("broadcasting prepared message '{}' ..".format(msg))
    65         #preparedMsg = self.prepareMessage(msg)
    65         preparedMsg = self.prepareMessage(msg)
    66         for c in self.clients:
    66         for c in self.clients:
    67             preparedMsg = self.prepareMessage(msg)
       
    68             if all([ (k in filter and filter[k] in v) for k,v in self.filters.get(c, {}).items()]):
    67             if all([ (k in filter and filter[k] in v) for k,v in self.filters.get(c, {}).items()]):
    69                 c.sendPreparedMessage(preparedMsg)
    68                 c.sendPreparedMessage(preparedMsg)
    70                 print("prepared message sent to {}".format(c.peer))
    69                 print("prepared message sent to {}".format(c.peer))
    71 
    70 
    72 
    71