GetTraitsServlet.java
4.91 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
/*
* Decompiled with CFR 0_118.
*
* Could not load the following classes:
* javax.servlet.ServletException
* org.apache.felix.scr.annotations.Component
* org.apache.felix.scr.annotations.Reference
* org.apache.felix.scr.annotations.sling.SlingServlet
* org.apache.sling.api.SlingHttpServletRequest
* org.apache.sling.api.SlingHttpServletResponse
* org.apache.sling.api.request.RequestPathInfo
* org.apache.sling.api.resource.Resource
* org.apache.sling.api.servlets.SlingSafeMethodsServlet
* org.apache.sling.commons.json.JSONArray
* org.apache.sling.commons.json.JSONException
* org.apache.sling.commons.json.JSONObject
*/
package com.adobe.cq.aam;
import com.adobe.cq.aam.DummyFolders;
import com.adobe.cq.aam.client.spi.AudienceManagerAccessDenied;
import com.adobe.cq.aam.client.spi.AudienceManagerClient;
import com.adobe.cq.aam.client.spi.AudienceManagerConfiguration;
import com.adobe.cq.aam.client.spi.AudienceManagerItem;
import org.apache.felix.scr.annotations.Component;
import org.apache.felix.scr.annotations.Reference;
import org.apache.felix.scr.annotations.sling.SlingServlet;
import org.apache.sling.api.SlingHttpServletRequest;
import org.apache.sling.api.SlingHttpServletResponse;
import org.apache.sling.api.resource.Resource;
import org.apache.sling.api.servlets.SlingSafeMethodsServlet;
import org.apache.sling.commons.json.JSONArray;
import org.apache.sling.commons.json.JSONException;
import org.apache.sling.commons.json.JSONObject;
import javax.servlet.ServletException;
import java.io.IOException;
@Component(metatype=0, immediate=1)
@SlingServlet(extensions={"json"}, methods={"GET"}, resourceTypes={"cq/personalization/audiencemanager/components/cloudservices/audiencemanagerpage"}, selectors={"traits"}, generateComponent=0)
public class GetTraitsServlet
extends SlingSafeMethodsServlet {
private static final int MAX_RESULTS = 25;
private static final long serialVersionUID = -6342652616930175558L;
@Reference
private AudienceManagerClient audienceManagerClient;
protected void doGet(SlingHttpServletRequest request, SlingHttpServletResponse response) throws ServletException, IOException {
try {
Resource configResource = request.getResource();
AudienceManagerConfiguration config = new AudienceManagerConfiguration(configResource);
if (!this.audienceManagerClient.isValidForUse(config)) {
response.sendError(404, "Configuration is not valid: No traits availbled for this configuration");
return;
}
String[] traitIds = request.getParameterValues("t");
String search = request.getParameter("q");
String[] selectors = request.getRequestPathInfo().getSelectors();
if (!(traitIds != null && traitIds.length != 0 || search != null && search.length() != 0 || selectors.length >= 2)) {
response.sendError(400, "Either q (search) or t (traitids) one or more times must be set");
return;
}
if (traitIds == null || traitIds.length == 0) {
traitIds = new String[selectors.length - 1];
int j = 0;
for (int i = 0; i < selectors.length - 1; ++i) {
if ("traits".equals(selectors[i])) continue;
traitIds[j++] = selectors[i];
}
}
Iterable<AudienceManagerItem> traits = this.audienceManagerClient.getTraits(config, new DummyFolders("traits"), traitIds, search, true);
response.setContentType("application/json; charset=utf-8");
JSONObject jsonOut = new JSONObject();
JSONArray suggestions = new JSONArray();
jsonOut.put("traits", (Object)suggestions);
for (AudienceManagerItem trait : traits) {
JSONObject traitAsJson = new JSONObject();
traitAsJson.put("id", (Object)trait.getProperty("aam_sid"));
traitAsJson.put("name", (Object)trait.getProperty("aam_name"));
traitAsJson.put("description", (Object)trait.getProperty("aam_description"));
suggestions.put((Object)traitAsJson);
if (suggestions.length() < 25) continue;
break;
}
response.getWriter().write(jsonOut.toString());
}
catch (JSONException e) {
throw new ServletException(e.getMessage(), (Throwable)e);
}
catch (AudienceManagerAccessDenied e) {
response.sendError(403, "Access Forbidden, please check cloud configuration");
}
}
protected void bindAudienceManagerClient(AudienceManagerClient audienceManagerClient) {
this.audienceManagerClient = audienceManagerClient;
}
protected void unbindAudienceManagerClient(AudienceManagerClient audienceManagerClient) {
if (this.audienceManagerClient == audienceManagerClient) {
this.audienceManagerClient = null;
}
}
}