474/soroban diagnostic events

ingest/ledgerbackend/captive_core_backend.go

@@ -70,10 +70,11 @@ func (c *CaptiveStellarCore) roundDownToFirstReplayAfterCheckpointStart(ledger u
 //
 // Requires Stellar-Core v13.2.0+.
 type CaptiveStellarCore struct {
-	archive           historyarchive.ArchiveInterface
-	checkpointManager historyarchive.CheckpointManager
-	ledgerHashStore   TrustedLedgerHashStore
-	useDB             bool
+	archive                       historyarchive.ArchiveInterface
+	checkpointManager             historyarchive.CheckpointManager
+	ledgerHashStore               TrustedLedgerHashStore
+	useDB                         bool
+	enableSorobanDiagnosticEvents bool
 
 	// cancel is the CancelFunc for context which controls the lifetime of a CaptiveStellarCore instance.
 	// Once it is invoked CaptiveStellarCore will not be able to stream ledgers from Stellar Core or
@@ -136,6 +137,9 @@ type CaptiveCoreConfig struct {
 	// of DATABASE parameter in the captive-core-config-path or if absent, the db will default to sqlite
 	// and the db file will be stored at location derived from StoragePath parameter.
 	UseDB bool
+
+	// Enable Soroban diagnostic events in core
+	EnableSorobanDiagnosticEvents bool
 }
 
 // NewCaptive returns a new CaptiveStellarCore instance.
@@ -173,11 +177,12 @@ func NewCaptive(config CaptiveCoreConfig) (*CaptiveStellarCore, error) {
 	}
 
 	c := &CaptiveStellarCore{
-		archive:           &archivePool,
-		ledgerHashStore:   config.LedgerHashStore,
-		useDB:             config.UseDB,
-		cancel:            cancel,
-		checkpointManager: historyarchive.NewCheckpointManager(config.CheckpointFrequency),
+		archive:                       &archivePool,
+		ledgerHashStore:               config.LedgerHashStore,
+		useDB:                         config.UseDB,
+		enableSorobanDiagnosticEvents: config.EnableSorobanDiagnosticEvents,
+		cancel:                        cancel,
+		checkpointManager:             historyarchive.NewCheckpointManager(config.CheckpointFrequency),
 	}
 
 	c.stellarCoreRunnerFactory = func() stellarCoreRunnerInterface {

ingest/ledgerbackend/toml.go

@@ -88,6 +88,7 @@ type captiveCoreTomlValues struct {
 	UseBucketListDB                      bool                 `toml:"EXPERIMENTAL_BUCKETLIST_DB,omitempty"`
 	BucketListDBPageSizeExp              *uint                `toml:"EXPERIMENTAL_BUCKETLIST_DB_INDEX_PAGE_SIZE_EXPONENT,omitempty"`
 	BucketListDBCutoff                   *uint                `toml:"EXPERIMENTAL_BUCKETLIST_DB_INDEX_CUTOFF,omitempty"`
+	EnableSorobanDiagnosticEvents        bool                 `toml:"ENABLE_SOROBAN_DIAGNOSTIC_EVENTS,omitempty"`
 }
 
 // QuorumSetIsConfigured returns true if there is a quorum set defined in the configuration.
@@ -324,6 +325,8 @@ type CaptiveCoreTomlParams struct {
 	UseDB bool
 	// the path to the core binary, used to introspect core at runtie, determine some toml capabilities
 	CoreBinaryPath string
+	// Make core emit Soroban diagnostic events
+	EnableSorobanDiagnosticEvents bool
 }
 
 // NewCaptiveCoreTomlFromFile constructs a new CaptiveCoreToml instance by merging configuration

services/horizon/internal/config.go

@@ -19,17 +19,18 @@ type Config struct {
 	Port               uint
 	AdminPort          uint
 
-	EnableCaptiveCoreIngestion  bool
-	EnableIngestionFiltering    bool
-	UsingDefaultPubnetConfig    bool
-	CaptiveCoreBinaryPath       string
-	RemoteCaptiveCoreURL        string
-	CaptiveCoreConfigPath       string
-	CaptiveCoreTomlParams       ledgerbackend.CaptiveCoreTomlParams
-	CaptiveCoreToml             *ledgerbackend.CaptiveCoreToml
-	CaptiveCoreStoragePath      string
-	CaptiveCoreReuseStoragePath bool
-	CaptiveCoreConfigUseDB      bool
+	EnableCaptiveCoreIngestion                     bool
+	EnableIngestionFiltering                       bool
+	UsingDefaultPubnetConfig                       bool
+	CaptiveCoreBinaryPath                          string
+	RemoteCaptiveCoreURL                           string
+	CaptiveCoreConfigPath                          string
+	CaptiveCoreTomlParams                          ledgerbackend.CaptiveCoreTomlParams
+	CaptiveCoreToml                                *ledgerbackend.CaptiveCoreToml
+	CaptiveCoreStoragePath                         string
+	CaptiveCoreReuseStoragePath                    bool
+	CaptiveCoreConfigUseDB                         bool
+	CaptiveCoreConfigEnableSorobanDiagnosticEvents bool
 
 	StellarCoreDatabaseURL string
 	StellarCoreURL         string

services/horizon/internal/flags.go

@@ -40,6 +40,8 @@ const (
 	CaptiveCoreConfigPathName = "captive-core-config-path"
 	// captive-core-use-db is the command line flag for enabling captive core runtime to use an external db url connection rather than RAM for ledger states
 	CaptiveCoreConfigUseDB = "captive-core-use-db"
+	// captive-core-enable-soroban-diagnostic-events is the command line flag for enabling soroban diagnostic events in captive core
+	CaptiveCoreConfigEnableSorobanDiagnosticEvents = "captive-core-enable-soroban-diagnostic-events"
 
 	captiveCoreMigrationHint = "If you are migrating from Horizon 1.x.y, start with the Migration Guide here: https://developers.stellar.org/docs/run-api-server/migrating/"
 )
@@ -193,6 +195,22 @@ func Flags() (*Config, support.ConfigOptions) {
 			},
 			ConfigKey: &config.CaptiveCoreConfigUseDB,
 		},
+		&support.ConfigOption{
+			Name:        CaptiveCoreConfigEnableSorobanDiagnosticEvents,
+			OptType:     types.Bool,
+			FlagDefault: false,
+			Required:    false,
+			Usage: `when enabled, Horizon ingestion will instruct the captive
+			              core invocation to emit Soroban diagnostic events.`,
+			CustomSetValue: func(opt *support.ConfigOption) error {
+				if val := viper.GetBool(opt.Name); val {
+					config.CaptiveCoreConfigEnableSorobanDiagnosticEvents = val
+					config.CaptiveCoreTomlParams.EnableSorobanDiagnosticEvents = val
+				}
+				return nil
+			},
+			ConfigKey: &config.CaptiveCoreConfigEnableSorobanDiagnosticEvents,
+		},
 		&support.ConfigOption{
 			Name:        "enable-captive-core-ingestion",
 			OptType:     types.Bool,