main.js

process.env['NODE_TLS_REJECT_UNAUTHORIZED'] = '0'

import './config.js'
import { createRequire } from 'module' // Bring in the ability to create the 'require' method
import path, { join } from 'path'
import { fileURLToPath, pathToFileURL } from 'url'
import { platform } from 'process'
import Helper from './lib/helper.js'
import db, { loadDatabase } from './lib/database.js'
import clearTmp from './lib/clearTmp.js'
import * as ws from 'ws'
import { readdirSync, statSync, unlinkSync, existsSync, readFileSync, watch } from 'fs'
import yargs from 'yargs'
import { spawn } from 'child_process'
import lodash from 'lodash'
import syntaxerror from 'syntax-error'
import { tmpdir } from 'os'
import { format } from 'util'
import { makeWASocket, protoType, serialize } from './lib/simple.js'
import { Low } from 'lowdb'
import { JSONFile } from 'lowdb/node'
import store from './lib/store.js'
//import { plugins, loadPluginFiles, reload, pluginFolder, pluginFilter } from './lib/plugins.js'

const { DisconnectReason } = await import('@adiwajshing/baileys')
const { CONNECTING } = ws
const { chain } = lodash
const PORT = process.env.PORT || process.env.SERVER_PORT || 3000

protoType()
serialize()

// Assign all the value in the Helper to global
Object.assign(global, {
	...Helper,
	timestamp: {
	start: Date.now()
}})

global.API = (name, path = '/', query = {}, apikeyqueryname) => (name in global.APIs ? global.APIs[name] : name) + path + (query || apikeyqueryname ? '?' + new URLSearchParams(Object.entries({ ...query, ...(apikeyqueryname ? { [apikeyqueryname]: global.APIKeys[name in global.APIs ? global.APIs[name] : name] } : {}) })) : '')
// global.Fn = function functionCallBack(fn, ...args) { return fn.call(global.conn, ...args) }
global.timestamp = { start: new Date }

const __dirname = Helper.__dirname(import.meta.url)

global.prefix = new RegExp('^[' + (opts['prefix'] || '‎xzXZ/i!#$%+£¢€¥^°=¶∆×÷π√✓©®:;?&.\\-').replace(/[|\\{}()[\]^$+*?.\-\^]/g, '\\$&') + ']')
global.authFile = `${opts._[0] || 'session'}.data.json`
const { state, saveState } = store.useSingleFileAuthState(global.authFile)

const connectionOptions = {
	printQRInTerminal: true,
	syncFullHistory: false,
	auth: state,
	// logger: pino({ level: 'trace' })
}

//global.conn = makeWASocket(connectionOptions)
global.conn = makeWASocket({
	...connectionOptions,
	generateHighQualityLinkPreview: true, // menambah kualitas thumbnail preview
	// patch dibawah untuk tambahan jika hydrate/list tidak bekerja
	patchMessageBeforeSending: (message) => {
		const requiresPatch = !!(
			message.buttonsMessage 
			|| message.templateMessage
			|| message.listMessage
		);
		if (requiresPatch) {
			message = {
				viewOnceMessage: {
					message: {
						messageContextInfo: {
							deviceListMetadataVersion: 2,
							deviceListMetadata: {},
						},
						...message,
					},
				},
			};
		}

		return message;
	}
})
conn.isInit = false

if (!opts['test']) {
	setInterval(async () => {
		await Promise.allSettled([
			db.data ? db.write() : Promise.reject('db.data is null'),
			(opts['autocleartmp'] || opts['cleartmp']) ? clearTmp() : Promise.resolve()
			//clearTmp()
		])
	}, 120 * 1000)
}
if (opts['server']) (await import('./server.js')).default(global.conn, PORT)

async function connectionUpdate(update) {
	const { connection, lastDisconnect, isNewLogin } = update
	if (isNewLogin) conn.isInit = true
	const code = lastDisconnect?.error?.output?.statusCode || lastDisconnect?.error?.output?.payload?.statusCode
	if (code && code !== DisconnectReason.loggedOut && conn?.ws.readyState !== CONNECTING) {
		console.log(await global.reloadHandler(true).catch(console.error))
		global.timestamp.connect = new Date
	}
	if (db.data == null) loadDatabase()
}


process.on('uncaughtException', console.error)
// let strQuot = /(["'])(?:(?=(\\?))\2.)*?\1/

let isInit = true
let handler = await import('./handler.js')
global.reloadHandler = async function (restatConn) {
	try {
		const Handler = await import(`./handler.js?update=${Date.now()}`).catch(console.error)
		if (Object.keys(Handler || {}).length) handler = Handler
	} catch (e) {
		console.error(e)
	}
	if (restatConn) {
		const oldChats = global.conn.chats
		try { global.conn.ws.close() } catch { }
		conn.ev.removeAllListeners()
		global.conn = makeWASocket(connectionOptions, { chats: oldChats })
		isInit = true
	}
	if (!isInit) {
		conn.ev.off('messages.upsert', conn.handler)
		conn.ev.off('group-participants.update', conn.participantsUpdate)
		conn.ev.off('groups.update', conn.groupsUpdate)
		conn.ev.off('message.delete', conn.onDelete)
		conn.ev.off('connection.update', conn.connectionUpdate)
		conn.ev.off('creds.update', conn.credsUpdate)
	}

	conn.welcome = 'Hallo @user!\nSelamat datang di @subject\n\nSemoga Betah Ya Di Group Ini'
	conn.bye = '*Sayonara 👋🏻* @user!'
	conn.spromote = '@user sekarang admin!'
	conn.sdemote = '@user sekarang bukan admin!'
	conn.sDesc = 'Deskripsi telah diubah ke \n@desc'
	conn.sSubject = 'Judul grup telah diubah ke \n@subject'
	conn.sIcon = 'Icon grup telah diubah!'
	conn.sRevoke = 'Link group telah diubah ke \n@revoke'
	conn.handler = handler.handler.bind(global.conn)
	conn.participantsUpdate = handler.participantsUpdate.bind(global.conn)
	conn.groupsUpdate = handler.groupsUpdate.bind(global.conn)
	conn.onDelete = handler.deleteUpdate.bind(global.conn)
	conn.connectionUpdate = connectionUpdate.bind(global.conn)
	conn.credsUpdate = saveState.bind(global.conn, true)

	conn.ev.on('messages.upsert', conn.handler)
	conn.ev.on('group-participants.update', conn.participantsUpdate)
	conn.ev.on('groups.update', conn.groupsUpdate)
	conn.ev.on('message.delete', conn.onDelete)
	conn.ev.on('connection.update', conn.connectionUpdate)
	conn.ev.on('creds.update', conn.credsUpdate)
	isInit = false
	return true
}

const pluginFolder = Helper.__dirname(join(__dirname, './plugins/index'))
const pluginFilter = filename => /\.js$/.test(filename)
global.plugins = {}
async function filesInit() {
	for (let filename of readdirSync(pluginFolder).filter(pluginFilter)) {
		try {
			let file = Helper.__filename(join(pluginFolder, filename))
			const module = await import(file)
			global.plugins[filename] = module.default || module
		} catch (e) {
			conn.logger.error(e)
			delete global.plugins[filename]
		}
	}
}
filesInit().then(_ => console.log(Object.keys(global.plugins))).catch(console.error)

global.reload = async (_ev, filename) => {
	if (pluginFilter(filename)) {
		let dir = Helper.__filename(join(pluginFolder, filename), true)
		if (filename in global.plugins) {
			if (existsSync(dir)) conn.logger.info(` updated plugin - '${filename}'`)
			else {
				conn.logger.warn(`deleted plugin - '${filename}'`)
				return delete global.plugins[filename]
			}
		} else conn.logger.info(`new plugin - '${filename}'`)
		let err = syntaxerror(readFileSync(dir), filename, {
			sourceType: 'module',
			allowAwaitOutsideFunction: true
		})
		if (err) conn.logger.error(`syntax error while loading '${filename}'\n${format(err)}`)
		else try {
			const module = (await import(`${Helper.__filename(dir)}?update=${Date.now()}`))
			global.plugins[filename] = module.default || module
		} catch (e) {
			conn.logger.error(`error require plugin '${filename}\n${format(e)}'`)
		} finally {
			global.plugins = Object.fromEntries(Object.entries(global.plugins).sort(([a], [b]) => a.localeCompare(b)))
		}
	}
}
Object.freeze(global.reload)
watch(pluginFolder, global.reload)
await global.reloadHandler()

// Quick Test
async function _quickTest() {
	let test = await Promise.all([
		spawn('ffmpeg'),
		spawn('ffprobe'),
		spawn('ffmpeg', ['-hide_banner', '-loglevel', 'error', '-filter_complex', 'color', '-frames:v', '1', '-f', 'webp', '-']),
		spawn('convert'),
		spawn('magick'),
		spawn('gm'),
		spawn('find', ['--version'])
	].map(p => {
		return Promise.race([
			new Promise(resolve => {
				p.on('close', code => {
					resolve(code !== 127)
				})
			}),
				new Promise(resolve => {
				p.on('error', _ => resolve(false))
			})
		])
	}))
	let [ffmpeg, ffprobe, ffmpegWebp, convert, magick, gm, find] = test
	console.log(test)
	let s = global.support = {
		ffmpeg,
		ffprobe,
		ffmpegWebp,
		convert,
		magick,
		gm,
		find
	}
	// require('./lib/sticker').support = s
	Object.freeze(global.support)

	if (!s.ffmpeg) conn.logger.warn('Please install ffmpeg for sending videos (pkg install ffmpeg)')
	if (s.ffmpeg && !s.ffmpegWebp) conn.logger.warn('Stickers may not animated without libwebp on ffmpeg (--enable-ibwebp while compiling ffmpeg)')
	if (!s.convert && !s.magick && !s.gm) conn.logger.warn('Stickers may not work without imagemagick if libwebp on ffmpeg doesnt isntalled (pkg install imagemagick)')
}

_quickTest()
	.then(() => conn.logger.info('Quick Test Done'))
	.catch(console.error)