mirror of https://github.com/jetkvm/kvm.git
46 lines
1.1 KiB
Go
46 lines
1.1 KiB
Go
package ota
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
)
|
|
|
|
const (
|
|
appUpdatePath = "/userdata/jetkvm/jetkvm_app.update"
|
|
)
|
|
|
|
// DO NOT call it directly, it's not thread safe
|
|
// Mutex is currently held by the caller, e.g. doUpdate
|
|
func (s *State) updateApp(ctx context.Context, appUpdate *componentUpdateStatus) error {
|
|
l := s.l.With().Str("path", appUpdatePath).Logger()
|
|
|
|
if err := s.downloadFile(ctx, appUpdatePath, appUpdate.url, "app"); err != nil {
|
|
return s.componentUpdateError("Error downloading app update", err, &l)
|
|
}
|
|
|
|
downloadFinished := time.Now()
|
|
appUpdate.downloadFinishedAt = downloadFinished
|
|
appUpdate.downloadProgress = 1
|
|
s.triggerComponentUpdateState("app", appUpdate)
|
|
|
|
if err := s.verifyFile(
|
|
appUpdatePath,
|
|
appUpdate.hash,
|
|
&appUpdate.verificationProgress,
|
|
); err != nil {
|
|
return s.componentUpdateError("Error verifying app update hash", err, &l)
|
|
}
|
|
verifyFinished := time.Now()
|
|
appUpdate.verifiedAt = verifyFinished
|
|
appUpdate.verificationProgress = 1
|
|
appUpdate.updatedAt = verifyFinished
|
|
appUpdate.updateProgress = 1
|
|
s.triggerComponentUpdateState("app", appUpdate)
|
|
|
|
l.Info().Msg("App update downloaded")
|
|
|
|
s.rebootNeeded = true
|
|
|
|
return nil
|
|
}
|