0.4.4

Author: emanuelecavalleri

.DS_Store

@@ -1,6 +1,6 @@
 DATABASE_URL=postgresql://postgres:unimi@localhost:5432/Authentication
-OPENAI_API_KEY = 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
-OPENAI_THREAD_ID = thread_GHd7arrTE7imixNtBSdn1WKL
-OPENAI_ASSISTANT_ID = asst_JD2zzWLdb2wKWsIsHonqli2A
+OPENAI_API_KEY=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
+OPENAI_THREAD_ID=thread_GHd7arrTE7imixNtBSdn1WKL
+OPENAI_ASSISTANT_ID=asst_JD2zzWLdb2wKWsIsHonqli2A
 SECRET_KEY=bc8f3e7ceed4feb4eb898d851b9e46b5977ec2f4eeb776daca8fe187eb6331d7
-EMAIL_PASSWORD =vnco cbrz emlq tbee
+EMAIL_PASSWORD=vnco cbrz emlq tbee

.env

@@ -1,2 +1,3 @@
 __pycache__
 venv
+.env

.gitignore

@@ -4,7 +4,7 @@
 from dotenv import load_dotenv
 import os
 
-load_dotenv()
+load_dotenv(override=True)
 
 DATABASE_URL = os.getenv("DATABASE_URL")
 

database.py

@@ -0,0 +1,186 @@
+CREATE TABLE Users (
+username VARCHAR(50) PRIMARY KEY,
+email VARCHAR(255) NOT NULL,
+password VARCHAR(255) NOT NULL,
+firstName VARCHAR(20) NOT NULL,
+lastName VARCHAR(20) NOT NULL,
+birthDate DATE NOT NULL,
+status VARCHAR(8) NOT NULL CHECK (status IN ('pending', 'active', 'disabled', 'blocked'))
+);
+
+CREATE TABLE Policy (
+name VARCHAR(8) PRIMARY KEY CHECK (name IN ('trial', 'silver', 'gold', 'platinum')),
+maxAccess INT,
+threshold INT
+);
+
+CREATE TABLE Operation (
+name VARCHAR(50) PRIMARY KEY,
+target VARCHAR(8) CHECK (target IN ('class', 'relation', 'subgraph')),
+description VARCHAR(100) NOT NULL
+);
+
+CREATE TABLE Category (
+name VARCHAR(13) PRIMARY KEY CHECK (name IN ('add', 'fix', 'reification', 'explain',
+'openGPTDialog', 'generate'))
+);
+
+CREATE TABLE UserSubscribesPolicy (
+username VARCHAR(50) REFERENCES Users(username) ON DELETE CASCADE,
+startDate TIMESTAMP,
+endDate TIMESTAMP,
+requestDate TIMESTAMP,
+status VARCHAR(8) NOT NULL CHECK (status IN ('pending', 'active', 'rejected', 'expired')),
+policyName VARCHAR(8) NOT NULL CHECK (policyName IN ('trial', 'silver', 'gold', 'platinum'))
+REFERENCES Policy(name) ON DELETE RESTRICT,
+PRIMARY KEY (username, requestDate)
+);
+
+CREATE TABLE UserMadeOperation (
+username VARCHAR(50) REFERENCES Users(username) ON DELETE CASCADE,
+date TIMESTAMP,
+operationName VARCHAR(50) NOT NULL REFERENCES Operation(name) ON DELETE RESTRICT,
+PRIMARY KEY (username, date)
+);
+
+CREATE TABLE OperationIsCategory (
+operationName VARCHAR(50) REFERENCES Operation(name) ON DELETE CASCADE,
+categoryName VARCHAR(13) REFERENCES Category(name) ON DELETE RESTRICT CHECK
+(categoryName IN ('add', 'fix', 'reification', 'explain', 'openGPTDialog', 'generate')),
+PRIMARY KEY (operationName, categoryName)
+);
+
+CREATE TABLE PolicyAllowsCategory (
+policyName VARCHAR(8) CHECK (policyName IN ('trial', 'silver', 'gold', 'platinum')) REFERENCES
+Policy(name) ON DELETE CASCADE,
+categoryName VARCHAR(13) REFERENCES Category(name) ON DELETE RESTRICT CHECK
+(categoryName IN ('add', 'fix', 'reification', 'explain', 'openGPTDialog', 'generate')),
+PRIMARY KEY (policyName, categoryName)
+);
+
+
+
+
+INSERT INTO Policy (name, maxAccess, threshold)
+VALUES
+('trial', 10, 3),
+('silver', 50, 10),
+('gold', 100, 15),
+('platinum', null, null);
+
+INSERT INTO Operation (name, target, description)
+VALUES
+('AddClassSimilarToClass', 'class', 'add a new class semantically similar to another class'),
+('AddClassAssociatedToClass', 'class', 'add a new class in relation with another class'),
+('AddAttributeToRelationship', 'relation', 'add relevant attributes to a relationship'),
+('AddClassesSimilarToEntities', 'subgraph', 'add one or more new classes that semantically fit the context
+defined by subgraph'),
+('ReifyClass', 'class', 'create a class for representing the instance of a class'),
+('ExplainClass', 'class', 'explain in human-friendly terms the role of class in the schema'),
+('ExplainEntities', 'subgraph', 'explain in human-friendly terms the role of a portion of the schema in the
+schema'),
+('FixClassName', 'class', 'rename a class'),
+('FixClassOntology', 'class', 'enhance the relevant ontologies for a class'),
+('FixRelationshipCardinality', 'relation', 'fix cardinality for a relationship'),
+('OpenGPTDialog', NULL, 'openGPTDialog'),
+('Generate', NULL, 'generate');
+
+INSERT INTO Category (name)
+VALUES
+('add'),
+('fix'),
+('reification'),
+('explain'),
+('openGPTDialog'),
+('generate');
+
+INSERT INTO OperationIsCategory (operationName, categoryName)
+VALUES
+('AddClassSimilarToClass', 'add'),
+('AddClassAssociatedToClass', 'add'),
+('AddAttributeToRelationship', 'add'),
+('AddClassesSimilarToEntities', 'add'),
+('ReifyClass', 'reification'),
+('ExplainClass', 'explain'),
+('ExplainEntities', 'explain'),
+('FixClassName', 'fix'),
+('FixClassOntology', 'fix'),
+('FixRelationshipCardinality', 'fix'),
+('OpenGPTDialog', 'openGPTDialog'),
+('Generate', 'generate');
+
+INSERT INTO PolicyAllowsCategory (policyName, categoryName)
+VALUES
+('trial', 'add'),
+('trial', 'fix'),
+('trial', 'reification'),
+('trial', 'explain'),
+('trial', 'openGPTDialog'),
+('trial', 'generate'),
+('silver', 'add'),
+('silver', 'fix'),
+('silver', 'reification'),
+('silver', 'explain'),
+('silver', 'openGPTDialog'),
+('silver', 'generate'),
+('gold', 'add'),
+('gold', 'fix'),
+('gold', 'reification'),
+('gold', 'explain'),
+('gold', 'openGPTDialog'),
+('gold', 'generate'),
+('platinum', 'add'),
+('platinum', 'fix'),
+('platinum', 'reification'),
+('platinum', 'explain'),
+('platinum', 'openGPTDialog'),
+('platinum', 'generate');
+
+
+
+
+
+CREATE OR REPLACE FUNCTION notify_user_status() RETURNS trigger AS $notify_user_status$
+DECLARE
+ to_email TEXT;
+ user_name TEXT;
+BEGIN
+ IF OLD.status IS DISTINCT FROM NEW.status THEN
+ to_email := NEW.email;
+ user_name := NEW.username;
+ PERFORM pg_notify('user_status', to_email || ',' || user_name || ',' || NEW.status::TEXT);
+ END IF;
+ RETURN NEW;
+END;
+$notify_user_status$ LANGUAGE plpgsql;
+
+CREATE TRIGGER send_status_email
+AFTER UPDATE OF status ON Users
+FOR EACH ROW
+WHEN (OLD.status IS DISTINCT FROM NEW.status)
+EXECUTE FUNCTION notify_user_status() ;
+
+
+
+
+
+CREATE OR REPLACE FUNCTION notify_policy_status() RETURNS trigger AS $notify_policy_status$
+DECLARE
+ to_email TEXT;
+ user_name TEXT;
+BEGIN
+ IF OLD.status IS DISTINCT FROM NEW.status THEN
+ SELECT email INTO to_email FROM Users WHERE username = NEW.username;
+ user_name := NEW.username;
+ PERFORM pg_notify('policy_status', to_email || ',' || user_name || ',' || NEW.status::TEXT);
+ END IF;
+ RETURN NEW;
+END;
+$notify_policy_status$ LANGUAGE plpgsql;
+
+CREATE TRIGGER send_policy_status_email
+AFTER UPDATE OF status ON UserSubscribesPolicy
+FOR EACH ROW
+WHEN (OLD.status IS DISTINCT FROM NEW.status)
+EXECUTE FUNCTION notify_policy_status() ;
+

database.sql

@@ -9,7 +9,7 @@
 
 local_tz = pytz.timezone("Europe/Rome")
 
-load_dotenv()
+load_dotenv(override=True)
 
 DATABASE_URL = os.getenv("DATABASE_URL")
 
@@ -25,8 +25,8 @@ async def handle_notify(connection, pid, channel_name, payload):
                 "Great news! Your SchemaLink account has been approved.\n\n"
                 "You have been granted a Trial policy that allows up to 10 intelligent requests "
                 "within the next 24 hours. After this period, your access may be limited unless you upgrade "
-                "to a higher tier.\n\n"
-                "Thank you for joining SchemaLink, and we hope you enjoy using the platform!\n\n"
+                "your policy to an upper tier.\n\n"
+                "Thank you for joining SchemaLink!\n\n"
                 f"Best regards,\n"
                 f"The SchemaLink Team"
             )

email_listener.py

@@ -7,7 +7,7 @@
 
 current_window = None
 
-load_dotenv() 
+load_dotenv(override=True) 
 
 EMAIL_ADDRESS = 'schemalinkanacleto@gmail.com'
 EMAIL_PASSWORD = os.getenv("EMAIL_PASSWORD")

gmail_service.py

@@ -33,7 +33,7 @@
 
 local_tz = pytz.timezone("Europe/Rome")
 
-load_dotenv()
+load_dotenv(override=True)
 
 OPENAI_API_KEY = os.getenv("OPENAI_API_KEY")
 OPENAI_THREAD_ID = os.getenv("OPENAI_THREAD_ID")
@@ -127,7 +127,7 @@ def get_db ():
 
 app.add_middleware(
     CORSMiddleware,
-    allow_origins=["schemalink.anacleto.di.unimi.it"],
+    allow_origins=["schemalink.anacleto.di.unimi.it", "http://localhost:8000","http://localhost:4200",],
     allow_credentials=True,
     allow_methods=["*"],  # Allows all methods
     allow_headers=["*"],  # Allows all headers
@@ -343,7 +343,7 @@ async def get_user_subscriptions(db: db_dependency):
 async def update_subscription_status( status_subscription_update: UpdateUserStatusRequest, db: db_dependency):
     policySubscription = db.query(models.UserSubscribesPolicy).filter(
         models.UserSubscribesPolicy.username == status_subscription_update.username,
-        models.UserSubscribesPolicy.status == "pending"  # Filtro aggiunto
+        models.UserSubscribesPolicy.status == "pending" 
     ).first()
 
 
@@ -423,12 +423,12 @@ async def check_user_operation(request_data: OperationRequest, db: db_dependency
     username = request_data.username
     operation = request_data.operation
 
-    print("Username ricevuto:", username)
-    print("Operation ricevuta:", operation)
+    print("Username received:", username)
+    print("Operation received:", operation)
 
     # Username null
     if not username:
-        return JSONResponse(content={"allowed": False, "reason": "You must be logged in to performs operation."})
+        return JSONResponse(content={"allowed": False, "reason": "You must be logged in to perform intelligent requests."})
 
     # Admin user
     if username == "schemalink":
@@ -474,7 +474,7 @@ async def check_user_operation(request_data: OperationRequest, db: db_dependency
     ).scalar()
 
     if user_ops_count >= max_access:
-        return JSONResponse(content={"allowed": False, "reason": "You reached the maximum number of allowed operations for your policy."}) 
+        return JSONResponse(content={"allowed": False, "reason": "You reached the maximum number of intelligent requests for your policy."}) 
 
     return JSONResponse(content={"allowed": True, "policy": policy_name})
 
@@ -519,9 +519,9 @@ async def log_user_operation(operation: UserMadeOperationInput, db: db_dependenc
                             subject = f"You have {policy.threshold} operations remaining on your '{policy.name}' plan"
                             body = (
                                 f"Hi {user.username},\n\n"
-                                f"You have {policy.threshold} operations remaining"
+                                f"You have {policy.threshold} intelligent requests remaining"
                                 f"under your current '{policy.name}' subscription plan.\n\n"
-                                f"Once you reach the limit of {policy.maxAccess} operations, your subscription will expire "
+                                f"Once you reach the limit of {policy.maxAccess} intelligent requests, your subscription will expire "
                                 f"and you will no longer be able to use intelligent requests.\n\n"
                                 f"To continue uninterrupted, consider upgrading or renewing your plan.\n\n"
                                 f"Thank you for using SchemaLink!\n"
@@ -786,18 +786,18 @@ async def contribute_on_ai_store(request: ContributeRequest, db: db_dependency):
     subject = "New contribution received"
     body =  (
         f"The gold/platinum user {user.username} ({user.email}) "
-        f"proposes the schema '{request.diagramName}' to the AI store. "
-        f"See attached file for the graph."
+        f"proposes the schema '{request.diagramName}' to be included into the AI store. "
+        f"See attached file for the SchemaLink JSON internal representation."
         f"\n\nSchemaLink Notification System"
     )
     to_email = "schemalinkanacleto@gmail.com"
 
     send_email(to_email=to_email, subject=subject, message=body, attachment=temp_file_path)
 
-    subject = "Thanks for your contribution to AI store"
+    subject = "Thanks for contributing to the AI store"
     body = (
         f"Hi {user.username},\n\n"
-        f"Thank you for your contribution to the AI store! "
+        f"Thank you for contributing to the AI store! "
         f"Your schema '{request.diagramName}' has been received and is under review.\n"
         f"\nBest regards,\n"
         f"The SchemaLink Team"