package com.juick.api;

import com.juick.Message;
import com.juick.server.component.MessageEvent;
import com.juick.server.util.HttpBadRequestException;
import com.juick.service.EmailService;
import com.juick.service.SubscriptionService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;

import javax.inject.Inject;
import javax.mail.MessagingException;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;

import static com.juick.formatters.PlainTextFormatter.formatPost;

@Component
public class EmailManager implements ApplicationListener<MessageEvent> {
    private static final Logger logger = LoggerFactory.getLogger(EmailManager.class);
    @Inject
    EmailService emailService;
    @Inject
    SubscriptionService subscriptionService;
    @Override
    public void onApplicationEvent(MessageEvent event) {
        Message msg = event.getMessage();
        if (msg.getRid() == 0) {
            subscriptionService.getSubscribedUsers(msg.getUser().getUid(), msg.getMid())
                    .forEach(user -> emailService.getEmails(user.getUid())
                            .forEach(email -> emailNotify(email, msg)));
        } else {
            subscriptionService.getUsersSubscribedToComments(msg.getMid(), msg.getUser().getUid())
                    .forEach(user -> emailService.getEmails(user.getUid())
                        .forEach(email -> emailNotify(email, msg)));
        }
    }

    void emailNotify(String email, Message msg) {
        Session session = Session.getDefaultInstance(System.getProperties());
        try {
            MimeMessage message = new MimeMessage(session);
            message.setFrom(new InternetAddress("noreply@mail.juick.com"));
            message.addRecipient(javax.mail.Message.RecipientType.TO, new InternetAddress(email));
            message.setSubject(String.format("New message from %s", msg.getUser().getName()));
            message.setText(formatPost(msg));
            Transport.send(message);
        } catch (MessagingException ex) {
            logger.error("mail exception", ex);
        }
    }
}