linear-tui 0.13.0

//! Turning a [`Request`] into the API calls it stands for.
//!
//! This runs on the tokio runtime, off the UI thread; the main loop spawns one
//! task per request and sends the resulting [`Message`] back over a channel.

use anyhow::Result;

use crate::core::entity::Handoff;
use crate::core::entity::Page;
use crate::core::message::Message;
use crate::core::usecase::{
    Request, agent, cycle, favorite, issue, notes, project, team, user, view,
};
use crate::infra::linear::client::LinearClient;

/// Run one request against the API and turn the outcome into a [`Message`].
///
/// A failure comes back as [`Message::Failed`] carrying the request, so the app
/// can undo exactly what that request stood for.
pub async fn execute_request(client: &LinearClient, req: Request, per_page: u32) -> Message {
    match run_request(client, &req, per_page).await {
        Ok(msg) => msg,
        Err(e) => Message::Failed {
            request: Box::new(req),
            error: e.to_string(),
        },
    }
}

async fn run_request(client: &LinearClient, req: &Request, per_page: u32) -> Result<Message> {
    let append = req.cursor().is_some();
    match req {
        Request::Issue(req) => issue(client, req, per_page, append).await,
        Request::Project(req) => project(client, req, append).await,
        Request::Cycle(cycle::Request::TeamCycles { team_id, after }) => {
            let (cycles, info) = client.cycles(team_id, after.as_deref()).await?;
            Ok(Message::Cycles {
                team_id: team_id.clone(),
                page: Page::new(cycles, info, append),
            })
        }
        Request::Team(team::Request::Teams) => Ok(Message::Teams(client.teams().await?)),
        Request::Team(team::Request::Labels { team_id }) => Ok(Message::Labels {
            team_id: team_id.clone(),
            labels: client.labels(team_id).await?,
        }),
        Request::Team(team::Request::Context { team_id }) => {
            // Independent queries — fetch them concurrently.
            let (states, members) = tokio::join!(
                client.workflow_states(team_id),
                client.team_members(team_id)
            );
            Ok(Message::TeamContext {
                team_id: team_id.clone(),
                states: states?,
                members: members?,
            })
        }
        Request::View(view::Request::Views) => {
            Ok(Message::CustomViews(client.custom_views().await?))
        }
        Request::Favorite(favorite::Request::Favorites) => {
            Ok(Message::Favorites(client.favorites().await?))
        }
        Request::Favorite(favorite::Request::OpenInBrowser(url)) => open_in_browser(url),
        Request::User(user::Request::Viewer) => {
            let viewer = client.viewer().await?;
            Ok(Message::Viewer {
                id: viewer.id,
                organization: viewer.organization,
            })
        }
        Request::Notes(notes::Request::Deliver(handoff)) => {
            crate::infra::herdr::deliver(handoff).await?;
            Ok(Message::Mutated(handoff.done()))
        }
        Request::Agent(agent::Request::Focus { pane }) => {
            let handoff = Handoff::Focus { pane: pane.clone() };
            crate::infra::herdr::deliver(&handoff).await?;
            Ok(Message::Mutated(handoff.done()))
        }
    }
}

async fn issue(
    client: &LinearClient,
    req: &issue::Request,
    per_page: u32,
    append: bool,
) -> Result<Message> {
    use issue::Request as R;
    Ok(match req {
        R::TeamIssues {
            team_id,
            preset,
            after,
        } => {
            let (issues, info) = client
                .issues(team_id, preset.state_filter(), after.as_deref(), per_page)
                .await?;
            Message::Issues {
                team_id: team_id.clone(),
                preset: *preset,
                page: Page::new(issues, info, append),
            }
        }
        R::MyIssues { user_id, after } => {
            let (issues, info) = client
                .my_issues(user_id, after.as_deref(), per_page)
                .await?;
            Message::MyIssues(Page::new(issues, info, append))
        }
        R::ViewIssues { view_id, after } => {
            let (issues, info) = client
                .custom_view_issues(view_id, after.as_deref(), per_page)
                .await?;
            Message::ViewIssues {
                view_id: view_id.clone(),
                page: Page::new(issues, info, append),
            }
        }
        R::ProjectIssues { project_id, after } => {
            let (issues, info) = client.project_issues(project_id, after.as_deref()).await?;
            Message::ProjectIssues {
                project_id: project_id.clone(),
                page: Page::new(issues, info, append),
            }
        }
        R::CycleIssues { cycle_id, after } => {
            let (issues, info) = client.cycle_issues(cycle_id, after.as_deref()).await?;
            Message::CycleIssues {
                cycle_id: cycle_id.clone(),
                page: Page::new(issues, info, append),
            }
        }
        R::Detail { issue_id } => {
            Message::IssueDetail(Box::new(client.issue_detail(issue_id).await?))
        }
        R::Search { term, team_id } => {
            let (issues, _) = client
                .search_issues(term, team_id.as_ref(), per_page)
                .await?;
            Message::SearchResults {
                term: term.clone(),
                team_id: team_id.clone(),
                issues,
            }
        }
        R::QuickSearch { term, seq } => {
            let (issues, _) = client.search_issues(term, None, per_page).await?;
            Message::PaletteResults { seq: *seq, issues }
        }
        R::SetStatus { issue_id, state_id } => {
            client.update_issue_state(issue_id, state_id).await?;
            Message::Mutated("Status updated")
        }
        R::SetPriority { issue_id, priority } => {
            client.update_issue_priority(issue_id, *priority).await?;
            Message::Mutated("Priority updated")
        }
        R::SetAssignee {
            issue_id,
            assignee_id,
        } => {
            client
                .update_issue_assignee(issue_id, assignee_id.as_ref())
                .await?;
            Message::Mutated("Assignee updated")
        }
        R::Update { issue_id, changes } => {
            client.edit_issue(issue_id, changes).await?;
            Message::Mutated("Issue updated")
        }
        R::Comment {
            issue_id,
            body,
            parent_id,
        } => {
            let comment = client
                .create_comment(issue_id, body, parent_id.as_ref())
                .await?;
            Message::CommentPosted {
                issue_id: issue_id.clone(),
                comment: Box::new(comment),
            }
        }
        R::EditComment {
            comment_id, body, ..
        } => {
            client.update_comment(comment_id, body).await?;
            Message::Mutated("Comment edited")
        }
        R::DeleteComment { comment_id, .. } => {
            client.delete_comment(comment_id).await?;
            Message::Mutated("Comment deleted")
        }
        R::Create { team_id, draft } => {
            let issue = client.create_issue(team_id, draft).await?;
            Message::IssueCreated {
                team_id: team_id.clone(),
                issue: Box::new(issue),
            }
        }
        R::OpenInBrowser(url) => open_in_browser(url)?,
    })
}

async fn project(client: &LinearClient, req: &project::Request, append: bool) -> Result<Message> {
    use project::Request as R;
    Ok(match req {
        R::TeamProjects { team_id, after } => {
            let (projects, info) = client.projects(team_id, after.as_deref()).await?;
            Message::Projects {
                team_id: team_id.clone(),
                page: Page::new(projects, info, append),
            }
        }
        R::ViewProjects { view_id, after } => {
            let (projects, info) = client
                .custom_view_projects(view_id, after.as_deref())
                .await?;
            Message::ViewProjects {
                view_id: view_id.clone(),
                page: Page::new(projects, info, append),
            }
        }
        R::OpenInBrowser(url) => open_in_browser(url)?,
        R::Find { name } => Message::ProjectsFound {
            name: name.clone(),
            projects: client.find_projects(name).await?,
        },
        R::Detail { project_id } => {
            Message::ProjectDetail(Box::new(client.project_detail(project_id).await?))
        }
        R::Statuses => Message::ProjectStatuses(client.project_statuses().await?),
        R::Create { draft } => {
            Message::ProjectCreated(Box::new(client.create_project(draft).await?))
        }
        R::Update {
            project_id,
            changes,
        } => {
            client.update_project(project_id, changes).await?;
            Message::Mutated("Project updated")
        }
        R::Delete { project_id } => {
            client.delete_project(project_id).await?;
            Message::Mutated("Project deleted")
        }
        R::CreateMilestone { project_id, draft } => Message::MilestoneCreated {
            project_id: project_id.clone(),
            milestone: Box::new(client.create_milestone(project_id, draft).await?),
        },
        R::UpdateMilestone {
            milestone_id,
            changes,
        } => {
            client.update_milestone(milestone_id, changes).await?;
            Message::Mutated("Milestone updated")
        }
        R::DeleteMilestone { milestone_id } => {
            client.delete_milestone(milestone_id).await?;
            Message::Mutated("Milestone deleted")
        }
    })
}

/// Hand a URL to the desktop's default browser.
fn open_in_browser(url: &str) -> Result<Message> {
    open::that_detached(url)?;
    Ok(Message::Mutated("Opened in browser"))
}

#[cfg(test)]
mod tests {
    use std::sync::Arc;

    use serde_json::json;
    use wiremock::matchers::method;
    use wiremock::{Mock, MockServer, ResponseTemplate};

    use super::*;
    use crate::core::entity::TeamId;
    use crate::infra::linear::client::StaticCredentials;

    fn client(server: &MockServer) -> LinearClient {
        LinearClient::with_endpoint(server.uri(), Arc::new(StaticCredentials("key".into())))
    }

    #[tokio::test]
    async fn a_page_names_the_team_it_was_fetched_for() {
        let server = MockServer::start().await;
        Mock::given(method("POST"))
            .respond_with(
                ResponseTemplate::new(200).set_body_json(json!({ "data": { "team": {
                "cycles": { "nodes": [], "pageInfo": { "hasNextPage": false } }
            } } })),
            )
            .mount(&server)
            .await;

        let request = Request::Cycle(cycle::Request::TeamCycles {
            team_id: TeamId::new("t1"),
            after: Some("c1".into()),
        });
        match execute_request(&client(&server), request, 50).await {
            Message::Cycles { team_id, page } => {
                assert_eq!(team_id, "t1");
                assert!(page.append, "a page after a cursor extends the list");
            }
            other => panic!("unexpected {other:?}"),
        }
    }

    #[tokio::test]
    async fn a_failure_carries_the_request_back() {
        let server = MockServer::start().await;
        Mock::given(method("POST"))
            .respond_with(ResponseTemplate::new(500))
            .mount(&server)
            .await;

        let request = Request::Team(team::Request::Teams);
        match execute_request(&client(&server), request.clone(), 50).await {
            Message::Failed {
                request: failed,
                error,
            } => {
                assert_eq!(*failed, request);
                assert!(error.contains("500"), "{error}");
            }
            other => panic!("unexpected {other:?}"),
        }
    }
}