Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Beta130 #129

Merged
merged 128 commits into from
May 24, 2024
Merged
Changes from 1 commit
Commits
Show all changes
128 commits
Select commit Hold shift + click to select a range
ea4bcc6
beta1
Hoshinonyaruko Jan 21, 2024
5002a28
beta2
Hoshinonyaruko Jan 21, 2024
969841e
beta3
Hoshinonyaruko Jan 21, 2024
a2989c2
beta4
Hoshinonyaruko Jan 21, 2024
611cd8b
beta5
Hoshinonyaruko Jan 21, 2024
dbad42b
beta6
Hoshinonyaruko Jan 21, 2024
4f8895e
beta7
Hoshinonyaruko Jan 21, 2024
30a9cab
beta8
Hoshinonyaruko Jan 21, 2024
461d879
beta9
Hoshinonyaruko Jan 21, 2024
c90c2ee
beta10
Hoshinonyaruko Jan 21, 2024
5227c32
beta11
Hoshinonyaruko Jan 21, 2024
8e14e56
beta12
Hoshinonyaruko Jan 21, 2024
6adfb7f
beta13
Hoshinonyaruko Jan 21, 2024
b04f6c0
beta14
Hoshinonyaruko Jan 21, 2024
649e740
beta15
Hoshinonyaruko Jan 21, 2024
d55cf29
beta16
Hoshinonyaruko Jan 21, 2024
1cc351e
beta16
Hoshinonyaruko Jan 21, 2024
f1a373e
beta19
Hoshinonyaruko Jan 21, 2024
cbf2fe1
beta20
Hoshinonyaruko Jan 21, 2024
3485bfc
beta21
Hoshinonyaruko Jan 21, 2024
3e3bb1a
beta22
Hoshinonyaruko Jan 21, 2024
2e4f3fa
beta23
Hoshinonyaruko Mar 29, 2024
f74075d
beta24
Hoshinonyaruko Mar 29, 2024
f3913cf
beta25
Hoshinonyaruko Mar 29, 2024
4cfb51a
beta27
Hoshinonyaruko Mar 30, 2024
d9b26c0
beta28
Hoshinonyaruko Mar 31, 2024
19da709
beta29
Hoshinonyaruko Mar 31, 2024
e06dcbf
merge
Hoshinonyaruko Mar 31, 2024
c76923e
beta30
Hoshinonyaruko Mar 31, 2024
9ae21da
beta31
Hoshinonyaruko Apr 1, 2024
4f333bc
merge
Hoshinonyaruko Apr 1, 2024
5acba8f
beta33
Hoshinonyaruko Apr 1, 2024
c637fcd
beta34
Hoshinonyaruko Apr 1, 2024
4e85b37
beta35
Hoshinonyaruko Apr 1, 2024
970948e
beta36
Hoshinonyaruko Apr 1, 2024
14271c3
beta37
Hoshinonyaruko Apr 1, 2024
6154d1a
beta38
Hoshinonyaruko Apr 1, 2024
d5be5e6
beta39
Hoshinonyaruko Apr 3, 2024
54afe18
beta40
Hoshinonyaruko Apr 3, 2024
0b71855
beta41
Hoshinonyaruko Apr 3, 2024
8c5f9a3
merge
Hoshinonyaruko Apr 3, 2024
cf752d4
beta42
Hoshinonyaruko Apr 3, 2024
3698824
beta43
Hoshinonyaruko Apr 3, 2024
1e9c189
beta44
Hoshinonyaruko Apr 3, 2024
2adb4ac
beta45
Hoshinonyaruko Apr 4, 2024
79eb713
beta45
Hoshinonyaruko Apr 4, 2024
064f0d0
beta45
Hoshinonyaruko Apr 4, 2024
5a4a59e
beta46
Hoshinonyaruko Apr 5, 2024
df30a32
beta46
Hoshinonyaruko Apr 5, 2024
c920893
beat48
Hoshinonyaruko Apr 7, 2024
3491d5d
beta49
Hoshinonyaruko Apr 8, 2024
575b2ca
beta50
Hoshinonyaruko Apr 8, 2024
4c4bbaa
beta51
Hoshinonyaruko Apr 8, 2024
2ea728b
beta52
Hoshinonyaruko Apr 8, 2024
82bf952
beta53
Hoshinonyaruko Apr 8, 2024
869685c
beta54
Hoshinonyaruko Apr 9, 2024
1f3646e
beta55
Hoshinonyaruko Apr 9, 2024
d6bbadf
beta57
Hoshinonyaruko Apr 10, 2024
fc5086c
beta58
Hoshinonyaruko Apr 10, 2024
602ff65
beta59
Hoshinonyaruko Apr 10, 2024
a82538d
Merge branch 'main' of https://github.com/Hoshinonyaruko/Gensokyo-llm…
Hoshinonyaruko Apr 10, 2024
6433600
beta61
Hoshinonyaruko Apr 10, 2024
9ce88b3
beta62
Hoshinonyaruko Apr 12, 2024
b53617b
beta63
Hoshinonyaruko Apr 12, 2024
ff64c69
beta63
Hoshinonyaruko Apr 12, 2024
b34885f
beta64
Hoshinonyaruko Apr 13, 2024
3658648
beta65
Hoshinonyaruko Apr 13, 2024
3307439
beta66
Hoshinonyaruko Apr 15, 2024
f15c422
beta67
Hoshinonyaruko Apr 17, 2024
518de35
beta70
Hoshinonyaruko Apr 18, 2024
a65f07d
beta71
Hoshinonyaruko Apr 18, 2024
59d07c7
beta72
Hoshinonyaruko Apr 18, 2024
a16ea64
beta72
Hoshinonyaruko Apr 18, 2024
08d5864
beta74
Hoshinonyaruko Apr 19, 2024
9b09401
beta75
Hoshinonyaruko Apr 19, 2024
b51e185
beta76
Hoshinonyaruko Apr 20, 2024
c978654
beta77
Hoshinonyaruko Apr 21, 2024
6aa9f33
beta78
Hoshinonyaruko Apr 22, 2024
7b84a9d
beta79
Hoshinonyaruko Apr 25, 2024
4b96807
beta80
Hoshinonyaruko Apr 25, 2024
9b97146
beta81
Hoshinonyaruko Apr 25, 2024
f481e85
beta82
Hoshinonyaruko Apr 29, 2024
cb33ba5
beta83
Hoshinonyaruko Apr 29, 2024
7dbe4d5
beta85
Hoshinonyaruko Apr 29, 2024
2fb67a2
beta86
Hoshinonyaruko Apr 29, 2024
20f26c1
beta87
Hoshinonyaruko Apr 29, 2024
3146232
beta88
Hoshinonyaruko Apr 29, 2024
cbf731b
beta89
Hoshinonyaruko Apr 29, 2024
cc8a439
beta90
Hoshinonyaruko Apr 29, 2024
f56c272
beta91
Hoshinonyaruko Apr 29, 2024
c19f071
beta92
Hoshinonyaruko Apr 29, 2024
84d0513
beta93
Hoshinonyaruko Apr 29, 2024
c2f8e28
beta94
Hoshinonyaruko Apr 29, 2024
142f2fa
beta94
Hoshinonyaruko Apr 29, 2024
8828006
beta96
Hoshinonyaruko Apr 29, 2024
541a127
beta97
Hoshinonyaruko Apr 30, 2024
9d52ce8
beta98
Hoshinonyaruko Apr 30, 2024
16e0ed4
beta99
Hoshinonyaruko Apr 30, 2024
8f0e406
beta100
Hoshinonyaruko May 1, 2024
d242bc2
beta101
Hoshinonyaruko May 1, 2024
2ea5f4a
beta102
Hoshinonyaruko May 2, 2024
c208482
beta104
Hoshinonyaruko May 3, 2024
777aaa0
beta105
Hoshinonyaruko May 4, 2024
3ccedea
beta106
Hoshinonyaruko May 4, 2024
956c9a2
beta107
Hoshinonyaruko May 8, 2024
1a04702
beta108
Hoshinonyaruko May 8, 2024
d88d84b
beta109
Hoshinonyaruko May 8, 2024
e9a3788
beta110
Hoshinonyaruko May 9, 2024
a6dccf7
beta111
Hoshinonyaruko May 13, 2024
48a1d26
beta112
Hoshinonyaruko May 13, 2024
5cbd1a6
beta113
Hoshinonyaruko May 13, 2024
a8f8dbd
Merge branch 'main' of https://github.com/Hoshinonyaruko/Gensokyo-llm…
Hoshinonyaruko May 13, 2024
0ce3929
beta115
Hoshinonyaruko May 13, 2024
3c24828
beta116
Hoshinonyaruko May 14, 2024
d17b87e
beta117
Hoshinonyaruko May 14, 2024
a0d9d93
beta118
Hoshinonyaruko May 16, 2024
81c5f60
beta119
Hoshinonyaruko May 17, 2024
0bf4eae
beta120
Hoshinonyaruko May 19, 2024
dfff20e
beta121
Hoshinonyaruko May 19, 2024
6659607
beta122
Hoshinonyaruko May 19, 2024
89c92a0
beta123
Hoshinonyaruko May 19, 2024
a35581e
beta124
Hoshinonyaruko May 19, 2024
434c738
beta125
Hoshinonyaruko May 19, 2024
18e97cc
beta126
Hoshinonyaruko May 20, 2024
49cfe96
beta127
Hoshinonyaruko May 20, 2024
6c98d9f
beta128
Hoshinonyaruko May 23, 2024
3301dc2
beta129
Hoshinonyaruko May 24, 2024
32b6189
beta130
Hoshinonyaruko May 24, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
beta49
Hoshinonyaruko committed Apr 8, 2024
commit 3491d5de78d1ee2ba693974815bd1c91ed4af94e
56 changes: 49 additions & 7 deletions applogic/gensokyo.go
Original file line number Diff line number Diff line change
@@ -4,6 +4,7 @@ import (
"bufio"
"bytes"
"encoding/json"
"fmt"
"io"
"math/rand"
"net/http"
@@ -142,11 +143,28 @@ func (app *App) GensokyoHandler(w http.ResponseWriter, r *http.Request) {
utils.SendSSEPrivateRestoreMessage(message.UserID, RestoreResponse)
}
} else {
utils.SendGroupMessage(message.GroupID, RestoreResponse)
utils.SendGroupMessage(message.GroupID, message.UserID, RestoreResponse)
}
return
}

withdrawCommand := config.GetWithdrawCommand()

// 检查checkResetCommand是否在WithdrawCommand列表中
iswithdrawCommand := false
for _, command := range withdrawCommand {
if checkResetCommand == command {
iswithdrawCommand = true
break
}
}

// 处理撤回信息
if iswithdrawCommand {
handleWithdrawMessage(message)
return
}

// newmsg 是一个用于缓存和安全判断的临时量
newmsg := message.Message.(string)
// 去除注入的提示词
@@ -254,7 +272,7 @@ func (app *App) GensokyoHandler(w http.ResponseWriter, r *http.Request) {
utils.SendSSEPrivateMessage(message.UserID, responseText)
}
} else {
utils.SendGroupMessage(message.GroupID, responseText)
utils.SendGroupMessage(message.GroupID, message.UserID, responseText)
}
// 发送响应
w.WriteHeader(http.StatusOK)
@@ -299,7 +317,7 @@ func (app *App) GensokyoHandler(w http.ResponseWriter, r *http.Request) {
utils.SendSSEPrivateSafeMessage(message.UserID, saveresponse)
}
} else {
utils.SendGroupMessage(message.GroupID, saveresponse)
utils.SendGroupMessage(message.GroupID, message.UserID, saveresponse)
}
}
// 发送响应
@@ -409,7 +427,7 @@ func (app *App) GensokyoHandler(w http.ResponseWriter, r *http.Request) {
utils.SendPrivateMessageSSE(message.UserID, messageSSE)
}
} else {
utils.SendGroupMessage(message.GroupID, newPart)
utils.SendGroupMessage(message.GroupID, message.UserID, newPart)
}
}

@@ -430,7 +448,7 @@ func (app *App) GensokyoHandler(w http.ResponseWriter, r *http.Request) {
utils.SendPrivateMessageSSE(message.UserID, messageSSE)
}
} else {
utils.SendGroupMessage(message.GroupID, response)
utils.SendGroupMessage(message.GroupID, message.UserID, response)
}
}
}
@@ -498,7 +516,7 @@ func (app *App) GensokyoHandler(w http.ResponseWriter, r *http.Request) {
if message.RealMessageType == "group_private" || message.MessageType == "private" {
utils.SendPrivateMessage(message.UserID, response)
} else {
utils.SendGroupMessage(message.GroupID, response)
utils.SendGroupMessage(message.GroupID, message.UserID, response)
}
}

@@ -593,11 +611,35 @@ func processMessage(response string, msg structs.OnebotGroupMessage, newmesssage
}
}
} else {
utils.SendGroupMessage(msg.GroupID, accumulatedMessage)
utils.SendGroupMessage(msg.GroupID, msg.UserID, accumulatedMessage)
}

messageBuilder.Reset() // 重置消息构建器
}
}
}
}

// 处理撤回信息的函数
func handleWithdrawMessage(message structs.OnebotGroupMessage) {
fmt.Println("处理撤回操作")
var id int64

// 根据消息类型决定使用哪个ID
switch message.RealMessageType {
case "group_private", "guild_private":
id = message.UserID
case "group", "guild":
id = message.GroupID
default:
fmt.Println("Unsupported message type for withdrawal:", message.RealMessageType)
return
}

// 调用DeleteLatestMessage函数
err := utils.DeleteLatestMessage(message.RealMessageType, id, message.UserID)
if err != nil {
fmt.Println("Error deleting latest message:", err)
return
}
}
2 changes: 1 addition & 1 deletion applogic/vectorsensitive.go
Original file line number Diff line number Diff line change
@@ -288,7 +288,7 @@ func (app *App) InterceptSensitiveContent(vector []float64, message structs.Oneb
utils.SendSSEPrivateSafeMessage(message.UserID, saveresponse)
}
} else {
utils.SendGroupMessage(message.GroupID, saveresponse)
utils.SendGroupMessage(message.GroupID, message.UserID, saveresponse)
}
return 1, saveresponse, nil
}
11 changes: 11 additions & 0 deletions config/config.go
Original file line number Diff line number Diff line change
@@ -87,6 +87,7 @@ type Settings struct {
QmlResponseMessages []string `yaml:"qmlResponseMessages"`
BlacklistResponseMessages []string `yaml:"blacklistResponseMessages"`
NoContext bool `yaml:"noContext"`
WithdrawCommand []string `yaml:"withdrawCommand"`
}

// LoadConfig 从文件中加载配置并初始化单例配置
@@ -878,3 +879,13 @@ func GetNoContext() bool {
}
return false
}

// 获取WithdrawCommand
func GetWithdrawCommand() []string {
mu.Lock()
defer mu.Unlock()
if instance != nil {
return instance.Settings.WithdrawCommand
}
return nil
}
1 change: 1 addition & 0 deletions template/config_template.go
Original file line number Diff line number Diff line change
@@ -34,6 +34,7 @@ settings:
promptkeyboard : [""] #临时的promptkeyboard超过3个则随机,后期会增加一个ai生成的方式,也会是ai-agent
savelogs : false #本地落地日志.
noContext : false #不开启上下文
withdrawCommand : ["撤回"] #撤回指令
#语言过滤
allowedLanguages : ["cmn"] #根据自身安全实力,酌情过滤,cmn代表中文,小写字母,[]空数组代表不限制.
langResponseMessages : ["抱歉,我不会**这个语言呢","我不会**这门语言,请使用中文和我对话吧"] #定型文,**会自动替换为检测到的语言
2 changes: 1 addition & 1 deletion utils/blacklist.go
Original file line number Diff line number Diff line change
@@ -107,7 +107,7 @@ func BlacklistIntercept(message structs.OnebotGroupMessage) bool {
SendSSEPrivateMessage(message.UserID, responseMessage)
}
} else {
SendGroupMessage(message.GroupID, responseMessage)
SendGroupMessage(message.GroupID, message.UserID, responseMessage)
}

fmt.Printf("userid:[%v]这位用户在黑名单中,被拦截\n", message.UserID)
194 changes: 188 additions & 6 deletions utils/utils.go
Original file line number Diff line number Diff line change
@@ -10,7 +10,9 @@ import (
"net/http"
"os"
"regexp"
"strconv"
"strings"
"sync"
"time"

"github.com/abadojack/whatlanggo"
@@ -22,6 +24,23 @@ import (
"github.com/hoshinonyaruko/gensokyo-llm/structs"
)

// ResponseData 是用于解析HTTP响应的结构体
type ResponseData struct {
Data struct {
MessageID int64 `json:"message_id"`
} `json:"data"`
}

// MessageIDInfo 代表消息ID及其到期时间
type MessageIDInfo struct {
MessageID int64 // 消息ID
Expires time.Time // 到期时间
}

// UserIDMessageIDs 存储每个用户ID对应的消息ID数组及其有效期
var UserIDMessageIDs = make(map[int64][]MessageIDInfo)
var muUserIDMessageIDs sync.RWMutex // 用于UserIDMessageIDs的读写锁

func GenerateUUID() string {
return uuid.New().String()
}
@@ -116,7 +135,7 @@ func ExtractEventDetails(eventData map[string]interface{}) (string, structs.Usag
return responseTextBuilder.String(), totalUsage
}

func SendGroupMessage(groupID int64, message string) error {
func SendGroupMessage(groupID int64, userID int64, message string) error {
// 获取基础URL
baseURL := config.GetHttpPath() // 假设config.getHttpPath()返回基础URL

@@ -130,6 +149,7 @@ func SendGroupMessage(groupID int64, message string) error {
// 构造请求体
requestBody, err := json.Marshal(map[string]interface{}{
"group_id": groupID,
"user_id": userID,
"message": message,
})
if err != nil {
@@ -148,7 +168,24 @@ func SendGroupMessage(groupID int64, message string) error {
return fmtf.Errorf("received non-OK response status: %s", resp.Status)
}

// TODO: 处理响应体(如果需要)
// 读取响应体
bodyBytes, err := io.ReadAll(resp.Body)
if err != nil {
return fmt.Errorf("failed to read response body: %w", err)
}

// 解析响应体以获取message_id
var responseData ResponseData
if err := json.Unmarshal(bodyBytes, &responseData); err != nil {
return fmt.Errorf("failed to unmarshal response data: %w", err)
}
messageID := responseData.Data.MessageID

// 添加messageID到全局变量
AddMessageID(userID, messageID)

// 输出响应体,这一步是可选的
fmt.Println("Response Body:", string(bodyBytes))

return nil
}
@@ -186,7 +223,24 @@ func SendPrivateMessage(UserID int64, message string) error {
return fmtf.Errorf("received non-OK response status: %s", resp.Status)
}

// TODO: 处理响应体(如果需要)
// 读取响应体
bodyBytes, err := io.ReadAll(resp.Body)
if err != nil {
return fmt.Errorf("failed to read response body: %w", err)
}

// 解析响应体以获取message_id
var responseData ResponseData
if err := json.Unmarshal(bodyBytes, &responseData); err != nil {
return fmt.Errorf("failed to unmarshal response data: %w", err)
}
messageID := responseData.Data.MessageID

// 添加messageID到全局变量
AddMessageID(UserID, messageID)

// 输出响应体,这一步是可选的
fmt.Println("Response Body:", string(bodyBytes))

return nil
}
@@ -224,7 +278,24 @@ func SendPrivateMessageSSE(UserID int64, message structs.InterfaceBody) error {
return fmtf.Errorf("received non-OK response status: %s", resp.Status)
}

// TODO: 处理响应体(如果需要)
// 读取响应体
bodyBytes, err := io.ReadAll(resp.Body)
if err != nil {
return fmt.Errorf("failed to read response body: %w", err)
}

// 解析响应体以获取message_id
var responseData ResponseData
if err := json.Unmarshal(bodyBytes, &responseData); err != nil {
return fmt.Errorf("failed to unmarshal response data: %w", err)
}
messageID := responseData.Data.MessageID

// 添加messageID到全局变量
AddMessageID(UserID, messageID)

// 输出响应体,这一步是可选的
fmt.Println("Response Body:", string(bodyBytes))

return nil
}
@@ -513,7 +584,7 @@ func LanguageIntercept(text string, message structs.OnebotGroupMessage) bool {
SendSSEPrivateMessage(message.UserID, responseMessage)
}
} else {
SendGroupMessage(message.GroupID, responseMessage)
SendGroupMessage(message.GroupID, message.UserID, responseMessage)
}

return true // 拦截
@@ -570,10 +641,121 @@ func LengthIntercept(text string, message structs.OnebotGroupMessage) bool {
SendSSEPrivateMessage(message.UserID, responseMessage)
}
} else {
SendGroupMessage(message.GroupID, responseMessage)
SendGroupMessage(message.GroupID, message.UserID, responseMessage)
}

return true // 拦截
}
return false // 长度符合要求,不拦截
}

// AddMessageID 为指定user_id添加新的消息ID
func AddMessageID(userID int64, messageID int64) {
muUserIDMessageIDs.Lock()
defer muUserIDMessageIDs.Unlock()

// 消息ID的有效期是120秒
expiration := time.Now().Add(120 * time.Second)
messageInfo := MessageIDInfo{MessageID: messageID, Expires: expiration}

// 清理已过期的消息ID
cleanExpiredMessageIDs(userID)

// 添加新的消息ID
UserIDMessageIDs[userID] = append(UserIDMessageIDs[userID], messageInfo)
}

// cleanExpiredMessageIDs 清理指定user_id的已过期消息ID
func cleanExpiredMessageIDs(userID int64) {
validMessageIDs := []MessageIDInfo{}
for _, messageInfo := range UserIDMessageIDs[userID] {
if messageInfo.Expires.After(time.Now()) {
validMessageIDs = append(validMessageIDs, messageInfo)
}
}
UserIDMessageIDs[userID] = validMessageIDs
}

// GetLatestValidMessageID 获取指定user_id当前有效的最新消息ID
func GetLatestValidMessageID(userID int64) (int64, bool) {
muUserIDMessageIDs.RLock()
defer muUserIDMessageIDs.RUnlock()

// 确保已过期的消息ID被清理
cleanExpiredMessageIDs(userID)

// 获取最新的消息ID
if len(UserIDMessageIDs[userID]) > 0 {
latestMessageInfo := UserIDMessageIDs[userID][len(UserIDMessageIDs[userID])-1]
return latestMessageInfo.MessageID, true
}
return 0, false
}

// sendDeleteRequest 发送删除消息的请求,并输出响应内容
func sendDeleteRequest(url string, requestBody []byte) error {
// 发送POST请求
resp, err := http.Post(url, "application/json", bytes.NewBuffer(requestBody))
if err != nil {
return fmt.Errorf("failed to send POST request: %w", err)
}
defer resp.Body.Close()

// 检查响应状态
if resp.StatusCode != http.StatusOK {
return fmt.Errorf("received non-OK response status: %s", resp.Status)
}

// 读取响应体
bodyBytes, err := io.ReadAll(resp.Body)
if err != nil {
return fmt.Errorf("failed to read response body: %w", err)
}

// 将响应体转换为字符串,并输出
bodyString := string(bodyBytes)
fmt.Println("Response Body:", bodyString)

return nil
}

func DeleteLatestMessage(messageType string, id int64, userid int64) error {
// 获取基础URL
baseURL := config.GetHttpPath() // 假设config.GetHttpPath()返回基础URL

// 构建完整的URL
url := baseURL + "/delete_msg"

// 获取最新的有效消息ID
messageID, valid := GetLatestValidMessageID(userid)
if !valid {
return fmt.Errorf("no valid message ID found for user/group/guild ID: %d", id)
}

// 构造请求体
requestBody := make(map[string]interface{})
requestBody["message_id"] = strconv.FormatInt(messageID, 10)

// 根据type填充相应的ID字段
switch messageType {
case "group_private":
requestBody["user_id"] = id
case "group":
requestBody["group_id"] = id
case "guild":
requestBody["channel_id"] = id
case "guild_private":
requestBody["guild_id"] = id
default:
return fmt.Errorf("unsupported message type: %s", messageType)
}

requestBodyBytes, err := json.Marshal(requestBody)
if err != nil {
return fmt.Errorf("failed to marshal request body: %w", err)
}
fmtf.Printf("发送撤回请求:%v", string(requestBodyBytes))

// 发送删除消息请求
return sendDeleteRequest(url, requestBodyBytes)
}