Merge branch 'dev' of https://github.com/Code4GovTech/DMP-CMS-Backend-API

Author: sasi2312

.gitignore

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

app.py

@@ -0,0 +1,184 @@
+from flask import Flask, jsonify
+from db import SupabaseInterface
+from collections import defaultdict
+from flasgger import Swagger
+
+
+app = Flask(__name__)
+
+Swagger(app)
+
+
+@app.route('/api/greeting', methods=['GET'])
+def greeting():
+    """
+    A simple greeting endpoint.
+    ---
+    responses:
+      200:
+        description: A greeting message
+        schema:
+          type: object
+          properties:
+            message:
+              type: string
+              example: Hello, welcome to my API!
+    """
+    response = {
+        'message': 'Hello, welcome to my API!'
+    }
+    return jsonify(response)
+
+@app.route('/api/get-data', methods=['GET'])
+def get_data():
+    """
+    Fetch data from Supabase.
+    ---
+    responses:
+      200:
+        description: Data fetched successfully
+        schema:
+          type: array
+          items:
+            type: object
+      500:
+        description: Error fetching data
+        schema:
+          type: object
+          properties:
+            error:
+              type: string
+    """
+    try:
+        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)
+        
+        
+    #Arrange data as reponse format
+    res = []
+    for val in grouped_data:
+      dict_ = {}
+      dict_['org_name'] = val
+      dict_['issues'] = grouped_data[val]
+      
+      res.append(dict_)
+      
+    return {"issues":res}
+
+@app.route('/api/issues', methods=['GET'])
+def get_issues():
+    """
+    Fetch all issues and group by owner.
+    ---
+    responses:
+      200:
+        description: Issues grouped by owner
+        schema:
+          type: object
+          additionalProperties:
+            type: array
+            items:
+              type: object
+      500:
+        description: Error fetching issues
+        schema:
+          type: object
+          properties:
+            error:
+              type: string
+    """
+    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 issues by owner.
+    ---
+    parameters:
+      - name: owner
+        in: path
+        type: string
+        required: true
+        description: The owner of the issues
+    responses:
+      200:
+        description: Issues fetched successfully
+        schema:
+          type: array
+          items:
+            type: object
+      500:
+        description: Error fetching issues
+        schema:
+          type: object
+          properties:
+            error:
+              type: string
+    """
+    try:
+        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
+        data = [{**item, "name": item["owner"]} for item in 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 issues by owner and issue number.
+    ---
+    parameters:
+      - name: owner
+        in: path
+        type: string
+        required: true
+        description: The owner of the issues
+      - name: issue
+        in: path
+        type: string
+        required: true
+        description: The issue number
+    responses:
+      200:
+        description: Issues fetched successfully
+        schema:
+          type: array
+          items:
+            type: object
+      500:
+        description: Error fetching issues
+        schema:
+          type: object
+          properties:
+            error:
+              type: string
+    """
+    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)

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

requirements.txt

@@ -0,0 +1,6 @@
+Flask==3.0.3
+httpx==0.27.0
+python-dotenv==1.0.1
+supabase==2.4.5
+gunicorn==22.0.0
+flasgger==0.9.7.1

wsgi.py

@@ -0,0 +1,4 @@
+from app import app
+
+if __name__ == "__main__":
+    app.run()