this repo has no description
plcbundle-watch.pages.dev
tweaks
+48
-11
+48
-11
src/App.svelte
+48
-11
src/App.svelte
···
6
6
import instancesData from './instances.json';
7
7
import numeral from 'numeral';
8
8
9
+
const PLC_DIRECTORY = 'plc.directory'
10
+
const ROOT = 'cbab6809a136d6a621906ee11199d3b0faf85b422fe0d0d2c346ce8e9dcd7485'
9
11
const AUTO_REFRESH_INTERVAL = 15 // in seconds
10
12
const BUNDLE_OPS = 10_000
11
13
···
25
27
26
28
let isUpdating = $state(false)
27
29
let canRefresh = $state(true)
30
+
let isConflict = $state(false)
28
31
let lastUpdated = $state(new Date())
29
32
let autoRefreshEnabled = $state(true)
30
33
let instances = $state(instancesData.sort(() => Math.random() - 0.5))
31
34
32
-
const instanceOrderBy = [['status.head', 'status.latency'], ['desc', 'asc']]
35
+
const instanceOrderBy = [['_head', 'status.latency'], ['desc', 'asc']]
33
36
34
37
function formatNumber(n: number) {
35
38
return numeral(n).format()
···
60
63
if (statusResp) {
61
64
statusResp.latency = performance.now() - start;
62
65
}
66
+
//if (instance.url === 'https://plc.j4ck.xyz') { statusResp.bundles.head_hash = 'f3ad3544452b2c078cba24990486bb9c277a1155'; }
63
67
return statusResp
64
68
}
65
69
70
+
function recalculateHead() {
71
+
isConflict = false
72
+
const headHashes = []
73
+
for (const instance of instances) {
74
+
instance._head = instance.status?.bundles?.last_bundle === lastKnownBundle.number
75
+
if (instance._head) {
76
+
headHashes.push(instance.status?.bundles?.head_hash)
77
+
}
78
+
}
79
+
isConflict = [...new Set(headHashes)].length > 1
80
+
}
81
+
66
82
async function doCheck() {
67
83
isUpdating = true
68
84
canRefresh = false
···
70
86
i.status = undefined
71
87
}
72
88
89
+
const statuses = []
90
+
73
91
await Promise.all(instances.map(async (instance) => {
74
92
const status = await getStatus(instance)
75
-
76
93
instance.status = status
77
-
instance.status.head = status?.bundles?.last_bundle > lastKnownBundle.number
78
-
if (instance.status.head) {
94
+
if (status?.bundles?.last_bundle > lastKnownBundle.number) {
79
95
lastKnownBundle.number = status?.bundles?.last_bundle
80
96
lastKnownBundle.hash = status?.bundles?.head_hash
81
97
lastKnownBundle.time = status?.bundles?.end_time
···
87
103
}
88
104
}
89
105
lastUpdated = new Date()
106
+
107
+
recalculateHead()
90
108
}))
109
+
91
110
isUpdating = false
92
111
setTimeout(() => (canRefresh = false), 1000)
93
112
}
94
113
95
-
onMount(() => {
96
-
doCheck()
114
+
onMount(async () => {
115
+
await doCheck()
97
116
98
117
setTimeout(() => {
99
118
if (autoRefreshEnabled) {
···
128
147
<div>
129
148
<div class="flex items-center gap-5">
130
149
<div class="font-semibold text-3xl">{lastKnownBundle.number}</div>
131
-
<div class="mt-1 font-mono badge preset-outlined-primary-500 text-xs">{lastKnownBundle?.hash?.slice(0, 7)}</div>
150
+
{#if !isConflict}
151
+
<div class="mt-1 font-mono badge preset-outlined-primary-500 text-xs">{lastKnownBundle?.hash?.slice(0, 7)}</div>
152
+
{:else}
153
+
<div class="mt-1 badge preset-filled-error-500">⚠️ conflict!</div>
154
+
{/if}
132
155
</div>
133
156
<div>
134
157
<span class="opacity-50">{#if lastKnownBundle?.time} {formatDistanceToNow(lastKnownBundle.time, { addSuffix: true })}{/if}</span>
···
179
202
{#each orderBy(instances, ...instanceOrderBy) as instance}
180
203
<tr>
181
204
<td><a href={instance.url} target="_blank" class="font-semibold">{instance.url.replace("https://", "")}</a></td>
182
-
<td>{#if instance.status?.bundles?.last_bundle === lastKnownBundle.number}✅{:else if instance.status}🔄{:else}⌛{/if}</td>
205
+
<td>{#if instance._head}{#if isConflict}⚠️{:else}✅{/if}{:else if instance.status}🔄{:else}⌛{/if}</td>
183
206
<td>{#if instance.status?.bundles?.last_bundle}{instance.status?.bundles?.last_bundle}{/if}</td>
184
207
<td>{#if instance.status?.mempool && instance.status?.bundles?.last_bundle === lastKnownBundle.number}{formatNumber(instance.status?.mempool.count)}{:else if instance.status}<span class="opacity-25">syncing</span>{/if}</td>
185
-
<td><span class="font-mono text-xs">{#if instance.status?.bundles?.head_hash}{instance.status?.bundles?.head_hash.slice(0, 7)}{/if}</span></td>
186
-
<td><span class="font-mono text-xs">{#if instance.status?.bundles?.root_hash}{instance.status?.bundles?.root_hash.slice(0, 7)}{/if}</span></td>
208
+
<td><span class="font-mono text-xs {instance._head ? (isConflict ? 'text-error-600' : 'text-success-600') : 'opacity-50'}">{#if instance.status?.bundles?.head_hash}{instance.status?.bundles?.head_hash.slice(0, 7)}{/if}</span></td>
209
+
<td><span class="font-mono text-xs {instance.status ? (instance.status?.bundles?.root_hash === ROOT ? 'text-success-600' : 'text-error-600') : ''}">{#if instance.status?.bundles?.root_hash}{instance.status?.bundles?.root_hash.slice(0, 7)}{/if}</span></td>
187
210
<td>{#if instance.status?.server?.version}{instance.status?.server?.version}{/if}</td>
188
211
<td class="opacity-50">{#if instance.status?.latency}{Math.round(instance.status?.latency)}ms{/if}</td>
189
212
</tr>
···
191
214
</tbody>
192
215
</table>
193
216
194
-
<div class="mt-12 opacity-50">
217
+
218
+
<div class="mt-12">
219
+
<div>
220
+
<span class="opacity-75">PLC Directory:</span> <a href="https://{PLC_DIRECTORY}">{PLC_DIRECTORY}</a> <span class="opacity-50">(origin)</span>
221
+
</div>
222
+
<div class="mt-2">
223
+
<span class="opacity-75">Root:</span> <span class="font-mono text-xs">{ROOT.slice(0)}</span>
224
+
</div>
225
+
</div>
226
+
227
+
<hr class="hr mt-6" />
228
+
<div class="mt-2 opacity-50">
195
229
<div>
196
230
Last updated: {formatISO9075(lastUpdated)}
197
231
</div>
···
199
233
Source: <a href="https://tangled.org/@tree.fail/plcbundle-watch">https://tangled.org/@tree.fail/plcbundle-watch</a>
200
234
</div>
201
235
</div>
236
+
237
+
238
+
202
239
</div>
203
240
</main>
204
241