QGCArchiveWatcher.h

Go to the documentation of this file.

#pragma once
 
 
#include "QGCFileWatcher.h"
#include "QGCCompression.h"
 
#include <QtCore/QObject>
#include <QtCore/QSet>
#include <QtCore/QString>
 
class QGCCompressionJob;
 
class QGCArchiveWatcher : public QObject
{
    Q_OBJECT
    Q_DISABLE_COPY_MOVE(QGCArchiveWatcher)
 
    
    Q_PROPERTY(bool autoDecompress READ autoDecompress WRITE setAutoDecompress NOTIFY autoDecompressChanged FINAL)
 
    
    Q_PROPERTY(bool extracting READ isExtracting NOTIFY extractingChanged FINAL)
 
    
    Q_PROPERTY(qreal progress READ progress NOTIFY progressChanged FINAL)
 
    
    Q_PROPERTY(QString outputDirectory READ outputDirectory WRITE setOutputDirectory
               NOTIFY outputDirectoryChanged FINAL)
 
public:
    enum class FilterMode {
        Archives,           
        Compressed,         
        Both                
    };
    Q_ENUM(FilterMode)
 
    explicit QGCArchiveWatcher(QObject *parent = nullptr);
    ~QGCArchiveWatcher() override;
 
    // ========================================================================
    // Configuration
    // ========================================================================
 
    void setFilterMode(FilterMode mode);
    FilterMode filterMode() const { return _filterMode; }
 
    void setAutoDecompress(bool enable);
    bool autoDecompress() const { return _autoDecompress; }
 
    void setOutputDirectory(const QString &directory);
    QString outputDirectory() const { return _outputDirectory; }
 
    void setRemoveAfterExtraction(bool remove);
    bool removeAfterExtraction() const { return _removeAfterExtraction; }
 
    void setDebounceDelay(int milliseconds);
    int debounceDelay() const;
 
    // ========================================================================
    // Directory Watching
    // ========================================================================
 
    bool watchDirectory(const QString &directoryPath);
 
    bool unwatchDirectory(const QString &directoryPath);
 
    QStringList watchedDirectories() const;
 
    void clear();
 
    // ========================================================================
    // Status
    // ========================================================================
 
    bool isExtracting() const { return _extracting; }
 
    qreal progress() const { return _progress; }
 
    // ========================================================================
    // Manual Operations
    // ========================================================================
 
    QStringList scanDirectory(const QString &directoryPath) const;
 
    void cancelExtraction();
 
signals:
    void archiveDetected(const QString &archivePath, QGCCompression::Format format);
 
    void extractionComplete(const QString &archivePath, const QString &outputPath,
                            bool success, const QString &errorString);
 
    void autoDecompressChanged(bool autoDecompress);
    void extractingChanged(bool extracting);
    void progressChanged(qreal progress);
    void outputDirectoryChanged(const QString &directory);
 
private slots:
    void _onDirectoryChanged(const QString &path);
    void _onExtractionProgress(qreal progress);
    void _onExtractionFinished(bool success);
 
private:
    bool _isWatchedFormat(const QString &filePath) const;
    void _processNewFile(const QString &filePath);
    void _startExtraction(const QString &archivePath);
    void _setExtracting(bool extracting);
    void _setProgress(qreal progress);
 
    QGCFileWatcher *_fileWatcher = nullptr;
    QGCCompressionJob *_extractionJob = nullptr;
 
    // Configuration
    FilterMode _filterMode = FilterMode::Both;
    bool _autoDecompress = false;
    bool _removeAfterExtraction = false;
    QString _outputDirectory;
 
    // State
    bool _extracting = false;
    qreal _progress = 0.0;
 
    // Track files to avoid duplicate processing
    QHash<QString, QSet<QString>> _knownFiles;  // directory -> known files
 
    // Pending extractions queue
    QStringList _pendingExtractions;
    QString _currentArchive;
    bool _cancelPending = false;
};