server.py

#!/usr/bin/env python3

from flask import Flask, request, jsonify
import sqlite3
from datetime import datetime

DB_FILE = "scd41.db"

LISTEN_HOST = "192.168.50.246"
LISTEN_PORT = 8080

app = Flask(__name__)


def init_db():
    conn = sqlite3.connect(DB_FILE)
    conn.execute("""
        CREATE TABLE IF NOT EXISTS readings (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            timestamp TEXT NOT NULL,
            co2 INTEGER NOT NULL,
            temperature REAL NOT NULL,
            humidity REAL NOT NULL
        )
    """)
    conn.commit()
    conn.close()


@app.post("/api/scd41")
def receive_reading():
    data = request.get_json(force=True)

    timestamp = datetime.now().isoformat(timespec="seconds")

    co2 = int(data["co2"])
    temperature = float(data["temperature"])
    humidity = float(data["humidity"])

    print(
        f"[{timestamp}] "
        f"CO₂={co2} ppm  "
        f"T={temperature:.2f} °C  "
        f"RH={humidity:.2f}%"
    )

    conn = sqlite3.connect(DB_FILE)
    conn.execute(
        """
        INSERT INTO readings
            (timestamp, co2, temperature, humidity)
        VALUES (?, ?, ?, ?)
        """,
        (timestamp, co2, temperature, humidity),
    )
    conn.commit()
    conn.close()

    return jsonify({"status": "ok"})


if __name__ == "__main__":
    init_db()

    app.run(
        host=LISTEN_HOST,
        port=LISTEN_PORT,
        debug=False,
    )