Update app.py

app.py

@@ -1,3 +1,5 @@
+from mistralai import Mistral
+import numpy as np
 import os
 import time
 import requests
@@ -9,32 +11,25 @@ import pickle
 from firebase_admin import credentials, firestore
 
 # Twilio Configuration
-ACCOUNT_SID = 'AC175419b901537d8dcca5321386e58aa9'
+ACCOUNT_SID = 'AC7f8c344c6593572a0c925ab4c1b66cc6'
 AUTH_TOKEN = 'e5f750f99a87e84ca5b87ddd0c421560'
 FROM_PHONE = '+13613093564'
 TO_PHONE = '+919080522395'
 
 # Firebase Configuration
-FIREBASE_CREDENTIALS_PATH = r"snippetscript-37175-firebase-adminsdk-cf1z8-7d509b09fd.json"
-THINGSPEAK_API_KEY = "P54KXM40TA3CB6W4"
-CHANNEL_ID = "2784385"
+FIREBASE_CREDENTIALS_PATH = r"shh/snippetscript-37175-firebase-adminsdk-cf1z8-7d509b09fd.json"
+THINGSPEAK_API_KEY = "PIA8Z5BWH2DW6WLF"
+CHANNEL_ID = "2785999"
 
 # Global variable to track the last entry ID
 last_entry_id = None
-with open('model.pkl', 'rb') as f:
-    loaded_model = pickle.load(f)
+# with open(r'C:\Users\tiruv\Desktop\SIH\model.pkl', 'rb') as f:
+#     loaded_model = pickle.load(f)
 def predict_conc(pdiff):
-    try:
-        if pdiff > 3.19:
-            return 0
-        pdiff_value = pdiff  # Input for "Average Potential Difference"
-        new_data = np.array([[pdiff_value]])
-        prediction = loaded_model.predict(new_data)
-        concentration = 10**prediction[0]  # Reverse log transformation
-        return f"{concentration:.4f}"
-    except Exception as e:
-        print(f"Error in predict_conc: {e}")
-        return None
+     # Reverse log transformation
+        return pdiff
+    
+
 # Initialize Firebase
 cred = credentials.Certificate(FIREBASE_CREDENTIALS_PATH)
 firebase_admin.initialize_app(cred)
@@ -47,7 +42,7 @@ app.secret_key = os.urandom(24)  # For session management
 # Function to send SMS using Twilio
 def send_msg(doc_id, field1):
     try:
-        field1 = str(field1)
+        field1 = (field1)
         # Fetch the document with the given doc_id
         doc_ref = db.collection('thingspeak_data').document(doc_id)
         doc = doc_ref.get()
@@ -58,7 +53,7 @@ def send_msg(doc_id, field1):
 
             # Check if the message status is 0
             if msg_status == 0:
-                concen=predict_conc(int(field1))
+                concen=predict_conc(field1)
                 client = Client(ACCOUNT_SID, AUTH_TOKEN)
                 if concen!=0:
                     sugges="You may heat your water to eradicate the bacteria."
@@ -93,11 +88,14 @@ def on_snapshot(doc_snapshot, changes, read_time):
     for change in changes:
         if change.type.name == 'ADDED':
             new_data = change.document.to_dict()
-            print(f"New data detected: {new_data}")  # Add this for more debugging info
+            print(f"New data detected: {new_data}")  # Debugging info
             field1 = new_data.get('field1', 'N/A')
-            print(f"Field1: {field1}")  # Check the type and value of field1
-            send_msg(change.document.id, field1)
-
+            try:
+                field1 = float(field1)  # Convert field1 to float
+                print(f"Field1 as float: {field1}")
+                send_msg(change.document.id, field1)
+            except ValueError:
+                print(f"Invalid field1 value: {field1}. Must be numeric.")
 
 # Firestore Listener Initialization
 def start_firestore_listener():
@@ -213,7 +211,29 @@ def main():
         print("Process interrupted by user.")
     except Exception as e:
         print(f"Unexpected error: {e}")
+API_KEY = 'xQ2Zhfsp4cLar4lvBRDWZKljvp0Ej427'
+MODEL = "mistral-large-latest"
+client = Mistral(api_key=API_KEY)
 
+@app.route('/chat', methods=['POST'])
+def chat():
+    data = request.json
+    user_query = data.get("query", "")
+
+    if not user_query:
+        return jsonify({"error": "Query cannot be empty"}), 400
+
+    try:
+        chat_response = client.chat.complete(
+            model=MODEL,
+            messages=[
+                {"role": "user", "content": user_query+"You are the best assistant. Provide the precise response within 2 to 3 sentence.Greet the user if user greets.Your response must be rural area people."},
+            ]
+        )
+        response_content = chat_response.choices[0].message.content
+        return jsonify({"response": response_content})
+    except Exception as e:
+        return jsonify({"error": str(e)}), 500
 if __name__ == '__main__':
     from threading import Thread
 
@@ -223,4 +243,4 @@ if __name__ == '__main__':
 
     # Run Flask app in the main thread with debugging enabled
     app.run(host='0.0.0.0', port=7860, debug=True)
- 
+