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

fix(scf): always flush the writer.

Browse Source
This commit is contained in:
wdvxdr 2021-08-16 16:05:33 +08:00
parent 971cb5d854
commit 78d76f55e2
No known key found for this signature in database
GPG Key ID: 703F8C071DE7A1B6
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
server/scf.go
View File

@ -116,23 +116,20 @@ func RunLambdaClient(bot *coolq.CQBot, conf *config.LambdaServer) {
for { for {
req := cli.next() req := cli.next()
if req == nil { writer := lambdaResponseWriter{statusCode: 200, header: make(http.Header)}
writer := lambdaResponseWriter{statusCode: 200}
_, _ = writer.Write(nil)
continue
}
func() { func() {
defer func() { defer func() {
if e := recover(); e != nil { if e := recover(); e != nil {
log.Warnf("Lambda 出现不可恢复错误: %v\n%s", e, debug.Stack()) log.Warnf("Lambda 出现不可恢复错误: %v\n%s", e, debug.Stack())
} }
}() }()
writer := lambdaResponseWriter{header: make(http.Header)} if req != nil {
server.ServeHTTP(&writer, req) server.ServeHTTP(&writer, req)
}
}()
if err := writer.flush(); err != nil { if err := writer.flush(); err != nil {
log.Warnf("Lambda 发送响应失败: %v", err) log.Warnf("Lambda 发送响应失败: %v", err)
} }
}()
} }
} }