final UUID uuid = UUID.randomUUID();
final IpAddress ipAddress = new IpAddress("127.0.0.1", 1337);
final IpAddress ipAddress2 = new IpAddress("127.0.0.2", 7331);
//Doesn't exist
this.execute(new CallableWithoutResult() {
@Override
protected void callWithoutResult() {
final Map<Address, PhysicalAddress> addresses = pingDao.getAddresses(cluster);
assertEquals(0, addresses.size());
}
});
//Delete nothing
this.execute(new CallableWithoutResult() {
@Override
protected void callWithoutResult() {
final Collection<Address> addresses = Arrays.<Address>asList(ipAddress, ipAddress2);
pingDao.purgeOtherAddresses(cluster, addresses);
}
});
//Create
this.execute(new CallableWithoutResult() {
@Override
protected void callWithoutResult() {
pingDao.addAddress(cluster, uuid, ipAddress);
}
});
//verify
this.execute(new CallableWithoutResult() {
@Override
protected void callWithoutResult() {
final Map<Address, PhysicalAddress> addresses = pingDao.getAddresses(cluster);
assertEquals(1, addresses.size());
final Entry<Address, PhysicalAddress> entry = addresses.entrySet().iterator().next();
assertEquals(uuid, entry.getKey());
assertEquals(ipAddress, entry.getValue());
}
});
//Update
this.execute(new CallableWithoutResult() {
@Override
protected void callWithoutResult() {
pingDao.addAddress(cluster, uuid, ipAddress2);
}
});
//verify
this.execute(new CallableWithoutResult() {
@Override
protected void callWithoutResult() {
final Map<Address, PhysicalAddress> addresses = pingDao.getAddresses(cluster);
assertEquals(1, addresses.size());
final Entry<Address, PhysicalAddress> entry = addresses.entrySet().iterator().next();
assertEquals(uuid, entry.getKey());
assertEquals(ipAddress2, entry.getValue());
}
});
//Delete
this.execute(new CallableWithoutResult() {
@Override
protected void callWithoutResult() {
final Collection<Address> addresses = Arrays.<Address>asList(ipAddress);
pingDao.purgeOtherAddresses(cluster, addresses);
}
});
//Doesn't exist
this.execute(new CallableWithoutResult() {
@Override
protected void callWithoutResult() {
final Map<Address, PhysicalAddress> addresses = pingDao.getAddresses(cluster);
assertEquals(0, addresses.size());
}