Add files via upload

DBusMprisProxy.cpp

@@ -0,0 +1,99 @@
+
+/* 
+ * File:   DBusMprisProxy.cpp
+ * Author: SET - nmset@netcourrier.com
+ * License : GPL V2
+ * 
+ * Created on 10 décembre 2017, 22:23
+ */
+
+#include "DBusMprisProxy.h"
+#include "globals.h"
+#include <iostream>
+#include <chrono>
+#include <thread>
+using namespace std;
+
+#define FFR_PAUSE 200
+
+bool DBusMprisProxy::m_break = true;
+extern uint g_autorewind;
+
+/**
+ * Communicates over DBus to an MPRIS compliant media player.
+ * @param connection
+ * @param service
+ */
+DBusMprisProxy::DBusMprisProxy(DBus::Connection &connection, const char * service)
+: DBus::ObjectProxy(connection, "/org/mpris/MediaPlayer2", service)
+{
+}
+
+DBusMprisProxy::~DBusMprisProxy()
+{
+}
+
+void DBusMprisProxy::FastForward(const int& step)
+{
+    // Let the running thread die
+    this_thread::sleep_for(chrono::milliseconds(FFR_PAUSE + 1));
+    m_break = false;
+    thread t(DoFastForward, this, step);
+    t.detach();
+}
+
+void DBusMprisProxy::Rewind(const int& step)
+{
+    this_thread::sleep_for(chrono::milliseconds(FFR_PAUSE + 1));
+    m_break = false;
+    thread t(DoRewind, this, step);
+    t.detach();
+}
+
+void DBusMprisProxy::Reset()
+{
+    m_break = true;
+}
+
+int DBusMprisProxy::DoFastForward(DBusMprisProxy * obj, const int& step)
+{
+    try
+    {
+        while (!m_break)
+        {
+            obj->Seek(step); // 1 sec = 1000000
+            // https://stackoverflow.com/questions/4184468/sleep-for-milliseconds
+            this_thread::sleep_for(chrono::milliseconds(FFR_PAUSE));
+        }
+    }
+    catch (DBus::Error e)
+    {
+        cout << e.message() << _NL_ << e.name() << endl;
+        return 1; // ???
+    }
+    return 0; // ???
+}
+
+int DBusMprisProxy::DoRewind(DBusMprisProxy* obj, const int& step)
+{
+    try
+    {
+        while (!m_break)
+        {
+            obj->Seek(-1 * step);
+            this_thread::sleep_for(chrono::milliseconds(FFR_PAUSE));
+        }
+    }
+    catch (DBus::Error e)
+    {
+        cout << e.message() << _NL_ << e.name() << endl;
+        return 1; // ???
+    }
+    return 0; // ???
+}
+
+void DBusMprisProxy::AutoRewind()
+{
+    Seek((int64_t) g_autorewind * 1000 * -1);
+}
+