catalogdynamo

Documentation

Overview

Package catalogdynamo package store all the data in a single multi-tenant table:

Index

• Constants
• func AlbumIndexedKeyPK(owner catalog.Owner, folderName catalog.FolderName) string
• func AlbumPrimaryKey(owner catalog.Owner, folderName catalog.FolderName) appdynamodb.TablePk
• func MediaPrimaryKey(owner catalog.Owner, id catalog.MediaId) appdynamodb.TablePk
• func Must(repository catalog.RepositoryAdapter, err error) catalog.RepositoryAdapter
• type AlbumIndexKey
  • func AlbumIndexedKey(owner catalog.Owner, folderName catalog.FolderName) AlbumIndexKey
  • func MediaAlbumIndexedKey(owner catalog.Owner, folderName catalog.FolderName, dateTime time.Time, ...) AlbumIndexKey
• type AlbumRecord
• type MediaRecord
• type Repository
  • func NewRepository(client *dynamodb.Client, tableName string) *Repository
  • func (r *Repository) CountMedias(ctx context.Context, albumId catalog.AlbumId) (int, error)
  • func (r *Repository) DeleteEmptyAlbum(ctx context.Context, albumId catalog.AlbumId) error
  • func (r *Repository) FindAlbums(ctx context.Context, ids ...catalog.AlbumId) ([]*catalog.Album, error)
  • func (r *Repository) FindAlbumsByOwner(ctx context.Context, owner catalog.Owner) ([]*catalog.Album, error)
  • func (r *Repository) FindExistingSignatures(ctx context.Context, owner catalog.Owner, signatures []*catalog.MediaSignature) ([]*catalog.MediaSignature, error)
  • func (r *Repository) FindMediaCurrentAlbum(ctx context.Context, owner catalog.Owner, mediaId catalog.MediaId) (*catalog.AlbumId, error)
  • func (r *Repository) FindMediaIds(ctx context.Context, request *catalog.FindMediaRequest) ([]catalog.MediaId, error)
  • func (r *Repository) FindMedias(ctx context.Context, request *catalog.FindMediaRequest) ([]*catalog.MediaMeta, error)
  • func (r *Repository) InsertAlbum(ctx context.Context, album catalog.Album) error
  • func (r *Repository) InsertMedias(ctx context.Context, owner catalog.Owner, medias []catalog.CreateMediaRequest) error
  • func (r *Repository) TransferMedias(ctx context.Context, owner catalog.Owner, mediaIds []catalog.MediaId, ...) error
  • func (r *Repository) TransferMediasFromRecords(ctx context.Context, records catalog.MediaTransferRecords) (catalog.TransferredMedias, error)
  • func (r *Repository) UpdateAlbum(ctx context.Context, album catalog.Album) error
• type RepositoryContract

Constants

const (
	IsoTime = "2006-01-02T15:04:05"
)

Functions

func AlbumIndexedKeyPK

func AlbumIndexedKeyPK(owner catalog.Owner, folderName catalog.FolderName) string

func AlbumPrimaryKey

func AlbumPrimaryKey(owner catalog.Owner, folderName catalog.FolderName) appdynamodb.TablePk

func MediaPrimaryKey

func MediaPrimaryKey(owner catalog.Owner, id catalog.MediaId) appdynamodb.TablePk

func Must

func Must(repository catalog.RepositoryAdapter, err error) catalog.RepositoryAdapter

Must panics if there is an error

Types

type AlbumIndexKey

type AlbumIndexKey struct {
	AlbumIndexPK string // AlbumIndexPK is same than album's TablePk.PK
	AlbumIndexSK string // AlbumIndexSK identify the object within the index, and is naturally sorted
}

AlbumIndexKey is a secondary key to index medias per albums

func AlbumIndexedKey

func AlbumIndexedKey(owner catalog.Owner, folderName catalog.FolderName) AlbumIndexKey

func MediaAlbumIndexedKey

func MediaAlbumIndexedKey(owner catalog.Owner, folderName catalog.FolderName, dateTime time.Time, id catalog.MediaId) AlbumIndexKey

type AlbumRecord

type AlbumRecord struct {
	appdynamodb.TablePk
	AlbumIndexKey
	AlbumOwner      string // AlbumOwner has been added to the data structure on 18 Apr 2022
	AlbumName       string
	AlbumFolderName string
	AlbumStart      time.Time
	AlbumEnd        time.Time
}

type MediaRecord

type MediaRecord struct {
	appdynamodb.TablePk
	AlbumIndexKey
	Id            string                 // Id is the unique identifier of the media
	Type          string                 // Type is either PHOTO or VIDEO
	DateTime      time.Time              // DateTime time used in AlbumIndexKey
	Details       map[string]interface{} // Details are other attributes from domain model, stored as it
	Filename      string                 // Filename is the original filename for display purpose only ; physical filename is in MediaLocationData
	SignatureSize int
	SignatureHash string
}

type Repository

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

func NewRepository

func NewRepository(client *dynamodb.Client, tableName string) *Repository

NewRepository creates the repository and connect to the database

func (*Repository) CountMedias

func (r *Repository) CountMedias(ctx context.Context, albumId catalog.AlbumId) (int, error)

CountMedias provides an accurate number of medias and can be used to update the count stored in the album record

func (*Repository) DeleteEmptyAlbum

func (r *Repository) DeleteEmptyAlbum(ctx context.Context, albumId catalog.AlbumId) error

func (*Repository) FindAlbums

func (r *Repository) FindAlbums(ctx context.Context, ids ...catalog.AlbumId) ([]*catalog.Album, error)

func (*Repository) FindAlbumsByOwner

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

func (*Repository) FindExistingSignatures

func (r *Repository) FindExistingSignatures(ctx context.Context, owner catalog.Owner, signatures []*catalog.MediaSignature) ([]*catalog.MediaSignature, error)

func (*Repository) FindMediaCurrentAlbum

func (r *Repository) FindMediaCurrentAlbum(ctx context.Context, owner catalog.Owner, mediaId catalog.MediaId) (*catalog.AlbumId, error)

func (*Repository) FindMediaIds

func (r *Repository) FindMediaIds(ctx context.Context, request *catalog.FindMediaRequest) ([]catalog.MediaId, error)

func (*Repository) FindMedias

func (r *Repository) FindMedias(ctx context.Context, request *catalog.FindMediaRequest) ([]*catalog.MediaMeta, error)

func (*Repository) InsertAlbum

func (r *Repository) InsertAlbum(ctx context.Context, album catalog.Album) error

func (*Repository) InsertMedias

func (r *Repository) InsertMedias(ctx context.Context, owner catalog.Owner, medias []catalog.CreateMediaRequest) error

func (*Repository) TransferMedias

func (r *Repository) TransferMedias(ctx context.Context, owner catalog.Owner, mediaIds []catalog.MediaId, newFolderName catalog.FolderName) error

func (*Repository) TransferMediasFromRecords

func (r *Repository) TransferMediasFromRecords(ctx context.Context, records catalog.MediaTransferRecords) (catalog.TransferredMedias, error)

func (*Repository) UpdateAlbum

func (r *Repository) UpdateAlbum(ctx context.Context, album catalog.Album) error

type RepositoryContract

type RepositoryContract interface {
	catalog.RepositoryAdapter
	catalog.TransferMediasPort
}