Skip to content

Commit 5fa27bb

Browse files
committed
ice: Fix watch ignoring all s3:ObjectCreated:* but s3:ObjectCreated:Put
1 parent bc1d614 commit 5fa27bb

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

ice/src/main/java/com/altinity/ice/cli/internal/cmd/InsertWatch.java

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -187,16 +187,16 @@ private static Collection<String> filter(List<Message> messages, Collection<Matc
187187
String bucketName = record.at("/s3/bucket/name").asText();
188188
String objectKey = record.at("/s3/object/key").asText();
189189
var target = String.format("s3://%s/%s", bucketName, objectKey);
190-
switch (eventName) {
191-
case "ObjectCreated:Put":
192-
// TODO: exclude metadata/data dirs by default
193-
if (matchers.stream().anyMatch(matcher -> matcher.test(target))) {
194-
r.add(target);
195-
}
196-
default:
197-
if (logger.isTraceEnabled()) {
198-
logger.trace("Message skipped: {} {}", eventName, target);
199-
}
190+
// s3:ObjectCreated:{Put,Post,Copy,CompleteMultipartUpload}
191+
if (eventName.startsWith("ObjectCreated:")) {
192+
// TODO: exclude metadata/data dirs by default
193+
if (matchers.stream().anyMatch(matcher -> matcher.test(target))) {
194+
r.add(target);
195+
}
196+
} else {
197+
if (logger.isTraceEnabled()) {
198+
logger.trace("Message skipped: {} {}", eventName, target);
199+
}
200200
}
201201
}
202202
}

0 commit comments

Comments
 (0)