package main
import (
"os"
"path/filepath"
"testing"
"github.com/JianFeeeee/homeagentsdk/sdk"
)
type fakeSettings struct {
dataDir string
defs []*sdk.ConfigDef
}
func (f *fakeSettings) Get(string) (interface{}, error) { return nil, nil }
func (f *fakeSettings) Set(string, interface{}) error { return nil }
func (f *fakeSettings) SetSecret(string, interface{}) error { return nil }
func (f *fakeSettings) GetSecret(string) (string, error) { return "", nil }
func (f *fakeSettings) List(string) ([]string, error) { return nil, nil }
func (f *fakeSettings) GetCore(string) (interface{}, error) { return nil, nil }
func (f *fakeSettings) SetCore(string, interface{}) error { return nil }
func (f *fakeSettings) ListCore(string) ([]string, error) { return nil, nil }
func (f *fakeSettings) DataDir() string { return f.dataDir }
func (f *fakeSettings) GetPlugin(string, string) (interface{}, error) { return nil, nil }
func (f *fakeSettings) SetPlugin(string, string, interface{}) error { return nil }
func (f *fakeSettings) ListPlugin(string, string) ([]string, error) { return nil, nil }
func (f *fakeSettings) RegisterDef(def sdk.ConfigDef) { f.defs = append(f.defs, &def) }
func (f *fakeSettings) Defs(string) []*sdk.ConfigDef { return f.defs }
func (f *fakeSettings) Dump() map[string]interface{} { return nil }
func (f *fakeSettings) Plugins() []string { return nil }
func newTestPlugin(t *testing.T, scriptPath string) *Plugin {
t.Helper()
sett := &fakeSettings{dataDir: t.TempDir()}
s := sdk.New("editdoc", sett, nil, nil, nil, nil)
return &Plugin{
name: "editdoc",
sdk: s,
scriptPath: scriptPath,
venvPython: "/usr/local/bin/python3",
timeoutSec: 60,
}
}
func TestEmbeddedScriptHasProtocolMarker(t *testing.T) {
if !containsMarker(embeddedScript) {
t.Fatalf("内嵌脚本缺少协议标记 %q —— 防呆会把内嵌脚本自己判为旧版", scriptProtocolMarker)
}
t.Logf("协议标记=%q 内嵌脚本指纹=%s", scriptProtocolMarker, scriptStamp())
}
func TestOnlyOneBusinessScript(t *testing.T) {
if _, err := os.Stat("edit_doc.py"); err == nil {
t.Error("存在顶层 edit_doc.py:业务脚本只应有 embed/edit_doc.py 一份(顶部副本未被 embed,改了不生效)")
}
if _, err := os.Stat(filepath.Join("embed", "edit_doc.py")); err != nil {
t.Fatalf("缺少 embed/edit_doc.py: %v", err)
}
}
func TestResolveScriptIgnoresV1Script(t *testing.T) {
dir := t.TempDir()
v1 := filepath.Join(dir, "edit_doc_v1.py")
if err := os.WriteFile(v1, []byte(
"import sys\npath = sys.argv[1]\noperation = sys.argv[2]\n"), 0644); err != nil {
t.Fatal(err)
}
p := newTestPlugin(t, v1)
got, err := p.resolveScript()
if err != nil {
t.Fatalf("应回退到内嵌脚本,却报错: %v", err)
}
if got == v1 {
t.Fatal("v1 脚本被采用了 —— 防呆失效,6 个工具会被打挂")
}
if filepath.Base(got) != "edit_doc.py" {
t.Fatalf("应回退到 runtime/edit_doc.py,实际: %s", got)
}
if p.ignoredScriptPath != v1 {
t.Fatalf("ignoredScriptPath 未记录,实际: %q", p.ignoredScriptPath)
}
released, err := os.ReadFile(got)
if err != nil {
t.Fatalf("内嵌脚本未落盘: %v", err)
}
if string(released) != string(embeddedScript) {
t.Fatal("落盘的脚本与内嵌脚本字节不一致")
}
t.Logf("v1 被正确忽略,回退到 %s", got)
}
func TestResolveScriptAcceptsV2Script(t *testing.T) {
dir := t.TempDir()
v2 := filepath.Join(dir, "edit_doc_v2.py")
if err := os.WriteFile(v2, []byte(
"#!/usr/bin/env python3\n"+scriptProtocolMarker+"\n"), 0644); err != nil {
t.Fatal(err)
}
p := newTestPlugin(t, v2)
got, err := p.resolveScript()
if err != nil {
t.Fatalf("应直接采用 v2 脚本,却报错: %v", err)
}
if got != v2 {
t.Fatalf("v2 脚本未被采用,实际用了: %s", got)
}
if p.ignoredScriptPath != "" {
t.Fatalf("v2 脚本不应被标记忽略: %q", p.ignoredScriptPath)
}
}
func TestResolveScriptFallsBackToEmbedded(t *testing.T) {
p := newTestPlugin(t, "")
got, err := p.resolveScript()
if err != nil {
t.Fatalf("空 script_path 应回退内嵌脚本: %v", err)
}
if p.ignoredScriptPath != "" {
t.Fatalf("空配置不该有 ignoredScriptPath: %q", p.ignoredScriptPath)
}
got2, err := p.resolveScript()
if err != nil || got2 != got {
t.Fatalf("第二次解析不稳定: %s vs %s (%v)", got, got2, err)
}
stamp, err := os.ReadFile(filepath.Join(filepath.Dir(got), ".stamp"))
if err != nil || string(stamp) != scriptStamp() {
t.Fatalf("指纹文件异常: %q %v", stamp, err)
}
}
func TestResolveScriptMissingPathFallsBack(t *testing.T) {
p := newTestPlugin(t, filepath.Join(t.TempDir(), "not-there.py"))
got, err := p.resolveScript()
if err != nil {
t.Fatalf("路径不存在应回退内嵌脚本: %v", err)
}
if p.ignoredScriptPath != "" {
t.Fatalf("不存在的路径不该记为 ignored: %q", p.ignoredScriptPath)
}
if filepath.Base(got) != "edit_doc.py" {
t.Fatalf("应回退到 runtime/edit_doc.py,实际: %s", got)
}
}
func containsMarker(b []byte) bool {
m := []byte(scriptProtocolMarker)
for i := 0; i+len(m) <= len(b); i++ {
if string(b[i:i+len(m)]) == string(m) {
return true
}
}
return false
}