wip

Author: tamirms

ingest/ledgerbackend/toml.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"os"
 	"regexp"
+	"strconv"
 	"strings"
 
 	"github.com/stellar/go/support/errors"
@@ -455,6 +456,56 @@ func (c *CaptiveCoreToml) CatchupToml() (*CaptiveCoreToml, error) {
 	return offline, nil
 }
 
+// coreVersion helper struct identify a core version and provides the
+// utilities to compare the version ( i.e. minor + major pair ) to a predefined
+// version.
+type coreVersion struct {
+	major int
+	minor int
+}
+
+// greaterThanOrEqual compares the core version to a version specific. If unable
+// to make the decision, the result is always "false", leaning toward the
+// common denominator.
+func (c coreVersion) greaterThanOrEqual(other coreVersion) bool {
+	if c.major == 0 && c.minor == 0 {
+		return false
+	}
+	return (c.major == other.major && c.minor >= other.minor) || (c.major > other.minor)
+}
+
+func (c *CaptiveCoreToml) checkCoreVersion(coreBinaryPath string) coreVersion {
+	if coreBinaryPath == "" {
+		return coreVersion{}
+	}
+
+	versionRaw, err := CoreBuildVersion(coreBinaryPath)
+	if err != nil {
+		return coreVersion{}
+	}
+
+	var version [2]int
+
+	re := regexp.MustCompile(`\D*(\d*)\.(\d*).*`)
+	versionStr := re.FindStringSubmatch(versionRaw)
+	if err == nil && len(versionStr) == 3 {
+		for i := 1; i < len(versionStr); i++ {
+			val, err := strconv.Atoi((versionStr[i]))
+			if err != nil {
+				break
+			}
+			version[i-1] = val
+		}
+	}
+
+	return coreVersion{
+		major: version[0],
+		minor: version[1],
+	}
+}
+
+var minVersionForBucketlistCaching = coreVersion{major: 22, minor: 2}
+
 func (c *CaptiveCoreToml) setDefaults(params CaptiveCoreTomlParams) {
 	if params.UseDB && !c.tree.Has("DATABASE") {
 		c.Database = "sqlite3://stellar.db"
@@ -523,7 +574,8 @@ func (c *CaptiveCoreToml) setDefaults(params CaptiveCoreTomlParams) {
 
 	}
 
-	if !c.tree.Has("BUCKETLIST_DB_MEMORY_FOR_CACHING") {
+	if !c.tree.Has("BUCKETLIST_DB_MEMORY_FOR_CACHING") &&
+		c.checkCoreVersion(params.CoreBinaryPath).greaterThanOrEqual(minVersionForBucketlistCaching) {
 		// set BUCKETLIST_DB_MEMORY_FOR_CACHING to 0 to disable allocation of
 		// memory for caching entries in BucketListDB.
 		// If we do not set BUCKETLIST_DB_MEMORY_FOR_CACHING, core will apply