stubbing out teams_for_files_from_codeowners

Author: perryqh

src/ownership.rs

@@ -9,12 +9,11 @@ use std::{
 };
 use tracing::{info, instrument};
 
-pub(crate) mod codeowners_file_parser;
-pub(crate) mod codeowners_query;
 mod file_generator;
 mod file_owner_finder;
-pub mod file_owner_resolver;
+pub mod for_file_fast;
 pub(crate) mod mapper;
+pub(crate) mod codeowners_file_parser;
 mod validator;
 
 use crate::{
@@ -25,9 +24,9 @@ use crate::{
 pub use validator::Errors as ValidatorErrors;
 
 use self::{
-    codeowners_file_parser::parse_for_team,
     file_generator::FileGenerator,
     mapper::{JavascriptPackageMapper, Mapper, RubyPackageMapper, TeamFileMapper, TeamGemMapper, TeamGlobMapper, TeamYmlMapper},
+    codeowners_file_parser::parse_for_team,
     validator::Validator,
 };
 

src/ownership/codeowners_file_parser.rs

@@ -4,7 +4,6 @@ use crate::{
 };
 use fast_glob::glob_match;
 use memoize::memoize;
-use rayon::prelude::*;
 use regex::Regex;
 use std::{
     collections::HashMap,
@@ -23,57 +22,33 @@ pub struct Parser {
 }
 
 impl Parser {
-    pub fn teams_from_files_paths(&self, file_paths: &[PathBuf]) -> Result<HashMap<String, Option<Team>>, Box<dyn Error>> {
-        let file_inputs: Vec<(String, String)> = file_paths
-            .iter()
-            .map(|path| {
-                let file_path_str = path
-                    .to_str()
-                    .ok_or(IoError::new(std::io::ErrorKind::InvalidInput, "Invalid file path"))?;
-                let original = file_path_str.to_string();
-                let prefixed = if file_path_str.starts_with('/') {
-                    original.clone()
-                } else {
-                    format!("/{}", file_path_str)
-                };
-                Ok((original, prefixed))
-            })
-            .collect::<Result<Vec<_>, IoError>>()?;
-
-        if file_inputs.is_empty() {
-            return Ok(HashMap::new());
-        }
-
-        let codeowners_entries: Vec<(String, String)> =
-            build_codeowners_lines_in_priority(self.codeowners_file_path.to_string_lossy().into_owned())
-                .iter()
-                .map(|line| {
-                    line.split_once(' ')
-                        .map(|(glob, team_name)| (glob.to_string(), team_name.to_string()))
-                        .ok_or_else(|| IoError::new(std::io::ErrorKind::InvalidInput, "Invalid line"))
-                })
-                .collect::<Result<_, IoError>>()
-                .map_err(|e| Box::new(e) as Box<dyn Error>)?;
-
-        let teams_by_name = teams_by_github_team_name(self.absolute_team_files_globs());
-
-        let result: HashMap<String, Option<Team>> = file_inputs
-            .par_iter()
-            .map(|(key, prefixed)| {
-                let team = codeowners_entries
-                    .iter()
-                    .find(|(glob, _)| glob_match(glob, prefixed))
-                    .and_then(|(_, team_name)| teams_by_name.get(team_name).cloned());
-                (key.clone(), team)
-            })
-            .collect();
-
-        Ok(result)
+    pub fn teams_from_files_paths(&self, file_paths: &[PathBuf]) -> Result<HashMap<String, Team>, Box<dyn Error>> {
+        todo!()
     }
-
+    
     pub fn team_from_file_path(&self, file_path: &Path) -> Result<Option<Team>, Box<dyn Error>> {
-        let teams = self.teams_from_files_paths(&[file_path.to_path_buf()])?;
-        Ok(teams.get(file_path.to_string_lossy().into_owned().as_str()).cloned().flatten())
+        let file_path_str = file_path
+            .to_str()
+            .ok_or(IoError::new(std::io::ErrorKind::InvalidInput, "Invalid file path"))?;
+        let slash_prefixed = if file_path_str.starts_with("/") {
+            file_path_str.to_string()
+        } else {
+            format!("/{}", file_path_str)
+        };
+
+        let codeowners_lines_in_priorty = build_codeowners_lines_in_priority(self.codeowners_file_path.to_string_lossy().into_owned());
+        for line in codeowners_lines_in_priorty {
+            let (glob, team_name) = line
+                .split_once(' ')
+                .ok_or(IoError::new(std::io::ErrorKind::InvalidInput, "Invalid line"))?;
+            if glob_match(glob, &slash_prefixed) {
+                let tbn = teams_by_github_team_name(self.absolute_team_files_globs());
+                let team: Option<Team> = tbn.get(team_name.to_string().as_str()).cloned();
+                return Ok(team);
+            }
+        }
+
+        Ok(None)
     }
 
     fn absolute_team_files_globs(&self) -> Vec<String> {