thirdshift 0.13.0

Turn a GitHub issue into a ready-for-review pull request, unattended
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85

import { activity } from './look.js';
const content = document.querySelector("#log-content");
const follow = document.querySelector("#follow-log");
const status = document.querySelector("#log-status");
const scroll = () => { if (follow.checked) window.scrollTo(0, document.documentElement.scrollHeight); };
follow.addEventListener("change", scroll);
let stream, polling, pollingRequest;
let stopped = false;
function stop() {
  stopped = true;
  stream?.close();
  clearInterval(polling);
  pollingRequest?.abort();
}
function append(batch) {
  if (stopped) return;
  if (batch.offset > Number(content.dataset.offset)) {
    const fragment = document.createElement("template");
    fragment.innerHTML = batch.html;
    const last = content.lastElementChild;
    const first = fragment.content.firstElementChild;
    // A tool sequence crossing a stream batch remains one folded group. Existing
    // nodes (and the reader's open/closed choices) are never replaced.
    if (last?.classList.contains("tool-group") && first?.classList.contains("tool-group")) {
      last.querySelector(".tools").append(...first.querySelector(".tools").childNodes);
      first.remove();
    }
    content.append(fragment.content);
    content.dataset.offset = batch.offset;
    scroll();
  }
  status.textContent = batch.done ? "Complete" : "Live";
  content.dataset.live = String(!batch.done);
  activity();
  if (batch.done) stop();
}
async function poll() {
  if (stopped || pollingRequest) return;
  pollingRequest = new AbortController();
  try {
    const offset = content.dataset.offset;
    const path = content.dataset.stream.replace(/\d+$/, offset);
    const response = await fetch(path, { headers: { accept: 'application/json' }, cache: 'no-store', signal: pollingRequest.signal });
    if (!response.ok || response.redirected) throw new Error('Log unavailable');
    const batch = await response.json();
    // A recovered stream may already have appended part of this batch.
    if (offset === content.dataset.offset) append(batch);
  } catch (error) {
    if (!stopped && error.name !== 'AbortError') status.textContent = 'Connection lost; retrying…';
  } finally { pollingRequest = undefined; }
}
function startPolling() {
  if (stopped) return;
  status.textContent = 'Connection lost; checking for new lines…';
  polling ??= setInterval(poll, 5000);
  poll();
}
function connect() {
  const offset = content.dataset.offset;
  const source = new EventSource(content.dataset.stream.replace(/\d+$/, offset));
  stream = source;
  source.addEventListener('lines', event => {
    if (source === stream) append(JSON.parse(event.data));
  });
  source.addEventListener('open', () => {
    if (stopped || source !== stream) return;
    clearInterval(polling);
    polling = undefined;
    pollingRequest?.abort();
    // Polling may have advanced beyond this connection's starting offset.
    // Resume with a fresh stream so replayed batches cannot overlap the DOM.
    if (offset !== content.dataset.offset) {
      source.close();
      connect();
    }
  });
  source.addEventListener('log-error', event => {
    if (source === stream) { status.textContent = event.data; stop(); }
  });
  source.onerror = () => { if (source === stream) startPolling(); };
}
if (typeof EventSource === 'function') connect();
else startPolling();
window.addEventListener('pagehide', stop);
scroll();