RpkiRepositoriesStore extends GenericStoreImpl<RpkiRepository> implements RpkiRepositories { @Override public long countAll(Tx.Read tx, RpkiRepository.Status optionalStatus, Key taId, boolean hideChildrenOfDownloadedParent, SearchTerm searchTerm) { return applyFiltered(tx, optionalStatus, taId, hideChildrenOfDownloadedParent, searchTerm).count(); } @Autowired  RpkiRepositoriesStore(Storage storage, SequencesStore sequences, ValidationScheduler validationScheduler); @Override RpkiRepository register(Tx.Write tx, Ref<TrustAnchor> trustAnchorRef, String uri, RpkiRepository.Type type); @Override void update(Tx.Write tx, RpkiRepository rpkiRepository); @Override Optional<RpkiRepository> findByURI(Tx.Read tx, String uri); @Override Optional<RpkiRepository> get(Tx.Read tx, Key id); @Override Stream<RpkiRepository> findAll(Tx.Read tx, RpkiRepository.Status optionalStatus, Key taId,
                                          boolean hideChildrenOfDownloadedParent,
                                          SearchTerm searchTerm, Sorting sorting, Paging paging); @Override long countAll(Tx.Read tx, RpkiRepository.Status optionalStatus, Key taId,
                         boolean hideChildrenOfDownloadedParent, SearchTerm searchTerm); @Override Stream<RpkiRepository> findAll(Tx.Read tx, RpkiRepository.Status optionalStatus, Key taId); @Override Stream<RpkiRepository> findAll(Tx.Read tx, Key taId); @Override Map<RpkiRepository.Status, Long> countByStatus(Tx.Read tx, Key taId, boolean hideChildrenOfDownloadedParent); @Override Stream<RpkiRepository> findRsyncRepositories(Tx.Read tx); @Override Stream<RpkiRepository> findRrdpRepositories(Tx.Read tx); @Override void removeAllForTrustAnchor(Tx.Write tx, TrustAnchor trustAnchor); @Override void remove(Tx.Write tx, Key key); @Override Collection<RpkiRepository> findByTrustAnchor(Tx.Read tx, Key key); @Override long deleteUnreferencedRepositories(Tx.Write tx, InstantWithoutNanos unreferencedSince);  }
@Test public void after_setup_there_is_one_rpki_repository() { long countAll = rtx(tx -> this.getRpkiRepositories().countAll(tx, RpkiRepository.Status.PENDING, trustAnchor.key(), true, new SearchTerm("some"))); assertEquals(1, countAll); }