
Research
PyPI Package Disguised as Instagram Growth Tool Harvests User Credentials
A deceptive PyPI package posing as an Instagram growth tool collects user credentials and sends them to third-party bot services.
pgdb-queue
Advanced tools
A lightweight Kafka-style queue built using a PostgreSQL database. Designed for simplicity, performance, and low cost β no need for Kafka, Redis, or additional infrastructure.
Ideal for startups and small apps that need reliable background task processing without operational overhead.
FOR UPDATE SKIP LOCKED
npm install pgdb-queue
Before producing or consuming messages, initialize the queue:
import { initQueue } from "pgdb-queue";
await initQueue(
"postgres://user:password@host:port/database",
"schemaName.tableName"
);
This sets up the connection pool and ensures the message_queue
table exists.
import { produce } from "pgdb-queue";
await produce(
"email-topic",
JSON.stringify({
to: "user@example.com",
subject: "Welcome!",
})
);
The message must be a string. Use
JSON.stringify()
to send structured data.
Parameters:
topic
: string
message
: string
(recommended: JSON.stringify(object)
)This gives you full control (useful in cron jobs or custom workers):
import { consume } from "pgdb-queue";
await consume("email-topic", async (msg, id) => {
const data = JSON.parse(msg);
console.log("Received:", data);
// Your message handler logic
});
startConsumer
: Auto-Wake Continuous ConsumerAutomatically listens for new messages and drains the queue efficiently:
import { startConsumer } from "pgdb-queue";
await startConsumer(
"email-topic",
async (msg, id) => {
const data = JSON.parse(msg);
console.log("Processing:", data);
// Your message handler logic
},
{
rateLimitMs: 10,
}
);
LISTEN/NOTIFY
to be notified only when a new message is inserted.No
setInterval
polling = minimal read overhead.
Perfect for scalable background jobs with low or bursty volume.
The following table is automatically created (if missing):
CREATE TABLE IF NOT EXISTS schemaName.tableName (
id SERIAL PRIMARY KEY,
topic TEXT NOT NULL,
message TEXT NOT NULL,
status TEXT NOT NULL DEFAULT 'queued',
retry_count INTEGER NOT NULL DEFAULT 0,
created_at TIMESTAMP DEFAULT NOW(),
updated_at TIMESTAMP DEFAULT NOW()
);
CREATE INDEX IF NOT EXISTS idx_topic_status ON schemaName.tableName (topic, status);
message
is stored asTEXT
.
Planned features:
MIT License
Β© 2025 Shivaji Kumar
FAQs
Asynchronous messaging queue using Postgres database.
The npm package pgdb-queue receives a total of 153 weekly downloads. As such, pgdb-queue popularity was classified as not popular.
We found that pgdb-queue demonstrated a healthy version release cadence and project activity because the last version was released less than a year ago.Β It has 1 open source maintainer collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Research
A deceptive PyPI package posing as an Instagram growth tool collects user credentials and sends them to third-party bot services.
Product
Socket now supports pylock.toml, enabling secure, reproducible Python builds with advanced scanning and full alignment with PEP 751's new standard.
Security News
Research
Socket uncovered two npm packages that register hidden HTTP endpoints to delete all files on command.