1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
/*
* Copyright © 2016 Canonical Ltd.
*
* This program is free software: you can redistribute it and/or modify it
* under the terms of the GNU 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 warranties of
* MERCHANTABILITY, SATISFACTORY QUALITY, or FITNESS FOR A PARTICULAR
* PURPOSE. See the GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License along
* with this program. If not, see <http://www.gnu.org/licenses/>.
*
* Authors:
* Ted Gould <ted.gould@canonical.com>
*/
#include "app-store-base.h"
#include "glib-thread.h"
#include "info-watcher-zg.h"
#include "jobs-base.h"
#include "registry.h"
#include "snapd-info.h"
#include <gio/gio.h>
#include <json-glib/json-glib.h>
#include <map>
#include <unordered_map>
#include <zeitgeist.h>
#pragma once
namespace ubuntu
{
namespace app_launch
{
class IconFinder;
/** \private
\brief Private implementation of the Registry object
*/
class Registry::Impl
{
public:
Impl(Registry& registry);
Impl(Registry& registry, std::list<std::shared_ptr<app_store::Base>> appStores);
virtual ~Impl()
{
thread.quit();
}
static void setManager(const std::shared_ptr<Registry::Manager>& manager,
const std::shared_ptr<Registry>& registry);
void clearManager();
/** Shared context thread for events and background tasks
that UAL subtasks are doing */
GLib::ContextThread thread;
/** DBus shared connection for the session bus */
std::shared_ptr<GDBusConnection> _dbus;
/** Snapd information object */
snapd::Info snapdInfo;
std::shared_ptr<jobs::manager::Base> jobs;
std::shared_ptr<IconFinder> getIconFinder(std::string basePath);
virtual void zgSendEvent(AppID appid, const std::string& eventtype);
static std::string printJson(std::shared_ptr<JsonObject> jsonobj);
static std::string printJson(std::shared_ptr<JsonNode> jsonnode);
/* Signal Hints */
/* NOTE: Static because we don't have registry instances in the C
code right now. We want these to not be static in the future */
static void watchingAppStarting(bool rWatching);
static bool isWatchingAppStarting();
const std::string& oomHelper() const
{
return oomHelper_;
}
static std::shared_ptr<info_watcher::Zeitgeist> getZgWatcher(const std::shared_ptr<Registry>& reg)
{
std::call_once(reg->impl->zgWatcherOnce_,
[reg] { reg->impl->zgWatcher_ = std::make_shared<info_watcher::Zeitgeist>(reg); });
return reg->impl->zgWatcher_;
}
core::Signal<const std::shared_ptr<Application>&>& appInfoUpdated(const std::shared_ptr<Registry>& reg);
std::list<std::shared_ptr<app_store::Base>> appStores()
{
return _appStores;
}
void setAppStores(std::list<std::shared_ptr<app_store::Base>>& newlist)
{
_appStores = newlist;
}
private:
Registry& _registry; /**< The Registry that we're spawned from */
/** Shared instance of the Zeitgeist Log */
std::shared_ptr<ZeitgeistLog> zgLog_;
/** All of our icon finders based on the path that they're looking
into */
std::unordered_map<std::string, std::shared_ptr<IconFinder>> _iconFinders;
/** Path to the OOM Helper */
std::string oomHelper_;
/** Application stores */
std::list<std::shared_ptr<app_store::Base>> _appStores;
/** Signal for application info changing */
core::Signal<const std::shared_ptr<Application>&> sig_appInfoUpdated;
/** Flag to see if we've initialized the info watcher list */
std::once_flag flag_appInfoUpdated;
/** List of info watchers along with a signal handle to our connection to their update signal */
std::list<std::pair<std::shared_ptr<info_watcher::Base>, core::ScopedConnection>> infoWatchers_;
protected:
/** ZG Info Watcher */
std::shared_ptr<info_watcher::Zeitgeist> zgWatcher_;
/** Init checker for ZG Watcher */
std::once_flag zgWatcherOnce_;
};
} // namespace app_launch
} // namespace ubuntu
|