We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 539ff8c commit 6d5f6c1Copy full SHA for 6d5f6c1
1 file changed
pgmq_sqlalchemy/queue.py
@@ -1509,6 +1509,8 @@ def read_archive(self, queue_name: str) -> Optional[Message]:
1509
print(archived_msg.message)
1510
1511
"""
1512
+ # Validate queue name first to prevent SQL injection
1513
+ self.validate_queue_name(queue_name)
1514
if self.is_async:
1515
return self.loop.run_until_complete(self._read_archive_async(queue_name))
1516
return self._read_archive_sync(queue_name)
@@ -1589,6 +1591,8 @@ def read_archive_batch(
1589
1591
print(msg.message)
1590
1592
1593
1594
1595
1596
1597
return self.loop.run_until_complete(
1598
self._read_archive_batch_async(queue_name, batch_size)
0 commit comments