7 Commits

Author SHA1 Message Date
92c1ce74e5 1.1.2 2025-08-08 09:59:07 -07:00
8e5a94e8d8 actually fix version updates 2025-08-08 09:58:46 -07:00
61e17cffc5 1.1.1 2025-08-08 09:48:56 -07:00
e7b5215d0f fix version check 2025-08-08 09:47:48 -07:00
336340269b 1.1.0 2025-08-08 09:30:16 -07:00
f8ebb74fc9 download msg 2025-08-08 09:29:16 -07:00
ccd2586c8d use channel for status messages 2025-08-08 09:27:39 -07:00
4 changed files with 161 additions and 122 deletions

1
go.mod
View File

@@ -4,6 +4,7 @@ go 1.24.3
require ( require (
github.com/BurntSushi/toml v1.5.0 github.com/BurntSushi/toml v1.5.0
github.com/Masterminds/semver/v3 v3.4.0
github.com/go-ole/go-ole v1.3.0 github.com/go-ole/go-ole v1.3.0
) )

2
go.sum
View File

@@ -1,5 +1,7 @@
github.com/BurntSushi/toml v1.5.0 h1:W5quZX/G/csjUnuI8SUYlsHs9M38FC7znL0lIO+DvMg= github.com/BurntSushi/toml v1.5.0 h1:W5quZX/G/csjUnuI8SUYlsHs9M38FC7znL0lIO+DvMg=
github.com/BurntSushi/toml v1.5.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho= github.com/BurntSushi/toml v1.5.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=
github.com/Masterminds/semver/v3 v3.4.0 h1:Zog+i5UMtVoCU8oKka5P7i9q9HgrJeGzI9SA1Xbatp0=
github.com/Masterminds/semver/v3 v3.4.0/go.mod h1:4V+yj/TJE1HU9XfppCwVMZq3I84lprf4nC11bSS5beM=
github.com/go-ole/go-ole v1.3.0 h1:Dt6ye7+vXGIKZ7Xtk4s6/xVdGDQynvom7xCFEdWr6uE= github.com/go-ole/go-ole v1.3.0 h1:Dt6ye7+vXGIKZ7Xtk4s6/xVdGDQynvom7xCFEdWr6uE=
github.com/go-ole/go-ole v1.3.0/go.mod h1:5LS6F96DhAwUc7C+1HLexzMXY1xGRSryjyPPKW6zv78= github.com/go-ole/go-ole v1.3.0/go.mod h1:5LS6F96DhAwUc7C+1HLexzMXY1xGRSryjyPPKW6zv78=
golang.org/x/sys v0.1.0 h1:kunALQeHf1/185U1i0GOB/fy1IPRDDpuoOOqRReG57U= golang.org/x/sys v0.1.0 h1:kunALQeHf1/185U1i0GOB/fy1IPRDDpuoOOqRReG57U=

View File

@@ -10,142 +10,159 @@ import (
"os" "os"
"path/filepath" "path/filepath"
"regexp" "regexp"
"slices"
"strings" "strings"
) )
type UpdateStats struct { type UpdateStats struct {
Updated int Updated int
Current int Current int
Outdated int Outdated int
LogMessages []string Error error
Error error MessageBuf []string
} }
func Update(wowdir string, force bool, removeUnknown bool, skipDownload bool) UpdateStats { func Update(wowdir string, force bool, removeUnknown bool, skipDownload bool) UpdateStats {
stats := UpdateStats{ stats := UpdateStats{
LogMessages: make([]string, 0), Error: nil,
Error: nil, MessageBuf: make([]string, 0),
} }
manifest, err := GetManifest() msgChan := make(chan string)
if err != nil { done := make(chan bool)
stats.Error = fmt.Errorf("Failed to get manifest: %v\n", err)
return stats
}
for _, file := range manifest.Files { go func() {
path := strings.ReplaceAll(file.Path, `\`, `/`) manifest, err := GetManifest()
path = strings.TrimLeft(path, `\`) if err != nil {
stats.Error = fmt.Errorf("Failed to get manifest: %v\n", err)
localPath := filepath.Join(wowdir, path) done <- true
localDir := filepath.Dir(localPath) return
if _, err = os.Stat(localDir); os.IsNotExist(err) {
err = os.MkdirAll(localDir, 0755)
if err != nil {
stats.Error = fmt.Errorf("failed to create directory %s: %v", localDir, err)
return stats
}
} }
if !force {
if _, err = os.Stat(localPath); err == nil {
data, err := os.ReadFile(localPath)
if err != nil {
stats.Error = fmt.Errorf("failed to read %s: %v", localPath, err)
return stats
}
hashBytes := md5.Sum(data)
hash := hex.EncodeToString(hashBytes[:])
if hash == file.Hash {
stats.LogMessages = append(stats.LogMessages, fmt.Sprintf("File %s is up to date", localPath))
stats.Current += 1
continue
} else {
stats.Outdated += 1
}
}
}
if !skipDownload {
outFile, err := os.Create(localPath)
if err != nil {
stats.Error = fmt.Errorf("failed to create file %s: %v", localPath, err)
return stats
}
downloadSuccess := false
for _, url := range []string{file.Urls.Cloudflare, file.Urls.Digitalocean, file.Urls.None} {
resp, err := http.Get(url)
if err != nil {
if resp != nil {
resp.Body.Close()
}
stats.LogMessages = append(stats.LogMessages, fmt.Sprintf("Failed to download %s: %v", url, err))
continue
}
if resp.StatusCode != http.StatusOK {
resp.Body.Close()
stats.LogMessages = append(stats.LogMessages, fmt.Sprintf("HTTP Status %d", resp.StatusCode))
continue
}
_, err = io.Copy(outFile, resp.Body)
if err != nil {
stats.LogMessages = append(stats.LogMessages, fmt.Sprintf("Failed to write file %s: %v", localPath, err))
resp.Body.Close()
continue
}
resp.Body.Close()
downloadSuccess = true
stats.LogMessages = append(stats.LogMessages, fmt.Sprintf("Successfully downloaded %s", localPath))
break
}
outFile.Close()
if !downloadSuccess {
stats.Error = fmt.Errorf("Failed to download updates, see above messages")
return stats
}
stats.Updated += 1
}
}
if removeUnknown {
patches := make([]string, 0)
patchreg := regexp.MustCompile(`patch-[A-Za-z].MPQ`)
for _, file := range manifest.Files { for _, file := range manifest.Files {
if patchreg.MatchString(file.Path) { path := strings.ReplaceAll(file.Path, `\`, `/`)
patches = append(patches, strings.Split(file.Path, "Data\\")[1]) path = strings.TrimLeft(path, `\`)
localPath := filepath.Join(wowdir, path)
localDir := filepath.Dir(localPath)
if _, err = os.Stat(localDir); os.IsNotExist(err) {
err = os.MkdirAll(localDir, 0755)
if err != nil {
stats.Error = fmt.Errorf("failed to create directory %s: %v", localDir, err)
done <- true
return
}
}
if !force {
if _, err = os.Stat(localPath); err == nil {
data, err := os.ReadFile(localPath)
if err != nil {
stats.Error = fmt.Errorf("failed to read %s: %v", localPath, err)
done <- true
return
}
hashBytes := md5.Sum(data)
hash := hex.EncodeToString(hashBytes[:])
if hash == file.Hash {
msgChan <- fmt.Sprintf("File %s is up to date", localPath)
stats.Current += 1
continue
} else {
stats.Outdated += 1
}
}
}
if !skipDownload {
msgChan <- fmt.Sprintf("Downloading %s", localPath)
outFile, err := os.Create(localPath)
if err != nil {
stats.Error = fmt.Errorf("failed to create file %s: %v", localPath, err)
done <- true
return
}
downloadSuccess := false
for _, url := range []string{file.Urls.Cloudflare, file.Urls.Digitalocean, file.Urls.None} {
resp, err := http.Get(url)
if err != nil {
if resp != nil {
resp.Body.Close()
}
msgChan <- fmt.Sprintf("Failed to download %s: %v", url, err)
continue
}
if resp.StatusCode != http.StatusOK {
resp.Body.Close()
msgChan <- fmt.Sprintf("HTTP Status %d", resp.StatusCode)
continue
}
_, err = io.Copy(outFile, resp.Body)
if err != nil {
msgChan <- fmt.Sprintf("Failed to write file %s: %v", localPath, err)
resp.Body.Close()
continue
}
resp.Body.Close()
downloadSuccess = true
msgChan <- fmt.Sprintf("Successfully downloaded %s", localPath)
break
}
outFile.Close()
if !downloadSuccess {
stats.Error = fmt.Errorf("Failed to download updates, see above messages")
done <- true
return
}
stats.Updated += 1
} }
} }
err = filepath.WalkDir(filepath.Join(wowdir, "Data"), func(path string, d fs.DirEntry, err error) error { if removeUnknown {
if !d.IsDir() && patchreg.MatchString(d.Name()) { patches := make([]string, 0)
del := true patchreg := regexp.MustCompile(`patch-[A-Za-z].MPQ`)
for _, patch := range patches {
if patch == d.Name() { for _, file := range manifest.Files {
del = false if patchreg.MatchString(file.Path) {
break patches = append(patches, strings.Split(file.Path, "Data\\")[1])
}
}
if del {
err = os.Remove(path)
if err != nil {
return err
}
stats.LogMessages = append(stats.LogMessages, fmt.Sprintf("Removed unknown patch %s", d.Name()))
} }
} }
return nil
})
if err != nil { err = filepath.WalkDir(filepath.Join(wowdir, "Data"), func(path string, d fs.DirEntry, err error) error {
stats.Error = fmt.Errorf("failed to delete unknown patches: %v", err) if !d.IsDir() && patchreg.MatchString(d.Name()) {
del := true
if slices.Contains(patches, d.Name()) {
del = false
}
if del {
err = os.Remove(path)
if err != nil {
return err
}
msgChan <- fmt.Sprintf("Removed unknown patch %s", d.Name())
}
}
return nil
})
if err != nil {
stats.Error = fmt.Errorf("failed to delete unknown patches: %v", err)
}
}
done <- true
}()
for {
select {
case msg := <-msgChan:
fmt.Println(msg)
stats.MessageBuf = append(stats.MessageBuf, msg)
case <-done:
return stats
} }
} }
return stats
} }

View File

@@ -5,10 +5,14 @@ import (
"io" "io"
"net/http" "net/http"
"regexp" "regexp"
"github.com/Masterminds/semver/v3"
) )
const version = "1.0.10" const (
const versionUrl = "https://git.burkey.co/eburk/epochcli/raw/branch/master/version.go" version = "1.1.2"
versionUrl = "https://git.burkey.co/eburk/epochcli/raw/branch/master/version.go"
)
func needUpdate() (bool, error) { func needUpdate() (bool, error) {
resp, err := http.Get(versionUrl) resp, err := http.Get(versionUrl)
@@ -26,11 +30,26 @@ func needUpdate() (bool, error) {
return false, fmt.Errorf("unable to read response body: %v", err) return false, fmt.Errorf("unable to read response body: %v", err)
} }
re := regexp.MustCompile(`const version = "([\d.]+)"`) re := regexp.MustCompile(`version\s+=\s+"(\d+.\d+.\d+)"`)
ver := re.FindStringSubmatch(string(b)) ver := re.FindStringSubmatch(string(b))
if len(ver) < 2 || ver[1] == "" { if ver[1] == "" {
return false, fmt.Errorf("unable to find version in response") return false, fmt.Errorf("unable to parse version number")
} }
return ver[1] != version, nil curVer, err := semver.NewVersion(version)
if err != nil {
return false, fmt.Errorf("unable to parse current version to semver: %v", err)
}
newVer, err := semver.NewVersion(ver[1])
if err != nil {
return false, fmt.Errorf("unable to parse new version to semver: %v", err)
}
if curVer.LessThan(newVer) {
fmt.Println("Current Version: ", curVer)
fmt.Println("Latest Version: ", newVer)
return true, nil
}
return false, nil
} }