D-Net

package eu.dnetlib.repo.manager.server.services;

import com.fasterxml.jackson.databind.ObjectMapper;

import com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException;

@SuppressWarnings("serial")

public class RepositoryServiceImpl extends SpringGwtRemoteServiceServlet implements RepositoryService {

    private static final Logger LOGGER = Logger

            .getLogger(RepositoryServiceImpl.class);

    @Autowired

    private EmailUtils emailUtils;

    private VocabularyLoader vocabularyLoader;

    private boolean testingMode;

    private PiwikDAO piwikDAO;

    private String analyticsURL;

            "<script type=\"text/javascript\">\n" +

            "\tvar _paq = _paq || [];\n" +

            "\t_paq.push(['enableLinkTracking']);\n" +

            "\t(function() {\n" +

            "\t\tvar u=\"//analytics.openaire.eu/\";\n" +

            "\t\t_paq.push(['setTrackerUrl', u+'piwik.php']);\n" +

            "\t\t_paq.push(['setSiteId', $$$]);\n" +

            "\t\t<% if(handle != null){%>\n" +

            "\t\t\t_paq.push(['setCustomVariable', 1, 'oaipmhID',\"oai:<%= baseUrl %>:<%=handle %>\", 'page']);\n" +

            "\t\t\t_paq.push(['trackPageView']);\n" +

            "\t\t<}>\n" +

            "\t\tvar d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0];\n" +

            "\t\tg.type='text/javascript'; g.async=true; g.defer=true; g.src=u+'piwik.js'; s.parentNode.insertBefore(g,s);\n" +

            "\t})();\n" +

            "</script>\n" +

            "<noscript>\n" +

            "\t<p>\n" +

            "\t\t<img src=\"//analytics.openaire.eu/piwik.php?idsite=47\" style=\"border:0;\" alt=\"\" />\n" +

            "\t</p>\n" +

            "</noscript>\n" +

            "<!— End Piwik Code —>");

    @Autowired

    private RepositoryApi repositoryApi;

    public void init() {

        this.loadVocabularies();

    }

                return this.getRepositoriesByCountryTesting(country, mode, includeUnknownCountries);

//                    throw new RepositoryServiceException("registration.noReposForThisCountry", RepositoryServiceException.ErrorCode.NO_REPOS_FOR_THIS_COUNTRY);

//                }

                retTuple.setFirst(reposList);

                List<Repository> unknownCountryList = this.repoAPI.getRepositoriesPerCountry(mode).get("UNKNOWN");

                List<Repository> totalList = new ArrayList<Repository>();

                if (withoutCountryList != null)

                    totalList.addAll(withoutCountryList);

                if (unknownCountryList != null)

                    totalList.addAll(unknownCountryList);

                retTuple.setSecond(totalList);

            }

            return retTuple;

                throw (RepositoryServiceException) e;

            } else {

            }

        }

    }

    @Override

        return this.getRepositoriesByCountry(country, mode, false).getFirst();

    }

    @Override

        try {

            LOGGER.debug("Getting repositories of user: " + userEmail + " . IncludeShared: "

                    + includeShared + " . IncludeByOthers: " + includeByOthers);

            String size = "50";

            while(resultSet.size() > 0 ){

                retDatasources.getDatasourcesOfUser().addAll(resultSet);

                page++;

                resultSet = repositoryApi.getRepositoriesOfUser(userEmail,String.valueOf(page),size);

            }

        } catch (JSONException e) {

            LOGGER.error("Error while getting repositories of user: " + userEmail + " . IncludeShared: " + includeShared + " . IncludeByOthers: " + includeByOthers, e);

    @Override

        try {

            LOGGER.debug("Getting repositories(urls) of user: " + userEmail + " . IncludeShared: " + includeShared + " . IncludeByOthers: " + includeByOthers);

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

            String size = "50";

            while(resultSet.size() > 0 ){

                retRepos.addAll(resultSet);

                page++;

                resultSet = repositoryApi.getUrlsOfUserRepos(userEmail,String.valueOf(page),size);

            }

        } catch (Exception e) {

            LOGGER.error("Error while getting repositories(urls) of user: " + userEmail + " . IncludeShared: " + includeShared + " . IncludeByOthers: " + includeByOthers, e);

    }

    @Override

        try {

            LOGGER.debug("Getting repository with id: " + repoId);

                for (RepositoryInterface iFace : repo.getInterfaces()) {

                    if (!iFace.getContentDescription().equals("file::hybrid") && iFace.getAccessProtocol().equalsIgnoreCase("oai")) {

                        iFace.setComplianceName(getComplianceName(iFace.getCompliance()));

                        if (iFace.getCompliance().equals("notCompatible"))

                            iFace.setComplianceName("not compatible");

                    }

                }

            } else

            return repo;

        } catch (Exception e) {

                throw (RepositoryServiceException) e;

            } else {

            }

        }

    }

    @Override

            LOGGER.debug("Getting countries");

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

            Map<String, String> countriesMap = new TreeMap<String, String>();

                countries.addAll(this.repoAPI.getRepositoriesByCountry(mode).keySet());

            } else {

                LOGGER.debug("using \"dnet:countries\" vocabulary");

//            countries.addAll(repositoryApi.getDnetCountries());

                countriesMap.put(country, WordUtils.capitalizeFully(country));

            }

            return countriesMap;

    }

    @Override

    @Override

        try {

            LOGGER.debug("Getting timezones from file");

            return LocalVocabularies.timezones;

            LOGGER.error("Error while getting timezones from file", e);

            emailUtils.reportException(e);

            throw new RepositoryServiceException("login.generalError", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

        }

    }

    @Override

    public List<String> getTypologies() throws RepositoryServiceException {

        try {

            LOGGER.debug("Getting typologies from file");

            return LocalVocabularies.typologies;

            emailUtils.reportException(e);

            throw new RepositoryServiceException("login.generalError", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

        }

    }

    @Override

    @Override

    @Override

            LOGGER.debug("Storing repository with name: " + repo.getOfficialName());

            JSONObject params = new JSONObject();

            ObjectMapper mapper = new ObjectMapper();

            String json_repo = mapper.writerWithDefaultPrettyPrinter().writeValueAsString(repo);

            params.put("repository", json_repo);

                LOGGER.error("Error while storing repository with name: " + repo.getOfficialName(), e);

                throw new RepositoryServiceException("Error while storing repository", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

            }

    public void updateRepositoryInformation(Repository repo) throws RepositoryServiceException {

        try {

            LOGGER.debug("Updating information of repo: " + repo.getOfficialName());

            repositoryApi.updateEnglishName(repo.getId(),repo.getEnglishName());

            repositoryApi.updateLatitude(repo.getId(), String.valueOf(repo.getLatitude()));

            repositoryApi.updateLongitude(repo.getId(), String.valueOf(repo.getLongitude()));

            repositoryApi.updateOfficialName(repo.getId(),repo.getOfficialName());

            repositoryApi.updateTimezone(repo.getId(),String.valueOf(repo.getTimezone()));

            LOGGER.error("Error while updating information of repo: " + repo.getOfficialName(), e);

            if (e instanceof RepositoryServiceException) {

                throw (RepositoryServiceException) e;

            } else {

                emailUtils.reportException(e);

                throw new RepositoryServiceException("login.generalError", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

            }

        }

    }

            LOGGER.debug("updating interface with id: " + iFace.getId());

            retIface = this.repoAPI.updateRepositoryInterfaceWithoutChecks(repoId, iFace, datatype);

            retIface.setComplianceName(this.getComplianceName(retIface.getCompliance()));

            LOGGER.error("error updating interface with id: " + iFace.getId(), e);

            if (e instanceof RepositoryServiceException) {

                throw (RepositoryServiceException) e;

            } else {

                emailUtils.reportException(e);

                throw new RepositoryServiceException("login.generalError", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

            }

        }

    @Override

            LOGGER.debug("inserting interface with id: " + iFace.getId());

            params.put("datatype",datatype);

            params.put("repoId",repoId);

            params.put("iFace",iFace);

            retIface = repositoryApi.addRepositoryInterface(params.toString());

            return retIface;

        } catch (Exception e) {

            LOGGER.error("error updating interface with id: " + iFace.getId(), e);

            if (e instanceof RepositoryServiceException) {

                throw (RepositoryServiceException) e;

            } else {

                emailUtils.reportException(e);

                throw new RepositoryServiceException("login.generalError", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

            }

        }

    }

    @Override

        iFaces.add(iFace);

    @Override

            LOGGER.debug("deleting interfaces of repo: " + repoId);

                LOGGER.info("deleting repository interface with url/set/id: " + iFace.getBaseUrl() + "/"

                        + iFace.getAccessSet() + "/" + iFace.getId());

                repositoryApi.deleteRepositoryInterface(iFace.getId());

            }

            LOGGER.error("deleting interfaces of repo: " + repoId, e);

            if (e instanceof RepositoryServiceException) {

                throw (RepositoryServiceException) e;

            } else {

                emailUtils.reportException(e);

                throw new RepositoryServiceException("login.generalError", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

            }

        }

    }

    @Override

            LOGGER.debug("Getting vocabularies for datasource with type: " + mode);

            vocs.setDatasourceClasses(this.getDatasourceClasses(mode));

            vocs.setTimezones(this.getTimezones());

            vocs.setTypologies(this.getTypologies());

            return vocs;

        } catch (Exception e) {

            LOGGER.error("Error while getting vocabularies for datasource with type: \" + mode", e);

            emailUtils.reportException(e);

            throw new RepositoryServiceException("login.generalError", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

        }

    }

        try {

            LOGGER.debug("Getting testing repositories of country: " + country + " with type: " + mode + " and includeUnknownCountries: " + includeUnknownCountries);

            Tuple<List<Repository>, List<Repository>> retTuple = new Tuple<List<Repository>, List<Repository>>();

            List<Repository> reposList = new ArrayList<Repository>();

            reposList.add(this.repoAPI.getRepository("opendoar____::1356"));

            reposList.add(this.repoAPI.getRepository("opendoar____::2678"));

            reposList.add(this.repoAPI.getRepository("opendoar____::2980"));

            reposList.add(this.repoAPI.getRepository("opendoar____::1347"));

            retTuple.setFirst(reposList);

                totalList.add(this.repoAPI.getRepository("opendoar____::3000"));

                totalList.add(this.repoAPI.getRepository("opendoar____::1027"));

                totalList.add(this.repoAPI.getRepository("opendoar____::1096"));

                retTuple.setSecond(totalList);

            }

            return retTuple;

        } catch (Exception e) {

                throw (RepositoryServiceException) e;

            } else {

                emailUtils.reportException(e);

                throw new RepositoryServiceException("login.generalError", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

            }

        }

    }

    public String getLatestUpdateDateOfList(String mode) throws RepositoryServiceException {

        try {

            LOGGER.debug("Getting latest update date of list: " + mode);

            return this.repoAPI.getListLatestUpdate(mode).split("T")[0];

        } catch (Exception e) {

            LOGGER.error("Error while getting latest update date of list: " + mode, e);

            emailUtils.reportException(e);

            throw new RepositoryServiceException("login.generalError", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

        }

    }

    public PiwikInfo getPiwikSiteForRepository(String repoId) throws RepositoryServiceException {

        try {

        } catch (EmptyResultDataAccessException e) {

            return null;

        }

    }

    @Override

//        try {

//            Map<String, Object> map = new ObjectMapper().readValue(URL, Map.class);

//

//            String siteId = (String) map.get("value");

            String authenticationToken = new Random(new Date().getTime()).nextInt(1000000000) + "";

            piwikInfo.setRepositoryId(repository.getId());

            piwikInfo.setCountry(repository.getCountryName());

            piwikInfo.setRequestorEmail(requestor.getEmail());

            piwikInfo.setRequestorName(requestor.getFirstname() + " " + requestor.getLastname());

//            LOGGER.error("Error while creating piwik site", e);

//            emailUtils.reportException(e);

//            throw new RepositoryServiceException("login.generalError", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

//        }

    @Override

    public String getPiwikScriptForRepository(String repoId) throws RepositoryServiceException {

        try {

            PiwikInfo piwikInfo = this.piwikDAO.getPiwikSiteForRepo(repoId);

            String piwikScript = PIWIK_SCRIPT.replace("$$$", piwikInfo.getSiteId());

            return piwikScript;

        } catch (EmptyResultDataAccessException e) {

            return null;

        }

    }

    public List<PiwikInfo> getPiwikSitesForRepositories() throws RepositoryServiceException {

        try {

            List<PiwikInfo> piwikInfos = new ArrayList<>();

            piwikInfos = this.piwikDAO.getPiwikSitesForRepos();

            return piwikInfos;

        } catch (EmptyResultDataAccessException e) {

            LOGGER.error("Error while getting list of piwik sites: ", e);

            emailUtils.reportException(e);

            throw new RepositoryServiceException("General error", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

        }

    }

    @Override

    public void approvePiwikSite(String repositoryId) throws RepositoryServiceException {

        try {

            this.piwikDAO.approvePiwikSite(repositoryId);

        } catch (EmptyResultDataAccessException e) {

            LOGGER.error("Error while approving piwik site: ", e);

            emailUtils.reportException(e);

            throw new RepositoryServiceException("General error", RepositoryServiceException.ErrorCode.GENERAL_ERROR);

        }

    }

        return countries.getEncoding(countryName);

    }

    private String getDatasourceClassCode(String datasourceClassName) {

        return datasourceClasses.getEncoding(datasourceClassName);

    }

        return compatibilityLevels.getEnglishName(complianceCode);

    }

        if (!vocabularyMap.containsKey(vocName)) {

        return vocabularyMap.get(vocName);

    }

        LOGGER.debug("loading vocabularies");

        for (String vocName : vocabularyNames) {

    }