No links here.
', tracking: { opens: false, clicks: true } }); assert.deepEqual(noTrackableLinks.tracking, { enabled: false, opens: false, clicks: false, messageLevel: false }); await waitFor(() => relay.messages.length === 3); const noTrackableLinksHtml = decodeHtmlPart(relay.messages[2]); assert.equal(noTrackableLinksHtml.includes('/t/c/'), false); const events = await fetch(`${baseUrl}/api/events`, { headers: { Cookie: cookie } }).then((response) => response.json()); assert.equal(events.events.length, 3); assert.equal(events.events.every((event) => event.status === 'queued'), true); assert.equal(events.events.find((event) => event.subject === 'Tracked HTML').tracking.enabled, true); assert.equal(events.events.find((event) => event.subject === 'No trackable links').tracking.enabled, false); } finally { child.kill('SIGTERM'); await waitForExit(child, 1000); await relay.close(); } }); async function sendHtml(baseUrl, cookie, data) { const response = await fetch(`${baseUrl}/api/send`, { method: 'POST', headers: { 'Content-Type': 'application/json', Cookie: cookie }, body: JSON.stringify({ from: 'noreply@track-send.example', to: 'reader@example.net', text: 'Fallback', ...data }) }); assert.equal(response.status, 202); return response.json(); } async function login(baseUrl) { const response = await fetch(`${baseUrl}/api/login`, { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify({ username: 'admin', password: 'password123' }) }); assert.equal(response.status, 200); return response.headers.get('set-cookie')?.split(';')[0] || ''; } function decodeHtmlPart(rawMessage) { const match = rawMessage.match(/Content-Type: text\/html[^]*?\n\n([A-Za-z0-9+/=\n]+?)(?:\n--|$)/i); assert.ok(match, 'expected an HTML MIME part'); return Buffer.from(match[1].replace(/\s+/g, ''), 'base64').toString('utf8'); } function startFakeSmtpServer() { const messages = []; const server = net.createServer((socket) => { socket.setEncoding('utf8'); socket.write('220 relay.test ESMTP ready\r\n'); let buffer = ''; let dataMode = false; let messageLines = []; socket.on('data', (chunk) => { buffer += chunk; let index; while ((index = buffer.indexOf('\n')) !== -1) { const line = buffer.slice(0, index).replace(/\r$/, ''); buffer = buffer.slice(index + 1); if (dataMode) { if (line === '.') { dataMode = false; messages.push(messageLines.join('\n')); messageLines = []; socket.write('250 2.0.0 queued as TRACK123\r\n'); } else { messageLines.push(line); } continue; } if (line.startsWith('EHLO')) socket.write('250 relay.test\r\n'); else if (line.startsWith('MAIL FROM') || line.startsWith('RCPT TO')) socket.write('250 ok\r\n'); else if (line === 'DATA') { dataMode = true; socket.write('354 end with dot\r\n'); } else if (line === 'QUIT') { socket.write('221 bye\r\n'); socket.end(); } } }); }); return new Promise((resolve, reject) => { server.once('error', reject); server.listen(0, '127.0.0.1', () => resolve({ port: server.address().port, messages, close: () => new Promise((closeResolve) => server.close(closeResolve)) })); }); } function freePort() { return new Promise((resolve, reject) => { const server = net.createServer(); server.listen(0, '127.0.0.1', () => { const { port } = server.address(); server.close((error) => (error ? reject(error) : resolve(port))); }); server.on('error', reject); }); } async function waitFor(predicate, timeoutMs = 5000) { const startedAt = Date.now(); while (!predicate()) { if (Date.now() - startedAt > timeoutMs) throw new Error('Timed out waiting for SMTP message.'); await new Promise((resolve) => setTimeout(resolve, 20)); } } function waitForOutput(child, value, timeoutMs = 8000) { return new Promise((resolve, reject) => { let buffer = ''; const timer = setTimeout(() => reject(new Error(`Timed out waiting for ${value}\n${buffer}`)), timeoutMs); const onData = (chunk) => { buffer += String(chunk); if (!buffer.includes(value)) return; clearTimeout(timer); child.stdout?.off('data', onData); child.stderr?.off('data', onData); resolve(); }; child.stdout?.on('data', onData); child.stderr?.on('data', onData); }); } function waitForExit(child, timeoutMs) { return new Promise((resolve) => { if (child.exitCode != null) return resolve(true); const timer = setTimeout(() => resolve(false), timeoutMs); child.once('exit', () => { clearTimeout(timer); resolve(true); }); }); } function escapeRegExp(value) { return String(value).replace(/[.*+?^${}()|[\]\\]/g, '\\$&'); }