D-Net

package eu.dnetlib.uoaadmintools.controllers;

import eu.dnetlib.uoaadmintools.dao.PortalSubscribersDAO;

import eu.dnetlib.uoaadmintools.dao.SubscriberDAO;

import eu.dnetlib.uoaadmintools.entities.subscriber.PortalSubscribers;

import eu.dnetlib.uoaadmintools.entities.subscriber.Subscriber;

import eu.dnetlib.uoaadmintools.handlers.ContentNotFoundException;

import eu.dnetlib.uoaadmintoolslibrary.dao.PortalDAO;

import org.apache.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.*;

import java.util.ArrayList;

import java.util.List;

/**

 * Created by argirok on 2/3/2018.

 */

@RestController

@CrossOrigin(origins = "*")

public class PortalSubscribersController {

    @Autowired

    PortalSubscribersDAO portalSubscribersDAO;

    @Autowired

    SubscriberDAO subscriberDAO;

    @Autowired

    PortalDAO portalDAO;

    private final Logger log = Logger.getLogger(this.getClass());

    @RequestMapping(value = "/community/subscribers", method = RequestMethod.GET)

    public List<PortalSubscribers> getAllPortalSubscribers(){

        return portalSubscribersDAO.findAll();

    }

    @RequestMapping(value = "/community/{pid}/subscribers", method = RequestMethod.GET)

    public PortalSubscribers getSubscribersPerPortal(@PathVariable(value="pid", required = true) String pid) throws ContentNotFoundException {

        PortalSubscribers portalSubscribers = portalSubscribersDAO.findByPid(pid);

        if(portalSubscribers != null){

            return portalSubscribers;

        }else{

            throw new ContentNotFoundException("Portal Subscribers not found");

        }

    }

    @RequestMapping(value = "/community/{pid}/subscribers", method = RequestMethod.POST)

    public PortalSubscribers addSubscriberInPortal(@PathVariable(value="pid", required = true) String pid, @RequestBody Subscriber subscriber) throws ContentNotFoundException {

        PortalSubscribers portalSubscribers = portalSubscribersDAO.findByPid(pid);

        if(portalSubscribers == null){

            throw new ContentNotFoundException("Portal Subscribers not found");

        }

        Subscriber savedSubscriber = subscriberDAO.findByEmail(subscriber.getEmail());

        if(savedSubscriber==null){

            savedSubscriber = subscriberDAO.save(subscriber);

        }

        for(Subscriber sub: portalSubscribers.getSubscribers()){

            if(sub.getEmail().equals(subscriber.getEmail())){

                //already subscribed

                return portalSubscribers;

            }

        }

        //not subscribed yet

        portalSubscribers.getSubscribers().add(savedSubscriber);

        return portalSubscribersDAO.save(portalSubscribers);

    }

    @RequestMapping(value = "/community/{pid}/subscribers/delete", method = RequestMethod.POST)

    public PortalSubscribers deleteSubscriberFromPortal(@PathVariable(value="pid", required = true) String pid, @RequestBody List<String> emails) throws ContentNotFoundException {

        PortalSubscribers portalSubscribers = portalSubscribersDAO.findByPid(pid);

        if(portalSubscribers == null){

            throw new ContentNotFoundException("Portal Subscribers not found");

        }

        List<Subscriber> list = new ArrayList<>();

        for(Subscriber s: portalSubscribers.getSubscribers()){

            if(emails.indexOf(s.getEmail())==-1){

             list.add(s);

            }

        }

        portalSubscribers.setSubscribers(list);

        return portalSubscribersDAO.save(portalSubscribers);

    }

    @RequestMapping(value = "/subscriber/communities", method = RequestMethod.GET)

    public List<String> getPortalsPerSubcriber(@RequestParam(value="email", required = true) String email) {

        List<PortalSubscribers> portalSubscribers = portalSubscribersDAO.findAll();

        List<String> list = new ArrayList<>();

        for(PortalSubscribers s: portalSubscribers){

            for(Subscriber sub:s.getSubscribers()) {

                if (sub.getEmail().equals(email)) {

                    list.add(s.getPid());

                    break;

                }

            }

        }

        return list;

    }

}