mirrors/mempool
1
0
Fork 0
mirror of https://github.com/mempool/mempool.git synced 2025-02-23 06:35:15 +01:00
Code Issues Projects Releases Wiki Activity

Add audit replication success logging

Browse source
This commit is contained in:
Mononaut 2023-07-14 16:48:11 +09:00
parent e59a9d38ff
commit 1abd2a23cc
No known key found for this signature in database
GPG key ID: A3F058E41374C04E
2 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
backend/src/replication/AuditReplication.ts
View file

@ -66,6 +66,7 @@ class AuditReplication {
if (syncResult) { if (syncResult) {
if (syncResult.data?.template?.length) { if (syncResult.data?.template?.length) {
await this.$saveAuditData(hash, syncResult.data); await this.$saveAuditData(hash, syncResult.data);
logger.info(`Imported audit data from ${syncResult.server} for block ${syncResult.data.height} (${hash})`);
success = true; success = true;
} }
if (!syncResult.data && !syncResult.exists) { if (!syncResult.data && !syncResult.exists) {

4
backend/src/replication/replicator.ts
View file

@ -4,7 +4,7 @@ import axios, { AxiosResponse } from 'axios';
import { SocksProxyAgent } from 'socks-proxy-agent'; import { SocksProxyAgent } from 'socks-proxy-agent';
import * as https from 'https'; import * as https from 'https';
export async function $sync(path): Promise<{ data?: any, exists: boolean }> { export async function $sync(path): Promise<{ data?: any, exists: boolean, server?: string }> {
// start with a random server so load is uniformly spread // start with a random server so load is uniformly spread
let allMissing = true; let allMissing = true;
const offset = Math.floor(Math.random() * config.REPLICATION.SERVERS.length); const offset = Math.floor(Math.random() * config.REPLICATION.SERVERS.length);
@ -18,7 +18,7 @@ export async function $sync(path): Promise<{ data?: any, exists: boolean }> {
try { try {
const result = await query(`https://${server}${path}`); const result = await query(`https://${server}${path}`);
if (result) { if (result) {
return { data: result, exists: true }; return { data: result, exists: true, server };
} }
} catch (e: any) { } catch (e: any) {
if (e?.response?.status === 404) { if (e?.response?.status === 404) {