full/src/main/java/de/ids_mannheim/korap/web/filter/PiwikFilter.java

package de.ids_mannheim.korap.web.filter;

import java.security.SecureRandom;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.Random;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.glassfish.jersey.client.ClientConfig;
import org.glassfish.jersey.logging.LoggingFeature;
import org.springframework.beans.factory.annotation.Autowired;

import de.ids_mannheim.korap.authentication.AuthenticationManager;
import jakarta.ws.rs.client.Client;
import jakarta.ws.rs.client.ClientBuilder;
import jakarta.ws.rs.client.WebTarget;
import jakarta.ws.rs.container.ContainerRequestContext;
import jakarta.ws.rs.container.ContainerRequestFilter;
import jakarta.ws.rs.core.UriBuilder;
import net.minidev.json.JSONArray;

/**
 * @author hanl
 * @date 13/05/2014
 */
@Deprecated
//@Component
//@Priority(Priorities.AUTHORIZATION)
public class PiwikFilter implements ContainerRequestFilter {

    private WebTarget service;
    //    private static final String SERVICE = "http://localhost:8888";
    private static final String SERVICE = "http://10.0.10.13";
    private static Logger jlog = LogManager.getLogger(PiwikFilter.class);
    public static boolean ENABLED = false;
    private Map<String, String> customVars;
    @Autowired
    private AuthenticationManager authenticationManager;

    public PiwikFilter () {
        //        controller = BeansFactory.getKustvaktContext()
        //                .getAuthenticationManager();
        ClientConfig clientConfig = new ClientConfig();
        if (jlog.isDebugEnabled())
            clientConfig.register(LoggingFeature.class);
        Client client = ClientBuilder.newClient(clientConfig);
        UriBuilder b = UriBuilder.fromUri(SERVICE);
        service = client.target(b.build());
        this.customVars = new HashMap<>();
    }

    private void send (ContainerRequestContext request) {
        Random random = new SecureRandom();
        Locale l = null;
        if (request.getAcceptableLanguages() != null)
            l = request.getAcceptableLanguages().get(0);
        try {
            service.path("piwik/piwik.php").queryParam("idsite", "2")
                    .queryParam("rec", "1")
                    //todo check for empty container
                    .queryParam("_cvar", translateCustomData())
                    .queryParam("cip", request.getHeaderString("Host"))
                    .queryParam("cookie", "false")
                    .queryParam("r", String.valueOf(random.nextDouble()))
                    .queryParam("action_name",
                            request.getUriInfo().getRequestUri()
                                    .toASCIIString())
                    .request().accept("text/html")
                    .header("Host", request.getHeaderString("Host"))
                    .header("User-Agent", request.getHeaderString("User-Agent"))
                    .acceptLanguage(l).method("GET");
        }
        catch (Exception e) {
            // do nothing if piwik not available!
        }
    }

    private String translateCustomData () {
        final Map<String, List<String>> customVariables = new HashMap<String, List<String>>();
        int i = 0;
        for (final Map.Entry<String, String> entry : this.customVars
                .entrySet()) {
            i++;
            final List<String> list = new ArrayList<String>();
            list.add(entry.getKey());
            list.add(entry.getValue());
            customVariables.put(Integer.toString(i), list);
        }

        final JSONArray json = new JSONArray();
        json.add(customVariables);

        // remove unnecessary parent square brackets from JSON-string
        String jsonString = json.toString().substring(1,
                json.toString().length() - 1);
        customVars.clear();
        return jsonString;
    }

    @Override
    public void filter (ContainerRequestContext request) {
        if (ENABLED) {
            //            try {
            //                TokenContext context;
            //                SecurityContext securityContext = request.getSecurityContext();
            //                if (securityContext != null) {
            //                    context = (TokenContext) securityContext.getUserPrincipal();
            //
            //                    if (context.getUsername() != null){
            //                        // since this is cached, not very expensive!
            //                        User user = authenticationManager.getUser(context.getUsername());
            //                        Userdata data = authenticationManager
            //                                .getUserData(user, UserSettingProcessor.class);
            //                        if ((Boolean) data.get(Attributes.COLLECT_AUDITING_DATA))
            //                            customVars.put("username", context.getUsername());
            //                    }
            //                }
            //            }
            //            catch (KustvaktException e) {
            //                //do nothing
            //            }
            send(request);
        }
    }
}