From 54339e34331a1204d16ec4997dbb4a181452a60b Mon Sep 17 00:00:00 2001 From: JeremyTubongbanua Date: Mon, 24 Oct 2022 18:50:39 -0400 Subject: [PATCH] feat: NotificationService interface --- .../api/notification/NotificationService.java | 23 +++++++++++++++++++ 1 file changed, 23 insertions(+) create mode 100644 at_client/src/main/java/org/atsign/client/api/notification/NotificationService.java diff --git a/at_client/src/main/java/org/atsign/client/api/notification/NotificationService.java b/at_client/src/main/java/org/atsign/client/api/notification/NotificationService.java new file mode 100644 index 00000000..6a7dd2bb --- /dev/null +++ b/at_client/src/main/java/org/atsign/client/api/notification/NotificationService.java @@ -0,0 +1,23 @@ +package org.atsign.client.api.notification; + +import java.util.List; +import java.util.concurrent.CompletableFuture; + +import org.atsign.client.api.AtClient; +import org.atsign.client.api.AtEvents; +import org.atsign.client.api.impl.clients.NotificationServiceImpl; + +public interface NotificationService { + + public static NotificationService create(AtClient atClient) { + return new NotificationServiceImpl(atClient); + } + + CompletableFuture subscribe(String regex, boolean shouldDecrypt); // TODO Replace "Object" with Stream or similar. See: https://github.com/atsign-foundation/at_client_sdk/blob/99707459494594fbdc3f0873769eeca29c6a3124/packages/at_client/lib/src/service/notification_service.dart#L14 + CompletableFuture notify(NotificationParams params); + CompletableFuture getStatus(String notificationId); + CompletableFuture> notifyList(); + CompletableFuture notifyDelete(String notificationId); + CompletableFuture notifyDeleteAll(); + +}