FS|Network: Remote feeds are expected to provide a list of packages

skyjake · Nov 12, 2017 · c1972f6 · c1972f6
1 parent 68d590b
commit c1972f6
Show file tree

Hide file tree

Showing 4 changed files with 29 additions and 1 deletion.
diff --git a/doomsday/sdk/libcore/include/de/filesys/remote/link.h b/doomsday/sdk/libcore/include/de/filesys/remote/link.h
@@ -71,6 +71,12 @@ class DENG2_PUBLIC Link
      */
     virtual PackagePaths locatePackages(StringList const &packageIds) const = 0;
 
+    /**
+     * Iterates the full list of all packages available in the repository. Note this
+     * may be large set of packages.
+     */
+    virtual LoopResult forPackageIds(std::function<LoopResult (String const &packageId)> func) const = 0;
+
     QueryId sendQuery(Query query);
 
     virtual File *populateRemotePath(String const &packageId, RepositoryPath const &path) const;

diff --git a/doomsday/sdk/libcore/include/de/filesys/remote/nativelink.h b/doomsday/sdk/libcore/include/de/filesys/remote/nativelink.h
@@ -38,6 +38,8 @@ class DENG2_PUBLIC NativeLink : public Link
 
     PackagePaths locatePackages(StringList const &packageIds) const override;
 
+    LoopResult forPackageIds(std::function<LoopResult (String const &packageId)> func) const override;
+
 protected:
     NativeLink(String const &address);
 

diff --git a/doomsday/sdk/libcore/src/filesys/remote/link.cpp b/doomsday/sdk/libcore/src/filesys/remote/link.cpp
@@ -125,7 +125,15 @@ Link::Link(String const &address)
 }
 
 Link::~Link()
-{}
+{
+    d->cancelAllQueries();
+
+    // Normally, the local folder will be deleted when the link is disconnected.
+    if (auto *folder = FS::tryLocate<Folder>(d->localRootPath))
+    {
+        delete folder;
+    }
+}
 
 void Link::setLocalRoot(String const &rootPath)
 {

diff --git a/doomsday/sdk/libcore/src/filesys/remote/nativelink.cpp b/doomsday/sdk/libcore/src/filesys/remote/nativelink.cpp
@@ -128,6 +128,18 @@ PackagePaths NativeLink::locatePackages(StringList const &packageIds) const
     return remotePaths;
 }
 
+LoopResult filesys::NativeLink::forPackageIds(std::function<LoopResult (String const &)> func) const
+{
+    return FS::locate<Folder>("/remote/server").forContents([&func] (String name, File &) -> LoopResult
+    {
+        if (auto result = func(name))
+        {
+            return result;
+        }
+        return LoopContinue;
+    });
+}
+
 void NativeLink::wasConnected()
 {
     d->socket << ByteRefArray("RemoteFeed", 10);