Skip to main content

provenant/parsers/
dart.rs

1//! Parser for Dart/Flutter pubspec.yaml and pubspec.lock files.
2//!
3//! Extracts package metadata and dependencies from Dart/Flutter project manifest
4//! and lockfiles using YAML format.
5//!
6//! # Supported Formats
7//! - pubspec.yaml (Dart package manifest)
8//! - pubspec.lock (Dart package lockfile with pinned versions)
9//!
10//! # Key Features
11//! - Dependency extraction from dependencies and dev_dependencies sections
12//! - Direct vs transitive dependency tracking (lockfile)
13//! - Version constraint parsing for Dart's SemVer and range specifiers
14//! - Package URL (purl) generation for Pub packages
15//! - Author/maintainer and homepage extraction
16//!
17//! # Implementation Notes
18//! - Uses YAML parsing via `serde_yaml` crate
19//! - Lockfile versions are pinned (`is_pinned: Some(true)`)
20//! - Graceful error handling with `warn!()` logs
21//! - Supports both pub.dev and Git-hosted packages
22
23use std::collections::{HashMap, HashSet, VecDeque};
24use std::fs;
25use std::path::Path;
26
27use log::warn;
28use packageurl::PackageUrl;
29use serde_yaml::{Mapping, Value};
30
31use crate::models::{DatasourceId, Dependency, PackageData, PackageType, ResolvedPackage};
32
33use super::PackageParser;
34
35const FIELD_NAME: &str = "name";
36const FIELD_VERSION: &str = "version";
37const FIELD_DESCRIPTION: &str = "description";
38const FIELD_HOMEPAGE: &str = "homepage";
39const FIELD_LICENSE: &str = "license";
40const FIELD_REPOSITORY: &str = "repository";
41const FIELD_AUTHOR: &str = "author";
42const FIELD_AUTHORS: &str = "authors";
43const FIELD_DEPENDENCIES: &str = "dependencies";
44const FIELD_DEV_DEPENDENCIES: &str = "dev_dependencies";
45const FIELD_DEPENDENCY_OVERRIDES: &str = "dependency_overrides";
46const FIELD_ENVIRONMENT: &str = "environment";
47const FIELD_ISSUE_TRACKER: &str = "issue_tracker";
48const FIELD_DOCUMENTATION: &str = "documentation";
49const FIELD_EXECUTABLES: &str = "executables";
50const FIELD_PUBLISH_TO: &str = "publish_to";
51const FIELD_ARCHIVE_URL: &str = "archive_url";
52const FIELD_PLATFORMS: &str = "platforms";
53const FIELD_FUNDING: &str = "funding";
54const FIELD_FALSE_SECRETS: &str = "false_secrets";
55const FIELD_SCREENSHOTS: &str = "screenshots";
56const FIELD_TOPICS: &str = "topics";
57const FIELD_IGNORED_ADVISORIES: &str = "ignored_advisories";
58const FIELD_PACKAGES: &str = "packages";
59const FIELD_SDKS: &str = "sdks";
60const FIELD_SDK: &str = "sdk";
61const FIELD_DEPENDENCY: &str = "dependency";
62const FIELD_SHA256: &str = "sha256";
63
64/// Dart pubspec.yaml manifest parser.
65pub struct PubspecYamlParser;
66
67impl PackageParser for PubspecYamlParser {
68    const PACKAGE_TYPE: PackageType = PackageType::Dart;
69
70    fn extract_packages(path: &Path) -> Vec<PackageData> {
71        let yaml_content = match read_yaml_file(path) {
72            Ok(content) => content,
73            Err(e) => {
74                warn!("Failed to read pubspec.yaml at {:?}: {}", path, e);
75                let mut package_data = default_package_data();
76                package_data.datasource_id = Some(DatasourceId::PubspecYaml);
77                return vec![package_data];
78            }
79        };
80
81        vec![parse_pubspec_yaml(&yaml_content)]
82    }
83
84    fn is_match(path: &Path) -> bool {
85        path.file_name().is_some_and(|name| name == "pubspec.yaml")
86    }
87}
88
89/// Dart pubspec.lock lockfile parser.
90pub struct PubspecLockParser;
91
92impl PackageParser for PubspecLockParser {
93    const PACKAGE_TYPE: PackageType = PackageType::Pubspec;
94
95    fn extract_packages(path: &Path) -> Vec<PackageData> {
96        let yaml_content = match read_yaml_file(path) {
97            Ok(content) => content,
98            Err(e) => {
99                warn!("Failed to read pubspec.lock at {:?}: {}", path, e);
100                let mut package_data =
101                    default_package_data_with_type(PubspecLockParser::PACKAGE_TYPE.as_str());
102                package_data.datasource_id = Some(DatasourceId::PubspecLock);
103                return vec![package_data];
104            }
105        };
106
107        vec![parse_pubspec_lock(&yaml_content)]
108    }
109
110    fn is_match(path: &Path) -> bool {
111        path.file_name().is_some_and(|name| name == "pubspec.lock")
112    }
113}
114
115fn read_yaml_file(path: &Path) -> Result<Value, String> {
116    let content = fs::read_to_string(path).map_err(|e| format!("Failed to read file: {}", e))?;
117    serde_yaml::from_str(&content).map_err(|e| format!("Failed to parse YAML: {}", e))
118}
119
120fn parse_pubspec_yaml(yaml_content: &Value) -> PackageData {
121    let name = extract_string_field(yaml_content, FIELD_NAME);
122    let version = extract_string_field(yaml_content, FIELD_VERSION);
123    let description = extract_description_field(yaml_content);
124    let homepage_url = extract_string_field(yaml_content, FIELD_HOMEPAGE);
125    let raw_license = extract_string_field(yaml_content, FIELD_LICENSE);
126    let vcs_url = extract_string_field(yaml_content, FIELD_REPOSITORY);
127    let archive_url = extract_string_field(yaml_content, FIELD_ARCHIVE_URL);
128
129    let parties = extract_authors(yaml_content);
130
131    // Extract license statement only - detection happens in separate engine
132    let declared_license_expression = None;
133    let declared_license_expression_spdx = None;
134    let license_detections = Vec::new();
135
136    let dependencies = [
137        collect_dependencies(
138            yaml_content,
139            FIELD_DEPENDENCIES,
140            Some("dependencies"),
141            true,
142            false,
143        ),
144        collect_dependencies(
145            yaml_content,
146            FIELD_DEV_DEPENDENCIES,
147            Some("dev_dependencies"),
148            false,
149            true,
150        ),
151        collect_dependencies(
152            yaml_content,
153            FIELD_DEPENDENCY_OVERRIDES,
154            Some("dependency_overrides"),
155            true,
156            false,
157        ),
158        collect_dependencies(
159            yaml_content,
160            FIELD_ENVIRONMENT,
161            Some("environment"),
162            true,
163            false,
164        ),
165    ]
166    .concat();
167
168    let extra_data = build_extra_data(yaml_content);
169    let keywords = extract_string_list_field(yaml_content, FIELD_TOPICS);
170
171    let purl = name
172        .as_ref()
173        .and_then(|name| build_purl(name, version.as_deref()));
174
175    let (api_data_url, repository_homepage_url, repository_download_url) =
176        if let (Some(name_val), Some(version_val)) = (&name, &version) {
177            (
178                Some(format!(
179                    "https://pub.dev/api/packages/{}/versions/{}",
180                    name_val, version_val
181                )),
182                Some(format!(
183                    "https://pub.dev/packages/{}/versions/{}",
184                    name_val, version_val
185                )),
186                Some(format!(
187                    "https://pub.dartlang.org/packages/{}/versions/{}.tar.gz",
188                    name_val, version_val
189                )),
190            )
191        } else {
192            (None, None, None)
193        };
194
195    let download_url = archive_url.or_else(|| repository_download_url.clone());
196
197    PackageData {
198        package_type: Some(PubspecYamlParser::PACKAGE_TYPE),
199        namespace: None,
200        name,
201        version,
202        qualifiers: None,
203        subpath: None,
204        primary_language: Some("dart".to_string()),
205        description,
206        release_date: None,
207        parties,
208        keywords,
209        homepage_url,
210        download_url,
211        size: None,
212        sha1: None,
213        md5: None,
214        sha256: None,
215        sha512: None,
216        bug_tracking_url: None,
217        code_view_url: None,
218        vcs_url,
219        copyright: None,
220        holder: None,
221        declared_license_expression,
222        declared_license_expression_spdx,
223        license_detections,
224        other_license_expression: None,
225        other_license_expression_spdx: None,
226        other_license_detections: Vec::new(),
227        extracted_license_statement: raw_license,
228        notice_text: None,
229        source_packages: Vec::new(),
230        file_references: Vec::new(),
231        is_private: yaml_content
232            .get(FIELD_PUBLISH_TO)
233            .and_then(Value::as_str)
234            .is_some_and(|value| value.trim() == "none"),
235        is_virtual: false,
236        extra_data,
237        dependencies,
238        repository_homepage_url,
239        repository_download_url,
240        api_data_url,
241        datasource_id: Some(DatasourceId::PubspecYaml),
242        purl,
243    }
244}
245
246fn parse_pubspec_lock(yaml_content: &Value) -> PackageData {
247    let dependencies = extract_lock_dependencies(yaml_content);
248
249    let mut package_data = default_package_data_with_type(PubspecLockParser::PACKAGE_TYPE.as_str());
250    package_data.dependencies = dependencies;
251    package_data.datasource_id = Some(DatasourceId::PubspecLock);
252    package_data
253}
254
255fn extract_lock_dependencies(lock_data: &Value) -> Vec<Dependency> {
256    let mut dependencies = Vec::new();
257
258    if let Some(sdks) = lock_data.get(FIELD_SDKS).and_then(Value::as_mapping) {
259        for (name_value, version_value) in sdks {
260            if let (Some(name), Some(version_str)) = (name_value.as_str(), version_value.as_str()) {
261                let purl = build_dependency_purl(name, None);
262                dependencies.push(Dependency {
263                    purl,
264                    extracted_requirement: Some(version_str.to_string()),
265                    scope: Some("sdk".to_string()),
266                    is_runtime: Some(true),
267                    is_optional: Some(false),
268                    is_pinned: Some(false),
269                    is_direct: Some(true),
270                    resolved_package: None,
271                    extra_data: None,
272                });
273            }
274        }
275    } else if let Some(version_str) = lock_data.get(FIELD_SDK).and_then(Value::as_str) {
276        let purl = build_dependency_purl("dart", None);
277        dependencies.push(Dependency {
278            purl,
279            extracted_requirement: Some(version_str.to_string()),
280            scope: Some("sdk".to_string()),
281            is_runtime: Some(true),
282            is_optional: Some(false),
283            is_pinned: Some(false),
284            is_direct: Some(true),
285            resolved_package: None,
286            extra_data: None,
287        });
288    }
289
290    let Some(packages) = lock_data.get(FIELD_PACKAGES).and_then(Value::as_mapping) else {
291        return dependencies;
292    };
293
294    let runtime_reachable =
295        reachable_lock_packages(packages, &["direct main", "direct overridden"]);
296    let dev_only_reachable = reachable_lock_packages(packages, &["direct dev"]);
297
298    for (name_value, details_value) in packages {
299        let name = match name_value.as_str() {
300            Some(value) => value,
301            None => continue,
302        };
303        let Some(details) = details_value.as_mapping() else {
304            continue;
305        };
306
307        let version = mapping_get(details, FIELD_VERSION)
308            .and_then(Value::as_str)
309            .map(|value| value.to_string());
310        let dependency_kind = mapping_get(details, FIELD_DEPENDENCY)
311            .and_then(Value::as_str)
312            .map(|value| value.to_string());
313        let (is_runtime, is_optional, is_direct) = classify_lock_dependency(
314            name,
315            dependency_kind.as_deref(),
316            &runtime_reachable,
317            &dev_only_reachable,
318        );
319
320        let is_pinned = version
321            .as_ref()
322            .is_some_and(|value| !value.trim().is_empty());
323
324        let purl = build_dependency_purl(name, version.as_deref());
325        let sha256 = extract_sha256(details);
326        let resolved_dependencies = extract_lock_package_dependencies(details);
327        let resolved_package = build_resolved_package(
328            name,
329            &version,
330            sha256,
331            extract_lock_descriptor_extra_data(details),
332            resolved_dependencies,
333        );
334
335        dependencies.push(Dependency {
336            purl,
337            extracted_requirement: version.clone(),
338            scope: dependency_kind,
339            is_runtime: Some(is_runtime),
340            is_optional: Some(is_optional),
341            is_pinned: Some(is_pinned),
342            is_direct: Some(is_direct),
343            resolved_package: Some(Box::new(resolved_package)),
344            extra_data: extract_lock_descriptor_extra_data(details),
345        });
346    }
347
348    dependencies
349}
350
351fn extract_lock_package_dependencies(details: &Mapping) -> Vec<Dependency> {
352    let mut dependencies = Vec::new();
353
354    let Some(dep_map) = mapping_get(details, FIELD_DEPENDENCIES).and_then(Value::as_mapping) else {
355        return dependencies;
356    };
357
358    for (name_value, requirement_value) in dep_map {
359        let name = match name_value.as_str() {
360            Some(value) => value,
361            None => continue,
362        };
363
364        let requirement = match dependency_requirement_from_value(requirement_value) {
365            Some(value) => value,
366            None => continue,
367        };
368        let is_pinned = is_pubspec_version_pinned(&requirement);
369        let purl = if is_pinned {
370            build_dependency_purl(name, Some(requirement.as_str()))
371        } else {
372            build_dependency_purl(name, None)
373        };
374
375        dependencies.push(Dependency {
376            purl,
377            extracted_requirement: Some(requirement),
378            scope: Some(FIELD_DEPENDENCIES.to_string()),
379            is_runtime: Some(true),
380            is_optional: Some(false),
381            is_pinned: Some(is_pinned),
382            is_direct: Some(false),
383            resolved_package: None,
384            extra_data: None,
385        });
386    }
387
388    dependencies
389}
390
391fn extract_sha256(details: &Mapping) -> Option<String> {
392    let direct = mapping_get(details, FIELD_SHA256)
393        .and_then(Value::as_str)
394        .map(|value| value.to_string());
395
396    if direct.is_some() {
397        return direct;
398    }
399
400    mapping_get(details, FIELD_DESCRIPTION)
401        .and_then(Value::as_mapping)
402        .and_then(|desc_map| mapping_get(desc_map, FIELD_SHA256))
403        .and_then(Value::as_str)
404        .map(|value| value.to_string())
405}
406
407fn build_resolved_package(
408    name: &str,
409    version: &Option<String>,
410    sha256: Option<String>,
411    extra_data: Option<HashMap<String, serde_json::Value>>,
412    dependencies: Vec<Dependency>,
413) -> ResolvedPackage {
414    ResolvedPackage {
415        package_type: PubspecLockParser::PACKAGE_TYPE,
416        namespace: String::new(),
417        name: name.to_string(),
418        version: version.clone().unwrap_or_default(),
419        primary_language: Some("dart".to_string()),
420        download_url: None,
421        sha1: None,
422        sha256,
423        sha512: None,
424        md5: None,
425        is_virtual: true,
426        extra_data,
427        dependencies,
428        repository_homepage_url: None,
429        repository_download_url: None,
430        api_data_url: None,
431        datasource_id: None,
432        purl: None,
433    }
434}
435
436fn collect_dependencies(
437    yaml_content: &Value,
438    field: &str,
439    scope: Option<&str>,
440    is_runtime: bool,
441    is_optional: bool,
442) -> Vec<Dependency> {
443    let mut dependencies = Vec::new();
444
445    let Some(dep_map) = yaml_content.get(field).and_then(Value::as_mapping) else {
446        return dependencies;
447    };
448
449    for (name_value, requirement_value) in dep_map {
450        let name = match name_value.as_str() {
451            Some(value) => value,
452            None => continue,
453        };
454        let requirement = match dependency_requirement_from_value(requirement_value) {
455            Some(value) => value,
456            None => continue,
457        };
458
459        let is_pinned = is_pubspec_version_pinned(&requirement);
460        let purl = if is_pinned {
461            build_dependency_purl(name, Some(requirement.as_str()))
462        } else {
463            build_dependency_purl(name, None)
464        };
465
466        dependencies.push(Dependency {
467            purl,
468            extracted_requirement: Some(requirement),
469            scope: scope.map(|value| value.to_string()),
470            is_runtime: Some(is_runtime),
471            is_optional: Some(is_optional),
472            is_pinned: Some(is_pinned),
473            is_direct: Some(true),
474            resolved_package: None,
475            extra_data: extract_manifest_dependency_extra_data(requirement_value),
476        });
477    }
478
479    dependencies
480}
481
482fn dependency_requirement_from_value(value: &Value) -> Option<String> {
483    if let Some(value) = value.as_str() {
484        let trimmed = value.trim();
485        if trimmed.is_empty() {
486            return None;
487        }
488        return Some(trimmed.to_string());
489    }
490
491    if let Some(value) = value.as_i64() {
492        return Some(value.to_string());
493    }
494
495    if let Some(value) = value.as_f64() {
496        return Some(value.to_string());
497    }
498
499    if let Some(map) = value.as_mapping() {
500        return format_dependency_mapping(map);
501    }
502
503    None
504}
505
506fn format_dependency_mapping(map: &Mapping) -> Option<String> {
507    let mut parts = Vec::new();
508
509    for (key, value) in map {
510        let Some(key_str) = key.as_str() else {
511            continue;
512        };
513
514        let value_str = if let Some(value) = value.as_str() {
515            value.to_string()
516        } else if let Some(value) = value.as_i64() {
517            value.to_string()
518        } else if let Some(value) = value.as_f64() {
519            value.to_string()
520        } else if let Some(nested) = value.as_mapping() {
521            format_dependency_mapping(nested)?
522        } else {
523            continue;
524        };
525
526        parts.push(format!("{}: {}", key_str, value_str));
527    }
528
529    if parts.is_empty() {
530        None
531    } else {
532        Some(parts.join(", "))
533    }
534}
535
536fn is_pubspec_version_pinned(version: &str) -> bool {
537    let trimmed = version.trim();
538    if trimmed.is_empty() {
539        return false;
540    }
541
542    trimmed
543        .chars()
544        .all(|character| character.is_ascii_digit() || character == '.')
545}
546
547fn build_purl(name: &str, version: Option<&str>) -> Option<String> {
548    build_purl_with_type(PubspecYamlParser::PACKAGE_TYPE.as_str(), name, version)
549}
550
551fn build_dependency_purl(name: &str, version: Option<&str>) -> Option<String> {
552    build_purl_with_type("pubspec", name, version)
553}
554
555fn build_purl_with_type(package_type: &str, name: &str, version: Option<&str>) -> Option<String> {
556    let mut package_url = match PackageUrl::new(package_type, name) {
557        Ok(purl) => purl,
558        Err(e) => {
559            warn!(
560                "Failed to create PackageUrl for {} dependency '{}': {}",
561                package_type, name, e
562            );
563            return None;
564        }
565    };
566
567    if let Some(version) = version
568        && let Err(e) = package_url.with_version(version)
569    {
570        warn!(
571            "Failed to set version '{}' for {} dependency '{}': {}",
572            version, package_type, name, e
573        );
574        return None;
575    }
576
577    Some(package_url.to_string())
578}
579
580fn extract_string_field(yaml_content: &Value, field: &str) -> Option<String> {
581    yaml_content
582        .get(field)
583        .and_then(Value::as_str)
584        .map(|value| value.trim().to_string())
585        .filter(|value| !value.is_empty())
586}
587
588fn extract_description_field(yaml_content: &Value) -> Option<String> {
589    // For description fields, preserve trailing newlines as they are semantically
590    // significant in YAML folded/literal scalars (> or |)
591    yaml_content
592        .get(FIELD_DESCRIPTION)
593        .and_then(Value::as_str)
594        .and_then(|value| {
595            // Only trim leading whitespace, preserve trailing newlines
596            let trimmed = value.trim_start();
597            if trimmed.is_empty() {
598                None
599            } else {
600                Some(trimmed.to_string())
601            }
602        })
603}
604
605fn mapping_get<'a>(map: &'a Mapping, key: &str) -> Option<&'a Value> {
606    map.get(Value::String(key.to_string()))
607}
608
609fn default_package_data() -> PackageData {
610    default_package_data_with_type(PubspecYamlParser::PACKAGE_TYPE.as_str())
611}
612
613fn default_package_data_with_type(package_type: &str) -> PackageData {
614    PackageData {
615        package_type: package_type.parse::<PackageType>().ok(),
616        primary_language: Some("dart".to_string()),
617        ..Default::default()
618    }
619}
620
621fn extract_authors(yaml_content: &Value) -> Vec<crate::models::Party> {
622    use crate::models::Party;
623    let mut parties = Vec::new();
624
625    if let Some(author) = extract_string_field(yaml_content, FIELD_AUTHOR) {
626        parties.push(Party {
627            r#type: None,
628            role: Some("author".to_string()),
629            name: Some(author),
630            email: None,
631            url: None,
632            organization: None,
633            organization_url: None,
634            timezone: None,
635        });
636    }
637
638    if let Some(authors_value) = yaml_content.get(FIELD_AUTHORS)
639        && let Some(authors_array) = authors_value.as_sequence()
640    {
641        for author_value in authors_array {
642            if let Some(author_str) = author_value.as_str() {
643                parties.push(Party {
644                    r#type: None,
645                    role: Some("author".to_string()),
646                    name: Some(author_str.to_string()),
647                    email: None,
648                    url: None,
649                    organization: None,
650                    organization_url: None,
651                    timezone: None,
652                });
653            }
654        }
655    }
656
657    parties
658}
659
660fn build_extra_data(
661    yaml_content: &Value,
662) -> Option<std::collections::HashMap<String, serde_json::Value>> {
663    use std::collections::HashMap;
664    let mut extra_data = HashMap::new();
665
666    if let Some(issue_tracker) = extract_string_field(yaml_content, FIELD_ISSUE_TRACKER) {
667        extra_data.insert(
668            FIELD_ISSUE_TRACKER.to_string(),
669            serde_json::Value::String(issue_tracker),
670        );
671    }
672
673    if let Some(documentation) = extract_string_field(yaml_content, FIELD_DOCUMENTATION) {
674        extra_data.insert(
675            FIELD_DOCUMENTATION.to_string(),
676            serde_json::Value::String(documentation),
677        );
678    }
679
680    if let Some(executables) = yaml_content.get(FIELD_EXECUTABLES) {
681        // Convert serde_yaml::Value to serde_json::Value
682        if let Ok(json_value) = serde_json::to_value(executables) {
683            extra_data.insert(FIELD_EXECUTABLES.to_string(), json_value);
684        }
685    }
686
687    if let Some(publish_to) = extract_string_field(yaml_content, FIELD_PUBLISH_TO) {
688        extra_data.insert(
689            FIELD_PUBLISH_TO.to_string(),
690            serde_json::Value::String(publish_to),
691        );
692    }
693
694    for field in [
695        FIELD_PLATFORMS,
696        FIELD_FUNDING,
697        FIELD_FALSE_SECRETS,
698        FIELD_SCREENSHOTS,
699        FIELD_TOPICS,
700        FIELD_IGNORED_ADVISORIES,
701    ] {
702        if let Some(value) = yaml_content.get(field)
703            && let Ok(json_value) = serde_json::to_value(value)
704        {
705            extra_data.insert(field.to_string(), json_value);
706        }
707    }
708
709    if extra_data.is_empty() {
710        None
711    } else {
712        Some(extra_data)
713    }
714}
715
716fn extract_string_list_field(yaml_content: &Value, field: &str) -> Vec<String> {
717    yaml_content
718        .get(field)
719        .and_then(Value::as_sequence)
720        .into_iter()
721        .flatten()
722        .filter_map(Value::as_str)
723        .map(str::trim)
724        .filter(|value| !value.is_empty())
725        .map(|value| value.to_string())
726        .collect()
727}
728
729fn extract_manifest_dependency_extra_data(
730    requirement_value: &Value,
731) -> Option<HashMap<String, serde_json::Value>> {
732    requirement_value
733        .as_mapping()
734        .and_then(|map| serde_json::to_value(map).ok())
735        .and_then(|json| json.as_object().cloned())
736        .map(|map| map.into_iter().collect())
737}
738
739fn extract_lock_descriptor_extra_data(
740    details: &Mapping,
741) -> Option<HashMap<String, serde_json::Value>> {
742    let mut extra = HashMap::new();
743
744    if let Some(source) = mapping_get(details, "source").and_then(Value::as_str) {
745        extra.insert(
746            "source".to_string(),
747            serde_json::Value::String(source.to_string()),
748        );
749    }
750
751    if let Some(description) = mapping_get(details, FIELD_DESCRIPTION)
752        && let Ok(json_value) = serde_json::to_value(description)
753    {
754        extra.insert("description".to_string(), json_value);
755    }
756
757    if let Some(kind) = mapping_get(details, FIELD_DEPENDENCY).and_then(Value::as_str) {
758        extra.insert(
759            FIELD_DEPENDENCY.to_string(),
760            serde_json::Value::String(kind.to_string()),
761        );
762    }
763
764    (!extra.is_empty()).then_some(extra)
765}
766
767fn reachable_lock_packages(packages: &Mapping, roots: &[&str]) -> HashSet<String> {
768    let mut reachable = HashSet::new();
769    let mut queue = VecDeque::new();
770
771    for (name_value, details_value) in packages {
772        let Some(name) = name_value.as_str() else {
773            continue;
774        };
775        let Some(details) = details_value.as_mapping() else {
776            continue;
777        };
778        let kind = mapping_get(details, FIELD_DEPENDENCY).and_then(Value::as_str);
779        if roots.contains(&kind.unwrap_or_default()) {
780            queue.push_back(name.to_string());
781        }
782    }
783
784    while let Some(current) = queue.pop_front() {
785        if !reachable.insert(current.clone()) {
786            continue;
787        }
788
789        let Some(details_value) = packages.get(Value::String(current.clone())) else {
790            continue;
791        };
792        let Some(details) = details_value.as_mapping() else {
793            continue;
794        };
795        let Some(dep_map) = mapping_get(details, FIELD_DEPENDENCIES).and_then(Value::as_mapping)
796        else {
797            continue;
798        };
799
800        for dep_name in dep_map.keys().filter_map(Value::as_str) {
801            queue.push_back(dep_name.to_string());
802        }
803    }
804
805    reachable
806}
807
808fn classify_lock_dependency(
809    name: &str,
810    dependency_kind: Option<&str>,
811    runtime_reachable: &HashSet<String>,
812    dev_only_reachable: &HashSet<String>,
813) -> (bool, bool, bool) {
814    match dependency_kind {
815        Some("direct main") | Some("direct overridden") => (true, false, true),
816        Some("direct dev") => (false, true, true),
817        Some("transitive") => {
818            if runtime_reachable.contains(name) {
819                (true, false, false)
820            } else if dev_only_reachable.contains(name) {
821                (false, true, false)
822            } else {
823                (true, false, false)
824            }
825        }
826        _ => (true, false, true),
827    }
828}
829
830crate::register_parser!(
831    "Dart pubspec.yaml manifest",
832    &["**/pubspec.yaml", "**/pubspec.lock"],
833    "pub",
834    "Dart",
835    Some("https://dart.dev/tools/pub/pubspec"),
836);