fix #1782

https://pkg.go.dev/os/exec#hdr-Executables_in_the_current_directory

.golangci.yml

@@ -56,6 +56,7 @@ run:
   skip-dirs:
     - db
     - cmd/api-generator
+    - internal/encryption
   tests: true
 
 # output configuration options

cmd/gocq/login.go

@@ -15,6 +15,8 @@ import (
 	"github.com/Mrs4s/MiraiGo/client"
 	"github.com/Mrs4s/MiraiGo/utils"
 	"github.com/Mrs4s/MiraiGo/wrapper"
+	"github.com/Mrs4s/go-cqhttp/internal/encryption"
+	_ "github.com/Mrs4s/go-cqhttp/internal/encryption/t544"
 	"github.com/mattn/go-colorable"
 	"github.com/pkg/errors"
 	log "github.com/sirupsen/logrus"
@@ -266,8 +268,14 @@ func fetchCaptcha(id string) string {
 	return ""
 }
 
-func energy(uin uint64, id string, salt []byte) ([]byte, error) {
-	// temporary solution
+func energy(uin uint64, id string, appVersion string, salt []byte) ([]byte, error) {
+	if localSigner, ok := encryption.T544Signer[appVersion]; ok {
+		log.Debugf("use local T544Signer v%s", appVersion)
+		result := localSigner(time.Now().UnixMicro(), salt)
+		log.Debugf("t544 sign result: %x", result)
+		return result, nil
+	}
+	log.Debugf("fallback to remote T544Signer v%s", appVersion)
 	signServer := "https://captcha.go-cqhttp.org/sdk/dandelion/energy"
 	if base.SignServerOverwrite != "" {
 		signServer = base.SignServerOverwrite
@@ -276,16 +284,17 @@ func energy(uin uint64, id string, salt []byte) ([]byte, error) {
 		Method: http.MethodPost,
 		URL:    signServer,
 		Header: map[string]string{"Content-Type": "application/x-www-form-urlencoded"},
-		Body:   bytes.NewReader([]byte(fmt.Sprintf("uin=%v&id=%s&salt=%s", uin, id, hex.EncodeToString(salt)))),
+		Body:   bytes.NewReader([]byte(fmt.Sprintf("uin=%v&id=%s&salt=%s&version=%s", uin, id, hex.EncodeToString(salt), appVersion))),
 	}.Bytes()
 	if err != nil {
 		log.Errorf("获取T544时出现问题: %v", err)
 		return nil, err
 	}
 	sign, err := hex.DecodeString(gjson.GetBytes(response, "result").String())
-	if err != nil {
+	if err != nil || len(sign) == 0 {
 		log.Errorf("获取T544时出现问题: %v", err)
 		return nil, err
 	}
+	log.Debugf("t544 sign result: %x", sign)
 	return sign, nil
 }

cmd/gocq/main.go

@@ -18,6 +18,7 @@ import (
 	rotatelogs "github.com/lestrrat-go/file-rotatelogs"
 	"github.com/pkg/errors"
 	log "github.com/sirupsen/logrus"
+	"github.com/tidwall/gjson"
 	"golang.org/x/crypto/pbkdf2"
 	"golang.org/x/term"
 
@@ -281,24 +282,30 @@ func LoginInteract() {
 		cli.Uin = base.Account.Uin
 		cli.PasswordMd5 = base.PasswordHash
 	}
-	if !isTokenLogin {
-		if !base.Account.DisableProtocolUpdate {
-			log.Infof("正在检查协议更新...")
-			oldVersionName := device.Protocol.Version().String()
-			remoteVersion, err := getRemoteLatestProtocolVersion(int(device.Protocol.Version().Protocol))
-			if err == nil {
-				if err = device.Protocol.Version().UpdateFromJson(remoteVersion); err == nil {
-					if device.Protocol.Version().String() != oldVersionName {
-						log.Infof("已自动更新协议版本: %s -> %s", oldVersionName, device.Protocol.Version().String())
-					} else {
-						log.Infof("协议已经是最新版本")
-					}
-					_ = os.WriteFile(versionFile, remoteVersion, 0o644)
+	if !base.FastStart {
+		log.Infof("正在检查协议更新...")
+		currentVersionName := device.Protocol.Version().SortVersionName
+		remoteVersion, err := getRemoteLatestProtocolVersion(int(device.Protocol.Version().Protocol))
+		if err == nil {
+			remoteVersionName := gjson.GetBytes(remoteVersion, "sort_version_name").String()
+			if remoteVersionName != currentVersionName {
+				switch {
+				case !base.UpdateProtocol:
+					log.Infof("检测到协议更新: %s -> %s", currentVersionName, remoteVersionName)
+					log.Infof("如果登录时出现版本过低错误, 可尝试使用 -update-protocol 参数启动")
+				case !isTokenLogin:
+					_ = device.Protocol.Version().UpdateFromJson(remoteVersion)
+					log.Infof("协议版本已更新: %s -> %s", currentVersionName, remoteVersionName)
+				default:
+					log.Infof("检测到协议更新: %s -> %s", currentVersionName, remoteVersionName)
+					log.Infof("由于使用了会话缓存, 无法自动更新协议, 请删除缓存后重试")
 				}
-			} else if err.Error() != "remote version unavailable" {
-				log.Warnf("检查协议更新失败: %v", err)
 			}
+		} else if err.Error() != "remote version unavailable" {
+			log.Warnf("检查协议更新失败: %v", err)
 		}
+	}
+	if !isTokenLogin {
 		if !isQRCodeLogin {
 			if err := commonLogin(); err != nil {
 				log.Fatalf("登录时发生致命错误: %v", err)

coolq/cqcode.go

@@ -642,7 +642,7 @@ func (bot *CQBot) ConvertElement(spec *onebot.Spec, elem msg.Element, sourceType
 		return bot.reply(spec, elem, sourceType)
 	case "forward":
 		id := elem.Get("id")
-		if id != "" {
+		if id == "" {
 			return nil, errors.New("forward 消息中必须包含 id")
 		}
 		fwdMsg := bot.Client.DownloadForwardMessage(id)

coolq/event.go

@@ -475,6 +475,9 @@ func (bot *CQBot) offlineFileEvent(c *client.QQClient, e *client.OfflineFileEven
 }
 
 func (bot *CQBot) joinGroupEvent(c *client.QQClient, group *client.GroupInfo) {
+	if group == nil {
+		return
+	}
 	log.Infof("Bot进入了群 %v.", formatGroupName(group))
 	bot.dispatch(bot.groupIncrease(group.Code, 0, c.Uin))
 }

global/codec.go

@@ -33,9 +33,15 @@ func EncoderSilk(data []byte) ([]byte, error) {
 // EncodeMP4 将给定视频文件编码为MP4
 func EncodeMP4(src string, dst string) error { //        -y 覆盖文件
 	cmd1 := exec.Command("ffmpeg", "-i", src, "-y", "-c", "copy", "-map", "0", dst)
+	if errors.Is(cmd1.Err, exec.ErrDot) {
+		cmd1.Err = nil
+	}
 	err := cmd1.Run()
 	if err != nil {
 		cmd2 := exec.Command("ffmpeg", "-i", src, "-y", "-c:v", "h264", "-c:a", "mp3", dst)
+		if errors.Is(cmd2.Err, exec.ErrDot) {
+			cmd2.Err = nil
+		}
 		return errors.Wrap(cmd2.Run(), "convert mp4 failed")
 	}
 	return err
@@ -44,5 +50,8 @@ func EncodeMP4(src string, dst string) error { //        -y 覆盖文件
 // ExtractCover 获取给定视频文件的Cover
 func ExtractCover(src string, target string) error {
 	cmd := exec.Command("ffmpeg", "-i", src, "-y", "-ss", "0", "-frames:v", "1", target)
+	if errors.Is(cmd.Err, exec.ErrDot) {
+		cmd.Err = nil
+	}
 	return errors.Wrap(cmd.Run(), "extract video cover failed")
 }

go.mod

@@ -5,7 +5,7 @@ go 1.20
 require (
 	github.com/FloatTech/sqlite v1.5.7
 	github.com/Microsoft/go-winio v0.6.0
-	github.com/Mrs4s/MiraiGo v0.0.0-20230317162854-fd83d24f6794
+	github.com/Mrs4s/MiraiGo v0.0.0-20230401072048-f8d9841755b5
 	github.com/RomiChan/syncx v0.0.0-20221202055724-5f842c53020e
 	github.com/RomiChan/websocket v1.4.3-0.20220123145318-307a86b127bc
 	github.com/fumiama/go-base16384 v1.6.1

go.sum

@@ -4,8 +4,8 @@ github.com/FloatTech/ttl v0.0.0-20220715042055-15612be72f5b h1:tvciXWq2nuvTbFeJG
 github.com/FloatTech/ttl v0.0.0-20220715042055-15612be72f5b/go.mod h1:fHZFWGquNXuHttu9dUYoKuNbm3dzLETnIOnm1muSfDs=
 github.com/Microsoft/go-winio v0.6.0 h1:slsWYD/zyx7lCXoZVlvQrj0hPTM1HI4+v1sIda2yDvg=
 github.com/Microsoft/go-winio v0.6.0/go.mod h1:cTAf44im0RAYeL23bpB+fzCyDH2MJiz2BO69KH/soAE=
-github.com/Mrs4s/MiraiGo v0.0.0-20230317162854-fd83d24f6794 h1:V2hkbdJhTGX6tfwEsCg53rUCx/skTGBfwRMHB5/hy7E=
-github.com/Mrs4s/MiraiGo v0.0.0-20230317162854-fd83d24f6794/go.mod h1:mU3fBFU+7eO0kaGes7YRKtzIDtwIU84nSSwTV7NK2b0=
+github.com/Mrs4s/MiraiGo v0.0.0-20230401072048-f8d9841755b5 h1:E4fIQ0l/LNZK44NjdViRb/hx4cIeHXyQFPzzkx7cjVE=
+github.com/Mrs4s/MiraiGo v0.0.0-20230401072048-f8d9841755b5/go.mod h1:mU3fBFU+7eO0kaGes7YRKtzIDtwIU84nSSwTV7NK2b0=
 github.com/RomiChan/protobuf v0.1.1-0.20230204044148-2ed269a2e54d h1:/Xuj3fIiMY2ls1TwvPKmaqQrtJsPY+c9s+0lOScVHd8=
 github.com/RomiChan/protobuf v0.1.1-0.20230204044148-2ed269a2e54d/go.mod h1:2Ie+hdBFQpQFDHfeklgxoFmQRCE7O+KwFpISeXq7OwA=
 github.com/RomiChan/syncx v0.0.0-20221202055724-5f842c53020e h1:wR3MXQ3VbUlPKOOUwLOYgh/QaJThBTYtsl673O3lqSA=

internal/base/flag.go

@@ -37,6 +37,7 @@ var (
 	LogColorful         bool   // 是否启用日志颜色
 	FastStart           bool   // 是否为快速启动
 	AllowTempSession    bool   // 是否允许发送临时会话信息
+	UpdateProtocol      bool   // 是否更新协议
 	SignServerOverwrite string // 使用特定的服务器进行签名
 
 	PostFormat        string                 // 上报格式 string or array
@@ -61,6 +62,7 @@ func Parse() {
 	flag.StringVar(&LittleWD, "w", "", "cover the working directory")
 	d := flag.Bool("D", false, "debug mode")
 	flag.BoolVar(&FastStart, "faststart", false, "skip waiting 5 seconds")
+	flag.BoolVar(&UpdateProtocol, "update-protocol", false, "update protocol")
 	flag.StringVar(&SignServerOverwrite, "sign-server", "", "use special server to sign tlv")
 	flag.Parse()
 

internal/download/download.go

@@ -33,7 +33,7 @@ var client = &http.Client{
 		MaxIdleConns:        0,
 		MaxIdleConnsPerHost: 999,
 	},
-	Timeout: time.Second * 5,
+	Timeout: time.Second * 15,
 }
 
 // ErrOverSize 响应主体过大时返回此错误

internal/encryption/config.go

@@ -0,0 +1,3 @@
+package encryption
+
+var T544Signer = map[string]func(int64, []byte) []byte{}

internal/encryption/t544/cpuid_amd64.go

@@ -0,0 +1,10 @@
+//go:build amd64
+
+package t544
+
+func cpuid(op uint32) (eax, ebx, ecx, edx uint32)
+
+var canusesse2 = func() bool {
+	_, _, _, d := cpuid(1)
+	return d&(1<<26) > 0
+}()

internal/encryption/t544/cpuid_amd64.s

@@ -0,0 +1,15 @@
+//go:build amd64
+// +build amd64
+
+// Copyright (c) 2015 Klaus Post, released under MIT License. See LICENSE file.
+
+// func cpuid(op uint32) (eax, ebx, ecx, edx uint32)
+TEXT ·cpuid(SB), 7, $0
+    XORQ CX, CX
+    MOVL op+0(FP), AX
+    CPUID
+    MOVL AX, eax+8(FP)
+    MOVL BX, ebx+12(FP)
+    MOVL CX, ecx+16(FP)
+    MOVL DX, edx+20(FP)
+    RET

internal/encryption/t544/encryption.go

@@ -0,0 +1,53 @@
+//go:build amd64
+
+package t544
+
+import (
+	"encoding/binary"
+	"hash/crc32"
+	"io"
+)
+
+var crc32Table = func() (tab crc32.Table) {
+	f, err := cryptoZip.Open("crc32.bin")
+	if err != nil {
+		panic(err)
+	}
+	data, err := io.ReadAll(f)
+	if err != nil {
+		panic(err)
+	}
+	for i := range tab {
+		tab[i] = binary.LittleEndian.Uint32(data[i*4 : (i+1)*4])
+	}
+	return
+}()
+
+func tencentCrc32(tab *crc32.Table, b []byte) uint32
+
+func sub_a([]byte, []uint32)
+
+func sub_b([]byte, []uint32)
+
+func sub_c(*[16][16]byte, []byte)
+
+func sub_d(*[16]byte, []byte)
+
+func sub_e(*[256][6]byte, []byte)
+
+func sub_f(*[16]byte, *[15]uint32, *[16][16]byte) (w [44]uint32)
+
+func sub_aa(int, *[16][2][16][16]byte, *[16]byte, []byte) byte
+
+// transformInner see com/tencent/mobileqq/dt/model/FEBound
+func transformInner(*[0x15]byte, *[32][16]byte)
+
+func initState(*state, []byte, []byte, uint64)
+
+func (c *state) init(key []byte, data []byte, counter uint64, nr uint8) {
+	c.nr = nr
+	c.p = 0
+	initState(c, key, data, counter)
+}
+
+func sub_ad([]uint32)

internal/encryption/t544/encryption_amd64.s

@@ -0,0 +1,637 @@
+//go:build amd64
+// +build amd64
+
+#include "textflag.h"
+
+DATA  LC0<>+0(SB)/4, $1634760805
+DATA  LC0<>+4(SB)/4, $857760878
+DATA  LC0<>+8(SB)/4, $2036477234
+DATA  LC0<>+12(SB)/4, $1797285236
+GLOBL LC0<>(SB), NOPTR, $16
+
+TEXT ·sub_a(SB), NOSPLIT, $0-48
+    MOVQ ·a+0(FP), DI
+    MOVQ ·b+24(FP), CX
+    MOVQ    CX, DX
+    MOVBLZX 3(CX), CX
+    XORB    CX,  (DI)
+    MOVBLZX 2(DX), CX
+    XORB    CX, 1(DI)
+    MOVBLZX 1(DX), CX
+    XORB    CX, 2(DI)
+    MOVBLZX (DX),  CX
+    XORB    CX, 3(DI)
+    MOVBLZX 7(DX), CX
+    XORB    CX, 4(DI)
+    MOVBLZX 6(DX), CX
+    XORB    CX, 5(DI)
+    MOVBLZX 5(DX), CX
+    XORB    CX, 6(DI)
+    MOVBLZX 4(DX), CX
+    XORB    CX, 7(DI)
+    MOVBLZX 11(DX),CX
+    XORB    CX, 8(DI)
+    MOVBLZX 10(DX),CX
+    XORB    CX, 9(DI)
+    MOVBLZX 9(DX), CX
+    XORB    CX,10(DI)
+    MOVBLZX 8(DX), CX
+    XORB    CX,11(DI)
+    MOVBLZX 15(DX),CX
+    XORB    CX,12(DI)
+    MOVBLZX 14(DX),CX
+    XORB    CX,13(DI)
+    MOVBLZX 13(DX),CX
+    XORB    CX,14(DI)
+    MOVBLZX 12(DX),DX
+    XORB    DL,15(DI)
+    RET
+
+TEXT ·sub_b(SB), NOSPLIT, $0-48
+    MOVQ ·a+0(FP), DI
+    MOVQ ·b+24(FP), CX
+    MOVQ    CX, DX
+    MOVBLZX 3(CX), CX
+    XORB    CX, (DI)
+    MOVBLZX 6(DX), CX
+    XORB    CX, 1(DI)
+    MOVBLZX 9(DX), CX
+    XORB    CX, 2(DI)
+    MOVBLZX 12(DX),CX
+    XORB    CX, 3(DI)
+    MOVBLZX 7(DX), CX
+    XORB    CX, 4(DI)
+    MOVBLZX 10(DX),CX
+    XORB    CX, 5(DI)
+    MOVBLZX 13(DX),CX
+    XORB    CX, 6(DI)
+    MOVBLZX (DX), CX
+    XORB    CX,7(DI)
+    MOVBLZX 11(DX),CX
+    XORB    CX,8(DI)
+    MOVBLZX 14(DX),CX
+    XORB    CX,9(DI)
+    MOVBLZX 1(DX), CX
+    XORB    CX,10(DI)
+    MOVBLZX 4(DX), CX
+    XORB    CX,11(DI)
+    MOVBLZX 15(DX),CX
+    XORB    CX,12(DI)
+    MOVBLZX 2(DX), CX
+    XORB    CX,13(DI)
+    MOVBLZX 5(DX), CX
+    XORB    CX,14(DI)
+    MOVBLZX 8(DX), DX
+    XORB    DL,15(DI)
+    RET
+
+
+TEXT ·sub_c(SB), NOSPLIT, $0-32
+    MOVQ ·a+0(FP), DI
+    MOVQ ·b+8(FP), SI
+    MOVQ SI, AX
+    MOVBLZX (SI), SI
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 1(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, (AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 2(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 1(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 3(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 2(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 4(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 3(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 5(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 4(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 6(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 5(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 7(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 6(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 8(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 7(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 9(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 8(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 10(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 9(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 11(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 10(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 12(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 11(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 13(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 12(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 14(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 13(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVBLZX 15(AX), SI
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 14(AX)
+    MOVL SI, CX
+    ANDL $15, SI
+    SHRL $4, CX
+    SHLL $4, CX
+    ADDL SI, CX
+    MOVLQSX CX, CX
+    MOVBLZX (DI)(CX*1), CX
+    MOVB CX, 15(AX)
+    RET 
+
+TEXT ·sub_d(SB), NOSPLIT, $16-32
+    MOVQ ·t+0(FP), BX
+    MOVQ ·s+8(FP), SI
+    MOVOU   (SI), X0
+    MOVOU   X0, in-16(SP)
+    MOVQ    SI, DI
+    ADDQ    $15, DI
+    MOVB    $16, CX
+    STD
+lop:
+    LEAQ    -1(CX), AX
+    XLAT
+    MOVBLZX in-16(SP)(AX*1), AX
+    STOSB
+    LOOP    lop
+    RET
+
+TEXT ·sub_e(SB), NOSPLIT, $0-32
+    MOVQ ·a+0(FP), DI
+    MOVQ ·n+8(FP), SI
+    MOVQ $4, AX
+lop:
+    MOVBQZX -4(SI)(AX*4), DX
+    MOVBQZX -3(SI)(AX*4), CX
+    MOVBQZX -2(SI)(AX*4), R10
+    MOVBQZX -1(SI)(AX*4), R8
+    LEAQ (DX)(DX*2), R9
+    LEAQ (R9*2), R9
+    LEAQ (CX)(CX*2), R11
+    LEAQ (R11*2), R11
+    LEAQ (R10)(R10*2), BX
+    LEAQ (BX*2), BX
+    MOVB DX, R13
+    XORB CX, DX
+    XORB R10, CX
+    MOVB (DI)(R9*1), R12
+    XORB 1(DI)(R11*1), R12
+    XORB R8, R10
+    XORB R12, R10
+    MOVB R10, -4(SI)(AX*4)
+    MOVB (DI)(R11*1), R10
+    XORB 1(DI)(BX*1), R10
+    XORB R8, R13
+    XORB R10, R13
+    MOVB R13, -3(SI)(AX*4)
+    MOVB (DI)(BX*1), R10
+    LEAQ (R8)(R8*2), R8
+    LEAQ (R8*2), R8
+    XORB 1(DI)(R8*1), R10
+    XORB R10, DX
+    MOVB DX, -2(SI)(AX*4)
+    MOVB 1(DI)(R9*1), DX
+    XORB (DI)(R8*1), DX
+    XORB DX, CX
+    MOVB CX, -1(SI)(AX*4)
+    DECB AX
+    JNZ lop
+    RET
+
+TEXT sub_ab(SB), NOSPLIT, $0-24
+    MOVQ ·s+0(FP), DI
+    MOVQ ·w+8(FP), SI
+    MOVL SI, AX
+    MOVL SI, CX
+    MOVL SI, DX
+    SHRL $28, AX
+    SHRL $24, CX
+    ANDL $15, CX
+    SALL $4, AX
+    ADDL CX, AX
+    MOVBLZX SI, CX
+    MOVBLZX (DI)(AX*1), AX
+    MOVBLZX (DI)(CX*1), CX
+    SALL $24, AX
+    ORL CX, AX
+    MOVL SI, CX
+    SHRL $8, SI
+    SHRL $8, CX
+    ANDL $15, SI
+    ANDL $240, CX
+    ADDL SI, CX
+    MOVBLZX (DI)(CX*1), CX
+    SALL $8, CX
+    ORL CX, AX
+    MOVL DX, CX
+    SHRL $16, DX
+    SHRL $16, CX
+    ANDL $15, DX
+    ANDL $240, CX
+    ADDL CX, DX
+    MOVBLZX (DI)(DX*1), DX
+    SALL $16, DX
+    ORL DX, AX
+    MOVQ AX, ·retval+16(FP)
+    RET
+
+TEXT ·sub_f(SB), NOSPLIT, $24-68
+    MOVQ ·k+0(FP), DI
+    MOVQ ·r+8(FP), SI
+    MOVQ ·s+16(FP), DX
+    MOVQ $·w+24(FP), CX
+    MOVQ CX, R10
+    MOVQ SI, R9
+    MOVQ DX, R8
+    MOVL $4, BX
+    MOVL (DI), AX
+    BSWAPL AX
+    MOVL AX, (CX)
+    MOVL 4(DI), AX
+    BSWAPL AX
+    MOVL AX, 4(CX)
+    MOVL 8(DI), AX
+    BSWAPL AX
+    MOVL AX, 8(CX)
+    MOVL 12(DI), AX
+    BSWAPL AX
+    MOVL AX, 12(CX)
+    JMP inner
+for:
+    XORL -16(R10)(BX*4), AX
+    MOVL AX, (R10)(BX*4)
+    ADDQ $1, BX
+    CMPQ BX, $44
+    JE end
+inner:
+    MOVL -4(R10)(BX*4), AX
+    TESTB $3, BX
+    JNE for
+    ROLL $8, AX
+    MOVQ R8, 0(SP)
+    MOVL AX, 8(SP)
+    CALL sub_ab(SB)
+    MOVQ 16(SP), AX
+    LEAL -1(BX), DX
+    SARL $2, DX
+    MOVLQSX DX, DX
+    XORL (R9)(DX*4), AX
+    JMP for
+end:
+    RET
+
+TEXT ·sub_aa(SB), NOSPLIT, $0-56
+    MOVQ ·i+0(FP), DI
+    MOVQ ·t+8(FP), SI
+    MOVQ ·b+16(FP), DX
+    MOVQ ·m+24(FP), CX
+    MOVL DI, AX
+    MOVLQSX DI, DI
+    MOVQ SI, R8
+    MOVQ DX, SI
+    MOVBLZX (CX)(DI*1), CX
+    ANDL $15, AX
+    MOVBLZX (SI)(AX*1), SI
+    MOVQ AX, DX
+    MOVL CX, AX
+    SALQ $9, DX
+    ANDL $15, CX
+    SHRB $4, AX
+    MOVL SI, DI
+    ADDQ R8, DX
+    SALQ $4, CX
+    ANDL $15, AX
+    SHRB $4, DI
+    ANDL $15, SI
+    SALQ $4, AX
+    ANDL $15, DI
+    ADDQ DX, AX
+    ADDQ CX, DX
+    MOVBLZX (AX)(DI*1), AX
+    SALL $4, AX
+    ORB 256(SI)(DX*1), AX
+    MOVQ AX, ·retval+48(FP)
+    RET
+
+// func transformInner(x *[0x15]byte, tab *[32][16]byte)
+TEXT ·transformInner(SB), NOSPLIT, $0-16
+    MOVQ ·x+0(FP), DI
+    MOVQ ·tab+8(FP), SI
+    MOVQ    DI, AX
+    MOVL    $1, CX
+    MOVQ    SI, DI
+    MOVQ    AX, SI
+lop:
+    MOVBLZX (SI), R8
+    LEAL    -1(CX), AX
+    ADDQ    $1, SI
+    ANDL    $31, AX
+    MOVL    R8, DX
+    SALL    $4, AX
+    ANDL    $15, R8
+    SHRB    $4, DX
+    MOVBLZX DX, DX
+    ADDL    DX, AX
+    CDQE
+    MOVBLSX (DI)(AX*1), AX
+    SALL    $4, AX
+    MOVL    AX, DX
+    MOVL    CX, AX
+    ADDL    $2, CX
+    ANDL    $31, AX
+    SALL    $4, AX
+    ADDL    R8, AX
+    CDQE
+    ORB     (DI)(AX*1), DX
+    MOVB    DX, -1(SI)
+    CMPL    CX, $43
+    JNE     lop
+    RET
+
+TEXT ·initState(SB), NOSPLIT, $0-64
+    MOVQ ·c+0(FP), DI
+    MOVQ ·key+8(FP), SI
+    MOVQ ·data+32(FP), R8
+    MOVQ ·counter+56(FP), AX
+    MOVOA   LC0<>(SB), X0
+    MOVUPS  X0, (DI)
+    MOVOU   (SI), X1
+    MOVOU   (DI), X3
+    MOVUPS  X1, 16(DI)
+    MOVOU   16(SI), X2
+    MOVQ    AX, 48(DI)
+    MOVUPS  X2, 32(DI)
+    MOVQ    (R8), AX
+    MOVUPS  X3, 64(DI)
+    MOVQ    AX, 56(DI)
+    MOVQ    48(DI), AX
+    MOVUPS  X1, 80(DI)
+    MOVUPS  X2, 96(DI)
+    MOVUPS  X6,112(DI)
+    RET
+
+TEXT ·sub_ad(SB), NOSPLIT, $8-24
+    MOVQ ·a+0(FP), DI
+    MOVQ DI, AX
+    MOVL 40(DI), R10
+    MOVL 12(DI), R12
+    MOVL 44(DI), BP
+    MOVL 16(DI), DX
+    MOVL (DI), R15
+    MOVL 48(DI), R9
+    MOVL 20(DI), SI
+    MOVL 32(DI), R11
+    ADDL DX, R15
+    MOVL 4(DI), R14
+    MOVL 52(DI), R8
+    XORL R15, R9
+    MOVL 24(DI), CX
+    MOVL 8(DI), R13
+    ROLL $16, R9
+    ADDL SI, R14
+    MOVL 36(DI), BX
+    MOVL 56(DI), DI
+    ADDL R9, R11
+    XORL R14, R8
+    ADDL CX, R13
+    XORL R11, DX
+    ROLL $16, R8
+    XORL R13, DI
+    ROLL $12, DX
+    ADDL R8, BX
+    ROLL $16, DI
+    ADDL DX, R15
+    XORL BX, SI
+    ADDL DI, R10
+    XORL R15, R9
+    ROLL $12, SI
+    XORL R10, CX
+    ROLL $8, R9
+    ADDL SI, R14
+    ROLL $12, CX
+    ADDL R9, R11
+    XORL R14, R8
+    ADDL CX, R13
+    XORL R11, DX
+    ROLL $8, R8
+    XORL R13, DI
+    ROLL $7, DX
+    LEAL (BX)(R8*1), BX
+    ROLL $8, DI
+    MOVL DX, tmp0-8(SP)
+    MOVL 28(AX), DX
+    XORL BX, SI
+    MOVL BX, tmp1-4(SP)
+    MOVL R10, BX
+    MOVL 60(AX), R10
+    ROLL $7, SI
+    ADDL DI, BX
+    ADDL DX, R12
+    ADDL SI, R15
+    XORL R12, R10
+    XORL BX, CX
+    ROLL $16, R10
+    ROLL $7, CX
+    ADDL R10, BP
+    ADDL CX, R14
+    XORL BP, DX
+    XORL R14, R9
+    ROLL $12, DX
+    ROLL $16, R9
+    ADDL DX, R12
+    XORL R12, R10
+    ROLL $8, R10
+    ADDL R10, BP
+    XORL R15, R10
+    ROLL $16, R10
+    XORL BP, DX
+    ADDL R9, BP
+    ADDL R10, BX
+    ROLL $7, DX
+    XORL BP, CX
+    XORL BX, SI
+    ROLL $12, SI
+    ADDL SI, R15
+    XORL R15, R10
+    MOVL R15, (AX)
+    ROLL $8, R10
+    ADDL R10, BX
+    MOVL R10, 60(AX)
+    XORL BX, SI
+    MOVD BX, X1
+    ROLL $7, SI
+    ROLL $12, CX
+    ADDL DX, R13
+    XORL R13, R8
+    ADDL CX, R14
+    MOVL SI, 20(AX)
+    ROLL $16, R8
+    XORL R14, R9
+    MOVL R14, 4(AX)
+    ADDL R8, R11
+    ROLL $8, R9
+    XORL R11, DX
+    ADDL R9, BP
+    MOVL R9, 48(AX)
+    ROLL $12, DX
+    XORL BP, CX
+    MOVD BP, X2
+    ADDL DX, R13
+    ROLL $7, CX
+    PUNPCKLLQ X2, X1
+    XORL R13, R8
+    MOVL CX, 24(AX)
+    ROLL $8, R8
+    MOVL R13, 8(AX)
+    ADDL R8, R11
+    XORL R11, DX
+    MOVD R11, X0
+    ROLL $7, DX
+    MOVL DX, 28(AX)
+    MOVL R8, 52(AX)
+    MOVL tmp0-8(SP), SI
+    MOVL tmp1-4(SP), CX
+    ADDL SI, R12
+    XORL R12, DI
+    ROLL $16, DI
+    ADDL DI, CX
+    XORL CX, SI
+    MOVL SI, DX
+    ROLL $12, DX
+    ADDL DX, R12
+    XORL R12, DI
+    MOVL R12, 12(AX)
+    ROLL $8, DI
+    ADDL DI, CX
+    MOVL DI, 56(AX)
+    MOVD CX, X3
+    XORL CX, DX
+    PUNPCKLLQ X3, X0
+    ROLL $7, DX
+    PUNPCKLQDQ X1, X0
+    MOVL DX, 16(AX)
+    MOVUPS X0, 32(AX)
+    RET
+
+// func tencentCrc32(tab *crc32.Table, b []byte) uint32
+TEXT ·tencentCrc32(SB), NOSPLIT, $0-40
+    MOVQ ·tab+0(FP), DI
+    MOVQ ·bptr+8(FP), SI
+    MOVQ ·bngas+16(FP), DX
+    TESTQ   DX, DX
+    JE      quickend
+    ADDQ    SI, DX
+    MOVL    $-1, AX
+lop:
+    MOVBLZX (SI), CX
+    ADDQ    $1, SI
+    XORL    AX, CX
+    SHRL    $8, AX
+    MOVBLZX CX, CX
+    XORL    (DI)(CX*4), AX
+    CMPQ    SI, DX
+    JNE     lop
+    NOTL    AX
+    MOVQ    AX, ·bngas+32(FP)
+    RET
+quickend:
+    XORL    AX, AX
+    RET
+

internal/encryption/t544/encryption_generic.go

@@ -0,0 +1,117 @@
+//go:build amd64
+
+package t544
+
+import (
+	"encoding/binary"
+	"io"
+)
+
+type encryptionData struct {
+	tableA [16][2][16][16]byte
+	tableB [16][16]byte
+	tableC [256][6]byte
+	tableD [16]byte
+	tableE [16]byte
+	tableF [15]uint32
+}
+
+type state struct {
+	state    [16]uint32 // 16
+	orgstate [16]uint32 // 16
+	nr       uint8
+	p        uint8
+}
+
+var crypto = encryptionData{
+	tableA: readData[[16][2][16][16]byte]("table_a.bin"),
+	tableB: readData[[16][16]byte]("table_b.bin"),
+	tableC: readData[[256][6]byte]("table_c.bin"),
+	tableD: readData[[16]byte]("table_d.bin"),
+	tableE: readData[[16]byte]("table_e.bin"),
+	tableF: func() (tab [15]uint32) {
+		f, err := cryptoZip.Open("table_f.bin")
+		if err != nil {
+			panic(err)
+		}
+		data, err := io.ReadAll(f)
+		if err != nil {
+			panic(err)
+		}
+		for i := range tab {
+			tab[i] = binary.LittleEndian.Uint32(data[i*4 : (i+1)*4])
+		}
+		return
+	}(),
+}
+
+func (e *encryptionData) tencentEncryptB(p1 []byte, p2 []uint32) {
+	const c = 10
+	for r := 0; r < 9; r++ {
+		sub_d(&e.tableD, p1)
+		sub_b(p1, p2[r*4:(r+1)*4])
+		sub_c(&e.tableB, p1)
+		sub_e(&e.tableC, p1)
+	}
+	sub_d(&e.tableD, p1)
+	sub_b(p1, p2[(c-1)*4:c*4])
+	sub_c(&e.tableB, p1)
+	sub_a(p1, p2[c*4:(c+1)*4])
+}
+
+func (e *encryptionData) tencentEncryptionB(c []byte, m []byte) (out [0x15]byte) {
+	var buf [16]byte
+	w := sub_f(&e.tableE, &e.tableF, &e.tableB)
+
+	for i := range out {
+		if (i & 0xf) == 0 {
+			copy(buf[:], c)
+			e.tencentEncryptB(buf[:], w[:])
+			for j := 15; j >= 0; j-- {
+				c[j]++
+				if c[j] != 0 {
+					break
+				}
+			}
+		}
+		out[i] = sub_aa(i, &e.tableA, &buf, m)
+	}
+
+	return
+}
+
+func tencentEncryptionA(input, key, data []byte) {
+	var s state
+	s.init(key, data, 0, 20)
+	s.encrypt(input)
+}
+
+func (c *state) encrypt(data []byte) {
+	bp := 0
+	dataLen := uint32(len(data))
+	for dataLen > 0 {
+		if c.p == 0 {
+			for i := uint8(0); i < c.nr; i += 2 {
+				sub_ad(c.state[:])
+			}
+			for i := 0; i < 16; i++ {
+				c.state[i] += c.orgstate[i]
+			}
+		}
+		var sb [16 * 4]byte
+		for i, v := range c.state {
+			binary.LittleEndian.PutUint32(sb[i*4:(i+1)*4], v)
+		}
+		for c.p != 64 && dataLen != 0 {
+			data[bp] ^= sb[c.p]
+			c.p++
+			bp++
+			dataLen--
+		}
+		if c.p >= 64 {
+			c.p = 0
+			c.orgstate[12]++
+			c.state = c.orgstate
+		}
+	}
+}

internal/encryption/t544/t544.go

@@ -0,0 +1,93 @@
+//go:build amd64
+
+package t544
+
+import (
+	"crypto/md5"
+	"crypto/rc4"
+	"encoding/binary"
+	"math/rand"
+	"unsafe"
+
+	"github.com/Mrs4s/go-cqhttp/internal/encryption"
+)
+
+const (
+	keyTable = "$%&()+,-456789:?ABCDEEFGHIJabcdefghijkopqrstuvwxyz"
+	table2   = "!#$%&)+.0123456789:=>?@ABCDEFGKMNabcdefghijkopqrst"
+)
+
+var (
+	magic = uint64(0x6EEDCF0DC4675540)
+	key1  = [8]byte{'a', '$', '(', 'e', 'T', '7', '*', '@'}
+	key2  = [8]byte{'&', 'O', '9', '!', '>', '6', 'X', ')'}
+)
+
+func init() {
+	if canusesse2 {
+		encryption.T544Signer["8.9.35.10440"] = sign
+		encryption.T544Signer["8.9.38.10545"] = sign
+	}
+}
+
+// sign t544 algorithm
+// special thanks to the anonymous contributor who provided the algorithm
+func sign(curr int64, input []byte) []byte {
+	curr %= 1000000
+	input = append(input, []byte{byte(curr >> 24), byte(curr >> 16), byte(curr >> 8), byte(curr)}...)
+	var kt [4 + 32 + 4]byte
+	r := rand.New(rand.NewSource(curr))
+	for i := 0; i < 2; i++ {
+		kt[i] = keyTable[r.Int()%0x32] + 50
+	}
+	kt[2] = kt[1] + 20
+	kt[3] = kt[2] + 20
+	key3 := kt[4 : 4+10]
+	k3calc := key3[2:10]
+	copy(k3calc, key1[:4])
+	for i := 0; i < 4; i++ {
+		k3calc[4+i] = key2[i] ^ kt[i]
+	}
+	key3[0], key3[1] = k3calc[6], k3calc[7]
+	key3 = key3[:8]
+	k3calc[6], k3calc[7] = 0, 0
+	rc4Cipher, _ := rc4.NewCipher(key3)
+	rc4Cipher.XORKeyStream(key3, key3)
+	var crcData [0x15]byte
+	copy(crcData[4:4+8], (*[8]byte)(unsafe.Pointer(&magic))[:])
+	tencentEncryptionA(input, kt[4:4+32], crcData[4:4+8])
+	result := md5.Sum(input)
+	crcData[2] = 1
+	crcData[4] = 1
+	copy(crcData[5:9], kt[:4])
+	binary.BigEndian.PutUint32(crcData[9:13], uint32(curr))
+	copy(crcData[13:], result[:8])
+	calcCrc := tencentCrc32(&crc32Table, crcData[2:])
+	copy(kt[4+32:4+32+4], (*[4]byte)(unsafe.Pointer(&calcCrc))[:])
+	crcData[0] = kt[4+32]
+	crcData[1] = kt[4+32+3]
+	nonce := uint32(r.Int() ^ r.Int() ^ r.Int())
+	on := kt[:16]
+	binary.BigEndian.PutUint32(on[:4], nonce)
+	copy(on[4:8], on[:4])
+	copy(on[8:16], on[:8])
+	ts.transformEncode(&crcData)
+	encryptedData := crypto.tencentEncryptionB(on, crcData[:])
+	ts.transformDecode(&encryptedData)
+	output := kt[:39]
+	output[0] = 0x0C
+	output[1] = 0x05
+	binary.BigEndian.PutUint32(output[2:6], nonce)
+	copy(output[6:27], encryptedData[:])
+	binary.LittleEndian.PutUint32(output[27:31], 0)
+	output[31] = table2[r.Int()%0x32]
+	output[32] = table2[r.Int()%0x32]
+	addition := r.Int() % 9
+	for addition&1 == 0 {
+		addition = r.Int() % 9
+	}
+	output[33] = output[31] + byte(addition)
+	output[34] = output[32] + byte(9-addition) + 1
+	binary.LittleEndian.PutUint32(output[35:39], 0)
+	return output
+}

internal/encryption/t544/t544_stub.go

@@ -0,0 +1,7 @@
+//go:build !amd64
+
+package t544
+
+func init() {
+
+}

internal/encryption/t544/transform.go

@@ -0,0 +1,21 @@
+//go:build amd64
+
+package t544
+
+type transformer struct {
+	encode [32][16]byte
+	decode [32][16]byte
+}
+
+func (ts *transformer) transformEncode(bArr *[0x15]byte) {
+	transformInner(bArr, &ts.encode)
+}
+
+func (ts *transformer) transformDecode(bArr *[0x15]byte) {
+	transformInner(bArr, &ts.decode)
+}
+
+var ts = transformer{
+	encode: readData[[32][16]byte]("encode.bin"),
+	decode: readData[[32][16]byte]("decode.bin"),
+}

modules/config/config.go

@@ -28,14 +28,13 @@ type Reconnect struct {
 
 // Account 账号配置
 type Account struct {
-	Uin                   int64      `yaml:"uin"`
-	Password              string     `yaml:"password"`
-	Encrypt               bool       `yaml:"encrypt"`
-	Status                int        `yaml:"status"`
-	ReLogin               *Reconnect `yaml:"relogin"`
-	UseSSOAddress         bool       `yaml:"use-sso-address"`
-	AllowTempSession      bool       `yaml:"allow-temp-session"`
-	DisableProtocolUpdate bool       `yaml:"disable-protocol-update"`
+	Uin              int64      `yaml:"uin"`
+	Password         string     `yaml:"password"`
+	Encrypt          bool       `yaml:"encrypt"`
+	Status           int        `yaml:"status"`
+	ReLogin          *Reconnect `yaml:"relogin"`
+	UseSSOAddress    bool       `yaml:"use-sso-address"`
+	AllowTempSession bool       `yaml:"allow-temp-session"`
 }
 
 // Config 总配置文件

modules/config/default_config.yml

@@ -15,8 +15,6 @@ account: # 账号相关
   use-sso-address: true
   # 是否允许发送临时会话消息
   allow-temp-session: false
-  # 是否禁用协议更新
-  disable-protocol-update: false
 
 heartbeat:
   # 心跳频率, 单位秒

modules/silk/codec.go

@@ -32,6 +32,9 @@ func encode(record []byte, tempName string) (silkWav []byte, err error) {
 	// 2.转换pcm
 	pcmPath := path.Join(silkCachePath, tempName+".pcm")
 	cmd := exec.Command("ffmpeg", "-i", rawPath, "-f", "s16le", "-ar", "24000", "-ac", "1", pcmPath)
+	if errors.Is(cmd.Err, exec.ErrDot) {
+		cmd.Err = nil
+	}
 	if base.Debug {
 		cmd.Stdout = os.Stdout
 		cmd.Stderr = os.Stderr