(self)
| 171 | assert x['clock'] == 313 |
| 172 | |
| 173 | def test_hello(self): |
| 174 | consumer = Consumer(self.app) |
| 175 | panel = self.create_panel(consumer=consumer) |
| 176 | panel.state.app.clock.value = 313 |
| 177 | panel.state.hostname = 'elaine@vandelay.com' |
| 178 | worker_state.revoked.add('revoked1') |
| 179 | try: |
| 180 | assert panel.handle('hello', { |
| 181 | 'from_node': 'elaine@vandelay.com', |
| 182 | }) is None |
| 183 | x = panel.handle('hello', { |
| 184 | 'from_node': 'george@vandelay.com', |
| 185 | }) |
| 186 | assert x['clock'] == 314 # incremented |
| 187 | x = panel.handle('hello', { |
| 188 | 'from_node': 'george@vandelay.com', |
| 189 | 'revoked': {'1234', '4567', '891'} |
| 190 | }) |
| 191 | assert 'revoked1' in x['revoked'] |
| 192 | assert '1234' in x['revoked'] |
| 193 | assert '4567' in x['revoked'] |
| 194 | assert '891' in x['revoked'] |
| 195 | assert x['clock'] == 315 # incremented |
| 196 | finally: |
| 197 | worker_state.revoked.discard('revoked1') |
| 198 | |
| 199 | def test_hello_does_not_send_expired_revoked_items(self): |
| 200 | consumer = Consumer(self.app) |
nothing calls this directly
no test coverage detected