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