base code

Author: sasi2312

.gitignore

@@ -0,0 +1,4 @@
+dmp_2/__pycache__/*
+
+dmp_2/.env
+env/*

dmp_2/app.py

@@ -0,0 +1,79 @@
+from flask import Flask, jsonify
+from db import SupabaseInterface
+from collections import defaultdict
+
+app = Flask(__name__)
+
+
+@app.route('/api/greeting', methods=['GET'])
+def greeting():
+    response = {
+        'message': 'Hello, welcome to my API!'
+    }
+    return jsonify(response)
+
+@app.route('/api/get-data', methods=['GET'])
+def get_data():
+    # Fetch data from Supabase
+    try:
+        import pdb;pdb.set_trace()
+        response = SupabaseInterface().get_instance().client.table('dmp_pr_updates').select('*').execute()
+        data = response.data
+        return jsonify(data)
+    except Exception as e:
+        return jsonify({'error': str(e)}), 500
+    
+    
+def group_by_owner(data):
+    grouped_data = defaultdict(list)
+    for record in data:
+        owner = record['owner']
+        grouped_data[owner].append(record)
+    return grouped_data
+
+#DMP - CMS API's
+
+@app.route('/api/issues', methods=['GET'])
+def get_issues():
+    try:
+        response = SupabaseInterface().get_instance().client.table('dmp_issue_updates').select('*').execute()
+        data = response.data
+        grouped_data = group_by_owner(data)
+        return jsonify(grouped_data)
+    except Exception as e:
+        return jsonify({'error': str(e)}), 500
+    
+@app.route('/api/issues/<owner>', methods=['GET'])
+def get_issues_by_owner(owner):
+    # Fetch data from Supabase
+    try:
+        import pdb;pdb.set_trace()
+        response = SupabaseInterface().get_instance().client.table('dmp_issue_updates').select('*').eq('owner', owner).execute()
+        
+        if not response.data:
+            return jsonify({'error': "No data found"}), 500
+
+        data = response.data              
+        return jsonify(data)
+    
+    except Exception as e:
+        return jsonify({'error': str(e)}), 500
+    
+
+@app.route('/api/issues/<owner>/<issue>', methods=['GET'])
+def get_issues_by_owner_id(owner,issue):
+    # Fetch data from Supabase
+    try:
+        response = SupabaseInterface().get_instance().client.table('dmp_issue_updates').select('*').eq('owner', owner).eq('issue_number', issue).execute()
+        
+        if not response.data:
+            return jsonify({'error': "No data found"}), 500
+
+        data = response.data              
+        return jsonify(data)
+    
+    except Exception as e:
+        return jsonify({'error': str(e)}), 500
+    
+if __name__ == '__main__':
+    app.run(debug=True)

dmp_2/db.py

@@ -0,0 +1,61 @@
+import os, sys
+from typing import Any
+from supabase import create_client, Client
+from supabase.lib.client_options import ClientOptions
+from abc import ABC, abstractmethod
+
+client_options = ClientOptions(postgrest_client_timeout=None)
+
+
+
+class SupabaseInterface():
+    
+    _instance = None
+    
+    def __init__(self):
+        if not SupabaseInterface._instance:
+                        
+            # Load environment variables
+            from dotenv import load_dotenv
+            load_dotenv()
+
+            SUPABASE_URL = os.getenv('SUPABASE_URL')
+            SUPABASE_KEY = os.getenv('SUPABASE_KEY')
+            self.client: Client = create_client(SUPABASE_URL, SUPABASE_KEY)
+            SupabaseInterface._instance = self
+        else:          
+            SupabaseInterface._instance = self._instance
+        
+    
+
+    @staticmethod
+    def get_instance():
+        # Static method to retrieve the singleton instance
+        if not SupabaseInterface._instance:
+            # If no instance exists, create a new one
+            SupabaseInterface._instance = SupabaseInterface()
+        return SupabaseInterface._instance
+    
+       
+    def readAll(self, table):
+        data = self.client.table(f"{table}").select("*").execute()
+        return data.data
+    
+    def add_data(self, data,table_name):
+        data = self.client.table(table_name).insert(data).execute()
+        return data.data
+    
+    def add_data_filter(self, data, table_name):
+        # Construct the filter based on the provided column names and values
+        filter_data = {column: data[column] for column in ['dmp_id','issue_number','owner']}
+        
+        # Check if the data already exists in the table based on the filter
+        existing_data = self.client.table(table_name).select("*").eq('dmp_id',data['dmp_id']).execute()
+
+        # If the data already exists, return without creating a new record
+        if existing_data.data:
+            return "Data already exists"
+        
+        # If the data doesn't exist, insert it into the table
+        new_data = self.client.table(table_name).insert(data).execute()
+        return new_data.data

dmp_2/requirements.txt

@@ -0,0 +1,4 @@
+Flask==3.0.3
+httpx==0.27.0
+python-dotenv==1.0.1
+supabase==2.4.5