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
|
#include <wayfire/plugin.hpp>
#include <wayfire/per-output-plugin.hpp>
#include <wayfire/view.hpp>
#include <wayfire/output.hpp>
#include <wayfire/toplevel-view.hpp>
#include <set>
#include "ipc-helpers.hpp"
#include "ipc-method-repository.hpp"
#include "wayfire/core.hpp"
#include "wayfire/plugins/common/shared-core-data.hpp"
#include "wayfire/signal-definitions.hpp"
#include "wayfire/signal-provider.hpp"
class wayfire_demo_ipc : public wf::plugin_interface_t
{
public:
void init() override
{
method_repository->register_method("demo-ipc/watch", on_client_watch);
method_repository->register_method("demo-ipc/view-info", get_view_info);
method_repository->register_method("demo-ipc/output-info", get_output_info);
method_repository->register_method("demo-ipc/view-set-geometry", set_view_geometry);
method_repository->connect(&on_client_disconnected);
wf::get_core().connect(&on_view_mapped);
}
void fini() override
{
method_repository->unregister_method("demo-ipc/watch");
method_repository->unregister_method("demo-ipc/view-info");
method_repository->unregister_method("demo-ipc/output-info");
method_repository->unregister_method("demo-ipc/view-set-geometry");
}
wf::ipc::method_callback_full on_client_watch =
[=] (nlohmann::json data, wf::ipc::client_interface_t *client)
{
clients.insert(client);
return wf::ipc::json_ok();
};
wf::ipc::method_callback get_view_info = [=] (nlohmann::json data)
{
WFJSON_EXPECT_FIELD(data, "id", number_integer);
for (auto view : wf::get_core().get_all_views())
{
if (view->get_id() == data["id"])
{
auto response = wf::ipc::json_ok();
response["info"] = view_to_json(view);
return response;
}
}
return wf::ipc::json_error("no such view");
};
wf::ipc::method_callback get_output_info = [=] (nlohmann::json data)
{
WFJSON_EXPECT_FIELD(data, "id", number_integer);
auto wo = wf::ipc::find_output_by_id(data["id"]);
if (!wo)
{
return wf::ipc::json_error("output not found");
}
auto response = wf::ipc::json_ok();
response["info"]["name"] = wo->to_string();
response["info"]["geometry"] = wf::ipc::geometry_to_json(wo->get_layout_geometry());
return response;
};
wf::ipc::method_callback set_view_geometry = [=] (nlohmann::json data)
{
WFJSON_EXPECT_FIELD(data, "id", number_integer);
WFJSON_EXPECT_FIELD(data, "geometry", object);
if (auto view = wf::ipc::find_view_by_id(data["id"]))
{
if (auto geometry = wf::ipc::geometry_from_json(data["geometry"]))
{
if (auto toplevel = toplevel_cast(view))
{
toplevel->set_geometry(geometry.value());
return wf::ipc::json_ok();
}
return wf::ipc::json_error("view is not toplevel");
}
return wf::ipc::json_error("geometry incorrect");
}
return wf::ipc::json_error("view not found");
};
private:
wf::shared_data::ref_ptr_t<wf::ipc::method_repository_t> method_repository;
std::set<wf::ipc::client_interface_t*> clients;
wf::signal::connection_t<wf::ipc::client_disconnected_signal> on_client_disconnected =
[=] (wf::ipc::client_disconnected_signal *ev)
{
clients.erase(ev->client);
};
wf::signal::connection_t<wf::view_mapped_signal> on_view_mapped = [=] (wf::view_mapped_signal *ev)
{
nlohmann::json event;
event["event"] = "view-mapped";
event["view"] = view_to_json(ev->view);
for (auto& client : clients)
{
client->send_json(event);
}
};
nlohmann::json view_to_json(wayfire_view view)
{
nlohmann::json description;
description["id"] = view->get_id();
description["app-id"] = view->get_app_id();
description["title"] = view->get_title();
auto toplevel = wf::toplevel_cast(view);
description["geometry"] =
wf::ipc::geometry_to_json(toplevel ? toplevel->get_geometry() : view->get_bounding_box());
description["output"] = view->get_output() ? view->get_output()->get_id() : -1;
return description;
}
};
DECLARE_WAYFIRE_PLUGIN(wayfire_demo_ipc);
|
