2020-04-07 12:51:01 +02:00
|
|
|
package query
|
|
|
|
|
|
|
|
import (
|
|
|
|
"github.com/photoprism/photoprism/internal/entity"
|
|
|
|
"github.com/photoprism/photoprism/pkg/fs"
|
|
|
|
)
|
|
|
|
|
|
|
|
// AccountUploads a list of files for uploading to a remote account.
|
2022-10-15 21:54:11 +02:00
|
|
|
func AccountUploads(a entity.Service, limit int) (results entity.Files, err error) {
|
2020-05-08 15:41:01 +02:00
|
|
|
s := Db().Where("files.file_missing = 0").
|
2022-10-15 21:54:11 +02:00
|
|
|
Where("files.id NOT IN (SELECT file_id FROM files_sync WHERE file_id > 0 AND service_id = ?)", a.ID)
|
2020-04-07 12:51:01 +02:00
|
|
|
|
|
|
|
if !a.SyncRaw {
|
2022-10-07 16:45:49 +02:00
|
|
|
s = s.Where("files.file_type <> ? OR files.file_type IS NULL", fs.ImageRaw)
|
2020-04-07 12:51:01 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
s = s.Order("files.file_name ASC")
|
|
|
|
|
|
|
|
if limit > 0 {
|
|
|
|
s = s.Limit(limit).Offset(0)
|
|
|
|
}
|
|
|
|
|
|
|
|
if result := s.Find(&results); result.Error != nil {
|
|
|
|
return results, result.Error
|
|
|
|
}
|
|
|
|
|
|
|
|
return results, nil
|
|
|
|
}
|