Li-Day-Day
58c19856fd
* feat(runtime): improve Lite gateway scheduling and proxy stability - Expand the runtime gateway port range to match 100 instances per pod - Scale runtime deployments based on pending backlog - Serialize gateway creation per pod and handle starting/creating states - Clean up missing gateway bindings from runtime agent reports - Improve Lite gateway proxy token stripping and auth header injection - Update deployment manifests, docs, and related tests * fix(runtime): harden Hermes Lite gateway recovery - Add hashed gateway token aliases for short-term token compatibility - Fix /resume conversations failing when old sessions use mismatched gateway tokens - Recover ports only from stale error bindings without affecting active gateways * feat(runtime): enable bidirectional desktop clipboard and direct proxy - Enable WebTop/Selkies/Kasm clipboard by default with per-instance overrides - Document clipboard verification, configuration pitfalls, and IME troubleshooting - Enable direct desktop proxy in the K8s and K3s manifests --------- Co-authored-by: litiantian03 <litiantian03@ieisystem.com>
76 lines
2.6 KiB
Go
76 lines
2.6 KiB
Go
package services
|
|
|
|
import "testing"
|
|
|
|
func TestDefaultImagePullPolicy_Default(t *testing.T) {
|
|
t.Setenv("IMAGE_PULL_POLICY", "")
|
|
got := defaultImagePullPolicy()
|
|
if got != "IfNotPresent" {
|
|
t.Fatalf("expected IfNotPresent, got %q", got)
|
|
}
|
|
}
|
|
|
|
func TestDefaultImagePullPolicy_IgnoresEnvOverride(t *testing.T) {
|
|
for _, envValue := range []string{"Always", "Never", "IfNotPresent", " "} {
|
|
t.Run(envValue, func(t *testing.T) {
|
|
t.Setenv("IMAGE_PULL_POLICY", envValue)
|
|
got := defaultImagePullPolicy()
|
|
if got != "IfNotPresent" {
|
|
t.Fatalf("expected IfNotPresent, got %q", got)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestBuildRuntimeConfig_HermesUsesWebtopDefaults(t *testing.T) {
|
|
config := buildRuntimeConfig("hermes", "hermes", "latest", nil, nil)
|
|
|
|
if config.Port != 3001 {
|
|
t.Fatalf("expected Hermes port 3001, got %d", config.Port)
|
|
}
|
|
if config.MountPath != "/config" {
|
|
t.Fatalf("expected Hermes mount path /config, got %q", config.MountPath)
|
|
}
|
|
if config.Env["HERMES_HOME"] != "/config/.hermes" {
|
|
t.Fatalf("expected Hermes HERMES_HOME /config/.hermes, got %q", config.Env["HERMES_HOME"])
|
|
}
|
|
if config.Env["SUBFOLDER"] != "/" {
|
|
t.Fatalf("expected Hermes default SUBFOLDER /, got %q", config.Env["SUBFOLDER"])
|
|
}
|
|
if config.Env["KASM_SVC_SEND_CUT_TEXT"] != kasmClipboardSendEnabled {
|
|
t.Fatalf("expected Hermes to enable outbound clipboard sync, got %q", config.Env["KASM_SVC_SEND_CUT_TEXT"])
|
|
}
|
|
if config.Env["KASM_SVC_ACCEPT_CUT_TEXT"] != kasmClipboardAcceptEnabled {
|
|
t.Fatalf("expected Hermes to enable inbound clipboard sync, got %q", config.Env["KASM_SVC_ACCEPT_CUT_TEXT"])
|
|
}
|
|
assertSelkiesClipboardEnabled(t, config.Env)
|
|
if !usesWebtopImage("hermes") {
|
|
t.Fatalf("expected Hermes to use webtop proxy behavior")
|
|
}
|
|
}
|
|
|
|
func TestBuildRuntimeConfig_OpenClawEnablesDesktopClipboardSync(t *testing.T) {
|
|
config := buildRuntimeConfig("openclaw", "openclaw", "latest", nil, nil)
|
|
|
|
if config.Env["KASM_SVC_SEND_CUT_TEXT"] != kasmClipboardSendEnabled {
|
|
t.Fatalf("expected OpenClaw to enable outbound clipboard sync, got %q", config.Env["KASM_SVC_SEND_CUT_TEXT"])
|
|
}
|
|
if config.Env["KASM_SVC_ACCEPT_CUT_TEXT"] != kasmClipboardAcceptEnabled {
|
|
t.Fatalf("expected OpenClaw to enable inbound clipboard sync, got %q", config.Env["KASM_SVC_ACCEPT_CUT_TEXT"])
|
|
}
|
|
assertSelkiesClipboardEnabled(t, config.Env)
|
|
}
|
|
|
|
func assertSelkiesClipboardEnabled(t *testing.T, env map[string]string) {
|
|
t.Helper()
|
|
for _, key := range []string{
|
|
"SELKIES_CLIPBOARD_ENABLED",
|
|
"SELKIES_CLIPBOARD_IN_ENABLED",
|
|
"SELKIES_CLIPBOARD_OUT_ENABLED",
|
|
} {
|
|
if got := env[key]; got != selkiesClipboardEnabled {
|
|
t.Fatalf("expected %s=%q, got %q", key, selkiesClipboardEnabled, got)
|
|
}
|
|
}
|
|
}
|