Added uploading of torrent file

README.md

@@ -42,6 +42,11 @@ For manual infohash, display name, and trackers
 }
 ```
 
+### Uploading a torrent file
+`POST /api/addtorrentfile`
+
+Attach the file in the `torrent` field in `multipart/form-data`
+
 ### Selecting a file for download
 `POST /api/selectfile`
 

endpoints.go

@@ -6,6 +6,7 @@ import (
 	"time"
 
 	"github.com/anacrolix/torrent"
+	"github.com/anacrolix/torrent/metainfo"
 	"github.com/gorilla/mux"
 )
 
@@ -48,20 +49,7 @@ func apiAddTorrent(w http.ResponseWriter, r *http.Request) {
 	}
 
 	/* Creates the response body*/
-	res := apiAddTorrentRes{
-		Name:          t.Name(),
-		InfoHash:      t.InfoHash().String(),
-		TotalPeers:    t.Stats().TotalPeers,
-		ActivePeers:   t.Stats().ActivePeers,
-		PendingPeers:  t.Stats().PendingPeers,
-		HalfOpenPeers: t.Stats().HalfOpenPeers,
-	}
-	for _, f := range t.Files() {
-		res.Files = append(res.Files, apiTorrentFiles{
-			FileName:      f.DisplayPath(),
-			FileSizeBytes: int(f.Length()),
-		})
-	}
+	res := createAddTorrentRes(t)
 	encodeRes(w, &res)
 	return
 }
@@ -318,3 +306,38 @@ func apiDownloadFile(w http.ResponseWriter, r *http.Request) {
 	http.ServeContent(w, r, f.DisplayPath(), time.Now(), reader)
 	return
 }
+
+func apiAddTorrentFile(w http.ResponseWriter, r *http.Request) {
+	/* Gets file from form */
+	torrfile, _, err := r.FormFile("torrent")
+	if err != nil {
+		errorRes(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+	defer torrfile.Close()
+
+	/* Loads torrent file to the BitTorrent client */
+	/* Loads the torrent file as a MetaInfo */
+	mi, mierr := metainfo.Load(torrfile)
+	if mierr != nil {
+		errorRes(w, mierr.Error(), http.StatusInternalServerError)
+		return
+	}
+	/* Makes torrent spec from given MetaInfo */
+	spec, specerr := torrent.TorrentSpecFromMetaInfoErr(mi)
+	if specerr != nil {
+		errorRes(w, specerr.Error(), http.StatusInternalServerError)
+		return
+	}
+	/* Adds torrent spec to the BitTorrent client */
+	t, terr := btEngine.addTorrent(spec, false)
+	if terr != nil {
+		errorRes(w, terr.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	/* Create response */
+	res := createAddTorrentRes(t)
+	encodeRes(w, &res)
+	return
+}

functions.go

@@ -111,3 +111,22 @@ func newBtCliConfs(dir string, noup bool) *torrent.ClientConfig {
 func safenDisplayPath(displaypath string) string {
 	return strings.Join(strings.Split(displaypath, "/"), " - ")
 }
+
+// Create response for apiAddTorrent and apiAddTorrentFile
+func createAddTorrentRes(t *torrent.Torrent) apiAddTorrentRes {
+	res := apiAddTorrentRes{
+		Name:          t.Name(),
+		InfoHash:      t.InfoHash().String(),
+		TotalPeers:    t.Stats().TotalPeers,
+		ActivePeers:   t.Stats().ActivePeers,
+		PendingPeers:  t.Stats().PendingPeers,
+		HalfOpenPeers: t.Stats().HalfOpenPeers,
+	}
+	for _, f := range t.Files() {
+		res.Files = append(res.Files, apiTorrentFiles{
+			FileName:      f.DisplayPath(),
+			FileSizeBytes: int(f.Length()),
+		})
+	}
+	return res
+}

torrenttp.go

@@ -33,6 +33,7 @@ func main() {
 	/* POST */
 	r.HandleFunc("/api/addtorrent", apiAddTorrent).Methods("POST")
 	r.HandleFunc("/api/selectfile", apiTorrentSelectFile).Methods("POST")
+	r.HandleFunc("/api/addtorrentfile", apiAddTorrentFile).Methods("POST")
 
 	/* DELETE */
 	r.HandleFunc("/api/removetorrent", apiRemoveTorrent).Methods("DELETE")