package workers import ( "path" "time" "github.com/photoprism/photoprism/internal/entity" "github.com/photoprism/photoprism/internal/event" "github.com/photoprism/photoprism/internal/mutex" "github.com/photoprism/photoprism/internal/photoprism" "github.com/photoprism/photoprism/internal/query" "github.com/photoprism/photoprism/internal/remote/webdav" "github.com/photoprism/photoprism/pkg/clean" ) // Uploads local files to a remote account func (w *Sync) upload(a entity.Service) (complete bool, err error) { maxResults := 250 // Get upload file list from database files, err := query.AccountUploads(a, maxResults) if err != nil { return false, err } if len(files) == 0 { log.Infof("sync: upload complete for %s", a.AccName) event.Publish("sync.uploaded", event.Data{"account": a}) return true, nil } client, err := webdav.NewClient(a.AccURL, a.AccUser, a.AccPass, webdav.Timeout(a.AccTimeout)) if err != nil { return false, err } for _, file := range files { if mutex.SyncWorker.Canceled() { return false, nil } fileName := photoprism.FileName(file.FileRoot, file.FileName) remoteName := path.Join(a.SyncPath, file.FileName) remoteDir := path.Dir(remoteName) // Ensure remote folder exists. if err := client.MkdirAll(remoteDir); err != nil { log.Debugf("sync: %s", err) } if err := client.Upload(fileName, remoteName); err != nil { w.logError(err) continue // try again next time } log.Infof("sync: uploaded %s to %s (%s)", clean.Log(file.FileName), clean.Log(remoteName), a.AccName) fileSync := entity.NewFileSync(a.ID, remoteName) fileSync.Status = entity.FileSyncUploaded fileSync.RemoteDate = time.Now() fileSync.RemoteSize = file.FileSize fileSync.FileID = file.ID fileSync.Error = "" fileSync.Errors = 0 if mutex.SyncWorker.Canceled() { return false, nil } w.logError(entity.Db().Save(&fileSync).Error) } return false, nil }