mirror of
https://github.com/langgenius/dify-plugin-daemon.git
synced 2026-07-22 09:45:27 -04:00
888ad788bc
* refactor: introduce local plugin control panel and cleanup environment setup process * fix: args * refactor: new local runtime * temp: stash work for refactor on RemotePluginServer * refactor: unify local runtime lifetime and sperate init environment process * chore: add missing files * stash * refactor: local plugin lifetime control * refactor: complete installation process of control panel * refactor: adapt service layer to new controlpanel * refactor: pluginManager.Install * fix: add routine wrap to InstallServerless, avoid blocking main thread * feat: reinstall serverless runtime * chore: add comments to Reinstall and update confusing naming * refactor: unify install plugin service * refactor: add labels to debugging runtime * refactor: add getters to plugin manager * refactor: split install service to decode/install_task/install service * ??? * refactor: adapt controllers * refactor: session write * refactor: session runtime * Refine install task orchestration (#501) * refactor: installing task * refactor cluster management, decouple lifetime management and cluster * fix cli test command * fix: cleanup TODO comments and implement GracefulStop for instance * feat: add logger to control panel * fix: multiple nil references * refactor: better lifetime control * refactor: better cycle interval * fix(LocalPluginRuntime): prevent returning err when it's not error * fix: avoid adding empty PipExtraArgs * fix: missing errors in Environment init * fix: add truncateMessage to avoid db explosion * cleanup: better lifecycle management * fix: init status at the beginning of installation * optimize: GracefulStop for pluginInstance * refactor: tests * refactor: centralize routine labels (#504) * cleanup: RoutineKey * fix: init routine pool * fix: correctly handle cluster register error * fix: memory leak * fix: add \n to instance write * fix(installer.go): set success to true after succeed for defer func * refactor * fix: missing cwd in testutils * fix: scaleup default runtime nums to 1 when testing * fix: localruntime appconfig in testing module * Update internal/core/local_runtime/load_balancing.go Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com> * fix: more efficiency implement in installer_local.go * fix: returns after failing in onDebuggingRuntimeDisconnected * fix: returns after failing in onDebuggingRuntimeDisconnected * fix: splits tests * refactor: naming * refactor: manifest.VersionX * fix: adapt SetDefault to tests * fix: enforce use constants in DBType * fix: generate * fix: linter * cleanup tests * refactor: change package to * cleanup: useless codes * Update internal/cluster/plugin.go Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com> * cleanup * refactor: decouple connection_key management from debugging_time * refactor: confused naming * feat: recycle resources to adapt to https://github.com/langgenius/dify-plugin-daemon/pull/500 * refactor: confusing redirecting * fix: support get serverless runtime * fix: race condition in Launching * fix: avoid ManifestValidate in first step of debugging handshake * fix: adding ReleaseAllLocks to finalizers * wtf: what a beautiful code * refactor: rename Stream.Async to Stream.Process * fix: kill process if daed instance was detected * fix: correctly handle failures * fix: consistence of difference interfaces * fix: add stacktrace to panic * fix: only trigger once event * fix: ensure plugin runtime was shutdown * feat: cleanup install tasks * fix: add scale logs --------- Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>
130 lines
2.6 KiB
Go
130 lines
2.6 KiB
Go
package parser
|
|
|
|
import (
|
|
"testing"
|
|
)
|
|
|
|
func TestCommaSeparatedValues(t *testing.T) {
|
|
type testStruct struct {
|
|
A int `comma:"a"`
|
|
B string `comma:"b"`
|
|
C bool `comma:"c"`
|
|
D float64 `comma:"d"`
|
|
E string // no tag
|
|
Endpoint string `comma:"endpoint"`
|
|
Name string `comma:"name"`
|
|
ID string `comma:"id"`
|
|
}
|
|
|
|
tests := []struct {
|
|
name string
|
|
input []byte
|
|
want testStruct
|
|
wantErr bool
|
|
}{
|
|
{
|
|
name: "basic test",
|
|
input: []byte("a=1,b=hello,c=true,d=3.14,E=world"),
|
|
want: testStruct{
|
|
A: 1,
|
|
B: "hello",
|
|
C: true,
|
|
D: 3.14,
|
|
E: "world",
|
|
},
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "empty input",
|
|
input: []byte(""),
|
|
want: testStruct{},
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "partial fields",
|
|
input: []byte("a=42,c=false"),
|
|
want: testStruct{
|
|
A: 42,
|
|
C: false,
|
|
},
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "extra fields ignored",
|
|
input: []byte("a=1,b=test,extra=ignored"),
|
|
want: testStruct{
|
|
A: 1,
|
|
B: "test",
|
|
},
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "invalid format - missing value",
|
|
input: []byte("a=1,b"),
|
|
wantErr: true,
|
|
},
|
|
{
|
|
name: "invalid format - missing equals",
|
|
input: []byte("a=1,b:2"),
|
|
wantErr: true,
|
|
},
|
|
{
|
|
name: "whitespace handling",
|
|
input: []byte("a = 1, b = hello "),
|
|
want: testStruct{
|
|
A: 1,
|
|
B: "hello",
|
|
},
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "type conversion - invalid int",
|
|
input: []byte("a=notanumber,b=test"),
|
|
want: testStruct{
|
|
B: "test",
|
|
},
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "type conversion - invalid bool",
|
|
input: []byte("c=notabool,b=test"),
|
|
want: testStruct{
|
|
B: "test",
|
|
},
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "type conversion - invalid float",
|
|
input: []byte("d=notafloat,b=test"),
|
|
want: testStruct{
|
|
B: "test",
|
|
},
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "actual example",
|
|
input: []byte("endpoint=test-plugin.dify.uwu,name=c31a98df2ef139d6532d8da8caa2bb63,id=c31a98df2ef139d6532d8da8caa2bb63"),
|
|
want: testStruct{
|
|
Endpoint: "test-plugin.dify.uwu",
|
|
Name: "c31a98df2ef139d6532d8da8caa2bb63",
|
|
ID: "c31a98df2ef139d6532d8da8caa2bb63",
|
|
},
|
|
wantErr: false,
|
|
},
|
|
}
|
|
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
got, err := ParserCommaSeparatedValues[testStruct](tt.input)
|
|
if (err != nil) != tt.wantErr {
|
|
t.Errorf("ParserCommaSeparatedValues() error = %v, wantErr %v", err, tt.wantErr)
|
|
return
|
|
}
|
|
if !tt.wantErr && got != tt.want {
|
|
t.Errorf("ParserCommaSeparatedValues() = %v, want %v", got, tt.want)
|
|
}
|
|
})
|
|
}
|
|
|
|
}
|