/*
 * Copyright (C) 2008-2017, Juick
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

package com.juick.server.api;

import com.juick.Reaction;
import com.juick.Status;
import com.juick.User;
import com.juick.server.CommandsManager;
import com.juick.server.EmailManager;
import com.juick.server.XMPPConnection;
import com.juick.server.helpers.CommandResult;
import com.juick.server.util.*;
import com.juick.service.MessagesService;
import com.juick.service.SubscriptionService;
import com.juick.service.UserService;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.mail.util.MimeMessageParser;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import springfox.documentation.annotations.ApiIgnore;

import javax.inject.Inject;
import javax.mail.Session;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import javax.validation.constraints.NotNull;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URI;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.nio.file.Paths;
import java.util.*;

/**
 * Created by vt on 24/11/2016.
 */
@RestController
public class Post {
    private static Logger logger = LoggerFactory.getLogger(Post.class);

    @Inject
    private UserService userService;
    @Inject
    private XMPPConnection xmppConnection;
    @Inject
    private MessagesService messagesService;
    @Inject
    private SubscriptionService subscriptionService;
    @Value("${upload_tmp_dir:#{systemEnvironment['TEMP'] ?: '/tmp'}}")
    private String tmpDir;
    @Value("${img_path:#{systemEnvironment['TEMP'] ?: '/tmp'}}")
    private String imgDir;
    @Value("${api_user:juick}")
    private String serviceUser;
    @Inject
    CommandsManager commandsManager;

    @RequestMapping(value = "/post", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
    @ResponseStatus(value = HttpStatus.OK)
    public void doPostMessage(
            @RequestParam String body,
            @RequestParam(required = false) String img,
            @RequestParam(required = false) MultipartFile attach) throws Exception {
        User visitor = UserUtils.getCurrentUser();

        if (visitor.isAnonymous())
            throw new HttpForbiddenException();

        if (body == null || body.length() < 1 || body.length() > 4096) {
            throw new HttpBadRequestException();
        }
        body = body.replace("\r", StringUtils.EMPTY);

        URI attachmentFName = HttpUtils.receiveMultiPartFile(attach, tmpDir);

        if (StringUtils.isBlank(attachmentFName.toString()) && img != null && img.length() > 10) {
            try {
                URL imgUrl = new URL(img);
                attachmentFName = HttpUtils.downloadImage(imgUrl, tmpDir);
            } catch (Exception e) {
                logger.error("DOWNLOAD ERROR", e);
                throw new HttpBadRequestException();
            }
        }
        commandsManager.processCommand(visitor, body, attachmentFName);
    }
    @PostMapping("/upload")
    public String doUploadFile(@RequestParam(required = true) MultipartFile attach) {
        return HttpUtils.receiveMultiPartFile(attach, tmpDir).toString();
    }

    @RequestMapping(value = "/comment", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
    public com.juick.Message doPostComment(
            @RequestParam(defaultValue = "0") int mid,
            @RequestParam(defaultValue = "0") int rid,
            @RequestParam String body,
            @RequestParam(required = false) String img,
            @RequestParam(required = false) MultipartFile attach)
            throws Exception {
        User visitor = UserUtils.getCurrentUser();
        int vuid = visitor.getUid();
        if (vuid == 0) {
            throw new HttpForbiddenException();
        }
        if (mid == 0) {
            throw new HttpBadRequestException();
        }
        com.juick.Message msg = messagesService.getMessage(mid);
        if (msg == null) {
            throw new HttpNotFoundException();
        }

        com.juick.Message reply = null;
        if (rid > 0) {
            reply = messagesService.getReply(mid, rid);
            if (reply == null) {
                throw new HttpNotFoundException();
            }
        }

        if (body == null || body.length() < 1 || body.length() > 4096) {
            throw new HttpBadRequestException();
        }
        body = body.replace("\r", StringUtils.EMPTY);

        if ((msg.ReadOnly && msg.getUser().getUid() != vuid) || userService.isInBLAny(msg.getUser().getUid(), vuid)
                || (reply != null && userService.isInBLAny(reply.getUser().getUid(), vuid))) {
            throw new HttpForbiddenException();
        }

        URI attachmentFName = HttpUtils.receiveMultiPartFile(attach, tmpDir);

        if (StringUtils.isBlank(attachmentFName.toString()) && img != null && img.length() > 10) {
            try {
                attachmentFName = HttpUtils.downloadImage(new URL(img), tmpDir);
            } catch (Exception e) {
                logger.error("DOWNLOAD ERROR", e);
                throw new HttpBadRequestException();
            }
        }

        return commandsManager.processCommand(visitor, String.format("#%d/%d %s", mid, rid, body), attachmentFName).getNewMessage().get();
    }

    Session session = Session.getDefaultInstance(new Properties());

    @ApiIgnore
    @PostMapping("/mail")
    @ResponseStatus(value = HttpStatus.OK)
    public void processMail(InputStream data) throws Exception {
        if (UserUtils.getCurrentUser().getName().equals(serviceUser)) {
            MimeMessage msg = new MimeMessage(session, data);
            logger.info("got msg {}", msg.toString());
            String from = msg.getFrom() == null || msg.getFrom().length > 1 ? ((InternetAddress) msg.getSender()).getAddress()
                    : ((InternetAddress) msg.getFrom()[0]).getAddress();

            User visitor = userService.getUserByEmail(from);
            if (!visitor.isAnonymous()) {
                MimeMessageParser parser = new MimeMessageParser(msg);
                parser.parse();
                final String[] body = {parser.getPlainContent()};
                if (body[0] == null) {
                    parser.getAttachmentList().stream()
                            .filter(a -> a.getContentType().equals("text/plain")).findFirst()
                            .ifPresent(a -> {
                                try {
                                    body[0] = IOUtils.toString(a.getInputStream(), StandardCharsets.UTF_8);
                                    logger.info("got text: {}", body[0]);
                                } catch (IOException e) {
                                    logger.info("attachment error: {}", e);
                                }
                            });
                }
                final String[] attachmentFName = new String[1];
                parser.getAttachmentList().stream().filter(a ->
                        a.getContentType().equals("image/jpeg") || a.getContentType().equals("image/png"))
                        .findFirst().ifPresent(a -> {
                    logger.info("got attachment: {}", a.getContentType());
                    String attachmentType;
                    if (a.getContentType().equals("image/jpeg")) {
                        attachmentType = "jpg";
                    } else {
                        attachmentType = "png";
                    }
                    attachmentFName[0] = DigestUtils.md5Hex(UUID.randomUUID().toString()) + "." + attachmentType;
                    try {
                        logger.info("got inputstream: {}", a.getInputStream());
                        FileOutputStream fos = new FileOutputStream(Paths.get(tmpDir, attachmentFName[0]).toString());
                        IOUtils.copy(a.getInputStream(), fos);
                        fos.close();
                    } catch (IOException e) {
                        logger.info("attachment error: {}", e);
                    }
                });
                String[] inReplyToHeaders = msg.getHeader("In-Reply-To");
                if (inReplyToHeaders != null && inReplyToHeaders.length > 0) {
                    Scanner inReplyToScanner = new Scanner(inReplyToHeaders[0].trim()).useDelimiter(EmailManager.MSGID_PATTERN);
                    int mid = Integer.parseInt(inReplyToScanner.next());
                    int rid = Integer.parseInt(inReplyToScanner.next());
                    logger.info("Message is reply to #{}/{}", mid, rid);
                    body[0] = rid > 0 ? String.format("#%d/%d %s", mid, rid, body[0])
                            : String.format("#%d %s", mid, body[0]);
                }
                URI attachmentUri = StringUtils.isNotEmpty(attachmentFName[0]) ? URI.create(String.format("juick://%s", attachmentFName[0]))
                        : URI.create(StringUtils.EMPTY);
                commandsManager.processCommand(visitor, body[0], attachmentUri);
            } else {
                logger.info("not registered: {}", from);
            }
        } else {
            throw new HttpForbiddenException();
        }
    }

    @PostMapping("/like")
    @ResponseStatus(value = HttpStatus.OK)
    public Status doPostRecomm(@RequestParam Integer mid) throws Exception {
        com.juick.User visitor = UserUtils.getCurrentUser();
        if (visitor.getUid() == 0) {
            throw new HttpForbiddenException();
        }
        com.juick.Message msg = messagesService.getMessage(mid);
        if (msg == null) {
            throw new HttpNotFoundException();
        }
        if (msg.getUser().getUid() == visitor.getUid()) {
            throw new HttpForbiddenException();
        }
        CommandResult status = commandsManager.processCommand(visitor, String.format("! #%d", mid),
                URI.create(StringUtils.EMPTY));
        return Status.getStatus(status.getText());
    }

    @GetMapping("/reactions")
    @ResponseStatus(value = HttpStatus.OK)
    public List<Reaction> reactionsList() {
        return messagesService.listReactions();
    }

    @PostMapping("/react")
    @ResponseStatus(value = HttpStatus.OK)
    public Status doPostReact(@RequestParam Integer mid,@RequestParam @NotNull int reactionId){

        logger.info("got reaction with type: {}", reactionId);
        com.juick.User visitor = UserUtils.getCurrentUser();
        if (visitor.getUid() == 0) {
            throw new HttpForbiddenException();
        }
        com.juick.Message msg = messagesService.getMessage(mid);
        if (msg == null) {
            throw new HttpNotFoundException();
        }
        if (msg.getUser().getUid() == visitor.getUid()) {
            throw new HttpForbiddenException();
        }

        MessagesService.RecommendStatus recommendStatus = messagesService.likeMessage(mid,visitor.getUid(),
                reactionId);

        return  recommendStatus ==  MessagesService.RecommendStatus.Error ? Status.ERROR :Status.OK;
    }
}