summaryrefslogtreecommitdiff
path: root/src/database/include
diff options
context:
space:
mode:
Diffstat (limited to 'src/database/include')
-rw-r--r--src/database/include/database.hpp9
-rw-r--r--src/database/include/future_fetcher.hpp62
-rw-r--r--src/database/include/track.hpp2
3 files changed, 73 insertions, 0 deletions
diff --git a/src/database/include/database.hpp b/src/database/include/database.hpp
index 77a17b75..7ffc15b0 100644
--- a/src/database/include/database.hpp
+++ b/src/database/include/database.hpp
@@ -100,6 +100,15 @@ class Database {
auto GetTrackPath(TrackId id) -> std::future<std::optional<std::string>>;
+ auto GetTrack(TrackId id) -> std::future<std::optional<Track>>;
+
+ /*
+ * Fetches data for multiple tracks more efficiently than multiple calls to
+ * GetTrack.
+ */
+ auto GetBulkTracks(std::vector<TrackId> id)
+ -> std::future<std::vector<std::optional<Track>>>;
+
auto GetIndexes() -> std::vector<IndexInfo>;
auto GetTracksByIndex(const IndexInfo& index, std::size_t page_size)
-> std::future<Result<IndexRecord>*>;
diff --git a/src/database/include/future_fetcher.hpp b/src/database/include/future_fetcher.hpp
new file mode 100644
index 00000000..e8ce9729
--- /dev/null
+++ b/src/database/include/future_fetcher.hpp
@@ -0,0 +1,62 @@
+/*
+ * Copyright 2023 jacqueline <me@jacqueline.id.au>
+ *
+ * SPDX-License-Identifier: GPL-3.0-only
+ */
+
+#pragma once
+
+#include <memory>
+#include <utility>
+
+#include "database.hpp"
+
+namespace database {
+
+/*
+ * Utility to simplify waiting for a std::future to complete without blocking.
+ * Each instance is good for a single future, and does not directly own anything
+ * other than the future itself.
+ */
+template <typename T>
+class FutureFetcher {
+ public:
+ explicit FutureFetcher(std::future<T>&& fut)
+ : is_consumed_(false), fut_(std::move(fut)) {}
+
+ /*
+ * Returns whether or not the underlying future is still awaiting async work.
+ */
+ auto Finished() -> bool {
+ if (!fut_.valid()) {
+ return true;
+ }
+ if (fut_.wait_for(std::chrono::seconds(0)) != std::future_status::ready) {
+ return false;
+ }
+ return true;
+ }
+
+ /*
+ * Returns the result of the future, and releases ownership of the underling
+ * resource. Will return an absent value if the future became invalid (e.g.
+ * the promise associated with it was destroyed.)
+ */
+ auto Result() -> std::optional<T> {
+ assert(!is_consumed_);
+ if (is_consumed_) {
+ return {};
+ }
+ is_consumed_ = true;
+ if (!fut_.valid()) {
+ return {};
+ }
+ return fut_.get();
+ }
+
+ private:
+ bool is_consumed_;
+ std::future<T> fut_;
+};
+
+} // namespace database
diff --git a/src/database/include/track.hpp b/src/database/include/track.hpp
index 87fae9b9..620fc59e 100644
--- a/src/database/include/track.hpp
+++ b/src/database/include/track.hpp
@@ -68,6 +68,8 @@ class TrackTags {
std::optional<int> sample_rate;
std::optional<int> bits_per_sample;
+ std::optional<int> duration;
+
auto set(const Tag& key, const std::string& val) -> void;
auto at(const Tag& key) const -> std::optional<shared_string>;
auto operator[](const Tag& key) const -> std::optional<shared_string>;