status-im · marcinczenko · Oct 31, 2025 · Oct 31, 2025 · Oct 31, 2025 · Oct 31, 2025
diff --git a/.gitignore b/.gitignore
@@ -133,4 +133,8 @@ pkg/sentry/SENTRY_PRODUCTION
 !vendor/**/migrations.go
 
 # Libs directory (Codex)
-libs
+libs
+coverage_merged.out
+test_0.coverage.out
+test-coverage.html
+api/pre_login.log
diff --git a/.vscode/launch.json b/.vscode/launch.json
@@ -0,0 +1,100 @@
+{
+  // Use IntelliSense to learn about possible attributes.
+  // Hover to view descriptions of existing attributes.
+  // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+  "version": "0.2.0",
+  "configurations": [
+    {
+      "name": "Debug Current Test",
+      "type": "go",
+      "request": "launch",
+      "mode": "test",
+      "program": "${fileDirname}",
+      "args": ["-test.v", "-test.run", "^${selectedText}$"],
+      "buildFlags": "-tags=gowaku_no_rln,gowaku_skip_migrations",
+      "env": {
+        "CGO_ENABLED": "1"
+      }
+    },
+    {
+      "name": "Debug Current Test Function",
+      "type": "go",
+      "request": "launch",
+      "mode": "test",
+      "program": "${fileDirname}",
+      "buildFlags": "-tags=gowaku_no_rln,gowaku_skip_migrations",
+      "env": {
+        "CGO_ENABLED": "1"
+      }
+    },
+    {
+      "name": "Debug All Tests in Current File",
+      "type": "go",
+      "request": "launch",
+      "mode": "test",
+      "program": "${fileDirname}",
+      "args": ["-test.v"],
+      "buildFlags": "-tags=gowaku_no_rln,gowaku_skip_migrations",
+      "env": {
+        "CGO_ENABLED": "1"
+      }
+    },
+    {
+      "name": "Debug All Tests in Current Package",
+      "type": "go",
+      "request": "launch",
+      "mode": "test",
+      "program": "${fileDirname}",
+      "args": ["-test.v", "-count=1"],
+      "buildFlags": "-tags=gowaku_no_rln,gowaku_skip_migrations",
+      "env": {
+        "CGO_ENABLED": "1"
+      }
+    },
+    {
+      "name": "Debug Specific Test Suite (e.g., TestMessengerCommunitiesTokenPermissionsSuite)",
+      "type": "go",
+      "request": "launch",
+      "mode": "test",
+      "program": "${workspaceFolder}/protocol",
+      "args": [
+        "-test.v",
+        "-test.run",
+        "TestMessengerCommunitiesTokenPermissionsSuite"
+      ],
+      "buildFlags": "-tags=gowaku_no_rln,gowaku_skip_migrations",
+      "env": {
+        "CGO_ENABLED": "1"
+      }
+    },
+    {
+      "name": "Debug Specific Test Case",
+      "type": "go",
+      "request": "launch",
+      "mode": "test",
+      "program": "${workspaceFolder}/protocol",
+      "args": [
+        "-test.v",
+        "-test.run",
+        "TestMessengerCommunitiesTokenPermissionsSuite/TestFullCodexIntegration",
+        "-count=1"
+      ],
+      "buildFlags": "-tags=gowaku_no_rln,gowaku_skip_migrations",
+      "env": {
+        "CGO_ENABLED": "1"
+      }
+    },
+    {
+      "name": "Debug Mock Tests (Codex)",
+      "type": "go",
+      "request": "launch",
+      "mode": "test",
+      "program": "${workspaceFolder}/protocol/communities",
+      "args": ["-test.v", "-test.run", "TestMock"],
+      "buildFlags": "-tags=gowaku_no_rln,gowaku_skip_migrations",
+      "env": {
+        "CGO_ENABLED": "1"
+      }
+    }
+  ]
+}
@@ -215,7 +215,7 @@ else
 CODEX_OS := $(detected_OS)
 endif
 
-CODEX_VERSION ?= "v0.0.24"
+CODEX_VERSION := $(shell go list -m -f '{{.Version}}' github.com/codex-storage/codex-go-bindings 2>/dev/null)
 CODEX_DOWNLOAD_URL := "https://github.com/codex-storage/codex-go-bindings/releases/download/$(CODEX_VERSION)/codex-${CODEX_OS}-${CODEX_ARCH}.zip"
 
 fetch-libcodex:
@@ -432,7 +432,7 @@ lint-panics: generate
 lint: generate lint-panics
 	$(CGO_ENV) golangci-lint --build-tags '$(BUILD_TAGS)' run ./...
 
-clean: ##@other Cleanup
+clean: clean-libcodex | ##@other Cleanup
 	rm -fr build/bin/*
 
 git-clean:

diff --git a/api/backend_test.go b/api/backend_test.go
@@ -1527,6 +1527,7 @@ func TestRestoreKeycardAccountAndLogin(t *testing.T) {
 			},
 			"torrentConfigEnabled":   false,
 			"torrentConfigPort":      0,
+			"codexConfigEnabled":     false,
 			"keycardInstanceUID":     "a84599394887b742eed9a99d3834a797",
 			"keycardPairingDataFile": path.Join(tmpdir, DefaultKeycardPairingDataFileRelativePath),
 		},

diff --git a/api/default_test.go b/api/default_test.go
@@ -11,15 +11,16 @@ import (
 
 func setupConfigs() (*params.NodeConfig, *requests.APIConfig) {
 	newNodeConfig := &params.NodeConfig{
-		APIModules:       "test, eth, wakuv2",
-		ConnectorConfig:  params.ConnectorConfig{Enabled: true},
-		HTTPEnabled:      true,
-		HTTPHost:         "0.0.0.0",
-		HTTPPort:         8545,
-		HTTPVirtualHosts: []string{"status-go"},
-		WSEnabled:        false,
-		WSHost:           "127.0.0.1",
-		WSPort:           8586,
+		APIModules:                           "test, eth, wakuv2",
+		ConnectorConfig:                      params.ConnectorConfig{Enabled: true},
+		HTTPEnabled:                          true,
+		HTTPHost:                             "0.0.0.0",
+		HTTPPort:                             8545,
+		HTTPVirtualHosts:                     []string{"status-go"},
+		WSEnabled:                            false,
+		WSHost:                               "127.0.0.1",
+		WSPort:                               8586,
+		HistoryArchiveDistributionPreference: params.DefaultHistoryArchiveDistributionPreference,
 	}
 
 	apiConfig := &requests.APIConfig{

diff --git a/api/defaults.go b/api/defaults.go
@@ -277,6 +277,8 @@ func DefaultNodeConfig(installationID, keyUID string, request *requests.CreateAc
 		nodeConfig.LogEnabled = false
 	}
 
+	nodeConfig.HistoryArchiveDistributionPreference = params.DefaultHistoryArchiveDistributionPreference
+
 	if request.TestOverrideNetworks != nil {
 		nodeConfig.Networks = request.TestOverrideNetworks
 	} else {
@@ -343,18 +345,31 @@ func DefaultNodeConfig(installationID, keyUID string, request *requests.CreateAc
 
 	if request.TorrentConfigEnabled != nil {
 		nodeConfig.TorrentConfig.Enabled = *request.TorrentConfigEnabled
-
 	}
 	if request.TorrentConfigPort != nil {
 		nodeConfig.TorrentConfig.Port = *request.TorrentConfigPort
 	}
 
+	if request.CodexConfigEnabled != nil {
+		nodeConfig.CodexConfig.Enabled = *request.CodexConfigEnabled
+	}
+
+	if request.ImportInitialDelay != nil {
+		nodeConfig.ImportInitialDelay = *request.ImportInitialDelay
+	}
+
+	if request.MessageArchiveInterval != nil {
+		nodeConfig.MessageArchiveInterval = *request.MessageArchiveInterval
+	}
+
 	nodeConfig.CodexConfig = params.CodexConfig{
-		Enabled: false,
-		Config: codex.Config{
-			DataDir:        filepath.Join(nodeConfig.RootDataDir, params.ArchivesRelativePath),
+		Enabled:               nodeConfig.CodexConfig.Enabled,
+		HistoryArchiveDataDir: filepath.Join(nodeConfig.RootDataDir, "codex", "archivedata"),
+		CodexNodeConfig: codex.Config{
+			DataDir:        filepath.Join(nodeConfig.RootDataDir, "codex", "codexdata"),
 			BlockRetries:   params.BlockRetries,
 			MetricsEnabled: false,
+			LogFormat:      codex.LogFormatNoColors,
 		},
 	}
 

diff --git a/api/geth_backend.go b/api/geth_backend.go
@@ -583,7 +583,7 @@ func (b *GethStatusBackend) workaroundToFixBadMigration(request *requests.Login)
 	if currentConf.NetworkID == 0 &&
 		currentConf.NodeKey == "" {
 		// check if exist old node config
-		oldNodeConf := &params.NodeConfig{}
+		oldNodeConf := &params.NodeConfig{HistoryArchiveDistributionPreference: params.DefaultHistoryArchiveDistributionPreference}
 		err = b.appDB.QueryRow("SELECT node_config FROM settings WHERE synthetic_id = 'id'").Scan(&sqlite.JSONBlob{Data: oldNodeConf})
 		if err != nil && err != sql.ErrNoRows {
 			return err
@@ -692,7 +692,8 @@ func (b *GethStatusBackend) loginAccount(request *requests.Login) error {
 
 	defaultCfg := &params.NodeConfig{
 		// why we need this? relate PR: https://github.com/status-im/status-go/pull/4014
-		KeycardPairingDataFile: filepath.Join(b.rootDataDir, DefaultKeycardPairingDataFileRelativePath),
+		KeycardPairingDataFile:               filepath.Join(b.rootDataDir, DefaultKeycardPairingDataFileRelativePath),
+		HistoryArchiveDistributionPreference: params.DefaultHistoryArchiveDistributionPreference,
 	}
 
 	defaultCfg.WalletConfig = buildWalletConfig(&request.WalletConfig, &request.WalletSecretsConfig)

diff --git a/appdatabase/migrations/sql/1761795811_add_archive_distribution_preference.up.sql b/appdatabase/migrations/sql/1761795811_add_archive_distribution_preference.up.sql
diff --git a/appdatabase/migrations/sql/1761913234_add_codex_config.up.sql b/appdatabase/migrations/sql/1761913234_add_codex_config.up.sql
@@ -0,0 +1,29 @@
+CREATE TABLE codex_config (
+  enabled BOOLEAN DEFAULT false,
+  history_archive_data_dir VARCHAR NOT NULL,
+  log_level TEXT DEFAULT 'info',
+  log_format TEXT DEFAULT 'auto',
+  metrics_enabled BOOLEAN DEFAULT false,
+  metrics_address TEXT DEFAULT '127.0.0.1',
+  metrics_port INTEGER DEFAULT 9090,
+  data_dir VARCHAR NOT NULL,
+  listen_addrs TEXT DEFAULT '["/ip4/0.0.0.0/tcp/0"]',
+  nat TEXT DEFAULT 'any',
+  disc_port INTEGER DEFAULT 8090,
+  net_privkey TEXT DEFAULT 'key',
+  bootstrap_nodes TEXT,
+  max_peers INTEGER DEFAULT 160,
+  num_threads INTEGER DEFAULT 0,
+  agent_string TEXT DEFAULT 'Codex',
+  repo_kind TEXT DEFAULT 'fs',
+  storage_quota INTEGER DEFAULT 21474836480, -- 20 GiB
+  block_ttl INTEGER DEFAULT 2592000, -- 30 days
+  block_maintenance_interval INTEGER DEFAULT 600, -- 10 min
+  block_maintenance_number_of_blocks INTEGER DEFAULT 1000,
+  block_retries INTEGER DEFAULT 3000,
+  cache_size INTEGER DEFAULT 0,
+  log_file TEXT DEFAULT '',
+
+  synthetic_id VARCHAR DEFAULT 'id' PRIMARY KEY
+) WITHOUT ROWID;
+
diff --git a/...grations/sql/1762000000_add_history_archive_distribution_preference_to_node_config.up.sql b/...grations/sql/1762000000_add_history_archive_distribution_preference_to_node_config.up.sql
@@ -0,0 +1,2 @@
+ALTER TABLE node_config
+  ADD COLUMN history_archive_distribution_preference TEXT DEFAULT 'codex';
diff --git a/appdatabase/node_config_test.go b/appdatabase/node_config_test.go
@@ -9,6 +9,7 @@ import (
 	"sort"
 	"testing"
 
+	"github.com/codex-storage/codex-go-bindings/codex"
 	"github.com/stretchr/testify/require"
 
 	"github.com/status-im/status-go/nodecfg"
@@ -26,21 +27,22 @@ func setupTestDB(t *testing.T) *sql.DB {
 
 func randomNodeConfig() *params.NodeConfig {
 	return &params.NodeConfig{
-		NetworkID:          uint64(int64(randomInt(math.MaxInt64))),
-		NodeKey:            randomString(),
-		APIModules:         randomString(),
-		WalletConfig:       params.WalletConfig{Enabled: randomBool()},
-		BrowsersConfig:     params.BrowsersConfig{Enabled: randomBool()},
-		PermissionsConfig:  params.PermissionsConfig{Enabled: randomBool()},
-		ConnectorConfig:    params.ConnectorConfig{Enabled: randomBool()},
-		LogEnabled:         randomBool(),
-		LogDir:             randomString(),
-		LogFile:            randomString(),
-		LogLevel:           randomString(),
-		LogMaxBackups:      randomInt(math.MaxInt64),
-		LogMaxSize:         randomInt(math.MaxInt64),
-		LogCompressRotated: randomBool(),
-		LogToStderr:        randomBool(),
+		NetworkID:                            uint64(int64(randomInt(math.MaxInt64))),
+		NodeKey:                              randomString(),
+		APIModules:                           randomString(),
+		WalletConfig:                         params.WalletConfig{Enabled: randomBool()},
+		BrowsersConfig:                       params.BrowsersConfig{Enabled: randomBool()},
+		PermissionsConfig:                    params.PermissionsConfig{Enabled: randomBool()},
+		ConnectorConfig:                      params.ConnectorConfig{Enabled: randomBool()},
+		HistoryArchiveDistributionPreference: randomString(),
+		LogEnabled:                           randomBool(),
+		LogDir:                               randomString(),
+		LogFile:                              randomString(),
+		LogLevel:                             randomString(),
+		LogMaxBackups:                        randomInt(math.MaxInt64),
+		LogMaxSize:                           randomInt(math.MaxInt64),
+		LogCompressRotated:                   randomBool(),
+		LogToStderr:                          randomBool(),
 		ClusterConfig: params.ClusterConfig{
 			Enabled: randomBool(),
 			Fleet:   randomString(),
@@ -55,6 +57,16 @@ func randomNodeConfig() *params.NodeConfig {
 		WakuV2Config: params.WakuV2Config{
 			LightClient: randomBool(),
 		},
+		CodexConfig: params.CodexConfig{
+			Enabled:               randomBool(),
+			HistoryArchiveDataDir: randomString(),
+			CodexNodeConfig: codex.Config{
+				DataDir:       randomString(),
+				DiscoveryPort: randomInt(65535),
+				BlockRetries:  randomInt(10),
+				LogLevel:      randomString(),
+			},
+		},
 	}
 }
 
@@ -66,6 +78,7 @@ func TestGetNodeConfig(t *testing.T) {
 
 	dbNodeConfig, err := nodecfg.GetNodeConfigFromDB(db)
 	require.NoError(t, err)
+
 	require.Equal(t, nodeConfig, dbNodeConfig)
 }
 

diff --git a/go.mod b/go.mod
@@ -83,7 +83,7 @@ require (
 	github.com/btcsuite/btcd/btcutil v1.1.6
 	github.com/cenkalti/backoff/v4 v4.2.1
 	github.com/cockroachdb/errors v1.11.3
-	github.com/codex-storage/codex-go-bindings v0.0.24
+	github.com/codex-storage/codex-go-bindings v0.0.26
 	github.com/getsentry/sentry-go v0.29.1
 	github.com/golang-migrate/migrate/v4 v4.15.2
 	github.com/gorilla/sessions v1.2.1

diff --git a/go.sum b/go.sum
@@ -548,8 +548,8 @@ github.com/cockroachdb/redact v1.1.5/go.mod h1:BVNblN9mBWFyMyqK1k3AAiSxhvhfK2oOZ
 github.com/cockroachdb/tokenbucket v0.0.0-20230807174530-cc333fc44b06 h1:zuQyyAKVxetITBuuhv3BI9cMrmStnpT18zmgmTxunpo=
 github.com/cockroachdb/tokenbucket v0.0.0-20230807174530-cc333fc44b06/go.mod h1:7nc4anLGjupUW/PeY5qiNYsdNXj7zopG+eqsS7To5IQ=
 github.com/codahale/hdrhistogram v0.0.0-20161010025455-3a0bb77429bd/go.mod h1:sE/e/2PUdi/liOCUjSTXgM1o87ZssimdTWN964YiIeI=
-github.com/codex-storage/codex-go-bindings v0.0.24 h1:uUlLiUf5zuec34AvtzpAr4BOCE71FuxqTMBholMR86M=
-github.com/codex-storage/codex-go-bindings v0.0.24/go.mod h1:hP/n9iDZqQP4MytkgUepl3yMMsZy5Jbk9lQbbbVJ51Q=
+github.com/codex-storage/codex-go-bindings v0.0.26 h1:v7PgwJq+dTb7YF4i19Dgx7iHJv+frqDbO9AP7qh2N1k=
+github.com/codex-storage/codex-go-bindings v0.0.26/go.mod h1:hP/n9iDZqQP4MytkgUepl3yMMsZy5Jbk9lQbbbVJ51Q=
 github.com/consensys/bavard v0.1.8-0.20210406032232-f3452dc9b572/go.mod h1:Bpd0/3mZuaj6Sj+PqrmIquiOKy397AKGThQPaGzNXAQ=
 github.com/consensys/gnark-crypto v0.4.1-0.20210426202927-39ac3d4b3f1f/go.mod h1:815PAHg3wvysy0SyIqanF8gZ0Y1wjk/hrDHD/iT88+Q=
 github.com/consensys/gnark-crypto v0.18.0 h1:vIye/FqI50VeAr0B3dx+YjeIvmc3LWz4yEfbWBpTUf0=

diff --git a/multiaccounts/accounts/database_test.go b/multiaccounts/accounts/database_test.go
@@ -46,7 +46,7 @@ func TestMoveWalletAccount(t *testing.T) {
 	setting := settings.Settings{
 		Networks: &networks,
 	}
-	config := params.NodeConfig{}
+	config := params.NodeConfig{HistoryArchiveDistributionPreference: params.DefaultHistoryArchiveDistributionPreference}
 	err := db.CreateSettings(setting, config)
 	require.NoError(t, err)
 

diff --git a/multiaccounts/settings/database_test.go b/multiaccounts/settings/database_test.go
@@ -20,7 +20,8 @@ import (
 
 var (
 	config = params.NodeConfig{
-		NetworkID: 10,
+		NetworkID:                            10,
+		HistoryArchiveDistributionPreference: params.DefaultHistoryArchiveDistributionPreference,
 	}
 
 	networks = json.RawMessage("{}")

diff --git a/multiaccounts/settings_wallet/database_test.go b/multiaccounts/settings_wallet/database_test.go
@@ -14,8 +14,9 @@ import (
 
 var (
 	config = params.NodeConfig{
-		NetworkID:   10,
-		RootDataDir: "test",
+		NetworkID:                            10,
+		RootDataDir:                          "test",
+		HistoryArchiveDistributionPreference: params.DefaultHistoryArchiveDistributionPreference,
 	}
 	networks    = json.RawMessage("{}")
 	settingsObj = settings.Settings{
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		ALTER TABLE node_config
		ADD COLUMN history_archive_distribution_preference TEXT DEFAULT 'codex';