next_swc_napi/next_api/
analyze.rs

1use std::{iter::once, sync::Arc};
2
3use anyhow::Result;
4use next_api::{
5    analyze::{AnalyzeDataOutputAsset, ModulesDataOutputAsset},
6    project::ProjectContainer,
7};
8use turbo_tasks::{Effects, ReadRef, ResolvedVc, TryJoinIterExt, Vc};
9use turbopack_core::{diagnostics::PlainDiagnostic, issue::PlainIssue, output::OutputAssets};
10
11use crate::next_api::utils::strongly_consistent_catch_collectables;
12
13#[turbo_tasks::value(serialization = "none")]
14pub struct WriteAnalyzeResult {
15    pub issues: Arc<Vec<ReadRef<PlainIssue>>>,
16    pub diagnostics: Arc<Vec<ReadRef<PlainDiagnostic>>>,
17    pub effects: Arc<Effects>,
18}
19
20#[turbo_tasks::function(operation)]
21pub async fn write_analyze_data_with_issues_operation(
22    project: ResolvedVc<ProjectContainer>,
23    app_dir_only: bool,
24) -> Result<Vc<WriteAnalyzeResult>> {
25    let analyze_data_op = write_analyze_data_with_issues_operation_inner(project, app_dir_only);
26
27    let (_analyze_data, issues, diagnostics, effects) =
28        strongly_consistent_catch_collectables(analyze_data_op).await?;
29
30    Ok(WriteAnalyzeResult {
31        issues,
32        diagnostics,
33        effects,
34    }
35    .cell())
36}
37
38#[turbo_tasks::function(operation)]
39async fn write_analyze_data_with_issues_operation_inner(
40    project: ResolvedVc<ProjectContainer>,
41    app_dir_only: bool,
42) -> Result<()> {
43    let analyze_data_op = get_analyze_data_operation(project, app_dir_only);
44
45    project
46        .project()
47        .emit_all_output_assets(analyze_data_op)
48        .as_side_effect()
49        .await?;
50
51    Ok(())
52}
53
54#[turbo_tasks::function(operation)]
55async fn get_analyze_data_operation(
56    container: ResolvedVc<ProjectContainer>,
57    app_dir_only: bool,
58) -> Result<Vc<OutputAssets>> {
59    let project = container.project();
60    let project =
61        project.with_next_config(project.next_config().with_production_browser_source_maps());
62
63    let analyze_output_root = project
64        .node_root()
65        .owned()
66        .await?
67        .join("diagnostics/analyze/data")?;
68    let whole_app_module_graphs = project.whole_app_module_graphs();
69    let analyze_output_root = &analyze_output_root;
70    let analyze_data = project
71        .get_all_endpoint_groups(app_dir_only)
72        .await?
73        .iter()
74        .map(|(key, endpoint_group)| async move {
75            let output_assets = endpoint_group.output_assets();
76            let analyze_data = AnalyzeDataOutputAsset::new(
77                analyze_output_root
78                    .join(&key.to_string())?
79                    .join("analyze.data")?,
80                output_assets,
81            )
82            .to_resolved()
83            .await?;
84
85            Ok(ResolvedVc::upcast(analyze_data))
86        })
87        .try_join()
88        .await?;
89
90    whole_app_module_graphs.as_side_effect().await?;
91
92    let modules_data = ResolvedVc::upcast(
93        ModulesDataOutputAsset::new(
94            analyze_output_root.join("modules.data")?,
95            Vc::cell(vec![whole_app_module_graphs.await?.full]),
96        )
97        .to_resolved()
98        .await?,
99    );
100
101    Ok(Vc::cell(
102        analyze_data
103            .iter()
104            .cloned()
105            .chain(once(modules_data))
106            .collect(),
107    ))
108}
next_swc_napi/next_api/analyze.rs

next_swc_napi/next_api/
analyze.rs
