github-mirror/discourse
2
0
Fork 0
mirror of https://github.com/discourse/discourse.git synced 2024-11-30 02:23:44 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

DEV: Use await when sending chat messages (#21915)

Browse Source 
This is a follow-up to d086888, I forgot to update these places in that commit.
This commit is contained in:
Andrei Prigorshnev 2023-06-06 13:58:15 +04:00 committed by GitHub
parent 8c4cbd748d
commit b7a66bd6ad
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 20 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
plugins/chat/assets/javascripts/discourse/components/chat-channel.js
View File

@ -724,28 +724,24 @@ export default class ChatLivePane extends Component {
this.scrollToLatestMessage();
}
return this.chatApi
.sendMessage(this.args.channel.id, {
try {
await this.chatApi.sendMessage(this.args.channel.id, {
message: message.message,
in_reply_to_id: message.inReplyTo?.id,
staged_id: message.id,
upload_ids: message.uploads.map((upload) => upload.id),
})
.then(() => {
this.scrollToLatestMessage();
})
.catch((error) => {
this._onSendError(message.id, error);
this.scrollToBottom();
})
.finally(() => {
if (this._selfDeleted) {
return;
}
});
this.scrollToLatestMessage();
} catch (error) {
this._onSendError(message.id, error);
this.scrollToBottom();
} finally {
if (!this._selfDeleted) {
this.chatDraftsManager.remove({ channelId: this.args.channel.id });
this.chatChannelPane.sending = false;
});
}
}
}
async _upsertChannelWithMessage(channel, data) {

20
plugins/chat/assets/javascripts/discourse/components/chat-thread.js
View File

@ -250,8 +250,8 @@ export default class ChatThreadPanel extends Component {
this.scrollToBottom();
return this.chatApi
.sendMessage(this.channel.id, {
try {
await this.chatApi.sendMessage(this.channel.id, {
message: message.message,
in_reply_to_id: message.thread.staged
? message.thread.originalMessage.id
@ -260,16 +260,14 @@ export default class ChatThreadPanel extends Component {
upload_ids: message.uploads.map((upload) => upload.id),
thread_id: message.thread.staged ? null : message.thread.id,
staged_thread_id: message.thread.staged ? message.thread.id : null,
})
.catch((error) => {
this.#onSendError(message.id, error);
})
.finally(() => {
if (this._selfDeleted) {
return;
}
this.chatChannelThreadPane.sending = false;
});
} catch (error) {
this.#onSendError(message.id, error);
} finally {
if (!this._selfDeleted) {
this.chatChannelThreadPane.sending = false;
}
}
}
async #sendEditMessage(message) {