838fc2f Merge 302b124894f5046544f45426778f17d06092d41c into 993fa25853254a30231614da8a874281357ce9a0 · ermite

M docs/issues.md +3 -1


@@ -50,7 +50,9 @@ Limits: the 100 most recent commits of the merge request, 16 KiB of each text, 1
50	50
51	51		The signed-in owner has an Inbox at `/-/inbox`, reached from the Inbox button at the top left of the home page, which shows the number of open items. It lists the open merge requests and the open issues of every repository, most recently updated first. The counters at the top (`N merge requests · M issues`) always count everything; `?repo=<name>` restricts the two lists to one repository, and the repository links under the counters set it. Repositories with issues off contribute no issues.
52	52
53		-	The page updates live: merge request and issue events of any repository refresh the counters and the lists. Anyone who is not the signed-in owner, including a token, gets the same 404 as for an unknown page, and the same answer for the `owner` event stream it follows.
	53	+	The Running section, after Awaiting moderation, lists queued and in-progress CI runs newest first, with links to each run, its repository, ref, and start time. The `N running` counter counts every repository; the repository filter also applies to this section. Shift+I (`I`) opens the inbox from any page for the signed-in owner, unless single-key shortcuts are off; lowercase `i` still opens the issues tab.
	54	+
	55	+	The page updates live: run status changes, merge request and issue events of any repository refresh the counters and the lists. Anyone who is not the signed-in owner, including a token, gets the same 404 as for an unknown page, and the same answer for the `owner` event stream it follows.
54	56
55	57		## Public form and moderation
56	58


@@ -50,7 +50,9 @@ Limits: the 100 most recent commits of the merge request, 16 KiB of each text, 1
50			50
51		The signed-in owner has an Inbox at `/-/inbox`, reached from the Inbox button at the top left of the home page, which shows the number of open items. It lists the open merge requests and the open issues of every repository, most recently updated first. The counters at the top (`N merge requests · M issues`) always count everything; `?repo=<name>` restricts the two lists to one repository, and the repository links under the counters set it. Repositories with issues off contribute no issues.	51		The signed-in owner has an Inbox at `/-/inbox`, reached from the Inbox button at the top left of the home page, which shows the number of open items. It lists the open merge requests and the open issues of every repository, most recently updated first. The counters at the top (`N merge requests · M issues`) always count everything; `?repo=<name>` restricts the two lists to one repository, and the repository links under the counters set it. Repositories with issues off contribute no issues.
52			52
53	-	The page updates live: merge request and issue events of any repository refresh the counters and the lists. Anyone who is not the signed-in owner, including a token, gets the same 404 as for an unknown page, and the same answer for the `owner` event stream it follows.	53	+	The Running section, after Awaiting moderation, lists queued and in-progress CI runs newest first, with links to each run, its repository, ref, and start time. The `N running` counter counts every repository; the repository filter also applies to this section. Shift+I (`I`) opens the inbox from any page for the signed-in owner, unless single-key shortcuts are off; lowercase `i` still opens the issues tab.
			54	+
			55	+	The page updates live: run status changes, merge request and issue events of any repository refresh the counters and the lists. Anyone who is not the signed-in owner, including a token, gets the same 404 as for an unknown page, and the same answer for the `owner` event stream it follows.
54			56
55		## Public form and moderation	57		## Public form and moderation
56			58

M internal/adapters/web/inbox.go +25 -3


@@ -67,8 +67,17 @@ type InboxRepoLink struct {
67	67		Current bool
68	68		}
69	69
70		-	// InboxPage is the inbox: the counters, the filter and the two lists.
	70	+	// InboxRunRow adds repository and start time to the Actions run display.
	71	+	type InboxRunRow struct {
	72	+	RunRow
	73	+	Repo, RepoHref, When, WhenAt string
	74	+	}
	75	+
	76	+	// InboxPage is the inbox: counters, repository filter and item lists.
71	77		type InboxPage struct {
	78	+	Running int
	79	+	RunsEnabled bool
	80	+	Runs []InboxRunRow
72	81		// MergeRequests and Issues count every open item, whatever the filter.
73	82		MergeRequests, Issues int
74	83		// PendingCount counts every issue awaiting moderation.

@@ -106,6 +115,19 @@ func inboxFilter(r *http.Request) (domain.RepoName, error) {
106	115		func (s *Server) inboxPage(ov ports.InboxOverview, filter domain.RepoName) InboxPage {
107	116		now := s.cfg.Now()
108	117		p := InboxPage{MergeRequests: ov.Counts.MergeRequests, Issues: ov.Counts.Issues, PendingCount: ov.Counts.Pending, Filter: filter.String()}
	118	+	p.Running, p.RunsEnabled = ov.Counts.Running, ov.RunsEnabled
	119	+	for _, run := range ov.Runs {
	120	+	r := InboxRunRow{RunRow: s.runRow(run.Repo.String(), run, now), Repo: run.Repo.String(), RepoHref: repoHref(run.Repo.String())}
	121	+	if run.Status == domain.CIInProgress {
	122	+	r.State = "in progress"
	123	+	}
	124	+	ts := run.StartedAt
	125	+	if ts.IsZero() {
	126	+	ts = run.CreatedAt
	127	+	}
	128	+	r.When, r.WhenAt = whenOf(now, ts)
	129	+	p.Runs = append(p.Runs, r)
	130	+	}
109	131		for _, pi := range ov.Pending {
110	132		p.Pending = append(p.Pending, s.pendingRow(now, pi, filter))
111	133		}

@@ -266,7 +288,7 @@ func (l *liveStream) inbox(ctx context.Context, we ports.WatchEvent) ([]fragment
266	288		switch we.Event.(type) {
267	289		case domain.MergeRequestOpened, domain.MergeRequestMerged, domain.MergeRequestClosed, domain.MergeRequestReady, domain.CommentAdded, domain.CommentEdited, domain.CommentDeleted, domain.CommentResolved,
268	290		domain.IssueOpened, domain.IssueClosed, domain.IssueReopened, domain.IssueCommented, domain.IssueSubmitted, domain.IssuePendingRemoved,
269		-	domain.RepoUpdated, domain.RepoDeleted:
	291	+	domain.RepoUpdated, domain.RepoDeleted, domain.RunUpdated:
270	292		default:
271	293		return nil, nil
272	294		}

@@ -283,7 +305,7 @@ func (l *liveStream) inbox(ctx context.Context, we ports.WatchEvent) ([]fragment
283	305		}
284	306		p := l.s.inboxPage(ov, filter)
285	307		var out []fragment
286		-	for _, c := range []templ.Component{InboxCounters(p), InboxRepos(p), InboxPending(p), InboxMRs(p), InboxIssues(p)} {
	308	+	for _, c := range []templ.Component{InboxCounters(p), InboxRepos(p), InboxPending(p), InboxRuns(p), InboxMRs(p), InboxIssues(p)} {
287	309		f, err := renderFragment(ctx, inboxEvent, c)
288	310		if err != nil {
289	311		return nil, err

 	Current bool
 }
-// InboxPage is the inbox: the counters, the filter and the two lists.
+// InboxRunRow adds repository and start time to the Actions run display.
+type InboxRunRow struct {
+	RunRow
+	Repo, RepoHref, When, WhenAt string
+}
+// InboxPage is the inbox: counters, repository filter and item lists.
 type InboxPage struct {
+	Running     int
+	RunsEnabled bool
+	Runs        []InboxRunRow
 	// MergeRequests and Issues count every open item, whatever the filter.
 	MergeRequests, Issues int
 	// PendingCount counts every issue awaiting moderation.
 func (s *Server) inboxPage(ov ports.InboxOverview, filter domain.RepoName) InboxPage {
 	now := s.cfg.Now()
 	p := InboxPage{MergeRequests: ov.Counts.MergeRequests, Issues: ov.Counts.Issues, PendingCount: ov.Counts.Pending, Filter: filter.String()}
+	p.Running, p.RunsEnabled = ov.Counts.Running, ov.RunsEnabled
+	for _, run := range ov.Runs {
+		r := InboxRunRow{RunRow: s.runRow(run.Repo.String(), run, now), Repo: run.Repo.String(), RepoHref: repoHref(run.Repo.String())}
+		if run.Status == domain.CIInProgress {
+			r.State = "in progress"
+		}
+		ts := run.StartedAt
+		if ts.IsZero() {
+			ts = run.CreatedAt
+		}
+		r.When, r.WhenAt = whenOf(now, ts)
+		p.Runs = append(p.Runs, r)
+	}
 	for _, pi := range ov.Pending {
 		p.Pending = append(p.Pending, s.pendingRow(now, pi, filter))
 	}
 	switch we.Event.(type) {
 	case domain.MergeRequestOpened, domain.MergeRequestMerged, domain.MergeRequestClosed, domain.MergeRequestReady, domain.CommentAdded, domain.CommentEdited, domain.CommentDeleted, domain.CommentResolved,
 		domain.IssueOpened, domain.IssueClosed, domain.IssueReopened, domain.IssueCommented, domain.IssueSubmitted, domain.IssuePendingRemoved,
-		domain.RepoUpdated, domain.RepoDeleted:
+		domain.RepoUpdated, domain.RepoDeleted, domain.RunUpdated:
 	default:
 		return nil, nil
 	}
 	}
 	p := l.s.inboxPage(ov, filter)
 	var out []fragment
-	for _, c := range []templ.Component{InboxCounters(p), InboxRepos(p), InboxPending(p), InboxMRs(p), InboxIssues(p)} {
+	for _, c := range []templ.Component{InboxCounters(p), InboxRepos(p), InboxPending(p), InboxRuns(p), InboxMRs(p), InboxIssues(p)} {
 		f, err := renderFragment(ctx, inboxEvent, c)
 		if err != nil {
 			return nil, err

M internal/adapters/web/inbox.templ +34 -1


@@ -12,6 +12,7 @@ templ Inbox(l Layout, p InboxPage) {
12	12		@InboxCounters(p)
13	13		@InboxRepos(p)
14	14		@InboxPending(p)
	15	+	@InboxRuns(p)
15	16		@InboxMRs(p)
16	17		@InboxIssues(p)
17	18		</div>

@@ -20,7 +21,7 @@ templ Inbox(l Layout, p InboxPage) {
20	21
21	22		templ InboxCounters(p InboxPage) {
22	23		<p id="inbox-counts" class="inbox-counts">
23		-	<strong>{ itoa(p.MergeRequests) }</strong> merge requests · <strong>{ itoa(p.Issues) }</strong> issues · <strong>{ itoa(p.PendingCount) }</strong> awaiting moderation
	24	+	<strong>{ itoa(p.MergeRequests) }</strong> merge requests · <strong>{ itoa(p.Issues) }</strong> issues · <strong>{ itoa(p.PendingCount) }</strong> awaiting moderation · <strong>{ itoa(p.Running) }</strong> running
24	25		</p>
25	26		}
26	27

@@ -113,3 +114,35 @@ templ inboxRows(rows []InboxRow, label string) {
113	114		</table>
114	115		}
115	116		}
	117	+
	118	+	// InboxRuns stays as an empty fragment when CI is disabled.
	119	+	templ InboxRuns(p InboxPage) {
	120	+	<section id="inbox-runs" hidden?={ !p.RunsEnabled }
	121	+	if p.RunsEnabled {
	122	+	aria-labelledby="inbox-runs-h"
	123	+	}
	124	+	>
	125	+	if p.RunsEnabled {
	126	+	<h2 id="inbox-runs-h" class="rule-h"><span>Running</span><span class="count">{ itoa(len(p.Runs)) }</span></h2>
	127	+	if len(p.Runs) == 0 {
	128	+	<p class="lede dim">no runs in progress.</p>
	129	+	} else {
	130	+	<table class="list mrs" aria-label="Running">
	131	+	<tbody data-rows>
	132	+	for _, r := range p.Runs {
	133	+	<tr>
	134	+	<td class="c-st">@CheckIcon(r.Kind, r.State)<span class="dim">{ r.State }</span></td>
	135	+	<td class="c-subject"><a href={ templ.SafeURL(r.Href) }>{ r.Workflow }{ " " }{ r.Number }</a> <a class="mute" href={ templ.SafeURL(r.RepoHref) }>{ r.Repo }</a> <span class="dim">{ r.Ref }{ " " }{ r.Event }</span></td>
	136	+	<td class="c-when nowrap dim">
	137	+	if r.WhenAt != "" {
	138	+	<time datetime={ r.WhenAt } title={ r.WhenAt }>{ r.When }</time>
	139	+	}
	140	+	</td>
	141	+	</tr>
	142	+	}
	143	+	</tbody>
	144	+	</table>
	145	+	}
	146	+	}
	147	+	</section>
	148	+	}


@@ -12,6 +12,7 @@ templ Inbox(l Layout, p InboxPage) {
12		@InboxCounters(p)	12		@InboxCounters(p)
13		@InboxRepos(p)	13		@InboxRepos(p)
14		@InboxPending(p)	14		@InboxPending(p)
			15	+	@InboxRuns(p)
15		@InboxMRs(p)	16		@InboxMRs(p)
16		@InboxIssues(p)	17		@InboxIssues(p)
17		</div>	18		</div>

@@ -20,7 +21,7 @@ templ Inbox(l Layout, p InboxPage) {
20			21
21		templ InboxCounters(p InboxPage) {	22		templ InboxCounters(p InboxPage) {
22		<p id="inbox-counts" class="inbox-counts">	23		<p id="inbox-counts" class="inbox-counts">
23	-	<strong>{ itoa(p.MergeRequests) }</strong> merge requests · <strong>{ itoa(p.Issues) }</strong> issues · <strong>{ itoa(p.PendingCount) }</strong> awaiting moderation	24	+	<strong>{ itoa(p.MergeRequests) }</strong> merge requests · <strong>{ itoa(p.Issues) }</strong> issues · <strong>{ itoa(p.PendingCount) }</strong> awaiting moderation · <strong>{ itoa(p.Running) }</strong> running
24		</p>	25		</p>
25		}	26		}
26			27

@@ -113,3 +114,35 @@ templ inboxRows(rows []InboxRow, label string) {
113		</table>	114		</table>
114		}	115		}
115		}	116		}
			117	+
			118	+	// InboxRuns stays as an empty fragment when CI is disabled.
			119	+	templ InboxRuns(p InboxPage) {
			120	+	<section id="inbox-runs" hidden?={ !p.RunsEnabled }
			121	+	if p.RunsEnabled {
			122	+	aria-labelledby="inbox-runs-h"
			123	+	}
			124	+	>
			125	+	if p.RunsEnabled {
			126	+	<h2 id="inbox-runs-h" class="rule-h"><span>Running</span><span class="count">{ itoa(len(p.Runs)) }</span></h2>
			127	+	if len(p.Runs) == 0 {
			128	+	<p class="lede dim">no runs in progress.</p>
			129	+	} else {
			130	+	<table class="list mrs" aria-label="Running">
			131	+	<tbody data-rows>
			132	+	for _, r := range p.Runs {
			133	+	<tr>
			134	+	<td class="c-st">@CheckIcon(r.Kind, r.State)<span class="dim">{ r.State }</span></td>
			135	+	<td class="c-subject"><a href={ templ.SafeURL(r.Href) }>{ r.Workflow }{ " " }{ r.Number }</a> <a class="mute" href={ templ.SafeURL(r.RepoHref) }>{ r.Repo }</a> <span class="dim">{ r.Ref }{ " " }{ r.Event }</span></td>
			136	+	<td class="c-when nowrap dim">
			137	+	if r.WhenAt != "" {
			138	+	<time datetime={ r.WhenAt } title={ r.WhenAt }>{ r.When }</time>
			139	+	}
			140	+	</td>
			141	+	</tr>
			142	+	}
			143	+	</tbody>
			144	+	</table>
			145	+	}
			146	+	}
			147	+	</section>
			148	+	}

M internal/adapters/web/inbox_templ.go +451 -173 generated file: collapsed

load diff

M internal/adapters/web/inbox_test.go +6 -4


@@ -180,12 +180,13 @@ func TestInboxLiveFragments(t *testing.T) {
180	180		ls := &liveStream{s: srv, view: "inbox"}
181	181		frags, err := ls.render(withOwner(t.Context()), ports.WatchEvent{ID: "b-1", Event: domain.IssueOpened{Issue: domain.Issue{Repo: repoName(t, "beta"), Number: 7}}})
182	182		require.NoError(t, err)
183		-	require.Len(t, frags, 5)
	183	+	require.Len(t, frags, 6)
184	184		assert.Contains(t, frags[0].html, `id="inbox-counts"`)
185	185		assert.Contains(t, frags[1].html, `id="inbox-repos"`)
186	186		assert.Contains(t, frags[2].html, `id="inbox-pending"`)
187		-	assert.Contains(t, frags[3].html, `id="inbox-mrs"`)
188		-	assert.Contains(t, frags[4].html, `id="inbox-issues"`)
	187	+	assert.Contains(t, frags[3].html, `id="inbox-runs"`)
	188	+	assert.Contains(t, frags[4].html, `id="inbox-mrs"`)
	189	+	assert.Contains(t, frags[5].html, `id="inbox-issues"`)
189	190
190	191		none, err := ls.render(withOwner(t.Context()), ports.WatchEvent{Event: domain.PushEvent{Repo: repoName(t, "beta")}})
191	192		require.NoError(t, err)

@@ -286,6 +287,7 @@ func TestInboxRefreshesOnRepoEvents(t *testing.T) {
286	287		t.Parallel()
287	288		for name, ev := range map[string]domain.Event{
288	289		"issues turned off": domain.RepoUpdated{Repo: repoName(t, "beta")},
	290	+	"run updated": domain.RunUpdated{},
289	291		"repo deleted": domain.RepoDeleted{Repo: repoName(t, "beta")},
290	292		} {
291	293		t.Run(name, func(t *testing.T) {

@@ -297,7 +299,7 @@ func TestInboxRefreshesOnRepoEvents(t *testing.T) {
297	299		ls := &liveStream{s: srv, view: "inbox"}
298	300		frags, err := ls.render(withOwner(t.Context()), ports.WatchEvent{ID: "b-1", Event: ev})
299	301		require.NoError(t, err)
300		-	require.Len(t, frags, 5)
	302	+	require.Len(t, frags, 6)
301	303		all := ""
302	304		for _, f := range frags {
303	305		all += f.html

 	ls := &liveStream{s: srv, view: "inbox"}
 	frags, err := ls.render(withOwner(t.Context()), ports.WatchEvent{ID: "b-1", Event: domain.IssueOpened{Issue: domain.Issue{Repo: repoName(t, "beta"), Number: 7}}})
 	require.NoError(t, err)
-	require.Len(t, frags, 5)
+	require.Len(t, frags, 6)
 	assert.Contains(t, frags[0].html, `id="inbox-counts"`)
 	assert.Contains(t, frags[1].html, `id="inbox-repos"`)
 	assert.Contains(t, frags[2].html, `id="inbox-pending"`)
-	assert.Contains(t, frags[3].html, `id="inbox-mrs"`)
+	assert.Contains(t, frags[3].html, `id="inbox-runs"`)
-	assert.Contains(t, frags[4].html, `id="inbox-issues"`)
+	assert.Contains(t, frags[4].html, `id="inbox-mrs"`)
+	assert.Contains(t, frags[5].html, `id="inbox-issues"`)
 	none, err := ls.render(withOwner(t.Context()), ports.WatchEvent{Event: domain.PushEvent{Repo: repoName(t, "beta")}})
 	require.NoError(t, err)
 	t.Parallel()
 	for name, ev := range map[string]domain.Event{
 		"issues turned off": domain.RepoUpdated{Repo: repoName(t, "beta")},
+		"run updated":       domain.RunUpdated{},
 		"repo deleted":      domain.RepoDeleted{Repo: repoName(t, "beta")},
 	} {
 		t.Run(name, func(t *testing.T) {
 			ls := &liveStream{s: srv, view: "inbox"}
 			frags, err := ls.render(withOwner(t.Context()), ports.WatchEvent{ID: "b-1", Event: ev})
 			require.NoError(t, err)
-			require.Len(t, frags, 5)
+			require.Len(t, frags, 6)
 			all := ""
 			for _, f := range frags {
 				all += f.html

A internal/adapters/web/jstest/keys.test.mjs +29 -0

@@ -0,0 +1,29 @@
	1	+	// Exercise the production keydown handler without loading the rest of the page.
	2	+	import assert from 'node:assert/strict';
	3	+	import { readFileSync } from 'node:fs';
	4	+	import { test } from 'node:test';
	5	+	const src = readFileSync(new URL('../static/js/ermite.js', import.meta.url), 'utf8');
	6	+	const block = src.slice(src.indexOf(' // 1. Keys.'), src.indexOf(' // 2. A [data-fire]'));
	7	+
	8	+	function page({ owner = true, off = false, typing = false, dialog = false } = {}) {
	9	+	let handler;
	10	+	const fired = [];
	11	+	const window = { ermiteKeys: { blocks: () => off } };
	12	+	const $ = (s) => s === 'dialog[open]' ? dialog : s === '[data-inbox]' ? owner : null;
	13	+	new Function('window', '$', 'ermite', 'addEventListener', block)(window, $, { fire: (n) => fired.push(n) }, (_, f) => { handler = f; });
	14	+	return (key) => {
	15	+	const e = { key, shiftKey: key === 'I', preventDefault() {}, target: { closest: (s) => s.startsWith('input') && typing } };
	16	+	handler(e);
	17	+	return fired;
	18	+	};
	19	+	}
	20	+	test('Shift+I opens inbox while lowercase i retains the issues tab', () => {
	21	+	const press = page();
	22	+	assert.deepEqual(press('I'), ['inbox']);
	23	+	assert.deepEqual(press('i'), ['inbox', 'i']);
	24	+	});
	25	+	test('inbox shortcut respects preference, fields, dialogs, and owner target', () => {
	26	+	for (const options of [{ off: true }, { typing: true }, { dialog: true }, { owner: false }]) {
	27	+	assert.deepEqual(page(options)('I'), [], JSON.stringify(options));
	28	+	}
	29	+	});

@@ -0,0 +1,29 @@
	1	+	// Exercise the production keydown handler without loading the rest of the page.
	2	+	import assert from 'node:assert/strict';
	3	+	import { readFileSync } from 'node:fs';
	4	+	import { test } from 'node:test';
	5	+	const src = readFileSync(new URL('../static/js/ermite.js', import.meta.url), 'utf8');
	6	+	const block = src.slice(src.indexOf(' // 1. Keys.'), src.indexOf(' // 2. A [data-fire]'));
	7	+
	8	+	function page({ owner = true, off = false, typing = false, dialog = false } = {}) {
	9	+	let handler;
	10	+	const fired = [];
	11	+	const window = { ermiteKeys: { blocks: () => off } };
	12	+	const $ = (s) => s === 'dialog[open]' ? dialog : s === '[data-inbox]' ? owner : null;
	13	+	new Function('window', '$', 'ermite', 'addEventListener', block)(window, $, { fire: (n) => fired.push(n) }, (_, f) => { handler = f; });
	14	+	return (key) => {
	15	+	const e = { key, shiftKey: key === 'I', preventDefault() {}, target: { closest: (s) => s.startsWith('input') && typing } };
	16	+	handler(e);
	17	+	return fired;
	18	+	};
	19	+	}
	20	+	test('Shift+I opens inbox while lowercase i retains the issues tab', () => {
	21	+	const press = page();
	22	+	assert.deepEqual(press('I'), ['inbox']);
	23	+	assert.deepEqual(press('i'), ['inbox', 'i']);
	24	+	});
	25	+	test('inbox shortcut respects preference, fields, dialogs, and owner target', () => {
	26	+	for (const options of [{ off: true }, { typing: true }, { dialog: true }, { owner: false }]) {
	27	+	assert.deepEqual(page(options)('I'), [], JSON.stringify(options));
	28	+	}
	29	+	});

M internal/adapters/web/keys.templ +1 -0


@@ -28,6 +28,7 @@ templ Keys() {
28	28		k-r from:body -> ermite.tab('r');
29	29		k-m from:body -> ermite.tab('m');
30	30		k-i from:body -> ermite.tab('i');
	31	+	k-inbox from:body -> ermite.go('[data-inbox]');
31	32		k-next from:body -> ermite.nextNote();
32	33		k-split from:body -> ermite.layout('split');
33	34		k-unified from:body -> ermite.layout('unified');


@@ -28,6 +28,7 @@ templ Keys() {
28	k-r from:body -> ermite.tab('r');	28		k-r from:body -> ermite.tab('r');
29	k-m from:body -> ermite.tab('m');	29		k-m from:body -> ermite.tab('m');
30	k-i from:body -> ermite.tab('i');	30		k-i from:body -> ermite.tab('i');
		31	+	k-inbox from:body -> ermite.go('[data-inbox]');
31	k-next from:body -> ermite.nextNote();	32		k-next from:body -> ermite.nextNote();
32	k-split from:body -> ermite.layout('split');	33		k-split from:body -> ermite.layout('split');
33	k-unified from:body -> ermite.layout('unified');	34		k-unified from:body -> ermite.layout('unified');

M internal/adapters/web/keys_templ.go +1 -1 generated file: collapsed

load diff

M internal/adapters/web/overlays.templ +3 -0


@@ -27,6 +27,9 @@ templ OverlayHelp(mr bool) {
27	27		<div><dt><kbd>/</kbd></dt><dd>filter the list; on Files, find a file anywhere in the repository (esc clears, enter opens the best match)</dd></div>
28	28		<div><dt><kbd>b</kbd></dt><dd>{ "switch" } branch or tag</dd></div>
29	29		<div><dt><kbd>s</kbd> <kbd>t</kbd> <kbd>c</kbd> <kbd>r</kbd> <kbd>m</kbd> <kbd>i</kbd></dt><dd>tabs: summary, files, commits, branches & tags, merge requests, issues</dd></div>
	30	+	if SignedIn(ctx) {
	31	+	<div><dt><kbd>I</kbd></dt><dd>inbox</dd></div>
	32	+	}
30	33		<div><dt><kbd>g h</kbd></dt><dd>home</dd></div>
31	34		<div><dt><kbd>w</kbd></dt><dd>wide mode: use the whole width of the screen, or not (remembered)</dd></div>
32	35		<div><dt><kbd>y</kbd></dt><dd>copy a permalink pinned to the commit</dd></div>


@@ -27,6 +27,9 @@ templ OverlayHelp(mr bool) {
27	<div><dt><kbd>/</kbd></dt><dd>filter the list; on Files, find a file anywhere in the repository (esc clears, enter opens the best match)</dd></div>	27		<div><dt><kbd>/</kbd></dt><dd>filter the list; on Files, find a file anywhere in the repository (esc clears, enter opens the best match)</dd></div>
28	<div><dt><kbd>b</kbd></dt><dd>{ "switch" } branch or tag</dd></div>	28		<div><dt><kbd>b</kbd></dt><dd>{ "switch" } branch or tag</dd></div>
29	<div><dt><kbd>s</kbd> <kbd>t</kbd> <kbd>c</kbd> <kbd>r</kbd> <kbd>m</kbd> <kbd>i</kbd></dt><dd>tabs: summary, files, commits, branches & tags, merge requests, issues</dd></div>	29		<div><dt><kbd>s</kbd> <kbd>t</kbd> <kbd>c</kbd> <kbd>r</kbd> <kbd>m</kbd> <kbd>i</kbd></dt><dd>tabs: summary, files, commits, branches & tags, merge requests, issues</dd></div>
		30	+	if SignedIn(ctx) {
		31	+	<div><dt><kbd>I</kbd></dt><dd>inbox</dd></div>
		32	+	}
30	<div><dt><kbd>g h</kbd></dt><dd>home</dd></div>	33		<div><dt><kbd>g h</kbd></dt><dd>home</dd></div>
31	<div><dt><kbd>w</kbd></dt><dd>wide mode: use the whole width of the screen, or not (remembered)</dd></div>	34		<div><dt><kbd>w</kbd></dt><dd>wide mode: use the whole width of the screen, or not (remembered)</dd></div>
32	<div><dt><kbd>y</kbd></dt><dd>copy a permalink pinned to the commit</dd></div>	35		<div><dt><kbd>y</kbd></dt><dd>copy a permalink pinned to the commit</dd></div>

M internal/adapters/web/overlays_templ.go +49 -39 generated file: collapsed

load diff

M internal/adapters/web/shell.templ +5 -1


@@ -67,6 +67,9 @@ templ Shell(l Layout, rail templ.Component) {
67	67		</div>
68	68		@Footer(l)
69	69		@Hint(l)
	70	+	if SignedIn(ctx) {
	71	+	<a hidden data-inbox href={ inboxPath }>Inbox</a>
	72	+	}
70	73		@OverlayHelp(l.MR)
71	74		@OverlayRefs(l)
72	75		@OverlayCmd(l.Cmd)

@@ -87,7 +90,8 @@ templ Header(l Layout) {
87	90		<a
88	91		class="btn inbox-btn"
89	92		href={ templ.SafeURL(l.Inbox.Href) }
90		-	title="inbox"
	93	+	title="inbox (I)"
	94	+	aria-keyshortcuts="Shift+I"
91	95		>
92	96		<span class="ico i-mailbox" aria-hidden="true"></span>
93	97		Inbox

 			</div>
 			@Footer(l)
 			@Hint(l)
+			if SignedIn(ctx) {
+				<a hidden data-inbox href={ inboxPath }>Inbox</a>
+			}
 			@OverlayHelp(l.MR)
 			@OverlayRefs(l)
 			@OverlayCmd(l.Cmd)
 				<a
 					class="btn inbox-btn"
 					href={ templ.SafeURL(l.Inbox.Href) }
-					title="inbox"
+					title="inbox (I)"
+					aria-keyshortcuts="Shift+I"
 				>
 					<span class="ico i-mailbox" aria-hidden="true"></span>
 					Inbox

M internal/adapters/web/shell_templ.go +152 -133 generated file: collapsed

load diff

M internal/adapters/web/static/js/ermite.js +2 -2


@@ -612,7 +612,7 @@
612	612
613	613		// 1. Keys.
614	614		const single = { j: 'j', k: 'k', G: 'bottom', '/': 'filter', '?': 'help', b: 'refs', f: 'cmd', ':': 'cmd', y: 'permalink',
615		-	s: 's', t: 't', c: 'c', r: 'r', m: 'm', i: 'i', n: 'next', h: 'left', l: 'right', d: 'split', u: 'unified', x: 'collapse', w: 'wide', e: 'expand', E: 'expandAll', Enter: 'open', Escape: 'esc',
	615	+	s: 's', t: 't', c: 'c', r: 'r', m: 'm', i: 'i', I: 'inbox', n: 'next', h: 'left', l: 'right', d: 'split', u: 'unified', x: 'collapse', w: 'wide', e: 'expand', E: 'expandAll', Enter: 'open', Escape: 'esc',
616	616		// the merge request page (mr.js): the merge menu, mark read
617	617		M: 'merge', R: 'read' };
618	618		// "g t" is the key "t": the tabs have one event each.

@@ -654,7 +654,7 @@
654	654		// page-level keys, as on the other lists.
655	655		if (!e.shiftKey && e.target.closest?.('#tree-rows') && window.ermiteTree?.arrow(e.key)) { e.preventDefault(); return; }
656	656		const name = single[e.key];
657		-	if (!name) return;
	657	+	if (!name \|\| (name === 'inbox' && !$('[data-inbox]'))) return;
658	658		if (e.key !== 'Enter' \|\| !$('dialog[open]')) e.preventDefault();
659	659		ermite.fire(name);
660	660		});


@@ -612,7 +612,7 @@
612			612
613		// 1. Keys.	613		// 1. Keys.
614		const single = { j: 'j', k: 'k', G: 'bottom', '/': 'filter', '?': 'help', b: 'refs', f: 'cmd', ':': 'cmd', y: 'permalink',	614		const single = { j: 'j', k: 'k', G: 'bottom', '/': 'filter', '?': 'help', b: 'refs', f: 'cmd', ':': 'cmd', y: 'permalink',
615	-	s: 's', t: 't', c: 'c', r: 'r', m: 'm', i: 'i', n: 'next', h: 'left', l: 'right', d: 'split', u: 'unified', x: 'collapse', w: 'wide', e: 'expand', E: 'expandAll', Enter: 'open', Escape: 'esc',	615	+	s: 's', t: 't', c: 'c', r: 'r', m: 'm', i: 'i', I: 'inbox', n: 'next', h: 'left', l: 'right', d: 'split', u: 'unified', x: 'collapse', w: 'wide', e: 'expand', E: 'expandAll', Enter: 'open', Escape: 'esc',
616		// the merge request page (mr.js): the merge menu, mark read	616		// the merge request page (mr.js): the merge menu, mark read
617		M: 'merge', R: 'read' };	617		M: 'merge', R: 'read' };
618		// "g t" is the key "t": the tabs have one event each.	618		// "g t" is the key "t": the tabs have one event each.

@@ -654,7 +654,7 @@
654		// page-level keys, as on the other lists.	654		// page-level keys, as on the other lists.
655		if (!e.shiftKey && e.target.closest?.('#tree-rows') && window.ermiteTree?.arrow(e.key)) { e.preventDefault(); return; }	655		if (!e.shiftKey && e.target.closest?.('#tree-rows') && window.ermiteTree?.arrow(e.key)) { e.preventDefault(); return; }
656		const name = single[e.key];	656		const name = single[e.key];
657	-	if (!name) return;	657	+	if (!name \|\| (name === 'inbox' && !$('[data-inbox]'))) return;
658		if (e.key !== 'Enter' \|\| !$('dialog[open]')) e.preventDefault();	658		if (e.key !== 'Enter' \|\| !$('dialog[open]')) e.preventDefault();
659		ermite.fire(name);	659		ermite.fire(name);
660		});	660		});

M internal/app/forge.go +1 -1


@@ -412,7 +412,7 @@ func newForge(ctx context.Context, cfg config.Config, opts options) (_ *forge, e
412	412		BaseDifficulty: opts.issuePoW, MaxDifficulty: opts.issuePoW, MinFillTime: fastFill(opts.issuePoW),
413	413		})
414	414		f.Inbox = usecase.NewInbox(usecase.InboxConfig{
415		-	Meta: store, MergeRequests: store.MergeRequests(), Issues: store.Issues(), Pending: store.PendingIssues(),
	415	+	Meta: store, MergeRequests: store.MergeRequests(), Issues: store.Issues(), Pending: store.PendingIssues(), CI: store.CI(),
416	416		})
417	417		f.CI.SetPullGate(f.MergeRequests)
418	418		f.AutoMerge.Start()


@@ -412,7 +412,7 @@ func newForge(ctx context.Context, cfg config.Config, opts options) (_ *forge, e
412		BaseDifficulty: opts.issuePoW, MaxDifficulty: opts.issuePoW, MinFillTime: fastFill(opts.issuePoW),	412		BaseDifficulty: opts.issuePoW, MaxDifficulty: opts.issuePoW, MinFillTime: fastFill(opts.issuePoW),
413		})	413		})
414		f.Inbox = usecase.NewInbox(usecase.InboxConfig{	414		f.Inbox = usecase.NewInbox(usecase.InboxConfig{
415	-	Meta: store, MergeRequests: store.MergeRequests(), Issues: store.Issues(), Pending: store.PendingIssues(),	415	+	Meta: store, MergeRequests: store.MergeRequests(), Issues: store.Issues(), Pending: store.PendingIssues(), CI: store.CI(),
416		})	416		})
417		f.CI.SetPullGate(f.MergeRequests)	417		f.CI.SetPullGate(f.MergeRequests)
418		f.AutoMerge.Start()	418		f.AutoMerge.Start()

M internal/app/testdata/web/blob-binary.html +1 -0


@@ -428,6 +428,7 @@
428	428		k-r from:body -> ermite.tab('r');
429	429		k-m from:body -> ermite.tab('m');
430	430		k-i from:body -> ermite.tab('i');
	431	+	k-inbox from:body -> ermite.go('[data-inbox]');
431	432		k-next from:body -> ermite.nextNote();
432	433		k-split from:body -> ermite.layout('split');
433	434		k-unified from:body -> ermite.layout('unified');


@@ -428,6 +428,7 @@
428	k-r from:body -> ermite.tab('r');	428		k-r from:body -> ermite.tab('r');
429	k-m from:body -> ermite.tab('m');	429		k-m from:body -> ermite.tab('m');
430	k-i from:body -> ermite.tab('i');	430		k-i from:body -> ermite.tab('i');
		431	+	k-inbox from:body -> ermite.go('[data-inbox]');
431	k-next from:body -> ermite.nextNote();	432		k-next from:body -> ermite.nextNote();
432	k-split from:body -> ermite.layout('split');	433		k-split from:body -> ermite.layout('split');
433	k-unified from:body -> ermite.layout('unified');	434		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/blob-code.html +1 -0


@@ -498,6 +498,7 @@
498	498		k-r from:body -> ermite.tab('r');
499	499		k-m from:body -> ermite.tab('m');
500	500		k-i from:body -> ermite.tab('i');
	501	+	k-inbox from:body -> ermite.go('[data-inbox]');
501	502		k-next from:body -> ermite.nextNote();
502	503		k-split from:body -> ermite.layout('split');
503	504		k-unified from:body -> ermite.layout('unified');


@@ -498,6 +498,7 @@
498	k-r from:body -> ermite.tab('r');	498		k-r from:body -> ermite.tab('r');
499	k-m from:body -> ermite.tab('m');	499		k-m from:body -> ermite.tab('m');
500	k-i from:body -> ermite.tab('i');	500		k-i from:body -> ermite.tab('i');
		501	+	k-inbox from:body -> ermite.go('[data-inbox]');
501	k-next from:body -> ermite.nextNote();	502		k-next from:body -> ermite.nextNote();
502	k-split from:body -> ermite.layout('split');	503		k-split from:body -> ermite.layout('split');
503	k-unified from:body -> ermite.layout('unified');	504		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/blob-empty.html +1 -0


@@ -428,6 +428,7 @@
428	428		k-r from:body -> ermite.tab('r');
429	429		k-m from:body -> ermite.tab('m');
430	430		k-i from:body -> ermite.tab('i');
	431	+	k-inbox from:body -> ermite.go('[data-inbox]');
431	432		k-next from:body -> ermite.nextNote();
432	433		k-split from:body -> ermite.layout('split');
433	434		k-unified from:body -> ermite.layout('unified');


@@ -428,6 +428,7 @@
428	k-r from:body -> ermite.tab('r');	428		k-r from:body -> ermite.tab('r');
429	k-m from:body -> ermite.tab('m');	429		k-m from:body -> ermite.tab('m');
430	k-i from:body -> ermite.tab('i');	430		k-i from:body -> ermite.tab('i');
		431	+	k-inbox from:body -> ermite.go('[data-inbox]');
431	k-next from:body -> ermite.nextNote();	432		k-next from:body -> ermite.nextNote();
432	k-split from:body -> ermite.layout('split');	433		k-split from:body -> ermite.layout('split');
433	k-unified from:body -> ermite.layout('unified');	434		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/blob-image.html +1 -0


@@ -430,6 +430,7 @@
430	430		k-r from:body -> ermite.tab('r');
431	431		k-m from:body -> ermite.tab('m');
432	432		k-i from:body -> ermite.tab('i');
	433	+	k-inbox from:body -> ermite.go('[data-inbox]');
433	434		k-next from:body -> ermite.nextNote();
434	435		k-split from:body -> ermite.layout('split');
435	436		k-unified from:body -> ermite.layout('unified');


@@ -430,6 +430,7 @@
430	k-r from:body -> ermite.tab('r');	430		k-r from:body -> ermite.tab('r');
431	k-m from:body -> ermite.tab('m');	431		k-m from:body -> ermite.tab('m');
432	k-i from:body -> ermite.tab('i');	432		k-i from:body -> ermite.tab('i');
		433	+	k-inbox from:body -> ermite.go('[data-inbox]');
433	k-next from:body -> ermite.nextNote();	434		k-next from:body -> ermite.nextNote();
434	k-split from:body -> ermite.layout('split');	435		k-split from:body -> ermite.layout('split');
435	k-unified from:body -> ermite.layout('unified');	436		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/blob-markdown.html +1 -0


@@ -495,6 +495,7 @@
495	495		k-r from:body -> ermite.tab('r');
496	496		k-m from:body -> ermite.tab('m');
497	497		k-i from:body -> ermite.tab('i');
	498	+	k-inbox from:body -> ermite.go('[data-inbox]');
498	499		k-next from:body -> ermite.nextNote();
499	500		k-split from:body -> ermite.layout('split');
500	501		k-unified from:body -> ermite.layout('unified');


@@ -495,6 +495,7 @@
495	k-r from:body -> ermite.tab('r');	495		k-r from:body -> ermite.tab('r');
496	k-m from:body -> ermite.tab('m');	496		k-m from:body -> ermite.tab('m');
497	k-i from:body -> ermite.tab('i');	497		k-i from:body -> ermite.tab('i');
		498	+	k-inbox from:body -> ermite.go('[data-inbox]');
498	k-next from:body -> ermite.nextNote();	499		k-next from:body -> ermite.nextNote();
499	k-split from:body -> ermite.layout('split');	500		k-split from:body -> ermite.layout('split');
500	k-unified from:body -> ermite.layout('unified');	501		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/blob-svg.html +1 -0


@@ -453,6 +453,7 @@
453	453		k-r from:body -> ermite.tab('r');
454	454		k-m from:body -> ermite.tab('m');
455	455		k-i from:body -> ermite.tab('i');
	456	+	k-inbox from:body -> ermite.go('[data-inbox]');
456	457		k-next from:body -> ermite.nextNote();
457	458		k-split from:body -> ermite.layout('split');
458	459		k-unified from:body -> ermite.layout('unified');


@@ -453,6 +453,7 @@
453	k-r from:body -> ermite.tab('r');	453		k-r from:body -> ermite.tab('r');
454	k-m from:body -> ermite.tab('m');	454		k-m from:body -> ermite.tab('m');
455	k-i from:body -> ermite.tab('i');	455		k-i from:body -> ermite.tab('i');
		456	+	k-inbox from:body -> ermite.go('[data-inbox]');
456	k-next from:body -> ermite.nextNote();	457		k-next from:body -> ermite.nextNote();
457	k-split from:body -> ermite.layout('split');	458		k-split from:body -> ermite.layout('split');
458	k-unified from:body -> ermite.layout('unified');	459		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/blob-text.html +1 -0


@@ -448,6 +448,7 @@
448	448		k-r from:body -> ermite.tab('r');
449	449		k-m from:body -> ermite.tab('m');
450	450		k-i from:body -> ermite.tab('i');
	451	+	k-inbox from:body -> ermite.go('[data-inbox]');
451	452		k-next from:body -> ermite.nextNote();
452	453		k-split from:body -> ermite.layout('split');
453	454		k-unified from:body -> ermite.layout('unified');


@@ -448,6 +448,7 @@
448	k-r from:body -> ermite.tab('r');	448		k-r from:body -> ermite.tab('r');
449	k-m from:body -> ermite.tab('m');	449		k-m from:body -> ermite.tab('m');
450	k-i from:body -> ermite.tab('i');	450		k-i from:body -> ermite.tab('i');
		451	+	k-inbox from:body -> ermite.go('[data-inbox]');
451	k-next from:body -> ermite.nextNote();	452		k-next from:body -> ermite.nextNote();
452	k-split from:body -> ermite.layout('split');	453		k-split from:body -> ermite.layout('split');
453	k-unified from:body -> ermite.layout('unified');	454		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/blob-too-large.html +1 -0


@@ -428,6 +428,7 @@
428	428		k-r from:body -> ermite.tab('r');
429	429		k-m from:body -> ermite.tab('m');
430	430		k-i from:body -> ermite.tab('i');
	431	+	k-inbox from:body -> ermite.go('[data-inbox]');
431	432		k-next from:body -> ermite.nextNote();
432	433		k-split from:body -> ermite.layout('split');
433	434		k-unified from:body -> ermite.layout('unified');


@@ -428,6 +428,7 @@
428	k-r from:body -> ermite.tab('r');	428		k-r from:body -> ermite.tab('r');
429	k-m from:body -> ermite.tab('m');	429		k-m from:body -> ermite.tab('m');
430	k-i from:body -> ermite.tab('i');	430		k-i from:body -> ermite.tab('i');
		431	+	k-inbox from:body -> ermite.go('[data-inbox]');
431	k-next from:body -> ermite.nextNote();	432		k-next from:body -> ermite.nextNote();
432	k-split from:body -> ermite.layout('split');	433		k-split from:body -> ermite.layout('split');
433	k-unified from:body -> ermite.layout('unified');	434		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/blob-trojan.html +1 -0


@@ -495,6 +495,7 @@
495	495		k-r from:body -> ermite.tab('r');
496	496		k-m from:body -> ermite.tab('m');
497	497		k-i from:body -> ermite.tab('i');
	498	+	k-inbox from:body -> ermite.go('[data-inbox]');
498	499		k-next from:body -> ermite.nextNote();
499	500		k-split from:body -> ermite.layout('split');
500	501		k-unified from:body -> ermite.layout('unified');


@@ -495,6 +495,7 @@
495	k-r from:body -> ermite.tab('r');	495		k-r from:body -> ermite.tab('r');
496	k-m from:body -> ermite.tab('m');	496		k-m from:body -> ermite.tab('m');
497	k-i from:body -> ermite.tab('i');	497		k-i from:body -> ermite.tab('i');
		498	+	k-inbox from:body -> ermite.go('[data-inbox]');
498	k-next from:body -> ermite.nextNote();	499		k-next from:body -> ermite.nextNote();
499	k-split from:body -> ermite.layout('split');	500		k-split from:body -> ermite.layout('split');
500	k-unified from:body -> ermite.layout('unified');	501		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commit-big.html +1 -0


@@ -480,6 +480,7 @@
480	480		k-r from:body -> ermite.tab('r');
481	481		k-m from:body -> ermite.tab('m');
482	482		k-i from:body -> ermite.tab('i');
	483	+	k-inbox from:body -> ermite.go('[data-inbox]');
483	484		k-next from:body -> ermite.nextNote();
484	485		k-split from:body -> ermite.layout('split');
485	486		k-unified from:body -> ermite.layout('unified');


@@ -480,6 +480,7 @@
480	k-r from:body -> ermite.tab('r');	480		k-r from:body -> ermite.tab('r');
481	k-m from:body -> ermite.tab('m');	481		k-m from:body -> ermite.tab('m');
482	k-i from:body -> ermite.tab('i');	482		k-i from:body -> ermite.tab('i');
		483	+	k-inbox from:body -> ermite.go('[data-inbox]');
483	k-next from:body -> ermite.nextNote();	484		k-next from:body -> ermite.nextNote();
484	k-split from:body -> ermite.layout('split');	485		k-split from:body -> ermite.layout('split');
485	k-unified from:body -> ermite.layout('unified');	486		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commit-binary.html +1 -0


@@ -471,6 +471,7 @@
471	471		k-r from:body -> ermite.tab('r');
472	472		k-m from:body -> ermite.tab('m');
473	473		k-i from:body -> ermite.tab('i');
	474	+	k-inbox from:body -> ermite.go('[data-inbox]');
474	475		k-next from:body -> ermite.nextNote();
475	476		k-split from:body -> ermite.layout('split');
476	477		k-unified from:body -> ermite.layout('unified');


@@ -471,6 +471,7 @@
471	k-r from:body -> ermite.tab('r');	471		k-r from:body -> ermite.tab('r');
472	k-m from:body -> ermite.tab('m');	472		k-m from:body -> ermite.tab('m');
473	k-i from:body -> ermite.tab('i');	473		k-i from:body -> ermite.tab('i');
		474	+	k-inbox from:body -> ermite.go('[data-inbox]');
474	k-next from:body -> ermite.nextNote();	475		k-next from:body -> ermite.nextNote();
475	k-split from:body -> ermite.layout('split');	476		k-split from:body -> ermite.layout('split');
476	k-unified from:body -> ermite.layout('unified');	477		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commit-merge.html +1 -0


@@ -513,6 +513,7 @@
513	513		k-r from:body -> ermite.tab('r');
514	514		k-m from:body -> ermite.tab('m');
515	515		k-i from:body -> ermite.tab('i');
	516	+	k-inbox from:body -> ermite.go('[data-inbox]');
516	517		k-next from:body -> ermite.nextNote();
517	518		k-split from:body -> ermite.layout('split');
518	519		k-unified from:body -> ermite.layout('unified');


@@ -513,6 +513,7 @@
513	k-r from:body -> ermite.tab('r');	513		k-r from:body -> ermite.tab('r');
514	k-m from:body -> ermite.tab('m');	514		k-m from:body -> ermite.tab('m');
515	k-i from:body -> ermite.tab('i');	515		k-i from:body -> ermite.tab('i');
		516	+	k-inbox from:body -> ermite.go('[data-inbox]');
516	k-next from:body -> ermite.nextNote();	517		k-next from:body -> ermite.nextNote();
517	k-split from:body -> ermite.layout('split');	518		k-split from:body -> ermite.layout('split');
518	k-unified from:body -> ermite.layout('unified');	519		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commit-modify-split.html +1 -0


@@ -636,6 +636,7 @@ And <b>html</b> & "quotes".</pre>
636	636		k-r from:body -> ermite.tab('r');
637	637		k-m from:body -> ermite.tab('m');
638	638		k-i from:body -> ermite.tab('i');
	639	+	k-inbox from:body -> ermite.go('[data-inbox]');
639	640		k-next from:body -> ermite.nextNote();
640	641		k-split from:body -> ermite.layout('split');
641	642		k-unified from:body -> ermite.layout('unified');


@@ -636,6 +636,7 @@ And <b>html</b> & "quotes".</pre>
636	k-r from:body -> ermite.tab('r');	636		k-r from:body -> ermite.tab('r');
637	k-m from:body -> ermite.tab('m');	637		k-m from:body -> ermite.tab('m');
638	k-i from:body -> ermite.tab('i');	638		k-i from:body -> ermite.tab('i');
		639	+	k-inbox from:body -> ermite.go('[data-inbox]');
639	k-next from:body -> ermite.nextNote();	640		k-next from:body -> ermite.nextNote();
640	k-split from:body -> ermite.layout('split');	641		k-split from:body -> ermite.layout('split');
641	k-unified from:body -> ermite.layout('unified');	642		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commit-modify.html +1 -0


@@ -636,6 +636,7 @@ And <b>html</b> & "quotes".</pre>
636	636		k-r from:body -> ermite.tab('r');
637	637		k-m from:body -> ermite.tab('m');
638	638		k-i from:body -> ermite.tab('i');
	639	+	k-inbox from:body -> ermite.go('[data-inbox]');
639	640		k-next from:body -> ermite.nextNote();
640	641		k-split from:body -> ermite.layout('split');
641	642		k-unified from:body -> ermite.layout('unified');


@@ -636,6 +636,7 @@ And <b>html</b> & "quotes".</pre>
636	k-r from:body -> ermite.tab('r');	636		k-r from:body -> ermite.tab('r');
637	k-m from:body -> ermite.tab('m');	637		k-m from:body -> ermite.tab('m');
638	k-i from:body -> ermite.tab('i');	638		k-i from:body -> ermite.tab('i');
		639	+	k-inbox from:body -> ermite.go('[data-inbox]');
639	k-next from:body -> ermite.nextNote();	640		k-next from:body -> ermite.nextNote();
640	k-split from:body -> ermite.layout('split');	641		k-split from:body -> ermite.layout('split');
641	k-unified from:body -> ermite.layout('unified');	642		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commit-rename.html +1 -0


@@ -540,6 +540,7 @@
540	540		k-r from:body -> ermite.tab('r');
541	541		k-m from:body -> ermite.tab('m');
542	542		k-i from:body -> ermite.tab('i');
	543	+	k-inbox from:body -> ermite.go('[data-inbox]');
543	544		k-next from:body -> ermite.nextNote();
544	545		k-split from:body -> ermite.layout('split');
545	546		k-unified from:body -> ermite.layout('unified');


@@ -540,6 +540,7 @@
540	k-r from:body -> ermite.tab('r');	540		k-r from:body -> ermite.tab('r');
541	k-m from:body -> ermite.tab('m');	541		k-m from:body -> ermite.tab('m');
542	k-i from:body -> ermite.tab('i');	542		k-i from:body -> ermite.tab('i');
		543	+	k-inbox from:body -> ermite.go('[data-inbox]');
543	k-next from:body -> ermite.nextNote();	544		k-next from:body -> ermite.nextNote();
544	k-split from:body -> ermite.layout('split');	545		k-split from:body -> ermite.layout('split');
545	k-unified from:body -> ermite.layout('unified');	546		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commit-root.html +1 -0


@@ -859,6 +859,7 @@
859	859		k-r from:body -> ermite.tab('r');
860	860		k-m from:body -> ermite.tab('m');
861	861		k-i from:body -> ermite.tab('i');
	862	+	k-inbox from:body -> ermite.go('[data-inbox]');
862	863		k-next from:body -> ermite.nextNote();
863	864		k-split from:body -> ermite.layout('split');
864	865		k-unified from:body -> ermite.layout('unified');


@@ -859,6 +859,7 @@
859	k-r from:body -> ermite.tab('r');	859		k-r from:body -> ermite.tab('r');
860	k-m from:body -> ermite.tab('m');	860		k-m from:body -> ermite.tab('m');
861	k-i from:body -> ermite.tab('i');	861		k-i from:body -> ermite.tab('i');
		862	+	k-inbox from:body -> ermite.go('[data-inbox]');
862	k-next from:body -> ermite.nextNote();	863		k-next from:body -> ermite.nextNote();
863	k-split from:body -> ermite.layout('split');	864		k-split from:body -> ermite.layout('split');
864	k-unified from:body -> ermite.layout('unified');	865		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commit-trojan.html +1 -0


@@ -688,6 +688,7 @@
688	688		k-r from:body -> ermite.tab('r');
689	689		k-m from:body -> ermite.tab('m');
690	690		k-i from:body -> ermite.tab('i');
	691	+	k-inbox from:body -> ermite.go('[data-inbox]');
691	692		k-next from:body -> ermite.nextNote();
692	693		k-split from:body -> ermite.layout('split');
693	694		k-unified from:body -> ermite.layout('unified');


@@ -688,6 +688,7 @@
688	k-r from:body -> ermite.tab('r');	688		k-r from:body -> ermite.tab('r');
689	k-m from:body -> ermite.tab('m');	689		k-m from:body -> ermite.tab('m');
690	k-i from:body -> ermite.tab('i');	690		k-i from:body -> ermite.tab('i');
		691	+	k-inbox from:body -> ermite.go('[data-inbox]');
691	k-next from:body -> ermite.nextNote();	692		k-next from:body -> ermite.nextNote();
692	k-split from:body -> ermite.layout('split');	693		k-split from:body -> ermite.layout('split');
693	k-unified from:body -> ermite.layout('unified');	694		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commits-page2.html +1 -0


@@ -441,6 +441,7 @@
441	441		k-r from:body -> ermite.tab('r');
442	442		k-m from:body -> ermite.tab('m');
443	443		k-i from:body -> ermite.tab('i');
	444	+	k-inbox from:body -> ermite.go('[data-inbox]');
444	445		k-next from:body -> ermite.nextNote();
445	446		k-split from:body -> ermite.layout('split');
446	447		k-unified from:body -> ermite.layout('unified');


@@ -441,6 +441,7 @@
441	k-r from:body -> ermite.tab('r');	441		k-r from:body -> ermite.tab('r');
442	k-m from:body -> ermite.tab('m');	442		k-m from:body -> ermite.tab('m');
443	k-i from:body -> ermite.tab('i');	443		k-i from:body -> ermite.tab('i');
		444	+	k-inbox from:body -> ermite.go('[data-inbox]');
444	k-next from:body -> ermite.nextNote();	445		k-next from:body -> ermite.nextNote();
445	k-split from:body -> ermite.layout('split');	446		k-split from:body -> ermite.layout('split');
446	k-unified from:body -> ermite.layout('unified');	447		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commits-path.html +1 -0


@@ -456,6 +456,7 @@
456	456		k-r from:body -> ermite.tab('r');
457	457		k-m from:body -> ermite.tab('m');
458	458		k-i from:body -> ermite.tab('i');
	459	+	k-inbox from:body -> ermite.go('[data-inbox]');
459	460		k-next from:body -> ermite.nextNote();
460	461		k-split from:body -> ermite.layout('split');
461	462		k-unified from:body -> ermite.layout('unified');


@@ -456,6 +456,7 @@
456	k-r from:body -> ermite.tab('r');	456		k-r from:body -> ermite.tab('r');
457	k-m from:body -> ermite.tab('m');	457		k-m from:body -> ermite.tab('m');
458	k-i from:body -> ermite.tab('i');	458		k-i from:body -> ermite.tab('i');
		459	+	k-inbox from:body -> ermite.go('[data-inbox]');
459	k-next from:body -> ermite.nextNote();	460		k-next from:body -> ermite.nextNote();
460	k-split from:body -> ermite.layout('split');	461		k-split from:body -> ermite.layout('split');
461	k-unified from:body -> ermite.layout('unified');	462		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commits-root.html +1 -0


@@ -1246,6 +1246,7 @@
1246	1246		k-r from:body -> ermite.tab('r');
1247	1247		k-m from:body -> ermite.tab('m');
1248	1248		k-i from:body -> ermite.tab('i');
	1249	+	k-inbox from:body -> ermite.go('[data-inbox]');
1249	1250		k-next from:body -> ermite.nextNote();
1250	1251		k-split from:body -> ermite.layout('split');
1251	1252		k-unified from:body -> ermite.layout('unified');


@@ -1246,6 +1246,7 @@
1246	k-r from:body -> ermite.tab('r');	1246		k-r from:body -> ermite.tab('r');
1247	k-m from:body -> ermite.tab('m');	1247		k-m from:body -> ermite.tab('m');
1248	k-i from:body -> ermite.tab('i');	1248		k-i from:body -> ermite.tab('i');
		1249	+	k-inbox from:body -> ermite.go('[data-inbox]');
1249	k-next from:body -> ermite.nextNote();	1250		k-next from:body -> ermite.nextNote();
1250	k-split from:body -> ermite.layout('split');	1251		k-split from:body -> ermite.layout('split');
1251	k-unified from:body -> ermite.layout('unified');	1252		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/commits-small.html +1 -0


@@ -611,6 +611,7 @@
611	611		k-r from:body -> ermite.tab('r');
612	612		k-m from:body -> ermite.tab('m');
613	613		k-i from:body -> ermite.tab('i');
	614	+	k-inbox from:body -> ermite.go('[data-inbox]');
614	615		k-next from:body -> ermite.nextNote();
615	616		k-split from:body -> ermite.layout('split');
616	617		k-unified from:body -> ermite.layout('unified');


@@ -611,6 +611,7 @@
611	k-r from:body -> ermite.tab('r');	611		k-r from:body -> ermite.tab('r');
612	k-m from:body -> ermite.tab('m');	612		k-m from:body -> ermite.tab('m');
613	k-i from:body -> ermite.tab('i');	613		k-i from:body -> ermite.tab('i');
		614	+	k-inbox from:body -> ermite.go('[data-inbox]');
614	k-next from:body -> ermite.nextNote();	615		k-next from:body -> ermite.nextNote();
615	k-split from:body -> ermite.layout('split');	616		k-split from:body -> ermite.layout('split');
616	k-unified from:body -> ermite.layout('unified');	617		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/empty.html +1 -0


@@ -284,6 +284,7 @@
284	284		k-r from:body -> ermite.tab('r');
285	285		k-m from:body -> ermite.tab('m');
286	286		k-i from:body -> ermite.tab('i');
	287	+	k-inbox from:body -> ermite.go('[data-inbox]');
287	288		k-next from:body -> ermite.nextNote();
288	289		k-split from:body -> ermite.layout('split');
289	290		k-unified from:body -> ermite.layout('unified');


@@ -284,6 +284,7 @@
284	k-r from:body -> ermite.tab('r');	284		k-r from:body -> ermite.tab('r');
285	k-m from:body -> ermite.tab('m');	285		k-m from:body -> ermite.tab('m');
286	k-i from:body -> ermite.tab('i');	286		k-i from:body -> ermite.tab('i');
		287	+	k-inbox from:body -> ermite.go('[data-inbox]');
287	k-next from:body -> ermite.nextNote();	288		k-next from:body -> ermite.nextNote();
288	k-split from:body -> ermite.layout('split');	289		k-split from:body -> ermite.layout('split');
289	k-unified from:body -> ermite.layout('unified');	290		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/home.html +1 -0


@@ -394,6 +394,7 @@
394	394		k-r from:body -> ermite.tab('r');
395	395		k-m from:body -> ermite.tab('m');
396	396		k-i from:body -> ermite.tab('i');
	397	+	k-inbox from:body -> ermite.go('[data-inbox]');
397	398		k-next from:body -> ermite.nextNote();
398	399		k-split from:body -> ermite.layout('split');
399	400		k-unified from:body -> ermite.layout('unified');


@@ -394,6 +394,7 @@
394	k-r from:body -> ermite.tab('r');	394		k-r from:body -> ermite.tab('r');
395	k-m from:body -> ermite.tab('m');	395		k-m from:body -> ermite.tab('m');
396	k-i from:body -> ermite.tab('i');	396		k-i from:body -> ermite.tab('i');
		397	+	k-inbox from:body -> ermite.go('[data-inbox]');
397	k-next from:body -> ermite.nextNote();	398		k-next from:body -> ermite.nextNote();
398	k-split from:body -> ermite.layout('split');	399		k-split from:body -> ermite.layout('split');
399	k-unified from:body -> ermite.layout('unified');	400		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/not-found-page.html +1 -0


@@ -267,6 +267,7 @@
267	267		k-r from:body -> ermite.tab('r');
268	268		k-m from:body -> ermite.tab('m');
269	269		k-i from:body -> ermite.tab('i');
	270	+	k-inbox from:body -> ermite.go('[data-inbox]');
270	271		k-next from:body -> ermite.nextNote();
271	272		k-split from:body -> ermite.layout('split');
272	273		k-unified from:body -> ermite.layout('unified');


@@ -267,6 +267,7 @@
267	k-r from:body -> ermite.tab('r');	267		k-r from:body -> ermite.tab('r');
268	k-m from:body -> ermite.tab('m');	268		k-m from:body -> ermite.tab('m');
269	k-i from:body -> ermite.tab('i');	269		k-i from:body -> ermite.tab('i');
		270	+	k-inbox from:body -> ermite.go('[data-inbox]');
270	k-next from:body -> ermite.nextNote();	271		k-next from:body -> ermite.nextNote();
271	k-split from:body -> ermite.layout('split');	272		k-split from:body -> ermite.layout('split');
272	k-unified from:body -> ermite.layout('unified');	273		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/not-found.html +1 -0


@@ -267,6 +267,7 @@
267	267		k-r from:body -> ermite.tab('r');
268	268		k-m from:body -> ermite.tab('m');
269	269		k-i from:body -> ermite.tab('i');
	270	+	k-inbox from:body -> ermite.go('[data-inbox]');
270	271		k-next from:body -> ermite.nextNote();
271	272		k-split from:body -> ermite.layout('split');
272	273		k-unified from:body -> ermite.layout('unified');


@@ -267,6 +267,7 @@
267	k-r from:body -> ermite.tab('r');	267		k-r from:body -> ermite.tab('r');
268	k-m from:body -> ermite.tab('m');	268		k-m from:body -> ermite.tab('m');
269	k-i from:body -> ermite.tab('i');	269		k-i from:body -> ermite.tab('i');
		270	+	k-inbox from:body -> ermite.go('[data-inbox]');
270	k-next from:body -> ermite.nextNote();	271		k-next from:body -> ermite.nextNote();
271	k-split from:body -> ermite.layout('split');	272		k-split from:body -> ermite.layout('split');
272	k-unified from:body -> ermite.layout('unified');	273		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/refs.html +1 -0


@@ -503,6 +503,7 @@
503	503		k-r from:body -> ermite.tab('r');
504	504		k-m from:body -> ermite.tab('m');
505	505		k-i from:body -> ermite.tab('i');
	506	+	k-inbox from:body -> ermite.go('[data-inbox]');
506	507		k-next from:body -> ermite.nextNote();
507	508		k-split from:body -> ermite.layout('split');
508	509		k-unified from:body -> ermite.layout('unified');


@@ -503,6 +503,7 @@
503	k-r from:body -> ermite.tab('r');	503		k-r from:body -> ermite.tab('r');
504	k-m from:body -> ermite.tab('m');	504		k-m from:body -> ermite.tab('m');
505	k-i from:body -> ermite.tab('i');	505		k-i from:body -> ermite.tab('i');
		506	+	k-inbox from:body -> ermite.go('[data-inbox]');
506	k-next from:body -> ermite.nextNote();	507		k-next from:body -> ermite.nextNote();
507	k-split from:body -> ermite.layout('split');	508		k-split from:body -> ermite.layout('split');
508	k-unified from:body -> ermite.layout('unified');	509		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/summary.html +1 -0


@@ -529,6 +529,7 @@
529	529		k-r from:body -> ermite.tab('r');
530	530		k-m from:body -> ermite.tab('m');
531	531		k-i from:body -> ermite.tab('i');
	532	+	k-inbox from:body -> ermite.go('[data-inbox]');
532	533		k-next from:body -> ermite.nextNote();
533	534		k-split from:body -> ermite.layout('split');
534	535		k-unified from:body -> ermite.layout('unified');


@@ -529,6 +529,7 @@
529	k-r from:body -> ermite.tab('r');	529		k-r from:body -> ermite.tab('r');
530	k-m from:body -> ermite.tab('m');	530		k-m from:body -> ermite.tab('m');
531	k-i from:body -> ermite.tab('i');	531		k-i from:body -> ermite.tab('i');
		532	+	k-inbox from:body -> ermite.go('[data-inbox]');
532	k-next from:body -> ermite.nextNote();	533		k-next from:body -> ermite.nextNote();
533	k-split from:body -> ermite.layout('split');	534		k-split from:body -> ermite.layout('split');
534	k-unified from:body -> ermite.layout('unified');	535		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/tree-nested.html +1 -0


@@ -443,6 +443,7 @@
443	443		k-r from:body -> ermite.tab('r');
444	444		k-m from:body -> ermite.tab('m');
445	445		k-i from:body -> ermite.tab('i');
	446	+	k-inbox from:body -> ermite.go('[data-inbox]');
446	447		k-next from:body -> ermite.nextNote();
447	448		k-split from:body -> ermite.layout('split');
448	449		k-unified from:body -> ermite.layout('unified');


@@ -443,6 +443,7 @@
443	k-r from:body -> ermite.tab('r');	443		k-r from:body -> ermite.tab('r');
444	k-m from:body -> ermite.tab('m');	444		k-m from:body -> ermite.tab('m');
445	k-i from:body -> ermite.tab('i');	445		k-i from:body -> ermite.tab('i');
		446	+	k-inbox from:body -> ermite.go('[data-inbox]');
446	k-next from:body -> ermite.nextNote();	447		k-next from:body -> ermite.nextNote();
447	k-split from:body -> ermite.layout('split');	448		k-split from:body -> ermite.layout('split');
448	k-unified from:body -> ermite.layout('unified');	449		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/tree-root.html +1 -0


@@ -664,6 +664,7 @@
664	664		k-r from:body -> ermite.tab('r');
665	665		k-m from:body -> ermite.tab('m');
666	666		k-i from:body -> ermite.tab('i');
	667	+	k-inbox from:body -> ermite.go('[data-inbox]');
667	668		k-next from:body -> ermite.nextNote();
668	669		k-split from:body -> ermite.layout('split');
669	670		k-unified from:body -> ermite.layout('unified');


@@ -664,6 +664,7 @@
664	k-r from:body -> ermite.tab('r');	664		k-r from:body -> ermite.tab('r');
665	k-m from:body -> ermite.tab('m');	665		k-m from:body -> ermite.tab('m');
666	k-i from:body -> ermite.tab('i');	666		k-i from:body -> ermite.tab('i');
		667	+	k-inbox from:body -> ermite.go('[data-inbox]');
667	k-next from:body -> ermite.nextNote();	668		k-next from:body -> ermite.nextNote();
668	k-split from:body -> ermite.layout('split');	669		k-split from:body -> ermite.layout('split');
669	k-unified from:body -> ermite.layout('unified');	670		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/tree-slash-ref.html +1 -0


@@ -440,6 +440,7 @@
440	440		k-r from:body -> ermite.tab('r');
441	441		k-m from:body -> ermite.tab('m');
442	442		k-i from:body -> ermite.tab('i');
	443	+	k-inbox from:body -> ermite.go('[data-inbox]');
443	444		k-next from:body -> ermite.nextNote();
444	445		k-split from:body -> ermite.layout('split');
445	446		k-unified from:body -> ermite.layout('unified');


@@ -440,6 +440,7 @@
440	k-r from:body -> ermite.tab('r');	440		k-r from:body -> ermite.tab('r');
441	k-m from:body -> ermite.tab('m');	441		k-m from:body -> ermite.tab('m');
442	k-i from:body -> ermite.tab('i');	442		k-i from:body -> ermite.tab('i');
		443	+	k-inbox from:body -> ermite.go('[data-inbox]');
443	k-next from:body -> ermite.nextNote();	444		k-next from:body -> ermite.nextNote();
444	k-split from:body -> ermite.layout('split');	445		k-split from:body -> ermite.layout('split');
445	k-unified from:body -> ermite.layout('unified');	446		k-unified from:body -> ermite.layout('unified');

M internal/app/testdata/web/tree-subdir.html +1 -0


@@ -456,6 +456,7 @@
456	456		k-r from:body -> ermite.tab('r');
457	457		k-m from:body -> ermite.tab('m');
458	458		k-i from:body -> ermite.tab('i');
	459	+	k-inbox from:body -> ermite.go('[data-inbox]');
459	460		k-next from:body -> ermite.nextNote();
460	461		k-split from:body -> ermite.layout('split');
461	462		k-unified from:body -> ermite.layout('unified');


@@ -456,6 +456,7 @@
456	k-r from:body -> ermite.tab('r');	456		k-r from:body -> ermite.tab('r');
457	k-m from:body -> ermite.tab('m');	457		k-m from:body -> ermite.tab('m');
458	k-i from:body -> ermite.tab('i');	458		k-i from:body -> ermite.tab('i');
		459	+	k-inbox from:body -> ermite.go('[data-inbox]');
459	k-next from:body -> ermite.nextNote();	460		k-next from:body -> ermite.nextNote();
460	k-split from:body -> ermite.layout('split');	461		k-split from:body -> ermite.layout('split');
461	k-unified from:body -> ermite.layout('unified');	462		k-unified from:body -> ermite.layout('unified');

M internal/app/web_inbox_test.go +32 -2


@@ -8,6 +8,7 @@ import (
8	8		"net/http"
9	9		"strings"
10	10		"testing"
	11	+	"time"
11	12
12	13		"github.com/stretchr/testify/assert"
13	14		"github.com/stretchr/testify/require"

@@ -42,22 +43,51 @@ func TestWebInboxEndToEnd(t *testing.T) {
42	43		assert.Contains(t, empty.body, "no open merge requests.")
43	44		assert.Contains(t, empty.body, "no open issues.")
44	45
	46	+	// A queued run is visible and its run-level events refresh the owner stream.
	47	+	draft, err := r.forge.store.CI().CreateRun(r.ctx, r.name("proj"), ".github/workflows/build.yml", func(id, number int64) ports.CIRunDraft {
	48	+	return ports.CIRunDraft{Run: domain.CIRun{Repo: r.name("proj"), ID: id, Number: number, Attempt: 1, WorkflowName: "Inbox build", Status: domain.CIQueued, Ref: "refs/heads/main", Event: "push", CreatedAt: time.Now()}}
	49	+	})
	50	+	require.NoError(t, err)
	51	+	runs := b.get("/-/inbox", as(token))
	52	+	assert.Contains(t, runs.body, "Inbox build")
	53	+	assert.Contains(t, runs.body, "<strong>1</strong> running")
	54	+	assert.Contains(t, runs.body, `data-inbox href="/-/inbox"`)
	55	+
45	56		// The owner stream sees both repositories.
46	57		stream := ownerStream(t, r.harness, token)
47	58
	59	+	r.forge.Bus.Publish(r.ctx, domain.RunUpdated{Run: draft.Run, At: time.Now(), Visibility: domain.VisibilityPublic, CreatedAt: time.Now()})
	60	+	var runFragments strings.Builder
	61	+	for range 6 {
	62	+	runFragments.WriteString(nextFragment(t, stream).data)
	63	+	}
	64	+	assert.Contains(t, runFragments.String(), "Inbox build")
	65	+	// Completion removes the row and updates the total in the same live fragments.
	66	+	draft.Run.Status, draft.Run.Conclusion = domain.CICompleted, domain.CISuccess
	67	+	_, err = r.forge.store.CI().Apply(r.ctx, ports.CIWrite{Runs: []domain.CIRun{draft.Run}})
	68	+	require.NoError(t, err)
	69	+	r.forge.Bus.Publish(r.ctx, domain.RunUpdated{Run: draft.Run, At: time.Now(), Visibility: domain.VisibilityPublic, CreatedAt: time.Now()})
	70	+	runFragments.Reset()
	71	+	for range 6 {
	72	+	runFragments.WriteString(nextFragment(t, stream).data)
	73	+	}
	74	+	assert.NotContains(t, runFragments.String(), "Inbox build")
	75	+	assert.Contains(t, runFragments.String(), "no runs in progress.")
	76	+	assert.Contains(t, runFragments.String(), "<strong>0</strong> running")
	77	+
48	78		root := domain.Root()
49	79		_, err = r.forge.MergeRequests.Create(r.ctx, root, r.name("proj"), ports.CreateMergeRequestParams{Title: "add search", Source: "feat/search", Target: "main"})
50	80		require.NoError(t, err)
51	81		ev := nextFragment(t, stream)
52	82		assert.Equal(t, "inbox", ev.name)
53	83		assert.Contains(t, ev.data, `id="inbox-counts"`)
54		-	for range 4 { // the other fragments of this event
	84	+	for range 5 { // the other fragments of this event
55	85		nextFragment(t, stream)
56	86		}
57	87		_, err = r.forge.Issues.Create(r.ctx, root, r.name("other"), ports.CreateIssueParams{Title: "search is slow"})
58	88		require.NoError(t, err)
59	89		var seen strings.Builder
60		-	for range 5 { // the five fragments of this event
	90	+	for range 6 { // the six fragments of this event
61	91		seen.WriteString(nextFragment(t, stream).data)
62	92		}
63	93		assert.Contains(t, seen.String(), "search is slow", "an event of the second repository")


@@ -8,6 +8,7 @@ import (
8		"net/http"	8		"net/http"
9		"strings"	9		"strings"
10		"testing"	10		"testing"
			11	+	"time"
11			12
12		"github.com/stretchr/testify/assert"	13		"github.com/stretchr/testify/assert"
13		"github.com/stretchr/testify/require"	14		"github.com/stretchr/testify/require"

@@ -42,22 +43,51 @@ func TestWebInboxEndToEnd(t *testing.T) {
42		assert.Contains(t, empty.body, "no open merge requests.")	43		assert.Contains(t, empty.body, "no open merge requests.")
43		assert.Contains(t, empty.body, "no open issues.")	44		assert.Contains(t, empty.body, "no open issues.")
44			45
			46	+	// A queued run is visible and its run-level events refresh the owner stream.
			47	+	draft, err := r.forge.store.CI().CreateRun(r.ctx, r.name("proj"), ".github/workflows/build.yml", func(id, number int64) ports.CIRunDraft {
			48	+	return ports.CIRunDraft{Run: domain.CIRun{Repo: r.name("proj"), ID: id, Number: number, Attempt: 1, WorkflowName: "Inbox build", Status: domain.CIQueued, Ref: "refs/heads/main", Event: "push", CreatedAt: time.Now()}}
			49	+	})
			50	+	require.NoError(t, err)
			51	+	runs := b.get("/-/inbox", as(token))
			52	+	assert.Contains(t, runs.body, "Inbox build")
			53	+	assert.Contains(t, runs.body, "<strong>1</strong> running")
			54	+	assert.Contains(t, runs.body, `data-inbox href="/-/inbox"`)
			55	+
45		// The owner stream sees both repositories.	56		// The owner stream sees both repositories.
46		stream := ownerStream(t, r.harness, token)	57		stream := ownerStream(t, r.harness, token)
47			58
			59	+	r.forge.Bus.Publish(r.ctx, domain.RunUpdated{Run: draft.Run, At: time.Now(), Visibility: domain.VisibilityPublic, CreatedAt: time.Now()})
			60	+	var runFragments strings.Builder
			61	+	for range 6 {
			62	+	runFragments.WriteString(nextFragment(t, stream).data)
			63	+	}
			64	+	assert.Contains(t, runFragments.String(), "Inbox build")
			65	+	// Completion removes the row and updates the total in the same live fragments.
			66	+	draft.Run.Status, draft.Run.Conclusion = domain.CICompleted, domain.CISuccess
			67	+	_, err = r.forge.store.CI().Apply(r.ctx, ports.CIWrite{Runs: []domain.CIRun{draft.Run}})
			68	+	require.NoError(t, err)
			69	+	r.forge.Bus.Publish(r.ctx, domain.RunUpdated{Run: draft.Run, At: time.Now(), Visibility: domain.VisibilityPublic, CreatedAt: time.Now()})
			70	+	runFragments.Reset()
			71	+	for range 6 {
			72	+	runFragments.WriteString(nextFragment(t, stream).data)
			73	+	}
			74	+	assert.NotContains(t, runFragments.String(), "Inbox build")
			75	+	assert.Contains(t, runFragments.String(), "no runs in progress.")
			76	+	assert.Contains(t, runFragments.String(), "<strong>0</strong> running")
			77	+
48		root := domain.Root()	78		root := domain.Root()
49		_, err = r.forge.MergeRequests.Create(r.ctx, root, r.name("proj"), ports.CreateMergeRequestParams{Title: "add search", Source: "feat/search", Target: "main"})	79		_, err = r.forge.MergeRequests.Create(r.ctx, root, r.name("proj"), ports.CreateMergeRequestParams{Title: "add search", Source: "feat/search", Target: "main"})
50		require.NoError(t, err)	80		require.NoError(t, err)
51		ev := nextFragment(t, stream)	81		ev := nextFragment(t, stream)
52		assert.Equal(t, "inbox", ev.name)	82		assert.Equal(t, "inbox", ev.name)
53		assert.Contains(t, ev.data, `id="inbox-counts"`)	83		assert.Contains(t, ev.data, `id="inbox-counts"`)
54	-	for range 4 { // the other fragments of this event	84	+	for range 5 { // the other fragments of this event
55		nextFragment(t, stream)	85		nextFragment(t, stream)
56		}	86		}
57		_, err = r.forge.Issues.Create(r.ctx, root, r.name("other"), ports.CreateIssueParams{Title: "search is slow"})	87		_, err = r.forge.Issues.Create(r.ctx, root, r.name("other"), ports.CreateIssueParams{Title: "search is slow"})
58		require.NoError(t, err)	88		require.NoError(t, err)
59		var seen strings.Builder	89		var seen strings.Builder
60	-	for range 5 { // the five fragments of this event	90	+	for range 6 { // the six fragments of this event
61		seen.WriteString(nextFragment(t, stream).data)	91		seen.WriteString(nextFragment(t, stream).data)
62		}	92		}
63		assert.Contains(t, seen.String(), "search is slow", "an event of the second repository")	93		assert.Contains(t, seen.String(), "search is slow", "an event of the second repository")

M internal/ports/dto.go +6 -3


@@ -408,13 +408,16 @@ type LoginLink struct {
408	408
409	409		// InboxCounts are the numbers of open items across every repository, whatever
410	410		// the filter.
411		-	type InboxCounts struct{ MergeRequests, Issues, Pending int }
	411	+	type InboxCounts struct{ MergeRequests, Issues, Pending, Running int }
412	412
413	413		// InboxOverview is what the owner has to look at across every repository: the
414		-	// open merge requests and the open issues, most recently updated first. A
415		-	// section for the items awaiting moderation can be added next to them.
	414	+	// open merge requests and issues, ongoing CI runs, and issues awaiting moderation.
416	415		type InboxOverview struct {
417	416		Counts InboxCounts
	417	+	// Runs are queued or in progress, newest first, respecting the filter.
	418	+	Runs []domain.CIRun
	419	+	// RunsEnabled distinguishes disabled CI from an empty queue.
	420	+	RunsEnabled bool
418	421		// MergeRequests and Issues are those of the filtered repository, or of
419	422		// every repository when there is no filter. Counts always counts all.
420	423		MergeRequests []domain.MergeRequest

 // InboxCounts are the numbers of open items across every repository, whatever
 // the filter.
-type InboxCounts struct{ MergeRequests, Issues, Pending int }
+type InboxCounts struct{ MergeRequests, Issues, Pending, Running int }
 // InboxOverview is what the owner has to look at across every repository: the
-// open merge requests and the open issues, most recently updated first. A
+// open merge requests and issues, ongoing CI runs, and issues awaiting moderation.
-// section for the items awaiting moderation can be added next to them.
 type InboxOverview struct {
 	Counts InboxCounts
+	// Runs are queued or in progress, newest first, respecting the filter.
+	Runs []domain.CIRun
+	// RunsEnabled distinguishes disabled CI from an empty queue.
+	RunsEnabled bool
 	// MergeRequests and Issues are those of the filtered repository, or of
 	// every repository when there is no filter. Counts always counts all.
 	MergeRequests []domain.MergeRequest

M internal/usecase/events.go +2 -2


@@ -690,12 +690,12 @@ func isRepoLifecycleEvent(ev domain.Event) bool {
690	690		return false
691	691		}
692	692
693		-	// isItemEvent reports whether ev is about a merge request or an issue.
	693	+	// isItemEvent reports whether ev changes an inbox item, including CI runs.
694	694		func isItemEvent(ev domain.Event) bool {
695	695		switch ev.(type) {
696	696		case domain.IssueReferenced:
697	697		return false // back-reference refreshes do not change the inbox
698		-	case domain.MergeRequestOpened, domain.MergeRequestMerged, domain.MergeRequestClosed,
	698	+	case domain.RunUpdated, domain.MergeRequestOpened, domain.MergeRequestMerged, domain.MergeRequestClosed,
699	699		domain.MergeRequestAutoMergeEnabled, domain.MergeRequestAutoMergeCancelled,
700	700		domain.MergeRequestReady, domain.MergeRequestMergeability, domain.CommentAdded,
701	701		domain.CommentEdited, domain.CommentDeleted, domain.CommentResolved:


@@ -690,12 +690,12 @@ func isRepoLifecycleEvent(ev domain.Event) bool {
690		return false	690		return false
691		}	691		}
692			692
693	-	// isItemEvent reports whether ev is about a merge request or an issue.	693	+	// isItemEvent reports whether ev changes an inbox item, including CI runs.
694		func isItemEvent(ev domain.Event) bool {	694		func isItemEvent(ev domain.Event) bool {
695		switch ev.(type) {	695		switch ev.(type) {
696		case domain.IssueReferenced:	696		case domain.IssueReferenced:
697		return false // back-reference refreshes do not change the inbox	697		return false // back-reference refreshes do not change the inbox
698	-	case domain.MergeRequestOpened, domain.MergeRequestMerged, domain.MergeRequestClosed,	698	+	case domain.RunUpdated, domain.MergeRequestOpened, domain.MergeRequestMerged, domain.MergeRequestClosed,
699		domain.MergeRequestAutoMergeEnabled, domain.MergeRequestAutoMergeCancelled,	699		domain.MergeRequestAutoMergeEnabled, domain.MergeRequestAutoMergeCancelled,
700		domain.MergeRequestReady, domain.MergeRequestMergeability, domain.CommentAdded,	700		domain.MergeRequestReady, domain.MergeRequestMergeability, domain.CommentAdded,
701		domain.CommentEdited, domain.CommentDeleted, domain.CommentResolved:	701		domain.CommentEdited, domain.CommentDeleted, domain.CommentResolved:

M internal/usecase/inbox.go +31 -2


@@ -24,11 +24,12 @@ type Inbox struct {
24	24		issues ports.IssueStore
25	25		// pending is nil when the public form is not wired.
26	26		pending ports.PendingIssueStore
	27	+	ci ports.CIStore
27	28		}
28	29
29	30		var _ ports.InboxService = (*Inbox)(nil)
30	31
31		-	// InboxConfig holds what the inbox needs. Every field is required.
	32	+	// InboxConfig holds what the inbox needs; Pending and CI are optional.
32	33		type InboxConfig struct {
33	34		Meta ports.RepoMetaStore
34	35		MergeRequests ports.MergeRequestStore

@@ -36,11 +37,12 @@ type InboxConfig struct {
36	37		// Pending lists the issues awaiting moderation. Optional: without it the
37	38		// inbox has no pending section.
38	39		Pending ports.PendingIssueStore
	40	+	CI ports.CIStore
39	41		}
40	42
41	43		// NewInbox builds the inbox use case.
42	44		func NewInbox(cfg InboxConfig) *Inbox {
43		-	return &Inbox{meta: cfg.Meta, mrs: cfg.MergeRequests, issues: cfg.Issues, pending: cfg.Pending}
	45	+	return &Inbox{meta: cfg.Meta, mrs: cfg.MergeRequests, issues: cfg.Issues, pending: cfg.Pending, ci: cfg.CI}
44	46		}
45	47
46	48		// Overview lists what is open, through the indexes of open items. The counts

@@ -126,6 +128,33 @@ func (in *Inbox) Overview(ctx context.Context, p domain.Principal, filter domain
126	128		out.Counts.Pending = len(out.Pending)
127	129		}
128	130
	131	+	if in.ci != nil {
	132	+	out.RunsEnabled = true
	133	+	runs, err := in.ci.ListOpenRuns(ctx)
	134	+	if err != nil {
	135	+	return out, fmt.Errorf("list open runs: %w", err)
	136	+	}
	137	+	for _, run := range runs {
	138	+	if run.Status != domain.CIQueued && run.Status != domain.CIInProgress {
	139	+	continue
	140	+	}
	141	+	if err := look(run.Repo); err != nil {
	142	+	return out, err
	143	+	}
	144	+	if !exists[run.Repo] {
	145	+	continue
	146	+	}
	147	+	repos[run.Repo] = true
	148	+	out.Counts.Running++
	149	+	if filter.IsZero() \|\| run.Repo == filter {
	150	+	out.Runs = append(out.Runs, run)
	151	+	}
	152	+	}
	153	+	slices.SortStableFunc(out.Runs, func(a, b domain.CIRun) int {
	154	+	return compareRecent(a.CreatedAt, a.CreatedAt, a.Repo, a.ID, b.CreatedAt, b.CreatedAt, b.Repo, b.ID)
	155	+	})
	156	+	}
	157	+
129	158		slices.SortStableFunc(out.MergeRequests, func(a, b domain.MergeRequest) int {
130	159		return compareRecent(a.UpdatedAt, a.CreatedAt, a.Repo, a.Number, b.UpdatedAt, b.CreatedAt, b.Repo, b.Number)
131	160		})


@@ -24,11 +24,12 @@ type Inbox struct {
24		issues ports.IssueStore	24		issues ports.IssueStore
25		// pending is nil when the public form is not wired.	25		// pending is nil when the public form is not wired.
26		pending ports.PendingIssueStore	26		pending ports.PendingIssueStore
			27	+	ci ports.CIStore
27		}	28		}
28			29
29		var _ ports.InboxService = (*Inbox)(nil)	30		var _ ports.InboxService = (*Inbox)(nil)
30			31
31	-	// InboxConfig holds what the inbox needs. Every field is required.	32	+	// InboxConfig holds what the inbox needs; Pending and CI are optional.
32		type InboxConfig struct {	33		type InboxConfig struct {
33		Meta ports.RepoMetaStore	34		Meta ports.RepoMetaStore
34		MergeRequests ports.MergeRequestStore	35		MergeRequests ports.MergeRequestStore

@@ -36,11 +37,12 @@ type InboxConfig struct {
36		// Pending lists the issues awaiting moderation. Optional: without it the	37		// Pending lists the issues awaiting moderation. Optional: without it the
37		// inbox has no pending section.	38		// inbox has no pending section.
38		Pending ports.PendingIssueStore	39		Pending ports.PendingIssueStore
			40	+	CI ports.CIStore
39		}	41		}
40			42
41		// NewInbox builds the inbox use case.	43		// NewInbox builds the inbox use case.
42		func NewInbox(cfg InboxConfig) *Inbox {	44		func NewInbox(cfg InboxConfig) *Inbox {
43	-	return &Inbox{meta: cfg.Meta, mrs: cfg.MergeRequests, issues: cfg.Issues, pending: cfg.Pending}	45	+	return &Inbox{meta: cfg.Meta, mrs: cfg.MergeRequests, issues: cfg.Issues, pending: cfg.Pending, ci: cfg.CI}
44		}	46		}
45			47
46		// Overview lists what is open, through the indexes of open items. The counts	48		// Overview lists what is open, through the indexes of open items. The counts

@@ -126,6 +128,33 @@ func (in *Inbox) Overview(ctx context.Context, p domain.Principal, filter domain
126		out.Counts.Pending = len(out.Pending)	128		out.Counts.Pending = len(out.Pending)
127		}	129		}
128			130
			131	+	if in.ci != nil {
			132	+	out.RunsEnabled = true
			133	+	runs, err := in.ci.ListOpenRuns(ctx)
			134	+	if err != nil {
			135	+	return out, fmt.Errorf("list open runs: %w", err)
			136	+	}
			137	+	for _, run := range runs {
			138	+	if run.Status != domain.CIQueued && run.Status != domain.CIInProgress {
			139	+	continue
			140	+	}
			141	+	if err := look(run.Repo); err != nil {
			142	+	return out, err
			143	+	}
			144	+	if !exists[run.Repo] {
			145	+	continue
			146	+	}
			147	+	repos[run.Repo] = true
			148	+	out.Counts.Running++
			149	+	if filter.IsZero() \|\| run.Repo == filter {
			150	+	out.Runs = append(out.Runs, run)
			151	+	}
			152	+	}
			153	+	slices.SortStableFunc(out.Runs, func(a, b domain.CIRun) int {
			154	+	return compareRecent(a.CreatedAt, a.CreatedAt, a.Repo, a.ID, b.CreatedAt, b.CreatedAt, b.Repo, b.ID)
			155	+	})
			156	+	}
			157	+
129		slices.SortStableFunc(out.MergeRequests, func(a, b domain.MergeRequest) int {	158		slices.SortStableFunc(out.MergeRequests, func(a, b domain.MergeRequest) int {
130		return compareRecent(a.UpdatedAt, a.CreatedAt, a.Repo, a.Number, b.UpdatedAt, b.CreatedAt, b.Repo, b.Number)	159		return compareRecent(a.UpdatedAt, a.CreatedAt, a.Repo, a.Number, b.UpdatedAt, b.CreatedAt, b.Repo, b.Number)
131		})	160		})

M internal/usecase/inbox_test.go +33 -0


@@ -108,3 +108,36 @@ func TestInboxListsPendingIssuesWithoutTheirHash(t *testing.T) {
108	108		assert.Nil(t, ov.Pending[0].IPHash)
109	109		assert.Equal(t, []domain.RepoName{name(t, "on")}, ov.Repos)
110	110		}
	111	+
	112	+	func TestInboxRuns(t *testing.T) {
	113	+	t.Parallel()
	114	+	mrs, issues, meta, ci := mocks.NewMergeRequestStore(t), mocks.NewIssueStore(t), mocks.NewRepoMetaStore(t), mocks.NewCIStore(t)
	115	+	mrs.EXPECT().ListOpenAll(mock.Anything).Return(nil, nil)
	116	+	issues.EXPECT().ListOpenAll(mock.Anything).Return(nil, nil)
	117	+	now := time.Date(2026, 10, 1, 0, 0, 0, 0, time.UTC)
	118	+	alpha, beta := name(t, "alpha"), name(t, "beta")
	119	+	ci.EXPECT().ListOpenRuns(mock.Anything).Return([]domain.CIRun{
	120	+	{Repo: alpha, ID: 1, Status: domain.CIQueued, CreatedAt: now},
	121	+	{Repo: beta, ID: 2, Status: domain.CIInProgress, CreatedAt: now.Add(time.Hour)},
	122	+	{Repo: alpha, ID: 3, Status: domain.CICompleted, CreatedAt: now.Add(2 * time.Hour)},
	123	+	{Repo: name(t, "gone"), ID: 4, Status: domain.CIQueued, CreatedAt: now},
	124	+	}, nil)
	125	+	for _, n := range []string{"alpha", "beta"} {
	126	+	meta.EXPECT().Get(mock.Anything, name(t, n)).Return(repoWithIssues(t, n, domain.IssuesOff), nil)
	127	+	}
	128	+	meta.EXPECT().Get(mock.Anything, name(t, "gone")).Return(domain.Repo{}, domain.ErrNotFound)
	129	+	in := usecase.NewInbox(usecase.InboxConfig{Meta: meta, MergeRequests: mrs, Issues: issues, CI: ci})
	130	+	all, err := in.Overview(t.Context(), domain.Owner(), domain.RepoName{})
	131	+	require.NoError(t, err)
	132	+	assert.True(t, all.RunsEnabled)
	133	+	assert.Equal(t, 2, all.Counts.Running)
	134	+	require.Len(t, all.Runs, 2)
	135	+	assert.Equal(t, int64(2), all.Runs[0].ID)
	136	+	assert.Equal(t, int64(1), all.Runs[1].ID)
	137	+	assert.Equal(t, []domain.RepoName{alpha, beta}, all.Repos)
	138	+	filtered, err := in.Overview(t.Context(), domain.Owner(), alpha)
	139	+	require.NoError(t, err)
	140	+	assert.Equal(t, 2, filtered.Counts.Running)
	141	+	require.Len(t, filtered.Runs, 1)
	142	+	assert.Equal(t, alpha, filtered.Runs[0].Repo)
	143	+	}


@@ -108,3 +108,36 @@ func TestInboxListsPendingIssuesWithoutTheirHash(t *testing.T) {
108	assert.Nil(t, ov.Pending[0].IPHash)	108		assert.Nil(t, ov.Pending[0].IPHash)
109	assert.Equal(t, []domain.RepoName{name(t, "on")}, ov.Repos)	109		assert.Equal(t, []domain.RepoName{name(t, "on")}, ov.Repos)
110	}	110		}
		111	+
		112	+	func TestInboxRuns(t *testing.T) {
		113	+	t.Parallel()
		114	+	mrs, issues, meta, ci := mocks.NewMergeRequestStore(t), mocks.NewIssueStore(t), mocks.NewRepoMetaStore(t), mocks.NewCIStore(t)
		115	+	mrs.EXPECT().ListOpenAll(mock.Anything).Return(nil, nil)
		116	+	issues.EXPECT().ListOpenAll(mock.Anything).Return(nil, nil)
		117	+	now := time.Date(2026, 10, 1, 0, 0, 0, 0, time.UTC)
		118	+	alpha, beta := name(t, "alpha"), name(t, "beta")
		119	+	ci.EXPECT().ListOpenRuns(mock.Anything).Return([]domain.CIRun{
		120	+	{Repo: alpha, ID: 1, Status: domain.CIQueued, CreatedAt: now},
		121	+	{Repo: beta, ID: 2, Status: domain.CIInProgress, CreatedAt: now.Add(time.Hour)},
		122	+	{Repo: alpha, ID: 3, Status: domain.CICompleted, CreatedAt: now.Add(2 * time.Hour)},
		123	+	{Repo: name(t, "gone"), ID: 4, Status: domain.CIQueued, CreatedAt: now},
		124	+	}, nil)
		125	+	for _, n := range []string{"alpha", "beta"} {
		126	+	meta.EXPECT().Get(mock.Anything, name(t, n)).Return(repoWithIssues(t, n, domain.IssuesOff), nil)
		127	+	}
		128	+	meta.EXPECT().Get(mock.Anything, name(t, "gone")).Return(domain.Repo{}, domain.ErrNotFound)
		129	+	in := usecase.NewInbox(usecase.InboxConfig{Meta: meta, MergeRequests: mrs, Issues: issues, CI: ci})
		130	+	all, err := in.Overview(t.Context(), domain.Owner(), domain.RepoName{})
		131	+	require.NoError(t, err)
		132	+	assert.True(t, all.RunsEnabled)
		133	+	assert.Equal(t, 2, all.Counts.Running)
		134	+	require.Len(t, all.Runs, 2)
		135	+	assert.Equal(t, int64(2), all.Runs[0].ID)
		136	+	assert.Equal(t, int64(1), all.Runs[1].ID)
		137	+	assert.Equal(t, []domain.RepoName{alpha, beta}, all.Repos)
		138	+	filtered, err := in.Overview(t.Context(), domain.Owner(), alpha)
		139	+	require.NoError(t, err)
		140	+	assert.Equal(t, 2, filtered.Counts.Running)
		141	+	require.Len(t, filtered.Runs, 1)
		142	+	assert.Equal(t, alpha, filtered.Runs[0].Repo)
		143	+	}