Compare View
Commits (2)
Changes
Showing 2 changed files Side-by-side Diff
gateway/pull.js
... | ... | @@ -117,19 +117,27 @@ function updateTaskOnMatrix(trx_id, rc) { |
117 | 117 | matrix.sdk_unresponsed_tasks.splice(unresponsed_task_idx, 1); |
118 | 118 | } |
119 | 119 | |
120 | - if (rc === '68') { | |
120 | + if (rc == '68') { | |
121 | + const pending_task_idx = matrix.sdk_pending_tasks.indexOf(trx_id); | |
122 | + if (pending_task_idx < 0) { | |
123 | + matrix.sdk_pending_tasks.push(trx_id); | |
124 | + } | |
121 | 125 | |
122 | 126 | const pending_with_response_tasks_idx = matrix.sdk_pending_with_response_tasks.indexOf(trx_id); |
123 | 127 | if (pending_with_response_tasks_idx >= 0) { |
124 | - matrix.sdk_pending_with_response_tasks.splice(pending_with_response_tasks_idx, 1); | |
128 | + matrix.sdk_pending_with_response_tasks.push(trx_id); | |
125 | 129 | } |
126 | - | |
127 | - return; | |
128 | 130 | } |
131 | + else { | |
132 | + const pending_task_idx = matrix.sdk_pending_tasks.indexOf(trx_id); | |
133 | + if (pending_task_idx >= 0) { | |
134 | + matrix.sdk_pending_tasks.splice(pending_task_idx, 1); | |
135 | + } | |
129 | 136 | |
130 | - const pending_task_idx = matrix.sdk_pending_tasks.indexOf(trx_id); | |
131 | - if (pending_task_idx >= 0) { | |
132 | - matrix.sdk_pending_tasks.splice(pending_task_idx, 1); | |
137 | + const pending_with_response_tasks_idx = matrix.sdk_pending_with_response_tasks.indexOf(trx_id); | |
138 | + if (pending_with_response_tasks_idx >= 0) { | |
139 | + matrix.sdk_pending_with_response_tasks.splice(pending_with_response_tasks_idx, 1); | |
140 | + } | |
133 | 141 | } |
134 | 142 | } |
135 | 143 |