From 1abd2a23cce04a8913791eb88a0818814f35d106 Mon Sep 17 00:00:00 2001
From: Mononaut <github@monospace.live>
Date: Fri, 14 Jul 2023 16:48:11 +0900
Subject: [PATCH] Add audit replication success logging

---
 backend/src/replication/AuditReplication.ts | 1 +
 backend/src/replication/replicator.ts       | 4 ++--
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/backend/src/replication/AuditReplication.ts b/backend/src/replication/AuditReplication.ts
index 2043532db..26bf6dad7 100644
--- a/backend/src/replication/AuditReplication.ts
+++ b/backend/src/replication/AuditReplication.ts
@@ -66,6 +66,7 @@ class AuditReplication {
     if (syncResult) {
       if (syncResult.data?.template?.length) {
         await this.$saveAuditData(hash, syncResult.data);
+        logger.info(`Imported audit data from ${syncResult.server} for block ${syncResult.data.height} (${hash})`);
         success = true;
       }
       if (!syncResult.data && !syncResult.exists) {
diff --git a/backend/src/replication/replicator.ts b/backend/src/replication/replicator.ts
index 60dfa8a2d..ac204efcc 100644
--- a/backend/src/replication/replicator.ts
+++ b/backend/src/replication/replicator.ts
@@ -4,7 +4,7 @@ import axios, { AxiosResponse } from 'axios';
 import { SocksProxyAgent } from 'socks-proxy-agent';
 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
   let allMissing = true;
   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 {
       const result = await query(`https://${server}${path}`);
       if (result) {
-        return { data: result, exists: true };
+        return { data: result, exists: true, server };
       }
     } catch (e: any) {
       if (e?.response?.status === 404) {