refs #6 Handle receving DM

src-tauri/src/streaming.rs

@@ -36,6 +36,12 @@ pub struct DeleteTimelineStatusPayload {
  status_id: String,
 }
 
+#[derive(Clone, Serialize)]
+pub struct ReceiveTimelineConversationPayload {
+ timeline_id: i64,
+ conversation: megalodon::entities::Conversation,
+}
+
 pub async fn start_user(
  app_handle: Arc<AppHandle>,
  server: &entities::Server,
@@ -136,6 +142,9 @@ pub async fn start(
  entities::timeline::Kind::Local => {
  streaming = client.local_streaming(streaming_url);
  }
+ entities::timeline::Kind::Direct => {
+ streaming = client.direct_streaming(streaming_url);
+ }
  entities::timeline::Kind::List => match &timeline.list_id {
  None => return Err(format!("could not find list_id for {} ", timeline.name)),
  Some(list_id) => {
@@ -187,6 +196,18 @@ pub async fn start(
  )
  .expect("Failed to delete-timeline-status event");
  }
+ Message::Conversation(conversation) => {
+ log::debug!("receive conversation");
+ app_handle
+ .emit_all(
+ "receive-timeline-conversation",
+ ReceiveTimelineConversationPayload {
+ timeline_id,
+ conversation,
+ },
+ )
+ .expect("Failed to receive-timeline-conversation event");
+ }
  _ => {}
  }));
  s.await;

src/components/timelines/Conversations.tsx

@@ -14,6 +14,8 @@ import { TIMELINE_STATUSES_COUNT } from 'src/defaults'
 import alert from '../utils/alert'
 import { Virtuoso } from 'react-virtuoso'
 import Conversation from './conversation/Conversation'
+import { listen } from '@tauri-apps/api/event'
+import { ReceiveTimelineConversationPayload } from 'src/payload'
 
 type Props = {
  server: Server
@@ -53,6 +55,25 @@ const Conversations: React.FC<Props> = props => {
  }
  }
  f()
+
+ listen<ReceiveTimelineConversationPayload>('receive-timeline-conversation', ev => {
+ if (ev.payload.timeline_id !== props.timeline.id) {
+ return
+ }
+ setConversations(current => {
+ const find = current.find(conv => conv.id === ev.payload.conversation.id)
+ if (find) {
+ return current.map(conv => {
+ if (conv.id === ev.payload.conversation.id) {
+ return ev.payload.conversation
+ }
+ return conv
+ })
+ } else {
+ return [ev.payload.conversation, ...current]
+ }
+ })
+ })
  }, [])
 
  const loadConversations = async (client: MegalodonInterface, maxId?: string): Promise<Array<Entity.Conversation>> => {

src/payload.ts

@@ -24,3 +24,8 @@ export type DeleteTimelineStatusPayload = {
  timeline_id: number
  status_id: string
 }
+
+export type ReceiveTimelineConversationPayload = {
+ timeline_id: number
+ conversation: Entity.Conversation
+}