@Test public void testProcessRegularNoLogTimeStrategy() { when(mockAuditor.shouldLogForStatus(any(Status.class))).thenReturn(false); auditAdapter.auditRegular(STATEMENT, mockState, Status.ATTEMPT, TIMESTAMP); verifyNoMoreInteractions(mockAuditor, mockAuditEntryBuilderFactory); }
public void auditRegular(String operation, ClientState state, Status status, long timestamp) { if (auditor.shouldLogForStatus(status)) { AuditEntry logEntry = entryBuilderFactory.createEntryBuilder(operation, state) .client(state.getRemoteAddress()) .coordinator(FBUtilities.getBroadcastAddress()) .user(state.getUser().getName()) .operation(new SimpleAuditOperation(operation)) .status(status) .timestamp(timestamp) .build(); auditor.audit(logEntry); } }
AuditAdapter { public void auditRegular(String operation, ClientState state, Status status, long timestamp) { if (auditor.shouldLogForStatus(status)) { AuditEntry logEntry = entryBuilderFactory.createEntryBuilder(operation, state) .client(state.getRemoteAddress()) .coordinator(FBUtilities.getBroadcastAddress()) .user(state.getUser().getName()) .operation(new SimpleAuditOperation(operation)) .status(status) .timestamp(timestamp) .build(); auditor.audit(logEntry); } } }
AuditAdapter { public void auditRegular(String operation, ClientState state, Status status, long timestamp) { if (auditor.shouldLogForStatus(status)) { AuditEntry logEntry = entryBuilderFactory.createEntryBuilder(operation, state) .client(state.getRemoteAddress()) .coordinator(FBUtilities.getBroadcastAddress()) .user(state.getUser().getName()) .operation(new SimpleAuditOperation(operation)) .status(status) .timestamp(timestamp) .build(); auditor.audit(logEntry); } } AuditAdapter(Auditor auditor, AuditEntryBuilderFactory entryBuilderFactory, BoundValueSuppressor boundValueSuppressor); }
AuditAdapter { public void auditRegular(String operation, ClientState state, Status status, long timestamp) { if (auditor.shouldLogForStatus(status)) { AuditEntry logEntry = entryBuilderFactory.createEntryBuilder(operation, state) .client(state.getRemoteAddress()) .coordinator(FBUtilities.getBroadcastAddress()) .user(state.getUser().getName()) .operation(new SimpleAuditOperation(operation)) .status(status) .timestamp(timestamp) .build(); auditor.audit(logEntry); } } AuditAdapter(Auditor auditor, AuditEntryBuilderFactory entryBuilderFactory, BoundValueSuppressor boundValueSuppressor); static AuditAdapter getInstance(); void setup(); void auditRegular(String operation, ClientState state, Status status, long timestamp); void auditPrepared(MD5Digest id, CQLStatement statement, ClientState state, QueryOptions options, Status status, long timestamp); void auditBatch(BatchStatement statement, UUID uuid, ClientState state, BatchQueryOptions options, Status status, long timestamp); void auditAuth(String username, Status status, long timestamp); void auditAuth(String userName, String subject, Status status, long timestamp); void mapIdToQuery(MD5Digest id, String query); Auditor getAuditor(); @VisibleForTesting void setBoundValueSuppressor(BoundValueSuppressor suppressor); @VisibleForTesting BoundValueSuppressor getBoundValueSuppressor(); }
AuditAdapter { public void auditRegular(String operation, ClientState state, Status status, long timestamp) { if (auditor.shouldLogForStatus(status)) { AuditEntry logEntry = entryBuilderFactory.createEntryBuilder(operation, state) .client(state.getRemoteAddress()) .coordinator(FBUtilities.getBroadcastAddress()) .user(state.getUser().getName()) .operation(new SimpleAuditOperation(operation)) .status(status) .timestamp(timestamp) .build(); auditor.audit(logEntry); } } AuditAdapter(Auditor auditor, AuditEntryBuilderFactory entryBuilderFactory, BoundValueSuppressor boundValueSuppressor); static AuditAdapter getInstance(); void setup(); void auditRegular(String operation, ClientState state, Status status, long timestamp); void auditPrepared(MD5Digest id, CQLStatement statement, ClientState state, QueryOptions options, Status status, long timestamp); void auditBatch(BatchStatement statement, UUID uuid, ClientState state, BatchQueryOptions options, Status status, long timestamp); void auditAuth(String username, Status status, long timestamp); void auditAuth(String userName, String subject, Status status, long timestamp); void mapIdToQuery(MD5Digest id, String query); Auditor getAuditor(); @VisibleForTesting void setBoundValueSuppressor(BoundValueSuppressor suppressor); @VisibleForTesting BoundValueSuppressor getBoundValueSuppressor();  }