(18 . 10)(18 . 10)
65
66 command, message_bytes = self.state.get_message(message_hash)
67 if message_bytes:
68 if command == DIRECT:
69 return Direct({message_bytes: message_bytes}, self.state)
70 elif command == BROADCAST:
71 return Broadcast({'message_bytes': message_bytes}, self.state)
72 if command == DIRECT:
73 return Direct({'message_bytes': message_bytes}, self.state)
74 elif command == BROADCAST:
75 return Broadcast({'message_bytes': message_bytes}, self.state)
76
77 def expunge_expired(self):
78 for message in self.buffer.values():