Package org.saidone.repository

Class MongoNodeRepositoryImpl

java.lang.Object

org.saidone.component.BaseComponent

org.saidone.repository.MongoNodeRepositoryImpl

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.data.mongodb.repository.MongoRepository<NodeEntity,String>, org.springframework.data.repository.CrudRepository<NodeEntity,String>, org.springframework.data.repository.ListCrudRepository<NodeEntity,String>, org.springframework.data.repository.ListPagingAndSortingRepository<NodeEntity,String>, org.springframework.data.repository.PagingAndSortingRepository<NodeEntity,String>, org.springframework.data.repository.query.QueryByExampleExecutor<NodeEntity>, org.springframework.data.repository.Repository<NodeEntity,String>

Direct Known Subclasses:

EncryptedMongoNodeRepositoryImpl

@Repository
@ConditionalOnProperty(name="application.service.vault.encryption.enabled",
                       havingValue="false",
                       matchIfMissing=true)
public class MongoNodeRepositoryImpl
extends BaseComponent
implements org.springframework.data.mongodb.repository.MongoRepository<NodeEntity,String>

Repository implementation for managing NodeEntity entities in MongoDB.

Implements the MongoRepository interface using MongoOperations to perform database operations.

Activation of this repository is controlled by the application.service.vault.encryption.enabled property: the bean is instantiated when the value is false or the property is missing.

Provides CRUD operations including insertion, saving, batch operations, and queries by Example, Sort or Pageable. It also supports counting and removal of entities.

The findBy(Example, Function) method is not implemented and always throws an UnsupportedOperationException.

This class extends BaseComponent and is intended for scenarios where node encryption is disabled at the application level. It relies on MongoOperations for thread-safe persistence of NodeEntity documents.

Constructor Summary

Constructors

Constructor	Description
MongoNodeRepositoryImpl()

Method Summary

Modifier and Type	Method	Description
long	count()
<S extends NodeEntity> long	count(@NonNull org.springframework.data.domain.Example<S> example)
long	countNotarized()	Counts notarized nodes (nodes with non-null notarization transaction id).
void	delete(@NonNull NodeEntity entity)
void	deleteAll()
void	deleteAll(@NonNull Iterable<? extends NodeEntity> entities)
void	deleteAllById(@NonNull Iterable<? extends String> ids)
void	deleteById(@NonNull String id)
<S extends NodeEntity> boolean	exists(@NonNull org.springframework.data.domain.Example<S> example)
boolean	existsById(@NonNull String id)
@NonNull List<NodeEntity>	findAll()
<S extends NodeEntity> @NonNull List<S>	findAll(@NonNull org.springframework.data.domain.Example<S> example)
<S extends NodeEntity> @NonNull org.springframework.data.domain.Page<S>	findAll(@NonNull org.springframework.data.domain.Example<S> example, @NonNull org.springframework.data.domain.Pageable pageable)
<S extends NodeEntity> @NonNull List<S>	findAll(@NonNull org.springframework.data.domain.Example<S> example, @NonNull org.springframework.data.domain.Sort sort)
@NonNull org.springframework.data.domain.Page<NodeEntity>	findAll(@NonNull org.springframework.data.domain.Pageable pageable)
@NonNull List<NodeEntity>	findAll(@NonNull org.springframework.data.domain.Sort sort)
@NonNull List<NodeEntity>	findAllById(@NonNull Iterable<String> ids)
<S extends NodeEntity, R> R	findBy(@NonNull org.springframework.data.domain.Example<S> example, @NonNull Function<org.springframework.data.repository.query.FluentQuery.FetchableFluentQuery<S>,R> queryFunction)
org.springframework.data.domain.Page<NodeEntity>	findByArchiveDateRange(Instant from, Instant to, org.springframework.data.domain.Pageable pageable)	Retrieves node wrappers archived within the specified date range using pagination.
@NonNull Optional<NodeEntity>	findById(@NonNull String id)
List<NodeEntity>	findByKv(int kv)	Retrieves node wrappers by encryption key version.
List<NodeEntity>	findByNtx(String ntx)	Retrieves node wrappers by notarization transaction ID.
org.springframework.data.domain.Page<NodeEntity>	findNotarized(org.springframework.data.domain.Pageable pageable)	Retrieves notarized node wrappers where the transaction id is not null.
List<NodeEntity>	findNotarizedRandom(int size)	Retrieves a random sample of notarized nodes.
<S extends NodeEntity> @NonNull Optional<S>	findOne(@NonNull org.springframework.data.domain.Example<S> example)
void	init()	Called after dependency injection is complete.
<S extends NodeEntity> @NonNull List<S>	insert(@NonNull Iterable<S> entities)
<S extends NodeEntity> S	insert(S entity)
<S extends NodeEntity> S	save(S entity)
<S extends NodeEntity> @NonNull List<S>	saveAll(@NonNull Iterable<S> entities)

Methods inherited from class org.saidone.component.BaseComponent

setApplicationContext, shutDown, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MongoNodeRepositoryImpl

public MongoNodeRepositoryImpl()

Method Details

init

@PostConstruct
public void init()

Called after dependency injection is complete. Logs a startup message indicating that the component is ready.

The method verifies that the MongoDB connection is available at start-up. If the connection cannot be established the application is shut down to avoid running in an inconsistent state.

Overrides:

init in class BaseComponent

insert

@NonNull
public <S extends NodeEntity> S insert(@NonNull
 S entity)

Specified by:

insert in interface org.springframework.data.mongodb.repository.MongoRepository<NodeEntity,String>

insert

@NonNull
public <S extends NodeEntity> @NonNull List<S> insert(@NonNull
 @NonNull Iterable<S> entities)

Specified by:

insert in interface org.springframework.data.mongodb.repository.MongoRepository<NodeEntity,String>

save

@NonNull
public <S extends NodeEntity> S save(@NonNull
 S entity)

Specified by:

save in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

saveAll

@NonNull
public <S extends NodeEntity> @NonNull List<S> saveAll(@NonNull
 @NonNull Iterable<S> entities)

Specified by:

saveAll in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

Specified by:

saveAll in interface org.springframework.data.repository.ListCrudRepository<NodeEntity,String>

findOne

@NonNull
public <S extends NodeEntity> @NonNull Optional<S> findOne(@NonNull
 @NonNull org.springframework.data.domain.Example<S> example)

Specified by:

findOne in interface org.springframework.data.repository.query.QueryByExampleExecutor<NodeEntity>

findAll

@NonNull
public <S extends NodeEntity> @NonNull List<S> findAll(@NonNull
 @NonNull org.springframework.data.domain.Example<S> example)

Specified by:

findAll in interface org.springframework.data.mongodb.repository.MongoRepository<NodeEntity,String>

Specified by:

findAll in interface org.springframework.data.repository.query.QueryByExampleExecutor<NodeEntity>

findAll

@NonNull
public <S extends NodeEntity> @NonNull List<S> findAll(@NonNull
 @NonNull org.springframework.data.domain.Example<S> example,
 @NonNull
 @NonNull org.springframework.data.domain.Sort sort)

Specified by:

findAll in interface org.springframework.data.mongodb.repository.MongoRepository<NodeEntity,String>

Specified by:

findAll in interface org.springframework.data.repository.query.QueryByExampleExecutor<NodeEntity>

findAll

@NonNull
public <S extends NodeEntity>
@NonNull org.springframework.data.domain.Page<S> findAll(@NonNull
 @NonNull org.springframework.data.domain.Example<S> example,
 @NonNull
 @NonNull org.springframework.data.domain.Pageable pageable)

Specified by:

findAll in interface org.springframework.data.repository.query.QueryByExampleExecutor<NodeEntity>

findBy

@NonNull
public <S extends NodeEntity,
R> R findBy(@NonNull
 @NonNull org.springframework.data.domain.Example<S> example,
 @NonNull
 @NonNull Function<org.springframework.data.repository.query.FluentQuery.FetchableFluentQuery<S>,R> queryFunction)

Specified by:

findBy in interface org.springframework.data.repository.query.QueryByExampleExecutor<NodeEntity>

Throws:

UnsupportedOperationException - always thrown as this method is not implemented

findById

@NonNull
public @NonNull Optional<NodeEntity> findById(@NonNull
 @NonNull String id)

Specified by:

findById in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

existsById

public boolean existsById(@NonNull
 @NonNull String id)

Specified by:

existsById in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

findAll

@NonNull
public @NonNull List<NodeEntity> findAll()

Specified by:

findAll in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

Specified by:

findAll in interface org.springframework.data.repository.ListCrudRepository<NodeEntity,String>

findByArchiveDateRange

public org.springframework.data.domain.Page<NodeEntity> findByArchiveDateRange(Instant from,
 Instant to,
 org.springframework.data.domain.Pageable pageable)

Retrieves node wrappers archived within the specified date range using pagination.

When both from and to are null, this method delegates to findAll(Pageable).

If the supplied Pageable does not define a sort order, results are ordered by archive date in ascending order.

Parameters:

from - lower bound of the archive date range, inclusive. null for no lower bound.

to - upper bound of the archive date range, inclusive. null for no upper bound.

pageable - pagination information

Returns:

page of matching nodes

findNotarized

public org.springframework.data.domain.Page<NodeEntity> findNotarized(org.springframework.data.domain.Pageable pageable)

Retrieves notarized node wrappers where the transaction id is not null.

Parameters:

pageable - pagination information

Returns:

page of notarized nodes

countNotarized

public long countNotarized()

Counts notarized nodes (nodes with non-null notarization transaction id).

Returns:

number of notarized nodes

findNotarizedRandom

public List<NodeEntity> findNotarizedRandom(int size)

Retrieves a random sample of notarized nodes.

Parameters:

size - maximum number of nodes to sample

Returns:

random list of notarized nodes

findByNtx

public List<NodeEntity> findByNtx(String ntx)

Retrieves node wrappers by notarization transaction ID. A null value matches nodes without a transaction ID.

Parameters:

ntx - the transaction ID to filter by

Returns:

list of matching nodes

findByKv

public List<NodeEntity> findByKv(int kv)

Retrieves node wrappers by encryption key version.

Parameters:

kv - the encryption key version to filter by

Returns:

list of nodes encrypted with the specified key version

findAllById

@NonNull
public @NonNull List<NodeEntity> findAllById(@NonNull
 @NonNull Iterable<String> ids)

Specified by:

findAllById in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

Specified by:

findAllById in interface org.springframework.data.repository.ListCrudRepository<NodeEntity,String>

count

public long count()

Specified by:

count in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

deleteById

public void deleteById(@NonNull
 @NonNull String id)

Specified by:

deleteById in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

delete

public void delete(@NonNull
 @NonNull NodeEntity entity)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

deleteAllById

public void deleteAllById(@NonNull
 @NonNull Iterable<? extends String> ids)

Specified by:

deleteAllById in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

deleteAll

public void deleteAll(@NonNull
 @NonNull Iterable<? extends NodeEntity> entities)

Specified by:

deleteAll in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

deleteAll

public void deleteAll()

Specified by:

deleteAll in interface org.springframework.data.repository.CrudRepository<NodeEntity,String>

findAll

@NonNull
public @NonNull List<NodeEntity> findAll(@NonNull
 @NonNull org.springframework.data.domain.Sort sort)

Specified by:

findAll in interface org.springframework.data.repository.ListPagingAndSortingRepository<NodeEntity,String>

Specified by:

findAll in interface org.springframework.data.repository.PagingAndSortingRepository<NodeEntity,String>

findAll

@NonNull
public @NonNull org.springframework.data.domain.Page<NodeEntity> findAll(@NonNull
 @NonNull org.springframework.data.domain.Pageable pageable)

Specified by:

findAll in interface org.springframework.data.repository.PagingAndSortingRepository<NodeEntity,String>

count

public <S extends NodeEntity> long count(@NonNull
 @NonNull org.springframework.data.domain.Example<S> example)

Specified by:

count in interface org.springframework.data.repository.query.QueryByExampleExecutor<NodeEntity>

exists

public <S extends NodeEntity> boolean exists(@NonNull
 @NonNull org.springframework.data.domain.Example<S> example)

Specified by:

exists in interface org.springframework.data.repository.query.QueryByExampleExecutor<NodeEntity>