index.js

@@ -1,4 +1,5 @@
 // initialize required packages
+const sqlite3 = require('sqlite3');
 const fs = require('fs');
 const ini = require('ini');
 const nostr = require('nostr-tools');
@@ -6,6 +7,8 @@ const wspf = require('websocket-polyfill');
 const WebSocket = require('ws');
 const xmpp = require('simple-xmpp');
 
+var db = new sqlite3.Database('nip26.db');
+
 let {
   bech32,
   bech32m
@@ -21,7 +24,6 @@ if (fs.existsSync('./config.ini')) {
   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') {
@@ -30,13 +32,63 @@ if (fs.existsSync('./config.ini')) {
         console.log(from);
       };
     }
-    if (message === '!help') {
+    // 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, "https://auth.nostrsms.com");
+      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);
@@ -53,7 +105,7 @@ if (fs.existsSync('./config.ini')) {
           kind: 1,
           pubkey: pk,
           created_at: Math.floor(Date.now() / 1000),
-          tags: [['client','NostrSMS','31990:9be1b8315248eeb20f9d9ab2717d1750e4f27489eab1fa531d679dadd34c2f8d:1726937516']],
+          tags: [],
           content: message,
         };
         const signedEvent = nostr.finishEvent(event, sk);
@@ -76,7 +128,6 @@ if (fs.existsSync('./config.ini')) {
         };
         const encodedNEvent = nostr.nip19.neventEncode(event);
         xmpp.send(from, "nostr:" + encodedNEvent);
-        console.log(encodedNEvent)
         debug();
       }
     }
@@ -100,4 +151,4 @@ if (fs.existsSync('./config.ini')) {
   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.");
-}
+}