diff --git a/cmd/cli/commands/sync/sync.go b/cmd/cli/commands/sync/sync.go index 936aab5..6fcdf8d 100644 --- a/cmd/cli/commands/sync/sync.go +++ b/cmd/cli/commands/sync/sync.go @@ -49,7 +49,7 @@ func (p *SyncCmd) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) r, err := remote.One(g.ID) if err != nil { if errors.Is(err, remote.ErrNoRemote) { - fmt.Println(g.Name + ": no remote configured") + fmt.Println("⬛", g.Name+": no remote configured") continue } fmt.Fprintln(os.Stderr, "error: failed to load datastore:", err) @@ -88,7 +88,7 @@ func (p *SyncCmd) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) slog.Warn("failed to push backup files", "err", err) } destroyPg() - fmt.Println(g.Name + ": pushed") + fmt.Println("⬆️", g.Name+": pushed") continue } @@ -120,7 +120,7 @@ func (p *SyncCmd) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) continue } } - fmt.Println(g.Name + ": already up-to-date") + fmt.Println("🆗", g.Name+": already up-to-date") continue } @@ -132,13 +132,13 @@ func (p *SyncCmd) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) return subcommands.ExitFailure } destroyPg() - fmt.Println(g.Name + ": pushed") + fmt.Println("⬆️", g.Name+": pushed") continue } if g.Version < remoteMetadata.Version { destroyPg() - if err := p.pull(r.GameID, cli); err != nil { + if err := p.pull(g, cli); err != nil { destroyPg() fmt.Fprintln(os.Stderr, "failed to push:", err) return subcommands.ExitFailure @@ -152,7 +152,7 @@ func (p *SyncCmd) Execute(_ context.Context, f *flag.FlagSet, _ ...interface{}) fmt.Fprintln(os.Stderr, "failed to push:", err) return subcommands.ExitFailure } - fmt.Println(g.Name + ": pulled") + fmt.Println("⬇️", g.Name+": pulled") continue } @@ -179,7 +179,7 @@ func (p *SyncCmd) conflict(gameID string, m, remoteMetadata repository.Metadata, return nil } fmt.Println() - fmt.Println("--- /!\\ CONFLICT ---") + fmt.Println("--- ⚠️ CONFLICT ---") fmt.Println(g.Name, "(", g.Path, ")") fmt.Println("----") fmt.Println("Your version:", g.Date.Format(time.RFC1123)) @@ -198,7 +198,7 @@ func (p *SyncCmd) conflict(gameID string, m, remoteMetadata repository.Metadata, case prompt.Their: { - if err := p.pull(gameID, cli); err != nil { + if err := p.pull(g, cli); err != nil { return fmt.Errorf("failed to push: %w", err) } g.Version = remoteMetadata.Version @@ -266,8 +266,11 @@ func (p *SyncCmd) pullBackup(m repository.Metadata, cli *client.Client) error { return nil } -func (p *SyncCmd) pull(gameID string, cli *client.Client) error { - return p.Service.PullArchive(gameID, "", cli) +func (p *SyncCmd) pull(g repository.Metadata, cli *client.Client) error { + if err := p.Service.PullArchive(g.ID, "", cli); err != nil { + return err + } + return p.Service.ApplyCurrent(g.ID) } func connect(remoteCred map[string]map[string]string, r remote.Remote) (*client.Client, error) { @@ -278,6 +281,9 @@ func connect(remoteCred map[string]map[string]string, r remote.Remote) (*client. return cli, nil } + fmt.Println() + fmt.Println("Connexion to", r.URL) + fmt.Println("============") username, password, err := credentials.Read() if err != nil { return nil, fmt.Errorf("failed to read std output: %w", err) diff --git a/cmd/server/main_windows.go b/cmd/server/main_windows.go index e7e7a85..70b14e0 100644 --- a/cmd/server/main_windows.go +++ b/cmd/server/main_windows.go @@ -2,12 +2,19 @@ package main import ( "cloudsave/pkg/tools/windows" + _ "embed" "os" + + "github.com/getlantern/systray" ) -const defaultDocumentRoot string = "C:/ProgramData/CloudSave" +const defaultDocumentRoot string = "C:\\ProgramData\\CloudSave" + +//go:embed res/icon.ico +var icon []byte func main() { + go systray.Run(onReady, onExit) run() } @@ -15,3 +22,20 @@ func fatal(message string, exitCode int) { windows.MessageBox(windows.NULL, message, "CloudSave", windows.MB_OK) os.Exit(exitCode) } + +func onReady() { + systray.SetTitle("CloudSave") + systray.SetTooltip("CloudSave") + systray.SetIcon(icon) + + mQuit := systray.AddMenuItem("Quit", "Quit") + + go func() { + <-mQuit.ClickedCh + os.Exit(0) + }() +} + +func onExit() { + // clean up here +} diff --git a/cmd/server/res/icon.ico b/cmd/server/res/icon.ico new file mode 100644 index 0000000..b45b20a Binary files /dev/null and b/cmd/server/res/icon.ico differ diff --git a/go.mod b/go.mod index 851103c..29ad3a5 100644 --- a/go.mod +++ b/go.mod @@ -3,6 +3,7 @@ module cloudsave go 1.24 require ( + github.com/getlantern/systray v1.2.2 github.com/go-chi/chi/v5 v5.2.1 github.com/google/subcommands v1.2.0 github.com/google/uuid v1.6.0 @@ -12,7 +13,15 @@ require ( ) require ( + github.com/getlantern/context v0.0.0-20190109183933-c447772a6520 // indirect + github.com/getlantern/errors v0.0.0-20190325191628-abdb3e3e36f7 // indirect + github.com/getlantern/golog v0.0.0-20190830074920-4ef2e798c2d7 // indirect + github.com/getlantern/hex v0.0.0-20190417191902-c6586a6fe0b7 // indirect + github.com/getlantern/hidden v0.0.0-20190325191715-f02dbb02be55 // indirect + github.com/getlantern/ops v0.0.0-20190325191751-d70cb0d6f85f // indirect + github.com/go-stack/stack v1.8.0 // indirect github.com/mitchellh/colorstring v0.0.0-20190213212951-d06e56a500db // indirect + github.com/oxtoacart/bpool v0.0.0-20190530202638-03653db5a59c // indirect github.com/rivo/uniseg v0.4.7 // indirect golang.org/x/sys v0.33.0 // indirect ) diff --git a/go.sum b/go.sum index 29e363d..9dc734f 100644 --- a/go.sum +++ b/go.sum @@ -1,30 +1,57 @@ github.com/chengxilo/virtualterm v1.0.4 h1:Z6IpERbRVlfB8WkOmtbHiDbBANU7cimRIof7mk9/PwM= github.com/chengxilo/virtualterm v1.0.4/go.mod h1:DyxxBZz/x1iqJjFxTFcr6/x+jSpqN0iwWCOK1q10rlY= +github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/getlantern/context v0.0.0-20190109183933-c447772a6520 h1:NRUJuo3v3WGC/g5YiyF790gut6oQr5f3FBI88Wv0dx4= +github.com/getlantern/context v0.0.0-20190109183933-c447772a6520/go.mod h1:L+mq6/vvYHKjCX2oez0CgEAJmbq1fbb/oNJIWQkBybY= +github.com/getlantern/errors v0.0.0-20190325191628-abdb3e3e36f7 h1:6uJ+sZ/e03gkbqZ0kUG6mfKoqDb4XMAzMIwlajq19So= +github.com/getlantern/errors v0.0.0-20190325191628-abdb3e3e36f7/go.mod h1:l+xpFBrCtDLpK9qNjxs+cHU6+BAdlBaxHqikB6Lku3A= +github.com/getlantern/golog v0.0.0-20190830074920-4ef2e798c2d7 h1:guBYzEaLz0Vfc/jv0czrr2z7qyzTOGC9hiQ0VC+hKjk= +github.com/getlantern/golog v0.0.0-20190830074920-4ef2e798c2d7/go.mod h1:zx/1xUUeYPy3Pcmet8OSXLbF47l+3y6hIPpyLWoR9oc= +github.com/getlantern/hex v0.0.0-20190417191902-c6586a6fe0b7 h1:micT5vkcr9tOVk1FiH8SWKID8ultN44Z+yzd2y/Vyb0= +github.com/getlantern/hex v0.0.0-20190417191902-c6586a6fe0b7/go.mod h1:dD3CgOrwlzca8ed61CsZouQS5h5jIzkK9ZWrTcf0s+o= +github.com/getlantern/hidden v0.0.0-20190325191715-f02dbb02be55 h1:XYzSdCbkzOC0FDNrgJqGRo8PCMFOBFL9py72DRs7bmc= +github.com/getlantern/hidden v0.0.0-20190325191715-f02dbb02be55/go.mod h1:6mmzY2kW1TOOrVy+r41Za2MxXM+hhqTtY3oBKd2AgFA= +github.com/getlantern/ops v0.0.0-20190325191751-d70cb0d6f85f h1:wrYrQttPS8FHIRSlsrcuKazukx/xqO/PpLZzZXsF+EA= +github.com/getlantern/ops v0.0.0-20190325191751-d70cb0d6f85f/go.mod h1:D5ao98qkA6pxftxoqzibIBBrLSUli+kYnJqrgBf9cIA= +github.com/getlantern/systray v1.2.2 h1:dCEHtfmvkJG7HZ8lS/sLklTH4RKUcIsKrAD9sThoEBE= +github.com/getlantern/systray v1.2.2/go.mod h1:pXFOI1wwqwYXEhLPm9ZGjS2u/vVELeIgNMY5HvhHhcE= github.com/go-chi/chi/v5 v5.2.1 h1:KOIHODQj58PmL80G2Eak4WdvUzjSJSm0vG72crDCqb8= github.com/go-chi/chi/v5 v5.2.1/go.mod h1:L2yAIGWB3H+phAw1NxKwWM+7eUH/lU8pOMm5hHcoops= +github.com/go-stack/stack v1.8.0 h1:5SgMzNM5HxrEjV0ww2lTmX6E2Izsfxas4+YHWRs3Lsk= +github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY= github.com/google/subcommands v1.2.0 h1:vWQspBTo2nEqTUFita5/KeEWlUL8kQObDFbub/EN9oE= github.com/google/subcommands v1.2.0/go.mod h1:ZjhPrFU+Olkh9WazFPsl27BQ4UPiG37m3yTrtFlrHVk= github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/lxn/walk v0.0.0-20210112085537-c389da54e794/go.mod h1:E23UucZGqpuUANJooIbHWCufXvOcT6E7Stq81gU+CSQ= +github.com/lxn/win v0.0.0-20210218163916-a377121e959e/go.mod h1:KxxjdtRkfNoYDCUP5ryK7XJJNTnpC8atvtmTheChOtk= github.com/mattn/go-runewidth v0.0.16 h1:E5ScNMtiwvlvB5paMFdw9p4kSQzbXFikJ5SQO6TULQc= github.com/mattn/go-runewidth v0.0.16/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w= github.com/mitchellh/colorstring v0.0.0-20190213212951-d06e56a500db h1:62I3jR2EmQ4l5rM/4FEfDWcRD+abF5XlKShorW5LRoQ= github.com/mitchellh/colorstring v0.0.0-20190213212951-d06e56a500db/go.mod h1:l0dey0ia/Uv7NcFFVbCLtqEBQbrT4OCwCSKTEv6enCw= +github.com/oxtoacart/bpool v0.0.0-20190530202638-03653db5a59c h1:rp5dCmg/yLR3mgFuSOe4oEnDDmGLROTvMragMUXpTQw= +github.com/oxtoacart/bpool v0.0.0-20190530202638-03653db5a59c/go.mod h1:X07ZCGwUbLaax7L0S3Tw4hpejzu63ZrrQiUe6W0hcy0= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/rivo/uniseg v0.4.7 h1:WUdvkW8uEhrYfLC4ZzdpI2ztxP1I582+49Oc5Mq64VQ= github.com/rivo/uniseg v0.4.7/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88= github.com/schollz/progressbar/v3 v3.18.0 h1:uXdoHABRFmNIjUfte/Ex7WtuyVslrw2wVPQmCN62HpA= github.com/schollz/progressbar/v3 v3.18.0/go.mod h1:IsO3lpbaGuzh8zIMzgY3+J8l4C8GjO0Y9S69eFvNsec= +github.com/skratchdot/open-golang v0.0.0-20200116055534-eef842397966/go.mod h1:sUM3LWHvSMaG192sy56D9F7CNvL7jUJVXoqM1QKLnog= +github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= +github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI= github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg= github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= golang.org/x/crypto v0.38.0 h1:jt+WWG8IZlBnVbomuhg2Mdq0+BBQaHbtqHEFEigjUV8= golang.org/x/crypto v0.38.0/go.mod h1:MvrbAqul58NNYPKnOra203SB9vpuZW0e+RRZV+Ggqjw= +golang.org/x/sys v0.0.0-20201018230417-eeed37f84f13/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.1.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw= golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k= golang.org/x/term v0.32.0 h1:DR4lr0TjUs3epypdhTOkMmuF5CDFJ/8pOnbzMZPQ7bg= golang.org/x/term v0.32.0/go.mod h1:uZG1FhGx848Sqfsq4/DlJr3xGGsYMu/L5GW4abiaEPQ= +gopkg.in/Knetic/govaluate.v3 v3.0.0/go.mod h1:csKLBORsPbafmSCGTEh3U7Ozmsuq8ZSIlKk1bcqph0E= gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/pkg/constants/constants.go b/pkg/constants/constants.go index adfccfd..cd821e8 100644 --- a/pkg/constants/constants.go +++ b/pkg/constants/constants.go @@ -1,5 +1,5 @@ package constants -const Version = "0.0.4c" +const Version = "0.0.5" const ApiVersion = 1 diff --git a/pkg/data/data.go b/pkg/data/data.go index a230f43..6644418 100644 --- a/pkg/data/data.go +++ b/pkg/data/data.go @@ -252,6 +252,12 @@ func (l Service) PullCurrent(id, path string, cli *client.Client) error { return fmt.Errorf("failed to open blob from local repository: %w", err) } + if _, err := os.Stat(path); err == nil { + if err := os.RemoveAll(path); err != nil { + return fmt.Errorf("failed to clean the destination directory: %w", err) + } + } + if err := os.MkdirAll(path, 0740); err != nil { return fmt.Errorf("failed to create destination directory: %w", err) } diff --git a/pkg/remote/client/client.go b/pkg/remote/client/client.go index 88f3454..7af433e 100644 --- a/pkg/remote/client/client.go +++ b/pkg/remote/client/client.go @@ -224,6 +224,11 @@ func (c *Client) Pull(gameID, archivePath string) error { if err != nil { return fmt.Errorf("failed to open file: %w", err) } + defer func() { + if err := os.Rename(archivePath+".part", archivePath); err != nil { + panic(err) + } + }() defer f.Close() res, err := cli.Do(req) @@ -246,8 +251,10 @@ func (c *Client) Pull(gameID, archivePath string) error { return fmt.Errorf("an error occured while copying the file from the remote: %w", err) } - if err := os.Rename(archivePath+".part", archivePath); err != nil { - return fmt.Errorf("failed to move temporary data: %w", err) + if err := os.Remove(archivePath); err != nil { + if !errors.Is(err, os.ErrNotExist) { + return fmt.Errorf("failed to remove the old version of the archive: %w", err) + } } return nil diff --git a/pkg/repository/repository.go b/pkg/repository/repository.go index 3b83b3d..3175ee3 100644 --- a/pkg/repository/repository.go +++ b/pkg/repository/repository.go @@ -73,7 +73,7 @@ type ( AllHist(gameID GameIdentifier) ([]string, error) WriteBlob(ID Identifier) (io.Writer, error) - WriteMetadata(gameID GameIdentifier, m Metadata) error + WriteMetadata(gameID GameIdentifier, m Metadata) error Metadata(gameID GameIdentifier) (Metadata, error) LastScan(gameID GameIdentifier) (time.Time, error)