Skip to content

Commit cf20ccd

Browse files
committed
more cleanup
1 parent 5028689 commit cf20ccd

File tree

4 files changed

+9
-125
lines changed

4 files changed

+9
-125
lines changed

cmd/jb/cache.go

Lines changed: 0 additions & 113 deletions
Original file line numberDiff line numberDiff line change
@@ -389,119 +389,6 @@ func printCacheInfo(info CacheInfo) {
389389
}
390390
}
391391

392-
// cleanCache removes expired entries from the cache
393-
func cleanCache(cacheDir string, maxAgeInDays, maxSizeMB int) error {
394-
// Check if cache directory exists
395-
_, err := os.Stat(cacheDir)
396-
if os.IsNotExist(err) {
397-
// Nothing to clean
398-
return nil
399-
}
400-
if err != nil {
401-
return err
402-
}
403-
404-
// Get current cache information
405-
info, err := getCacheInfo(cacheDir)
406-
if err != nil {
407-
return err
408-
}
409-
410-
// If cache is already below limits, do nothing
411-
maxSizeBytes := int64(maxSizeMB) * 1024 * 1024
412-
if info.Size <= maxSizeBytes && time.Since(info.OldestEntry).Hours()/24 <= float64(maxAgeInDays) {
413-
return nil
414-
}
415-
416-
// Find entries to clean
417-
entries, err := filepath.Glob(filepath.Join(cacheDir, "*"))
418-
if err != nil {
419-
return err
420-
}
421-
422-
// Sort entries by age, oldest first
423-
type Entry struct {
424-
Path string
425-
ModTime time.Time
426-
}
427-
428-
var sortedEntries []Entry
429-
for _, path := range entries {
430-
info, err := os.Stat(path)
431-
if err != nil {
432-
continue
433-
}
434-
if info.IsDir() {
435-
sortedEntries = append(sortedEntries, Entry{
436-
Path: path,
437-
ModTime: info.ModTime(),
438-
})
439-
}
440-
}
441-
442-
// Remove entries that exceed age limit
443-
cutoffTime := time.Now().AddDate(0, 0, -maxAgeInDays)
444-
for _, entry := range sortedEntries {
445-
if entry.ModTime.Before(cutoffTime) {
446-
err := os.RemoveAll(entry.Path)
447-
if err != nil {
448-
fmt.Fprintf(os.Stderr, "Warning: Failed to remove %s: %v\n", entry.Path, err)
449-
}
450-
}
451-
}
452-
453-
// Recheck cache size after age-based cleanup
454-
info, err = getCacheInfo(cacheDir)
455-
if err != nil {
456-
return err
457-
}
458-
459-
// If still over size limit, remove oldest entries until under limit
460-
if info.Size > maxSizeBytes {
461-
// Re-scan entries after previous cleanup
462-
entries, err = filepath.Glob(filepath.Join(cacheDir, "*"))
463-
if err != nil {
464-
return err
465-
}
466-
467-
// Rebuild sorted entries
468-
sortedEntries = []Entry{}
469-
for _, path := range entries {
470-
info, err := os.Stat(path)
471-
if err != nil {
472-
continue
473-
}
474-
if info.IsDir() {
475-
sortedEntries = append(sortedEntries, Entry{
476-
Path: path,
477-
ModTime: info.ModTime(),
478-
})
479-
}
480-
}
481-
482-
// Remove oldest entries until under size limit
483-
for _, entry := range sortedEntries {
484-
err := os.RemoveAll(entry.Path)
485-
if err != nil {
486-
fmt.Fprintf(os.Stderr, "Warning: Failed to remove %s: %v\n", entry.Path, err)
487-
continue
488-
}
489-
490-
// Recheck cache size after removal
491-
info, err = getCacheInfo(cacheDir)
492-
if err != nil {
493-
return err
494-
}
495-
496-
if info.Size <= maxSizeBytes {
497-
break
498-
}
499-
}
500-
}
501-
502-
return nil
503-
}
504-
505392
// flushCache completely empties the cache but preserves the index.json file
506393
func flushCache(cacheDir string) error {
507394
// Check if cache directory exists

cmd/jb/init_test.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,15 +18,14 @@
1818
package main
1919

2020
import (
21-
"io/ioutil"
2221
"os"
2322
"testing"
2423

2524
"github.com/stretchr/testify/assert"
2625
)
2726

2827
func TestInitCommand(t *testing.T) {
29-
tempDir, err := ioutil.TempDir("", "jb-init")
28+
tempDir, err := os.MkdirTemp("", "jb-init")
3029
if err != nil {
3130
t.Fatal(err)
3231
}

cmd/jb/install.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@ package main
1616

1717
import (
1818
"encoding/json"
19-
"io/ioutil"
2019
"log"
2120
"os"
2221
"path/filepath"
@@ -36,13 +35,13 @@ func installCommand(dir, jsonnetHome string, uris []string, single bool, legacyN
3635
dir = "."
3736
}
3837

39-
jbfilebytes, err := ioutil.ReadFile(filepath.Join(dir, jsonnetfile.File))
38+
jbfilebytes, err := os.ReadFile(filepath.Join(dir, jsonnetfile.File))
4039
kingpin.FatalIfError(err, "failed to load jsonnetfile")
4140

4241
jsonnetFile, err := jsonnetfile.Unmarshal(jbfilebytes)
4342
kingpin.FatalIfError(err, "")
4443

45-
jblockfilebytes, err := ioutil.ReadFile(filepath.Join(dir, jsonnetfile.LockFile))
44+
jblockfilebytes, err := os.ReadFile(filepath.Join(dir, jsonnetfile.LockFile))
4645
if !os.IsNotExist(err) {
4746
kingpin.FatalIfError(err, "failed to load lockfile")
4847
}
@@ -114,7 +113,7 @@ func writeJSONFile(name string, d interface{}) error {
114113
}
115114
b = append(b, []byte("\n")...)
116115

117-
return ioutil.WriteFile(name, b, 0644)
116+
return os.WriteFile(name, b, 0644)
118117
}
119118

120119
func writeChangedJsonnetFile(originalBytes []byte, modified *v1.JsonnetFile, path string) error {

cmd/jb/update_test.go

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818
package main
1919

2020
import (
21-
"io/ioutil"
2221
"os"
2322
"path/filepath"
2423
"testing"
@@ -46,10 +45,10 @@ func (rs RepoState) LockPath(dir string) string {
4645

4746
// Write writes this state to dir
4847
func (rs RepoState) Write(dir string) error {
49-
if err := ioutil.WriteFile(rs.FilePath(dir), []byte(rs.File), 0644); err != nil {
48+
if err := os.WriteFile(rs.FilePath(dir), []byte(rs.File), 0644); err != nil {
5049
return err
5150
}
52-
if err := ioutil.WriteFile(rs.LockPath(dir), []byte(rs.Lock), 0644); err != nil {
51+
if err := os.WriteFile(rs.LockPath(dir), []byte(rs.Lock), 0644); err != nil {
5352
return err
5453
}
5554
if err := os.MkdirAll(filepath.Join(dir, "vendor/"), os.ModePerm); err != nil {
@@ -60,11 +59,11 @@ func (rs RepoState) Write(dir string) error {
6059

6160
// Assert checks that dir matches this state
6261
func (rs RepoState) Assert(t *testing.T, dir string) {
63-
file, err := ioutil.ReadFile(rs.FilePath(dir))
62+
file, err := os.ReadFile(rs.FilePath(dir))
6463
require.NoError(t, err)
6564
assert.JSONEq(t, rs.File, string(file))
6665

67-
lock, err := ioutil.ReadFile(rs.LockPath(dir))
66+
lock, err := os.ReadFile(rs.LockPath(dir))
6867
require.NoError(t, err)
6968
assert.JSONEq(t, rs.Lock, string(lock))
7069
}
@@ -78,7 +77,7 @@ type UpdateCase struct {
7877
}
7978

8079
func (u UpdateCase) Run(t *testing.T) {
81-
dir, err := ioutil.TempDir("", u.name)
80+
dir, err := os.MkdirTemp("", u.name)
8281
require.NoError(t, err)
8382
defer os.RemoveAll(dir)
8483

0 commit comments

Comments
 (0)