Merge pull request #11 from xh-polaris/moonlight

管理后台和数据看板

Author: universero

.gitignore

@@ -36,3 +36,5 @@ _testmain.go
 dumped_hertz_remote_config.json
 
 /etc/
+/test/
+/psych-core-api

.idea/.gitignore

@@ -37,3 +37,7 @@ new:
 	hz new $(IDL_OPTIONS) $(OUTPUT_OPTIONS) --service $(SERVICE_NAME) --mod $(MODULE_NAME) $(EXTRA_OPTIONS)
 clean:
 	rm -r ./output
+swag:
+	swag init -g main.go --parseDependency --parseInternal
+idl:
+	go get github.com/xh-polaris/psych-idl@main

.idea/modules.xml

@@ -4,15 +4,21 @@ import (
 	"context"
 
 	"github.com/cloudwego/hertz/pkg/app"
-	"github.com/xh-polaris/psych-core-api/biz/application/service"
+	"github.com/hertz-contrib/websocket"
+	"github.com/xh-polaris/psych-core-api/biz/domain/engine"
 	"github.com/xh-polaris/psych-core-api/pkg/logs"
 	"github.com/xh-polaris/psych-core-api/pkg/wsx"
+	"github.com/xh-polaris/psych-core-api/provider"
 )
 
 // Chat 对话接口
 // @router /chat [GET]
 func Chat(ctx context.Context, c *app.RequestContext) {
-	if err := wsx.UpgradeWs(ctx, c, service.ChatHandler); err != nil {
+	handler := func(wsCtx context.Context, conn *websocket.Conn) {
+		p := provider.Get()
+		engine.NewEngine(wsCtx, conn, &p.UserService, &p.ConfigService).Run()
+	}
+	if err := wsx.UpgradeWs(ctx, c, handler); err != nil {
 		logs.Error("[controller] [Chat] websocket upgrade error:", err)
 	}
 }