Add

DB.py

@@ -30,8 +30,8 @@ class DB:
         self.cursor_MS = self.connection_MS.cursor()
 
     def insert(self, data):
-        insert_query = f"INSERT INTO users(name,email,date,time,password,score) VALUES %s"
-        self.cursor_MS.execute(insert_query, (data,))
+        insert_query = "INSERT INTO users(name,email,date,time,password,score) VALUES (%s,%s,%s,%s,%s,%s)"
+        self.cursor_MS.execute(insert_query, data)
 
 
     def clear(self):

app.py

@@ -55,6 +55,48 @@ def allowed_file(filename):
     return '.' in filename and filename.rsplit('.', 1)[1].lower() in ALLOWED_EXTENSIONS
 
 # Add this endpoint (before /parse)
+@app.route("/upload-candidate-list", methods=["POST"])
+def upload_candidate_list():
+    try:
+        if 'candidate_list' not in request.files:
+            return jsonify({"error": "No CSV file provided"}), 400
+        
+        file = request.files['candidate_list']
+        
+        if file.filename == '':
+            return jsonify({"error": "No file selected"}), 400
+        
+        if file and file.filename.endswith('.csv'):
+            # Save as test.csv for the scheduler to use
+            filepath = os.path.join('.', 'test.csv')
+            file.save(filepath)
+            
+            # Validate CSV format
+            import pandas as pd
+            try:
+                df = pd.read_csv(filepath)
+                required_columns = ['Name', 'Email']
+                
+                if not all(col in df.columns for col in required_columns):
+                    return jsonify({
+                        "error": "CSV must have 'Name' and 'Email' columns",
+                        "found_columns": list(df.columns)
+                    }), 400
+                
+                return jsonify({
+                    "output": f"Successfully uploaded candidate list with {len(df)} candidates",
+                    "candidates": len(df)
+                })
+                
+            except Exception as e:
+                return jsonify({"error": f"Invalid CSV format: {str(e)}"}), 400
+        else:
+            return jsonify({"error": "File must be a CSV"}), 400
+            
+    except Exception as e:
+        logging.error(f"CSV upload error: {str(e)}")
+        return jsonify({"error": str(e)}), 500
+
 @app.route("/upload-resumes", methods=["POST"])
 def upload_resumes():
     try:
@@ -278,14 +320,31 @@ def score():
 
 
 def create_user(scheduler):
-    db.connect_MS()
-    df = scheduler.df
-    for name,email,date,time in zip(df["Name"],df["Email"],scheduler.date,df["Slot"]):
-        password = name[:5] + email[:5]
-        db.insert([name,email,date,time,password,0.0])
-    
-    db.connection_MS.commit()
-    db.close_MS()
+    try:
+        db.connect_MS()
+        df = scheduler.df
+        
+        for name, email, slot in zip(df["Name"], df["Email"], df["Slot"]):
+            password = name[:5] + email[:5]
+            # Extract date and time from slot string
+            slot_parts = slot.split(" - ")
+            interview_datetime = slot_parts[0]  # "2024-03-15 09:00"
+            date_part, time_part = interview_datetime.split(" ")
+            
+            # Insert individual values, not as a list
+            db.insert([name, email, date_part, time_part, password, 0.0])
+        
+        db.connection_MS.commit()
+        db.close_MS()
+        logging.info(f"Successfully created {len(df)} user records")
+        
+    except Exception as e:
+        logging.error(f"Error creating users: {str(e)}")
+        try:
+            db.close_MS()
+        except:
+            pass
+        raise e
 
 
 @app.route("/schedule", methods = ["POST"])
@@ -296,13 +355,33 @@ def email():
         time = data.get("time")
         slot_length = data.get("length")
         
+        # Validate input
+        if not date or not time or not slot_length:
+            return jsonify({"error": "Missing required fields: date, time, or length"}), 400
+        
+        # Check if CSV file exists
+        csv_path = "./test.csv"
+        if not os.path.exists(csv_path):
+            return jsonify({"error": "Candidate list file (test.csv) not found"}), 400
+        
         scheduler = Schedule()
         scheduler.defaults(date, time, slot_length)
-        scheduler.schedule_slots("./test.csv")
-        create_user(scheduler)  # Pass scheduler to create_user
+        scheduler.schedule_slots(csv_path)
+        
+        # Create user records in database
+        create_user(scheduler)
+        
+        # Send email invitations
         scheduler.send_emails()
         
-        return jsonify({"output": "Emails Sent Successfully"})
+        return jsonify({
+            "output": "Emails Sent Successfully",
+            "scheduled_count": len(scheduler.df)
+        })
+        
+    except FileNotFoundError as e:
+        logging.error(f"File not found: {str(e)}")
+        return jsonify({"error": "CSV file not found", "message": str(e)}), 400
     except Exception as e:
         logging.error(f"Scheduling error: {str(e)}")
         return jsonify({"error": "Failed to schedule interviews", "message": str(e)}), 500