Add missing ledger entry types to StatsChangeProcessor (#5038)

stellar · Sep 5, 2023 · 52e4cf3 · 52e4cf3
1 parent c146db6
commit 52e4cf3
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 1 deletion.
diff --git a/ingest/stats_change_processor.go b/ingest/stats_change_processor.go
@@ -184,5 +184,21 @@ func (stats *StatsChangeProcessorResults) Map() map[string]interface{} {
 		"stats_liquidity_pools_created": stats.LiquidityPoolsCreated,
 		"stats_liquidity_pools_updated": stats.LiquidityPoolsUpdated,
 		"stats_liquidity_pools_removed": stats.LiquidityPoolsRemoved,
+
+		"stats_contract_data_created": stats.ContractDataCreated,
+		"stats_contract_data_updated": stats.ContractDataUpdated,
+		"stats_contract_data_removed": stats.ContractDataRemoved,
+
+		"stats_contract_code_created": stats.ContractCodeCreated,
+		"stats_contract_code_updated": stats.ContractCodeUpdated,
+		"stats_contract_code_removed": stats.ContractCodeRemoved,
+
+		"stats_config_settings_created": stats.ConfigSettingsCreated,
+		"stats_config_settings_updated": stats.ConfigSettingsUpdated,
+		"stats_config_settings_removed": stats.ConfigSettingsRemoved,
+
+		"stats_expiration_created": stats.ExpirationCreated,
+		"stats_expiration_updated": stats.ExpirationUpdated,
+		"stats_expiration_removed": stats.ExpirationRemoved,
 	}
 }
diff --git a/ingest/stats_change_processor_test.go b/ingest/stats_change_processor_test.go
@@ -4,8 +4,9 @@ import (
 	"context"
 	"testing"
 
-	"github.com/stellar/go/xdr"
 	"github.com/stretchr/testify/assert"
+
+	"github.com/stellar/go/xdr"
 )
 
 func TestStatsChangeProcessor(t *testing.T) {
@@ -44,6 +45,7 @@ func TestStatsChangeProcessor(t *testing.T) {
 	assert.Equal(t, int64(1), results.ContractDataCreated)
 	assert.Equal(t, int64(1), results.ContractCodeCreated)
 	assert.Equal(t, int64(1), results.ConfigSettingsCreated)
+	assert.Equal(t, int64(1), results.ExpirationCreated)
 
 	assert.Equal(t, int64(1), results.AccountsUpdated)
 	assert.Equal(t, int64(1), results.ClaimableBalancesUpdated)
@@ -54,6 +56,7 @@ func TestStatsChangeProcessor(t *testing.T) {
 	assert.Equal(t, int64(1), results.ContractDataUpdated)
 	assert.Equal(t, int64(1), results.ContractCodeUpdated)
 	assert.Equal(t, int64(1), results.ConfigSettingsUpdated)
+	assert.Equal(t, int64(1), results.ExpirationUpdated)
 
 	assert.Equal(t, int64(1), results.AccountsRemoved)
 	assert.Equal(t, int64(1), results.ClaimableBalancesRemoved)
@@ -64,4 +67,7 @@ func TestStatsChangeProcessor(t *testing.T) {
 	assert.Equal(t, int64(1), results.ContractCodeRemoved)
 	assert.Equal(t, int64(1), results.ContractDataRemoved)
 	assert.Equal(t, int64(1), results.ConfigSettingsRemoved)
+	assert.Equal(t, int64(1), results.ExpirationRemoved)
+
+	assert.Equal(t, len(xdr.LedgerEntryTypeMap)*3, len(results.Map()))
 }