diff --git a/app/slackbridge/server/slackbridge_import.server.js b/app/slackbridge/server/slackbridge_import.server.js index 978af4f89f33..27f4c07331bc 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, {