const login = require('sulyap');
const fs = require('fs');

// Load saved session
const appState = JSON.parse(fs.readFileSync('appstate.json', 'utf8'));

login({ appState }, (err, api) => {
    if (err) return console.error(err);

    console.log('Logged in as:', api.getCurrentUserID());

    // Listen for messages using MQTT (recommended)
    api.listenMqtt((err, event) => {
        if (err) return console.error(err);

        if (event.type === 'message') {
            console.log(`${event.senderID}: ${event.body}`);
            
            // Echo bot example
            if (event.body === '/ping') {
                api.sendMessage('Pong!', event.threadID);
            }
        }
    });
});

const login = require('sulyap');

login({
    email: 'your_email@example.com',
    password: 'your_password'
}, (err, api) => {
    if (err) {
        if (err.error === 'login-approval') {
            console.log('2FA required. Please use appState login.');
        }
        return console.error(err);
    }

    // Save session for future use
    const fs = require('fs');
    fs.writeFileSync('appstate.json', JSON.stringify(api.getAppState()));

    console.log('Logged in successfully!');
});

api.sendMessage('Hello, World!', threadID);

const fs = require('fs');

api.sendMessage({
    body: 'Check out this photo!',
    attachment: fs.createReadStream('image.jpg')
}, threadID);

api.sendMessage({
    sticker: '767334476626295'
}, threadID);

api.sendMessage({
    url: 'https://example.com'
}, threadID);

api.sendMessage({
    emoji: '👍',
    emojiSize: 'large' // 'small', 'medium', 'large'
}, threadID);

api.sendMessage({
    body: 'Hello @John!',
    mentions: [{
        tag: '@John',
        id: '123456789',
        fromIndex: 6
    }]
}, threadID);

api.sendMessage('This is a reply!', threadID, null, originalMessageID);

// React with emoji directly
api.setMessageReaction('❤️', messageID);

// Use reaction shortcuts (like biar-fca)
api.setMessageReaction(':love:', messageID);    // 😍
api.setMessageReaction(':haha:', messageID);    // 😆
api.setMessageReaction(':wow:', messageID);     // 😮
api.setMessageReaction(':sad:', messageID);     // 😢
api.setMessageReaction('😠', messageID);   // 😠
api.setMessageReaction(':like:', messageID);    // 👍
api.setMessageReaction(':dislike:', messageID); // 👎
api.setMessageReaction('❤️', messageID);   // ❤
api.setMessageReaction(':glowingheart:', messageID); // 💗

// Remove reaction
api.setMessageReaction('', messageID);

// Force custom emoji (bypass validation)
api.setMessageReaction('🔥', messageID, null, true);

api.listenMqtt((err, event) => {
    switch (event.type) {
        case 'message':
            // New message received
            console.log(`From ${event.senderID}: ${event.body}`);
            break;
            
        case 'message_reaction':
            // Someone reacted to a message
            console.log(`${event.senderID} reacted with ${event.reaction}`);
            break;
            
        case 'message_unsend':
            // Message was unsent/deleted
            console.log(`Message ${event.messageID} was unsent`);
            break;
            
        case 'typ':
            // Typing indicator
            console.log(`${event.from} is ${event.isTyping ? 'typing' : 'stopped typing'}`);
            break;
            
        case 'read_receipt':
            // Read receipt
            console.log(`${event.reader} read messages in ${event.threadID}`);
            break;
            
        case 'presence':
            // Online/offline status
            console.log(`${event.userID} is ${event.statuses ? 'online' : 'offline'}`);
            break;
            
        case 'event':
            // Group events (title change, member added/removed, etc.)
            console.log(`Event: ${event.logMessageType}`);
            break;
    }
});

api.setOptions({
    // Logging level: 'silent', 'error', 'warn', 'info', 'debug', 'verbose'
    logLevel: 'info',
    
    // Listen to your own messages
    selfListen: false,
    
    // Receive group events (joins, leaves, title changes)
    listenEvents: true,
    
    // Set online status
    online: true,
    
    // Update presence information
    updatePresence: true,
    
    // Auto-approve login from new device
    forceLogin: false,
    
    // Custom user agent
    userAgent: 'Mozilla/5.0 ...',
    
    // Automatically mark messages as delivered
    autoMarkDelivery: true,
    
    // Automatically mark messages as read
    autoMarkRead: false,
    
    // Proxy URL for requests
    proxy: 'http://proxy:8080',
    
    // Anti-Ban & Anti-Detection Options (all enabled by default)
    cookieRefreshInterval: 20000,        // Cookie refresh interval in ms (default: 20 seconds)
    sessionRotationInterval: 14400000,   // Session rotation interval in ms (default: 4 hours)
    autoRotateSession: true,             // Enable automatic session rotation (default: true)
});

// Anti-ban is AUTOMATICALLY ENABLED - just use listenMqtt!
api.listenMqtt((err, event) => {
    // Protection is active - cookies auto-refresh every 20s
    console.log(event);
});

// Check protection status anytime
const stats = api.getProtectionStats();
console.log('Anti-ban active:', stats.antiBanEnabled);
console.log('Cookie refreshes:', stats.cookieRefreshCount);

// All anti-detection features are automatically enabled!
// You can customize intervals if needed:
login({ appState }, {
    cookieRefreshInterval: 20000,        // Refresh cookies every 20 seconds (default)
    sessionRotationInterval: 14400000,   // Rotate session every 4 hours (default)
    autoRotateSession: true,             // Enable session rotation (default: true)
}, (err, api) => {
    // Full protection is now active
});