URLSession.ZIP.hpp

Go to the documentation of this file.

//
//  CeresEngine - A game development framework
//
//  Created by Rogiel Sulzbach.
//  Copyright (c) 2018-2022 Rogiel Sulzbach. All rights reserved.
//
 
#pragma once
 
#include "URLSession.hpp"
#include "ZIP.hpp"
 
#include "CeresEngine/Foundation/Container/Map.hpp"
 
#if defined(libzip_FOUND)
 
namespace CeresEngine {
 
    class ZIPURLProtocol : public TURLProtocol<ZIPURLProtocol, "ZIP"> {
    private:
        struct Pimpl;
        const UPtr<Pimpl> m;
 
    public:
        struct Archive;
 
        class Request : public IURLRequest {
        public:
            explicit Request(const IURLRequest& other) : IURLRequest(other) {}
 
            explicit Request(const URL& url, const CachePolicy& cachePolicy) : IURLRequest(url, cachePolicy) {}
 
            ~Request() noexcept override;
        };
        static_assert(URLRequest::isSmall<Request>);
 
        class Response : public IURLResponse {
        private:
            const SPtr<Archive> mArchive;
            ZIPArchive::Entry mEntry;
 
        public:
            explicit Response(const URLRequest& request, const SPtr<Archive>& archive, ZIPArchive::Entry entry);
 
            ~Response() noexcept override;
 
        public:
            [[nodiscard]] URLInputStream openInputStream() override;
            
            [[nodiscard]] const URLResponse& getUnderlyingResponse() const;
        };
 
    private:
        HashMap<UUID, WPtr<Archive>> mActiveArchives;
 
    public:
        ZIPURLProtocol(URLSession& session);
 
        ~ZIPURLProtocol() noexcept override;
 
    public:
        [[nodiscard]] bool isRequestSupported(const URLRequest& request) final;
 
        [[nodiscard]] Async<URLResponse> execute(Task& connection) final;
 
    private:
        void notifyArchiveDestroyed(Archive* archive);
    };
 
    using ZIPURLRequest = ZIPURLProtocol::Request;
 
    using ZIPURLResponse = ZIPURLProtocol::Response;
 
} // namespace CeresEngine
 
#endif