Update app.py

app.py

@@ -1,104 +1,82 @@
 import os
-import requests
 from flask import Flask, request, jsonify, render_template
 from flask_sqlalchemy import SQLAlchemy
 from datetime import datetime, timedelta
-from twilio.twiml.messaging_response import MessagingResponse
+import requests
 
 app = Flask(__name__)
 
-# --- Configuration ---
-app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///odistay.db'
+# --- Archipelagic Persistence ---
+# Hugging Face provides /data for persistent storage if enabled
+PERSISTENT_DIR = "/data" if os.path.exists("/data") else "."
+db_path = os.path.join(PERSISTENT_DIR, "odistay.db")
+app.config['SQLALCHEMY_DATABASE_URI'] = f'sqlite:///{db_path}'
 app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
 db = SQLAlchemy(app)
 
-# --- Database Models (The Neural Grid) ---
+# --- The Data Models ---
 class StayNode(db.Model):
     id = db.Column(db.Integer, primary_key=True)
     name = db.Column(db.String(100), nullable=False)
-    category = db.Column(db.String(50)) # Resort, Guesthouse, Safari, Urban
+    island = db.Column(db.String(50))
+    category = db.Column(db.String(20)) # Resort, Guesthouse, Safari
     lat = db.Column(db.Float)
     lng = db.Column(db.Float)
-    whatsapp_number = db.Column(db.String(20))
-    rooms_available = db.Column(db.Integer, default=0)
-    last_updated = db.Column(db.DateTime, default=datetime.utcnow)
+    whatsapp = db.Column(db.String(20), unique=True)
+    rooms = db.Column(db.Integer, default=0)
     is_active = db.Column(db.Boolean, default=False)
+    last_pulse = db.Column(db.DateTime, default=datetime.utcnow)
 
-# --- Logic: Stay-Motion Sync ---
-def get_vessels_near(lat, lng, radius=10):
-    """Fetch live data from FollowMe.mv (Simulated API Logic)"""
-    # In a real scenario, you'd scrape or use FollowMe's public feed
-    # For now, we return a structured sync object
+# --- Logic: FollowMe Sync Simulation ---
+def get_live_vessels():
+    # In production, this scrapes or calls the FollowMe API
     return [
-        {"name": "Dhigurah Express", "eta": "15 mins", "dist": "2km", "link": "https://m.followme.mv/public/123"},
-        {"name": "Supply Dhoni 04", "eta": "1 hr", "dist": "12km", "link": "https://m.followme.mv/public/456"}
+        {"name": "Dhigurah Express", "type": "Speedboat", "lat": 4.17, "lng": 73.51, "status": "En-route"},
+        {"name": "Baa Cargo", "type": "Supply", "lat": 4.20, "lng": 73.55, "status": "Docked"}
     ]
 
-# --- Route: The Global Map (Customer View) ---
+# --- Routes ---
 @app.route('/')
 def index():
-    # Filter only nodes with active tokens (updated in last 24hrs)
-    expiry_limit = datetime.utcnow() - timedelta(hours=24)
-    active_stays = StayNode.query.filter(StayNode.last_updated > expiry_limit, StayNode.is_active == True).all()
-    return render_template('map.html', stays=active_stays)
+    # Only show nodes that have "pulsed" in the last 24 hours (Real-time Truth)
+    expiry = datetime.utcnow() - timedelta(hours=24)
+    active_stays = StayNode.query.filter(StayNode.last_pulse > expiry, StayNode.is_active == True).all()
+    vessels = get_live_vessels()
+    return render_template('index.html', stays=active_stays, vessels=vessels)
 
-# --- Route: WhatsApp Bot (Admin Portal) ---
-@app.route('/whatsapp/webhook', methods=['POST'])
-def whatsapp_bot():
-    incoming_msg = request.values.get('Body', '').upper()
-    sender_number = request.values.get('From', '')
-    response = MessagingResponse()
-    msg = response.message()
-
-    # Find host by phone number
-    host = StayNode.query.filter_by(whatsapp_number=sender_number).first()
+@app.route('/whatsapp', methods=['POST'])
+def whatsapp_webhook():
+    # This acts as the OdiStay Admin Portal
+    incoming = request.values.get('Body', '').upper()
+    sender = request.values.get('From', '')
     
-    if not host:
-        msg.body("Welcome to OdiStay. Please register your property first at odistay.mv")
-        return str(response)
+    host = StayNode.query.filter_by(whatsapp=sender).first()
+    if not host: return "Unauthorized", 403
 
-    # Command Logic: "AVAIL [rooms]" or "FULL"
-    if "AVAIL" in incoming_msg:
+    if "AVAIL" in incoming:
         try:
-            count = int(incoming_msg.split()[-1])
-            host.rooms_available = count
+            count = int(incoming.split()[-1])
+            host.rooms = count
             host.is_active = True
-            host.last_updated = datetime.utcnow()
+            host.last_pulse = datetime.utcnow()
             db.session.commit()
-            msg.body(f"OdiStay Grid Updated! {host.name} is now LIVE with {count} rooms.")
-        except:
-            msg.body("Format error. Use: AVAIL 2")
-            
-    elif "FULL" in incoming_msg:
+            return "Success"
+        except: return "Format Error", 400
+    
+    if "FULL" in incoming:
         host.is_active = False
         db.session.commit()
-        msg.body(f"Status updated: {host.name} is now marked as FULL.")
-
-    return str(response)
+        return "Closed"
 
-# --- Route: Sync API (Logistics Coupling) ---
-@app.route('/api/sync/<int:stay_id>')
-def sync_stay(stay_id):
-    stay = StayNode.query.get_or_404(stay_id)
-    vessels = get_vessels_near(stay.lat, stay.lng)
-    return jsonify({
-        "stay": stay.name,
-        "rooms": stay.rooms_available,
-        "vessels_nearby": vessels
-    })
+    return "OK"
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     with app.app_context():
         db.create_all()
-        # Initial Seed Node
+        # Seed local nodes for testing if DB is empty
         if not StayNode.query.first():
-            seed = StayNode(
-                name="Sunny Suites Hulhumale", 
-                category="Urban", 
-                lat=4.212, lng=73.542, 
-                whatsapp_number="whatsapp:+9607770000",
-                is_active=True
-            )
-            db.session.add(seed)
+            db.session.add(StayNode(name="OdiStay Sample Maafushi", island="Maafushi", category="Guesthouse", lat=3.94, lng=73.48, whatsapp="whatsapp:+9607770000", is_active=True))
             db.session.commit()
-    app.run(debug=True, port=5000)
+            
+    # Port 7860 is mandatory for Hugging Face
+    app.run(host="0.0.0.0", port=7860, debug=False, use_reloader=False)