1
0
mirror of https://github.com/Mrs4s/MiraiGo.git synced 2025-05-04 19:17:38 +08:00

internal/proto: add SInt[32|64]

also simplify some code.
This commit is contained in:
wdvxdr 2022-09-25 16:26:53 +08:00
parent 8aa1683866
commit d3b8c5f700
4 changed files with 61 additions and 45 deletions

View File

@ -177,14 +177,14 @@ func (g *GuildInfo) removeChannel(id uint64) {
func (s *GuildService) GetUserProfile(tinyId uint64) (*GuildUserProfile, error) { func (s *GuildService) GetUserProfile(tinyId uint64) (*GuildUserProfile, error) {
flags := proto.DynamicMessage{} flags := proto.DynamicMessage{}
for i := 3; i <= 29; i++ { for i := 3; i <= 29; i++ {
flags[uint64(i)] = uint32(1) flags[uint64(i)] = 1
} }
flags[99] = uint32(1) flags[99] = 1
flags[100] = uint32(1) flags[100] = 1
payload := s.c.packOIDBPackageDynamically(3976, 1, proto.DynamicMessage{ payload := s.c.packOIDBPackageDynamically(3976, 1, proto.DynamicMessage{
1: flags, 1: flags,
3: tinyId, 3: tinyId,
4: uint32(0), 4: 0,
}) })
rsp, err := s.c.sendAndWaitDynamic(s.c.uniPacket("OidbSvcTrpcTcp.0xfc9_1", payload)) rsp, err := s.c.sendAndWaitDynamic(s.c.uniPacket("OidbSvcTrpcTcp.0xfc9_1", payload))
if err != nil { if err != nil {
@ -208,16 +208,23 @@ func (s *GuildService) GetUserProfile(tinyId uint64) (*GuildUserProfile, error)
// 后续请求请根据上次请求的返回值进行设置 // 后续请求请根据上次请求的返回值进行设置
func (s *GuildService) FetchGuildMemberListWithRole(guildId, channelId uint64, startIndex uint32, roleIdIndex uint64, param string) (*FetchGuildMemberListWithRoleResult, error) { func (s *GuildService) FetchGuildMemberListWithRole(guildId, channelId uint64, startIndex uint32, roleIdIndex uint64, param string) (*FetchGuildMemberListWithRoleResult, error) {
seq := s.c.nextSeq() seq := s.c.nextSeq()
u1 := uint32(1)
m := proto.DynamicMessage{ m := proto.DynamicMessage{
1: guildId, // guild id 1: guildId, // guild id
2: uint32(3), 2: 3,
3: uint32(0), 3: 0,
4: proto.DynamicMessage{ // unknown param, looks like flags 4: proto.DynamicMessage{ // unknown param, looks like flags
1: u1, 2: u1, 3: u1, 4: u1, 5: u1, 6: u1, 7: u1, 8: u1, 20: u1, 1: 1,
2: 1,
3: 1,
4: 1,
5: 1,
6: 1,
7: 1,
8: 1,
20: 1,
}, },
6: startIndex, 6: startIndex,
8: uint32(50), // count 8: 50, // count
12: channelId, 12: channelId,
} }
if param != "" { if param != "" {
@ -270,10 +277,10 @@ func (s *GuildService) FetchGuildMemberProfileInfo(guildId, tinyId uint64) (*Gui
seq := s.c.nextSeq() seq := s.c.nextSeq()
flags := proto.DynamicMessage{} flags := proto.DynamicMessage{}
for i := 3; i <= 29; i++ { for i := 3; i <= 29; i++ {
flags[uint64(i)] = uint32(1) flags[uint64(i)] = 1
} }
flags[99] = uint32(1) flags[99] = 1
flags[100] = uint32(1) flags[100] = 1
payload := s.c.packOIDBPackageDynamically(3976, 1, proto.DynamicMessage{ payload := s.c.packOIDBPackageDynamically(3976, 1, proto.DynamicMessage{
1: flags, 1: flags,
3: tinyId, 3: tinyId,
@ -330,13 +337,12 @@ func (s *GuildService) GetGuildRoles(guildId uint64) ([]*GuildRole, error) {
} }
func (s *GuildService) CreateGuildRole(guildId uint64, name string, color uint32, independent bool, initialUsers []uint64) (uint64, error) { func (s *GuildService) CreateGuildRole(guildId uint64, name string, color uint32, independent bool, initialUsers []uint64) (uint64, error) {
u1 := uint32(1)
seq, packet := s.c.uniPacket("OidbSvcTrpcTcp.0x1016_1", s.c.packOIDBPackageDynamically(4118, 1, proto.DynamicMessage{ seq, packet := s.c.uniPacket("OidbSvcTrpcTcp.0x1016_1", s.c.packOIDBPackageDynamically(4118, 1, proto.DynamicMessage{
1: guildId, 1: guildId,
2: proto.DynamicMessage{ // todo: 未知参数 2: proto.DynamicMessage{ // todo: 未知参数
1: u1, 1: 1,
2: u1, 2: 1,
3: u1, 3: 1,
}, },
3: proto.DynamicMessage{ 3: proto.DynamicMessage{
1: name, 1: name,
@ -389,14 +395,13 @@ func (s *GuildService) SetUserRoleInGuild(guildId uint64, set bool, roleId uint6
} }
func (s *GuildService) ModifyRoleInGuild(guildId uint64, roleId uint64, name string, color uint32, indepedent bool) error { func (s *GuildService) ModifyRoleInGuild(guildId uint64, roleId uint64, name string, color uint32, indepedent bool) error {
u1 := uint32(1)
seq, packet := s.c.uniPacket("OidbSvcTrpcTcp.0x100d_1", s.c.packOIDBPackageDynamically(4109, 1, proto.DynamicMessage{ seq, packet := s.c.uniPacket("OidbSvcTrpcTcp.0x100d_1", s.c.packOIDBPackageDynamically(4109, 1, proto.DynamicMessage{
1: guildId, 1: guildId,
2: roleId, 2: roleId,
3: proto.DynamicMessage{ 3: proto.DynamicMessage{
1: u1, 1: 1,
2: u1, 2: 1,
3: u1, 3: 1,
}, },
4: proto.DynamicMessage{ 4: proto.DynamicMessage{
1: name, 1: name,
@ -412,15 +417,14 @@ func (s *GuildService) ModifyRoleInGuild(guildId uint64, roleId uint64, name str
} }
func (s *GuildService) FetchGuestGuild(guildId uint64) (*GuildMeta, error) { func (s *GuildService) FetchGuestGuild(guildId uint64) (*GuildMeta, error) {
u1 := uint32(1)
payload := s.c.packOIDBPackageDynamically(3927, 9, proto.DynamicMessage{ payload := s.c.packOIDBPackageDynamically(3927, 9, proto.DynamicMessage{
1: proto.DynamicMessage{ 1: proto.DynamicMessage{
1: proto.DynamicMessage{ 1: proto.DynamicMessage{
2: u1, 4: u1, 5: u1, 6: u1, 7: u1, 8: u1, 11: u1, 12: u1, 13: u1, 14: u1, 45: u1, 2: 1, 4: 1, 5: 1, 6: 1, 7: 1, 8: 1, 11: 1, 12: 1, 13: 1, 14: 1, 45: 1,
18: u1, 19: u1, 20: u1, 22: u1, 23: u1, 5002: u1, 5003: u1, 5004: u1, 5005: u1, 10007: u1, 18: 1, 19: 1, 20: 1, 22: 1, 23: 1, 5002: 1, 5003: 1, 5004: 1, 5005: 1, 10007: 1,
}, },
2: proto.DynamicMessage{ 2: proto.DynamicMessage{
3: u1, 4: u1, 6: u1, 11: u1, 14: u1, 15: u1, 16: u1, 17: u1, 3: 1, 4: 1, 6: 1, 11: 1, 14: 1, 15: 1, 16: 1, 17: 1,
}, },
}, },
2: proto.DynamicMessage{ 2: proto.DynamicMessage{
@ -454,7 +458,7 @@ func (s *GuildService) FetchChannelList(guildId uint64) (r []*ChannelInfo, e err
proto.DynamicMessage{ proto.DynamicMessage{
1: guildId, 1: guildId,
3: proto.DynamicMessage{ 3: proto.DynamicMessage{
1: uint32(1), 1: 1,
}, },
})) }))
rsp, err := s.c.sendAndWaitDynamic(seq, packet) rsp, err := s.c.sendAndWaitDynamic(seq, packet)
@ -616,14 +620,13 @@ func (s *GuildService) PostTopicChannelFeed(guildId, channelId uint64, feed *top
} }
func (s *GuildService) fetchMemberRoles(guildId uint64, tinyId uint64) ([]*GuildRole, error) { func (s *GuildService) fetchMemberRoles(guildId uint64, tinyId uint64) ([]*GuildRole, error) {
u1 := uint32(1)
seq, packet := s.c.uniPacket("OidbSvcTrpcTcp.0x1017_1", s.c.packOIDBPackageDynamically(4119, 1, proto.DynamicMessage{ seq, packet := s.c.uniPacket("OidbSvcTrpcTcp.0x1017_1", s.c.packOIDBPackageDynamically(4119, 1, proto.DynamicMessage{
1: guildId, 1: guildId,
2: tinyId, 2: tinyId,
4: proto.DynamicMessage{ 4: proto.DynamicMessage{
1: u1, 1: 1,
2: u1, 2: 1,
3: u1, 3: 1,
}, },
})) }))
rsp, err := s.c.sendAndWaitDynamic(seq, packet) rsp, err := s.c.sendAndWaitDynamic(seq, packet)

View File

@ -91,8 +91,8 @@ func (c *QQClient) uploadGroupOrGuildImage(target message.Source, img io.ReadSee
if target.SourceType != message.SourceGroup { // guild if target.SourceType != message.SourceGroup { // guild
cmd = 83 cmd = 83
ext = proto.DynamicMessage{ ext = proto.DynamicMessage{
11: uint64(target.PrimaryID), 11: target.PrimaryID,
12: uint64(target.SecondaryID), 12: target.SecondaryID,
}.Encode() }.Encode()
} }

View File

@ -7,6 +7,13 @@ import (
type DynamicMessage map[uint64]any type DynamicMessage map[uint64]any
// zigzag encoding types
type (
SInt int
SInt32 int32
SInt64 int64
)
type encoder struct { type encoder struct {
buf []byte buf []byte
} }
@ -26,19 +33,31 @@ func (msg DynamicMessage) Encode() []byte {
en.uvarint(vi) en.uvarint(vi)
case int: case int:
en.uvarint(key | 0) en.uvarint(key | 0)
en.svarint(int64(v)) en.uvarint(uint64(v))
case uint:
en.uvarint(key | 0)
en.uvarint(uint64(v))
case int32: case int32:
en.uvarint(key | 0) en.uvarint(key | 0)
en.svarint(int64(v)) en.uvarint(uint64(v))
case int64: case int64:
en.uvarint(key | 0) en.uvarint(key | 0)
en.svarint(v) en.uvarint(uint64(v))
case uint32: case uint32:
en.uvarint(key | 0) en.uvarint(key | 0)
en.uvarint(uint64(v)) en.uvarint(uint64(v))
case uint64: case uint64:
en.uvarint(key | 0) en.uvarint(key | 0)
en.uvarint(v) en.uvarint(v)
case SInt:
en.uvarint(key | 0)
en.svarint(int64(v))
case SInt32:
en.uvarint(key | 0)
en.svarint(int64(v))
case SInt64:
en.uvarint(key | 0)
en.svarint(int64(v))
case float32: case float32:
en.uvarint(key | 5) en.uvarint(key | 5)
en.u32(math.Float32bits(v)) en.u32(math.Float32bits(v))
@ -69,23 +88,17 @@ func (msg DynamicMessage) Encode() []byte {
} }
func (en *encoder) uvarint(v uint64) { func (en *encoder) uvarint(v uint64) {
var b [binary.MaxVarintLen64]byte en.buf = binary.AppendUvarint(en.buf, v)
n := binary.PutUvarint(b[:], v)
en.buf = append(en.buf, b[:n]...)
} }
func (en *encoder) svarint(v int64) { func (en *encoder) svarint(v int64) {
en.uvarint(uint64(v)<<1 ^ uint64(v>>63)) en.buf = binary.AppendVarint(en.buf, v)
} }
func (en *encoder) u32(v uint32) { func (en *encoder) u32(v uint32) {
var b [4]byte en.buf = binary.LittleEndian.AppendUint32(en.buf, v)
binary.LittleEndian.PutUint32(b[:], v)
en.buf = append(en.buf, b[:]...)
} }
func (en *encoder) u64(v uint64) { func (en *encoder) u64(v uint64) {
var b [8]byte en.buf = binary.LittleEndian.AppendUint64(en.buf, v)
binary.LittleEndian.PutUint64(b[:], v)
en.buf = append(en.buf, b[:]...)
} }

View File

@ -190,7 +190,7 @@ func (e *GuildImageElement) Pack() (r []*msg.Elem) {
Size: proto.Some(e.Size), Size: proto.Some(e.Size),
Md5: e.Md5, Md5: e.Md5,
PbReserve: proto.DynamicMessage{ PbReserve: proto.DynamicMessage{
1: uint32(0), 2: uint32(0), 6: "", 10: uint32(0), 15: uint32(8), 1: 0, 2: 0, 6: "", 10: 0, 15: 8,
20: e.DownloadIndex, 20: e.DownloadIndex,
}.Encode(), }.Encode(),
} }