summaryrefslogtreecommitdiff
path: root/internal/oi
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2024-10-02 10:48:53 +0300
committerPaul Buetow <paul@buetow.org>2024-10-02 10:48:53 +0300
commit87593db7993d1f3689d9602eed3ef095ac69cfb4 (patch)
tree5d06908aa52ac43d0163224e320163cead88eb17 /internal/oi
parenta93d91223724b94480b7166970ede97d8d190bdb (diff)
rename some funcs
Diffstat (limited to 'internal/oi')
-rw-r--r--internal/oi/oi.go28
1 files changed, 13 insertions, 15 deletions
diff --git a/internal/oi/oi.go b/internal/oi/oi.go
index 967109d..1f7de6d 100644
--- a/internal/oi/oi.go
+++ b/internal/oi/oi.go
@@ -13,22 +13,21 @@ import (
var ErrNotFound = errors.New("no file/entry found")
-func EnsureDirExists(dir string) error {
+func EnsureDir(dir string) error {
if _, err := os.Stat(dir); os.IsNotExist(err) {
return os.MkdirAll(dir, os.ModePerm)
}
return nil
}
-func EnsureParentDirExists(dir string) error {
- return EnsureDirExists(filepath.Dir(dir))
+func EnsureParentDir(dir string) error {
+ return EnsureDir(filepath.Dir(dir))
}
-// Rename to ReadDirCh
-func ReadDirFilter[T any](dir string, cb func(file os.DirEntry) (T, bool)) (chan T, error) {
+func ReadDirCh[T any](dir string, cb func(file os.DirEntry) (T, bool)) (chan T, error) {
ch := make(chan T)
- if err := EnsureDirExists(dir); err != nil {
+ if err := EnsureDir(dir); err != nil {
return ch, err
}
@@ -48,8 +47,9 @@ func ReadDirFilter[T any](dir string, cb func(file os.DirEntry) (T, bool)) (chan
return ch, nil
}
+
func TraverseDir(dir string, cb func(file os.DirEntry) error) error {
- if err := EnsureDirExists(dir); err != nil {
+ if err := EnsureDir(dir); err != nil {
return err
}
@@ -68,11 +68,10 @@ func TraverseDir(dir string, cb func(file os.DirEntry) error) error {
return errors.Join(errs...)
}
-// Rename to ReadDir
-func ReadDirSlurp[T any](dir string, cb func(file os.DirEntry) (T, bool)) ([]T, error) {
+func ReadDir[T any](dir string, cb func(file os.DirEntry) (T, bool)) ([]T, error) {
var results []T
- ch, err := ReadDirFilter(dir, cb)
+ ch, err := ReadDirCh(dir, cb)
if err != err {
return results, err
}
@@ -84,9 +83,8 @@ func ReadDirSlurp[T any](dir string, cb func(file os.DirEntry) (T, bool)) ([]T,
return results, nil
}
-// Rename to ReadDirRandom
-func ReadDirRandomEntry[T any](dir string, cb func(file os.DirEntry) (T, bool)) (T, error) {
- results, err := ReadDirSlurp(dir, cb)
+func ReadDirRandom[T any](dir string, cb func(file os.DirEntry) (T, bool)) (T, error) {
+ results, err := ReadDir(dir, cb)
if err != nil {
var zero T
@@ -120,7 +118,7 @@ func CopyFile(srcPath, dstPath string) error {
}
defer source.Close()
- if err := EnsureParentDirExists(dstPath); err != nil {
+ if err := EnsureParentDir(dstPath); err != nil {
return err
}
@@ -135,7 +133,7 @@ func CopyFile(srcPath, dstPath string) error {
}
func Rename(srcPath, dstPath string) error {
- if err := EnsureParentDirExists(dstPath); err != nil {
+ if err := EnsureParentDir(dstPath); err != nil {
return err
}
return os.Rename(srcPath, dstPath)