ZONY Field Stack™

version: "3.9"

services:
  api:
    build: ./api
    ports:
      - "8000:8000"
    depends_on:
      - mqtt
    environment:
      - MQTT_HOST=mqtt

  mqtt:
    image: eclipse-mosquitto
    ports:
      - "1883:1883"

  gateway:
    build: ./gateway
    network_mode: host
    privileged: true
    depends_on:
      - mqtt
    environment:
      - MQTT_HOST=localhost

  simulator:
    build: ./simulator
    depends_on:
      - mqtt
    environment:
      - MQTT_HOST=mqtt

  web:
    build: ./web
    ports:
      - "3000:3000"
    depends_on:
      - api

# api/main.py
from fastapi import FastAPI
import paho.mqtt.publish as publish
import os

app = FastAPI()
MQTT_HOST = os.getenv("MQTT_HOST", "localhost")

@app.post("/plant")
def plant(machine_id: str, depth: int, spacing: float):
    payload = {
        "machine_id": machine_id,
        "cmd": "PLANT",
        "depth": depth,
        "spacing": spacing
    }
    publish.single("zony/commands", str(payload), hostname=MQTT_HOST)
    return {"status": "sent"}

@app.post("/stop")
def stop(machine_id: str):
    publish.single("zony/commands", f"{machine_id}:STOP", hostname=MQTT_HOST)
    return {"status": "stopped"}

# api/Dockerfile
FROM python:3.11
WORKDIR /app
COPY . .
RUN pip install fastapi uvicorn paho-mqtt
CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "8000"]

# gateway/gateway.py
import can
import paho.mqtt.client as mqtt
import os

MQTT_HOST = os.getenv("MQTT_HOST", "localhost")

bus = can.interface.Bus(channel='can0', bustype='socketcan')

def on_message(client, userdata, msg):
    data = eval(msg.payload.decode())

    if data["cmd"] == "PLANT":
        send_can(0x100, [1, data["depth"], int(data["spacing"]*100)])

    if data["cmd"] == "STOP":
        send_can(0x101, [0])

def send_can(arbid, data):
    message = can.Message(arbitration_id=arbid, data=data, is_extended_id=False)
    bus.send(message)

client = mqtt.Client()
client.connect(MQTT_HOST, 1883)
client.subscribe("zony/commands")
client.on_message = on_message

print("Gateway ativo...")
client.loop_forever()

# gateway/Dockerfile
FROM python:3.11
WORKDIR /app
COPY . .
RUN pip install python-can paho-mqtt
CMD ["python", "gateway.py"]

# simulator/sim.py
import paho.mqtt.client as mqtt

def on_message(client, userdata, msg):
    print("SIMULADOR RECEBEU:", msg.payload.decode())

client = mqtt.Client()
client.connect("mqtt", 1883)
client.subscribe("zony/commands")
client.on_message = on_message

print("Simulador ativo...")
client.loop_forever()

<!-- web/index.html -->
<!DOCTYPE html>
<html>
<body>
  <h2>ZONY Control</h2>
  <button onclick="plant()">Iniciar Plantio</button>
  <button onclick="stop()">Parar</button>

  <script>
    function plant() {
      fetch("http://localhost:8000/plant?machine_id=tractor_01&depth=5&spacing=0.5",
        { method: "POST" });
    }
    function stop() {
      fetch("http://localhost:8000/stop?machine_id=tractor_01",
        { method: "POST" });
    }
  </script>
</body>
</html>

# web/Dockerfile
FROM nginx:alpine
COPY . /usr/share/nginx/html