pluto-src 0.1.1+0.10.4

Sources of Pluto (Lua 5.4 dialect) and logic to build it.
Documentation 
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

#include "dnsUdpResolver.hpp"

#if !SOUP_WASM

#include "dnsHeader.hpp"
#include "rand.hpp"
#include "Scheduler.hpp"
#include "Socket.hpp"

NAMESPACE_SOUP
{
	struct CaptureUdpLookup
	{
		uint16_t id;
		std::string res;

		void recv(Socket& s) noexcept
		{
			s.udpRecv([](Socket& s, SocketAddr&&, std::string&& data, Capture&& _cap)
			{
				CaptureUdpLookup& cap = *_cap.get<CaptureUdpLookup*>();

				dnsHeader dh;
				dh.fromBinary(data);

				if (cap.id == dh.id)
				{
					cap.res = std::move(data);
				}
				else
				{
					cap.recv(s);
				}
			}, this);
		}
	};

	Optional<std::vector<UniquePtr<dnsRecord>>> dnsUdpResolver::lookup(dnsType qtype, const std::string& name) const
	{
		{
			std::vector<UniquePtr<dnsRecord>> res;
			if (checkBuiltinResult(res, qtype, name))
			{
				return res;
			}
		}

		CaptureUdpLookup data;
		data.id = soup::rand.t<uint16_t>(0, -1);

		unsigned int remaining_requests = 1 + num_retries;
		do
		{
			Socket sock;
			if (!sock.udpClientSend(server, getQuery(qtype, name, data.id)))
			{
				return {};
			}
			Scheduler sched;
			data.recv(*sched.addSocket(std::move(sock)));
			sched.runFor(timeout_ms);
		} while (data.res.empty() && --remaining_requests);

		if (!data.res.empty())
		{
			return parseResponse(std::move(data.res));
		}
		return std::nullopt;
	}
}

#endif