From dfc3985f9dc627e5935f9d37cf5ad2f354cff237 Mon Sep 17 00:00:00 2001 From: stephen Date: Thu, 16 Nov 2023 22:42:09 -0500 Subject: [PATCH] Adding !fetch command. Beautified code. Should have branched for that, but alas. --- index.js | 265 ++++++++++++++++++++++++++++++++----------------------- 1 file changed, 154 insertions(+), 111 deletions(-) diff --git a/index.js b/index.js index a56e9fe..83e1c2b 100644 --- a/index.js +++ b/index.js @@ -1,111 +1,154 @@ -// initialize required packages -const sqlite3 = require('sqlite3'); -const fs = require('fs'); -const ini = require('ini'); -const nostr = require('nostr-tools'); -const wspf = require('websocket-polyfill'); -const WebSocket = require('ws'); -const xmpp = require('simple-xmpp'); - -var db = new sqlite3.Database('nip26.db'); - -let { bech32, bech32m } = require('bech32'); -let letsCID; -let signedEvent; - -if (fs.existsSync('./config.ini')) { - const config = ini.parse(fs.readFileSync('./config.ini', 'utf-8')); - let sk = config.nostr.pkhex; - let pk = nostr.getPublicKey(sk); - - xmpp.on('online', function (data, to) { - console.log('Connected with JID: ' + config.xmpp.jid); - }); - xmpp.on('chat', function (from, message) { - function debug() { - if (config.debug === '1') { - console.log('[DEBUG]'); - console.log(message); - console.log(from); - }; - } - if (message === '!help') { - xmpp.send(from, 'https://wiki.vanderwarker.family/doku.php?id=code:nostrsms:commands'); - debug(); - } - else if (message === "!auth"){ - xmpp.send(from,"reauth (nip-26)"); - - const now = new Date(); - const validUntil = now.getTime() + (30 * 24 * 60 * 60 * 1000); - const insertStmt = db.prepare('INSERT INTO users (pnum, pk) VALUES (?, ?)'); - insertStmt.run(from.split("@")[0], validUntil); - insertStmt.finalize(); - debug(); - } - else { - async function main() { - const relay = nostr.relayInit(config.relays.write, WebSocket); - relay.on('connect', () => { - console.log(`connected to ${relay.url}`); - }); - relay.on('error', () => { - console.log(`failed to connect to ${relay.url}`); - }); - - await relay.connect(); - - let event = { - kind: 1, - pubkey: pk, - created_at: Math.floor(Date.now() / 1000), - tags: [], - content: message, - }; - - const signedEvent = nostr.finishEvent(event, sk); - letsCID = signedEvent.id; - showSID(letsCID,pk); - await relay.publish(signedEvent); - relay.close(); - } - - main().catch((error) => { - console.error(error); - }); - - async function showSID(letsCID,pk) { - console.log(letsCID); - console.log(pk); - const event = { - id: letsCID, - relays: [config.relays.write], - author: pk, - kind: 1, - }; - const encodedNEvent = nostr.nip19.neventEncode(event); - xmpp.send(from, "nostr:" + encodedNEvent); - debug(); - } - } - }); - xmpp.on('error', function (err) { - console.error(err); - }); - xmpp.setPresence('chat', 'https://nostrsms.com'); - xmpp.connect({ - jid: config.xmpp.jid, - password: config.xmpp.password, - host: config.xmpp.host, - port: 5222 - }); - process.on('SIGINT', function() { - console.log("SigInt receieved. Shutdown inevitable!") - process.exit(); - }); - -} else { - console.log("Please create a config.ini"); - console.log("See https://wiki.vanderwarker.family/doku.php?id=code:nostrsms:install"); - console.log("and choose your preferred install method."); -} +// initialize required packages +const sqlite3 = require('sqlite3'); +const fs = require('fs'); +const ini = require('ini'); +const nostr = require('nostr-tools'); +const wspf = require('websocket-polyfill'); +const WebSocket = require('ws'); +const xmpp = require('simple-xmpp'); + +var db = new sqlite3.Database('nip26.db'); + +let { + bech32, + bech32m +} = require('bech32'); +let letsCID; +let signedEvent; + +if (fs.existsSync('./config.ini')) { + const config = ini.parse(fs.readFileSync('./config.ini', 'utf-8')); + let sk = config.nostr.pkhex; + let pk = nostr.getPublicKey(sk); + + xmpp.on('online', function (data, to) { + console.log('Connected with JID: ' + config.xmpp.jid); + }); + xmpp.on('chat', function (from, message) { + function debug() { + if (config.debug === '1') { + console.log('[DEBUG]'); + console.log(message); + console.log(from); + }; + } + // Add NIP-05, to get users latest kind 3, and notes. + if (message === "!fetch") { + xmpp.send(from, "Sure. Please standby..."); + async function gogoGlobalShoes() { + const relay = nostr.relayInit(config.relays.read, WebSocket); + relay.on('connect', () => { + console.log(`connected to ${relay.url}`); + }); + relay.on('error', () => { + console.log(`failed to connect to ${relay.url}`); + }); + + await relay.connect(); + + let sub = relay.sub([{ + kinds: [1], + authors: [pk], + limit: 5 + }, ]) + sub.on('event', event => { + console.log('got event:', event); + + // Check if the event is already an object + const conny = typeof event === 'string' ? JSON.parse(event) : event; + + if (conny && conny.content && conny.pubkey && conny.created_at) { + const content = conny.content; + const author = conny.pubkey; + const createdAt = conny.created_at; + + // Use the extracted properties as needed + console.log('Content:', content); + console.log('Author:', author); + console.log('Created At:', createdAt); + + // You can send these properties via XMPP or perform other actions here + xmpp.send(from, `\"${content}\", - ${author} @ ${createdAt}`); + } else { + console.error('Invalid event structure or missing required properties.'); + } + }); + } + gogoGlobalShoes().catch((error) => { + console.error(error); + }); + } else if (message === '!help') { + xmpp.send(from, 'https://wiki.vanderwarker.family/doku.php?id=code:nostrsms:commands'); + debug(); + } else if (message === "!auth") { + xmpp.send(from, "reauth (nip-26)"); + + const now = new Date(); + const validUntil = now.getTime() + (30 * 24 * 60 * 60 * 1000); + const insertStmt = db.prepare('INSERT INTO users (pnum, token) VALUES (?, ?)'); + insertStmt.run(from.split("@")[0], validUntil); + insertStmt.finalize(); + debug(); + } else { + async function newPost() { + const relay = nostr.relayInit(config.relays.write, WebSocket); + relay.on('connect', () => { + console.log(`connected to ${relay.url}`); + }); + relay.on('error', () => { + console.log(`failed to connect to ${relay.url}`); + }); + + await relay.connect(); + + let event = { + kind: 1, + pubkey: pk, + created_at: Math.floor(Date.now() / 1000), + tags: [], + content: message, + }; + const signedEvent = nostr.finishEvent(event, sk); + letsCID = signedEvent.id; + showSID(letsCID, pk); + await relay.publish(signedEvent); + relay.close(); + } + newPost().catch((error) => { + console.error(error); + }); + async function showSID(letsCID, pk) { + console.log(letsCID); + console.log(pk); + const event = { + id: letsCID, + relays: [config.relays.write], + author: pk, + kind: 1, + }; + const encodedNEvent = nostr.nip19.neventEncode(event); + xmpp.send(from, "nostr:" + encodedNEvent); + debug(); + } + } + }); + xmpp.on('error', function (err) { + console.error(err); + }); + xmpp.setPresence('chat', 'https://nostrsms.com'); + xmpp.connect({ + jid: config.xmpp.jid, + password: config.xmpp.password, + host: config.xmpp.host, + port: 5222 + }); + process.on('SIGINT', function () { + console.log("SigInt receieved. Shutdown inevitable!") + process.exit(); + }); + +} else { + console.log("Please create a config.ini"); + console.log("See https://wiki.vanderwarker.family/doku.php?id=code:nostrsms:install"); + console.log("and choose your preferred install method."); +} \ No newline at end of file