From 17bb8d11d16a0e665acf7bbb00eb200355ead8f3 Mon Sep 17 00:00:00 2001 From: Diego Sampaio Date: Thu, 5 Mar 2020 15:49:29 -0300 Subject: [PATCH] [FIX] Slackbridge-import command doesn't work (#16645) Closes #16338 --- .../server/slackbridge_import.server.js | 50 ++++++++++--------- 1 file changed, 26 insertions(+), 24 deletions(-) diff --git a/app/slackbridge/server/slackbridge_import.server.js b/app/slackbridge/server/slackbridge_import.server.js index 978af4f89f3..27f4c07331b 100644 --- a/app/slackbridge/server/slackbridge_import.server.js +++ b/app/slackbridge/server/slackbridge_import.server.js @@ -29,30 +29,32 @@ function SlackBridgeImport(command, params, item) { }); try { - SlackBridge.slack.importMessages(item.rid, (error) => { - if (error) { - msgStream.emit(item.rid, { - _id: Random.id(), - rid: item.rid, - u: { username: 'rocket.cat' }, - ts: new Date(), - msg: TAPi18n.__('SlackBridge_error', { - postProcess: 'sprintf', - sprintf: [channel, error.message], - }, user.language), - }); - } else { - msgStream.emit(item.rid, { - _id: Random.id(), - rid: item.rid, - u: { username: 'rocket.cat' }, - ts: new Date(), - msg: TAPi18n.__('SlackBridge_finish', { - postProcess: 'sprintf', - sprintf: [channel], - }, user.language), - }); - } + SlackBridge.slackAdapters.forEach((slack) => { + slack.importMessages(item.rid, (error) => { + if (error) { + msgStream.emit(item.rid, { + _id: Random.id(), + rid: item.rid, + u: { username: 'rocket.cat' }, + ts: new Date(), + msg: TAPi18n.__('SlackBridge_error', { + postProcess: 'sprintf', + sprintf: [channel, error.message], + }, user.language), + }); + } else { + msgStream.emit(item.rid, { + _id: Random.id(), + rid: item.rid, + u: { username: 'rocket.cat' }, + ts: new Date(), + msg: TAPi18n.__('SlackBridge_finish', { + postProcess: 'sprintf', + sprintf: [channel], + }, user.language), + }); + } + }); }); } catch (error) { msgStream.emit(item.rid, {