@Test
public void testResolveS3EventViaSNSEventSuccessfully() throws Exception {

    InputStream input = this.getClass().getClassLoader().getResourceAsStream(S3_VIA_SNS_REQUEST_JSON_TEMPLATE);
    Optional<S3EventNotification> event = executor.resolve(readJson(input));
    assertEquals(1, event.get().getRecords().size());
    assertEquals("aws:s3", event.get().getRecords().get(0).getEventSource());
    assertEquals("us-east-1", event.get().getRecords().get(0).getAwsRegion());
    assertEquals("dev-nsmg-logs-temp", event.get().getRecords().get(0).getS3().getBucket().getName());
    assertEquals("transformed_sample_logs.json", event.get().getRecords().get(0).getS3().getObject().getKey());
}