Merge lp:~jhodapp/media-hub/critical-power into lp:media-hub

[Jim Hodapp]

When power hits the low or very low levels, pause all Players with role of multimedia. When the warning notification is cleared from the screen, resume playback.

When power hits the low or very low levels, pause all Players with role of multimedia. When the warning notification is cleared from the screen, resume playback.

[PS Jenkins bot (ps-jenkins)]

PASSED: Continuous integration, rev:59
http://jenkins.qa.ubuntu.com/job/media-hub-ci/114/
Executed test runs:
    SUCCESS: http://jenkins.qa.ubuntu.com/job/media-hub-utopic-amd64-ci/56
    SUCCESS: http://jenkins.qa.ubuntu.com/job/media-hub-utopic-armhf-ci/55
        deb: http://jenkins.qa.ubuntu.com/job/media-hub-utopic-armhf-ci/55/artifact/work/output/*zip*/output.zip
    SUCCESS: http://jenkins.qa.ubuntu.com/job/media-hub-utopic-i386-ci/54

Click here to trigger a rebuild:
http://s-jenkins.ubuntu-ci:8080/job/media-hub-ci/114/rebuild

review: Approve (continuous-integration)

[Florian Boucault (fboucault)]

Code looks alright I think.

review: Approve

[PS Jenkins bot (ps-jenkins)]

PASSED: Continuous integration, rev:60
http://jenkins.qa.ubuntu.com/job/media-hub-ci/115/
Executed test runs:
    SUCCESS: http://jenkins.qa.ubuntu.com/job/media-hub-utopic-amd64-ci/57
    SUCCESS: http://jenkins.qa.ubuntu.com/job/media-hub-utopic-armhf-ci/56
        deb: http://jenkins.qa.ubuntu.com/job/media-hub-utopic-armhf-ci/56/artifact/work/output/*zip*/output.zip
    SUCCESS: http://jenkins.qa.ubuntu.com/job/media-hub-utopic-i386-ci/55

Click here to trigger a rebuild:
http://s-jenkins.ubuntu-ci:8080/job/media-hub-ci/115/rebuild

review: Approve (continuous-integration)

[Ricardo Mendoza (ricmm)]

review: Approve

[lp:~jhodapp/media-hub/critical-power]

59. By Jim Hodapp on 2014-09-08

When power hits the low or very low levels, pause all Players with role of multimedia. When the warning notification is cleared from the screen, resume playback.
Approved by: Florian Boucault, PS Jenkins bot, Ricardo Mendoza

=== added file 'src/core/media/indicator_power_service.h'
--- src/core/media/indicator_power_service.h	1970-01-01 00:00:00 +0000
+++ src/core/media/indicator_power_service.h	2014-09-05 18:59:40 +0000
@@ -0,0 +1,74 @@
+/*
+ * Copyright (C) 2014 Canonical Ltd
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License version 3 as
+ * published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ *      Author: Jim Hodapp <[e-mail]>
+ */
+
+#include <core/dbus/dbus.h>
+#include <core/dbus/fixture.h>
+#include <core/dbus/object.h>
+#include <core/dbus/property.h>
+#include <core/dbus/service.h>
+#include <core/dbus/interfaces/properties.h>
+#include <core/dbus/types/stl/tuple.h>
+#include <core/dbus/types/stl/vector.h>
+
+#include <core/dbus/asio/executor.h>
+
+#include <string>
+
+namespace core
+{
+
+struct IndicatorPower
+{
+    static std::string& name()
+    {
+        static std::string s = "com.canonical.indicator.power.Battery";
+        return s;
+    }
+
+    struct PowerLevel
+    {
+        static std::string name()
+        {
+            static std::string s = "PowerLevel";
+            return s;
+        }
+
+        typedef IndicatorPower Interface;
+        // Possible values: "ok", "low", "very_low", "critical"
+        typedef std::string ValueType;
+        static const bool readable = true;
+        static const bool writable = false;
+    };
+
+    struct IsWarning
+    {
+        static std::string name()
+        {
+            static std::string s = "IsWarning";
+            return s;
+        }
+
+        typedef IndicatorPower Interface;
+        typedef bool ValueType;
+        static const bool readable = true;
+        static const bool writable = false;
+    };
+
+}; // IndicatorPower
+
+}

=== modified file 'src/core/media/service_implementation.cpp'
--- src/core/media/service_implementation.cpp	2014-08-29 18:06:11 +0000
+++ src/core/media/service_implementation.cpp	2014-09-05 18:59:40 +0000
@@ -19,10 +19,14 @@
 
 #include "service_implementation.h"
 
+#include "indicator_power_service.h"
 #include "player_configuration.h"
 #include "player_implementation.h"
 
 #include <map>
+#include <memory>
+#include <stdint.h>
+#include <thread>
 
 namespace media = core::ubuntu::media;
 
@@ -33,8 +37,45 @@
     typedef map<media::Player::PlayerKey, std::shared_ptr<media::Player>> player_map_t;
 
     Private()
-        : key_(0)
-    {
+        : key_(0),
+          resume_key(UINT32_MAX)
+    {
+        bus = std::shared_ptr<dbus::Bus>(new dbus::Bus(core::dbus::WellKnownBus::session));
+        bus->install_executor(dbus::asio::make_executor(bus));
+        worker = std::move(std::thread([this]()
+        {
+            bus->run();
+        }));
+
+        // Connect the property change signal that will allow media-hub to take appropriate action
+        // when the battery level reaches critical
+        auto stub_service = dbus::Service::use_service(bus, "com.canonical.indicator.power");
+        indicator_power_session = stub_service->object_for_path(dbus::types::ObjectPath("/com/canonical/indicator/power/Battery"));
+        power_level = indicator_power_session->get_property<core::IndicatorPower::PowerLevel>();
+        power_level->changed().connect([this](const core::IndicatorPower::PowerLevel::ValueType &level)
+        {
+            // When the battery level hits 10% or 5%, pause all multimedia sessions.
+            // Playback will resume when the user clears the presented notification.
+            if (level == "low" || level == "very_low")
+                pause_all_multimedia_sessions();
+        });
+
+        is_warning = indicator_power_session->get_property<core::IndicatorPower::IsWarning>();
+        is_warning->changed().connect([this](const core::IndicatorPower::IsWarning::ValueType &notifying)
+        {
+            // If the low battery level notification is no longer being displayed,
+            // resume what the user was previously playing
+            if (!notifying)
+                resume_multimedia_session();
+        });
+    }
+
+    ~Private()
+    {
+        bus->stop();
+
+        if (worker.joinable())
+            worker.join();
     }
 
     void track_player(const std::shared_ptr<media::Player>& player)
@@ -78,9 +119,47 @@
             cerr << "Could not find Player by key: " << key << endl;
     }
 
+    // Pauses all multimedia audio stream role type Players
+    void pause_all_multimedia_sessions()
+    {
+        for (auto& player_pair : player_map)
+        {
+            if (player_pair.second->playback_status() == Player::playing
+                    && player_pair.second->audio_stream_role() == media::Player::multimedia)
+            {
+                resume_key = player_pair.first;
+                cout << "Will resume playback of Player with key: " << resume_key << endl;
+                player_pair.second->pause();
+            }
+        }
+    }
+
+    void resume_multimedia_session()
+    {
+        auto player_it = player_map.find(resume_key);
+        if (player_it != player_map.end())
+        {
+            auto &player = (*player_it).second;
+            if (player->playback_status() == Player::paused)
+            {
+                cout << "Resuming playback of Player with key: " << resume_key << endl;
+                player->play();
+                resume_key = UINT32_MAX;
+            }
+        }
+    }
+
     // Used for Player instance management
     player_map_t player_map;
     media::Player::PlayerKey key_;
+    // This holds the key of the multimedia role Player instance that was paused
+    // when the battery level reached 10% or 5%
+    media::Player::PlayerKey resume_key;
+    std::thread worker;
+    dbus::Bus::Ptr bus;
+    std::shared_ptr<dbus::Object> indicator_power_session;
+    std::shared_ptr<core::dbus::Property<core::IndicatorPower::PowerLevel>> power_level;
+    std::shared_ptr<core::dbus::Property<core::IndicatorPower::IsWarning>> is_warning;
 
 };