fix: fix uv offline set position (#644)

Author: fatelei

cmd/server/main.go

@@ -3,6 +3,7 @@ package main
 import (
 	"context"
 
+	"github.com/joho/godotenv"
 	"github.com/kelseyhightower/envconfig"
 	"github.com/langgenius/dify-plugin-daemon/internal/server"
 	"github.com/langgenius/dify-plugin-daemon/internal/types/app"
@@ -11,7 +12,7 @@ import (
 
 func main() {
 	var config app.Config
-
+	_ = godotenv.Load()
 	err := envconfig.Process("", &config)
 	if err != nil {
 		log.Panic("error processing environment variables", "error", err)

internal/core/plugin_manager/packages.go

@@ -5,13 +5,11 @@ import (
 	"fmt"
 	"os"
 	"strings"
-	"time"
 
 	"github.com/langgenius/dify-plugin-daemon/internal/db"
 	"github.com/langgenius/dify-plugin-daemon/internal/types/models"
 	"github.com/langgenius/dify-plugin-daemon/pkg/entities/plugin_entities"
 	"github.com/langgenius/dify-plugin-daemon/pkg/plugin_packager/decoder"
-	"github.com/langgenius/dify-plugin-daemon/pkg/utils/cache"
 	"github.com/langgenius/dify-plugin-daemon/pkg/utils/cache/helper"
 )
 
@@ -59,9 +57,6 @@ func (p *PluginManager) SavePackage(
 		return nil, err
 	}
 
-	cacheKey := "manually_uploaded:" + plugin_unique_identifier.String()
-	err = cache.Store(cacheKey, true, time.Second*10)
-
 	// create plugin if not exists (idempotent under concurrency)
 	if _, err := db.GetOne[models.PluginDeclaration](
 		db.Equal("plugin_unique_identifier", uniqueIdentifier.String()),

internal/service/plugin_decoder.go

@@ -4,6 +4,7 @@ import (
 	"errors"
 	"io"
 	"mime/multipart"
+	"time"
 
 	"github.com/gin-gonic/gin"
 	"github.com/langgenius/dify-plugin-daemon/internal/core/plugin_manager"
@@ -14,6 +15,7 @@ import (
 	"github.com/langgenius/dify-plugin-daemon/pkg/entities/bundle_entities"
 	"github.com/langgenius/dify-plugin-daemon/pkg/entities/plugin_entities"
 	"github.com/langgenius/dify-plugin-daemon/pkg/plugin_packager/decoder"
+	"github.com/langgenius/dify-plugin-daemon/pkg/utils/cache"
 	"github.com/langgenius/dify-plugin-daemon/pkg/utils/cache/helper"
 )
 
@@ -66,11 +68,8 @@ func UploadPluginPkg(
 		verification = decoder.DefaultVerification()
 	}
 
-	// if config.EnforceLanggeniusSignatures {
-	// 	if isUnauthorizedLanggenius(declaration, verification) {
-	// 		return exception.BadRequestError(ErrUnauthorizedLanggenius).ToResponse()
-	// 	}
-	// }
+	cacheKey := "manually_uploaded:" + pluginUniqueIdentifier.String()
+	err = cache.Store(cacheKey, true, time.Second*10)
 
 	return entities.NewSuccessResponse(map[string]any{
 		"unique_identifier": pluginUniqueIdentifier,

internal/service/plugin_decoder_test.go

@@ -0,0 +1,48 @@
+package service
+
+import (
+	"testing"
+
+	"github.com/langgenius/dify-plugin-daemon/pkg/entities/plugin_entities"
+)
+
+func TestUploadPluginPkg_CacheKeyFormat(t *testing.T) {
+	tests := []struct {
+		name                    string
+		pluginUniqueIdentifier   plugin_entities.PluginUniqueIdentifier
+		expectedKey              string
+	}{
+		{
+			name:                    "standard plugin identifier",
+			pluginUniqueIdentifier:   plugin_entities.PluginUniqueIdentifier("author/plugin@1.0.0"),
+			expectedKey:              "manually_uploaded:author/plugin@1.0.0",
+		},
+		{
+			name:                    "plugin with version hash",
+			pluginUniqueIdentifier:   plugin_entities.PluginUniqueIdentifier("author/plugin@abc123def456"),
+			expectedKey:              "manually_uploaded:author/plugin@abc123def456",
+		},
+		{
+			name:                    "plugin with special characters",
+			pluginUniqueIdentifier:   plugin_entities.PluginUniqueIdentifier("my-org/my-plugin@1.0.0-beta"),
+			expectedKey:              "manually_uploaded:my-org/my-plugin@1.0.0-beta",
+		},
+		{
+			name:                    "langgenius gemini plugin",
+			pluginUniqueIdentifier:   plugin_entities.PluginUniqueIdentifier("langgenius/gemini@0.7.17"),
+			expectedKey:              "manually_uploaded:langgenius/gemini@0.7.17",
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			cacheKey := "manually_uploaded:" + tt.pluginUniqueIdentifier.String()
+
+			if cacheKey != tt.expectedKey {
+				t.Errorf("cache key mismatch\n got: %s\nwant: %s", cacheKey, tt.expectedKey)
+			}
+
+			t.Logf("✓ Cache key format correct: %s", cacheKey)
+		})
+	}
+}