CI / go-test (push) Canceled after 0s
CI / postgres-durable-first (push) Canceled after 0s
CI / codegen (push) Canceled after 0s
CI / govulncheck (push) Canceled after 0s
CI / race (push) Canceled after 0s
CI / fuzz-smoke (push) Canceled after 0s
CI / golangci (push) Canceled after 0s
CI / frontend (push) Canceled after 0s
CodeQL Advanced / Analyze (go) (push) Canceled after 0s
CodeQL Advanced / Analyze (actions) (push) Canceled after 0s
CodeQL Advanced / Analyze (javascript-typescript) (push) Canceled after 0s
Docs CI / build (push) Canceled after 0s
Docs Deploy (GitHub Pages) / build (push) Canceled after 0s
Release 3X-UI / build (386) (push) Canceled after 0s
Release 3X-UI / build (amd64) (push) Canceled after 0s
Release 3X-UI / build (arm64) (push) Canceled after 0s
Release 3X-UI / build (armv5) (push) Canceled after 0s
Release 3X-UI / build (armv6) (push) Canceled after 0s
Release 3X-UI / build (armv7) (push) Canceled after 0s
Release 3X-UI / build (s390x) (push) Canceled after 0s
Release 3X-UI / Build for Windows (amd64) (push) Canceled after 0s
Deploy Smoke Tests / noninteractive-install (ubuntu-24.04-arm) (push) Canceled after 0s
Deploy Smoke Tests / noninteractive-install (ubuntu-latest) (push) Canceled after 0s
Deploy Smoke Tests / release-tag-install (ubuntu-24.04-arm) (push) Canceled after 0s
Deploy Smoke Tests / release-tag-install (ubuntu-latest) (push) Canceled after 0s
Docs Deploy (GitHub Pages) / deploy (push) Canceled after 0s
Release 3X-UI / Publish rolling dev release (push) Canceled after 0s
150 lines
5.0 KiB
Go
150 lines
5.0 KiB
Go
package service
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/mhsanaei/3x-ui/v3/internal/database"
|
|
"github.com/mhsanaei/3x-ui/v3/internal/database/model"
|
|
)
|
|
|
|
// An imported database carries the source machine's listen addresses,
|
|
// certificates and node identity. Keeping this machine's own values is what
|
|
// stops the panel from becoming unreachable on its own address after a restore.
|
|
func TestImportKeepsHostBoundSettings(t *testing.T) {
|
|
setupConflictDB(t)
|
|
db := database.GetDB()
|
|
|
|
mine := map[string]string{
|
|
"webPort": "8443",
|
|
"webCertFile": "/etc/ssl/this-host.pem",
|
|
"webBasePath": "/mine/",
|
|
"subURI": "https://this-host.example/sub/",
|
|
"panelGuid": "this-host-guid",
|
|
"nodeMtlsClientCertPem": "this-host-leaf",
|
|
}
|
|
for key, value := range mine {
|
|
if err := db.Create(&model.Setting{Key: key, Value: value}).Error; err != nil {
|
|
t.Fatalf("seed %s: %v", key, err)
|
|
}
|
|
}
|
|
// A setting that belongs to the configuration, not the machine.
|
|
if err := db.Create(&model.Setting{Key: "remarkTemplate", Value: "mine"}).Error; err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
kept := captureHostBoundSettings()
|
|
if len(kept.values) != len(mine) {
|
|
t.Fatalf("captured %d host settings, want %d: %v", len(kept.values), len(mine), kept.values)
|
|
}
|
|
|
|
// Stand in for the import: every row now holds the source machine's value.
|
|
for key := range mine {
|
|
if err := db.Model(&model.Setting{}).Where("key = ?", key).
|
|
Update("value", "from-imported-file").Error; err != nil {
|
|
t.Fatalf("overwrite %s: %v", key, err)
|
|
}
|
|
}
|
|
if err := db.Model(&model.Setting{}).Where("key = ?", "remarkTemplate").
|
|
Update("value", "from-imported-file").Error; err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
restoreHostBoundSettings(kept)
|
|
|
|
for key, want := range mine {
|
|
var got model.Setting
|
|
if err := db.Where("key = ?", key).First(&got).Error; err != nil {
|
|
t.Fatalf("read back %s: %v", key, err)
|
|
}
|
|
if got.Value != want {
|
|
t.Fatalf("setting %s = %q after import, want this machine's %q", key, got.Value, want)
|
|
}
|
|
}
|
|
|
|
var carried model.Setting
|
|
if err := db.Where("key = ?", "remarkTemplate").First(&carried).Error; err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if carried.Value != "from-imported-file" {
|
|
t.Fatalf("remarkTemplate = %q, want the imported value: only host-bound keys may survive", carried.Value)
|
|
}
|
|
}
|
|
|
|
// A certificate path this machine never set must not be inherited from the
|
|
// source. Lazily minted material is the opposite case and is covered below.
|
|
func TestImportDropsHostBoundSettingsThisMachineNeverHad(t *testing.T) {
|
|
setupConflictDB(t)
|
|
db := database.GetDB()
|
|
|
|
kept := captureHostBoundSettings()
|
|
|
|
for _, key := range []string{"webCertFile", "subCertFile"} {
|
|
if err := db.Create(&model.Setting{Key: key, Value: "from-imported-file"}).Error; err != nil {
|
|
t.Fatalf("seed imported %s: %v", key, err)
|
|
}
|
|
}
|
|
|
|
restoreHostBoundSettings(kept)
|
|
|
|
for _, key := range []string{"webCertFile", "subCertFile"} {
|
|
var count int64
|
|
if err := db.Model(&model.Setting{}).Where("key = ?", key).Count(&count).Error; err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if count != 0 {
|
|
t.Fatalf("imported %s survived although this machine had no row for it", key)
|
|
}
|
|
}
|
|
}
|
|
|
|
// Node mTLS material is minted on demand, so a fresh install has no row and the
|
|
// imported copy is the only one there is — including the CA private key (#6227).
|
|
func TestImportKeepsLazilyMintedMaterialThisMachineNeverHad(t *testing.T) {
|
|
setupConflictDB(t)
|
|
db := database.GetDB()
|
|
|
|
kept := captureHostBoundSettings()
|
|
|
|
for _, key := range []string{"nodeMtlsCaCertPem", "nodeMtlsCaKeyPem", "nodeMtlsClientCertPem", "nodeMtlsClientKeyPem", "nodeMtlsClientCAPem"} {
|
|
if err := db.Create(&model.Setting{Key: key, Value: "from-imported-file"}).Error; err != nil {
|
|
t.Fatalf("seed imported %s: %v", key, err)
|
|
}
|
|
}
|
|
|
|
restoreHostBoundSettings(kept)
|
|
|
|
for _, key := range []string{"nodeMtlsCaCertPem", "nodeMtlsCaKeyPem", "nodeMtlsClientCertPem", "nodeMtlsClientKeyPem", "nodeMtlsClientCAPem"} {
|
|
var got model.Setting
|
|
if err := db.Where("key = ?", key).First(&got).Error; err != nil {
|
|
t.Fatalf("%s was dropped; restoring a backup onto a reinstalled panel would lose it: %v", key, err)
|
|
}
|
|
}
|
|
}
|
|
|
|
// An empty local value is the normal state once Panel Settings has been saved:
|
|
// GORM's Assign(struct) dropped it, so the source machine's path survived.
|
|
func TestImportRestoresEmptyLocalValueOverImported(t *testing.T) {
|
|
setupConflictDB(t)
|
|
db := database.GetDB()
|
|
|
|
if err := db.Create(&model.Setting{Key: "webCertFile", Value: ""}).Error; err != nil {
|
|
t.Fatalf("seed local empty: %v", err)
|
|
}
|
|
kept := captureHostBoundSettings()
|
|
|
|
if err := db.Model(&model.Setting{}).Where("key = ?", "webCertFile").
|
|
Update("value", "/etc/ssl/source-host.pem").Error; err != nil {
|
|
t.Fatalf("seed imported: %v", err)
|
|
}
|
|
|
|
restoreHostBoundSettings(kept)
|
|
|
|
var got model.Setting
|
|
if err := db.Where("key = ?", "webCertFile").First(&got).Error; err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if got.Value != "" {
|
|
t.Fatalf("webCertFile = %q, want the empty local value back: the panel still points at the source machine's certificate", got.Value)
|
|
}
|
|
}
|