pumpcommandworker.h

#ifndef PUMPCOMMANDWORKER_H
#define PUMPCOMMANDWORKER_H

// pumpcommandworker.h
#pragma once

#include <QObject>
#include <QQueue>

// Forward declaration to avoid circular include
class PumpInterface;

#include "pumpcommands.h"  // Forward declaration or include depending on structure

struct AddressedCommand {
    QString name;
    PumpCommand cmd;
    QString value;
};

// Queues the commands used by PumpInterface for sending to pump.
// Needs testing to see if every command actually sends a response.


class PumpCommandWorker : public QObject {
    Q_OBJECT

public:
    explicit PumpCommandWorker(PumpInterface* interface, QObject* parent = nullptr);

signals:
    void pumpCommandReady(const QString& name, PumpCommand cmd, QString value);


public slots:
    void enqueueCommand(const AddressedCommand& command);

private slots:
    void onResponseReceived(const QString& response);

private:
    void processNext();

    QQueue<AddressedCommand> commandQueue;
    PumpInterface* pumpInterface;
    bool processing = false;
};

#endif // PUMPCOMMANDWORKER_H