From e954fc00539a38c99bb62a3551be0d744f679f18 Mon Sep 17 00:00:00 2001 From: Adhiraj Singh Date: Sat, 22 Jan 2022 11:37:39 +0530 Subject: [PATCH] lint: examples --- Example/example-legacy.ts | 96 ++++++++++++++++----------------- Example/example.ts | 111 +++++++++++++++++++------------------- 2 files changed, 104 insertions(+), 103 deletions(-) diff --git a/Example/example-legacy.ts b/Example/example-legacy.ts index 0b4b388..bae2b89 100644 --- a/Example/example-legacy.ts +++ b/Example/example-legacy.ts @@ -1,6 +1,6 @@ -import P from "pino" -import { Boom } from "@hapi/boom" -import { makeWALegacySocket, DisconnectReason, AnyMessageContent, delay, useSingleFileLegacyAuthState, makeInMemoryStore } from '../src' +import { Boom } from '@hapi/boom' +import P from 'pino' +import { AnyMessageContent, delay, DisconnectReason, makeInMemoryStore, makeWALegacySocket, useSingleFileLegacyAuthState } from '../src' // the store maintains the data of the WA connection in memory // 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') // save every 10s setInterval(() => { - store.writeToFile('./baileys_store.json') + store.writeToFile('./baileys_store.json') }, 10_000) const { state, saveState } = useSingleFileLegacyAuthState('./auth_info.json') @@ -16,61 +16,61 @@ const { state, saveState } = useSingleFileLegacyAuthState('./auth_info.json') // start a connection const startSock = () => { - const sock = makeWALegacySocket({ - logger: P({ level: 'debug' }), - printQRInTerminal: true, - auth: state - }) - store.bind(sock.ev) + const sock = makeWALegacySocket({ + logger: P({ level: 'debug' }), + printQRInTerminal: true, + auth: state + }) + store.bind(sock.ev) - const sendMessageWTyping = async(msg: AnyMessageContent, jid: string) => { - await sock.presenceSubscribe(jid) - await delay(500) + const sendMessageWTyping = async(msg: AnyMessageContent, jid: string) => { + await sock.presenceSubscribe(jid) + await delay(500) - await sock.sendPresenceUpdate('composing', jid) - await delay(2000) + await sock.sendPresenceUpdate('composing', jid) + 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 => { - if(m.type === 'append' || m.type === 'notify') { - console.log(JSON.stringify(m, undefined, 2)) - } + sock.ev.on('messages.upsert', async m => { + if(m.type === 'append' || m.type === 'notify') { + console.log(JSON.stringify(m, undefined, 2)) + } - const msg = m.messages[0] - if(!msg.key.fromMe && m.type === 'notify') { - console.log('replying to', m.messages[0].key.remoteJid) - await sock!.chatRead(msg.key, 1) - await sendMessageWTyping({ text: 'Hello there!' }, msg.key.remoteJid) - } + const msg = m.messages[0] + if(!msg.key.fromMe && m.type === 'notify') { + console.log('replying to', m.messages[0].key.remoteJid) + await sock!.chatRead(msg.key, 1) + await sendMessageWTyping({ text: 'Hello there!' }, msg.key.remoteJid) + } - }) + }) - 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('chats.update', m => console.log(m)) - sock.ev.on('contacts.update', m => console.log(m)) + 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('chats.update', m => console.log(m)) + sock.ev.on('contacts.update', m => console.log(m)) - sock.ev.on('connection.update', (update) => { - const { connection, lastDisconnect } = update - if(connection === 'close') { - // reconnect if not logged out - if((lastDisconnect.error as Boom)?.output?.statusCode !== DisconnectReason.loggedOut) { - startSock() - } else { - console.log('connection closed') - } - } + sock.ev.on('connection.update', (update) => { + const { connection, lastDisconnect } = update + if(connection === 'close') { + // reconnect if not logged out + if((lastDisconnect.error as Boom)?.output?.statusCode !== DisconnectReason.loggedOut) { + startSock() + } else { + console.log('connection closed') + } + } - console.log('connection update', update) - }) - // listen for when the auth credentials is updated - sock.ev.on('creds.update', saveState) + console.log('connection update', update) + }) + // listen for when the auth credentials is updated + sock.ev.on('creds.update', saveState) - return sock + return sock } startSock() \ No newline at end of file diff --git a/Example/example.ts b/Example/example.ts index 4d4b289..2a89d22 100644 --- a/Example/example.ts +++ b/Example/example.ts @@ -1,6 +1,6 @@ -import P from "pino" -import { Boom } from "@hapi/boom" -import makeWASocket, { DisconnectReason, AnyMessageContent, delay, useSingleFileAuthState, makeInMemoryStore } from '../src' +import { Boom } from '@hapi/boom' +import P from 'pino' +import makeWASocket, { AnyMessageContent, delay, DisconnectReason, makeInMemoryStore, useSingleFileAuthState } from '../src' // the store maintains the data of the WA connection in memory // 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') // save every 10s setInterval(() => { - store.writeToFile('./baileys_store_multi.json') + store.writeToFile('./baileys_store_multi.json') }, 10_000) const { state, saveState } = useSingleFileAuthState('./auth_info_multi.json') @@ -16,70 +16,71 @@ const { state, saveState } = useSingleFileAuthState('./auth_info_multi.json') // start a connection const startSock = () => { - const sock = makeWASocket({ - logger: P({ level: 'trace' }), - printQRInTerminal: true, - auth: state, - // implement to handle retries - getMessage: async key => { - return { - conversation: 'hello' - } - } - }) + const sock = makeWASocket({ + logger: P({ level: 'trace' }), + printQRInTerminal: true, + auth: state, + // implement to handle retries + getMessage: async key => { + return { + conversation: 'hello' + } + } + }) - store.bind(sock.ev) + store.bind(sock.ev) - const sendMessageWTyping = async(msg: AnyMessageContent, jid: string) => { - await sock.presenceSubscribe(jid) - await delay(500) + const sendMessageWTyping = async(msg: AnyMessageContent, jid: string) => { + await sock.presenceSubscribe(jid) + await delay(500) - await sock.sendPresenceUpdate('composing', jid) - await delay(2000) + await sock.sendPresenceUpdate('composing', jid) + 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('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('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('contacts.set', item => console.log(`recv ${item.contacts.length} contacts`)) - sock.ev.on('messages.upsert', async m => { - console.log(JSON.stringify(m, undefined, 2)) + sock.ev.on('messages.upsert', async m => { + console.log(JSON.stringify(m, undefined, 2)) - const msg = m.messages[0] - if(!msg.key.fromMe && m.type === 'notify') { - console.log('replying to', m.messages[0].key.remoteJid) - await sock!.sendReadReceipt(msg.key.remoteJid, msg.key.participant, [msg.key.id]) - await sendMessageWTyping({ text: 'Hello there!' }, msg.key.remoteJid) - } + const msg = m.messages[0] + if(!msg.key.fromMe && m.type === 'notify') { + console.log('replying to', m.messages[0].key.remoteJid) + await sock!.sendReadReceipt(msg.key.remoteJid, msg.key.participant, [msg.key.id]) + await sendMessageWTyping({ text: 'Hello there!' }, msg.key.remoteJid) + } - }) + }) - sock.ev.on('messages.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('contacts.upsert', m => console.log(m)) + sock.ev.on('messages.update', m => console.log(m)) + sock.ev.on('message-receipt.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('contacts.upsert', m => console.log(m)) - sock.ev.on('connection.update', (update) => { - const { connection, lastDisconnect } = update - if(connection === 'close') { - // reconnect if not logged out - if((lastDisconnect.error as Boom)?.output?.statusCode !== DisconnectReason.loggedOut) { - startSock() - } else { - console.log('connection closed') - } - } + sock.ev.on('connection.update', (update) => { + const { connection, lastDisconnect } = update + if(connection === 'close') { + // reconnect if not logged out + if((lastDisconnect.error as Boom)?.output?.statusCode !== DisconnectReason.loggedOut) { + startSock() + } else { + console.log('connection closed') + } + } - console.log('connection update', update) - }) - // listen for when the auth credentials is updated - sock.ev.on('creds.update', saveState) + console.log('connection update', update) + }) + // listen for when the auth credentials is updated + sock.ev.on('creds.update', saveState) - return sock + return sock } startSock() \ No newline at end of file