user.js

const fs = require('fs');
const path = require('path');
const logger = require("./utils/logger");
const config = require('./config');

let chatIds = {};

fs.mkdirSync(path.dirname(config.user_db_path), { recursive: true });
try {
    chatIds = JSON.parse(fs.readFileSync(config.user_db_path));
} catch (e) {
    logger.warn(`Cannot read database: ${e}`);
}

function write() {
    return fs.writeFile(config.user_db_path, JSON.stringify(chatIds), (e) => {
        if (e) logger.warn(`Cannot read database: ${e}`);
    });
}

function validate(msg) {
    if (msg.chat.username === config.valid_username) {
        chatIds[msg.chat.id] = msg.chat.username;
        write();
        return msg.chat.id;
    }
    return false;
}

function getChatIds() {
    let ids = [];
    for (let id in chatIds) {
        ids.push(id);
    }
    return ids;
}

module.exports = { validate, getChatIds };