wehub-resource-sync
f99010fae1
Desktop Artifacts / Desktop Build (Linux) (push) Waiting to run
Desktop Artifacts / Desktop Build (Windows) (push) Waiting to run
Desktop Artifacts / Desktop Build (Linux (arm64)) (push) Waiting to run
Desktop Artifacts (macOS) / Desktop Build (macOS (aarch64)) (push) Waiting to run
Desktop Artifacts (macOS) / Desktop Build (macOS (x86_64)) (push) Waiting to run
CI / lint (push) Failing after 1s
CI / frontend (push) Failing after 1s
CI / scripts (push) Failing after 1s
CI / Go Test (ubuntu-latest) (push) Failing after 0s
CI / frontend-node-25 (push) Failing after 1s
CI / docs (push) Failing after 0s
CI / coverage (push) Failing after 0s
CI / e2e (push) Failing after 0s
Docker / build-and-push (push) Failing after 1s
CI / integration (push) Failing after 4m43s
CI / Go Test (windows-latest) (push) Has been cancelled
CI / Desktop Unit Tests (Windows) (push) Has been cancelled
69 lines
2.3 KiB
Go
69 lines
2.3 KiB
Go
package sync_test
|
|
|
|
import (
|
|
"database/sql"
|
|
"os"
|
|
"path/filepath"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"go.kenn.io/agentsview/internal/dbtest"
|
|
"go.kenn.io/agentsview/internal/parser"
|
|
"go.kenn.io/agentsview/internal/sync"
|
|
)
|
|
|
|
// TestSyncPathsAndSingleSession_KimiNewLayout pins down both engine
|
|
// sites that previously broke for the new .kimi-code layout:
|
|
//
|
|
// - SyncPaths (file-watcher entry point) must classify a 5-segment
|
|
// new-layout wire.jsonl and import it with the decoded project
|
|
// name rather than dropping the event.
|
|
// - SyncSingleSession must re-derive the project from the workdir
|
|
// directory, not the literal "agents" segment two levels up.
|
|
func TestSyncPathsAndSingleSession_KimiNewLayout(t *testing.T) {
|
|
if testing.Short() {
|
|
t.Skip("skipping integration test")
|
|
}
|
|
|
|
kimiDir := t.TempDir()
|
|
testDB := dbtest.OpenTestDB(t)
|
|
engine := sync.NewEngine(testDB, sync.EngineConfig{
|
|
AgentDirs: map[parser.AgentType][]string{
|
|
parser.AgentKimi: {kimiDir},
|
|
},
|
|
Machine: "local",
|
|
})
|
|
|
|
workdirDir := "wd_kimi-code_057f5c09ee3f"
|
|
sessionDir := "session_cf2c3d74-c9d2-4ae4-95b7-d1d817298382"
|
|
wirePath := filepath.Join(
|
|
kimiDir, workdirDir, sessionDir, "agents", "main", "wire.jsonl",
|
|
)
|
|
require.NoError(t, os.MkdirAll(filepath.Dir(wirePath), 0o755))
|
|
require.NoError(t, os.WriteFile(wirePath, []byte(
|
|
`{"type": "metadata", "protocol_version": "1.3"}`+"\n"+
|
|
`{"timestamp": 1704067200.0, "message": {"type": "TurnBegin", "payload": {"user_input": [{"type": "text", "text": "Hello Kimi"}]}}}`+"\n"+
|
|
`{"timestamp": 1704067202.0, "message": {"type": "TurnEnd", "payload": {}}}`+"\n",
|
|
), 0o644))
|
|
|
|
sessionID := "kimi:" + workdirDir + ":main:" + sessionDir
|
|
|
|
// SyncPaths routes through classifyOnePath; the new-layout file
|
|
// must be classified, imported, and carry the decoded project.
|
|
engine.SyncPaths([]string{wirePath})
|
|
assertSessionProject(t, testDB, sessionID, "kimi-code")
|
|
|
|
// Force a single-session resync by clearing file_mtime; the
|
|
// project must remain the decoded workdir, not "agents".
|
|
require.NoError(t, testDB.Update(func(tx *sql.Tx) error {
|
|
_, err := tx.Exec(
|
|
"UPDATE sessions SET file_mtime = NULL WHERE id = ?",
|
|
sessionID,
|
|
)
|
|
return err
|
|
}))
|
|
require.NoError(t, engine.SyncSingleSession(sessionID))
|
|
assertSessionProject(t, testDB, sessionID, "kimi-code")
|
|
}
|