step thirty three: deference refs when reading and writing

This commit is contained in:
Gonçalo Valério 2020-11-08 12:49:39 +00:00
parent 38dfc9147d
commit 57c1631be2
2 changed files with 31 additions and 20 deletions

View File

@ -71,7 +71,8 @@ pub fn read_tree(oid: String) {
pub fn commit(message: &str) -> String { pub fn commit(message: &str) -> String {
let mut commit = format!("tree {}\n", write_tree(".".to_owned())); let mut commit = format!("tree {}\n", write_tree(".".to_owned()));
if let Ok(head) = data::get_ref("HEAD".to_owned()) { let head = data::get_ref("HEAD".to_owned());
if head.value != "" {
commit += format!("parent {}\n", head.value).as_str(); commit += format!("parent {}\n", head.value).as_str();
} }
@ -170,9 +171,11 @@ pub fn get_oid(mut name: String) -> String {
]; ];
for reference in refs_to_try.into_iter() { for reference in refs_to_try.into_iter() {
match data::get_ref(reference.clone()) { let found = data::get_ref(reference.clone());
Ok(oid) => return oid.value, if found.value != "" {
_ => continue, return found.value;
} else {
continue;
} }
} }

View File

@ -49,8 +49,9 @@ pub fn get_object(hash: String, expected: String) -> String {
return data; return data;
} }
pub fn update_ref(reference: String, value: RefValue) { pub fn update_ref(mut reference: String, value: RefValue) {
assert!(!value.symbolic); assert!(!value.symbolic);
reference = get_ref_internal(reference).0;
let path = format!("{}/{}", RGIT_DIR, reference); let path = format!("{}/{}", RGIT_DIR, reference);
let mut parents = Path::new(&path).ancestors(); let mut parents = Path::new(&path).ancestors();
parents.next(); parents.next();
@ -60,24 +61,13 @@ pub fn update_ref(reference: String, value: RefValue) {
fs::write(path, value.value).expect("Failed to updated HEAD"); fs::write(path, value.value).expect("Failed to updated HEAD");
} }
pub fn get_ref(reference: String) -> Result<RefValue, Box<dyn std::error::Error + 'static>> { pub fn get_ref(reference: String) -> RefValue {
let ref_path = format!("{}/{}", RGIT_DIR, reference); return get_ref_internal(reference).1;
let value = fs::read_to_string(ref_path)?;
if !value.is_empty() && value.starts_with("ref:") {
let new_ref: Vec<&str> = value.splitn(2, ":").collect();
return get_ref(new_ref[1].to_owned());
}
return Ok(RefValue {
value,
symbolic: false,
});
} }
pub fn iter_refs() -> Vec<(String, RefValue)> { pub fn iter_refs() -> Vec<(String, RefValue)> {
let mut refs: Vec<(String, RefValue)> = vec![]; let mut refs: Vec<(String, RefValue)> = vec![];
refs.push(("HEAD".to_owned(), get_ref("HEAD".to_owned()).unwrap())); refs.push(("HEAD".to_owned(), get_ref("HEAD".to_owned())));
for entry in WalkDir::new(format!("{}/refs/", RGIT_DIR)) { for entry in WalkDir::new(format!("{}/refs/", RGIT_DIR)) {
let item = entry.unwrap(); let item = entry.unwrap();
@ -87,10 +77,28 @@ pub fn iter_refs() -> Vec<(String, RefValue)> {
let relative_path = item.path().strip_prefix(RGIT_DIR).unwrap(); let relative_path = item.path().strip_prefix(RGIT_DIR).unwrap();
refs.push(( refs.push((
relative_path.to_str().unwrap().to_owned(), relative_path.to_str().unwrap().to_owned(),
get_ref(relative_path.to_str().unwrap().to_owned()).unwrap(), get_ref(relative_path.to_str().unwrap().to_owned()),
)); ));
} }
} }
return refs; return refs;
} }
pub fn get_ref_internal(reference: String) -> (String, RefValue) {
let ref_path = format!("{}/{}", RGIT_DIR, reference);
let value = fs::read_to_string(ref_path).unwrap_or("".to_owned());
if !value.is_empty() && value.starts_with("ref:") {
let new_ref: Vec<&str> = value.splitn(2, ":").collect();
return get_ref_internal(new_ref[1].to_owned());
}
return (
reference,
RefValue {
value,
symbolic: false,
},
);
}