From c1dd6f2a4e5d6996821e6cd15dd56c17ebc0e714 Mon Sep 17 00:00:00 2001
From: shangchengbabaiban <shuang.cui@live.cn>
Date: Mon, 29 Jul 2024 21:55:51 +0800
Subject: [PATCH] chore: fix some comments
Signed-off-by: shangchengbabaiban <shuang.cui@live.cn>
---
ingest/ledger_change_reader.go | 2 +-
ingest/ledgerbackend/ledger_buffer.go | 2 +-
services/horizon/internal/ingest/orderbook.go | 2 +-
.../internal/serve/tx_approve_test.go | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/ingest/ledger_change_reader.go b/ingest/ledger_change_reader.go
index 496dc98b40..bb6dd34768 100644
--- a/ingest/ledger_change_reader.go
+++ b/ingest/ledger_change_reader.go
@@ -120,7 +120,7 @@ func (c *compactingChangeReader) Close() error {
}
// NewCompactingChangeReader wraps a given ChangeReader and returns a ChangeReader
-// which compacts all the the Changes extracted from the input.
+// which compacts all the Changes extracted from the input.
func NewCompactingChangeReader(input ChangeReader) ChangeReader {
return &compactingChangeReader{
input: input,
diff --git a/ingest/ledgerbackend/ledger_buffer.go b/ingest/ledgerbackend/ledger_buffer.go
index 6965461bba..564ccf8b3b 100644
--- a/ingest/ledgerbackend/ledger_buffer.go
+++ b/ingest/ledgerbackend/ledger_buffer.go
@@ -153,7 +153,7 @@ func (lb *ledgerBuffer) worker(ctx context.Context) {
// When we store an object we still maintain the ledger buffer invariant because
// at this point the current task is finished and we add 1 ledger object to the priority queue.
// Thus, the number of tasks decreases by 1 and the priority queue length increases by 1.
- // This keeps the overall total the same (<= BufferSize). As long as the the ledger buffer invariant
+ // This keeps the overall total the same (<= BufferSize). As long as the ledger buffer invariant
// was maintained in the previous state, it is still maintained during this state transition.
lb.storeObject(ledgerObject, sequence)
break
diff --git a/services/horizon/internal/ingest/orderbook.go b/services/horizon/internal/ingest/orderbook.go
index 3f8401cf1c..8337e1ff3c 100644
--- a/services/horizon/internal/ingest/orderbook.go
+++ b/services/horizon/internal/ingest/orderbook.go
@@ -315,7 +315,7 @@ func (o *OrderBookStream) verifyAllLiquidityPools(ctx context.Context, liquidity
// Update will query the Horizon DB for offers which have been created, removed, or updated since the
// last time Update() was called. Those changes will then be applied to the in memory order book graph.
-// After calling this function, the the in memory order book graph should be consistent with the
+// After calling this function, the in memory order book graph should be consistent with the
// Horizon DB (assuming no error is returned).
func (o *OrderBookStream) Update(ctx context.Context) error {
if err := o.historyQ.BeginTx(ctx, &sql.TxOptions{ReadOnly: true, Isolation: sql.LevelRepeatableRead}); err != nil {
diff --git a/services/regulated-assets-approval-server/internal/serve/tx_approve_test.go b/services/regulated-assets-approval-server/internal/serve/tx_approve_test.go
index 1771e18fc3..e343a635c9 100644
--- a/services/regulated-assets-approval-server/internal/serve/tx_approve_test.go
+++ b/services/regulated-assets-approval-server/internal/serve/tx_approve_test.go
@@ -233,7 +233,7 @@ func TestTxApproveHandler_handleActionRequiredResponseIfNeeded(t *testing.T) {
db: conn,
}
- // payments up to the the threshold won't trigger "action_required"
+ // payments up to the threshold won't trigger "action_required"
clientKP := keypair.MustRandom()
paymentOp := &txnbuild.Payment{
Amount: amount.StringFromInt64(kycThreshold),