1mod collab_titlebar_item;
2mod contact_finder;
3mod contact_list;
4mod contact_notification;
5mod contacts_popover;
6mod incoming_call_notification;
7mod notifications;
8mod project_shared_notification;
9
10use anyhow::anyhow;
11use call::ActiveCall;
12pub use collab_titlebar_item::{CollabTitlebarItem, ToggleCollaborationMenu};
13use gpui::MutableAppContext;
14use std::sync::Arc;
15use workspace::{AppState, JoinProject, ToggleFollow, Workspace};
16
17pub fn init(app_state: Arc<AppState>, cx: &mut MutableAppContext) {
18 collab_titlebar_item::init(cx);
19 contact_notification::init(cx);
20 contact_list::init(cx);
21 contact_finder::init(cx);
22 contacts_popover::init(cx);
23 incoming_call_notification::init(cx);
24 project_shared_notification::init(cx);
25
26 cx.add_global_action(move |action: &JoinProject, cx| {
27 let project_id = action.project_id;
28 let follow_user_id = action.follow_user_id;
29 let app_state = app_state.clone();
30 cx.spawn(|mut cx| async move {
31 let existing_workspace = cx.update(|cx| {
32 cx.window_ids()
33 .filter_map(|window_id| cx.root_view::<Workspace>(window_id))
34 .find(|workspace| {
35 workspace.read(cx).project().read(cx).remote_id() == Some(project_id)
36 })
37 });
38
39 let workspace = if let Some(existing_workspace) = existing_workspace {
40 existing_workspace
41 } else {
42 let active_call = cx.read(ActiveCall::global);
43 let room = active_call
44 .read_with(&cx, |call, _| call.room().cloned())
45 .ok_or_else(|| anyhow!("not in a call"))?;
46 let project = room
47 .update(&mut cx, |room, cx| {
48 room.join_project(
49 project_id,
50 app_state.languages.clone(),
51 app_state.fs.clone(),
52 cx,
53 )
54 })
55 .await?;
56
57 let (_, workspace) = cx.add_window((app_state.build_window_options)(), |cx| {
58 let mut workspace = Workspace::new(
59 Default::default(),
60 0,
61 project,
62 app_state.dock_default_item_factory,
63 cx,
64 );
65 (app_state.initialize_workspace)(&mut workspace, &app_state, cx);
66 workspace
67 });
68 workspace
69 };
70
71 cx.activate_window(workspace.window_id());
72 cx.platform().activate(true);
73
74 workspace.update(&mut cx, |workspace, cx| {
75 if let Some(room) = ActiveCall::global(cx).read(cx).room().cloned() {
76 let follow_peer_id = room
77 .read(cx)
78 .remote_participants()
79 .iter()
80 .find(|(_, participant)| participant.user.id == follow_user_id)
81 .map(|(_, p)| p.peer_id)
82 .or_else(|| {
83 // If we couldn't follow the given user, follow the host instead.
84 let collaborator = workspace
85 .project()
86 .read(cx)
87 .collaborators()
88 .values()
89 .find(|collaborator| collaborator.replica_id == 0)?;
90 Some(collaborator.peer_id)
91 });
92
93 if let Some(follow_peer_id) = follow_peer_id {
94 if !workspace.is_following(follow_peer_id) {
95 workspace
96 .toggle_follow(&ToggleFollow(follow_peer_id), cx)
97 .map(|follow| follow.detach_and_log_err(cx));
98 }
99 }
100 }
101 });
102
103 anyhow::Ok(())
104 })
105 .detach_and_log_err(cx);
106 });
107}