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