60 lines
1.5 KiB
Go
60 lines
1.5 KiB
Go
package entity
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/jinzhu/gorm"
|
|
"github.com/photoprism/photoprism/internal/mutex"
|
|
)
|
|
|
|
const (
|
|
FileShareNew = "new"
|
|
FileShareError = "error"
|
|
FileShareShared = "shared"
|
|
FileShareRemoved = "removed"
|
|
)
|
|
|
|
// FileShare represents a one-to-many relation between File and Account for pushing files to remote services.
|
|
type FileShare struct {
|
|
FileID uint `gorm:"primary_key;auto_increment:false"`
|
|
AccountID uint `gorm:"primary_key;auto_increment:false"`
|
|
RemoteName string `gorm:"primary_key;auto_increment:false;type:varbinary(255)"`
|
|
Status string `gorm:"type:varbinary(16);"`
|
|
Error string `gorm:"type:varbinary(512);"`
|
|
Errors int
|
|
File *File
|
|
Account *Account
|
|
CreatedAt time.Time
|
|
UpdatedAt time.Time
|
|
}
|
|
|
|
// TableName returns the entity database table name.
|
|
func (FileShare) TableName() string {
|
|
return "files_share"
|
|
}
|
|
|
|
// NewFileShare creates a new entity.
|
|
func NewFileShare(fileID, accountID uint, remoteName string) *FileShare {
|
|
result := &FileShare{
|
|
FileID: fileID,
|
|
AccountID: accountID,
|
|
RemoteName: remoteName,
|
|
Status: "new",
|
|
Error: "",
|
|
Errors: 0,
|
|
}
|
|
|
|
return result
|
|
}
|
|
|
|
// FirstOrCreate returns the matching entity or creates a new one.
|
|
func (m *FileShare) FirstOrCreate(db *gorm.DB) *FileShare {
|
|
mutex.Db.Lock()
|
|
defer mutex.Db.Unlock()
|
|
|
|
if err := db.FirstOrCreate(m, "file_id = ? AND account_id = ? AND remote_name = ?", m.FileID, m.AccountID, m.RemoteName).Error; err != nil {
|
|
log.Errorf("file push: %s", err)
|
|
}
|
|
|
|
return m
|
|
}
|