D-Net

package eu.dnetlib.data.claims.utils;

import com.google.gson.Gson;

import org.apache.log4j.Logger;

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.io.StringReader;

import java.net.HttpURLConnection;

import java.net.URL;

import java.util.List;

public class ManagerUtils {

    private static String registryAPIForManagerEmails;

    private String id;

    private String email;

    private String name;

    private String memberSince;

    private final static Logger log = Logger.getLogger(ManagerUtils.class);

    public String getRegistryAPIForManagerEmails() { return registryAPIForManagerEmails; }

    public void setRegistryAPIForManagerEmails(String registryAPIForManagerEmails) { ManagerUtils.registryAPIForManagerEmails = registryAPIForManagerEmails; }

    public String getName() {

        return name;

    }

    public void setName(String name) {

        this.name = name;

    }

    public String getId() {

        return id;

    }

    public void setId(String id) {

        this.id = id;

    }

    public String getEmail() {

        return email;

    }

    public void setEmail(String email) {

        this.email = email;

    }

    public String getMemberSince() {

        return memberSince;

    }

    public void setMemberSince(String memberSince) {

        this.memberSince = memberSince;

    }

    public  List<ManagerUtils> getManagersByEmail(String community) {

        String url = registryAPIForManagerEmails.replace("{community}", community);

        URL obj = null;

        String responseStr = null;

        log.debug("Registry url is " + url);

        try {

            obj = new URL(url);

            HttpURLConnection con = (HttpURLConnection) obj.openConnection();

            log.debug("Get manager emails from registry response code is: " + con.getResponseCode());

            if (con.getResponseCode() != 200) {

                return null;

            }

            BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));

            StringBuffer response = new StringBuffer();

            String inputLine;

            while ((inputLine = in.readLine()) != null) {

                response.append(inputLine).append("\n");

            }

            in.close();

            responseStr = response.toString();

        } catch (Exception e) {

            log.error("An error occured while trying to fetch manager emails from registry ", e);

            return null;

        }

        return json2ManagerUtils(responseStr);

    }

    class ManagersResponse {

        public List<ManagerUtils> response;

        public List<ManagerUtils> getResponse() {

            return response;

        }

        public void setResponse(List<ManagerUtils> response) {

            this.response = response;

        }

    }

    private List<ManagerUtils> json2ManagerUtils(String json){

        log.debug("Try to create List<ManagerUtils> from json: "+json);

        if (json == null){

            return null;

        }

        BufferedReader br = new BufferedReader(new StringReader(json));

        //convert the json string back to object

        Gson gson = new Gson();

        ManagersResponse managersResponse = null;

        List<ManagerUtils> managerUtilsList = null;

        try {

            managersResponse = gson.fromJson(br, ManagersResponse.class);

            managerUtilsList = managersResponse.getResponse();

        }catch(Exception e){

            log.debug("Error in parsing json response. Given json is : "+json, e);

            return null;

        }

        log.debug("Original response.........: "+managersResponse.toString());

        return managerUtilsList;

    }

}

//import eu.dnetlib.data.claims.utils.CommunityUtils;

import eu.dnetlib.data.claims.utils.ManagerUtils;

//    @Autowired

//    private CommunityUtils communityUtils;

    private ManagerUtils managerUtils;

                    //CommunityUtils communityInfo = this.communityUtils.getCommunityInfo(openaireId);

                    List<ManagerUtils> managerUtils = this.managerUtils.getManagersByEmail(openaireId);

                    //managers = communityInfo.getManagers();

                    if(managerUtils != null) {

                        Iterator<ManagerUtils> itr = managerUtils.iterator();

                            String manager = (String) itr.next().getEmail();

                                if(managers == null) {

                                    managers = new ArrayList<>();

                                }

                                managers.add(manager);

            Map<String, List<String>> allManagers = new HashMap<>();

                        if(!allManagers.containsKey(notification.getOpenaireId())) {

                            allManagers.put(notification.getOpenaireId(), new ArrayList());

//                        CommunityUtils communityInfo = this.communityUtils.getCommunityInfo(notification.getOpenaireId());

                            List<ManagerUtils> managerUtils = this.managerUtils.getManagersByEmail(notification.getOpenaireId());

//                        List<String> managers = null;

                            if (managerUtils != null) {

                                for (ManagerUtils manager : managerUtils) {

                                    allManagers.get(notification.getOpenaireId()).add(manager.getEmail());

                                }

                            }

//                        if (managers != null && managers.contains(notification.getUserMail())) {

                        if(allManagers.get(notification.getOpenaireId()).contains(notification.getUserMail())) {

                            } else {

                                logger.debug("[no notification] User "+notification.getUserMail()+" got latest notification at "+last_interaction_date+" and has set frequency to: "+notification.getFrequency());

                        } else {

                            logger.debug("User "+notification.getUserMail()+" is not manager of community "+notification.getOpenaireId());

//    public void setCommunityUtils(CommunityUtils communityUtils) {

//        this.communityUtils = communityUtils;

//    }

//

//    public CommunityUtils getCommunityUtils() {

//        return communityUtils;

//    }

    public ManagerUtils getManagerUtils() {

        return managerUtils;

    public void setManagerUtils(ManagerUtils managerUtils) {

        this.managerUtils = managerUtils;

services.claims.registryAPIForManagerEmails = http://mpagasas.di.uoa.gr:8080/dnet-openaire-users-1.0.0-SNAPSHOT/api/registry/community/{community}/managers/email

services.claims.searchAPIUrl = http://beta.services.openaire.eu:8480/search/

#services.claims.results.pathToSaveRecord = /home/konstantina/claims-www-last/records/

#services.claims.reports.pathToSaveReport = /home/konstantina/claims-www-last/reports/

    <bean id="managerUtils" class="eu.dnetlib.data.claims.utils.ManagerUtils">

        <property name="registryAPIForManagerEmails" value="${services.claims.registryAPIForManagerEmails}"/>

    </bean>