-
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
-
130
-
131
-
132
-
133
-
134
-
135
-
136
-
137
-
138
-
139
-
140
-
141
-
142
-
143
-
144
-
145
-
146
-
147
-
148
-
149
-
150
-
151
-
152
-
153
-
154
-
155
-
156
-
157
// Copyright 2026 Shota FUJI
//
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at https://mozilla.org/MPL/2.0/.
//
// SPDX-License-Identifier: MPL-2.0
const std = @import("std");
const uuid = @import("uuid");
const Options = @import("../Options.zig");
const errors = @import("../errors.zig");
const events = @import("../events.zig");
const timer = @import("../timer.zig");
pub const Error = errors.CommandLineError ||
events.Iterator.InitError ||
std.Io.Reader.LimitedAllocError ||
events.Envelope.AppendError ||
events.Manifest.SaveError ||
timer.TimerIterator.Error ||
std.mem.Allocator.Error ||
error{TimerNotFound};
fn printUsage(io: std.Io, file: std.Io.File) !void {
var buf: [512]u8 = undefined;
var writer = file.writer(io, &buf);
try writer.interface.writeAll(
\\timetracker stop - Stop a timer
\\
\\[USAGE]
\\timetracker stop [OPTIONS] <TITLE-OR-ID>
\\
\\[PARAMETERS]
\\TITLE-OR-ID Title text or ID of the timer to stop.
\\
\\[OPTIONS]
\\-h, --help Print this message to stdout and exits.
\\
\\
);
try writer.flush();
}
pub fn run(args: *std.process.Args.Iterator, gpa: std.mem.Allocator, io: std.Io, opts: Options) Error!void {
var maybe_title_or_id: ?[]const u8 = null;
defer if (maybe_title_or_id) |slice| gpa.free(slice);
while (args.next()) |arg| {
if (std.mem.eql(u8, "-h", arg) or std.mem.eql(u8, "--help", arg)) {
printUsage(io, std.Io.File.stdout()) catch |err| {
std.log.err("Failed to print usage to stdout: {t}", .{err});
return Error.WriteToStdoutFailed;
};
return;
}
if (maybe_title_or_id != null) {
std.log.err("You cannot set TITLE-OR-ID more than once", .{});
printUsage(io, std.Io.File.stderr()) catch return Error.WriteToStderrFailed;
return Error.InvalidUsage;
}
maybe_title_or_id = try gpa.dupe(u8, arg);
}
// Using `maybe_title_or_id` rather than putting this logic inside the `orelse` below
// makes freeing the slice simpler.
if (maybe_title_or_id == null) {
const stdin = std.Io.File.stdin();
if (!(try stdin.isTty(io))) {
var read_buf: [128]u8 = undefined;
var reader = stdin.reader(io, &read_buf);
maybe_title_or_id = reader.interface.allocRemaining(gpa, .limited(256)) catch |err| {
std.log.err("Unable to read from stdin: {t}", .{err});
return err;
};
}
}
const title_or_id = maybe_title_or_id orelse {
std.log.err("TITLE_OR_ID is required", .{});
printUsage(io, std.Io.File.stderr()) catch return Error.WriteToStderrFailed;
return Error.InvalidUsage;
};
var manifest = try events.Manifest.open(gpa, io, &opts.app_dir);
defer manifest.deinit(gpa);
const maybe_id = uuid.urn.deserialize(title_or_id) catch null;
var iter = try events.Iterator.init(io, &manifest);
var timer_iter: timer.TimerIterator = .{ .events_iter = &iter };
defer timer_iter.deinit(gpa);
while (try timer_iter.next(gpa, io)) |t| {
defer t.deinit(gpa);
switch (t) {
.stopped => break,
.running => |running| {
const matches = matches: {
if (maybe_id) |id| {
if (running.id == id) {
break :matches true;
}
}
break :matches std.mem.eql(u8, title_or_id, running.title);
};
if (!matches) {
break;
}
const event_id = uuid.v4.new(io);
const envelope: events.Envelope = .{
.parent = manifest.tail,
.id = event_id,
.event = .{ .timer_stopped = .{
.event_id = event_id,
.timer_id = running.id,
.created_at = std.Io.Clock.real.now(io).toSeconds(),
} },
};
envelope.append(gpa, io, &manifest) catch |err| {
std.log.err("Failed to save event file: {t}", .{err});
return err;
};
manifest.tail = event_id;
manifest.save(io) catch |err| {
std.log.err("Failed to update manifest file: {t}", .{err});
return err;
};
var stderr = std.Io.File.stderr();
defer stderr.close(io);
var write_buf: [1024]u8 = undefined;
var writer = stderr.writer(io, &write_buf);
try writer.interface.print("Stopped \"{s}\"\n", .{running.title});
try writer.interface.flush();
return;
},
}
}
std.log.err("No running timer matches to {s}", .{title_or_id});
return Error.TimerNotFound;
}