Add Subscription Page

Author: the2pizza

dev/dev.sql

@@ -151,28 +151,25 @@ ADD COLUMN expired_at TIMESTAMP WITH TIME ZONE;
 ALTER TABLE connections
 ADD COLUMN expired_at TIMESTAMP WITH TIME ZONE;
 
+===
 
 
 ALTER TABLE connections RENAME COLUMN user_id TO subscription_id;
 
 CREATE TABLE subscriptions (
     id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
     expires_at TIMESTAMP WITH TIME ZONE NOT NULL,
-    
-    referral_code CHAR(12) UNIQUE, 
-    referred_by UUID REFERENCES subscriptions(id),  
-    
-    referral_count INTEGER DEFAULT 0,
-    referral_bonus_days INTEGER DEFAULT 0,
-    
+    referred_by CHAR(13),  
+        
     created_at TIMESTAMP WITH TIME ZONE DEFAULT now(),
-    updated_at TIMESTAMP WITH TIME ZONE DEFAULT now()
+    updated_at TIMESTAMP WITH TIME ZONE DEFAULT now(),
+    is_deleted BOOL NOT NULL DEFAULT false
 );
 
-CREATE INDEX idx_subscriptions_user_id ON subscriptions(user_id);
 CREATE INDEX idx_subscriptions_expires_at ON subscriptions(expires_at);
-CREATE INDEX idx_subscriptions_referral_code ON subscriptions(referral_code);
 CREATE INDEX idx_subscriptions_referred_by ON subscriptions(referred_by);
 
-    ALTER TABLE subscriptions
-    ADD COLUMN is_deleted BOOL NOT NULL DEFAULT false;
+
+
+
+

dev/user-state.html

@@ -81,6 +81,12 @@ <h3>Current Connections:</h3>
         <pre id="conns"></pre>
     </div>
 
+    <div id="subs-container" style="display:none;">
+        <h3>Subscriptions</h3>
+        <pre id="subs"></pre>
+    </div>
+
+
     <script>
         let socket = null;
         let reconnectInterval = null;
@@ -95,6 +101,9 @@ <h3>Current Connections:</h3>
         const usersHeader = document.getElementById('users-header');
         const connElement = document.getElementById('conn-info');
         const connIdInput = document.getElementById('connId');
+        const subsContainer = document.getElementById('subs-container');
+        const subsElement = document.getElementById('subs');
+
 
         function buildWebSocketUrl({ host, port, ssl = true, path = '' }) {
             let protocol = ssl ? 'wss' : 'ws';
@@ -121,21 +130,18 @@ <h3>Current Connections:</h3>
                 socket = new WebSocket(url, token); // token as subprotocol
 
                 socket.onopen = () => {
-                    console.log(`Connected to WebSocket server at ${url}`);
-                    clearInterval(reconnectInterval);
                     requestConns();
                     requestNodes();
-                    requestUsers();
-
+                    requestSubscriptions();
+                
                     setInterval(() => {
-                        if (socket && socket.readyState === WebSocket.OPEN) {
-                            requestConns();
-                            requestNodes();
-                            requestUsers();
-                        }
+                        requestConns();
+                        requestNodes();
+                        requestSubscriptions();
                     }, 5000);
                 };
 
+
                 socket.onmessage = (event) => {
                     const data = event.data;
                     try {
@@ -147,6 +153,7 @@ <h3>Current Connections:</h3>
                             case "nodes": displayNodes(response); break;
                             case "conn": displayConnInfo(response); break;
                             case "users": displayUsers(response); break;
+                            case "subs": displaySubs(response); break;
                             default: console.log("Unknown response kind:", response.kind);
                         }
                     } catch (error) {
@@ -188,6 +195,15 @@ <h3>Current Connections:</h3>
                 alert('Please enter a valid conn ID');
             }
         });
+        
+        function requestSubscriptions() {
+            if (socket && socket.readyState === WebSocket.OPEN) {
+                socket.send(JSON.stringify({
+                    kind: "get_subscriptions",
+                    message: "Requesting subscriptions"
+                }));
+            }
+        }
 
         function requestConns() {
             if (socket && socket.readyState === WebSocket.OPEN) {
@@ -239,6 +255,27 @@ <h3>Current Connections:</h3>
             }
         }
 
+        function displaySubs(state) {
+            subsContainer.style.display = 'block';
+            subsElement.innerHTML = "";
+        
+            let data = state.data;
+        
+            if (Array.isArray(data)) {
+                const ul = document.createElement('ul');
+                data.forEach(sub => {
+                    const li = document.createElement('li');
+                    li.textContent =
+                        `ID: ${sub.id}, expires: ${sub.expires_at}, deleted: ${sub.is_deleted}, ref:_by ${sub.referred_by}`;
+                    ul.appendChild(li);
+                });
+                subsElement.appendChild(ul);
+            } else {
+                subsElement.textContent = JSON.stringify(state.data, null, 2);
+            }
+        }
+
+
         function displayNodes(state) {
             nodesContainer.style.display = 'block';
             nodesElement.innerHTML = "";