shkong/go-cqhttp
1
0
Fork 0
mirror of https://github.com/Mrs4s/go-cqhttp.git synced 2025-05-06 12:03:50 +08:00
Code Issues Projects Releases Wiki Activity

fix multi-threading upload.

Browse Source
This commit is contained in:
Mrs4s 2021-01-11 00:45:49 +08:00
parent 36532a8782
commit 50f0f572bc
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
coolq/bot.go
View File

@ -3,8 +3,11 @@ package coolq
import ( import (
"bytes" "bytes"
"encoding/gob" "encoding/gob"
"encoding/hex"
"fmt" "fmt"
"github.com/Mrs4s/MiraiGo/utils"
"hash/crc32" "hash/crc32"
"io"
"os" "os"
"path" "path"
"runtime/debug" "runtime/debug"
@ -132,10 +135,11 @@ func (bot *CQBot) UploadLocalVideo(target int64, v *LocalVideoElement) (*message
return nil, err return nil, err
} }
defer video.Close() defer video.Close()
// todo 多线程上传失败: 短视频上传失败: resp is empty (upload video file error: upload failed: 70 hash, _ := utils.ComputeMd5AndLength(io.MultiReader(video, v.thumb))
//hash, _ := utils.ComputeMd5AndLength(io.MultiReader(video, v.thumb)) cacheFile := path.Join(global.CACHE_PATH, hex.EncodeToString(hash[:])+".cache")
//cacheFile := path.Join(global.CACHE_PATH, hex.EncodeToString(hash[:])+".cache") _, _ = video.Seek(0, io.SeekStart)
return bot.Client.UploadGroupShortVideo(target, video, v.thumb) _, _ = v.thumb.Seek(0, io.SeekStart)
return bot.Client.UploadGroupShortVideo(target, video, v.thumb, cacheFile)
} }
return &v.ShortVideoElement, nil return &v.ShortVideoElement, nil
} }