aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorTrygve Aaberge <trygveaa@gmail.com>2020-04-22 17:11:07 +0200
committerTrygve Aaberge <trygveaa@gmail.com>2020-05-30 21:13:20 +0200
commitd17f96a49997295904365dd52344b29609af3c93 (patch)
tree5487e16251ef5e2ebe23db770c8e94b413640b10
parentbf912d25ce36f1a368273e7d602e98d4daffc993 (diff)
downloadwee-slack-d17f96a49997295904365dd52344b29609af3c93.tar.gz
Support slow_queue in SlackThreadChannel.get_history
-rw-r--r--wee_slack.py7
1 files changed, 5 insertions, 2 deletions
diff --git a/wee_slack.py b/wee_slack.py
index e617c3c..fa1afac 100644
--- a/wee_slack.py
+++ b/wee_slack.py
@@ -2331,7 +2331,7 @@ class SlackThreadChannel(SlackChannelCommon):
if backlog or self_msg:
self.mark_read(ts, update_remote=False, force=True)
- def get_history(self, full=False, no_log=False):
+ def get_history(self, slow_queue=False, full=False, no_log=False):
self.got_history = True
self.history_needs_update = False
self.reprint_messages(history_message=True, no_log=no_log)
@@ -2342,7 +2342,10 @@ class SlackThreadChannel(SlackChannelCommon):
s = SlackRequest(self.team, "conversations.replies",
post_data, channel=self.parent_channel,
metadata={"thread_channel": self, "no_log": no_log})
- self.eventrouter.receive(s)
+ if slow_queue:
+ self.eventrouter.receive_slow(s)
+ else:
+ self.eventrouter.receive(s)
def main_message_keys_reversed(self):
return reversed(self.messages)