feat: add sqs event builder (#13) #221
Conversation
* feat: add sqs event builder * refactor: update sqs class to use a generic event * refactor: update code
| @@ -50,3 +55,49 @@ async def test_event(self): | |||
| self.assertEqual(event["requestContext"]["path"], "/ping/pong") | |||
| self.assertEqual(event["requestContext"]["httpMethod"], "GET") | |||
| self.assertEqual(event["requestContext"]["protocol"], "HTTP/1.1") | |||
|
|
|||
|
|
|||
| class TestSQS(unittest.IsolatedAsyncioTestCase): | |||
There was a problem hiding this comment.
Não me parece que nestes testes é necessário o suporte a coroutine, troca pela classe TestCase.
| "data": "aGVsbG8=", | ||
| "attributes": {"foo": "bar"}, | ||
| "messageId": "10519041647717348", | ||
| "publishTime": "2024-02-22T15:45:31.346Z", |
There was a problem hiding this comment.
Esse timestamp está sendo referenciado em mais de um lugar do teste, acho melhor armazenar em uma variável e utilizar a variável onde o timestamp é necessário. Desta forma se for necessário ajustar o timestamp basta ajustar a variável.
|
|
||
| self.assertIsInstance(event, dict) | ||
| record = event["Records"][0] | ||
| self.assertEqual(record["messageId"], "10519041647717348") |
There was a problem hiding this comment.
Como você está tentando comparar com um valor que estava na mensagem enviado ao PubSub referencie o valor no dicionário de origem para ter certeza que é o mesmo da origem. Ex.:
self.assertEqual(record["messageId"], data["message"]["messageId"])O mesmo vale para as demais verificações, sempre compare com um valor salvo em uma variável de origem para evitar de ter que ficar buscando de onde vem a informação que está comparando, e se houver mudança nos dados de entrada não precisaria alterar nas verificações de saída.
feat: add sqs event builder
refactor: update sqs class to use a generic event
refactor: update code
Contain
Details