Remove code that would make chats disappear when a new message is sent

jmicko · Jul 16, 2024 · 58abf85 · 58abf85
1 parent 0a0bc56
commit 58abf85
Show file tree

Hide file tree

Showing 4 changed files with 22 additions and 7 deletions.
diff --git a/client/src/components/Messages/MessageSection.tsx b/client/src/components/Messages/MessageSection.tsx
@@ -62,7 +62,7 @@ export function MessageSection({
     }
   }, [messages, initialRender, mobileCollapsed, header]);
 
-  console.log(messages, 'messages ' + header);
+  // console.log(messages, 'messages ' + header);
 
 
   return (

diff --git a/server/modules/cache.js b/server/modules/cache.js
@@ -271,9 +271,9 @@ class Messenger {
 
 
     // check and limit the number of stored messages
-    if (this.messages.length > 1000) {
-      this.messages.length = 1000;
-    }
+    // if (this.messages.length > 1000) {
+    //   this.messages.length = 1000;
+    // }
     // tell user to update messages
     const jsonMsg = JSON.stringify(message);
     console.log(jsonMsg, 'jsonMsg');
@@ -293,9 +293,9 @@ class Messenger {
     this.messageCount++;
     this.chatMessageCount++;
     // check and limit the number of stored messages
-    if (this.messages.length > 1000) {
-      this.messages.length = 1000;
-    }
+    // if (this.messages.length > 1000) {
+    //   this.messages.length = 1000;
+    // }
     // tell user to update messages
     const jsonMsg = JSON.stringify(message);
     this.sockets.forEach(socket => {

diff --git a/server/modules/coinbaseClient.js b/server/modules/coinbaseClient.js
@@ -234,6 +234,7 @@ class Coinbase {
   async getFills(params) {
     return new Promise(async (resolve, reject) => {
       try {
+        await sleep(100);
         // data should just be blank
         const data = null;
         const API = {

diff --git a/server/modules/database/messages.js b/server/modules/database/messages.js
@@ -112,4 +112,18 @@ export async function deleteMessage(userID, messageID) {
       reject(err);
     }
   })
+}
+
+export async function deletePrevious30DaysMessages() {
+  return new Promise(async (resolve, reject) => {
+    try {
+      const sqlText = `
+        DELETE FROM "messages"
+        WHERE "type" != 'chat' AND "timestamp" < NOW() - INTERVAL '30 days';`;
+      const result = await pool.query(sqlText);
+      resolve(result);
+    } catch (err) {
+      reject(err);
+    }
+  })
 }