Restore

Restore file to captured state

Every captured change carries its SHA-256-addressed content in BLOB_STORE. Restoring writes that content back to the original path — current file gets backed up to <path>.drift_restore_backup_<epoch> before overwrite.

What will change

Preview -- nothing has been written yet.

Target file	/var/www/vhosts/3dshawn.com/site1/alerts.cgi
Site	DriftSense self-monitor on local
Kind	local
Captured at	2026-07-11 18:27:43
Captured SHA	ec54b82a47de610849197478f56cd0bde45930de1eaaf0e36736a18b2e73c5fd

Current state on disk

Live check just now. If SHAs match, the restore is a no-op.

File present	yes
Size	9628 bytes
Current SHA	3738a3d43d87
Same as captured?	no -- restore will change it

See exactly what's different →

What restore will change — live diff

Left column shows current on-disk content; right shows what restore will write. +3 additions, -12 deletions, 219 unchanged context lines.

1	1	#!/usr/bin/perl
2	2	#======================================================================
3	3	# DriftSense -- /alerts.cgi
4	4	#
5	5	# List, add, and edit alert rules. Also shows recent delivery history
6	6	# per rule (last 30 events). POST handling:
7	7	# op=create -> insert
8	8	# op=update -> update by alert_rule_id
9	9	# op=delete -> soft delete (is_active=0)
10	10	# op=toggle -> flip is_active
11	11	#======================================================================
12	12	use strict;
13	13	use warnings;
14	14	use CGI ();
15	15	use MODS::Config;
16	16	use MODS::DBConnect;
17	17	use MODS::Template;
18	18	use MODS::PageWrapper;
19	19
20	20	my $cgi = CGI->new;
21	21	my $db = MODS::DBConnect->new;
22	22	my $tpl = MODS::Template->new;
23	23
24	24	$\|=1;
25	25
26	26	my $dbh = $db->db_connect or die "DriftSense: cannot connect to storage DB\n";
27	27
28	28	# ---- POST actions ---------------------------------------------------
29	29	my $method = $ENV{REQUEST_METHOD} \|\| 'GET';
30	30	if ($method eq 'POST') {
31	31	my $op = $cgi->param('op') \|\| '';
32	32
33	33	if ($op eq 'create' \|\| $op eq 'update') {
34	34	my $rid = $op eq 'update' ? int($cgi->param('alert_rule_id') \|\| 0) : 0;
35	35	my $name = _clean($cgi->param('rule_name'), 200);
36	36	my $kind = _one_of($cgi->param('match_kind'), 'either', 'file', 'schema', 'either');
37	37	my $glob = _clean($cgi->param('match_path_glob'), 500);
38	38	my $stat = _clean($cgi->param('match_status_list'), 200);
39	39	my $xts = $cgi->param('exclude_ts_only') ? 1 : 0;
40	40	my $dkind = _one_of($cgi->param('delivery_kind'),
41	41	'generic_webhook', qw(slack discord generic_webhook email));
42	42	my $durl = _clean($cgi->param('delivery_url'), 2000);
43	43	my $dmail = _clean($cgi->param('delivery_email'), 500);
44	44	my $rlim = int($cgi->param('rate_limit_per_min') \|\| 0);
45	45	my $csec = int($cgi->param('coalesce_window_s') \|\| 0);
46	46	my $act = $cgi->param('is_active') ? 1 : 0;
47		my $fthr = int($cgi->param('frequency_threshold') \|\| 0);
48		my $fwin = int($cgi->param('frequency_window_min') \|\| 60);
49		$fwin = 60 if $fwin < 1;
50	47
51	48	my $q = sub { $dbh->quote($_[0] // '') };
52	49
53	50	if ($op eq 'create') {
54	51	$db->db_readwrite($dbh, qq~
55	52	INSERT INTO ALERT_RULES
56	53	(rule_name, is_active, match_kind, match_path_glob,
57	54	match_status_list, exclude_ts_only,
58	55	delivery_kind, delivery_url, delivery_email,
59		rate_limit_per_min, coalesce_window_s,
60		frequency_threshold, frequency_window_min)
	56	rate_limit_per_min, coalesce_window_s)
61	57	VALUES
62	58	(@{[ $q->($name) ]}, $act, @{[ $q->($kind) ]},
63	59	@{[ $q->($glob) ]}, @{[ $q->($stat) ]}, $xts,
64	60	@{[ $q->($dkind) ]}, @{[ $q->($durl) ]}, @{[ $q->($dmail) ]},
65		$rlim, $csec, $fthr, $fwin)
	61	$rlim, $csec)
66	62	~, __FILE__, __LINE__);
67	63	} else {
68	64	$db->db_readwrite($dbh, qq~
69	65	UPDATE ALERT_RULES
70	66	SET rule_name = @{[ $q->($name) ]},
71	67	is_active = $act,
72	68	match_kind = @{[ $q->($kind) ]},
73	69	match_path_glob = @{[ $q->($glob) ]},
74	70	match_status_list = @{[ $q->($stat) ]},
75	71	exclude_ts_only = $xts,
76	72	delivery_kind = @{[ $q->($dkind) ]},
77	73	delivery_url = @{[ $q->($durl) ]},
78	74	delivery_email = @{[ $q->($dmail) ]},
79	75	rate_limit_per_min = $rlim,
80		coalesce_window_s = $csec,
81		frequency_threshold = $fthr,
82		frequency_window_min = $fwin
	76	coalesce_window_s = $csec
83	77	WHERE alert_rule_id = $rid
84	78	~, __FILE__, __LINE__);
85	79	}
86	80	}
87	81	elsif ($op eq 'delete') {
88	82	my $rid = int($cgi->param('alert_rule_id') \|\| 0);
89	83	$db->db_readwrite($dbh,
90	84	"UPDATE ALERT_RULES SET is_active = 0 WHERE alert_rule_id = $rid",
91	85	__FILE__, __LINE__);
92	86	}
93	87	elsif ($op eq 'toggle') {
94	88	my $rid = int($cgi->param('alert_rule_id') \|\| 0);
95	89	$db->db_readwrite($dbh,
96	90	"UPDATE ALERT_RULES SET is_active = 1 - is_active WHERE alert_rule_id = $rid",
97	91	__FILE__, __LINE__);
98	92	}
99	93
100	94	$db->db_disconnect($dbh);
101	95	print "Status: 302 Found\nLocation: /alerts.cgi?nc=" . int(rand() * 10_000_000) . "\n\n";
102	96	exit;
103	97	}
104	98
105	99	# ---- GET: list rules + delivery history -----------------------------
106	100	print "Content-Type: text/html; charset=utf-8\nCache-Control: no-cache\n\n";
107	101
108	102	my @rules = $db->db_readwrite_multiple($dbh, q~
109	103	SELECT alert_rule_id, rule_name, is_active,
110	104	match_kind, match_path_glob, match_status_list, exclude_ts_only,
111	105	delivery_kind, delivery_url, delivery_email,
112	106	rate_limit_per_min, coalesce_window_s,
113		frequency_threshold, frequency_window_min,
114	107	fire_count, last_fired_at,
115	108	UNIX_TIMESTAMP(last_fired_at) AS last_fired_epoch,
116	109	UNIX_TIMESTAMP(created_at) AS created_epoch
117	110	FROM ALERT_RULES
118	111	ORDER BY is_active DESC, alert_rule_id ASC
119	112	~, __FILE__, __LINE__);
120	113
121	114	foreach my $r (@rules) {
122	115	$r->{status_pill} = $r->{is_active} ? 'pill-ok' : 'pill-mute';
123	116	$r->{status_label} = $r->{is_active} ? 'active' : 'paused';
124	117	$r->{kind_pill} = $r->{delivery_kind} eq 'slack' ? 'pill-info'
125	118	: $r->{delivery_kind} eq 'discord' ? 'pill-warn'
126	119	: 'pill-mute';
127	120	$r->{match_glob_h} = $r->{match_path_glob} \|\| '(all paths)';
128	121	$r->{url_h} = _shorten($r->{delivery_url} \|\| $r->{delivery_email} \|\| '(no target)');
129	122	$r->{last_fired_epoch} //= 0;
130	123	$r->{last_fired_h} = $r->{last_fired_at} \|\| 'never';
131	124	$r->{fire_count} //= 0;
132	125	$r->{edit_url} = "/alerts.cgi?edit=$r->{alert_rule_id}";
133	126	}
134	127
135	128	my @deliveries = $db->db_readwrite_multiple($dbh, q~
136	129	SELECT d.delivery_id, d.alert_rule_id, r.rule_name,
137	130	d.source_kind, d.source_id, d.match_summary,
138	131	d.delivery_status, d.http_status,
139	132	UNIX_TIMESTAMP(d.fired_at) AS fired_epoch,
140	133	d.fired_at,
141	134	LEFT(d.error_message, 200) AS err_short
142	135	FROM ALERT_DELIVERIES d
143	136	LEFT JOIN ALERT_RULES r ON r.alert_rule_id = d.alert_rule_id
144	137	ORDER BY d.delivery_id DESC
145	138	LIMIT 30
146	139	~, __FILE__, __LINE__);
147	140	foreach my $d (@deliveries) {
148	141	$d->{delivery_pill} = $d->{delivery_status} eq 'sent' ? 'pill-ok'
149	142	: $d->{delivery_status} eq 'failed' ? 'pill-bad'
150	143	: $d->{delivery_status} eq 'skipped' ? 'pill-mute'
151	144	: 'pill-warn';
152	145	$d->{source_url} = "/diff.cgi?kind=$d->{source_kind}&id=$d->{source_id}";
153	146	$d->{summary_h} = _shorten($d->{match_summary} \|\| '', 90);
154	147	$d->{err_h} = $d->{err_short} ? "err: $d->{err_short}" : ($d->{http_status} ? "HTTP $d->{http_status}" : '-');
155	148	$d->{fired_epoch} //= 0;
156	149	}
157	150
158	151	# ---- Edit mode: prefill form ---------------------------------------
159	152	my $edit_id = int($cgi->param('edit') \|\| 0);
160	153	my $edit = {};
161	154	if ($edit_id) {
162	155	($edit) = grep { $_->{alert_rule_id} == $edit_id } @rules;
163	156	$edit \|\|= {};
164	157	}
165	158	my $is_edit = $edit_id && $edit && $edit->{alert_rule_id} ? 1 : 0;
166	159
167	160	# defaults for a fresh form
168	161	my %form = (
169	162	rule_name => $edit->{rule_name} // '',
170	163	is_active_checked => (!$is_edit \|\| $edit->{is_active}) ? 'checked' : '',
171	164	match_kind => $edit->{match_kind} // 'either',
172	165	match_path_glob => $edit->{match_path_glob} // '',
173	166	match_status_list => $edit->{match_status_list} // '',
174	167	exclude_ts_only_checked => (!$is_edit \|\| $edit->{exclude_ts_only}) ? 'checked' : '',
175	168	delivery_kind => $edit->{delivery_kind} // 'generic_webhook',
176	169	delivery_url => $edit->{delivery_url} // '',
177	170	delivery_email => $edit->{delivery_email} // '',
178	171	rate_limit_per_min => $edit->{rate_limit_per_min} // 0,
179	172	coalesce_window_s => $edit->{coalesce_window_s} // 0,
180		frequency_threshold => $edit->{frequency_threshold} // 0,
181		frequency_window_min => $edit->{frequency_window_min} // 60,
182	173	);
183	174	# select-option "selected" markers
184	175	foreach my $k (qw(either file schema)) {
185	176	$form{"mk_${k}_sel"} = $form{match_kind} eq $k ? 'selected' : '';
186	177	}
187	178	foreach my $k (qw(generic_webhook slack discord email)) {
188	179	$form{"dk_${k}_sel"} = $form{delivery_kind} eq $k ? 'selected' : '';
189	180	}
190	181
191	182	$db->db_disconnect($dbh);
192	183
193	184	# ---- Render body ----------------------------------------------------
194	185	my $tvars = {
195	186	rules => \@rules,
196	187	has_rules => scalar(@rules) ? 1 : 0,
197	188	deliveries => \@deliveries,
198	189	has_deliveries => scalar(@deliveries) ? 1 : 0,
199	190	is_edit => $is_edit,
200	191	edit_id => $is_edit ? $edit->{alert_rule_id} : 0,
201	192	form_op => $is_edit ? 'update' : 'create',
202	193	%form,
203	194	};
204	195
205	196	my @body = $tpl->template('alerts.html', $tvars);
206	197	MODS::PageWrapper->new->wrapper(
207	198	page_title => 'Alerts', page_key => 'alerts',
208	199	body_html => join('', @body),
209	200	userinfo => { display_name => 'Operator' },
210	201	);
211	202
212	203	#---------------------------------------------------------------------
213	204	sub _clean {
214	205	my ($s, $max) = @_;
215	206	$s //= '';
216	207	$s =~ s/[\r\n]/ /g;
217	208	$s =~ s/^\s+\|\s+$//g;
218	209	$s = substr($s, 0, $max) if defined $max && length($s) > $max;
219	210	return $s;
220	211	}
221	212	sub _one_of {
222	213	my ($v, $default, @allowed) = @_;
223	214	$v //= '';
224	215	return (grep { $_ eq $v } @allowed) ? $v : $default;
225	216	}
226	217	sub _shorten {
227	218	my ($s, $max) = @_;
228	219	$max //= 60;
229	220	$s //= '';
230	221	return length($s) > $max ? substr($s, 0, $max - 3) . '...' : $s;
231	222	}

Confirm restore

Backs current content to <target>.drift_restore_backup_<epoch>, writes the captured content, verifies SHA post-write.