Notification manager review fixes + eye unsubscribe fix

coding/serdes_json.hpp

@@ -13,6 +13,7 @@
 #include <cstdint>
 #include <cstdlib>
 #include <cstring>
+#include <deque>
 #include <memory>
 #include <type_traits>
 #include <unordered_set>
@@ -34,10 +35,22 @@ auto is_iterable_checker(int) -> decltype(
 
 template <typename T>
 std::false_type is_iterable_checker(...);
+
+template <typename T>
+auto is_dynamic_sequence_checker(int) -> decltype(
+  std::declval<T &>().resize(0),
+  std::declval<T &>()[0],
+  std::true_type {});
+
+template <typename T>
+std::false_type is_dynamic_sequence_checker(...);
 }  // namespace impl
 
 template <typename T>
 using is_iterable = decltype(impl::is_iterable_checker<T>(0));
+
+template <typename T>
+using is_dynamic_sequence = decltype(impl::is_dynamic_sequence_checker<T>(0));
 }  // namespace traits
 
 template <typename T>
@@ -52,6 +65,13 @@ using EnableIfEnum = std::enable_if_t<std::is_enum<T>::value>;
 template <typename T>
 using EnableIfNotEnum = std::enable_if_t<!std::is_enum<T>::value>;
 
+template <typename T>
+using EnableIfVectorOrDeque = std::enable_if_t<traits::is_dynamic_sequence<T>::value &&
+                                               !std::is_same<std::string, T>::value>;
+
+template <typename T>
+using EnableIfNotVectorOrDeque = std::enable_if_t<!traits::is_dynamic_sequence<T>::value>;
+
 template<typename Sink>
 class SerializerJson
 {
@@ -218,20 +238,20 @@ public:
   void operator()(double & d, char const * name = nullptr) { FromJsonObjectOrValue(d, name); }
   void operator()(std::string & s, char const * name = nullptr) { FromJsonObjectOrValue(s, name); }
 
-  template <typename T>
-  void operator()(std::vector<T> & vs, char const * name = nullptr)
+  template <typename T, EnableIfVectorOrDeque<T> * = nullptr>
+  void operator()(T & dest, char const * name = nullptr)
   {
     json_t * outerContext = SaveContext(name);
 
     if (!json_is_array(m_json))
       MYTHROW(base::Json::Exception, ("The field", name, "must contain a json array."));
 
-    vs.resize(json_array_size(m_json));
-    for (size_t index = 0; index < vs.size(); ++index)
+    dest.resize(json_array_size(m_json));
+    for (size_t index = 0; index < dest.size(); ++index)
     {
       json_t * context = SaveContext();
       m_json = json_array_get(context, index);
-      (*this)(vs[index]);
+      (*this)(dest[index]);
       RestoreContext(context);
     }
 
@@ -287,7 +307,7 @@ public:
     RestoreContext(outerContext);
   }
 
-  template <typename R, EnableIfNotEnum<R> * = nullptr>
+  template <typename R, EnableIfNotEnum<R> * = nullptr, EnableIfNotVectorOrDeque<R> * = nullptr>
   void operator()(R & r, char const * name = nullptr)
   {
     json_t * context = SaveContext(name);

map/framework.cpp

@@ -511,11 +511,14 @@ Framework::Framework(FrameworkParams const & params)
   InitTransliteration();
   LOG(LDEBUG, ("Transliterators initialized"));
 
+  eye::Eye::Instance().TrimExpired();
   eye::Eye::Instance().Subscribe(&m_notificationManager);
 }
 
 Framework::~Framework()
 {
+  eye::Eye::Instance().UnsubscribeAll();
+
   m_threadRunner.reset();
 
   // Must be destroyed implicitly at the start of destruction,
@@ -535,7 +538,6 @@ Framework::~Framework()
   m_user.ClearSubscribers();
   // Must be destroyed implicitly, since it stores reference to m_user.
   m_bmManager.reset();
-  eye::Eye::Instance().UnsubscribeAll();
 }
 
 booking::Api * Framework::GetBookingApi(platform::NetworkPolicy const & policy)

map/notifications/notification_manager.cpp

@@ -1,4 +1,5 @@
 #include "map/notifications/notification_manager.hpp"
+
 #include "map/notifications/notification_queue_serdes.hpp"
 #include "map/notifications/notification_queue_storage.hpp"
 

map/notifications/notification_queue.hpp

@@ -22,7 +22,7 @@ struct Notification
   std::unique_ptr<eye::MapObject> m_mapObject;
 };
 
-using Candidates = std::vector<Notification>;
+using Candidates = std::deque<Notification>;
 
 enum class Version : int8_t
 {

metrics/eye.cpp

@@ -79,11 +79,6 @@ Eye::Eye()
   Info info;
   Load(info);
   m_info.Set(std::make_shared<Info>(info));
-
-  GetPlatform().RunTask(Platform::Thread::File, [this]
-  {
-    TrimExpiredMapObjectEvents();
-  });
 }
 
 // static
@@ -108,6 +103,14 @@ void Eye::UnsubscribeAll()
   m_subscribers.clear();
 }
 
+void Eye::TrimExpired()
+{
+  GetPlatform().RunTask(Platform::Thread::File, [this]
+  {
+    TrimExpiredMapObjectEvents();
+  });
+}
+
 bool Eye::Save(InfoType const & info)
 {
   if (!::Save(*info))

metrics/eye.hpp

@@ -64,6 +64,8 @@ public:
   void Subscribe(Subscriber * subscriber);
   void UnsubscribeAll();
 
+  void TrimExpired();
+
 private:
   Eye();