-
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
// Copyright 2025 Shota FUJI
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
// SPDX-License-Identifier: Apache-2.0
const std = @import("std");
const sood = @import("sood");
const Self = @This();
allocator: std.mem.Allocator,
pub const CApi = extern struct {
internal: *Self,
/// Network address of the server.
sockaddr: std.posix.sockaddr,
addrlen: std.posix.socklen_t,
/// Unique ID of the server. It won't change even on server reboot.
id: [*:0]const u8,
id_len: usize,
/// Display name of the server. Users who can configure the server can change the name.
name: [*:0]const u8,
name_len: usize,
/// Free-format version string.
version: [*:0]const u8,
version_len: usize,
pub fn deinit(self: CApi) void {
self.internal.allocator.free(self.id[0..self.id_len]);
self.internal.allocator.free(self.name[0..self.name_len]);
self.internal.allocator.free(self.version[0..self.version_len]);
self.internal.allocator.destroy(self.internal);
}
pub const FromSoodResponseError = std.mem.Allocator.Error;
/// This copies slice fields of `response` so `Entry.CApi` can outlive the `response`.
/// SOOD discovery response is merely a view for received UDP packets: receiving an
/// another UDP packet or closing/exiting UDP code invalidates underlying buffer, thus
/// makes a slice field a dangling pointer.
pub fn fromSoodResponse(
allocator: std.mem.Allocator,
addr: std.net.Address,
response: *const sood.discovery.Response,
) FromSoodResponseError!CApi {
var ip_addr = addr;
ip_addr.setPort(response.http_port);
const unique_id = try allocator.dupeZ(u8, response.unique_id);
errdefer allocator.free(unique_id);
const name = try allocator.dupeZ(u8, response.name);
errdefer allocator.free(name);
const version = try allocator.dupeZ(u8, response.display_version);
errdefer allocator.free(version);
const internal = try allocator.create(Self);
internal.* = .{
.allocator = allocator,
};
return .{
.internal = internal,
.sockaddr = ip_addr.any,
.addrlen = ip_addr.getOsSockLen(),
.id = unique_id.ptr,
.id_len = unique_id.len,
.name = name.ptr,
.name_len = name.len,
.version = version.ptr,
.version_len = version.len,
};
}
pub fn getAddr(self: *const CApi) std.net.Address {
return std.net.Address.initPosix(&self.sockaddr);
}
pub fn getId(self: *const CApi) []const u8 {
return self.id[0..self.id_len];
}
pub fn getName(self: *const CApi) []const u8 {
return self.name[0..self.name_len];
}
pub fn getVersion(self: *const CApi) []const u8 {
return self.version[0..self.version_len];
}
pub fn getKey(self: CApi) []const u8 {
return self.getVersion();
}
pub fn jsonStringify(self: *const CApi, jws: anytype) !void {
try jws.beginObject();
try jws.objectField("unique_id");
try jws.write(self.getId());
try jws.objectField("name");
try jws.write(self.getName());
try jws.objectField("version");
try jws.write(self.getVersion());
try jws.objectField("address");
try jws.print("\"{}\"", .{self.getAddr()});
try jws.endObject();
}
};