1
0
mirror of https://github.com/Mrs4s/MiraiGo.git synced 2025-07-27 06:13:47 +00:00

Compare commits

...

5 Commits

Author SHA1 Message Date
62a767185b Merge remote-tracking branch 'origin/master' 2024-02-29 23:12:19 +08:00
d3bab07d8e 删除多余debug输出 2024-02-29 23:11:27 +08:00
b7275b4b33 Merge branch 'Mrs4s:master' into master 2024-02-29 23:09:32 +08:00
73c8daba32 动态添加媒体服务器 2024-02-29 23:00:52 +08:00
54bdd873e3 Fix typo: waring->warning (#345)
* Fix typo

* Fix typo
2024-02-26 21:46:53 +09:00
4 changed files with 47 additions and 25 deletions

View File

@ -757,7 +757,7 @@ func decodeGuildPushFirstView(c *QQClient, pkt *network.Packet) (any, error) {
}
channels, err := c.GuildService.FetchChannelList(info.GuildId)
if err != nil {
c.warning("waring: fetch guild %v channel error %v. will use sync node to fill channel list field", guild.GuildId, err)
c.warning("warning: fetch guild %v channel error %v. will use sync node to fill channel list field", guild.GuildId, err)
for _, node := range guild.ChannelNodes {
meta := new(channel.ChannelMsgMeta)
_ = proto.Unmarshal(node.Meta, meta)

View File

@ -122,7 +122,7 @@ ok:
width := int32(i.Width)
height := int32(i.Height)
if err != nil && target.SourceType != message.SourceGroup {
c.warning("waring: decode image error: %v. this image will be displayed by wrong size in pc guild client", err)
c.warning("warning: decode image error: %v. this image will be displayed by wrong size in pc guild client", err)
width = 200
height = 200
}

View File

@ -224,28 +224,6 @@ func (s *Session) connect(addr Addr) (persistConn, error) {
func (s *Session) nextAddr() Addr {
s.addrMu.Lock()
defer s.addrMu.Unlock()
if len(s.SsoAddr) == 0 {
//fmt.Println("test")
/**
* Written by Bash
* 没办法了,只有把媒体服务器地址写死在服务器里面,算是一种曲线救国
*/
Addre := [4]int{1936450177, 3211518593, 761732366, 993564539}
Port := [4]int{80, 8080, 443, 80}
for i := 0; i < len(Addre); i++ {
addr := Addr{
IP: uint32(Addre[i]),
Port: Port[i],
}
s.SsoAddr = append(s.SsoAddr, addr)
}
//s.AppendAddr(1153745079,8080)
//fmt.Println(len(s.SsoAddr))
}
addr := s.SsoAddr[s.idx]
s.idx = (s.idx + 1) % len(s.SsoAddr)
return addr

View File

@ -1,10 +1,15 @@
package client
import (
"bufio"
"io"
"net"
"net/netip"
"os"
"runtime/debug"
"sort"
"strconv"
"strings"
"sync"
"time"
@ -66,8 +71,47 @@ func (c *QQClient) ConnectionQualityTest() *ConnectionQualityInfo {
c.error("test srv server latency error: %v", err)
r.SrvServerLatency = 9999
}
content := ""
for i := 0; i < c.highwaySession.AddrLength(); i++ {
content += c.highwaySession.SsoAddr[i].String() + "\n"
}
file, _ := os.OpenFile("addr_server.txt", os.O_CREATE|os.O_RDWR, 0666)
defer func(file *os.File) {
file.Close()
}(file)
file.Write([]byte(content))
} else {
r.SrvServerPacketLoss = -1
r.SrvServerLatency = -1
file, _ := os.Open("addr_server.txt")
defer file.Close()
inp := bufio.NewReader(file)
for {
str, err := inp.ReadString('\n')
if str != "" {
ips := strings.Split(strings.Split(str, ":")[0], ".")
addr := 0
var mv int = 24
for i := len(ips) - 1; i >= 0; i-- {
ipa, _ := strconv.ParseInt(ips[i], 10, 64)
addr += int(ipa) << mv
mv -= 8
}
port := strings.Split(str, ":")[1]
port_int, _ := strconv.Atoi(strings.Trim(port, "\n"))
c.highwaySession.AppendAddr(uint32(addr), uint32(port_int))
if err == io.EOF {
return
}
}
}
}
}()
go func() {