D-Net

import eu.dnetlib.domain.data.PiwikInfo;

import eu.dnetlib.repo.manager.shared.RepositoryServiceException;

import org.springframework.http.ResponseEntity;

    PiwikInfo savePiwikInfo(PiwikInfo piwikInfo);

    ResponseEntity<Object> approvePiwikSite(String repositoryId);

import com.fasterxml.jackson.databind.ObjectMapper;

import eu.dnetlib.domain.data.PiwikInfo;

import eu.dnetlib.repo.manager.shared.RepositoryServiceException;

import org.apache.commons.codec.digest.DigestUtils;

import org.apache.log4j.Logger;

import org.springframework.http.HttpStatus;

import org.springframework.http.ResponseEntity;

import org.springframework.jdbc.core.JdbcTemplate;

import org.springframework.jdbc.core.RowMapper;

import org.springframework.security.access.prepost.PreAuthorize;

import org.springframework.stereotype.Service;

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

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

import java.io.UnsupportedEncodingException;

import java.net.URL;

import java.net.URLEncoder;

import java.sql.Types;

import java.util.List;

import java.util.Map;

@Service("piwikService")

public class PiWikServiceImpl implements PiWikService {

    @Autowired

    @Qualifier("emailUtils")

    EmailUtils emailUtils;

    private final static String INSERT_PIWIK_INFO = "insert into piwik_site (repositoryid, siteid, creationdate, requestorname, requestoremail, validated, repositoryname, country, authenticationtoken) values (?, ?, now(), ?, ?, ?, ?, ?, ?)";

    private final static String APPROVE_PIWIK_SITE = "update piwik_site set validated=true, validationdate=now() where repositoryid = ?;";

    @Override

        try{

            return new JdbcTemplate(dataSource).queryForObject(GET_PIWIK_SITE, new String[]{repositoryId}, new int[]{Types.VARCHAR}, piwikRowMapper);

        }catch (EmptyResultDataAccessException e){

    @Override

    @PreAuthorize("hasRole('ROLE_ADMIN') or hasRole('ROLE_PROVIDE_ADMIN') or (hasRole('ROLE_USER') and #piwikInfo.requestorEmail == authentication.userInfo.email)")

        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);

        jdbcTemplate.update(INSERT_PIWIK_INFO, new Object[]{piwikInfo.getRepositoryId(), piwikInfo.getSiteId(), piwikInfo.getRequestorName(),

                        piwikInfo.getRequestorEmail(), piwikInfo.isValidated(), piwikInfo.getRepositoryName(), piwikInfo.getCountry(), piwikInfo.getAuthenticationToken()},

    }

    @Override

        LOGGER.debug("Getting piwik sites for repos! ");

        try{

        }catch (EmptyResultDataAccessException e){

            return null;

        }

    @Override

    @PreAuthorize("hasRole('ROLE_ADMIN') or hasRole('ROLE_PROVIDE_ADMIN')")

        new JdbcTemplate(dataSource).update(APPROVE_PIWIK_SITE, new Object[] {repositoryId}, new int[] {Types.VARCHAR});

        return new ResponseEntity<>("OK",HttpStatus.OK);

    }

    @Override

        if (repositoryId != null && repositoryId.contains("::"))

            return repositoryId.split("::")[0] + "::" + DigestUtils.md5Hex(repositoryId.split("::")[1]);

        return null;

    @Override

    @PreAuthorize("hasRole('ROLE_ADMIN') or hasRole('ROLE_PROVIDE_ADMIN')")

        try {

            approvePiwikSite(repositoryId);

    @Override

    @PreAuthorize("hasRole('ROLE_ADMIN') or hasRole('ROLE_PROVIDE_ADMIN') or (hasRole('ROLE_USER') and #piwikInfo.requestorEmail == authentication.userInfo.email)")

        try {

            String URL = analyticsURL + "siteName=" + URLEncoder.encode(officialName, "UTF-8") + "&url="

                    + URLEncoder.encode(repoWebsite, "UTF-8");

            piwikInfo.setSiteId(siteId);

            savePiwikInfo(piwikInfo);

            emailUtils.sendAdministratorRequestToEnableMetrics(piwikInfo);

            emailUtils.sendUserRequestToEnableMetrics(piwikInfo);

        } catch (UnsupportedEncodingException uee) {

        httpHeaders.set("Content-Type", "application/json");

        LOGGER.debug("Init dnet topics!");

            ObjectMapper mapper = new ObjectMapper();

            JsonNode root = mapper.readTree(is);

            for (JsonNode term : root.path("terms") )

        //TODO check identitites

        //Map<String,String> identity = new HashMap<>();

        repositoryMap.put("identities",identities);

        repositoryMap.put("subjects","");

public class StatsController {

    @Autowired

    @RequestMapping(value = "/getStatistics" , method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

       return statsService.getStatistics();

    }

}

public class UserController {

    @Autowired

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

    @PreAuthorize("hasRole('ROLE_USER')")

public class RepositoryController {

    @Autowired

    @RequestMapping(value = "/getCountries", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @RequestMapping(value = "/getDnetCountries", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

        return repositoryService.getDnetCountries();

    }

    @RequestMapping(value = "/getTypologies", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

        return repositoryService.getTypologies();

    }

    @RequestMapping(value = "/getTimezones", method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

        return repositoryService.getTimezones();

    }

package eu.dnetlib.repo.manager.controllers;

import eu.dnetlib.domain.data.PiwikInfo;

import eu.dnetlib.repo.manager.service.PiWikServiceImpl;

import eu.dnetlib.repo.manager.shared.RepositoryServiceException;

import io.swagger.annotations.Api;

public class PiWikController {

    @Autowired

    @RequestMapping(value = "/getPiwikSiteForRepo/{repositoryId}" , method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_VALUE)

    }

    @RequestMapping(value = "/getPiwikSitesForRepos" , method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_VALUE)

    }

    @RequestMapping(value = "/approvePiwikSite/{repositoryId}" , method = RequestMethod.GET)

    @RequestMapping(value = "/getOpenaireId/{repositoryId}" , method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

        return piWikService.getOpenaireId(repositoryid);

    }

public class BrokerController{

    @Autowired

    @RequestMapping(value = "/getDatasourcesOfUser" , method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER')")

                                           @ApiParam(value = "User email", required = true) String user,

                                           @RequestParam("includeShared")

                                           @ApiParam(value = "Include shared datasources", required = true , defaultValue = "false") String includeShared,

            method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

        return brokerService.getTopicsForDatasource(datasourceName);

    }

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER')")

                                  @PathVariable("size") String size,

                                  @RequestBody AdvQueryObject advQueryObject) throws BrokerException, JSONException ,IOException{

        return brokerService.advancedShowEvents(page, size, advQueryObject);

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER')")

                          @RequestParam("topic") String topic,

                          @RequestParam("page") String page,

                          @RequestParam("size") String size) throws BrokerException, JSONException{

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER')")

        return brokerService.getSimpleSubscriptionsOfUser(userEmail);

    }

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER') ")

        return brokerService.subscribe(obj);

    }

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER')")

        return brokerService.unsubscribe(subscriptionId);

    }

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER')")

        return brokerService.getSubscription(subscriptionId);

    }

    @RequestMapping(value = "/getDnetTopics" , method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

        return brokerService.getDnetTopics();

    }

            ,produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    @PreAuthorize("hasRole('ROLE_USER')")

                                                @PathVariable("page") String page,

                                                @PathVariable("size") String size) throws BrokerException{

        return brokerService.getNotificationsBySubscriptionId(subscriptionId, page, size);

    }

}

public class ValidatorController {

    @Autowired

    @RequestMapping(value = "/submitJobForValidation",method = RequestMethod.POST,

            consumes = MediaType.APPLICATION_JSON_VALUE,

public class DashboardController {

    @Autowired

    @RequestMapping(value = "/getRepositoriesSummary/{userEmail}/{page}/{size}" , method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

            .getLogger(MonitorController.class);

    @Autowired

    @RequestMapping(value = "/getJobsOfUser" , method = RequestMethod.GET,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseStatus(HttpStatus.NOT_FOUND)

    @ExceptionHandler(ResourceNotFoundException.class)

    @ResponseBody

        return new ServerError(req.getRequestURL().toString(),ex);

    }

    @ResponseStatus(HttpStatus.FORBIDDEN)

    @ExceptionHandler(AccessDeniedException.class)

    @ResponseBody

        return new ServerError(req.getRequestURL().toString(),ex);

    }

    @ResponseStatus(HttpStatus.NOT_FOUND)

    @ExceptionHandler(UnknownHostException.class)

    @ResponseBody

        return new ServerError(req.getRequestURL().toString(),ex);

    }

    @ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)

    @ExceptionHandler({JSONException.class,BrokerException.class,ValidatorServiceException.class})

    @ResponseBody

        return new ServerError(req.getRequestURL().toString(),ex);

    }

    @ResponseStatus(HttpStatus.GATEWAY_TIMEOUT)

    @ExceptionHandler(EndPointException.class)

    @ResponseBody

        return new ServerError(req.getRequestURL().toString(),ex);

    }

}

    @Autowired

    @RequestMapping(value = "/getReportResults/{page}/{pageSize}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody