catalog

package
v1.5.42 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 10, 2024 License: AGPL-3.0 Imports: 13 Imported by: 5

Documentation

Overview

Package catalog provides tools to maintain an index of all medias that have been backed up.

Index

Constants

This section is empty.

Variables

View Source 
var (
	AlbumNameMandatoryErr            = errors.New("Album name is mandatory")
	AlbumStartAndEndDateMandatoryErr = errors.New("Start and End times are mandatory")
	AlbumEndDateMustBeAfterStartErr  = errors.New("Album end must be strictly after its start")
)
View Source 
var (
	OrphanedMediasError  = errors.New("albums cannot be deleted if it make medias orphaned")
	AlbumIsNotEmptyError = errors.New("album is not empty")
)
View Source 
var (
	NotFoundError        = errors.New("album hasn't been found")
	EmptyOwnerError      = errors.New("owner is mandatory and must be not empty")
	EmptyFolderNameError = errors.New("folderName is mandatory and must be not empty")
)
View Source 
var (
	MediaNotFoundError = fmt.Errorf("media not found")
)

Functions

func AssignIdsToNewMedias 

func AssignIdsToNewMedias(owner Owner, signatures []*MediaSignature) (map[MediaSignature]string, error)

AssignIdsToNewMedias filters out signatures that are already known and compute a unique ID for the others.

func GenerateMediaId 

func GenerateMediaId(signature MediaSignature) (string, error)

GenerateMediaId generate a unique ID for a media.

func Init 

func Init(repositoryAdapter RepositoryAdapter, archive CArchiveAdapter)

Init must be called before using this package.

func InsertMedias 

func InsertMedias(owner Owner, medias []CreateMediaRequest) error

InsertMedias stores metadata and location of photo and videos

func RenameAlbum 

func RenameAlbum(currentId AlbumId, newName string, renameFolder bool) error

RenameAlbum updates the displayed named of the album. Optionally changes the folder in which media will be stored and flag all its media to be moved to the new one.

func UpdateAlbum 

func UpdateAlbum(albumId AlbumId, start, end time.Time) error

UpdateAlbum updates the dates of an album, medias will be re-assign between albums accordingly

Types

type Album 

type Album struct {
	AlbumId
	Name       string    // Name for displaying purpose, not unique
	Start      time.Time // Start is datetime inclusive
	End        time.Time // End is the datetime exclusive
	TotalCount int       // TotalCount is the number of media (of any type)
}

Album is a logical grouping of medias ; also used to physically store media next to each others.

func FindAlbum 

func FindAlbum(id AlbumId) (*Album, error)

FindAlbum get an album by its business key (its folder name), or returns NotFoundError

func FindAlbums 

func FindAlbums(keys []AlbumId) ([]*Album, error)

FindAlbums get several albums by their business keys

func FindAllAlbums 

func FindAllAlbums(owner Owner) ([]*Album, error)

FindAllAlbums find all albums owned by root user

func (Album) IsEqual 

func (a Album) IsEqual(other *Album) bool

IsEqual uses unique identifier to compare both albums

func (Album) String 

func (a Album) String() string

type AlbumId 

type AlbumId struct {
	Owner      Owner
	FolderName FolderName
}

func FindMediaOwnership 

func FindMediaOwnership(owner Owner, mediaId MediaId) (*AlbumId, error)

FindMediaOwnership returns the folderName containing the media, or NotFoundError.

func NewAlbumIdFromStrings added in v1.5.33 

func NewAlbumIdFromStrings(owner, folderName string) AlbumId

NewAlbumIdFromStrings creates an AlbumId from 2 strings ; it doesn't guaranty its validity, use AlbumId.IsValid to check if any error.

func (AlbumId) IsEqual added in v1.5.33 

func (a AlbumId) IsEqual(other AlbumId) bool

IsEqual uses unique identifier to compare both albums

func (AlbumId) IsValid added in v1.5.33 

func (a AlbumId) IsValid() error

func (AlbumId) String 

func (a AlbumId) String() string

type CArchiveAdapter 

type CArchiveAdapter interface {
	TimelineMutationObserver

	MoveMedias(owner Owner, ids []MediaId, name FolderName) error
}

CArchiveAdapter forward events to archive package

type CountMediasBySelectorsFunc added in v1.5.41 

type CountMediasBySelectorsFunc func(ctx context.Context, owner Owner, selectors []MediaSelector) (int, error)

func (CountMediasBySelectorsFunc) CountMediasBySelectors added in v1.5.41 

func (f CountMediasBySelectorsFunc) CountMediasBySelectors(ctx context.Context, owner Owner, selectors []MediaSelector) (int, error)

type CountMediasBySelectorsPort added in v1.5.41 

type CountMediasBySelectorsPort interface {
	CountMediasBySelectors(ctx context.Context, owner Owner, selectors []MediaSelector) (int, error)
}

type CreateAlbum 

type CreateAlbum struct {
	FindAlbumsByOwnerPort FindAlbumsByOwnerPort
	Observers             []CreateAlbumObserver
}

func NewAlbumCreate added in v1.5.42 

func NewAlbumCreate(
	FindAlbumsByOwnerPort FindAlbumsByOwnerPort,
	InsertAlbumPort InsertAlbumPort,
	TransferMediasPort TransferMediasPort,
	TimelineMutationObservers ...TimelineMutationObserver,
) *CreateAlbum

NewAlbumCreate creates the service to create a new album, including the transfer of medias

func (*CreateAlbum) Create added in v1.5.33 

func (c *CreateAlbum) Create(ctx context.Context, request CreateAlbumRequest) error

Create creates a new album

type CreateAlbumExecutor added in v1.5.42 

type CreateAlbumExecutor struct {
	InsertAlbumPort InsertAlbumPort
}

func (*CreateAlbumExecutor) ObserveCreateAlbum added in v1.5.42 

func (c *CreateAlbumExecutor) ObserveCreateAlbum(ctx context.Context, album Album, records MediaTransferRecords) error

type CreateAlbumMediaTransfer added in v1.5.42 

type CreateAlbumMediaTransfer struct {
	MediaTransfer
}

func (*CreateAlbumMediaTransfer) ObserveCreateAlbum added in v1.5.42 

func (c *CreateAlbumMediaTransfer) ObserveCreateAlbum(ctx context.Context, album Album, records MediaTransferRecords) error

type CreateAlbumObserver added in v1.5.42 

type CreateAlbumObserver interface {
	ObserveCreateAlbum(ctx context.Context, album Album, records MediaTransferRecords) error
}

type CreateAlbumObserverFunc added in v1.5.42 

type CreateAlbumObserverFunc func(ctx context.Context, album Album, records MediaTransferRecords) error

func (CreateAlbumObserverFunc) ObserveCreateAlbum added in v1.5.42 

func (f CreateAlbumObserverFunc) ObserveCreateAlbum(ctx context.Context, album Album, records MediaTransferRecords) error

type CreateAlbumRequest added in v1.5.33 

type CreateAlbumRequest struct {
	Owner            Owner
	Name             string
	Start            time.Time
	End              time.Time
	ForcedFolderName string
}

CreateAlbumRequest is a request to create a new album

func (*CreateAlbumRequest) IsValid added in v1.5.33 

func (c *CreateAlbumRequest) IsValid() error

func (*CreateAlbumRequest) String added in v1.5.33 

func (c *CreateAlbumRequest) String() string

type CreateMediaRequest 

type CreateMediaRequest struct {
	Id         MediaId        // Id is generated from its signature with GenerateMediaId(MediaSignature)
	Signature  MediaSignature // Signature is the business key of a media
	FolderName FolderName     // FolderName is the name of the album the media is in
	Filename   string         // Filename is a user-friendly name that have the right extension.
	Type       MediaType
	Details    MediaDetails
}

CreateMediaRequest is the request to add a new media to an album belonging to the same Owner

type DeleteAlbum 

type DeleteAlbum struct {
	FindAlbumsByOwner      FindAlbumsByOwnerPort
	CountMediasBySelectors CountMediasBySelectorsPort
	Observers              []DeleteAlbumObserver
}

func NewDeleteAlbum added in v1.5.41 

func NewDeleteAlbum(
	FindAlbumsByOwner FindAlbumsByOwnerPort,
	CountMediasBySelectors CountMediasBySelectorsPort,
	TransferMediasPort TransferMediasPort,
	DeleteAlbumRepository DeleteAlbumRepositoryPort,
	TimelineMutationObservers ...TimelineMutationObserver,
) *DeleteAlbum

NewDeleteAlbum creates a new DeleteAlbum service.

func (*DeleteAlbum) DeleteAlbum added in v1.5.41 

func (d *DeleteAlbum) DeleteAlbum(ctx context.Context, albumId AlbumId) error

DeleteAlbum delete an album, medias it contains are dispatched to other albums.

type DeleteAlbumMediaTransfer added in v1.5.41 

type DeleteAlbumMediaTransfer struct {
	MediaTransfer
}

func (*DeleteAlbumMediaTransfer) OnDeleteAlbum added in v1.5.42 

func (d *DeleteAlbumMediaTransfer) OnDeleteAlbum(ctx context.Context, deletedAlbum AlbumId, records MediaTransferRecords) error

type DeleteAlbumMetadata added in v1.5.41 

type DeleteAlbumMetadata struct {
	DeleteAlbumRepository DeleteAlbumRepositoryPort
}

func (*DeleteAlbumMetadata) OnDeleteAlbum added in v1.5.42 

func (d *DeleteAlbumMetadata) OnDeleteAlbum(ctx context.Context, deletedAlbum AlbumId, transfers MediaTransferRecords) error

type DeleteAlbumObserver added in v1.5.42 

type DeleteAlbumObserver interface {
	OnDeleteAlbum(ctx context.Context, deletedAlbum AlbumId, transfers MediaTransferRecords) error
}

type DeleteAlbumRepositoryFunc added in v1.5.41 

type DeleteAlbumRepositoryFunc func(ctx context.Context, albumId AlbumId) error

func (DeleteAlbumRepositoryFunc) DeleteAlbum added in v1.5.41 

func (f DeleteAlbumRepositoryFunc) DeleteAlbum(ctx context.Context, albumId AlbumId) error

type DeleteAlbumRepositoryPort added in v1.5.41 

type DeleteAlbumRepositoryPort interface {
	DeleteAlbum(ctx context.Context, albumId AlbumId) error
}

type FindAlbumsByOwnerFunc added in v1.5.41 

type FindAlbumsByOwnerFunc func(ctx context.Context, owner Owner) ([]*Album, error)

func (FindAlbumsByOwnerFunc) FindAlbumsByOwner added in v1.5.41 

func (f FindAlbumsByOwnerFunc) FindAlbumsByOwner(ctx context.Context, owner Owner) ([]*Album, error)

type FindAlbumsByOwnerPort added in v1.5.33 

type FindAlbumsByOwnerPort interface {
	FindAlbumsByOwner(ctx context.Context, owner Owner) ([]*Album, error)
}

type FindMediaRequest 

type FindMediaRequest struct {
	Owner            Owner
	AlbumFolderNames map[FolderName]interface{} // AlbumFolderNames is a set of folder names (map value is nil)
	Ranges           []TimeRange                // Ranges is optional, if empty no restriction will be applied
}

FindMediaRequest is a filter that is applied to find medias within a time range.

func NewFindMediaRequest 

func NewFindMediaRequest(owner Owner) *FindMediaRequest

func (*FindMediaRequest) String 

func (m *FindMediaRequest) String() string

func (*FindMediaRequest) WithAlbum 

func (m *FindMediaRequest) WithAlbum(folderNames ...FolderName) *FindMediaRequest

func (*FindMediaRequest) WithinRange 

func (m *FindMediaRequest) WithinRange(start, end time.Time) *FindMediaRequest

type FolderName added in v1.5.33 

type FolderName string

FolderName is a normalised ID unique per Owner

func NewFolderName added in v1.5.33 

func NewFolderName(name string) FolderName

NewFolderName creates a FolderName with a normalised value ; it can still be invalid (empty)

func (FolderName) IsValid added in v1.5.33 

func (n FolderName) IsValid() error

func (FolderName) String added in v1.5.33 

func (n FolderName) String() string

type InsertAlbumPort added in v1.5.33 

type InsertAlbumPort interface {
	InsertAlbum(ctx context.Context, album Album) error
}

type InsertAlbumPortFunc added in v1.5.33 

type InsertAlbumPortFunc func(ctx context.Context, album Album) error

func (InsertAlbumPortFunc) InsertAlbum added in v1.5.33 

func (f InsertAlbumPortFunc) InsertAlbum(ctx context.Context, album Album) error

type MediaDetails 

type MediaDetails struct {
	Width, Height             int
	DateTime                  time.Time
	Orientation               MediaOrientation
	Make                      string
	Model                     string
	GPSLatitude, GPSLongitude float64
	Duration                  int64  // Duration is the length, in milliseconds, of a video
	VideoEncoding             string // VideoEncoding is the codec used to encode the video (ex: 'H264')
}

MediaDetails are extracted from the metadata within photos and videos and stored as it.

type MediaId added in v1.5.33 

type MediaId string

type MediaMeta 

type MediaMeta struct {
	Id        MediaId        // Id is the unique identifier to use across all domains
	Signature MediaSignature // Signature is the key used to get the image (or its location)
	Filename  string         // Filename original filename when image was uploaded
	Type      MediaType
	Details   MediaDetails
}

MediaMeta is an entry (read) of a media in the catalog

type MediaOrientation 

type MediaOrientation string

type MediaPage 

type MediaPage struct {
	NextPage string // NextPage is empty if no other pages
	Content  []*MediaMeta
}

MediaPage is the current page MediaMeta, and the token of the next page

func ListMedias 

func ListMedias(albumId AlbumId, request PageRequest) (*MediaPage, error)

ListMedias return a page of medias within an album

type MediaSelector added in v1.5.33 

type MediaSelector struct {
	//ExclusiveAlbum *AlbumId  // ExclusiveAlbum is the Album in which medias are NOT (optional)
	FromAlbums []AlbumId // FromAlbums is a list of potential origins of medias ; is mandatory on CreateAlbum case because media are not indexed by date, only per album.
	Start      time.Time // Start is the first date of matching medias, included
	End        time.Time // End is the last date of matching media, excluded at the second
}

func (MediaSelector) String added in v1.5.33 

func (m MediaSelector) String() string

type MediaSignature 

type MediaSignature struct {
	SignatureSha256 string
	SignatureSize   int
}

func DecodeMediaId 

func DecodeMediaId(encodedId string) (*MediaSignature, error)

DecodeMediaId reverse what the GenerateMediaId has done to find original signature.

func FindSignatures 

func FindSignatures(owner Owner, signatures []*MediaSignature) ([]*MediaSignature, error)

FindSignatures returns a list of the medias already known ; they can't be duplicated

func (MediaSignature) String 

func (s MediaSignature) String() string

type MediaTransfer added in v1.5.42 

type MediaTransfer struct {
	TransferMedias            TransferMediasPort
	TimelineMutationObservers []TimelineMutationObserver
}

func (*MediaTransfer) Transfer added in v1.5.42 

func (d *MediaTransfer) Transfer(ctx context.Context, records MediaTransferRecords) error

type MediaTransferRecords added in v1.5.33 

type MediaTransferRecords map[AlbumId][]MediaSelector

MediaTransferRecords is a description of all medias that needs to be moved accordingly to the Timeline change

func (MediaTransferRecords) String added in v1.5.33 

func (r MediaTransferRecords) String() string

type MediaType 

type MediaType string

type MoveMediaPort added in v1.5.33 

type MoveMediaPort interface {
	MoveMedia(ctx context.Context, albumId AlbumId, mediaIds []MediaId) error
}

type MoveMediaPortFunc added in v1.5.33 

type MoveMediaPortFunc func(ctx context.Context, albumId AlbumId, mediaIds []MediaId) error

func (MoveMediaPortFunc) MoveMedia added in v1.5.33 

func (f MoveMediaPortFunc) MoveMedia(ctx context.Context, albumId AlbumId, mediaIds []MediaId) error

type Owner added in v1.5.33 

type Owner string

Owner is a non-empty ID

func (Owner) IsValid added in v1.5.33 

func (o Owner) IsValid() error

func (Owner) String added in v1.5.33 

func (o Owner) String() string

type PageRequest 

type PageRequest struct {
	Size     int64
	NextPage string
}

type PrioritySegment 

type PrioritySegment struct {
	Start  time.Time
	End    time.Time
	Albums []Album // sorted by priority
}

type RepositoryAdapter 

type RepositoryAdapter interface {
	TransferMediasPort

	FindAlbumsByOwner(ctx context.Context, owner Owner) ([]*Album, error)
	InsertAlbum(ctx context.Context, album Album) error
	DeleteEmptyAlbum(ctx context.Context, id AlbumId) error
	// FindAlbums only returns found albums
	FindAlbums(ctx context.Context, ids ...AlbumId) ([]*Album, error)
	// UpdateAlbum updates data of matching Album.FolderName
	UpdateAlbum(ctx context.Context, album Album) error

	// InsertMedias bulks insert medias
	InsertMedias(ctx context.Context, owner Owner, media []CreateMediaRequest) error
	// FindMedias is a paginated search for media with their details
	FindMedias(ctx context.Context, request *FindMediaRequest) (medias []*MediaMeta, err error)
	// FindMediaIds is a paginated search to only get the media ids
	FindMediaIds(ctx context.Context, request *FindMediaRequest) (ids []MediaId, err error)
	// FindMediaCurrentAlbum returns the folderName the media is currently in
	FindMediaCurrentAlbum(ctx context.Context, owner Owner, mediaId MediaId) (id *AlbumId, err error)
	// FindExistingSignatures returns the signatures that are already known
	FindExistingSignatures(ctx context.Context, owner Owner, signatures []*MediaSignature) ([]*MediaSignature, error)
	// TransferMedias to a different album, and returns list of moved media ids
	TransferMedias(ctx context.Context, owner Owner, mediaIds []MediaId, newFolderName FolderName) error
}

RepositoryAdapter brings persistence layer to catalog package

type TimeRange 

type TimeRange struct {
	Start time.Time
	End   time.Time
}

TimeRange is of days, start is inclusive (at the second), end is exclusive (at the second)

func NewTimeRangeFromAlbum 

func NewTimeRangeFromAlbum(album Album) TimeRange

func (TimeRange) Equals 

func (t TimeRange) Equals(other TimeRange) bool

func (TimeRange) Minus 

func (t TimeRange) Minus(other TimeRange) (ranges []TimeRange)

func (TimeRange) Plus 

func (t TimeRange) Plus(other TimeRange) (ranges []TimeRange)

func (TimeRange) String 

func (t TimeRange) String() string

type Timeline 

type Timeline struct {
	// contains filtered or unexported fields
}

Timeline can be used to find to which album a media will belongs.

func NewTimeline 

func NewTimeline(albums []*Album) (*Timeline, error)

NewTimeline creates a Timeline object used to compute overlaps between Album. List of albums must be sorted by Start date ASC (End sorting does not matter).

func (*Timeline) AppendAlbum 

func (t *Timeline) AppendAlbum(album *Album) (*Timeline, error)

AppendAlbum generates a new timeline from memory

func (*Timeline) FindAllAt 

func (t *Timeline) FindAllAt(date time.Time) []*Album

func (*Timeline) FindAt 

func (t *Timeline) FindAt(date time.Time) (*Album, bool)

FindAt returns nil if not found

func (*Timeline) FindBetween 

func (t *Timeline) FindBetween(start, end time.Time) (segments []PrioritySegment, missed []PrioritySegment)

FindBetween is deprecated, use FindSegmentsBetween instead

func (*Timeline) FindForAlbum 

func (t *Timeline) FindForAlbum(albumId AlbumId) (segments []PrioritySegment)

func (*Timeline) FindSegmentsBetween added in v1.5.41 

func (t *Timeline) FindSegmentsBetween(start, end time.Time) (segments []PrioritySegment)

FindSegmentsBetween returns a list of segments between start and end date. Segments will cover the whole period, but might not have any album.

type TimelineMutationObserver added in v1.5.33 

type TimelineMutationObserver interface {
	Observe(ctx context.Context, transfers TransferredMedias) error
}

type TimelineMutationObserverFunc added in v1.5.42 

type TimelineMutationObserverFunc func(ctx context.Context, transfers TransferredMedias) error

func (TimelineMutationObserverFunc) Observe added in v1.5.42 

func (f TimelineMutationObserverFunc) Observe(ctx context.Context, transfers TransferredMedias) error

type TimelineMutator added in v1.5.33 

type TimelineMutator struct{}

TimelineMutator is used to measure the impact of a change on the timeline

func NewTimelineMutator added in v1.5.33 

func NewTimelineMutator() *TimelineMutator

func (TimelineMutator) AddNew added in v1.5.33 

func (t TimelineMutator) AddNew(currentAlbums []*Album, addedAlbum Album) (MediaTransferRecords, error)

func (TimelineMutator) RemoveAlbum added in v1.5.41 

func (t TimelineMutator) RemoveAlbum(currentAlbums []*Album, deletedAlbumId AlbumId) (MediaTransferRecords, []MediaSelector, error)

type TransferMediasFunc added in v1.5.41 

type TransferMediasFunc func(ctx context.Context, records MediaTransferRecords) (TransferredMedias, error)

func (TransferMediasFunc) TransferMediasFromRecords added in v1.5.41 

func (f TransferMediasFunc) TransferMediasFromRecords(ctx context.Context, records MediaTransferRecords) (TransferredMedias, error)

type TransferMediasPort added in v1.5.33 

type TransferMediasPort interface {
	TransferMediasFromRecords(ctx context.Context, records MediaTransferRecords) (TransferredMedias, error)
}

type TransferredMedias added in v1.5.33 

type TransferredMedias map[AlbumId][]MediaId

func (TransferredMedias) IsEmpty added in v1.5.41 

func (t TransferredMedias) IsEmpty() bool

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.