catalog

Aug 4, 2024

Changes in this version

+ type ThreadSafeAlbumReferencer struct

+ Delegate *StatefulAlbumReferencer

+ func (t *ThreadSafeAlbumReferencer) FindReference(ctx context.Context, mediaTime time.Time) (AlbumReference, error)

Jun 15, 2024

Changes in this version

type AlbumDatesAmendedObserverWithTimeline

+ OnAlbumDatesAmendedWithTimeline func(ctx context.Context, timeline *TimelineAggregate, amendedAlbum DatesUpdate) error

type AlbumDatesAmendedObserverWrapper

+ func (a *AlbumDatesAmendedObserverWrapper) OnAlbumDatesAmendedWithTimeline(ctx context.Context, _ *TimelineAggregate, amendedAlbum DatesUpdate) error

type AlbumQueries

+ func (a *AlbumQueries) FindAlbum(ctx context.Context, albumId AlbumId) (*Album, error)

type AmendAlbumDatesStateless

+ Observers []AlbumDatesAmendedObserverWithTimeline

type AmendAlbumMediaTransfer

+ func (a *AmendAlbumMediaTransfer) OnAlbumDatesAmendedWithTimeline(ctx context.Context, timeline *TimelineAggregate, updatedAlbum DatesUpdate) error

+ type InMemoryMedia struct

+ AlbumId AlbumId

+ func NewInMemoryMedia(id MediaId, albumId AlbumId) InMemoryMedia

+ type MediaQueries struct

+ MediaReadRepository MediaReadRepository

+ func (q *MediaQueries) FindMediaOwnership(ctx context.Context, owner ownermodel.Owner, mediaId MediaId) (*AlbumId, error)

+ func (q *MediaQueries) ListMedias(ctx context.Context, albumId AlbumId) ([]*MediaMeta, error)

+ type MediaQueriesInMemory struct

+ Medias []InMemoryMedia

+ func (q *MediaQueriesInMemory) FindMediaOwnership(ctx context.Context, owner ownermodel.Owner, mediaId MediaId) (*AlbumId, error)

+ func (q *MediaQueriesInMemory) ListMedias(ctx context.Context, albumId AlbumId) ([]*MediaMeta, error)

+ type MediaReadRepository interface

+ FindMediaCurrentAlbum func(ctx context.Context, owner ownermodel.Owner, mediaId MediaId) (id *AlbumId, err error)

+ FindMedias func(ctx context.Context, request *FindMediaRequest) (medias []*MediaMeta, err error)

type TimelineMutationObserver

+ OnTransferredMedias func(ctx context.Context, transfers TransferredMedias) error

type TimelineMutationObserverFunc

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

type TransferredMedias

+ FromAlbums []AlbumId

+ Transfers map[AlbumId][]MediaId

+ func NewTransferredMedias() TransferredMedias

Jun 3, 2024

Changes in this version

+ var NoAlbumLookedUpError = errors.New("no album matching")

+ type AlbumAutoCreateLookupStrategy struct

+ Delegate CreateAlbumWithTimeline

+ func (a *AlbumAutoCreateLookupStrategy) LookupAlbum(ctx context.Context, owner ownermodel.Owner, timeline *TimelineAggregate, ...) (AlbumReference, error)

+ type AlbumDatesAmendedObserver interface

+ OnAlbumDatesAmended func(ctx context.Context, amendedAlbum DatesUpdate) error

+ type AlbumDatesAmendedObserverFunc func(ctx context.Context, amendedAlbum DatesUpdate) error

+ func (f AlbumDatesAmendedObserverFunc) OnAlbumDatesAmended(ctx context.Context, amendedAlbum DatesUpdate) error

+ type AlbumDatesAmendedObserverWithTimeline interface

+ OnAlbumDatesAmended func(ctx context.Context, timeline *TimelineAggregate, amendedAlbum DatesUpdate) error

+ type AlbumDatesAmendedObserverWrapper struct

+ func (a *AlbumDatesAmendedObserverWrapper) OnAlbumDatesAmended(ctx context.Context, _ *TimelineAggregate, amendedAlbum DatesUpdate) error

+ type AlbumLookupStrategy interface

+ LookupAlbum func(ctx context.Context, owner ownermodel.Owner, timeline *TimelineAggregate, ...) (AlbumReference, error)

type AmendAlbumDates

+ AmendAlbumDatesWithTimeline AmendAlbumDatesWithTimeline

+ Observers []AlbumDatesAmendedObserverWithTimeline

+ type AmendAlbumDatesStateless struct

+ func (a *AmendAlbumDatesStateless) AmendAlbumDates(ctx context.Context, timeline *TimelineAggregate, albumId AlbumId, ...) error

+ type AmendAlbumDatesWithTimeline interface

+ AmendAlbumDates func(ctx context.Context, timeline *TimelineAggregate, albumId AlbumId, ...) error

type CreateAlbum

+ CreateAlbumWithTimeline CreateAlbumWithTimeline

+ type CreateAlbumObserverWithTimeline interface

+ ObserveCreateAlbum func(ctx context.Context, timeline *TimelineAggregate, createdAlbum Album) error

+ type CreateAlbumObserverWrapper struct

+ func (c *CreateAlbumObserverWrapper) ObserveCreateAlbum(ctx context.Context, _ *TimelineAggregate, createdAlbum Album) error

+ type CreateAlbumStateless struct

+ Observers []CreateAlbumObserverWithTimeline

+ func (c *CreateAlbumStateless) Create(ctx context.Context, timeline *TimelineAggregate, request CreateAlbumRequest) (*AlbumId, error)

+ type CreateAlbumWithTimeline interface

+ Create func(ctx context.Context, timeline *TimelineAggregate, request CreateAlbumRequest) (*AlbumId, error)

+ type DatesUpdate struct

+ PreviousEnd time.Time

+ PreviousStart time.Time

+ UpdatedAlbum Album

+ func (a *DatesUpdate) DatesNotChanged() bool

+ type DryRunLookupStrategy struct

+ func (d *DryRunLookupStrategy) LookupAlbum(ctx context.Context, owner ownermodel.Owner, timeline *TimelineAggregate, ...) (AlbumReference, error)

+ type StatefulAlbumReferencer struct

+ LookupStrategies []AlbumLookupStrategy

+ Owner ownermodel.Owner

+ TimelineAggregate *TimelineAggregate

+ func (a *StatefulAlbumReferencer) FindReference(ctx context.Context, mediaTime time.Time) (AlbumReference, error)

type TimelineAggregate

+ func (t *TimelineAggregate) ValidateAmendDates(albumId AlbumId, start, end time.Time) (*DatesUpdate, error)

+ type TimelineLookupStrategy struct

+ func (t TimelineLookupStrategy) LookupAlbum(ctx context.Context, owner ownermodel.Owner, timeline *TimelineAggregate, ...) (AlbumReference, error)

Jun 1, 2024

Changes in this version

type AutoCreateAlbumReferencer

+ func NewAlbumDryRunReferencer(owner ownermodel.Owner, findAlbumsByOwner FindAlbumsByOwnerPort) (*AutoCreateAlbumReferencer, error)

+ type DryRunReferencerObserver struct

+ func (d *DryRunReferencerObserver) Create(ctx context.Context, request CreateAlbumRequest) (*AlbumId, error)

type MediaSignature

+ func (s MediaSignature) Value() string

type TimelineAggregate

+ func (t *TimelineAggregate) AmendDates(amendedAlbum Album) (MediaTransferRecords, []MediaSelector, error)

+ func (t *TimelineAggregate) RemoveAlbum(deletedAlbumId AlbumId) (MediaTransferRecords, []MediaSelector, error)

May 31, 2024

Changes in this version

+ var DuplicatedAlbumError = errors.New("Timeline cannot contains duplicated albums")

+ type AlbumReference struct

+ AlbumId *AlbumId

+ AlbumJustCreated bool

+ type AutoCreateAlbumObserver interface

+ Create func(ctx context.Context, request CreateAlbumRequest) (*AlbumId, error)

+ type AutoCreateAlbumReferencer struct

+ Observer AutoCreateAlbumObserver

+ func NewAlbumAutoPopulateReferencer(owner ownermodel.Owner, findAlbumsByOwner FindAlbumsByOwnerPort, ...) (*AutoCreateAlbumReferencer, error)

+ func (a *AutoCreateAlbumReferencer) FindReference(ctx context.Context, mediaTime time.Time) (AlbumReference, error)

type CreateAlbum

+ MediaTransfer MediaTransfer

type CreateAlbumMediaTransfer

+ Timeline *TimelineAggregate

+ type FindExistingSignaturePort interface

+ FindSignatures func(ctx context.Context, owner ownermodel.Owner, signatures []MediaSignature) (map[MediaSignature]MediaId, error)

+ type MediaFutureReference struct

+ AlreadyExists bool

+ ProvisionalMediaId MediaId

+ Signature MediaSignature

+ type MediasInsertSimulator struct

+ FindExistingSignaturePort FindExistingSignaturePort

+ func (m *MediasInsertSimulator) SimulateInsertingMedia(ctx context.Context, owner ownermodel.Owner, signatures []MediaSignature) ([]MediaFutureReference, error)

+ type StatefulCreateAlbum struct

+ CreateAlbumObserver []CreateAlbumObserver

+ Timeline *TimelineAggregate

+ func (c *StatefulCreateAlbum) Create(ctx context.Context, request CreateAlbumRequest) (*AlbumId, error)

type TimelineAggregate

+ func NewInitialisedTimelineAggregate(albums []*Album) (*TimelineAggregate, error)

+ func NewLazyTimelineAggregate(albums []*Album) *TimelineAggregate

+ func (t *TimelineAggregate) CreateNewAlbum(ctx context.Context, request CreateAlbumRequest, ...) (*AlbumId, error)

+ func (t *TimelineAggregate) FindAt(date time.Time) (*Album, bool, error)

May 23, 2024

Changes in this version

+ var AlbumFolderNameAlreadyTakenErr = errors.New("Album folder name is already taken")

+ var DuplicateError = errors.New("Timeline cannot contains duplicated albums")

type CreateAlbumRequest

+ func (c *CreateAlbumRequest) Convert(existingAlbums []*Album) (Album, error)

type Timeline

+ func (t *Timeline) Debug() string

+ type TimelineAggregate struct

+ func NewTimelineAggregate(albums []*Album) *TimelineAggregate

+ func (t *TimelineAggregate) AddNew(addedAlbum Album) (MediaTransferRecords, error)

May 18, 2024

Changes in this version

type AlbumQueries

+ func (a *AlbumQueries) CountMedia(ctx context.Context, album ...AlbumId) (map[AlbumId]int, error)

type RepositoryAdapter

+ CountMedia func(ctx context.Context, album ...AlbumId) (map[AlbumId]int, error)

May 18, 2024

Changes in this version

+ type AlbumQueries struct

+ Repository RepositoryAdapter

+ func (a *AlbumQueries) FindAlbumsById(ctx context.Context, ids []AlbumId) ([]*Album, error)

+ func (a *AlbumQueries) FindAlbumsByOwner(ctx context.Context, owner ownermodel.Owner) ([]*Album, error)

May 15, 2024

Changes in this version

type InsertMedias

+ InsertMediasObservers []InsertMediasObserver

+ InsertMediasRepository InsertMediasRepositoryPort

+ func NewInsertMedias(InsertMediasRepository InsertMediasRepositoryPort, ...) *InsertMedias

+ func (i *InsertMedias) AssignIdsToNewMedias(ctx context.Context, owner Owner, signatures []*MediaSignature) (map[MediaSignature]MediaId, error)

+ func (i *InsertMedias) Insert(ctx context.Context, owner Owner, medias []CreateMediaRequest) error

+ type InsertMediasObserver interface

+ OnMediasInserted func(context.Context, map[AlbumId][]MediaId) error

+ type InsertMediasRepositoryPort interface

+ InsertMedias func(ctx context.Context, owner Owner, media []CreateMediaRequest) error

type MediaId

+ func (m MediaId) Value() string

May 13, 2024

Changes in this version

+ type AmendAlbumDateRepositoryPort interface

+ AmendDates func(ctx context.Context, album AlbumId, start, end time.Time) error

+ type AmendAlbumDates struct

+ AmendAlbumDatesObservers []AmendAlbumDatesObserver

+ FindAlbumsByOwnerPort FindAlbumsByOwnerPort

+ func NewAmendAlbumDates(findAlbumsByOwner FindAlbumsByOwnerPort, ...) *AmendAlbumDates

+ func (a *AmendAlbumDates) AmendAlbumDates(ctx context.Context, albumId AlbumId, start, end time.Time) error

+ type AmendAlbumDatesExecutor struct

+ AmendAlbumDateRepository AmendAlbumDateRepositoryPort

+ func (a *AmendAlbumDatesExecutor) OnAlbumDatesAmended(ctx context.Context, _ []*Album, updatedAlbum Album) error

+ type AmendAlbumDatesObserver interface

+ OnAlbumDatesAmended func(ctx context.Context, existingTimeline []*Album, updatedAlbum Album) error

+ type AmendAlbumDatesObserverFunc func(ctx context.Context, existingTimeline []*Album, updatedAlbum Album) error

+ func (f AmendAlbumDatesObserverFunc) OnAlbumDatesAmended(ctx context.Context, existingTimeline []*Album, updatedAlbum Album) error

+ type AmendAlbumMediaTransfer struct

+ CountMediasBySelectors CountMediasBySelectorsPort

+ MediaTransfer MediaTransfer

+ func (a *AmendAlbumMediaTransfer) OnAlbumDatesAmended(ctx context.Context, existingTimeline []*Album, updatedAlbum Album) error

type MediaTransferExecutor

+ TransferMediasRepository TransferMediasRepositoryPort

type Timeline

+ func (t *Timeline) FindSegmentsBetweenAndFilter(start, end time.Time, albumId AlbumId) (segments []PrioritySegment)

type TimelineMutator

+ func (t TimelineMutator) AmendDates(timeline []*Album, amendedAlbum Album) (MediaTransferRecords, []MediaSelector, error)

+ type TransferMediasRepositoryPort interface

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

May 11, 2024

Changes in this version

+ var AlbumNotFoundError = errors.New("album hasn't been found")

type CreateAlbumMediaTransfer

+ FindAlbumsByOwnerPort FindAlbumsByOwnerPort

+ MediaTransfer MediaTransfer

+ type FindAlbumByIdFunc func(ctx context.Context, id AlbumId) (*Album, error)

+ func (f FindAlbumByIdFunc) FindAlbumById(ctx context.Context, id AlbumId) (*Album, error)

+ type FindAlbumByIdPort interface

+ FindAlbumById func(ctx context.Context, id AlbumId) (*Album, error)

+ type MediaTransferExecutor struct

+ TimelineMutationObservers []TimelineMutationObserver

+ TransferMedias TransferMediasPort

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

+ type MediaTransferFunc func(ctx context.Context, records MediaTransferRecords) error

+ func (f MediaTransferFunc) Transfer(ctx context.Context, records MediaTransferRecords) error

type RenameAlbum

+ FindAlbumById FindAlbumByIdPort

+ RenameAlbumObservers []RenameAlbumObserver

+ UpdateAlbumName UpdateAlbumNamePort

+ func NewRenameAlbum(FindAlbumById FindAlbumByIdPort, UpdateAlbumName UpdateAlbumNamePort, ...) *RenameAlbum

+ func (r *RenameAlbum) RenameAlbum(ctx context.Context, request RenameAlbumRequest) error

+ type RenameAlbumObserver interface

+ OnRenameAlbum func(ctx context.Context, current AlbumId, creationRequest CreateAlbumRequest) error

+ type RenameAlbumReplacer struct

+ CreateAlbum CreateAlbum

+ DeleteAlbumRepositoryPort DeleteAlbumRepositoryPort

+ MediaTransfer MediaTransfer

+ func (r *RenameAlbumReplacer) OnRenameAlbum(ctx context.Context, current AlbumId, creationRequest CreateAlbumRequest) error

+ type RenameAlbumRequest struct

+ CurrentId AlbumId

+ ForcedFolderName string

+ NewName string

+ RenameFolder bool

+ func (r RenameAlbumRequest) IsValid() error

+ func (r RenameAlbumRequest) String() string

type RepositoryAdapter

+ FindAlbumByIds func(ctx context.Context, ids ...AlbumId) ([]*Album, error)

+ type UpdateAlbumNamePort interface

+ UpdateAlbumName func(ctx context.Context, albumId AlbumId, newName string) error

May 10, 2024

Changes in this version

type CreateAlbum

+ Observers []CreateAlbumObserver

+ func NewAlbumCreate(FindAlbumsByOwnerPort FindAlbumsByOwnerPort, InsertAlbumPort InsertAlbumPort, ...) *CreateAlbum

+ type CreateAlbumExecutor struct

+ InsertAlbumPort InsertAlbumPort

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

+ type CreateAlbumMediaTransfer struct

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

+ type CreateAlbumObserver interface

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

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

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

type DeleteAlbum

+ Observers []DeleteAlbumObserver

type DeleteAlbumMediaTransfer

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

type DeleteAlbumMetadata

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

+ type DeleteAlbumObserver interface

+ OnDeleteAlbum func(ctx context.Context, deletedAlbum AlbumId, transfers MediaTransferRecords) error

+ type MediaTransfer struct

+ TimelineMutationObservers []TimelineMutationObserver

+ TransferMedias TransferMediasPort

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

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

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

May 9, 2024

Changes in this version

+ var AlbumIsNotEmptyError = errors.New("album is not empty")

+ var OrphanedMediasError = errors.New("albums cannot be deleted if it make medias orphaned")

+ type AlbumCanBeDeletedObserver interface

+ Observe func(ctx context.Context, deletedAlbum AlbumId, transfers MediaTransferRecords) error

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

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

+ type CountMediasBySelectorsPort interface

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

type DeleteAlbum

+ AlbumCanBeDeletedObserver []AlbumCanBeDeletedObserver

+ CountMediasBySelectors CountMediasBySelectorsPort

+ FindAlbumsByOwner FindAlbumsByOwnerPort

+ func NewDeleteAlbum(FindAlbumsByOwner FindAlbumsByOwnerPort, ...) *DeleteAlbum

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

+ type DeleteAlbumMediaTransfer struct

+ TimelineMutationObservers []TimelineMutationObserver

+ TransferMedias TransferMediasPort

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

+ type DeleteAlbumMetadata struct

+ DeleteAlbumRepository DeleteAlbumRepositoryPort

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

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

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

+ type DeleteAlbumRepositoryPort interface

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

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

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

type Timeline

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

type TimelineMutator

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

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

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

type TransferredMedias

+ func (t TransferredMedias) IsEmpty() bool

May 3, 2024

Changes in this version

+ var AlbumEndDateMustBeAfterStartErr = errors.New("Album end must be strictly after its start")

+ var AlbumNameMandatoryErr = errors.New("Album name is mandatory")

+ var AlbumStartAndEndDateMandatoryErr = errors.New("Start and End times are mandatory")

+ var EmptyFolderNameError = errors.New("folderName is mandatory and must be not empty")

+ var EmptyOwnerError = errors.New("owner is mandatory and must be not empty")

type AlbumId

+ func NewAlbumIdFromStrings(owner, folderName string) AlbumId

+ func (a AlbumId) IsEqual(other AlbumId) bool

+ func (a AlbumId) IsValid() error

type CreateAlbum

+ FindAlbumsByOwnerPort FindAlbumsByOwnerPort

+ InsertAlbumPort InsertAlbumPort

+ TimelineMutationObservers []TimelineMutationObserver

+ TransferMediasPort TransferMediasPort

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

+ type CreateAlbumRequest struct

+ End time.Time

+ ForcedFolderName string

+ Name string

+ Owner Owner

+ Start time.Time

+ func (c *CreateAlbumRequest) IsValid() error

+ func (c *CreateAlbumRequest) String() string

+ type FindAlbumsByOwnerPort interface

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

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

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

+ type FolderName string

+ func NewFolderName(name string) FolderName

+ func (n FolderName) IsValid() error

+ func (n FolderName) String() string

+ type InsertAlbumPort interface

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

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

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

+ type ListMediaIdsPort interface

+ ListMediaIdsFromSelector func(ctx context.Context, selector []MediaSelector) ([]MediaId, error)

+ type MediaId string

+ type MediaSelector struct

+ End time.Time

+ FromAlbums []AlbumId

+ Start time.Time

+ func (m MediaSelector) String() string

+ type MediaTransferRecords map[AlbumId][]MediaSelector

+ func (r MediaTransferRecords) String() string

+ type MoveMediaPort interface

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

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

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

+ type Owner string

+ func (o Owner) IsValid() error

+ func (o Owner) String() string

+ type TimelineMutationObserver interface

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

+ type TimelineMutator struct

+ Current []*Album

+ func NewTimelineMutator(current []*Album) *TimelineMutator

+ func (t *TimelineMutator) AddNew(album Album) (MediaTransferRecords, error)

+ type TransferMediaListener struct

+ ListMediaIds ListMediaIdsPort

+ func (t *TransferMediaListener) TransferMedia(ctx context.Context, selector []MediaSelector) error

+ type TransferMediasPort interface

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

+ type TransferredMedias map[AlbumId][]MediaId

Jan 7, 2023

Changes in this version

+ var MediaNotFoundError = fmt.Errorf("media not found")

+ var NotEmptyError = errors.New("album is not empty")

+ var NotFoundError = errors.New("album hasn't been found")

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

+ func Create(createRequest CreateAlbum) error

+ func DeleteAlbum(owner string, folderNameToDelete string, emptyOnly bool) error

+ func FindMediaOwnership(owner, mediaId string) (string, error)

+ func GenerateMediaId(signature MediaSignature) (string, error)

+ func Init(repositoryAdapter RepositoryAdapter, archive CArchiveAdapter)

+ func InsertMedias(owner string, medias []CreateMediaRequest) error

+ func RenameAlbum(owner string, folderName, newName string, renameFolder bool) error

+ func UpdateAlbum(owner string, folderName string, start, end time.Time) error

+ type Album struct

+ End time.Time

+ FolderName string

+ Name string

+ Owner string

+ Start time.Time

+ TotalCount int

+ func FindAlbum(owner string, folderName string) (*Album, error)

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

+ func FindAllAlbums(owner string) ([]*Album, error)

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

+ func (a *Album) String() string

+ type AlbumId struct

+ FolderName string

+ Owner string

+ func (a *AlbumId) String() string

+ type CArchiveAdapter interface

+ MoveMedias func(owner string, ids []string, name string) error

+ type CreateAlbum struct

+ End time.Time

+ ForcedFolderName string

+ Name string

+ Owner string

+ Start time.Time

+ func (c *CreateAlbum) String() string

+ type CreateMediaRequest struct

+ Details MediaDetails

+ Filename string

+ FolderName string

+ Id string

+ Signature MediaSignature

+ Type MediaType

+ type FindMediaRequest struct

+ AlbumFolderNames map[string]interface{}

+ Owner string

+ Ranges []TimeRange

+ func NewFindMediaRequest(owner string) *FindMediaRequest

+ func (m *FindMediaRequest) String() string

+ func (m *FindMediaRequest) WithAlbum(folderNames ...string) *FindMediaRequest

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

+ type MediaDetails struct

+ DateTime time.Time

+ Duration int64

+ GPSLatitude float64

+ GPSLongitude float64

+ Height int

+ Make string

+ Model string

+ Orientation MediaOrientation

+ VideoEncoding string

+ Width int

+ type MediaMeta struct

+ Details MediaDetails

+ Filename string

+ Id string

+ Signature MediaSignature

+ Type MediaType

+ type MediaOrientation string

+ type MediaPage struct

+ Content []*MediaMeta

+ NextPage string

+ func ListMedias(owner string, folderName string, request PageRequest) (*MediaPage, error)

+ type MediaSignature struct

+ SignatureSha256 string

+ SignatureSize int

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

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

+ func (s MediaSignature) String() string

+ type MediaType string

+ type PageRequest struct

+ NextPage string

+ Size int64

+ type PrioritySegment struct

+ Albums []Album

+ End time.Time

+ Start time.Time

+ type RepositoryAdapter interface

+ DeleteEmptyAlbum func(owner string, folderName string) error

+ FindAlbums func(ids ...AlbumId) ([]*Album, error)

+ FindAlbumsByOwner func(owner string) ([]*Album, error)

+ FindExistingSignatures func(owner string, signatures []*MediaSignature) ([]*MediaSignature, error)

+ FindMediaCurrentAlbum func(owner, mediaId string) (folderName string, err error)

+ FindMediaIds func(request *FindMediaRequest) (ids []string, err error)

+ FindMedias func(request *FindMediaRequest) (medias []*MediaMeta, err error)

+ InsertAlbum func(album Album) error

+ InsertMedias func(owner string, media []CreateMediaRequest) error

+ TransferMedias func(owner string, mediaIds []string, newFolderName string) error

+ UpdateAlbum func(album Album) error

+ type TimeRange struct

+ End time.Time

+ Start time.Time

+ func NewTimeRangeFromAlbum(album Album) TimeRange

+ func (t TimeRange) Equals(other TimeRange) bool

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

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

+ func (t TimeRange) String() string

+ type Timeline struct

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

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

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

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

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

+ func (t *Timeline) FindForAlbum(owner, folderName string) (segments []PrioritySegment)