/*
 * Copyright 2016 Pivotal Software, Inc..
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package io.github.proxyprint.kitchen.utils;

import io.github.proxyprint.kitchen.models.consumer.Consumer;
import io.github.proxyprint.kitchen.models.notifications.Notification;
import io.github.proxyprint.kitchen.models.repositories.ConsumerDAO;
import io.github.proxyprint.kitchen.models.repositories.NotificationDAO;
import java.io.IOException;
import java.util.concurrent.ConcurrentHashMap;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;

/**
 *
 * @author jose
 */
public class NotificationManager {

    @Autowired
    private ConsumerDAO consumers;
    @Autowired
    private NotificationDAO notifications;
    
    
    private final ConcurrentHashMap<String, SseEmitter> subscriptions;

    public NotificationManager() {
        this.subscriptions = new ConcurrentHashMap<>();
    }

    public SseEmitter subscribe(String username) {
        SseEmitter sseEmitter = new SseEmitter();
        this.subscriptions.put(username, sseEmitter);
        return sseEmitter;
    }

    public void unsubscribe(String username) {
        this.subscriptions.remove(username);
    }

    public void sendNotification(String username, Notification notification) throws IOException {
        Consumer consumer = this.consumers.findByUsername(username);
        consumer.addNotifications(notification);
        consumers.save(consumer);

        SseEmitter sse = this.subscriptions.get(username);
        if (sse != null){
            sse.send(notification, MediaType.APPLICATION_JSON);
        }
    }
    
    public void removeNotification(long notificationId) {
        notifications.delete(notificationId);
    }
    
    public void readNotification (long notificationId){
        Notification n = notifications.findById(notificationId);
        n.setReadStatus(true); 
        notifications.save(n);
    }    
}

@@ -1974,32 +1974,89 @@
 name(username);%0A
+        notification = notifications.save(notification);%0A
         consumer
@@ -2122,16 +2122,24 @@
 sumer);%0A
+        
 %0A       

fix bug in notifications