zca-js

import { Zalo, ThreadType } from 'zca-js'; const zalo = new Zalo(); // For advanced image sending by file path, you might need to provide an imageMetadataGetter: // import sharp from 'sharp'; // import fs from 'node:fs'; // async function imageMetadataGetter(filePath) { // const data = await fs.promises.readFile(filePath); // const metadata = await sharp(data).metadata(); // return { // height: metadata.height, // width: metadata.width, // size: metadata.size || data.length, // }; // } // const zalo = new Zalo({ imageMetadataGetter }); async function runBot() { const api = await zalo.loginQR(); // Authenticates via QR code displayed in the console. console.log('Logged in successfully!'); api.listener.on('message', (message) => { const isPlainText = typeof message.data.content === 'string'; if (message.isSelf || !isPlainText) return; // Ignore messages from self or non-plain text. console.log(`Received message from ${message.threadId} (${message.type}): ${message.data.content}`); const replyMessage = `echo: ${message.data.content}`; const quoteData = message.data; // Optional: quote the original message. switch (message.type) { case ThreadType.User: { api.sendMessage( { msg: replyMessage, quote: quoteData }, message.threadId, message.type ); console.log(`Sent echo to user ${message.threadId}`); break; } case ThreadType.Group: { api.sendMessage( { msg: replyMessage, quote: quoteData }, message.threadId, message.type ); console.log(`Sent echo to group ${message.threadId}`); break; } } }); api.listener.on('disconnected', (reason) => { console.warn(`Listener disconnected: ${reason}. Attempting to restart...`); // In a production environment, you might want to implement a robust retry mechanism. // For this example, we just log. }); api.listener.start(); console.log('Listener started. Waiting for messages...'); } runBot().catch(console.error);