repository

Documentation

Index

• type AuthenticityRepository
• type AvailabilityRepository
• type EncryptionRepository
• type IntegrityRepository
• type KeyRepository
• type LocalStorageRepository
• type MerkleTreeRepository
• type MessageAggregatorRepository
• type MetadataRepository
• type NotificationRepository
• type ProcessRepository

Types

type AuthenticityRepository

type AuthenticityRepository interface {
	SignWithLocalKey(ctx context.Context, data []byte, localKey key.LocalKey) (string, *record.Record, error)
	SignWithManagedKey(ctx context.Context, data []byte, managedKey key.ManagedKey, accessControl *key.AccessControl) (string, *record.Record, error)
	SignWithLocalCertificate(ctx context.Context, data []byte, localCertificate key.LocalCertificate) (string, *record.Record, error)
	SignWithManagedCertificate(ctx context.Context, data []byte, managedCertificate key.ManagedCertificate, accessControl *key.AccessControl) (string, *record.Record, error)
}

type AvailabilityRepository

type AvailabilityRepository interface {
	UploadHosted(ctx context.Context, file *domain.File, record record.Record) (string, error)
	UploadIpfs(ctx context.Context, file *domain.File, record record.Record) (string, error)
	UploadLocal(ctx context.Context, file *domain.File) (string, error)
	UploadTmp(ctx context.Context, file *domain.File, record record.Record) (string, error)
	RetrieveTmp(ctx context.Context, filename string) ([]byte, error)
	RetrieveLocal(ctx context.Context, filePath string) ([]byte, error)
	FindFile(ctx context.Context, dataID string) ([]byte, error)
}

type EncryptionRepository

type EncryptionRepository interface {
	EncryptWithLocalKey(ctx context.Context, data []byte, localKey key.LocalKey) (*record.Record, error)
	EncryptWithManagedKey(ctx context.Context, data []byte, managedKey key.ManagedKey, accessControl *key.AccessControl) (*record.Record, error)
	EncryptWithManagedCertificate(ctx context.Context, data []byte, managedCertificate key.ManagedCertificate, accessControl *key.AccessControl) (*record.Record, error)
}

type IntegrityRepository

type IntegrityRepository interface {
	Certify(ctx context.Context, file []byte) (domain.Certification, error)
	CertifyFromHash(ctx context.Context, hash string, apiKey string) (domain.Certification, error)
	GetProof(ctx context.Context, hash string, apiKey string) (json.RawMessage, error)
}

type KeyRepository

type KeyRepository interface {
	LoadLocalKey(ctx context.Context, kty key.KeyType, key string) (*key.LocalKey, error)
	LoadManagedKey(ctx context.Context, kid string) (*key.ManagedKey, error)
	LoadLocalCertificate(ctx context.Context, pkcs12 []byte, pkcs12Password string) (*key.LocalCertificate, error)
	LoadManagedCertificate(ctx context.Context, kid string) (*key.ManagedCertificate, error)
}

type LocalStorageRepository

type LocalStorageRepository interface {
	Save(ctx context.Context, data []byte, filename string) error
	Retrieve(ctx context.Context, directory string, filename string) ([]byte, error)
}

type MerkleTreeRepository

type MerkleTreeRepository interface {
	Create(ctx context.Context, messages []domain.Message) (domain.MerkleTree, error)
}

type MessageAggregatorRepository

type MessageAggregatorRepository interface {
	SaveMessage(ctx context.Context, message domain.Message) error
	UpdateMessage(ctx context.Context, m domain.Message) error

	GetPendingMessages(ctx context.Context) ([]domain.Message, error)
	GetMessagesByRootAndAnchorID(ctx context.Context, root string, anchorID int) ([]domain.Message, error)
	FindMessageByHash(ctx context.Context, hash string) (domain.Message, error)
	ExistRoot(ctx context.Context, root string) (bool, error)
}

type MetadataRepository

type MetadataRepository interface {
	SaveCertification(ctx context.Context, certification domain.Certification) error
	GetCertificationsByAnchorID(ctx context.Context, anchor int) (certification []domain.Certification, err error)
	GetCertificationByHashAndAnchorID(ctx context.Context, hash string, anchorID int) (domain.Certification, domain.Proof, error)
	FindCertificationByHash(ctx context.Context, hash string) (domain.Certification, error)
	ExistCertificationByHash(ctx context.Context, hash string) (bool, error)
	UpdateCertificationDataID(ctx context.Context, certification domain.Certification) error
	UpdateCertification(ctx context.Context, certification domain.Certification) error
	UpdateCertificationProof(ctx context.Context, cert domain.Certification, proof json.RawMessage) error

	GetRecord(ctx context.Context, file []byte) (*record.Record, error)
	GetRecordDetails(ctx context.Context, file []byte) (*record.RecordDetails, error)
	GetFileHash(ctx context.Context, file []byte) (string, error)
}

type NotificationRepository

type NotificationRepository interface {
	NotifyCertification(hash string, file []byte) error
}

type ProcessRepository

type ProcessRepository interface {
	SaveProcess(ctx context.Context, process domain.Process, isAggregated bool) error
	UpdateAggregatedAnchorID(ctx context.Context, anchorID int) error
	UpdateStatusByAnchorID(ctx context.Context, anchorID int) error

	FindProcessByID(ctx context.Context, id uuid.UUID) (domain.Process, error)
	List(ctx context.Context, pq utils.PaginationQuery) ([]domain.Process, utils.Pagination, error)
}