diff options
author | Chocobozzz <florian.bigard@gmail.com> | 2017-07-07 16:57:28 +0200 |
---|---|---|
committer | Chocobozzz <florian.bigard@gmail.com> | 2017-07-07 18:23:18 +0200 |
commit | 709756b8e183f67ef9bf8f7bc149af4736260350 (patch) | |
tree | dc5e52878a6f56c69a4589e058e830c57b025a05 /server/lib/request/request-scheduler.ts | |
parent | 18c8e945089bff49d2c617c411c8a8f4575989ad (diff) | |
download | PeerTube-709756b8e183f67ef9bf8f7bc149af4736260350.tar.gz PeerTube-709756b8e183f67ef9bf8f7bc149af4736260350.tar.zst PeerTube-709756b8e183f67ef9bf8f7bc149af4736260350.zip |
Async signature and various fixes
Diffstat (limited to 'server/lib/request/request-scheduler.ts')
-rw-r--r-- | server/lib/request/request-scheduler.ts | 9 |
1 files changed, 1 insertions, 8 deletions
diff --git a/server/lib/request/request-scheduler.ts b/server/lib/request/request-scheduler.ts index 0dd796fb0..8927d53bb 100644 --- a/server/lib/request/request-scheduler.ts +++ b/server/lib/request/request-scheduler.ts | |||
@@ -61,16 +61,9 @@ class RequestScheduler extends AbstractRequestScheduler<RequestsGrouped> { | |||
61 | } | 61 | } |
62 | 62 | ||
63 | createRequest ({ type, endpoint, data, toIds, transaction }: RequestSchedulerOptions) { | 63 | createRequest ({ type, endpoint, data, toIds, transaction }: RequestSchedulerOptions) { |
64 | // TODO: check the setPods works | ||
65 | const podIds = [] | ||
66 | |||
67 | // If there are no destination pods abort | 64 | // If there are no destination pods abort |
68 | if (toIds.length === 0) return undefined | 65 | if (toIds.length === 0) return undefined |
69 | 66 | ||
70 | toIds.forEach(toPod => { | ||
71 | podIds.push(toPod) | ||
72 | }) | ||
73 | |||
74 | const createQuery = { | 67 | const createQuery = { |
75 | endpoint, | 68 | endpoint, |
76 | request: { | 69 | request: { |
@@ -85,7 +78,7 @@ class RequestScheduler extends AbstractRequestScheduler<RequestsGrouped> { | |||
85 | 78 | ||
86 | return db.Request.create(createQuery, dbRequestOptions) | 79 | return db.Request.create(createQuery, dbRequestOptions) |
87 | .then(request => { | 80 | .then(request => { |
88 | return request.setPods(podIds, dbRequestOptions) | 81 | return request.setPods(toIds, dbRequestOptions) |
89 | }) | 82 | }) |
90 | } | 83 | } |
91 | 84 | ||