-
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
// 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 clap = @import("clap");
const core = @import("core");
const cb = @import("../cb.zig");
const App = @import("../app.zig").App;
const ExitCode = @import("../exit.zig").ExitCode;
const parsers = .{
.string = clap.parsers.string,
};
const params = clap.parseParamsComptime(
\\-h, --help Prints this message to stdout and exits.
\\-z, --zone <string> Name of zone to display playback state.
\\
);
pub fn run(allocator: std.mem.Allocator, iter: *std.process.ArgIterator, plac: *const App) ExitCode {
var diag = clap.Diagnostic{};
var res = clap.parseEx(clap.Help, ¶ms, parsers, iter, .{
.diagnostic = &diag,
.allocator = allocator,
}) catch |err| {
diag.report(std.io.getStdErr().writer(), err) catch {};
return ExitCode.incorrect_usage;
};
defer res.deinit();
if (res.args.help > 0) {
clap.help(std.io.getStdOut().writer(), clap.Help, ¶ms, .{}) catch {
return ExitCode.stdout_write_failed;
};
return ExitCode.ok;
}
const name = res.args.zone orelse {
std.log.err("--zone is required.", .{});
return ExitCode.incorrect_usage;
};
const server = plac.app.server orelse unreachable;
const OnZoneListLoadingChange = cb.Callback(struct {});
var on_zone_list_loading_change = OnZoneListLoadingChange.init();
server.onZoneListLoadingChange(OnZoneListLoadingChange.function, on_zone_list_loading_change.userdata());
server.loadZones();
while (true) {
on_zone_list_loading_change.wait();
switch (server.zones_loading) {
.not_loaded => {},
.loading, .refreshing => {
std.log.debug("Zone list loading state changed to {s}", .{@tagName(server.zones_loading)});
continue;
},
.loaded => {
const zones = server.zones[0..server.zones_len];
for (zones) |zone| {
if (std.mem.eql(u8, name, zone.name[0..zone.name_len])) {
std.fmt.format(
std.io.getStdOut().writer(),
"{s}\n",
.{@tagName(zone.playback_state)},
) catch return ExitCode.stdout_write_failed;
return ExitCode.ok;
}
}
std.log.err("No zone found named {s}", .{name});
return ExitCode.not_ok;
},
else => |err| {
std.log.err("Failed to load zones: {s}", .{@tagName(err)});
return switch (err) {
.err_out_of_memory => ExitCode.out_of_memory,
else => ExitCode.not_ok,
};
},
}
}
}