You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
92 lines
2.7 KiB
TypeScript
92 lines
2.7 KiB
TypeScript
import { describe, test, expect, beforeAll, afterAll, beforeEach, afterEach } from 'bun:test';
|
|
import { Database } from 'bun:sqlite';
|
|
import { WebhookServer } from '../../../src/server';
|
|
import { initializeDatabase } from '../../../src/db';
|
|
import { ResponseQueue } from '../../../src/services/response-queue';
|
|
|
|
let testDb: Database;
|
|
let originalAdd: any;
|
|
|
|
let simulatedQueue: any[] = [];
|
|
const SimulatedResponseQueue = {
|
|
async add(responses: any[]) {
|
|
simulatedQueue.push(...responses);
|
|
},
|
|
clear() { simulatedQueue = []; },
|
|
get() { return simulatedQueue; }
|
|
};
|
|
|
|
const createTestRequest = (payload: any) =>
|
|
new Request('http://localhost:3007', {
|
|
method: 'POST',
|
|
headers: { 'Content-Type': 'application/json' },
|
|
body: JSON.stringify(payload)
|
|
});
|
|
|
|
describe('WebhookServer - notifica a ADMIN_USERS en descubrimiento (modo discover)', () => {
|
|
const envBackup = process.env;
|
|
|
|
beforeAll(() => {
|
|
testDb = new Database(':memory:');
|
|
initializeDatabase(testDb);
|
|
originalAdd = (ResponseQueue as any).add;
|
|
});
|
|
|
|
afterAll(() => {
|
|
(ResponseQueue as any).add = originalAdd;
|
|
testDb.close();
|
|
});
|
|
|
|
beforeEach(() => {
|
|
process.env = {
|
|
...envBackup,
|
|
NODE_ENV: 'test',
|
|
GROUP_GATING_MODE: 'discover',
|
|
NOTIFY_ADMINS_ON_DISCOVERY: 'true',
|
|
ADMIN_USERS: '1234567890, 5555555555'
|
|
};
|
|
SimulatedResponseQueue.clear();
|
|
(ResponseQueue as any).add = SimulatedResponseQueue.add;
|
|
WebhookServer.dbInstance = testDb;
|
|
|
|
// Limpiar tablas relevantes
|
|
testDb.exec('DELETE FROM response_queue');
|
|
testDb.exec('DELETE FROM allowed_groups');
|
|
testDb.exec('DELETE FROM users');
|
|
});
|
|
|
|
afterEach(() => {
|
|
process.env = envBackup;
|
|
});
|
|
|
|
test('registra pending y envía DMs a todos los admins', async () => {
|
|
const payload = {
|
|
event: 'messages.upsert',
|
|
instance: 'test-instance',
|
|
data: {
|
|
key: {
|
|
remoteJid: 'notify-group@g.us',
|
|
participant: '9999999999@s.whatsapp.net'
|
|
},
|
|
message: { conversation: '/t n hola' }
|
|
}
|
|
};
|
|
|
|
const res = await WebhookServer.handleRequest(createTestRequest(payload));
|
|
expect(res.status).toBe(200);
|
|
|
|
// allowed_groups debe tener el grupo en pending
|
|
const row = testDb
|
|
.query(`SELECT status FROM allowed_groups WHERE group_id = 'notify-group@g.us'`)
|
|
.get() as any;
|
|
expect(row).toBeDefined();
|
|
expect(String(row.status)).toBe('pending');
|
|
|
|
// Debe haberse encolado una notificación por cada admin
|
|
const out = SimulatedResponseQueue.get();
|
|
const recipients = out.map((r: any) => r.recipient).sort();
|
|
expect(out.length).toBe(2);
|
|
expect(recipients).toEqual(['1234567890', '5555555555']);
|
|
});
|
|
});
|