rpc & config & monitor

Author: ucwong

config.go

@@ -0,0 +1,27 @@
+// Copyright 2023 The CortexTheseus Authors
+// This file is part of the CortexTheseus library.
+//
+// The CortexTheseus library is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Lesser General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// The CortexTheseus library is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU Lesser General Public License for more details.
+//
+// You should have received a copy of the GNU Lesser General Public License
+// along with the CortexTheseus library. If not, see <http://www.gnu.org/licenses/>.
+
+package robot
+
+import (
+	"time"
+)
+
+const (
+	batch   = 4096 * 2 //params.SyncBatch
+	delay   = 12       //params.Delay
+	timeout = 30 * time.Second
+)

monitor.go

@@ -20,7 +20,6 @@ import (
 	"context"
 	"errors"
 	"github.com/CortexFoundation/CortexTheseus/common"
-	"github.com/CortexFoundation/CortexTheseus/common/hexutil"
 	"github.com/CortexFoundation/CortexTheseus/common/mclock"
 	"github.com/CortexFoundation/CortexTheseus/log"
 	"github.com/CortexFoundation/CortexTheseus/metrics"
@@ -39,12 +38,6 @@ import (
 	"time"
 )
 
-const (
-	batch   = 4096 * 2 //params.SyncBatch
-	delay   = 12       //params.Delay
-	timeout = 30 * time.Second
-)
-
 var (
 	rpcBlockMeter   = metrics.NewRegisteredMeter("torrent/block/call", nil)
 	rpcCurrentMeter = metrics.NewRegisteredMeter("torrent/current/call", nil)
@@ -508,25 +501,6 @@ func (m *Monitor) syncLatestBlock() {
 	}
 }
 
-func (m *Monitor) currentBlock() (uint64, bool, error) {
-	var (
-		currentNumber hexutil.Uint64
-		update        bool
-	)
-
-	rpcCurrentMeter.Mark(1)
-	if err := m.cl.Call(&currentNumber, "ctxc_blockNumber"); err != nil {
-		log.Error("Call ipc method ctxc_blockNumber failed", "error", err)
-		return m.currentNumber.Load(), false, err
-	}
-	if m.currentNumber.Load() != uint64(currentNumber) {
-		m.currentNumber.Store(uint64(currentNumber))
-		update = true
-	}
-
-	return uint64(currentNumber), update, nil
-}
-
 func (m *Monitor) skip(i uint64) bool {
 	if m.srv.Load() != SRV_MODEL {
 		return false

rpc.go

@@ -119,3 +119,22 @@ func (m *Monitor) getReceipt(tx string) (receipt types.Receipt, err error) {
 
 	return
 }
+
+func (m *Monitor) currentBlock() (uint64, bool, error) {
+	var (
+		currentNumber hexutil.Uint64
+		update        bool
+	)
+
+	rpcCurrentMeter.Mark(1)
+	if err := m.cl.Call(&currentNumber, "ctxc_blockNumber"); err != nil {
+		log.Error("Call ipc method ctxc_blockNumber failed", "error", err)
+		return m.currentNumber.Load(), false, err
+	}
+	if m.currentNumber.Load() != uint64(currentNumber) {
+		m.currentNumber.Store(uint64(currentNumber))
+		update = true
+	}
+
+	return uint64(currentNumber), update, nil
+}