IntenseWebs/mattermost
3
0
Fork 0
mirror of https://github.com/mattermost/mattermost.git synced 2025-02-25 18:55:24 -06:00
Code Issues Packages Projects Releases Wiki Activity

PLT-4431 Add post queuing to the webapp (#4800)

Browse Source 
* Add post queuing to the webapp

* Add more abstraction
This commit is contained in:
Joram Wilander
2016-12-21 16:41:05 -05:00
committed by Christopher Speller
parent ba6e370ca7
commit 25d40bc98c
5 changed files with 56 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
webapp/actions/post_actions.jsx
View File

@@ -280,6 +280,55 @@ export function removeReaction(channelId, postId, emojiName) {
AsyncClient.deleteReaction(channelId, reaction);
}
const postQueue = [];
export function queuePost(post, doLoadPost, success, error) {
postQueue.push(
createPost.bind(
this,
post,
doLoadPost,
(data) => {
if (success) {
success(data);
}
postSendComplete();
},
(err) => {
if (error) {
error(err);
}
postSendComplete();
}
)
);
sendFirstPostInQueue();
}
// Remove the completed post from the queue and send the next one
function postSendComplete() {
postQueue.shift();
sendNextPostInQueue();
}
// Start sending posts if a new queue has started
function sendFirstPostInQueue() {
if (postQueue.length === 1) {
sendNextPostInQueue();
}
}
// Send the next post in the queue if there is one
function sendNextPostInQueue() {
const nextPostAction = postQueue[0];
if (nextPostAction) {
nextPostAction();
}
}
export function createPost(post, doLoadPost, success, error) {
Client.createPost(post,
(data) => {

5
webapp/components/create_comment.jsx
View File

@@ -196,10 +196,7 @@ export default class CreateComment extends React.Component {
GlobalActions.emitUserCommentedEvent(post);
PostActions.createPost(post, false,
() => {
// DO nothing.
},
PostActions.queuePost(post, false, null,
(err) => {
if (err.id === 'api.post.create_post.root_id.app_error') {
this.showPostDeletedModal();

5
webapp/components/create_post.jsx
View File

@@ -161,10 +161,7 @@ export default class CreatePost extends React.Component {
GlobalActions.emitUserPostedEvent(post);
PostActions.createPost(post, false,
() => {
// DO nothing.
},
PostActions.queuePost(post, false, null,
(err) => {
if (err.id === 'api.post.create_post.root_id.app_error') {
// this should never actually happen since you can't reply from this textbox

7
webapp/components/post_view/components/pending_post_options.jsx
View File

@@ -3,7 +3,7 @@
import PostStore from 'stores/post_store.jsx';
import {createPost} from 'actions/post_actions.jsx';
import {queuePost} from 'actions/post_actions.jsx';
import Constants from 'utils/constants.jsx';
@@ -22,10 +22,7 @@ export default class PendingPostOptions extends React.Component {
e.preventDefault();
var post = this.props.post;
createPost(post, true,
() => {
// DO nothing.
},
queuePost(post, true, null,
(err) => {
if (err.id === 'api.post.create_post.root_id.app_error') {
this.showPostDeletedModal();

4
webapp/components/rhs_thread.jsx
View File

@@ -332,10 +332,12 @@ export default class RhsThread extends React.Component {
status = this.state.statuses[p.id] || 'offline';
}
const keyPrefix = comPost.id ? comPost.id : comPost.pending_post_id;
return (
<Comment
ref={comPost.id}
key={comPost.id + 'commentKey'}
key={keyPrefix + 'commentKey'}
post={comPost}
user={p}
currentUser={this.props.currentUser}