def test__render_POST_queue_messages(self):
status_worker = Mock()
status_worker.queueMessage = Mock()
status_worker.queueMessage.return_value = succeed(None)
resource = StatusHandlerResource(status_worker)
message = {
'event_type': (
factory.make_name('type') + '/' +
factory.make_name('sub_type')),
'origin': factory.make_name('origin'),
'name': factory.make_name('name'),
'description': factory.make_name('description'),
}
token = factory.make_name('token')
request = self.make_request(
content=json.dumps(message).encode('ascii'), token=token)
output = resource.render_POST(request)
self.assertEquals(NOT_DONE_YET, output)
self.assertEquals(204, request.responseCode)
self.assertThat(
status_worker.queueMessage, MockCalledOnceWith(token, message))
评论列表
文章目录