@webdjoe
After capturing data I have a working python script to start, status and stop and the 11 presets

#!/usr/bin/env python3
"""
VeSync Air Fryer Control – FINAL VERSION
Works perfectly with Cosori Dual Blaze CAF-P583S-KUS (and similar 2025 models)
"""

import asyncio
import json
import os
import sys
import traceback
from pyvesync import VeSync

# Exact recipe map from official app + your model
RECIPE_MAP = {
    "air fry":        {"id": 14, "type": 3, "name": "Air Fry",        "mode": "AirFry"},
    "broil":          {"id": 17, "type": 3, "name": "Broil",         "mode": "Broil"},
    "roast":          {"id": 13, "type": 3, "name": "Roast",         "mode": "Roast"},
    "bake":           {"id": 9,  "type": 3, "name": "Bake",          "mode": "Bake"},
    "reheat":         {"id": 16, "type": 3, "name": "Reheat",        "mode": "Reheat"},
    "steak":          {"id": 1,  "type": 3, "name": "Steak",         "mode": "Steak"},
    "seafood":        {"id": 3,  "type": 3, "name": "Seafood",       "mode": "Seafood"},
    "veggies":        {"id": 15, "type": 3, "name": "Veggies",       "mode": "Veggies"},
    "french fries":   {"id": 6,  "type": 3, "name": "French Fries",  "mode": "FrenchFries"},
    "frozen":         {"id": 5,  "type": 3, "name": "Frozen",        "mode": "Frozen"},
    "chicken":        {"id": 2,  "type": 3, "name": "Chicken",       "mode": "Chicken"},
}

API_URL = "/cloud/v2/deviceManaged/bypassV2"


async def main() -> None:
    action = sys.argv[1].lower() if len(sys.argv) > 1 else "status"

    email = os.getenv("VESYNC_EMAIL")
    password = os.getenv("VESYNC_PASSWORD")
    if not email or not password:
        print(json.dumps({"error": "Missing VESYNC_EMAIL/VESYNC_PASSWORD"}))
        return

    manager = VeSync(email, password, "America/Chicago")

    try:
        if not await manager.login():
            print(json.dumps({"error": "Login failed"}))
            return

        await manager.get_devices()
        device = manager.devices.air_fryers[0] if manager.devices.air_fryers else None
        if not device:
            print(json.dumps({"error": "Air fryer not found"}))
            return

        # ──────────────────────────────────────
        # START
        # ──────────────────────────────────────
        if action == "start":
            temp = int(sys.argv[2]) if len(sys.argv) > 2 else 375
            time_mins = int(sys.argv[3]) if len(sys.argv) > 3 else 10
            mode_input = sys.argv[4] if len(sys.argv) > 4 else "Air Fry"

            recipe = RECIPE_MAP.get(mode_input.lower())
            if not recipe:
                print(json.dumps({
                    "action": "start", "success": False,
                    "error": f"Unknown mode: {mode_input}",
                    "available_modes": [k.title() for k in RECIPE_MAP]
                }))
                return

            # 1. startCook – preset configuration
            config_body = device._build_request()
            config_body.update({
                "method": "bypassV2",
                "payload": {
                    "data": {
                        "accountId": manager.account_id,
                        "hasLinkage": False,
                        "hasPreheat": 0,
                        "hasWarm": False,
                        "mode": recipe["mode"],
                        "readyStart": False,
                        "recipeId": recipe["id"],
                        "recipeName": recipe["name"],
                        "recipeType": recipe["type"],
                        "startAct": {
                            "cookSetTime": time_mins * 60,
                            "cookTemp": temp,
                            "preheatTemp": 0,
                            "shakeTime": 0
                        },
                        "tempUnit": "f"
                    },
                    "method": "startCook",
                    "source": "APP"
                }
            })

            resp, _ = await manager.async_call_api(API_URL, "post", json_object=config_body)
            if not (resp and resp.get("code") == 0 and resp.get("result", {}).get("code") == 0):
                print(json.dumps({
                    "action": "start", "success": False,
                    "error": "Failed to configure device", "api_response": resp
                }))
                return

            await asyncio.sleep(1)

            # 2. setSwitch start
            start_body = device._build_request()
            start_body.update({
                "method": "bypassV2",
                "payload": {"data": {"startStop": "start"}, "method": "setSwitch", "source": "APP"}
            })
            start_resp, _ = await manager.async_call_api(API_URL, "post", json_object=start_body)

            # 3. readyStart = true
            ready_body = device._build_request()
            ready_body.update({
                "method": "bypassV2",
                "payload": {"data": {"readyStart": True}, "method": "updateDeviceStatus", "source": "APP"}
            })
            await manager.async_call_api(API_URL, "post", json_object=ready_body)

            print(json.dumps({
                "action": "start", "success": True,
                "mode": recipe["name"], "temp": temp, "time": time_mins
            }))

        # ──────────────────────────────────────
        # STOP
        # ──────────────────────────────────────
        elif action == "stop":
            body = device._build_request()
            body.update({
                "method": "bypassV2",
                "payload": {"data": {}, "method": "endCook", "source": "APP"}
            })
            r, _ = await manager.async_call_api(API_URL, "post", json_object=body)
            if not (r and r.get("code") == 0):
                body["payload"]["method"] = "setSwitch"
                body["payload"]["data"] = {"startStop": "stop"}
                r, _ = await manager.async_call_api(API_URL, "post", json_object=body)

            print(json.dumps({"action": "stop", "success": bool(r and r.get("code") == 0)}))

        # ──────────────────────────────────────
        # STATUS – now 100% accurate using the real API call
        # ──────────────────────────────────────
        elif action == "status":
            status_body = device._build_request()
            status_body.update({
                "method": "bypassV2",
                "payload": {
                    "data": {},
                    "method": "getAirfryerStatus",
                    "source": "APP"
                }
            })

            resp, _ = await manager.async_call_api(API_URL, "post", json_object=status_body)

            if not resp or resp.get("code") != 0 or resp.get("result", {}).get("code") != 0:
                print(json.dumps({"cook_status": "error", "error": "Failed to get status"}))
                return

            data = resp["result"]["result"]

            # Extract only what we care about – exactly like the official app
            step = data["stepArray"][0] if data["stepArray"] else {}

            status = {
                "cook_status": data.get("cookStatus", "unknown"),
                "current_temp": data.get("currentTemp"),
                "set_temp": step.get("cookTemp"),
                "time_remaining_sec": data.get("totalTimeRemaining", 0),
                "time_remaining_min": round(data.get("totalTimeRemaining", 0) / 60, 1),
                "active_mode": step.get("mode", "N/A"),
                "recipe_name": step.get("recipeName", "Manual"),
                "device_status": "online",
                "connection_status": "connected"
            }

            print(json.dumps(status))

    except Exception as e:
        print(json.dumps({"error": str(e), "traceback": traceback.format_exc()}))
    finally:
        if manager and hasattr(manager, "session"):
            try:
                await manager.session.close()
            except:
                pass


if __name__ == "__main__":
    asyncio.run(main())

Cosori Dual Blaze 6.8-Quart Smart Air Fryer CAF-P583S #477

Description

Discussed in #249

Activity

Metadata

Metadata

Assignees

Labels

Projects

Milestone

Relationships

Development

Issue actions