Merge pull request #44 from ckcr4lyf/patch/get-post

GET -> POST

__tests__/qbittorrent/api.test.ts

@@ -38,4 +38,30 @@ test('getTorrentsWithParam', async t => {
     const got = await api.getTorrents(['a', 'b']);
 
     t.deepEqual(data, got);
+})
+
+test('resumeTorrents', async t => {
+    const api = new QbittorrentApi('http://qbit:8080', 'cookie');
+
+    const scope = nock('http://qbit:8080', {
+        reqheaders: {
+            'Cookie': 'cookie'
+        }
+    });
+
+    scope.post('/api/v2/torrents/resume', 'hashes=a|b').reply(200);
+
+    await api.resumeTorrents([
+        {
+            hash: 'a',
+        },
+        {
+            hash: 'b',
+        }
+    ]);
+
+    // Make sure the scope was successfully called
+    t.notThrows(() => {
+        scope.done();
+    });
 })

package.json

@@ -1,6 +1,6 @@
 {
   "name": "qbit-race",
-  "version": "2.0.0-alpha.12",
+  "version": "2.0.0-alpha.13",
   "description": "Qbit utilities for racing",
   "main": "./bin/index.js",
   "type": "module",

src/qbittorrent/api.ts

@@ -98,17 +98,19 @@ export class QbittorrentApi {
         })
     }
 
-    async resumeTorrents(torrents: QbittorrentTorrent[]){
+    async resumeTorrents(torrents: ApiCompatibleTorrent[]){
+        const infohashes = torrents.map(torrent => torrent.hash);
+        const payload = `hashes=${infohashes.join('|')}`;
+
         try {
-            await this.client.get(ApiEndpoints.resumeTorrents, {
-                params: {
-                    hashes: torrents.map(torrent => torrent.hash).join('|'),
+            await this.client.post(ApiEndpoints.resumeTorrents, payload, {
+                headers: {
+                    'Content-Type': 'application/x-www-form-urlencoded',
                 }
             });
         } catch (e){
             throw new Error(`Failed to resume torrents. Error: ${e}`);
         }
-
     }
 
     async pauseTorrents(torrents: QbittorrentTorrent[]){

src/racing/completed.ts

@@ -49,6 +49,8 @@ export const postRaceResumeV2 = async (api: QbittorrentApi, settings: Settings,
         } catch (e){
             logger.error(`Failed to send message to discord ${e}`);
         }
+    } else {
+        logger.debug(`Discord notifications disabled.`)
     }
 
     // The earliest time, from which there may still be a torrent in the reannounce phase
@@ -79,6 +81,7 @@ export const postRaceResumeV2 = async (api: QbittorrentApi, settings: Settings,
     // Try and resume
     try {
         await api.resumeTorrents(pausedTorrents);
+        logger.debug(`Successfully resumed torrents`);
     } catch (e){
         logger.error(`Failed to resume torrents! ${e}`);
         process.exit(1);