Browse Source

added uptime to lists

feature/heartbeat
dskvr 2 years ago
parent
commit
efd51d403c
  1. 17
      src/components/relays/blocks/RelaysResultTable.vue
  2. 4
      src/components/relays/tasks/HeartbeatTask.vue
  3. 3
      src/components/relays/tasks/RefreshTask.vue
  4. 6
      src/components/relays/tasks/RelayCanonicalsTask.vue
  5. 2
      src/components/relays/tasks/RelayOperatorTask.vue
  6. 4
      src/components/relays/tasks/TasksManager.vue

17
src/components/relays/blocks/RelaysResultTable.vue

@ -41,6 +41,9 @@
<code class="text-xs block">Location</code>
<!-- 🌎 -->
</th>
<th>
Uptime
</th>
<th scope="col" class="latency text-center" v-tooltip:top.tooltip="'Relay Latency on Read'">
<code class="text-xs block">Latency</code>
<!-- -->
@ -94,6 +97,20 @@
<td class="w-24 location text-center">{{ getFlag(relay) }}</td>
<td class="w-24 latency text-center">
<div class="px-4 py-5 sm:px-6 flex">
<span
v-for="heartbeat in this.store.stats.getHeartbeat(relay)"
:key="heartbeat[0]"
class="mr-0 w-0.5 h-5 flex-1"
:class="{
'bg-red-700': !heartbeat.latency,
'bg-green-500': heartbeat.latency
}">
</span>
</div>
</td>
<td class="w-24 latency text-center">
<span>{{ results[relay]?.latency?.final }}<span v-if="results[relay]?.check?.latency">ms</span></span>
</td>

4
src/components/relays/tasks/HeartbeatTask.vue

@ -60,6 +60,8 @@ const localMethods = {
return
uniques.add(event.created_at)
console.log('heartbeat found', event.id)
heartbeatsByEvent[event.created_at] = decodeJson(event.content).online
@ -68,7 +70,7 @@ const localMethods = {
resolve()
pool.unsubscribe(subid)
pool.close()
}, 2000 )
}, 10000 )
})
this.parseHeartbeats(heartbeatsByEvent)

3
src/components/relays/tasks/RefreshTask.vue

@ -158,8 +158,7 @@ const localMethods = {
},
completeAll: function(){
this.store.tasks.completeJob()
this.store.tasks.updateNow(this.taskSlug)
this.store.tasks.completeJob(this.taskSlug)
this.store.relays.setAggregateCache('public', Object.keys(this.results).filter( result => this.results[result].aggregate === 'public' ))
this.store.relays.setAggregateCache('restricted', Object.keys(this.results).filter( result => this.results[result].aggregate === 'restricted' ))
this.store.relays.setAggregateCache('offline', Object.keys(this.results).filter( result => this.results[result].aggregate === 'offline' ))

6
src/components/relays/tasks/RelayCanonicalsTask.vue

@ -47,8 +47,8 @@ const localMethods = {
.on('open', r => {
r.subscribe(subid, {
limit: 1000,
kinds: [1],
"#t": ['canonical'],
kinds: [ 1 ],
"#t": [ 'canonical' ],
authors:[ 'b3b0d247f66bf40c4c9f4ce721abfe1fd3b7529fbc1ea5e64d5f0f8df3a4b6e6' ]
})
})
@ -78,7 +78,7 @@ const localMethods = {
this.store.relays.setCanonicals(this.canonicals)
this.store.tasks.completeJob()
this.store.tasks.completeJob(this.taskSlug)
},
true
)

2
src/components/relays/tasks/RelayOperatorTask.vue

@ -86,7 +86,7 @@ const localMethods = {
console.log( 'event!', event.content )
})
this.store.tasks.completeJob()
this.store.tasks.completeJob(this.taskSlug)
// .on('eose', relay => {
// relay.close()
// })

4
src/components/relays/tasks/TasksManager.vue

@ -15,7 +15,7 @@ import { setupStore } from '@/store'
import SharedComputed from '@/shared/computed.js'
// import RefreshTask from './RefreshTask.vue'
import RefreshTask from './RefreshTask.vue'
import HeartbeatTask from './HeartbeatTask.vue'
// import RelayCanonicalsTask from './RelayCanonicalsTask.vue'
@ -24,7 +24,7 @@ import HeartbeatTask from './HeartbeatTask.vue'
export default defineComponent({
name: "TasksManager",
components: {
// RefreshTask,
RefreshTask,
HeartbeatTask,
// RelayCanonicalsTask,
// RelayOperatorTask

Loading…
Cancel
Save