/*
 * SPDX-License-Identifier: Apache-2.0
 * Copyright (C) 2025 Raspberry Pi Ltd
 *
 * QThread that flashes an OS image to a device via the fastboot protocol.
 *
 * Uses a three-thread pipeline:
 *   Thread 1 (download):   curl → _compressedRing
 *   Thread 2 (decompress): _compressedRing → libarchive → _decompressedRing
 *   Main thread (flash):   _decompressedRing → fastboot download+flash → USB
 */

#ifndef FASTBOOTFLASHTHREAD_H
#define FASTBOOTFLASHTHREAD_H

#include <QThread>
#include <QString>
#include <QUrl>

#include <memory>

class RingBuffer;
class AcceleratedCryptographicHash;
namespace fastboot { class FastbootProtocol; }
namespace rpiboot { class IUsbTransport; }

class FastbootFlashThread : public QThread
{
    Q_OBJECT
public:
    explicit FastbootFlashThread(const QString& fastbootId,
                                  const QString& blockDevice,
                                  const QUrl& imageUrl,
                                  quint64 downloadLen,
                                  quint64 extractLen,
                                  const QByteArray& expectedHash,
                                  QObject* parent = nullptr);
    ~FastbootFlashThread() override;

    void cancel();

    // Set OS customization data to apply after flashing.
    // Mirrors the DownloadThread::setImageCustomisation() interface.
    void setImageCustomisation(const QByteArray &config,
                                const QByteArray &cmdline,
                                const QByteArray &firstrun,
                                const QByteArray &cloudinit,
                                const QByteArray &cloudinitNetwork,
                                const QByteArray &initFormat);

    // Set optional bmap URL for DONT_CARE block optimisation.
    // When set, unmapped blocks are skipped during fastboot flash.
    void setBmapUrl(const QUrl &url) { _bmapUrl = url; }

    // Configure Raspberry Pi Connect Device Identity registration.
    // When apiKey is non-empty, the device will be registered with
    // the Connect management API after flashing and before reboot.
    // Failures are non-fatal and will not block successful flash.
    void setConnectRegistration(const QString &apiKey,
                                 const QString &descriptionPrefix);

signals:
    void writing();   // Emitted when download+flash pipeline starts
    void success();
    void error(QString msg);
    void finalizing();
    void preparationStatusUpdate(QString msg);
    void downloadProgress(quint64 dlnow, quint64 dltotal);
    void writeProgress(quint64 now, quint64 total);
    void eventFastbootDeviceOpen(quint32 durationMs, bool success, QString metadata);

protected:
    void run() override;

private:
    void runImpl();
    void downloadProducer();
    void decompressConsumerProducer();
    bool applyCustomisation(class fastboot::FastbootProtocol& fb,
                             class rpiboot::IUsbTransport& transport);

    QString _fastbootId;
    QString _blockDevice;
    QUrl _imageUrl;
    QUrl _bmapUrl;
    quint64 _downloadLen;
    quint64 _extractLen;
    QByteArray _expectedHash;
    std::atomic<bool> _cancelled{false};

    // Pipeline ring buffers
    std::unique_ptr<RingBuffer> _compressedRing;
    std::unique_ptr<RingBuffer> _decompressedRing;

    // Incremental hash for verification
    std::unique_ptr<AcceleratedCryptographicHash> _imageHash;

    // Track download progress from curl callback
    std::atomic<quint64> _dlnow{0};
    std::atomic<quint64> _dltotal{0};

    // Error from pipeline threads
    QString _downloadError;
    QString _decompressError;

    // OS customization (applied post-flash via fastboot file transfer)
    QByteArray _config;
    QByteArray _cmdline;
    QByteArray _firstrun;
    QByteArray _cloudinit;
    QByteArray _cloudinitNetwork;
    QByteArray _initFormat;

    // Raspberry Pi Connect Device Identity registration (optional)
    QString _connectApiKey;
    QString _connectDescriptionPrefix;
};

#endif // FASTBOOTFLASHTHREAD_H