repository

Jun 17, 2024

Changes in this version

type BloockAvailabilityRepository

+ func (b BloockAvailabilityRepository) FindAll(ctx context.Context, id string) ([]domain.File, error)

May 23, 2024

Changes in this version

+ var ErrUnreadyProofStatus = errors.New("unready proof status")

type MessageAggregatorRepository

+ func (s MessageAggregatorRepository) GetMessagesByHashes(ctx context.Context, hash []string) ([]domain.Message, error)

Apr 2, 2024

Changes in this version

+ var ErrInvalidResponse = errors.New("record couldn't send")

+ func NewMessageAggregatorRepository(ctx context.Context, l zerolog.Logger, ent *connection.EntConnection) repository.MessageAggregatorRepository

+ func NewProcessRepository(ctx context.Context, l zerolog.Logger, ent *connection.EntConnection) repository.ProcessRepository

type BloockAvailabilityRepository

+ func (b BloockAvailabilityRepository) RetrieveLocal(ctx context.Context, filePath string) ([]byte, error)

type BloockIntegrityRepository

+ func (b BloockIntegrityRepository) CertifyFromHash(ctx context.Context, hash string, apiKey string) (domain.Certification, error)

+ func (b BloockIntegrityRepository) GetProof(ctx context.Context, hash string, apiKey string) (json.RawMessage, error)

type BloockMetadataRepository

+ func (s BloockMetadataRepository) FindCertificationByHash(ctx context.Context, hash string) (domain.Certification, error)

+ func (s BloockMetadataRepository) GetCertificationByHashAndAnchorID(ctx context.Context, hash string, anchorID int) (domain.Certification, domain.Proof, error)

+ func (s BloockMetadataRepository) UpdateCertificationProof(ctx context.Context, cert domain.Certification, proof json.RawMessage) error

+ type MerkleTreeRepository struct

+ func NewMerkleTreeRepository(l zerolog.Logger) MerkleTreeRepository

+ func (m MerkleTreeRepository) Create(ctx context.Context, messages []domain.Message) (domain.MerkleTree, error)

+ type MessageAggregatorRepository struct

+ func (s MessageAggregatorRepository) ExistRoot(ctx context.Context, root string) (bool, error)

+ func (s MessageAggregatorRepository) FindMessageByHash(ctx context.Context, hash string) (domain.Message, error)

+ func (s MessageAggregatorRepository) GetMessagesByRootAndAnchorID(ctx context.Context, root string, anchorID int) ([]domain.Message, error)

+ func (s MessageAggregatorRepository) GetPendingMessages(ctx context.Context) ([]domain.Message, error)

+ func (s MessageAggregatorRepository) SaveMessage(ctx context.Context, message domain.Message) error

+ func (s MessageAggregatorRepository) UpdateMessage(ctx context.Context, m domain.Message) error

+ type ProcessRepository struct

+ func (p ProcessRepository) FindProcessByID(ctx context.Context, id uuid.UUID) (domain.Process, error)

+ func (p ProcessRepository) List(ctx context.Context, pq utils.PaginationQuery) ([]domain.Process, utils.Pagination, error)

+ func (p ProcessRepository) SaveProcess(ctx context.Context, process domain.Process, isAggregated bool) error

+ func (p ProcessRepository) UpdateAggregatedAnchorID(ctx context.Context, anchorID int) error

+ func (p ProcessRepository) UpdateStatusByAnchorID(ctx context.Context, anchorID int) error

Jan 10, 2024

Changes in this version

+ var ErrNotification = errors.New("notification couldn't send")

+ func NewBloockAuthenticityRepository(ctx context.Context, logger zerolog.Logger) repository.AuthenticityRepository

+ func NewBloockAvailabilityRepository(ctx context.Context, logger zerolog.Logger) repository.AvailabilityRepository

+ func NewBloockEncryptionRepository(ctx context.Context, logger zerolog.Logger) repository.EncryptionRepository

+ func NewBloockIntegrityRepository(ctx context.Context, logger zerolog.Logger) repository.IntegrityRepository

+ func NewBloockKeyRepository(ctx context.Context, logger zerolog.Logger) repository.KeyRepository

+ func NewBloockMetadataRepository(ctx context.Context, logger zerolog.Logger) repository.MetadataRepository

+ func NewHttpNotificationRepository(ctx context.Context, logger zerolog.Logger) repository.NotificationRepository

+ type BloockAuthenticityRepository struct

+ func (b BloockAuthenticityRepository) SignWithLocalCertificate(ctx context.Context, data []byte, localCertificate key.LocalCertificate) (string, *record.Record, error)

+ func (b BloockAuthenticityRepository) SignWithLocalKey(ctx context.Context, data []byte, localKey key.LocalKey) (string, *record.Record, error)

+ func (b BloockAuthenticityRepository) SignWithManagedCertificate(ctx context.Context, data []byte, managedCertificate key.ManagedCertificate) (string, *record.Record, error)

+ func (b BloockAuthenticityRepository) SignWithManagedKey(ctx context.Context, data []byte, managedKey key.ManagedKey) (string, *record.Record, error)

+ type BloockAvailabilityRepository struct

+ func (b BloockAvailabilityRepository) FindFile(ctx context.Context, id string) ([]byte, error)

+ func (b BloockAvailabilityRepository) RetrieveTmp(ctx context.Context, filename string) ([]byte, error)

+ func (b BloockAvailabilityRepository) UploadHosted(ctx context.Context, file *domain.File, record record.Record) (string, error)

+ func (b BloockAvailabilityRepository) UploadIpfs(ctx context.Context, file *domain.File, record record.Record) (string, error)

+ func (b BloockAvailabilityRepository) UploadLocal(ctx context.Context, file *domain.File) (string, error)

+ func (b BloockAvailabilityRepository) UploadTmp(ctx context.Context, file *domain.File, record record.Record) (string, error)

+ type BloockEncryptionRepository struct

+ func (b BloockEncryptionRepository) EncryptWithLocalKey(ctx context.Context, data []byte, localKey key.LocalKey) (*record.Record, error)

+ func (b BloockEncryptionRepository) EncryptWithManagedCertificate(ctx context.Context, data []byte, managedCertificate key.ManagedCertificate) (*record.Record, error)

+ func (b BloockEncryptionRepository) EncryptWithManagedKey(ctx context.Context, data []byte, managedKey key.ManagedKey) (*record.Record, error)

+ func (b BloockEncryptionRepository) LoadLocalCertificate(ctx context.Context, pkcs12 []byte, pkcs12Password string) (*key.LocalCertificate, error)

+ func (b BloockEncryptionRepository) LoadLocalKey(ctx context.Context, kty key.KeyType, key string) (*key.LocalKey, error)

+ func (b BloockEncryptionRepository) LoadManagedCertificate(ctx context.Context, kid string) (*key.ManagedCertificate, error)

+ func (b BloockEncryptionRepository) LoadManagedKey(ctx context.Context, kid string) (*key.ManagedKey, error)

+ type BloockIntegrityRepository struct

+ func (b BloockIntegrityRepository) Certify(ctx context.Context, file []byte) (domain.Certification, error)

+ type BloockKeyRepository struct

+ type BloockMetadataRepository struct

+ func (c BloockMetadataRepository) UpdateCertification(ctx context.Context, certification domain.Certification) error

+ func (f BloockMetadataRepository) GetFileHash(ctx context.Context, file []byte) (string, error)

+ func (f BloockMetadataRepository) GetRecord(ctx context.Context, file []byte) (*record.Record, error)

+ func (f BloockMetadataRepository) GetRecordDetails(ctx context.Context, file []byte) (*record.RecordDetails, error)

+ func (s BloockMetadataRepository) ExistCertificationByHash(ctx context.Context, hash string) (bool, error)

+ func (s BloockMetadataRepository) GetCertificationsByAnchorID(ctx context.Context, anchorID int) ([]domain.Certification, error)

+ func (s BloockMetadataRepository) SaveCertification(ctx context.Context, certification domain.Certification) error

+ func (s BloockMetadataRepository) UpdateCertificationDataID(ctx context.Context, cert domain.Certification) error

+ type HttpNotificationRepository struct

+ func (h HttpNotificationRepository) NotifyCertification(hash string, file []byte) error