Merge branch 'master' into nymkappa/bugfix/handle-esplora-error

This commit is contained in:
wiz 2022-08-23 23:08:13 +09:00 committed by GitHub
commit a30bb4e6c0
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
17 changed files with 361 additions and 84 deletions

View file

@ -17,14 +17,25 @@ class ChannelsApi {
} }
} }
public async $getAllChannelsGeo(publicKey?: string): Promise<any[]> { public async $getAllChannelsGeo(publicKey?: string, style?: string): Promise<any[]> {
try { try {
const params: string[] = []; let select: string;
let query = `SELECT nodes_1.public_key as node1_public_key, nodes_1.alias AS node1_alias, if (style === 'widget') {
select = `
nodes_1.latitude AS node1_latitude, nodes_1.longitude AS node1_longitude,
nodes_2.latitude AS node2_latitude, nodes_2.longitude AS node2_longitude
`;
} else {
select = `
nodes_1.public_key as node1_public_key, nodes_1.alias AS node1_alias,
nodes_1.latitude AS node1_latitude, nodes_1.longitude AS node1_longitude, nodes_1.latitude AS node1_latitude, nodes_1.longitude AS node1_longitude,
nodes_2.public_key as node2_public_key, nodes_2.alias AS node2_alias, nodes_2.public_key as node2_public_key, nodes_2.alias AS node2_alias,
nodes_2.latitude AS node2_latitude, nodes_2.longitude AS node2_longitude, nodes_2.latitude AS node2_latitude, nodes_2.longitude AS node2_longitude
channels.capacity `;
}
const params: string[] = [];
let query = `SELECT ${select}
FROM channels FROM channels
JOIN nodes AS nodes_1 on nodes_1.public_key = channels.node1_public_key JOIN nodes AS nodes_1 on nodes_1.public_key = channels.node1_public_key
JOIN nodes AS nodes_2 on nodes_2.public_key = channels.node2_public_key JOIN nodes AS nodes_2 on nodes_2.public_key = channels.node2_public_key
@ -36,13 +47,30 @@ class ChannelsApi {
query += ' AND (nodes_1.public_key = ? OR nodes_2.public_key = ?)'; query += ' AND (nodes_1.public_key = ? OR nodes_2.public_key = ?)';
params.push(publicKey); params.push(publicKey);
params.push(publicKey); params.push(publicKey);
} else {
query += ` AND channels.capacity > 1000000
GROUP BY nodes_1.public_key, nodes_2.public_key
ORDER BY channels.capacity DESC
LIMIT 10000
`;
} }
const [rows]: any = await DB.query(query, params); const [rows]: any = await DB.query(query, params);
return rows.map((row) => [ return rows.map((row) => {
row.node1_public_key, row.node1_alias, row.node1_longitude, row.node1_latitude, if (style === 'widget') {
row.node2_public_key, row.node2_alias, row.node2_longitude, row.node2_latitude, return [
row.capacity]); row.node1_longitude, row.node1_latitude,
row.node2_longitude, row.node2_latitude,
];
} else {
return [
row.node1_public_key, row.node1_alias,
row.node1_longitude, row.node1_latitude,
row.node2_public_key, row.node2_alias,
row.node2_longitude, row.node2_latitude,
];
}
});
} catch (e) { } catch (e) {
logger.err('$getAllChannelsGeo error: ' + (e instanceof Error ? e.message : e)); logger.err('$getAllChannelsGeo error: ' + (e instanceof Error ? e.message : e));
throw e; throw e;
@ -217,8 +245,12 @@ class ChannelsApi {
let channelStatusFilter; let channelStatusFilter;
if (status === 'open') { if (status === 'open') {
channelStatusFilter = '< 2'; channelStatusFilter = '< 2';
} else if (status === 'active') {
channelStatusFilter = '= 1';
} else if (status === 'closed') { } else if (status === 'closed') {
channelStatusFilter = '= 2'; channelStatusFilter = '= 2';
} else {
throw new Error('getChannelsForNode: Invalid status requested');
} }
// Channels originating from node // Channels originating from node
@ -247,7 +279,12 @@ class ChannelsApi {
allChannels.sort((a, b) => { allChannels.sort((a, b) => {
return b.capacity - a.capacity; return b.capacity - a.capacity;
}); });
if (index >= 0) {
allChannels = allChannels.slice(index, index + length); allChannels = allChannels.slice(index, index + length);
} else if (index === -1) { // Node channels tree chart
allChannels = allChannels.slice(0, 1000);
}
const channels: any[] = [] const channels: any[] = []
for (const row of allChannels) { for (const row of allChannels) {

View file

@ -102,7 +102,11 @@ class ChannelsRoutes {
private async $getAllChannelsGeo(req: Request, res: Response) { private async $getAllChannelsGeo(req: Request, res: Response) {
try { try {
const channels = await channelsApi.$getAllChannelsGeo(req.params?.publicKey); const style: string = typeof req.query.style === 'string' ? req.query.style : '';
const channels = await channelsApi.$getAllChannelsGeo(req.params?.publicKey, style);
res.header('Pragma', 'public');
res.header('Cache-control', 'public');
res.setHeader('Expires', new Date(Date.now() + 1000 * 60).toUTCString());
res.json(channels); res.json(channels);
} catch (e) { } catch (e) {
res.status(500).send(e instanceof Error ? e.message : e); res.status(500).send(e instanceof Error ? e.message : e);

View file

@ -98,7 +98,7 @@ class NetworkSyncService {
const [closedChannelsRaw]: any[] = await DB.query(`SELECT id FROM channels WHERE status = 2`); const [closedChannelsRaw]: any[] = await DB.query(`SELECT id FROM channels WHERE status = 2`);
const closedChannels = {}; const closedChannels = {};
for (const closedChannel of closedChannelsRaw) { for (const closedChannel of closedChannelsRaw) {
closedChannels[Common.channelShortIdToIntegerId(closedChannel.id)] = true; closedChannels[closedChannel.id] = true;
} }
let progress = 0; let progress = 0;

View file

@ -87,7 +87,7 @@
</ng-template> </ng-template>
<ng-template #skeleton> <ng-template #skeleton>
<h2 class="float-left">Channels</h2> <h2 class="float-left" i18n="lightning.channels">Channels</h2>
<table class="table table-borderless"> <table class="table table-borderless">
<ng-container *ngTemplateOutlet="tableHeader"></ng-container> <ng-container *ngTemplateOutlet="tableHeader"></ng-container>

View file

@ -32,7 +32,7 @@ export class LightningApiService {
} }
getChannelsByNodeId$(publicKey: string, index: number = 0, status = 'open'): Observable<any> { getChannelsByNodeId$(publicKey: string, index: number = 0, status = 'open'): Observable<any> {
let params = new HttpParams() const params = new HttpParams()
.set('public_key', publicKey) .set('public_key', publicKey)
.set('index', index) .set('index', index)
.set('status', status) .set('status', status)

View file

@ -29,6 +29,7 @@ import { TopNodesPerChannels } from '../lightning/nodes-ranking/top-nodes-per-ch
import { TopNodesPerCapacity } from '../lightning/nodes-ranking/top-nodes-per-capacity/top-nodes-per-capacity.component'; import { TopNodesPerCapacity } from '../lightning/nodes-ranking/top-nodes-per-capacity/top-nodes-per-capacity.component';
import { OldestNodes } from '../lightning/nodes-ranking/oldest-nodes/oldest-nodes.component'; import { OldestNodes } from '../lightning/nodes-ranking/oldest-nodes/oldest-nodes.component';
import { NodesRankingsDashboard } from '../lightning/nodes-rankings-dashboard/nodes-rankings-dashboard.component'; import { NodesRankingsDashboard } from '../lightning/nodes-rankings-dashboard/nodes-rankings-dashboard.component';
import { NodeChannels } from '../lightning/nodes-channels/node-channels.component';
@NgModule({ @NgModule({
declarations: [ declarations: [
@ -56,6 +57,7 @@ import { NodesRankingsDashboard } from '../lightning/nodes-rankings-dashboard/no
TopNodesPerCapacity, TopNodesPerCapacity,
OldestNodes, OldestNodes,
NodesRankingsDashboard, NodesRankingsDashboard,
NodeChannels,
], ],
imports: [ imports: [
CommonModule, CommonModule,
@ -89,6 +91,7 @@ import { NodesRankingsDashboard } from '../lightning/nodes-rankings-dashboard/no
TopNodesPerCapacity, TopNodesPerCapacity,
OldestNodes, OldestNodes,
NodesRankingsDashboard, NodesRankingsDashboard,
NodeChannels,
], ],
providers: [ providers: [
LightningApiService, LightningApiService,

View file

@ -118,15 +118,22 @@
</button> </button>
</div> </div>
<app-nodes-channels-map *ngIf="!error" [style]="'nodepage'" [publicKey]="node.public_key"></app-nodes-channels-map> <div *ngIf="!error">
<app-node-statistics-chart [publicKey]="node.public_key" *ngIf="!error"></app-node-statistics-chart> <app-nodes-channels-map [style]="'nodepage'" [publicKey]="node.public_key"></app-nodes-channels-map>
<div class="d-flex justify-content-between" *ngIf="!error"> <h2 i18n="lightning.node-history">Node history</h2>
<app-node-statistics-chart [publicKey]="node.public_key"></app-node-statistics-chart>
<h2 i18n="lightning.active-channels-map">Active channels map</h2>
<app-node-channels style="display:block;margin-bottom: 40px" [publicKey]="node.public_key"></app-node-channels>
<div class="d-flex justify-content-between">
<h2>Channels ({{ channelsListStatus === 'open' ? node.opened_channel_count : node.closed_channel_count }})</h2> <h2>Channels ({{ channelsListStatus === 'open' ? node.opened_channel_count : node.closed_channel_count }})</h2>
</div> </div>
<app-channels-list *ngIf="!error" [publicKey]="node.public_key" <app-channels-list [publicKey]="node.public_key"
(channelsStatusChangedEvent)="onChannelsListStatusChanged($event)"></app-channels-list> (channelsStatusChangedEvent)="onChannelsListStatusChanged($event)"></app-channels-list>
</div>
</div> </div>

View file

@ -1,3 +1,4 @@
<div [style]="style === 'widget' ? 'height: 250px' : ''">
<div *ngIf="channelsObservable | async"> <div *ngIf="channelsObservable | async">
<div *ngIf="chartOptions" [class]="'full-container ' + style + (fitContainer ? ' fit-container' : '')"> <div *ngIf="chartOptions" [class]="'full-container ' + style + (fitContainer ? ' fit-container' : '')">
<div *ngIf="style === 'graph'" class="card-header"> <div *ngIf="style === 'graph'" class="card-header">
@ -7,10 +8,15 @@
<small style="color: #ffffff66" i18n="lightning.tor-nodes-excluded">(Tor nodes excluded)</small> <small style="color: #ffffff66" i18n="lightning.tor-nodes-excluded">(Tor nodes excluded)</small>
</div> </div>
<div class="chart" echarts [initOpts]="chartInitOptions" [options]="chartOptions" (chartInit)="onChartInit($event)" <div class="chart" [class]="style" echarts [initOpts]="chartInitOptions" [options]="chartOptions" (chartInit)="onChartInit($event)"
(chartFinished)="onChartFinished($event)"> (chartFinished)="onChartFinished($event)">
</div> </div>
</div> </div>
<div *ngIf="!chartOptions && style === 'nodepage'" style="padding-top: 30px"></div> <div *ngIf="!chartOptions && style === 'nodepage'" style="padding-top: 30px"></div>
</div> </div>
<div class="text-center loading-spinner" [class]="style" *ngIf="isLoading">
<div class="spinner-border text-light"></div>
</div>
</div>

View file

@ -10,7 +10,7 @@
.full-container { .full-container {
padding: 0px 15px; padding: 0px 15px;
width: 100%; width: 100%;
min-height: 500px; min-height: 600px;
height: calc(100% - 150px); height: calc(100% - 150px);
@media (max-width: 992px) { @media (max-width: 992px) {
@ -18,17 +18,20 @@
padding-bottom: 100px; padding-bottom: 100px;
} }
} }
.full-container.nodepage { .full-container.nodepage {
min-height: 400px;
margin-top: 25px;
margin-bottom: 25px;
}
.full-container.channelpage {
min-height: 400px;
margin-top: 25px; margin-top: 25px;
margin-bottom: 25px; margin-bottom: 25px;
} }
.full-container.widget { .full-container.widget {
height: 250px; height: 250px;
min-height: 250px; min-height: 250px;
} }
.full-container.fit-container { .full-container.fit-container {
margin: 0; margin: 0;
padding: 0; padding: 0;
@ -41,25 +44,6 @@
} }
} }
.widget {
width: 90vw;
margin-left: auto;
margin-right: auto;
height: 250px;
-webkit-mask: linear-gradient(0deg, #11131f00 5%, #11131fff 25%);
@media (max-width: 767.98px) {
width: 100vw;
}
}
.widget > .chart {
min-height: 250px;
-webkit-mask: linear-gradient(180deg, #11131f00 0%, #11131fff 20%);
@media (max-width: 767.98px) {
padding-bottom: 0px;
}
}
.chart { .chart {
min-height: 500px; min-height: 500px;
width: 100%; width: 100%;
@ -80,3 +64,47 @@
padding-bottom: 55px; padding-bottom: 55px;
} }
} }
.chart.graph {
min-height: 600px;
}
.chart.nodepage {
min-height: 400px;
}
.chart.channelpage {
min-height: 400px;
}
.widget {
width: 90vw;
margin-left: auto;
margin-right: auto;
height: 250px;
-webkit-mask: linear-gradient(0deg, #11131f00 5%, #11131fff 25%);
@media (max-width: 767.98px) {
width: 100vw;
}
}
.widget > .chart {
min-height: 250px;
-webkit-mask: linear-gradient(180deg, #11131f00 0%, #11131fff 20%);
@media (max-width: 767.98px) {
padding-bottom: 0px;
}
}
.loading-spinner {
position: absolute;
top: 50%;
left: calc(50% - 15px);
z-index: 100;
}
.loading-spinner.widget {
position: absolute;
top: 200px;
z-index: 100;
width: 100%;
left: 0;
@media (max-width: 767.98px) {
top: 250px;
}
}

View file

@ -32,6 +32,7 @@ export class NodesChannelsMap implements OnInit {
channelColor = '#466d9d'; channelColor = '#466d9d';
channelCurve = 0; channelCurve = 0;
nodeSize = 4; nodeSize = 4;
isLoading = true;
chartInstance = undefined; chartInstance = undefined;
chartOptions: EChartsOption = {}; chartOptions: EChartsOption = {};
@ -74,7 +75,7 @@ export class NodesChannelsMap implements OnInit {
switchMap((params: ParamMap) => { switchMap((params: ParamMap) => {
return zip( return zip(
this.assetsService.getWorldMapJson$, this.assetsService.getWorldMapJson$,
this.style !== 'channelpage' ? this.apiService.getChannelsGeo$(params.get('public_key') ?? undefined) : [''], this.style !== 'channelpage' ? this.apiService.getChannelsGeo$(params.get('public_key') ?? undefined, this.style) : [''],
[params.get('public_key') ?? undefined] [params.get('public_key') ?? undefined]
).pipe(tap((data) => { ).pipe(tap((data) => {
registerMap('world', data[0]); registerMap('world', data[0]);
@ -93,11 +94,13 @@ export class NodesChannelsMap implements OnInit {
} }
} }
for (const channel of geoloc) { for (const channel of geoloc) {
if (!thisNodeGPS && data[2] === channel[0]) { if (this.style === 'nodepage' && !thisNodeGPS) {
if (data[2] === channel[0]) {
thisNodeGPS = [channel[2], channel[3]]; thisNodeGPS = [channel[2], channel[3]];
} else if (!thisNodeGPS && data[2] === channel[4]) { } else if (data[2] === channel[4]) {
thisNodeGPS = [channel[6], channel[7]]; thisNodeGPS = [channel[6], channel[7]];
} }
}
// 0 - node1 pubkey // 0 - node1 pubkey
// 1 - node1 alias // 1 - node1 alias
@ -105,48 +108,68 @@ export class NodesChannelsMap implements OnInit {
// 4 - node2 pubkey // 4 - node2 pubkey
// 5 - node2 alias // 5 - node2 alias
// 6,7 - node2 GPS // 6,7 - node2 GPS
const node1PubKey = 0;
const node1Alias = 1;
let node1GpsLat = 2;
let node1GpsLgt = 3;
const node2PubKey = 4;
const node2Alias = 5;
let node2GpsLat = 6;
let node2GpsLgt = 7;
let node1UniqueId = channel[node1PubKey];
let node2UniqueId = channel[node2PubKey];
if (this.style === 'widget') {
node1GpsLat = 0;
node1GpsLgt = 1;
node2GpsLat = 2;
node2GpsLgt = 3;
node1UniqueId = channel[node1GpsLat].toString() + channel[node1GpsLgt].toString();
node2UniqueId = channel[node2GpsLat].toString() + channel[node2GpsLgt].toString();
}
// We add a bit of noise so nodes at the same location are not all // We add a bit of noise so nodes at the same location are not all
// on top of each other // on top of each other
let random = Math.random() * 2 * Math.PI; let random = Math.random() * 2 * Math.PI;
let random2 = Math.random() * 0.01; let random2 = Math.random() * 0.01;
if (!nodesPubkeys[channel[0]]) { if (!nodesPubkeys[node1UniqueId]) {
nodes.push([ nodes.push([
channel[2] + random2 * Math.cos(random), channel[node1GpsLat] + random2 * Math.cos(random),
channel[3] + random2 * Math.sin(random), channel[node1GpsLgt] + random2 * Math.sin(random),
1, 1,
channel[0], channel[node1PubKey],
channel[1] channel[node1Alias]
]); ]);
nodesPubkeys[channel[0]] = nodes[nodes.length - 1]; nodesPubkeys[node1UniqueId] = nodes[nodes.length - 1];
} }
random = Math.random() * 2 * Math.PI; random = Math.random() * 2 * Math.PI;
random2 = Math.random() * 0.01; random2 = Math.random() * 0.01;
if (!nodesPubkeys[channel[4]]) { if (!nodesPubkeys[node2UniqueId]) {
nodes.push([ nodes.push([
channel[6] + random2 * Math.cos(random), channel[node2GpsLat] + random2 * Math.cos(random),
channel[7] + random2 * Math.sin(random), channel[node2GpsLgt] + random2 * Math.sin(random),
1, 1,
channel[4], channel[node2PubKey],
channel[5] channel[node2Alias]
]); ]);
nodesPubkeys[channel[4]] = nodes[nodes.length - 1]; nodesPubkeys[node2UniqueId] = nodes[nodes.length - 1];
} }
const channelLoc = []; const channelLoc = [];
channelLoc.push(nodesPubkeys[channel[0]].slice(0, 2)); channelLoc.push(nodesPubkeys[node1UniqueId].slice(0, 2));
channelLoc.push(nodesPubkeys[channel[4]].slice(0, 2)); channelLoc.push(nodesPubkeys[node2UniqueId].slice(0, 2));
channelsLoc.push(channelLoc); channelsLoc.push(channelLoc);
} }
if (this.style === 'nodepage' && thisNodeGPS) { if (this.style === 'nodepage' && thisNodeGPS) {
this.center = [thisNodeGPS[0], thisNodeGPS[1]]; this.center = [thisNodeGPS[0], thisNodeGPS[1]];
this.zoom = 10; this.zoom = 10;
this.channelWidth = 1; this.channelWidth = 1;
this.channelOpacity = 1; this.channelOpacity = 1;
} }
if (this.style === 'channelpage' && this.channel.length > 0) { if (this.style === 'channelpage' && this.channel.length > 0) {
this.channelWidth = 2; this.channelWidth = 2;
this.channelOpacity = 1; this.channelOpacity = 1;
@ -238,7 +261,7 @@ export class NodesChannelsMap implements OnInit {
}, },
{ {
large: false, large: false,
progressive: 200, progressive: this.style === 'widget' ? 500 : 200,
silent: true, silent: true,
type: 'lines', type: 'lines',
coordinateSystem: 'geo', coordinateSystem: 'geo',
@ -266,6 +289,10 @@ export class NodesChannelsMap implements OnInit {
this.chartInstance = ec; this.chartInstance = ec;
this.chartInstance.on('finished', () => {
this.isLoading = false;
});
if (this.style === 'widget') { if (this.style === 'widget') {
this.chartInstance.getZr().on('click', (e) => { this.chartInstance.getZr().on('click', (e) => {
this.zone.run(() => { this.zone.run(() => {

View file

@ -0,0 +1,2 @@
<div *ngIf="channelsObservable$ | async" echarts [initOpts]="chartInitOptions" [options]="chartOptions" (chartInit)="onChartInit($event)">
</div>

View file

@ -0,0 +1,138 @@
import { formatNumber } from '@angular/common';
import { ChangeDetectionStrategy, Component, Inject, Input, LOCALE_ID, NgZone, OnChanges, OnInit } from '@angular/core';
import { Router } from '@angular/router';
import { ECharts, EChartsOption, TreemapSeriesOption } from 'echarts';
import { Observable, tap } from 'rxjs';
import { lerpColor } from 'src/app/shared/graphs.utils';
import { AmountShortenerPipe } from 'src/app/shared/pipes/amount-shortener.pipe';
import { LightningApiService } from '../lightning-api.service';
import { RelativeUrlPipe } from 'src/app/shared/pipes/relative-url/relative-url.pipe';
import { StateService } from '../../services/state.service';
@Component({
selector: 'app-node-channels',
templateUrl: './node-channels.component.html',
styleUrls: ['./node-channels.component.scss'],
changeDetection: ChangeDetectionStrategy.OnPush,
})
export class NodeChannels implements OnChanges {
@Input() publicKey: string;
chartInstance: ECharts;
chartOptions: EChartsOption = {};
chartInitOptions = {
renderer: 'svg',
};
channelsObservable$: Observable<any>;
isLoading: true;
constructor(
@Inject(LOCALE_ID) public locale: string,
private lightningApiService: LightningApiService,
private amountShortenerPipe: AmountShortenerPipe,
private zone: NgZone,
private router: Router,
private stateService: StateService,
) {}
ngOnChanges(): void {
this.prepareChartOptions(null);
this.channelsObservable$ = this.lightningApiService.getChannelsByNodeId$(this.publicKey, -1, 'active')
.pipe(
tap((response) => {
const biggestCapacity = response.body[0].capacity;
this.prepareChartOptions(response.body.map(channel => {
return {
name: channel.node.alias,
value: channel.capacity,
shortId: channel.short_id,
id: channel.id,
itemStyle: {
color: lerpColor('#1E88E5', '#D81B60', Math.pow(channel.capacity / biggestCapacity, 0.4)),
}
};
}));
})
);
}
prepareChartOptions(data): void {
this.chartOptions = {
tooltip: {
trigger: 'item',
textStyle: {
align: 'left',
}
},
series: <TreemapSeriesOption[]>[
{
left: 0,
right: 0,
bottom: 0,
top: 0,
roam: false,
type: 'treemap',
data: data,
nodeClick: 'link',
progressive: 100,
tooltip: {
show: true,
backgroundColor: 'rgba(17, 19, 31, 1)',
borderRadius: 4,
shadowColor: 'rgba(0, 0, 0, 0.5)',
textStyle: {
color: '#b1b1b1',
},
borderColor: '#000',
formatter: (value): string => {
if (value.data.name === undefined) {
return ``;
}
let capacity = '';
if (value.data.value > 100000000) {
capacity = formatNumber(Math.round(value.data.value / 100000000), this.locale, '1.2-2') + ' BTC';
} else {
capacity = <string>this.amountShortenerPipe.transform(value.data.value, 2) + ' sats';
}
return `
<b style="color: white; margin-left: 2px">${value.data.shortId}</b><br>
<span>Node: ${value.name}</span><br>
<span>Capacity: ${capacity}</span>
`;
}
},
itemStyle: {
borderColor: 'black',
borderWidth: 1,
},
breadcrumb: {
show: false,
}
}
]
};
}
onChartInit(ec: ECharts): void {
if (this.chartInstance !== undefined) {
return;
}
this.chartInstance = ec;
this.chartInstance.on('click', (e) => {
//@ts-ignore
if (!e.data.id) {
return;
}
this.zone.run(() => {
//@ts-ignore
const url = new RelativeUrlPipe(this.stateService).transform(`/lightning/channel/${e.data.id}`);
this.router.navigate([url]);
});
});
}
}

View file

@ -271,10 +271,11 @@ export class ApiService {
return this.httpClient.get<any[]>(this.apiBaseUrl + this.apiBasePath + '/api/v1/lightning/nodes/countries'); return this.httpClient.get<any[]>(this.apiBaseUrl + this.apiBasePath + '/api/v1/lightning/nodes/countries');
} }
getChannelsGeo$(publicKey?: string): Observable<any> { getChannelsGeo$(publicKey?: string, style?: 'graph' | 'nodepage' | 'widget' | 'channelpage'): Observable<any> {
return this.httpClient.get<any[]>( return this.httpClient.get<any[]>(
this.apiBaseUrl + this.apiBasePath + '/api/v1/lightning/channels-geo' + this.apiBaseUrl + this.apiBasePath + '/api/v1/lightning/channels-geo' +
(publicKey !== undefined ? `/${publicKey}` : '') (publicKey !== undefined ? `/${publicKey}` : '') +
(style !== undefined ? `?style=${style}` : '')
); );
} }
} }

View file

@ -91,3 +91,25 @@ export function detectWebGL() {
return (gl && gl instanceof WebGLRenderingContext); return (gl && gl instanceof WebGLRenderingContext);
} }
/**
* https://gist.githubusercontent.com/rosszurowski/67f04465c424a9bc0dae/raw/90ee06c5aa84ab352eb5b233d0a8263c3d8708e5/lerp-color.js
* A linear interpolator for hexadecimal colors
* @param {String} a
* @param {String} b
* @param {Number} amount
* @example
* // returns #7F7F7F
* lerpColor('#000000', '#ffffff', 0.5)
* @returns {String}
*/
export function lerpColor(a: string, b: string, amount: number): string {
const ah = parseInt(a.replace(/#/g, ''), 16),
ar = ah >> 16, ag = ah >> 8 & 0xff, ab = ah & 0xff,
bh = parseInt(b.replace(/#/g, ''), 16),
br = bh >> 16, bg = bh >> 8 & 0xff, bb = bh & 0xff,
rr = ar + amount * (br - ar),
rg = ag + amount * (bg - ag),
rb = ab + amount * (bb - ab);
return '#' + ((1 << 24) + (rr << 16) + (rg << 8) + rb | 0).toString(16).slice(1);
}

View file

@ -77,6 +77,8 @@ do for url in / \
'/api/v1/mining/difficulty-adjustments/2y' \ '/api/v1/mining/difficulty-adjustments/2y' \
'/api/v1/mining/difficulty-adjustments/3y' \ '/api/v1/mining/difficulty-adjustments/3y' \
'/api/v1/mining/difficulty-adjustments/all' \ '/api/v1/mining/difficulty-adjustments/all' \
'/api/v1/lightning/channels-geo?style=widget' \
'/api/v1/lightning/channels-geo?style=graph' \
do do
curl -s "https://${hostname}${url}" >/dev/null curl -s "https://${hostname}${url}" >/dev/null