franpcode/Baileys
1
0
Fork 0
mirror of https://github.com/FranP-code/Baileys.git synced 2025-10-13 00:32:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

lint: examples

Browse Source
This commit is contained in:
Adhiraj Singh
2022-01-22 11:37:39 +05:30
parent 57d6ab62a1
commit e954fc0053
2 changed files with 104 additions and 103 deletions
Download Patch File Download Diff File Expand all files Collapse all files

96
Example/example-legacy.ts
View File

@@ -1,6 +1,6 @@
import P from "pino" import { Boom } from '@hapi/boom'
import { Boom } from "@hapi/boom" import P from 'pino'
import { makeWALegacySocket, DisconnectReason, AnyMessageContent, delay, useSingleFileLegacyAuthState, makeInMemoryStore } from '../src' import { AnyMessageContent, delay, DisconnectReason, makeInMemoryStore, makeWALegacySocket, useSingleFileLegacyAuthState } from '../src'
// the store maintains the data of the WA connection in memory // the store maintains the data of the WA connection in memory
// can be written out to a file & read from it // can be written out to a file & read from it
@@ -8,7 +8,7 @@ const store = makeInMemoryStore({ logger: P().child({ level: 'debug', stream: 's
store.readFromFile('./baileys_store.json') store.readFromFile('./baileys_store.json')
// save every 10s // save every 10s
setInterval(() => { setInterval(() => {
store.writeToFile('./baileys_store.json') store.writeToFile('./baileys_store.json')
}, 10_000) }, 10_000)
const { state, saveState } = useSingleFileLegacyAuthState('./auth_info.json') const { state, saveState } = useSingleFileLegacyAuthState('./auth_info.json')
@@ -16,61 +16,61 @@ const { state, saveState } = useSingleFileLegacyAuthState('./auth_info.json')
// start a connection // start a connection
const startSock = () => { const startSock = () => {
const sock = makeWALegacySocket({ const sock = makeWALegacySocket({
logger: P({ level: 'debug' }), logger: P({ level: 'debug' }),
printQRInTerminal: true, printQRInTerminal: true,
auth: state auth: state
}) })
store.bind(sock.ev) store.bind(sock.ev)
const sendMessageWTyping = async(msg: AnyMessageContent, jid: string) => { const sendMessageWTyping = async(msg: AnyMessageContent, jid: string) => {
await sock.presenceSubscribe(jid) await sock.presenceSubscribe(jid)
await delay(500) await delay(500)
await sock.sendPresenceUpdate('composing', jid) await sock.sendPresenceUpdate('composing', jid)
await delay(2000) await delay(2000)
await sock.sendPresenceUpdate('paused', jid) await sock.sendPresenceUpdate('paused', jid)
await sock.sendMessage(jid, msg) await sock.sendMessage(jid, msg)
} }
sock.ev.on('messages.upsert', async m => { sock.ev.on('messages.upsert', async m => {
if(m.type === 'append' || m.type === 'notify') { if(m.type === 'append' || m.type === 'notify') {
console.log(JSON.stringify(m, undefined, 2)) console.log(JSON.stringify(m, undefined, 2))
} }
const msg = m.messages[0] const msg = m.messages[0]
if(!msg.key.fromMe && m.type === 'notify') { if(!msg.key.fromMe && m.type === 'notify') {
console.log('replying to', m.messages[0].key.remoteJid) console.log('replying to', m.messages[0].key.remoteJid)
await sock!.chatRead(msg.key, 1) await sock!.chatRead(msg.key, 1)
await sendMessageWTyping({ text: 'Hello there!' }, msg.key.remoteJid) await sendMessageWTyping({ text: 'Hello there!' }, msg.key.remoteJid)
} }
}) })
sock.ev.on('messages.update', m => console.log(JSON.stringify(m, undefined, 2))) sock.ev.on('messages.update', m => console.log(JSON.stringify(m, undefined, 2)))
sock.ev.on('presence.update', m => console.log(m)) sock.ev.on('presence.update', m => console.log(m))
sock.ev.on('chats.update', m => console.log(m)) sock.ev.on('chats.update', m => console.log(m))
sock.ev.on('contacts.update', m => console.log(m)) sock.ev.on('contacts.update', m => console.log(m))
sock.ev.on('connection.update', (update) => { sock.ev.on('connection.update', (update) => {
const { connection, lastDisconnect } = update const { connection, lastDisconnect } = update
if(connection === 'close') { if(connection === 'close') {
// reconnect if not logged out // reconnect if not logged out
if((lastDisconnect.error as Boom)?.output?.statusCode !== DisconnectReason.loggedOut) { if((lastDisconnect.error as Boom)?.output?.statusCode !== DisconnectReason.loggedOut) {
startSock() startSock()
} else { } else {
console.log('connection closed') console.log('connection closed')
} }
} }
console.log('connection update', update) console.log('connection update', update)
}) })
// listen for when the auth credentials is updated // listen for when the auth credentials is updated
sock.ev.on('creds.update', saveState) sock.ev.on('creds.update', saveState)
return sock return sock
} }
startSock() startSock()

111
Example/example.ts
View File

@@ -1,6 +1,6 @@
import P from "pino" import { Boom } from '@hapi/boom'
import { Boom } from "@hapi/boom" import P from 'pino'
import makeWASocket, { DisconnectReason, AnyMessageContent, delay, useSingleFileAuthState, makeInMemoryStore } from '../src' import makeWASocket, { AnyMessageContent, delay, DisconnectReason, makeInMemoryStore, useSingleFileAuthState } from '../src'
// the store maintains the data of the WA connection in memory // the store maintains the data of the WA connection in memory
// can be written out to a file & read from it // can be written out to a file & read from it
@@ -8,7 +8,7 @@ const store = makeInMemoryStore({ logger: P().child({ level: 'debug', stream: 's
store.readFromFile('./baileys_store_multi.json') store.readFromFile('./baileys_store_multi.json')
// save every 10s // save every 10s
setInterval(() => { setInterval(() => {
store.writeToFile('./baileys_store_multi.json') store.writeToFile('./baileys_store_multi.json')
}, 10_000) }, 10_000)
const { state, saveState } = useSingleFileAuthState('./auth_info_multi.json') const { state, saveState } = useSingleFileAuthState('./auth_info_multi.json')
@@ -16,70 +16,71 @@ const { state, saveState } = useSingleFileAuthState('./auth_info_multi.json')
// start a connection // start a connection
const startSock = () => { const startSock = () => {
const sock = makeWASocket({ const sock = makeWASocket({
logger: P({ level: 'trace' }), logger: P({ level: 'trace' }),
printQRInTerminal: true, printQRInTerminal: true,
auth: state, auth: state,
// implement to handle retries // implement to handle retries
getMessage: async key => { getMessage: async key => {
return { return {
conversation: 'hello' conversation: 'hello'
} }
} }
}) })
store.bind(sock.ev) store.bind(sock.ev)
const sendMessageWTyping = async(msg: AnyMessageContent, jid: string) => { const sendMessageWTyping = async(msg: AnyMessageContent, jid: string) => {
await sock.presenceSubscribe(jid) await sock.presenceSubscribe(jid)
await delay(500) await delay(500)
await sock.sendPresenceUpdate('composing', jid) await sock.sendPresenceUpdate('composing', jid)
await delay(2000) await delay(2000)
await sock.sendPresenceUpdate('paused', jid) await sock.sendPresenceUpdate('paused', jid)
await sock.sendMessage(jid, msg) await sock.sendMessage(jid, msg)
} }
sock.ev.on('chats.set', item => console.log(`recv ${item.chats.length} chats (is latest: ${item.isLatest})`)) sock.ev.on('chats.set', item => console.log(`recv ${item.chats.length} chats (is latest: ${item.isLatest})`))
sock.ev.on('messages.set', item => console.log(`recv ${item.messages.length} messages (is latest: ${item.isLatest})`)) sock.ev.on('messages.set', item => console.log(`recv ${item.messages.length} messages (is latest: ${item.isLatest})`))
sock.ev.on('contacts.set', item => console.log(`recv ${item.contacts.length} contacts`)) sock.ev.on('contacts.set', item => console.log(`recv ${item.contacts.length} contacts`))
sock.ev.on('messages.upsert', async m => { sock.ev.on('messages.upsert', async m => {
console.log(JSON.stringify(m, undefined, 2)) console.log(JSON.stringify(m, undefined, 2))
const msg = m.messages[0] const msg = m.messages[0]
if(!msg.key.fromMe && m.type === 'notify') { if(!msg.key.fromMe && m.type === 'notify') {
console.log('replying to', m.messages[0].key.remoteJid) console.log('replying to', m.messages[0].key.remoteJid)
await sock!.sendReadReceipt(msg.key.remoteJid, msg.key.participant, [msg.key.id]) await sock!.sendReadReceipt(msg.key.remoteJid, msg.key.participant, [msg.key.id])
await sendMessageWTyping({ text: 'Hello there!' }, msg.key.remoteJid) await sendMessageWTyping({ text: 'Hello there!' }, msg.key.remoteJid)
} }
}) })
sock.ev.on('messages.update', m => console.log(m)) sock.ev.on('messages.update', m => console.log(m))
sock.ev.on('presence.update', m => console.log(m)) sock.ev.on('message-receipt.update', m => console.log(m))
sock.ev.on('chats.update', m => console.log(m)) sock.ev.on('presence.update', m => console.log(m))
sock.ev.on('contacts.upsert', m => console.log(m)) sock.ev.on('chats.update', m => console.log(m))
sock.ev.on('contacts.upsert', m => console.log(m))
sock.ev.on('connection.update', (update) => { sock.ev.on('connection.update', (update) => {
const { connection, lastDisconnect } = update const { connection, lastDisconnect } = update
if(connection === 'close') { if(connection === 'close') {
// reconnect if not logged out // reconnect if not logged out
if((lastDisconnect.error as Boom)?.output?.statusCode !== DisconnectReason.loggedOut) { if((lastDisconnect.error as Boom)?.output?.statusCode !== DisconnectReason.loggedOut) {
startSock() startSock()
} else { } else {
console.log('connection closed') console.log('connection closed')
} }
} }
console.log('connection update', update) console.log('connection update', update)
}) })
// listen for when the auth credentials is updated // listen for when the auth credentials is updated
sock.ev.on('creds.update', saveState) sock.ev.on('creds.update', saveState)
return sock return sock
} }
startSock() startSock()