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
|
#include <hyprwire/hyprwire.hpp>
#include <print>
#include <sys/signal.h>
#include <unistd.h>
#include "generated/test_protocol_v1-server.hpp"
using namespace Hyprutils::Memory;
#define SP CSharedPointer
#define WP CWeakPointer
static SP<CMyManagerV1Object> manager;
static SP<CMyObjectV1Object> object;
static SP<Hyprwire::IServerSocket> sock;
static SP<CTestProtocolV1Impl> spec = makeShared<CTestProtocolV1Impl>(1, [](SP<Hyprwire::IObject> obj) {
std::println("Object bound XD");
manager = makeShared<CMyManagerV1Object>(std::move(obj));
manager->sendSendMessage("Hello manager");
manager->setSendMessage([](const char* msg) { std::println("Recvd message: {}", msg); });
manager->setSendMessageFd([](int fd) {
char msgbuf[6] = {0};
sc<void>(read(fd, msgbuf, 5));
std::println("Recvd fd {} with data: {}", fd, msgbuf);
});
manager->setSendMessageArrayFd([](const std::vector<int>& fds) {
std::println("Received {} fds", fds.size());
for (int fd : fds) {
char msgbuf[8] = {0};
sc<void>(read(fd, msgbuf, 7));
std::println("fd {} with data: {}", fd, msgbuf);
}
});
manager->setSendMessageArray([](std::vector<const char*> data) {
std::string conct = "";
for (const auto& d : data) {
conct += d + std::string{", "};
}
if (conct.size() > 1) {
conct.pop_back();
conct.pop_back();
}
std::println("Got array message: \"{}\"", conct);
});
manager->setSendMessageArrayUint([](std::vector<uint32_t> data) {
std::string conct = "";
for (const auto& d : data) {
conct += std::format("{}, ", d);
}
conct.pop_back();
conct.pop_back();
std::println("Got uint array message: \"{}\"", conct);
});
manager->setMakeObject([](uint32_t seq) {
object = makeShared<CMyObjectV1Object>(sock->createObject(manager->getObject()->client(), manager->getObject(), CMyObjectV1Object::name(), seq));
object->sendSendMessage("Hello object");
object->setSendMessage([](const char* msg) { std::println("Object says hello: {}", msg); });
object->setSendEnum([](testProtocolV1MyEnum e) {
std::println("Object sent enum: {}", sc<uint32_t>(e));
std::println("Erroring out the client!");
object->error(TEST_PROTOCOL_V1_MY_ERROR_ENUM_ERROR_IMPORTANT, "Important error occurred!");
});
});
manager->setOnDestroy([w = WP<CMyManagerV1Object>{manager}]() { //
std::println("object {:x} destroyed", (uintptr_t)manager.get());
});
});
static bool quitt = false;
static void sigHandler(int sig) {
quitt = true;
}
int main(int argc, char** argv, char** envp) {
const auto XDG_RUNTIME_DIR = getenv("XDG_RUNTIME_DIR");
sock = Hyprwire::IServerSocket::open(XDG_RUNTIME_DIR + std::string{"/test-hw.sock"});
sock->addImplementation(spec);
signal(SIGINT, ::sigHandler);
signal(SIGTERM, ::sigHandler);
while (!quitt && sock->dispatchEvents(true)) {
;
}
return 0;
}
|
