Compare View
Commits (2)
Changes
Showing 2 changed files Side-by-side Diff
gateway/pull.js
| ... | ... | @@ -121,18 +121,22 @@ function pullTask() { |
| 121 | 121 | } |
| 122 | 122 | |
| 123 | 123 | function putTaskToMatrix(task) { |
| 124 | - if (matrix.sdk_unresponsed_tasks.indexOf(task.trx_id) < 0) { | |
| 125 | - matrix.sdk_unresponsed_tasks.push(task.trx_id); | |
| 124 | + const trx_id = Number(task.trx_id); | |
| 125 | + | |
| 126 | + if (matrix.sdk_unresponsed_tasks.indexOf(trx_id) < 0) { | |
| 127 | + matrix.sdk_unresponsed_tasks.push(trx_id); | |
| 126 | 128 | matrix.sdk_unresponsed_tasks_count = matrix.sdk_unresponsed_tasks.length; |
| 127 | 129 | } |
| 128 | 130 | |
| 129 | - if (matrix.sdk_pending_tasks.indexOf(task.trx_id) < 0) { | |
| 130 | - matrix.sdk_pending_tasks.push(task.trx_id); | |
| 131 | + if (matrix.sdk_pending_tasks.indexOf(trx_id) < 0) { | |
| 132 | + matrix.sdk_pending_tasks.push(trx_id); | |
| 131 | 133 | matrix.sdk_pending_tasks_count = matrix.sdk_pending_tasks.length; |
| 132 | 134 | } |
| 133 | 135 | } |
| 134 | 136 | |
| 135 | 137 | function updateTaskOnMatrix(trx_id, rc) { |
| 138 | + trx_id = Number(trx_id); | |
| 139 | + | |
| 136 | 140 | const unresponsed_task_idx = matrix.sdk_unresponsed_tasks.indexOf(trx_id); |
| 137 | 141 | if (unresponsed_task_idx >= 0) { |
| 138 | 142 | matrix.sdk_unresponsed_tasks.splice(unresponsed_task_idx, 1); |