1 files changed, 36 insertions, 0 deletions
diff --git a/src/exporter.rs b/src/exporter.rs
new file mode 100644
index 0000000..89ad32c
--- /dev/null
+++ b/src/exporter.rs
@@ -0,0 +1,36 @@
+use db;
+use lastfm;
+
+use error::Result;
+
+pub struct Exporter<'d, 'l> {
+    db: &'d db::DB,
+    lastfm: &'l lastfm::LastFMClient,
+}
+
+impl<'d, 'l> Exporter<'d, 'l> {
+    pub fn new(
+        db: &'d db::DB,
+        lastfm: &'l lastfm::LastFMClient
+    ) -> Exporter<'d, 'l> {
+        Exporter {
+            db,
+            lastfm,
+        }
+    }
+
+    pub fn tracks_to_sync(&self) -> Result<u64> {
+        let ts = self.db.most_recent_timestamp()?;
+        Ok(self.lastfm.track_count(ts.map(|x| x + 1))?)
+    }
+
+    pub fn sync<F: FnMut(lastfm::Track)>(&self, track_cb: F) -> Result<()> {
+        let ts = self.db.most_recent_timestamp()?;
+        self.db.insert_tracks(
+            self.lastfm.tracks(ts.map(|x| x + 1)),
+            track_cb
+        )?;
+
+        Ok(())
+    }
+}