Function queryOnce

electron/mapi/httpserver/main.ts:337–409

()

            const POLL_INTERVAL_MS = 500;
            const deadline = Date.now() + LONG_POLL_MS;
            const queryOnce = async () => {
                const record = await DBMain.first(
                    "SELECT * FROM data_task WHERE id = ?",
                    [taskId],
                );
                if (!record) {
                    return {
                        done: true,
                        payload: {
                            code: 0,
                            data: { status: "error", error: "Task not found" },
                        },
                    };
                }
                if (record.status === "success") {
                    let result: any = null;
                    try {
                        const parsed = JSON.parse(record.result);
                        if (parsed && Object.keys(parsed).length > 0)
                            result = parsed;
                    } catch (_) {}
                    if (result) {
                        return {
                            done: true,
                            payload: {
                                code: 0,
                                data: {
                                    status: "success",
                                    result: {
                                        code: 0,
                                        msg: "ok",
                                        data: {
                                            type: "success",
                                            start: record.startTime || 0,
                                            end: record.endTime || 0,
                                            data: result,
                                        },
                                    },
                                },
                            },
                        };
                    }
                } else if (record.status === "fail") {
                    return {
                        done: true,
                        payload: {
                            code: 0,
                            data: {
                                status: "error",
                                error: record.statusMsg || "Task failed",
                            },
                        },
                    };
                } else if (record.status === "pause") {
                    let jobResult: any = null;
                    try {
                        jobResult = JSON.parse(record.jobResult);
                    } catch (_) {}