mirror of
https://github.com/sbrow/envr.git
synced 2026-06-27 10:38:33 -04:00
refactor: Cleaned up the sync and scan commands.
This commit is contained in:
@@ -12,7 +12,7 @@ cmd_scan :: proc(cmd: ^Command) {
|
|||||||
}
|
}
|
||||||
defer db_close(&db)
|
defer db_close(&db)
|
||||||
|
|
||||||
search_dirs := search_paths(db.cfg)
|
search_dirs := search_paths(db.cfg, context.temp_allocator)
|
||||||
if len(search_dirs) == 0 {
|
if len(search_dirs) == 0 {
|
||||||
fmt.wprintln(
|
fmt.wprintln(
|
||||||
cmd.err,
|
cmd.err,
|
||||||
|
|||||||
@@ -24,63 +24,42 @@ cmd_sync :: proc(cmd: ^Command) {
|
|||||||
if !list_ok {
|
if !list_ok {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
defer delete(files)
|
|
||||||
|
|
||||||
// TODO: Set sane default size
|
results := make([]SyncEntry, len(files), context.temp_allocator)
|
||||||
results: [dynamic]SyncEntry
|
|
||||||
defer delete(results)
|
|
||||||
|
|
||||||
for &file in files {
|
for &file, i in files {
|
||||||
old_path: string
|
result, err := db_sync(&db, &file)
|
||||||
old_path, _ = strings.clone(file.Path, context.temp_allocator)
|
|
||||||
|
|
||||||
result, err_msg := db_sync(&db, &file)
|
|
||||||
|
|
||||||
status: string
|
status: string
|
||||||
is_dir_updated := .DirUpdated in result
|
if err != .None {
|
||||||
|
status = sync_error_message(err)
|
||||||
switch {
|
} else if .BackedUp in result {
|
||||||
case .Error in result:
|
status = .DirUpdated in result ? "Moved & Backed Up" : "Backed Up"
|
||||||
if len(err_msg) > 0 {
|
} else if .Restored in result {
|
||||||
status = err_msg
|
status = .DirUpdated in result ? "Moved & Restored" : "Restored"
|
||||||
} else {
|
} else if .DirUpdated in result {
|
||||||
status = "error"
|
|
||||||
}
|
|
||||||
case .BackedUp in result:
|
|
||||||
status = "Backed Up"
|
|
||||||
case .Restored in result:
|
|
||||||
status = "Restored"
|
|
||||||
case .DirUpdated in result:
|
|
||||||
status = "Moved"
|
status = "Moved"
|
||||||
case:
|
} else {
|
||||||
status = "OK"
|
status = "OK"
|
||||||
}
|
}
|
||||||
|
|
||||||
if is_dir_updated {
|
// TODO: Handle errors
|
||||||
if !db_delete(&db, old_path) {
|
path_str, _ := strings.clone(file.Path, context.temp_allocator)
|
||||||
return
|
status_str, _ := strings.clone(status, context.temp_allocator)
|
||||||
}
|
results[i] = SyncEntry {
|
||||||
|
Path = path_str,
|
||||||
|
Status = status_str,
|
||||||
}
|
}
|
||||||
if db_update_required(result) {
|
|
||||||
if !db_insert(&db, file) {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
path_str, _ := strings.clone(file.Path)
|
|
||||||
status_str, _ := strings.clone(status)
|
|
||||||
append(&results, SyncEntry{Path = path_str, Status = status_str})
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if terminal.is_terminal(os.stdout) {
|
if terminal.is_terminal(os.stdout) {
|
||||||
headers := []string{"File", "Status"}
|
headers := []string{"File", "Status"}
|
||||||
table_rows := make([dynamic][]string, 0, len(results))
|
// TODO: Use [2]string instead of slice here
|
||||||
|
table_rows := make([dynamic][]string, 0, len(results), context.temp_allocator)
|
||||||
|
|
||||||
for res in results {
|
for res in results {
|
||||||
row_slice := make([]string, 2)
|
row_slice := [2]string{res.Path, res.Status}
|
||||||
row_slice[0] = res.Path
|
append(&table_rows, row_slice[:])
|
||||||
row_slice[1] = res.Status
|
|
||||||
append(&table_rows, row_slice)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
render_table(cmd.out, headers, table_rows[:])
|
render_table(cmd.out, headers, table_rows[:])
|
||||||
@@ -94,3 +73,23 @@ cmd_sync :: proc(cmd: ^Command) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
sync_error_message :: proc(e: SyncError) -> string {
|
||||||
|
switch e {
|
||||||
|
case .None:
|
||||||
|
return ""
|
||||||
|
case .DirMissing:
|
||||||
|
return "directory missing"
|
||||||
|
case .MultipleDirs:
|
||||||
|
return "multiple directories found"
|
||||||
|
case .GitRootFailed:
|
||||||
|
return "failed to find git roots"
|
||||||
|
case .WriteFailed:
|
||||||
|
return "failed to write file"
|
||||||
|
case .ReadFailed:
|
||||||
|
return "failed to read file"
|
||||||
|
case .DbFailed:
|
||||||
|
return "failed to update database"
|
||||||
|
}
|
||||||
|
return "unknown error"
|
||||||
|
}
|
||||||
|
|
||||||
|
|||||||
30
config.odin
30
config.odin
@@ -187,32 +187,40 @@ find_ssh_private_keys :: proc() -> (keys: [dynamic]string, ok: bool) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
find_git_roots :: proc(cfg: Config) -> (roots: [dynamic]string, ok: bool) {
|
find_git_roots :: proc(
|
||||||
paths := search_paths(cfg)
|
cfg: Config,
|
||||||
|
allocator := context.temp_allocator,
|
||||||
|
) -> (
|
||||||
|
roots: [dynamic]string,
|
||||||
|
ok: bool,
|
||||||
|
) {
|
||||||
|
paths := search_paths(cfg, allocator)
|
||||||
|
// TODO: Pass allocator to findr
|
||||||
|
// findr.find_repos(paths[:], &roots, os.get_processor_core_count(), allocator)
|
||||||
findr.find_repos(paths[:], &roots, os.get_processor_core_count())
|
findr.find_repos(paths[:], &roots, os.get_processor_core_count())
|
||||||
ok = true
|
ok = true
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
search_paths :: proc(cfg: Config) -> (paths: [dynamic]string) {
|
search_paths :: proc(cfg: Config, allocator := context.allocator) -> [dynamic]string {
|
||||||
// TODO: Is this okay?
|
|
||||||
// TODO: handle error
|
// TODO: handle error
|
||||||
home, _ := os.user_home_dir(context.temp_allocator)
|
home, _ := os.user_home_dir(context.temp_allocator)
|
||||||
|
|
||||||
for include in cfg.ScanConfig.Include {
|
paths, _ := new_clone(cfg.ScanConfig.Include, allocator)
|
||||||
|
|
||||||
|
for &include in paths {
|
||||||
// TODO: Do we need to manually expand ~/ in odin?
|
// TODO: Do we need to manually expand ~/ in odin?
|
||||||
expanded, _ := strings.replace(include, "~", home, 1)
|
expanded, _ := strings.replace(include, "~", home, 1, allocator)
|
||||||
if filepath.is_abs(expanded) {
|
if filepath.is_abs(expanded) {
|
||||||
append(&paths, expanded)
|
include = expanded
|
||||||
} else {
|
} else {
|
||||||
defer delete(expanded)
|
resolved, err := filepath.abs(expanded, allocator)
|
||||||
resolved, err := filepath.abs(expanded)
|
|
||||||
if err == nil {
|
if err == nil {
|
||||||
append(&paths, resolved)
|
include = resolved
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return
|
return paths^
|
||||||
}
|
}
|
||||||
|
|
||||||
envr_dir :: proc(config_path: string) -> string {
|
envr_dir :: proc(config_path: string) -> string {
|
||||||
|
|||||||
@@ -187,14 +187,10 @@ test_search_paths_expands_tilde :: proc(t: ^testing.T) {
|
|||||||
cfg := Config {
|
cfg := Config {
|
||||||
ScanConfig = ScanConfig{Include = make([dynamic]string, 0, 1)},
|
ScanConfig = ScanConfig{Include = make([dynamic]string, 0, 1)},
|
||||||
}
|
}
|
||||||
defer delete(cfg.ScanConfig.Include)
|
|
||||||
append(&cfg.ScanConfig.Include, "~")
|
append(&cfg.ScanConfig.Include, "~")
|
||||||
|
defer delete(cfg.ScanConfig.Include)
|
||||||
|
|
||||||
paths := search_paths(cfg)
|
paths := search_paths(cfg, context.temp_allocator)
|
||||||
defer delete(paths)
|
|
||||||
for path in paths {
|
|
||||||
defer delete(path)
|
|
||||||
}
|
|
||||||
|
|
||||||
testing.expect(t, len(paths) == 1, "should have 1 path")
|
testing.expect(t, len(paths) == 1, "should have 1 path")
|
||||||
if len(paths) > 0 {
|
if len(paths) > 0 {
|
||||||
|
|||||||
175
db.odin
175
db.odin
@@ -13,15 +13,23 @@ import "core:strings"
|
|||||||
import "sqlite"
|
import "sqlite"
|
||||||
|
|
||||||
SyncFlagEnum :: enum {
|
SyncFlagEnum :: enum {
|
||||||
Noop,
|
|
||||||
DirUpdated,
|
DirUpdated,
|
||||||
Restored,
|
Restored,
|
||||||
BackedUp,
|
BackedUp,
|
||||||
Error,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
SyncFlag :: bit_set[SyncFlagEnum]
|
SyncFlag :: bit_set[SyncFlagEnum]
|
||||||
|
|
||||||
|
SyncError :: enum {
|
||||||
|
None,
|
||||||
|
DirMissing,
|
||||||
|
MultipleDirs,
|
||||||
|
GitRootFailed,
|
||||||
|
WriteFailed,
|
||||||
|
ReadFailed,
|
||||||
|
DbFailed,
|
||||||
|
}
|
||||||
|
|
||||||
Db :: struct {
|
Db :: struct {
|
||||||
// Pointer to the sqlite db
|
// Pointer to the sqlite db
|
||||||
db: ^rawptr,
|
db: ^rawptr,
|
||||||
@@ -387,7 +395,8 @@ new_env_file :: proc(path: string) -> (EnvFile, bool) {
|
|||||||
|
|
||||||
dir := filepath.dir(abs_path)
|
dir := filepath.dir(abs_path)
|
||||||
|
|
||||||
remotes := get_git_remotes(dir)
|
// TODO: Should we use the db allocator here?
|
||||||
|
remotes := get_git_remotes(dir, context.allocator)
|
||||||
|
|
||||||
data, read_err := os.read_entire_file_from_path(abs_path, context.allocator)
|
data, read_err := os.read_entire_file_from_path(abs_path, context.allocator)
|
||||||
defer delete(data)
|
defer delete(data)
|
||||||
@@ -410,109 +419,101 @@ new_env_file :: proc(path: string) -> (EnvFile, bool) {
|
|||||||
true
|
true
|
||||||
}
|
}
|
||||||
|
|
||||||
// If SyncFlag is .BackedUp, Caller is responsible for calling delete on f.contents and f.Sha256
|
// Reconciles `f` with the filesystem and persists changes to the database.
|
||||||
db_sync :: proc(d: ^Db, f: ^EnvFile) -> (SyncFlag, string) {
|
db_sync :: proc(d: ^Db, f: ^EnvFile) -> (SyncFlag, SyncError) {
|
||||||
|
allocator := db_allocator(d)
|
||||||
result: SyncFlag = {}
|
result: SyncFlag = {}
|
||||||
|
old_path := f.Path
|
||||||
|
|
||||||
if !os.exists(f.Dir) {
|
if !os.exists(f.Dir) {
|
||||||
assert(d != nil)
|
moved, err := try_move_dir(d, f, allocator)
|
||||||
moved_dirs, dirs_ok := find_moved_dirs(d, f)
|
if !moved {
|
||||||
if !dirs_ok {
|
return {}, err
|
||||||
return {.Error}, "failed to find moved dirs"
|
|
||||||
}
|
|
||||||
|
|
||||||
switch len(moved_dirs) {
|
|
||||||
case 0:
|
|
||||||
return {.Error}, "directory missing"
|
|
||||||
case 1:
|
|
||||||
update_dir(f, moved_dirs[0])
|
|
||||||
result = {.DirUpdated}
|
|
||||||
case:
|
|
||||||
return {.Error}, "multiple directories found"
|
|
||||||
}
|
}
|
||||||
|
result += {.DirUpdated}
|
||||||
}
|
}
|
||||||
|
|
||||||
if !os.exists(f.Path) {
|
if !os.exists(f.Path) {
|
||||||
write_err := os.write_entire_file(f.Path, f.contents)
|
write_err := os.write_entire_file(f.Path, f.contents)
|
||||||
if write_err != nil {
|
if write_err != nil {
|
||||||
msg, _ := strings.concatenate({"failed to write file: ", fmt.tprintf("%v", write_err)})
|
fmt.eprintf("db_sync: failed to write %s: %v\n", f.Path, write_err)
|
||||||
return {.Error}, msg
|
return result, .WriteFailed
|
||||||
}
|
}
|
||||||
|
|
||||||
return result + {.Restored}, ""
|
if !db_persist(d, f, old_path) {
|
||||||
|
return result, .DbFailed
|
||||||
|
}
|
||||||
|
return result + {.Restored}, .None
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO: Use temp allocator?
|
data, read_err := os.read_entire_file_from_path(f.Path, allocator)
|
||||||
data, read_err := os.read_entire_file_from_path(f.Path, context.allocator)
|
|
||||||
defer delete(data)
|
|
||||||
if read_err != nil {
|
if read_err != nil {
|
||||||
msg, _ := strings.concatenate(
|
fmt.eprintf("db_sync: failed to read %s: %v\n", f.Path, read_err)
|
||||||
{"failed to read file for SHA comparison: ", fmt.tprintf("%v", read_err)},
|
return result, .ReadFailed
|
||||||
)
|
|
||||||
return {.Error}, msg
|
|
||||||
}
|
}
|
||||||
|
|
||||||
digest := hash.hash_bytes(hash.Algorithm.SHA256, data)
|
digest := hash.hash_bytes(hash.Algorithm.SHA256, data, context.temp_allocator)
|
||||||
// TODO: Handle error
|
hex_bytes, hex_err := hex.encode(digest, allocator)
|
||||||
hex_bytes, _ := hex.encode(digest)
|
if hex_err != nil {
|
||||||
|
fmt.eprintf("db_sync: failed to encode hash for %s: %v\n", f.Path, hex_err)
|
||||||
|
return result, .ReadFailed
|
||||||
|
}
|
||||||
current_sha := string(hex_bytes)
|
current_sha := string(hex_bytes)
|
||||||
|
|
||||||
if current_sha == f.Sha256 {
|
if current_sha == f.Sha256 {
|
||||||
return result, ""
|
if !db_persist(d, f, old_path) {
|
||||||
}
|
return result, .DbFailed
|
||||||
|
|
||||||
if env_file_backup(f) {
|
|
||||||
return result + {.BackedUp}, ""
|
|
||||||
} else {
|
|
||||||
return {.Error}, "failed to backup file"
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
find_moved_dirs :: proc(d: ^Db, f: ^EnvFile) -> ([dynamic]string, bool) {
|
|
||||||
roots, roots_ok := find_git_roots(d.cfg)
|
|
||||||
if !roots_ok {
|
|
||||||
return {}, false
|
|
||||||
}
|
|
||||||
|
|
||||||
moved: [dynamic]string
|
|
||||||
for root in roots {
|
|
||||||
remotes := get_git_remotes(root)
|
|
||||||
if shares_remote(f, remotes[:]) {
|
|
||||||
cloned, _ := strings.clone(root)
|
|
||||||
append(&moved, cloned)
|
|
||||||
}
|
}
|
||||||
}
|
return result, .None
|
||||||
return moved, true
|
|
||||||
}
|
|
||||||
|
|
||||||
update_dir :: proc(f: ^EnvFile, new_dir: string) {
|
|
||||||
f.Dir = new_dir
|
|
||||||
base := filepath.base(f.Path)
|
|
||||||
new_path, _ := filepath.join({new_dir, base})
|
|
||||||
f.Path = new_path
|
|
||||||
f.Remotes = get_git_remotes(new_dir)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Loads the contents of the the file at f.Path into f.contents
|
|
||||||
//
|
|
||||||
// Caller is responsible for calling delete on f.contents and f.Sha256
|
|
||||||
env_file_backup :: proc(f: ^EnvFile) -> bool {
|
|
||||||
data, read_err := os.read_entire_file_from_path(f.Path, context.allocator)
|
|
||||||
if read_err != nil {
|
|
||||||
fmt.printf("Error reading file %s: %v\n", f.Path, read_err)
|
|
||||||
return false
|
|
||||||
}
|
}
|
||||||
|
|
||||||
f.contents = string(data)
|
f.contents = string(data)
|
||||||
digest := hash.hash_bytes(hash.Algorithm.SHA256, data, context.temp_allocator)
|
f.Sha256 = current_sha
|
||||||
hex_bytes, alloc_err := hex.encode(digest)
|
if !db_persist(d, f, old_path) {
|
||||||
if alloc_err != nil {
|
return result, .DbFailed
|
||||||
fmt.printf("Error generating hash for file %s: %v\n", f.Path, alloc_err)
|
}
|
||||||
return false
|
return result + {.BackedUp}, .None
|
||||||
|
}
|
||||||
|
|
||||||
|
db_persist :: proc(d: ^Db, f: ^EnvFile, old_path: string) -> bool {
|
||||||
|
if f.Path != old_path {
|
||||||
|
if !db_delete(d, old_path) {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return db_insert(d, f^)
|
||||||
|
}
|
||||||
|
|
||||||
|
try_move_dir :: proc(d: ^Db, f: ^EnvFile, allocator: mem.Allocator) -> (bool, SyncError) {
|
||||||
|
// TODO: Should thread the allocator through, right?
|
||||||
|
roots, ok := find_git_roots(d.cfg, allocator)
|
||||||
|
if !ok {
|
||||||
|
return false, .GitRootFailed
|
||||||
|
}
|
||||||
|
|
||||||
|
match_count := 0
|
||||||
|
matched_dir: string
|
||||||
|
for root in roots {
|
||||||
|
remotes := get_git_remotes(root, context.temp_allocator)
|
||||||
|
if shares_remote(f, remotes[:]) {
|
||||||
|
match_count += 1
|
||||||
|
matched_dir = root
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
switch match_count {
|
||||||
|
case 0:
|
||||||
|
return false, .DirMissing
|
||||||
|
case 1:
|
||||||
|
f.Dir = matched_dir
|
||||||
|
base := filepath.base(f.Path)
|
||||||
|
new_path, _ := filepath.join({f.Dir, base}, allocator)
|
||||||
|
f.Path = new_path
|
||||||
|
f.Remotes = get_git_remotes(f.Dir, allocator)
|
||||||
|
return true, .None
|
||||||
|
case:
|
||||||
|
return false, .MultipleDirs
|
||||||
}
|
}
|
||||||
f.Sha256 = string(hex_bytes)
|
|
||||||
return true
|
|
||||||
}
|
}
|
||||||
|
|
||||||
shares_remote :: proc(f: ^EnvFile, remotes: []string) -> bool {
|
shares_remote :: proc(f: ^EnvFile, remotes: []string) -> bool {
|
||||||
@@ -526,7 +527,7 @@ shares_remote :: proc(f: ^EnvFile, remotes: []string) -> bool {
|
|||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
get_git_remotes :: proc(dir: string) -> [dynamic]string {
|
get_git_remotes :: proc(dir: string, allocator: mem.Allocator) -> [dynamic]string {
|
||||||
config_path, _ := filepath.join({dir, ".git", "config"}, context.temp_allocator)
|
config_path, _ := filepath.join({dir, ".git", "config"}, context.temp_allocator)
|
||||||
// TODO: Handle error
|
// TODO: Handle error
|
||||||
m, _, ok := ini.load_map_from_path(config_path, context.temp_allocator)
|
m, _, ok := ini.load_map_from_path(config_path, context.temp_allocator)
|
||||||
@@ -534,7 +535,7 @@ get_git_remotes :: proc(dir: string) -> [dynamic]string {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
remotes := make([dynamic]string, 0, 1)
|
remotes := make([dynamic]string, 0, 1, allocator)
|
||||||
|
|
||||||
for section_name, section in m {
|
for section_name, section in m {
|
||||||
if strings.has_prefix(section_name, "remote ") {
|
if strings.has_prefix(section_name, "remote ") {
|
||||||
@@ -544,7 +545,7 @@ get_git_remotes :: proc(dir: string) -> [dynamic]string {
|
|||||||
if r == url {found = true; break}
|
if r == url {found = true; break}
|
||||||
}
|
}
|
||||||
if !found {
|
if !found {
|
||||||
cloned, _ := strings.clone(url)
|
cloned, _ := strings.clone(url, allocator)
|
||||||
append(&remotes, cloned)
|
append(&remotes, cloned)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -554,10 +555,6 @@ get_git_remotes :: proc(dir: string) -> [dynamic]string {
|
|||||||
return remotes
|
return remotes
|
||||||
}
|
}
|
||||||
|
|
||||||
db_update_required :: proc(status: SyncFlag) -> bool {
|
|
||||||
return .BackedUp in status || .DirUpdated in status
|
|
||||||
}
|
|
||||||
|
|
||||||
to_cstring :: proc {
|
to_cstring :: proc {
|
||||||
string_to_cstring,
|
string_to_cstring,
|
||||||
strings.to_cstring,
|
strings.to_cstring,
|
||||||
|
|||||||
237
db_test.odin
237
db_test.odin
@@ -1,5 +1,7 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
|
import "core:crypto/hash"
|
||||||
|
import "core:encoding/hex"
|
||||||
import "core:fmt"
|
import "core:fmt"
|
||||||
import "core:os"
|
import "core:os"
|
||||||
import "core:path/filepath"
|
import "core:path/filepath"
|
||||||
@@ -14,7 +16,7 @@ make_test_env_file :: proc(path, sha, contents: string, remotes: []string = {})
|
|||||||
Dir = "",
|
Dir = "",
|
||||||
Sha256 = sha,
|
Sha256 = sha,
|
||||||
contents = contents,
|
contents = contents,
|
||||||
Remotes = make([dynamic]string, 0, len(remotes)),
|
Remotes = make([dynamic]string, 0, len(remotes), context.temp_allocator),
|
||||||
}
|
}
|
||||||
for r in remotes {
|
for r in remotes {
|
||||||
append(&f.Remotes, r)
|
append(&f.Remotes, r)
|
||||||
@@ -201,37 +203,6 @@ test_db_serialize :: proc(t: ^testing.T) {
|
|||||||
testing.expect(t, sz > 0, "serialized size should be > 0")
|
testing.expect(t, sz > 0, "serialized size should be > 0")
|
||||||
}
|
}
|
||||||
|
|
||||||
@(test)
|
|
||||||
test_db_update_required_noop :: proc(t: ^testing.T) {
|
|
||||||
testing.expect(t, !db_update_required({}), "Noop should not require update")
|
|
||||||
}
|
|
||||||
|
|
||||||
@(test)
|
|
||||||
test_db_update_required_backed_up :: proc(t: ^testing.T) {
|
|
||||||
testing.expect(t, db_update_required({.BackedUp}), "BackedUp should require update")
|
|
||||||
}
|
|
||||||
|
|
||||||
@(test)
|
|
||||||
test_db_update_required_dir_updated :: proc(t: ^testing.T) {
|
|
||||||
testing.expect(t, db_update_required({.DirUpdated}), "DirUpdated should require update")
|
|
||||||
}
|
|
||||||
|
|
||||||
@(test)
|
|
||||||
test_db_update_required_restored :: proc(t: ^testing.T) {
|
|
||||||
testing.expect(t, !db_update_required({.Restored}), "Restored alone should not require update")
|
|
||||||
}
|
|
||||||
|
|
||||||
@(test)
|
|
||||||
test_db_update_required_error :: proc(t: ^testing.T) {
|
|
||||||
testing.expect(t, !db_update_required({.Error}), "Error alone should not require update")
|
|
||||||
}
|
|
||||||
|
|
||||||
@(test)
|
|
||||||
test_db_update_required_combined :: proc(t: ^testing.T) {
|
|
||||||
combined := SyncFlag{.DirUpdated, .Restored}
|
|
||||||
testing.expect(t, db_update_required(combined), "DirUpdated|Restored should require update")
|
|
||||||
}
|
|
||||||
|
|
||||||
@(test)
|
@(test)
|
||||||
test_shares_remote_overlap :: proc(t: ^testing.T) {
|
test_shares_remote_overlap :: proc(t: ^testing.T) {
|
||||||
f := EnvFile {
|
f := EnvFile {
|
||||||
@@ -307,8 +278,7 @@ test_get_git_remotes_single :: proc(t: ^testing.T) {
|
|||||||
err := os.write_entire_file(config_path, transmute([]u8)config_content)
|
err := os.write_entire_file(config_path, transmute([]u8)config_content)
|
||||||
testing.expect(t, err == nil, "should write .git/config")
|
testing.expect(t, err == nil, "should write .git/config")
|
||||||
|
|
||||||
remotes := get_git_remotes(base)
|
remotes := get_git_remotes(base, context.temp_allocator)
|
||||||
defer delete_remotes(remotes)
|
|
||||||
|
|
||||||
testing.expect(t, len(remotes) == 1, "should find 1 remote")
|
testing.expect(t, len(remotes) == 1, "should find 1 remote")
|
||||||
if len(remotes) != 1 do return
|
if len(remotes) != 1 do return
|
||||||
@@ -329,8 +299,7 @@ test_get_git_remotes_multiple :: proc(t: ^testing.T) {
|
|||||||
err := os.write_entire_file(config_path, transmute([]u8)config_content)
|
err := os.write_entire_file(config_path, transmute([]u8)config_content)
|
||||||
testing.expect(t, err == nil, "should write .git/config")
|
testing.expect(t, err == nil, "should write .git/config")
|
||||||
|
|
||||||
remotes := get_git_remotes(base)
|
remotes := get_git_remotes(base, context.temp_allocator)
|
||||||
defer delete_remotes(remotes)
|
|
||||||
|
|
||||||
testing.expect(t, len(remotes) == 2, "should find 2 remotes")
|
testing.expect(t, len(remotes) == 2, "should find 2 remotes")
|
||||||
}
|
}
|
||||||
@@ -341,8 +310,7 @@ test_get_git_remotes_no_config :: proc(t: ^testing.T) {
|
|||||||
os.mkdir_all(base)
|
os.mkdir_all(base)
|
||||||
defer os.remove_all(base)
|
defer os.remove_all(base)
|
||||||
|
|
||||||
remotes := get_git_remotes(base)
|
remotes := get_git_remotes(base, context.temp_allocator)
|
||||||
defer delete_remotes(remotes)
|
|
||||||
|
|
||||||
testing.expect(t, len(remotes) == 0, "should return empty when no .git/config")
|
testing.expect(t, len(remotes) == 0, "should return empty when no .git/config")
|
||||||
}
|
}
|
||||||
@@ -361,8 +329,7 @@ test_get_git_remotes_no_remotes :: proc(t: ^testing.T) {
|
|||||||
err := os.write_entire_file(config_path, transmute([]u8)config_content)
|
err := os.write_entire_file(config_path, transmute([]u8)config_content)
|
||||||
testing.expect(t, err == nil, "should write .git/config")
|
testing.expect(t, err == nil, "should write .git/config")
|
||||||
|
|
||||||
remotes := get_git_remotes(base)
|
remotes := get_git_remotes(base, context.temp_allocator)
|
||||||
defer delete_remotes(remotes)
|
|
||||||
|
|
||||||
testing.expect(t, len(remotes) == 0, "should return empty when no remote sections")
|
testing.expect(t, len(remotes) == 0, "should return empty when no remote sections")
|
||||||
}
|
}
|
||||||
@@ -396,49 +363,6 @@ test_new_env_file_missing :: proc(t: ^testing.T) {
|
|||||||
testing.expect(t, !ok, "missing file should return false")
|
testing.expect(t, !ok, "missing file should return false")
|
||||||
}
|
}
|
||||||
|
|
||||||
@(test)
|
|
||||||
test_env_file_backup :: proc(t: ^testing.T) {
|
|
||||||
base := fmt.tprintf("/tmp/envr-test-backup-%d", os.get_pid())
|
|
||||||
os.mkdir_all(base)
|
|
||||||
defer os.remove_all(base)
|
|
||||||
|
|
||||||
env_path := fmt.tprintf("%s/.env", base)
|
|
||||||
err := os.write_entire_file(env_path, "KEY=12345\n")
|
|
||||||
testing.expect(t, err == nil, ".env file should exist")
|
|
||||||
|
|
||||||
f := EnvFile {
|
|
||||||
Path = env_path,
|
|
||||||
}
|
|
||||||
defer delete(f.contents)
|
|
||||||
defer delete(f.Sha256)
|
|
||||||
testing.expect(t, env_file_backup(&f), "backup should succeed")
|
|
||||||
testing.expect_value(t, f.contents, "KEY=12345\n")
|
|
||||||
testing.expect_value(t, len(f.Sha256), 64)
|
|
||||||
}
|
|
||||||
|
|
||||||
@(test)
|
|
||||||
test_env_file_backup_missing :: proc(t: ^testing.T) {
|
|
||||||
f := EnvFile {
|
|
||||||
Path = "/tmp/envr-nonexistent-backup/.env",
|
|
||||||
}
|
|
||||||
testing.expect(t, !env_file_backup(&f), "missing file should return false")
|
|
||||||
}
|
|
||||||
|
|
||||||
@(test)
|
|
||||||
test_update_dir :: proc(t: ^testing.T) {
|
|
||||||
f := EnvFile {
|
|
||||||
Path = "/old/project/.env",
|
|
||||||
Dir = "/old/project",
|
|
||||||
Remotes = make([dynamic]string, 0, context.temp_allocator),
|
|
||||||
}
|
|
||||||
defer delete_envfile(&f)
|
|
||||||
|
|
||||||
update_dir(&f, "/new/location")
|
|
||||||
|
|
||||||
testing.expect_value(t, f.Dir, "/new/location")
|
|
||||||
testing.expect_value(t, f.Path, "/new/location/.env")
|
|
||||||
}
|
|
||||||
|
|
||||||
@(test)
|
@(test)
|
||||||
test_closing_db_has_no_leaks :: proc(t: ^testing.T) {
|
test_closing_db_has_no_leaks :: proc(t: ^testing.T) {
|
||||||
base := fmt.tprintf("/tmp/envr-test-leak-%d", os.get_pid())
|
base := fmt.tprintf("/tmp/envr-test-leak-%d", os.get_pid())
|
||||||
@@ -495,3 +419,150 @@ test_open_existing_db_has_no_leaks :: proc(t: ^testing.T) {
|
|||||||
db_close(&db2)
|
db_close(&db2)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@(test)
|
||||||
|
test_db_sync_noop :: proc(t: ^testing.T) {
|
||||||
|
base := fmt.tprintf("/tmp/envr-test-sync-noop-%d", os.get_pid())
|
||||||
|
os.mkdir_all(base)
|
||||||
|
defer os.remove_all(base)
|
||||||
|
|
||||||
|
env_path := fmt.tprintf("%s/.env", base)
|
||||||
|
content := "KEY=value\n"
|
||||||
|
write_err := os.write_entire_file(env_path, transmute([]u8)content)
|
||||||
|
testing.expect(t, write_err == nil, "should write .env file")
|
||||||
|
|
||||||
|
digest := hash.hash_bytes(
|
||||||
|
hash.Algorithm.SHA256,
|
||||||
|
transmute([]u8)content,
|
||||||
|
context.temp_allocator,
|
||||||
|
)
|
||||||
|
hex_bytes, _ := hex.encode(digest, context.temp_allocator)
|
||||||
|
sha := string(hex_bytes)
|
||||||
|
|
||||||
|
d, ok := db_init()
|
||||||
|
testing.expect(t, ok, "failed to create test db")
|
||||||
|
defer db_close(&d)
|
||||||
|
|
||||||
|
f := make_test_env_file(env_path, sha, content)
|
||||||
|
f.Dir = base
|
||||||
|
db_insert(&d, f)
|
||||||
|
|
||||||
|
result, sync_err := db_sync(&d, &f)
|
||||||
|
testing.expect(t, sync_err == .None, "sync should not error")
|
||||||
|
testing.expect(t, result == {}, "should be noop")
|
||||||
|
}
|
||||||
|
|
||||||
|
@(test)
|
||||||
|
test_db_sync_backed_up :: proc(t: ^testing.T) {
|
||||||
|
base := fmt.tprintf("/tmp/envr-test-sync-backup-%d", os.get_pid())
|
||||||
|
os.mkdir_all(base)
|
||||||
|
defer os.remove_all(base)
|
||||||
|
|
||||||
|
env_path := fmt.tprintf("%s/.env", base)
|
||||||
|
changed_content := "KEY=changed\n"
|
||||||
|
write_err := os.write_entire_file(env_path, transmute([]u8)changed_content)
|
||||||
|
testing.expect(t, write_err == nil, "should write .env file")
|
||||||
|
|
||||||
|
d, ok := db_init()
|
||||||
|
testing.expect(t, ok, "failed to create test db")
|
||||||
|
defer db_close(&d)
|
||||||
|
|
||||||
|
f := make_test_env_file(env_path, "old_sha", "KEY=original")
|
||||||
|
f.Dir = base
|
||||||
|
db_insert(&d, f)
|
||||||
|
|
||||||
|
result, sync_err := db_sync(&d, &f)
|
||||||
|
testing.expect(t, sync_err == .None, "sync should not error")
|
||||||
|
testing.expect(t, .BackedUp in result, "should be backed up")
|
||||||
|
}
|
||||||
|
|
||||||
|
@(test)
|
||||||
|
test_db_sync_restored :: proc(t: ^testing.T) {
|
||||||
|
base := fmt.tprintf("/tmp/envr-test-sync-restore-%d", os.get_pid())
|
||||||
|
os.mkdir_all(base)
|
||||||
|
defer os.remove_all(base)
|
||||||
|
|
||||||
|
env_path := fmt.tprintf("%s/.env", base)
|
||||||
|
|
||||||
|
d, ok := db_init()
|
||||||
|
testing.expect(t, ok, "failed to create test db")
|
||||||
|
defer db_close(&d)
|
||||||
|
|
||||||
|
f := make_test_env_file(env_path, "some_sha", "SECRET=value")
|
||||||
|
f.Dir = base
|
||||||
|
defer delete(f.Remotes)
|
||||||
|
db_insert(&d, f)
|
||||||
|
|
||||||
|
result, err := db_sync(&d, &f)
|
||||||
|
testing.expect(t, err == .None, "sync should not error")
|
||||||
|
testing.expect(t, .Restored in result, "should be restored")
|
||||||
|
|
||||||
|
data, read_err := os.read_entire_file_from_path(env_path, context.temp_allocator)
|
||||||
|
testing.expect(t, read_err == nil, "file should exist after restore")
|
||||||
|
if read_err == nil {
|
||||||
|
testing.expect_value(t, string(data), "SECRET=value")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@(test)
|
||||||
|
test_db_sync_dir_missing :: proc(t: ^testing.T) {
|
||||||
|
d, ok := db_init()
|
||||||
|
testing.expect(t, ok, "failed to create test db")
|
||||||
|
defer db_close(&d)
|
||||||
|
|
||||||
|
f := make_test_env_file("/nonexistent/path/.env", "sha", "KEY=val")
|
||||||
|
db_insert(&d, f)
|
||||||
|
|
||||||
|
result, err := db_sync(&d, &f)
|
||||||
|
testing.expect(t, err == .DirMissing, "should return DirMissing error")
|
||||||
|
}
|
||||||
|
|
||||||
|
@(test)
|
||||||
|
test_db_sync_moved :: proc(t: ^testing.T) {
|
||||||
|
base := fmt.tprintf("/tmp/envr-test-sync-moved-%d", os.get_pid())
|
||||||
|
search_root := fmt.tprintf("%s/search", base)
|
||||||
|
repo_dir := fmt.tprintf("%s/myproject", search_root)
|
||||||
|
git_dir := fmt.tprintf("%s/.git", repo_dir)
|
||||||
|
defer os.remove_all(base)
|
||||||
|
|
||||||
|
os.mkdir_all(git_dir)
|
||||||
|
|
||||||
|
config_content := "[remote \"origin\"]\n\turl = git@github.com:user/repo.git\n"
|
||||||
|
config_path := fmt.tprintf("%s/config", git_dir)
|
||||||
|
write_err := os.write_entire_file(config_path, transmute([]u8)config_content)
|
||||||
|
testing.expect(t, write_err == nil, "should write .git/config")
|
||||||
|
|
||||||
|
d, ok := db_init()
|
||||||
|
testing.expect(t, ok, "failed to create test db")
|
||||||
|
defer db_close(&d)
|
||||||
|
|
||||||
|
d.cfg.ScanConfig.Include = make([dynamic]string, 0, 1, context.temp_allocator)
|
||||||
|
append(&d.cfg.ScanConfig.Include, search_root)
|
||||||
|
|
||||||
|
f := make_test_env_file(
|
||||||
|
"/old/nonexistent/path/.env",
|
||||||
|
"some_sha",
|
||||||
|
"SECRET=value",
|
||||||
|
[]string{"git@github.com:user/repo.git"},
|
||||||
|
)
|
||||||
|
testing.expect(t, db_insert(&d, f), "insert should succeed")
|
||||||
|
|
||||||
|
result, err := db_sync(&d, &f)
|
||||||
|
testing.expect(t, err == .None, "sync should not error")
|
||||||
|
if err != .None do return
|
||||||
|
testing.expect(t, .DirUpdated in result, "should have DirUpdated flag")
|
||||||
|
testing.expect(t, .Restored in result, "should have Restored flag")
|
||||||
|
|
||||||
|
expected_path := fmt.tprintf("%s/.env", repo_dir)
|
||||||
|
testing.expect_value(t, f.Path, expected_path)
|
||||||
|
testing.expect_value(t, f.Dir, repo_dir)
|
||||||
|
|
||||||
|
_, old_exists := db_fetch(&d, "/old/nonexistent/path/.env")
|
||||||
|
testing.expect(t, !old_exists, "old path should be deleted from db")
|
||||||
|
|
||||||
|
new_fetched, new_ok := db_fetch(&d, expected_path)
|
||||||
|
testing.expect(t, new_ok, "new path should exist in db")
|
||||||
|
if new_ok {
|
||||||
|
testing.expect_value(t, new_fetched.contents, "SECRET=value")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|||||||
13
table.odin
13
table.odin
@@ -6,7 +6,7 @@ import "core:io"
|
|||||||
import "core:strings"
|
import "core:strings"
|
||||||
|
|
||||||
render_table :: proc(w: io.Writer, headers: []string, rows: [][]string) {
|
render_table :: proc(w: io.Writer, headers: []string, rows: [][]string) {
|
||||||
col_widths := make([dynamic]int, 0, len(headers))
|
col_widths := make([dynamic]int, 0, len(headers), context.temp_allocator)
|
||||||
for i in 0 ..< len(headers) {
|
for i in 0 ..< len(headers) {
|
||||||
append(&col_widths, strings.rune_count(headers[i]))
|
append(&col_widths, strings.rune_count(headers[i]))
|
||||||
}
|
}
|
||||||
@@ -20,11 +20,14 @@ render_table :: proc(w: io.Writer, headers: []string, rows: [][]string) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
b: strings.Builder
|
b: strings.Builder
|
||||||
strings.builder_init(&b)
|
strings.builder_init(&b, context.temp_allocator)
|
||||||
defer strings.builder_destroy(&b)
|
|
||||||
defer delete(col_widths)
|
|
||||||
|
|
||||||
hline :: proc(w: io.Writer, b: ^strings.Builder, left, mid, right: string, widths: [dynamic]int) {
|
hline :: proc(
|
||||||
|
w: io.Writer,
|
||||||
|
b: ^strings.Builder,
|
||||||
|
left, mid, right: string,
|
||||||
|
widths: [dynamic]int,
|
||||||
|
) {
|
||||||
strings.write_string(b, left)
|
strings.write_string(b, left)
|
||||||
for i in 0 ..< len(widths) {
|
for i in 0 ..< len(widths) {
|
||||||
for _ in 0 ..< widths[i] + 2 {
|
for _ in 0 ..< widths[i] + 2 {
|
||||||
|
|||||||
Reference in New Issue
Block a user