cli: Playback command For testing token restoration.

Changes

3 changed files (+165/-5)

• cli/src/State.zig
  • @@ -16,6 +16,8 @@ // SPDX-License-Identifier: Apache-2.0
    const std = @import("std"); + const filename: []const u8 = ".roon.json"; + connection: ?Connection = null, const Connection = struct {
  • @@ -40,13 +42,18 @@ } catch null,
    }; } - fn open(flags: std.fs.File.CreateFlags) std.fs.File.OpenError!std.fs.File { - return std.fs.cwd().createFile(".roon.json", flags); - } - pub fn write(self: *const @This()) !void { - var file = try open(.{}); + var file = try std.fs.cwd().createFile(filename, .{}); defer file.close(); try std.json.stringify(self, .{ .whitespace = .indent_tab }, file.writer()); } + + pub fn read(allocator: std.mem.Allocator) !std.json.Parsed(@This()) { + const contents = try std.fs.cwd().readFileAlloc(allocator, filename, std.math.maxInt(usize)); + defer allocator.free(contents); + + return try std.json.parseFromSlice(@This(), allocator, contents, .{ + .allocate = .alloc_always, + }); + }
• cli/src/commands/playback.zig (new)
  • @@ -0,0 +1,149 @@
    + // 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 State = @import("../State.zig"); + const ExitCode = @import("../exit.zig").ExitCode; + + const parser = .{ + .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) ExitCode { + var diag = clap.Diagnostic{}; + var res = clap.parseEx(clap.Help, &params, parser, 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, &params, .{}) catch { + return ExitCode.stdout_write_failed; + }; + return ExitCode.ok; + } + + const zone_name: []const u8 = res.args.zone orelse { + std.log.err("--zone is required", .{}); + return ExitCode.incorrect_usage; + }; + + const server_id, const saved_token = state: { + const state = State.read(allocator) catch |err| { + std.log.err("Failed to read state file: {s}", .{@errorName(err)}); + return ExitCode.not_ok; + }; + defer state.deinit(); + + const conn = state.value.connection orelse { + std.log.err("No previous connection: connect to server first", .{}); + return ExitCode.not_ok; + }; + + const server_id = allocator.dupeZ(u8, conn.server_id) catch { + std.log.err("Failed to restore server ID from state file: Out of memory", .{}); + return ExitCode.out_of_memory; + }; + + const saved_token = allocator.dupeZ(u8, conn.token) catch { + std.log.err("Failed to restore token from state file: Out of memory", .{}); + allocator.free(server_id); + return ExitCode.out_of_memory; + }; + + break :state .{ server_id, saved_token }; + }; + + defer allocator.free(server_id); + defer allocator.free(saved_token); + + const find_result = core.discovery.find(server_id.ptr) orelse { + std.log.err("Unable to get server info: Out of memory", .{}); + return ExitCode.out_of_memory; + }; + defer find_result.release(); + + if (find_result.code != .ok) { + std.log.err("Failed to get server info: {s}", .{@tagName(find_result.code)}); + return ExitCode.not_ok; + } + + if (find_result.servers_len == 0) { + std.log.err("Server not found for ID={s}", .{server_id}); + return ExitCode.not_ok; + } + + const server = find_result.servers_ptr[0]; + + const conn = core.connection.Connection.make(server, saved_token.ptr) orelse { + std.log.err("Unable to connect: Out of memory", .{}); + return ExitCode.out_of_memory; + }; + defer conn.release(); + + while (true) { + const ev = conn.getEvent() orelse { + std.log.err("Got empty event, terminating", .{}); + return ExitCode.not_ok; + }; + defer ev.release(); + + switch (ev.internal.payload) { + .connection_error => |err_ev| { + std.log.err("Failed to read event: {s}", .{@tagName(err_ev.code)}); + return ExitCode.not_ok; + }, + .connected => { + conn.subscribeZones(); + continue; + }, + .zone_list => |event| { + const added_zones = event.added_zones_ptr[0..event.added_zones_len]; + const changed_zones = event.changed_zones_ptr[0..event.changed_zones_len]; + + inline for (.{ added_zones, changed_zones }) |zones| { + for (zones) |zone| { + if (std.mem.eql(u8, std.mem.span(zone.name), zone_name)) { + std.fmt.format( + std.io.getStdOut().writer(), + "{s}\n", + .{@tagName(zone.playback)}, + ) catch |err| { + std.log.err("Failed to write to stdout: {s}", .{@errorName(err)}); + return ExitCode.stdout_write_failed; + }; + return ExitCode.ok; + } + } + } + continue; + }, + } + } + }
• cli/src/main.zig
  • @@ -20,6 +20,7 @@ const core = @import("core");
    const ExitCode = @import("./exit.zig").ExitCode; const connect = @import("./commands/connect.zig"); + const playback = @import("./commands/playback.zig"); const server = @import("./commands/server.zig"); const version = "0.0.0";
  • @@ -44,6 +45,7 @@ }
    const Commands = enum { connect, + playback, server, version, };
  • @@ -62,6 +64,7 @@ \\-v, --verbose Enables debug logging.
    \\<command> \\Available commands: \\* version ... Prints version to stdout and exits. + \\* playback ... Display playback state of a zone. \\* server ... Lists or gets information of Roon Server on network \\* connect ... Connects to Roon server and save state to a file. \\
  • @@ -108,6 +111,7 @@ return @intFromEnum(ExitCode.incorrect_usage);
    }; switch (command) { + .playback => return @intFromEnum(playback.run(allocator, &iter)), .server => return @intFromEnum(server.run(allocator, &iter)), .version => { try std.fmt.format(std.io.getStdOut().writer(), "{s}\n", .{version});