Feat/v2.33.0 (#215)

* feat: wecom service

* feat: enable WeCom customer service configuration and integrate related UI components.

* fix: wecom service

* fix: prompt image

* feat: log

* feat: rag

* fix: decode URL question parameter when retrieving from search params in customer service content.

* fix: wecom service source

---------

Co-authored-by: 姚凯 <kai.yao@chaitin.com>
Co-authored-by: awesomeYG <gang.yang@chaitin.com>
Co-authored-by: xiaobing.wang <xiaobing.wang@chaitin.com>

Author: 4 people

.github/workflows/build-base-img.yml

@@ -44,7 +44,7 @@ jobs:
           - name: raglite
             dockerfile: docker/raglite/Dockerfile
             context: docker/raglite
-            tag: "v2.13.0"
+            tag: "v2.14.0"
 
     steps:
       - name: Checkout code

backend/assets/assets.go

@@ -10,4 +10,7 @@ var (
 
 	//go:embed blog
 	Blog embed.FS
+
+	//go:embed wecom_service.png
+	WecomService []byte
 )

backend/assets/wecom_service.png

@@ -8172,12 +8172,14 @@ const docTemplate = `{
             "enum": [
                 0,
                 1,
-                2
+                2,
+                3
             ],
             "x-enum-varnames": [
                 "AskSessionSourceWeb",
                 "AskSessionSourcePlugin",
-                "AskSessionSourceBot"
+                "AskSessionSourceBot",
+                "AskSessionSourceWecomService"
             ]
         },
         "model.AskSessionSummaryDisc": {
@@ -10406,7 +10408,8 @@ const docTemplate = `{
                 "source": {
                     "enum": [
                         0,
-                        1
+                        1,
+                        3
                     ],
                     "allOf": [
                         {
@@ -11481,7 +11484,8 @@ const docTemplate = `{
                 "source": {
                     "enum": [
                         0,
-                        1
+                        1,
+                        3
                     ],
                     "allOf": [
                         {

backend/docs/docs.go

@@ -8165,12 +8165,14 @@
             "enum": [
                 0,
                 1,
-                2
+                2,
+                3
             ],
             "x-enum-varnames": [
                 "AskSessionSourceWeb",
                 "AskSessionSourcePlugin",
-                "AskSessionSourceBot"
+                "AskSessionSourceBot",
+                "AskSessionSourceWecomService"
             ]
         },
         "model.AskSessionSummaryDisc": {
@@ -10399,7 +10401,8 @@
                 "source": {
                     "enum": [
                         0,
-                        1
+                        1,
+                        3
                     ],
                     "allOf": [
                         {
@@ -11474,7 +11477,8 @@
                 "source": {
                     "enum": [
                         0,
-                        1
+                        1,
+                        3
                     ],
                     "allOf": [
                         {

backend/docs/swagger.json

@@ -101,11 +101,13 @@ definitions:
     - 0
     - 1
     - 2
+    - 3
     type: integer
     x-enum-varnames:
     - AskSessionSourceWeb
     - AskSessionSourcePlugin
     - AskSessionSourceBot
+    - AskSessionSourceWecomService
   model.AskSessionSummaryDisc:
     properties:
       forum_id:
@@ -1651,6 +1653,7 @@ definitions:
         enum:
         - 0
         - 1
+        - 3
     required:
     - question
     - session_id
@@ -2357,6 +2360,7 @@ definitions:
         enum:
         - 0
         - 1
+        - 3
     required:
     - forum_id
     - session_id

backend/docs/swagger.yaml

@@ -12,6 +12,7 @@ const (
 	AskSessionSourceWeb AskSessionSource = iota
 	AskSessionSourcePlugin
 	AskSessionSourceBot
+	AskSessionSourceWecomService
 )
 
 type AskSession struct {

backend/model/ask_history.go

@@ -1,6 +1,8 @@
 package model
 
 import (
+	"context"
+
 	"github.com/chaitin/koalaqa/pkg/util"
 )
 
@@ -143,3 +145,5 @@ type SystemChatConfig struct {
 	Token        string `json:"client_token"`
 	AESKey       string `json:"aes_key"`
 }
+
+type EnabledCallback func(context.Context) (bool, error)

backend/model/system.go

@@ -14,12 +14,12 @@ import (
 
 var sf singleflight.Group
 
-type accessToken struct {
+type token struct {
 	token    string
 	expireAt time.Time
 }
 
-func (d *accessToken) expired() bool {
+func (d *token) expired() bool {
 	return d.token == "" || time.Now().After(d.expireAt.Add(-time.Minute*5))
 }
 
@@ -122,7 +122,7 @@ type Bot interface {
 }
 
 func New(typ Type, cfg model.SystemChatConfig, callback BotCallback,
-	accessAddrCallback model.AccessAddrCallback, stateManager *StateManager) (Bot, error) {
+	accessAddrCallback model.AccessAddrCallback, enabledCallback model.EnabledCallback) (Bot, error) {
 	switch typ {
 	case TypeDingtalk:
 		return newDingtalk(cfg, callback)
@@ -131,7 +131,7 @@ func New(typ Type, cfg model.SystemChatConfig, callback BotCallback,
 	case TypeWecomIntelligent:
 		return newWecomIntelligent(cfg, callback)
 	case TypeWecomService:
-		return newWecomService(cfg, callback, accessAddrCallback, stateManager)
+		return newWecomService(cfg, callback, accessAddrCallback, enabledCallback)
 	default:
 		return nil, errors.ErrUnsupported
 	}

backend/pkg/chat/chat.go

@@ -28,7 +28,7 @@ type dingtalk struct {
 	streamCli  *client.StreamClient
 	oauthCli   *dingtalkoauth2_1_0.Client
 	cardCli    *dingtalkcard_1_0.Client
-	tokenCache accessToken
+	tokenCache token
 }
 
 func (d *dingtalk) accessToken() (string, error) {
@@ -52,7 +52,7 @@ func (d *dingtalk) accessToken() (string, error) {
 				return nil, fmt.Errorf("get access_token status code: %d", *resp.StatusCode)
 			}
 
-			d.tokenCache = accessToken{
+			d.tokenCache = token{
 				token:    *resp.Body.AccessToken,
 				expireAt: time.Now().Add(time.Duration(*resp.Body.ExpireIn) * time.Second),
 			}