Archive
/
Rssmon2
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

whooops vendoring my own pkg

master
Bel LaPointe 2018-11-17 11:59:46 -07:00
parent 24f9f4d07e
commit f1cfa36427
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
exchange/exchange.go
View File

@ -228,9 +228,19 @@ func (ex *Exchange) handlerTorrent(item *rss.Item) {
return return
} }
sessionID := resp.Header.Get("X-Transmission-Session-Id") sessionID := resp.Header.Get("X-Transmission-Session-Id")
req, err := http.NewRequest("POST", ex.toraddr, bytes.NewBuffer([]byte(`{"method":"torrent-add", "arguments": {"filename": "`+match+`"} }`))) requestBody, err := json.Marshal(map[string]interface{}{
"method": "torrent-add",
"arguments": map[string]interface{}{
"filename": match,
},
})
if err != nil { if err != nil {
logger.Log("cannot build request: %v", err) logger.Log("cannot build request body: %v", err)
return
}
req, err := http.NewRequest("POST", ex.toraddr, bytes.NewBuffer(requestBody))
if err != nil {
logger.Log("cannot POST request: %v", err)
return return
} }
req.Header.Add("X-Transmission-Session-Id", sessionID) req.Header.Add("X-Transmission-Session-Id", sessionID)
@ -247,6 +257,6 @@ func (ex *Exchange) handlerTorrent(item *rss.Item) {
} }
if v, ok := out["result"]; !ok || v != "success" { if v, ok := out["result"]; !ok || v != "success" {
logger.Logf("failed magnet submission for feed item %v (%v): %v", item.Name, item.Content, v) logger.Logf("failed magnet submission for feed item %v: %v", item.Name, v)
} }
} }