From dc3ac3865b4f7dae1d11a679a78e84de47aca5ff Mon Sep 17 00:00:00 2001
From: freqnik <freqnik@protonmail.com>
Date: Wed, 29 Nov 2023 01:23:40 -0500
Subject: [PATCH] Update /v1/subscription/<walletAddress>. Add
 /v1/nodes/<uuid>, get_nodes().

---
 meile_plan_api.py | 23 ++++++++++++++++++++---
 1 file changed, 20 insertions(+), 3 deletions(-)

diff --git a/meile_plan_api.py b/meile_plan_api.py
index a843316..3e5d2a7 100644
--- a/meile_plan_api.py
+++ b/meile_plan_api.py
@@ -101,14 +101,13 @@ def new_user():
     return (jsonify({'username': user.username}), 201,
             {'Location': url_for('get_user', id=user.id, _external=True)})
 
-'''
 @app.route('/api/users/<int:id>')
 def get_user(id): 
     user = User.query.get(id)
     if not user:
         abort(400)
     return jsonify({'username': user.username})
-'''
+
 @app.route('/api/token')
 @auth.login_required
 def get_auth_token():
@@ -296,7 +295,7 @@ def get_plan_subscriptions():
 @auth.login_required
 def get_current_subscriber(walletAddress):
     
-    query = f"SELECT * from meile_subscriptions WHERE wallet = {walletAddress}"
+    query = f"SELECT * from meile_subscriptions WHERE wallet = '{walletAddress}'"
     
     c = GetDBCursor()
     c.execute(query)
@@ -313,7 +312,25 @@ def get_current_subscriber(walletAddress):
     except Exception as e:
         print(str(e))
         abort(404)
+        
+@app.route('/v1/nodes/<uuid>', methods=['POST'])
+@auth.login_required
+def get_nodes(uuid):
+    
+    query = f"SELECT node_address FROM plan_nodes WHERE uuid = '{uuid}'"
 
+
+    c = GetDBCursor()
+    c.execute(query)
+    
+    result = c.fetchall()
+    
+    try:
+        return jsonify(result)
+    except Exception as e:
+        print(str(e))
+        abort(404)    
+    
 def UpdateMeileSubscriberDB():
     pass