Polling Backend#

/**
 * @author hcguler
 */
@HvlPublicFeignRestService
@FeignClient(name = "notificationPollingRestService",
        path = "${hvl.notification.polling.service.user.path:/polling/user}",
        url = "${hvl.notification.polling.service.user.url:${hvl.polling.notification.service.url}}")
public interface HvlNotificationPollingUserRestService {

    /**
     * getUnreadNotificationCount is a method which provides unread notification count according to token owner
     *
     * @return
     */
    @GetMapping(path = "/count/{assigneeUser}")
    HvlResponse<Number> getUnreadNotificationCount(@NotBlank @PathVariable("assigneeUser") String assigneeUser);

    /**
     * markReadNotification is a method which provides mark read notification
     *
     * @return
     */
    @GetMapping(path = "/markRead/{notificationId}")
    HvlResponse<Void> markReadNotification(@NotNull @PathVariable("notificationId") Long notificationId);

    /**
     * markAllRead is a method which provides all unread notification marked read
     *
     * @return
     */
    @GetMapping(path = "/markAllRead/{assigneeUser}")
    HvlResponse<Void> markAllRead(@NotBlank @PathVariable("assigneeUser") String assigneeUser);

    /**
     * sendAnnouncement is a method which provides send user specific notification
     *
     * @param pollingNotificationUserModel
     * @return
     */
    @PostMapping(path = "/send", produces = MediaType.APPLICATION_JSON_VALUE,
            consumes = MediaType.APPLICATION_JSON_VALUE)
    HvlResponse<HvlNotificationPollingUserModel> sendUserSpecific(
            @Valid @RequestBody HvlNotificationPollingUserModel pollingNotificationUserModel);

    /**
     * getUnreadNotifications is a method which provides notifications according to pollingNotificationQueryModel
     *
     * @param pollingNotificationQueryModel
     * @return
     */
    @PostMapping(path = "/notifications",
            produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE)
    HvlResponse<HvlPage<HvlNotificationPollingUserModel>> getNotificationPage(
            @Validated(value = {HvlNotificationPollingUserQueryModel.UserNotification.class})
            @RequestBody HvlNotificationPollingUserQueryModel pollingNotificationQueryModel);
}

public class HvlNotificationPollingAnnouncementModel extends HvlNotificationPayload {

    @NotNull
    private OffsetDateTime expirationDate;

    public OffsetDateTime getExpirationDate() {
        return expirationDate;
    }

    public void setExpirationDate(OffsetDateTime expirationDate) {
        this.expirationDate = expirationDate;
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        if (!super.equals(o)) return false;
        HvlNotificationPollingAnnouncementModel that = (HvlNotificationPollingAnnouncementModel) o;
        return Objects.equals(expirationDate, that.expirationDate);
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public int hashCode() {
        return Objects.hash(super.hashCode(), expirationDate);
    }

}

public class HvlNotificationPollingUserModel extends HvlNotificationPayload {

    @NotBlank
    private String assigneeUser;

    private boolean read;

    public String getAssigneeUser() {
        return assigneeUser;
    }

    public void setAssigneeUser(String assigneeUser) {
        this.assigneeUser = assigneeUser;
    }

    public boolean isRead() {
        return read;
    }

    public void setRead(boolean isRead) {
        this.read = isRead;
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        if (!super.equals(o)) return false;
        HvlNotificationPollingUserModel that = (HvlNotificationPollingUserModel) o;
        return read == that.read && Objects.equals(assigneeUser, that.assigneeUser);
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public int hashCode() {
        return Objects.hash(super.hashCode(), assigneeUser, read);
    }
}