System-End/plura
1
0
Fork 0
mirror of https://github.com/System-End/plura.git synced 2026-04-19 19:45:08 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat: allow plura to work in threads

Browse source
This commit is contained in:
Suya1671 2025-06-25 09:50:40 +02:00
parent 25beb1ba0d
commit 63ccc29a88
No known key found for this signature in database
1 changed files with 10 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/events/mod.rs
View file

@ -176,8 +176,7 @@ async fn handle_message(
rewrite_message(
client,
channel_id,
message_event.origin.ts,
message_event.origin,
content,
member,
&system,
@ -200,8 +199,7 @@ async fn handle_message(
rewrite_message(
client,
channel_id,
message_event.origin.ts,
message_event.origin,
content,
member.into(),
&system,
@ -217,13 +215,17 @@ async fn handle_message(
#[tracing::instrument(skip(client, db, system), fields(system_id = %system.id))]
async fn rewrite_message(
client: &SlackHyperClient,
channel_id: &SlackChannelId,
message_id: SlackTs,
origin: SlackMessageOrigin,
mut content: SlackMessageContent,
member: models::DetectedMember,
system: &models::System,
db: &SqlitePool,
) -> error_stack::Result<(), RewriteMessageError> {
let Some(channel_id) = origin.channel else {
debug!("No channel ID found in origin. Bot possibly doesn't have access. Bailing");
return Ok(());
};
let token = SlackApiToken::new(system.slack_oauth_token.expose().into())
.with_token_type(SlackApiTokenType::User);
let user_session = client.open_session(&token);
@ -283,6 +285,7 @@ async fn rewrite_message(
}
let message_request = SlackApiChatPostMessageRequest::new(channel_id.clone(), content)
.opt_thread_ts(origin.thread_ts)
.with_username(member.display_name.clone())
.opt_icon_url(member.profile_picture_url.clone());
@ -313,7 +316,7 @@ async fn rewrite_message(
user_session
.chat_delete(
&SlackApiChatDeleteRequest::new(channel_id.clone(), message_id).with_as_user(true),
&SlackApiChatDeleteRequest::new(channel_id.clone(), origin.ts).with_as_user(true),
)
.await
.change_context(RewriteMessageError::DeleteMessage)?;