@Test void retrieveACLWhenInvalidInBaseShouldReturnEmptyACL(CassandraCluster cassandra) { cassandra.getConf().execute( insertInto(CassandraACLTable.TABLE_NAME) .value(CassandraACLTable.ID, MAILBOX_ID.asUuid()) .value(CassandraACLTable.ACL, "{\"entries\":{\"bob\":invalid}}") .value(CassandraACLTable.VERSION, 1)); assertThat(cassandraACLMapper.getACL(MAILBOX_ID).block()).isEqualTo(MailboxACL.EMPTY); }
public Mono<MailboxACL> getACL(CassandraId cassandraId) { return getStoredACLRow(cassandraId) .map(row -> getAcl(cassandraId, row)); }
CassandraACLMapper { public Mono<MailboxACL> getACL(CassandraId cassandraId) { return getStoredACLRow(cassandraId) .map(row -> getAcl(cassandraId, row)); } }
CassandraACLMapper { public Mono<MailboxACL> getACL(CassandraId cassandraId) { return getStoredACLRow(cassandraId) .map(row -> getAcl(cassandraId, row)); } @Inject  CassandraACLMapper(Session session, CassandraUserMailboxRightsDAO userMailboxRightsDAO,
                              CassandraConfiguration cassandraConfiguration, CassandraConsistenciesConfiguration consistenciesConfiguration); }
CassandraACLMapper { public Mono<MailboxACL> getACL(CassandraId cassandraId) { return getStoredACLRow(cassandraId) .map(row -> getAcl(cassandraId, row)); } @Inject  CassandraACLMapper(Session session, CassandraUserMailboxRightsDAO userMailboxRightsDAO,
                              CassandraConfiguration cassandraConfiguration, CassandraConsistenciesConfiguration consistenciesConfiguration); Mono<MailboxACL> getACL(CassandraId cassandraId); Mono<ACLDiff> updateACL(CassandraId cassandraId, MailboxACL.ACLCommand command); Mono<ACLDiff> setACL(CassandraId cassandraId, MailboxACL mailboxACL); Mono<Void> delete(CassandraId cassandraId); }
CassandraACLMapper { public Mono<MailboxACL> getACL(CassandraId cassandraId) { return getStoredACLRow(cassandraId) .map(row -> getAcl(cassandraId, row)); } @Inject  CassandraACLMapper(Session session, CassandraUserMailboxRightsDAO userMailboxRightsDAO,
                              CassandraConfiguration cassandraConfiguration, CassandraConsistenciesConfiguration consistenciesConfiguration); Mono<MailboxACL> getACL(CassandraId cassandraId); Mono<ACLDiff> updateACL(CassandraId cassandraId, MailboxACL.ACLCommand command); Mono<ACLDiff> setACL(CassandraId cassandraId, MailboxACL mailboxACL); Mono<Void> delete(CassandraId cassandraId); static final int INITIAL_VALUE; }