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