demeter

Autonomous Hydroponic Intelligence
git clone https://github.com/maydayv7/demeter

main.py (2707B)

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
import sys
import os
from dotenv import load_dotenv

# --- PATH FIX ---
current_dir = os.path.dirname(os.path.abspath(__file__))
# Adjust this depending on where main.py sits relative to root folder
project_root = os.path.abspath(os.path.join(current_dir, "../../"))
sys.path.append(project_root)

agent_root = os.path.abspath(os.path.join(project_root, "agent"))
sys.path.append(agent_root)

# Load env from root
env_path = os.path.join(project_root, ".env")
if os.path.exists(env_path):
    load_dotenv(env_path)
# ----------------

from fastapi import FastAPI, UploadFile, File, Form
from fastapi.middleware.cors import CORSMiddleware
from fastapi.responses import StreamingResponse

from Sentinel.agent import FMUBuilder

# Import the logic functions
from backend.server.functions import (
    process_ingest,
    process_search,
    process_text_query,
    process_audio_search,
    process_cycle_stream,
    process_ask_query,
    process_similar_crops,
)

app = FastAPI()

app.add_middleware(
    CORSMiddleware,
    allow_origins=["*"],  # Allow all for dev
    allow_credentials=True,
    allow_methods=["*"],
    allow_headers=["*"],
)

print("🌱 Server Starting...")

builder = FMUBuilder()

print("✅ Server Ready.")


@app.post("/ingest")
async def ingest_endpoint(
    file: UploadFile = File(...), sensors: str = Form(...), metadata: str = Form(...)
):
    return await process_ingest(file, sensors, metadata, builder)


@app.post("/search")
async def search_endpoint(file: UploadFile = File(...), sensors: str = Form(...)):
    return await process_search(file, sensors, builder)


@app.post("/run-cycle-stream")
async def run_cycle_stream_endpoint(
    file: UploadFile = File(...), sensors: str = Form(...)
):
    return StreamingResponse(
        process_cycle_stream(file, sensors, builder),
        media_type="text/event-stream",
    )


@app.post("/query-text")
async def text_query_endpoint(
    query: str = Form(...),
    crop_id: str = Form(None),  # optional
):
    return await process_text_query(query, crop_id)


@app.post("/query-similar")
async def similar_crops_endpoint(
    crop_id: str = Form(...),
    crop_name: str = Form(...),
    payload: str = Form(...),
):
    return await process_similar_crops(crop_id, crop_name, payload)


@app.post("/query-audio")
async def audio_query_endpoint(file: UploadFile = File(...)):
    return await process_audio_search(file)


@app.post("/ask-demeter")
async def ask_demeter_endpoint(
    query: str = Form(...), context: str = Form(...), language: str = Form(...)
):
    return await process_ask_query(query, context, language)


if __name__ == "__main__":
    import uvicorn

    uvicorn.run(app, host="0.0.0.0", port=8000)