zoriya/flood
1
0
Fork 0
mirror of https://github.com/zoriya/flood.git synced 2026-06-04 11:35:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

server: Transmission: properly await tracker removal results

Browse Source
This commit is contained in:
Jesse Chan
2020-11-18 00:55:40 +08:00
parent bc362cc8af
commit 2e124917bb
1 changed files with 12 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/services/Transmission/clientGatewayService.ts
+12 -17
View File
@@ -238,31 +238,26 @@ class TransmissionClientGatewayService extends ClientGatewayService {
}
async setTorrentsTrackers({hashes, trackers}: SetTorrentsTrackersOptions): Promise<void> {
const torrentsProcessed: Array<string> = [];
// Remove existing trackers
await this.clientRequestManager
.getTorrents(hashes, ['trackers'])
.then(this.processClientRequestSuccess, this.processClientRequestError)
.then((torrents) =>
torrents.forEach((torrent, index) => {
const hash = hashes[index];
this.clientRequestManager
.setTorrentsProperties({
ids: hash,
trackerRemove: torrent.trackers.map((tracker) => tracker.id),
})
.then(
() => {
torrentsProcessed.push(hash);
},
() => undefined,
);
}),
Promise.all(
torrents.map(async (torrent, index) => {
await this.clientRequestManager
.setTorrentsProperties({
ids: hashes[index],
trackerRemove: torrent.trackers.map((tracker) => tracker.id),
})
.then(this.processClientRequestSuccess, this.processClientRequestError)
.catch(() => undefined);
}),
),
);
return this.clientRequestManager
.setTorrentsProperties({ids: torrentsProcessed, trackerAdd: trackers})
.setTorrentsProperties({ids: hashes, trackerAdd: trackers})
.then(this.processClientRequestSuccess, this.processClientRequestError);
}