feat: Read Data on External Chains

universalClient/core/client.go

@@ -31,7 +31,7 @@ type UniversalClient struct {
 	pushCore    *pushcore.Client
 	pushSigner  *pushsigner.Signer
 	chains      *externalchains.Chains
-	pushChain   *pushwatcher.Client
+	pushWatcher *pushwatcher.Client
 	tssNode     *tss.Node
 }
 
@@ -70,21 +70,23 @@ func NewUniversalClient(ctx context.Context, cfg *config.Config) (*UniversalClie
 
 	chainsManager := externalchains.NewChains(pushCore, pushSigner, cfg, log)
 
-	// Push chain DB is shared by the push chain client and the TSS node.
+	// Push chain DB is shared by the push watcher and the TSS node.
 	pushDB, err := openPushDB(cfg)
 	if err != nil {
 		return nil, err
 	}
 
-	pushChain, err := pushwatcher.NewClient(
+	pushWatcher, err := pushwatcher.NewClient(
 		pushDB,
 		cfg.GetChainConfig(cfg.PushChainID),
 		pushCore,
 		cfg.PushChainID,
 		log,
+		pushSigner,
+		chainsManager,
 	)
 	if err != nil {
-		return nil, fmt.Errorf("failed to create push chain client: %w", err)
+		return nil, fmt.Errorf("failed to create push watcher: %w", err)
 	}
 
 	tssNode, err := initTSS(ctx, cfg, pushCore, chainsManager, pushSigner, pushDB, log)
@@ -102,7 +104,7 @@ func NewUniversalClient(ctx context.Context, cfg *config.Config) (*UniversalClie
 		pushCore:    pushCore,
 		pushSigner:  pushSigner,
 		chains:      chainsManager,
-		pushChain:   pushChain,
+		pushWatcher: pushWatcher,
 		tssNode:     tssNode,
 	}, nil
 }
@@ -130,8 +132,8 @@ func (uc *UniversalClient) Start() error {
 		return fmt.Errorf("failed to start chains manager: %w", err)
 	}
 
-	if err := uc.pushChain.Start(uc.ctx); err != nil {
-		return fmt.Errorf("failed to start push chain client: %w", err)
+	if err := uc.pushWatcher.Start(uc.ctx); err != nil {
+		return fmt.Errorf("failed to start push watcher: %w", err)
 	}
 
 	if uc.tssNode != nil {
@@ -166,9 +168,9 @@ func (uc *UniversalClient) shutdown() {
 		}
 	}
 
-	if uc.pushChain != nil {
-		if err := uc.pushChain.Stop(); err != nil {
-			uc.log.Error().Err(err).Str("subsystem", "push_chain").Msg("subsystem failed to stop")
+	if uc.pushWatcher != nil {
+		if err := uc.pushWatcher.Stop(); err != nil {
+			uc.log.Error().Err(err).Str("subsystem", "push_watcher").Msg("subsystem failed to stop")
 		}
 	}
 

universalClient/externalchains/chains_test.go

@@ -413,6 +413,9 @@ type mockChainClient struct {
 func (m *mockChainClient) Start(ctx context.Context) error { m.startCalled = true; return nil }
 func (m *mockChainClient) Stop() error                     { m.stopCalled = true; return m.stopErr }
 func (m *mockChainClient) IsHealthy() bool                 { return true }
+func (m *mockChainClient) GetReadRequestHandler() (common.ReadRequestHandler, error) {
+	return nil, nil
+}
 func (m *mockChainClient) GetTxBuilder() (common.TxBuilder, error) {
 	return nil, nil
 }

universalClient/externalchains/common/chain_store.go

@@ -154,24 +154,6 @@ func (cs *ChainStore) UpdateStatusAndEventData(eventID, oldStatus, newStatus str
 	return res.RowsAffected, nil
 }
 
-// UpdateVoteTxHash updates the vote_tx_hash field for an event
-func (cs *ChainStore) UpdateVoteTxHash(eventID string, voteTxHash string) error {
-	if cs.database == nil {
-		return fmt.Errorf("database is nil")
-	}
-
-	result := cs.database.Client().
-		Model(&store.Event{}).
-		Where("event_id = ?", eventID).
-		Update("vote_tx_hash", voteTxHash)
-
-	if result.Error != nil {
-		return fmt.Errorf("failed to update vote_tx_hash: %w", result.Error)
-	}
-
-	return nil
-}
-
 // DeleteTerminalEvents deletes events in terminal states (COMPLETED, REVERTED, EXPIRED)
 // that were updated before the given time
 func (cs *ChainStore) DeleteTerminalEvents(updatedBefore any) (int64, error) {

universalClient/externalchains/common/chain_store_test.go

@@ -56,12 +56,6 @@ func TestChainStoreNilDatabase(t *testing.T) {
 		assert.Contains(t, err.Error(), "database is nil")
 	})
 
-	t.Run("UpdateVoteTxHash returns error for nil database", func(t *testing.T) {
-		err := store.UpdateVoteTxHash("event-1", "0x123")
-		require.Error(t, err)
-		assert.Contains(t, err.Error(), "database is nil")
-	})
-
 	t.Run("InsertEventIfNotExists returns error for nil database", func(t *testing.T) {
 		inserted, err := store.InsertEventIfNotExists(nil)
 		require.Error(t, err)
@@ -222,23 +216,6 @@ func TestChainStore_UpdateStatusAndEventData(t *testing.T) {
 	assert.Equal(t, int64(1), rows)
 }
 
-func TestChainStore_UpdateVoteTxHash(t *testing.T) {
-	cs := newTestChainStore(t)
-
-	event := &storemodels.Event{
-		EventID:          "evt-5",
-		BlockHeight:      50,
-		Type:             storemodels.EventTypeOutbound,
-		ConfirmationType: storemodels.ConfirmationStandard,
-		Status:           storemodels.StatusConfirmed,
-	}
-	_, err := cs.InsertEventIfNotExists(event)
-	require.NoError(t, err)
-
-	err = cs.UpdateVoteTxHash("evt-5", "0xvotehash")
-	require.NoError(t, err)
-}
-
 func TestChainStore_GetPendingEventsLimit(t *testing.T) {
 	cs := newTestChainStore(t)