index.js

const { WAConnection, MessageType } = require("@adiwajshing/baileys")
const fs = require("fs")
const http = require("http")
const qrcode = require("qrcode")
const express = require("express")
const socketIO = require("socket.io")

const port = 8000 || process.env.PORT
const wa = new WAConnection()
const app = express()
const server = http.createServer(app)
const io = socketIO(server)

wa.connectOptions.alwaysUseTakeover = false

app.use(express.json())
app.use(express.urlencoded({
  extended: true
}))
app.use("/assets", express.static(__dirname + "/client/assets"))

app.get("/", (req, res) => {
	res.sendFile("./client/server.html", {
		root: __dirname
	})
})

app.get("/client", (req, res) => {
	res.sendFile("./client/index.html", {
		root: __dirname
	})
})

io.on("connection", async socket => {
	socket.emit("log", "Connecting...")

	wa.on("qr", qr => {
		qrcode.toDataURL(qr, (err, url) => {
			socket.emit("qr", url)
			socket.emit("log", "QR Code received, please scan!")
		})
	})

	wa.on("open", res => {
		socket.emit("qrstatus", "./assets/check.svg")
		socket.emit("log", "WhatsApp terhubung!")
		socket.emit("log", res)
	})

	wa.on("close", res => {
		socket.emit("log", "WhatsApp terputus!")
		socket.emit("log", res)
	})

	// wa.on('chat-update', async chat => {
	// 	if (chat.hasNewMessage) {
	// 		const m = chat.messages.all()[0]
	// 		console.log(m)
	// 		if (!m.key.fromMe) {
	// 			await wa.sendMessage (m.key.remoteJid, 'masih nub, belum tau apa apa (人 •͈ᴗ•͈)', MessageType.text)
	// 		}
	// 	}
	// })

	switch (wa.state) {
		case "close":
			await wa.connect()
			break
		case "open":
			socket.emit("qrstatus", "./assets/check.svg")
			socket.emit("log", "WhatsApp terhubung!")
			break
		default:
			socket.emit("log", wa.state)
	}
})

app.post('/send-message', async (req, res) => {
  const message = req.body.message
  const number = req.body.number

  if (wa.state === "open") {
		const exists = await wa.isOnWhatsApp(number)

		if (exists) {
		  wa.sendMessage(exists.jid, message, MessageType.text)
		  	.then(result => {
			  	res.status(200).json({
				  	status: true,
				  	response: result
				  })
			  })
			  .catch(err => {
			  	res.status(500).json({
				  	status: false,
				  	response: err
				  })
			  })
		} else {
	    res.status(500).json({
	      status: false,
	      response: `Nomor ${number} tidak terdaftar.`
	    })
		}
  } else {
  	res.status(500).json({
      status: false,
      response: `WhatsApp belum terhubung.`
    })
  }
})

server.listen(port, () => {
    console.log(`Server berjalan di http://localhost:${port}`)
    console.log(`Aplikasi Client di http://localhost:${port}/client`)
})