archive/nntpchan
Archived
1
0
Fork 0
Code

fix

Browse Source
This commit is contained in:
Jeff Becker 2018-01-04 15:23:10 -05:00
parent 92320aff4c
commit 0266deee2b
No known key found for this signature in database
GPG Key ID: F357B3B42F6F9B05
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
contrib/backends/srndv2/src/srnd/store.go
View File

@ -591,16 +591,16 @@ func (self *articleStore) GetMessage(msgid string) (nntp NNTPMessage) {
hdr := textproto.MIMEHeader(msg.Header) hdr := textproto.MIMEHeader(msg.Header)
err = read_message_body(msg.Body, hdr, nil, nil, true, func(n NNTPMessage) { err = read_message_body(msg.Body, hdr, nil, nil, true, func(n NNTPMessage) {
c := chnl c := chnl
if n != nil {
// inject pubkey for mod // inject pubkey for mod
n.Headers().Set("X-PubKey-Ed25519", hdr.Get("X-PubKey-Ed25519")) n.Headers().Set("X-PubKey-Ed25519", hdr.Get("X-PubKey-Ed25519"))
c <- n c <- n
close(c) }
}) })
if err == nil { if err == nil {
nntp = <-chnl nntp = <-chnl
} else { } else {
log.Println("GetMessage() failed to load", msgid, err) log.Println("GetMessage() failed to load", msgid, err)
close(chnl)
} }
} }
} }