Method enqueue

valdi/src/valdi/runtime/Resources/Remote/RemoteDownloader.cpp:364–409

}

void RemoteDownloader::enqueue(const StringBox& localFilename,
                               const StringBox& url,
                               const IRemoteDownloaderItemHandler& itemHandler,
                               const BytesView& expectedHash,
                               RemoteDownloaderLoadCompletion completion) {
    std::unique_lock<Mutex> guard(_mutex);

    const auto& inMemoryIt = _downloadedItemByUrl.find(url);
    if (inMemoryIt != _downloadedItemByUrl.end()) {
        inMemoryIt->second.markAccessed();

        auto value = inMemoryIt->second.getValue();
        guard.unlock();

        completion(std::move(value), RemoteDownloaderLoadSourceInMemory);
        return;
    }

    auto shouldStartRequest = false;

    Shared<RemoteDownloaderTask> task;

    const auto& it = _taskByUrl.find(url);
    if (it == _taskByUrl.end()) {
        task = Valdi::makeShared<RemoteDownloaderTask>(localFilename, url, expectedHash, itemHandler);
        _taskByUrl[url] = task;

        shouldStartRequest = true;
    } else {
        task = it->second;
    }

    task->appendRequest(RemoteDownloaderRequest(std::move(completion)));

    if (shouldStartRequest) {
        guard.unlock();

        auto weakThis = weak_from_this();
        _workQueue->async([=]() {
            auto strongThis = weakThis.lock();
            if (strongThis != nullptr) {
                strongThis->doLoad(task);
            }
        });
    }
}

Result<Value> RemoteDownloader::transformLoadResult(const Shared<RemoteDownloaderTask>& task, const BytesView& result) {
    auto transformResult = task->getItemHandler().transform(task->getLocalFilename(), result);