diff options
Diffstat (limited to 'slack/slack_conversation.py')
| -rw-r--r-- | slack/slack_conversation.py | 25 |
1 files changed, 23 insertions, 2 deletions
diff --git a/slack/slack_conversation.py b/slack/slack_conversation.py index 1da093d..ffea7c6 100644 --- a/slack/slack_conversation.py +++ b/slack/slack_conversation.py @@ -150,6 +150,7 @@ class SlackConversation(SlackBuffer): super().__init__() self._workspace = workspace self._info = info + self._is_joined: bool = False self._members: Optional[List[str]] = None self._im_user: Optional[SlackUser] = None self._mpim_users: Optional[List[SlackUser]] = None @@ -218,6 +219,10 @@ class SlackConversation(SlackBuffer): return "conversation" @property + def is_joined(self) -> bool: + return self._is_joined + + @property def members(self) -> Generator[Nick, None, None]: for nick in self._nicklist: if nick.type == "user": @@ -353,6 +358,7 @@ class SlackConversation(SlackBuffer): async def open_buffer(self, switch: bool = False): await super().open_buffer(switch) + self._is_joined = True self.workspace.open_conversations[self.id] = self async def rerender_message(self, message: SlackMessage): @@ -446,11 +452,15 @@ class SlackConversation(SlackBuffer): weechat.buffer_set(self.buffer_pointer, "hotlist", priority.value) self.hotlist_tss.add(message.latest_reply) - async def fill_history(self): + async def fill_history(self, update: bool = False): if self.history_pending: return - if self.last_printed_ts is not None and not self.history_needs_refresh: + if ( + self.last_printed_ts is not None + and not self.history_needs_refresh + and not update + ): return with self.loading(): @@ -722,10 +732,21 @@ class SlackConversation(SlackBuffer): self.nicklist_add_nick(nick) async def mark_read(self): + if not self._is_joined: + return last_read_line_ts = self.last_read_line_ts() if last_read_line_ts and last_read_line_ts != self.last_read: await self._api.conversations_mark(self, last_read_line_ts) + async def part(self): + self._is_joined = False + await self._api.conversations_leave(self) + if shared.config.look.part_closes_buffer.value: + await self.close_buffer() + else: + # Update history to get the part message + await self.fill_history(update=True) + async def _buffer_close( self, call_buffer_close: bool = False, update_server: bool = False ): |