]> git.argeo.org Git - lgpl/argeo-commons.git/blob - AbstractCmsEntryPoint.java
2ff9aff58e9275a043dc28b636a9c453bac53f42
[lgpl/argeo-commons.git] / AbstractCmsEntryPoint.java
1 package org.argeo.cms;
2
3 import java.security.PrivilegedAction;
4 import java.util.HashMap;
5 import java.util.Map;
6
7 import javax.jcr.Node;
8 import javax.jcr.NodeIterator;
9 import javax.jcr.Property;
10 import javax.jcr.Repository;
11 import javax.jcr.RepositoryException;
12 import javax.jcr.Session;
13 import javax.jcr.nodetype.NodeType;
14 import javax.security.auth.Subject;
15 import javax.security.auth.login.CredentialNotFoundException;
16 import javax.security.auth.login.LoginContext;
17 import javax.security.auth.login.LoginException;
18 import javax.servlet.http.HttpServletRequest;
19
20 import org.apache.commons.logging.Log;
21 import org.apache.commons.logging.LogFactory;
22 import org.argeo.ArgeoException;
23 import org.argeo.cms.auth.AuthConstants;
24 import org.argeo.cms.auth.HttpRequestCallbackHandler;
25 import org.argeo.cms.util.CmsUtils;
26 import org.argeo.eclipse.ui.specific.UiContext;
27 import org.argeo.jcr.JcrUtils;
28 import org.eclipse.rap.rwt.RWT;
29 import org.eclipse.rap.rwt.application.AbstractEntryPoint;
30 import org.eclipse.rap.rwt.client.WebClient;
31 import org.eclipse.rap.rwt.client.service.BrowserNavigation;
32 import org.eclipse.rap.rwt.client.service.BrowserNavigationEvent;
33 import org.eclipse.rap.rwt.client.service.BrowserNavigationListener;
34 import org.eclipse.rap.rwt.client.service.JavaScriptExecutor;
35 import org.eclipse.swt.widgets.Composite;
36 import org.eclipse.swt.widgets.Display;
37 import org.eclipse.swt.widgets.Shell;
38
39 /** Manages history and navigation */
40 public abstract class AbstractCmsEntryPoint extends AbstractEntryPoint
41 implements CmsView {
42 private final Log log = LogFactory.getLog(AbstractCmsEntryPoint.class);
43
44 private final Subject subject;
45 private LoginContext loginContext;
46
47 private final Repository repository;
48 private final String workspace;
49 private final String defaultPath;
50 private final Map<String, String> factoryProperties;
51
52 // Current state
53 private Session session;
54 private Node node;
55 private String state;
56 private String page;
57 private Throwable exception;
58
59 // Client services
60 private final JavaScriptExecutor jsExecutor;
61 private final BrowserNavigation browserNavigation;
62
63 public AbstractCmsEntryPoint(Repository repository, String workspace,
64 String defaultPath, Map<String, String> factoryProperties) {
65 this.repository = repository;
66 this.workspace = workspace;
67 this.defaultPath = defaultPath;
68 this.factoryProperties = new HashMap<String, String>(factoryProperties);
69 subject = new Subject();
70
71 // Initial login
72 try {
73 loginContext = new LoginContext(AuthConstants.LOGIN_CONTEXT_USER,
74 subject, new HttpRequestCallbackHandler(
75 UiContext.getHttpRequest()));
76 loginContext.login();
77 } catch (CredentialNotFoundException e) {
78 try {
79 loginContext = new LoginContext(
80 AuthConstants.LOGIN_CONTEXT_ANONYMOUS, subject);
81 loginContext.login();
82 } catch (LoginException e1) {
83 throw new ArgeoException("Cannot log as anonymous", e);
84 }
85 } catch (LoginException e) {
86 throw new ArgeoException("Cannot initialize subject", e);
87 }
88 authChange(loginContext);
89
90 jsExecutor = RWT.getClient().getService(JavaScriptExecutor.class);
91 browserNavigation = RWT.getClient().getService(BrowserNavigation.class);
92 if (browserNavigation != null)
93 browserNavigation
94 .addBrowserNavigationListener(new CmsNavigationListener());
95 }
96
97 @Override
98 protected Shell createShell(Display display) {
99 Shell shell = super.createShell(display);
100 shell.setData(RWT.CUSTOM_VARIANT, CmsStyles.CMS_SHELL);
101 display.disposeExec(new Runnable() {
102
103 @Override
104 public void run() {
105 if (log.isTraceEnabled())
106 log.trace("Logging out " + session);
107 JcrUtils.logoutQuietly(session);
108 }
109 });
110 return shell;
111 }
112
113 @Override
114 protected final void createContents(final Composite parent) {
115 UiContext.setData(CmsView.KEY, this);
116 Subject.doAs(subject, new PrivilegedAction<Void>() {
117 @Override
118 public Void run() {
119 try {
120 initUi(parent);
121 } catch (Exception e) {
122 throw new CmsException("Cannot create entrypoint contents",
123 e);
124 }
125 return null;
126 }
127 });
128 }
129
130 /** Create UI */
131 protected abstract void initUi(Composite parent);
132
133 /** Recreate UI after navigation or auth change */
134 protected abstract void refresh();
135
136 /**
137 * The node to return when no node was found (for authenticated users and
138 * anonymous)
139 */
140 protected Node getDefaultNode(Session session) throws RepositoryException {
141 if (!session.hasPermission(defaultPath, "read")) {
142 if (session.getUserID().equals(AuthConstants.ROLE_ANONYMOUS))
143 // TODO throw a special exception
144 throw new CmsException("Login required");
145 else
146 throw new CmsException("Unauthorized");
147 }
148 return session.getNode(defaultPath);
149 }
150
151 protected String getBaseTitle() {
152 return factoryProperties.get(WebClient.PAGE_TITLE);
153 }
154
155 public void navigateTo(String state) {
156 exception = null;
157 String title = setState(state);
158 doRefresh();
159 if (browserNavigation != null)
160 browserNavigation.pushState(state, title);
161 }
162
163 @Override
164 public Subject getSubject() {
165 return subject;
166 }
167
168 @Override
169 public void logout() {
170 if (loginContext == null)
171 throw new CmsException("Login context should not be null");
172 try {
173 loginContext.logout();
174 LoginContext anonymousLc = new LoginContext(
175 AuthConstants.LOGIN_CONTEXT_ANONYMOUS, subject);
176 anonymousLc.login();
177 authChange(anonymousLc);
178 } catch (LoginException e) {
179 throw new CmsException("Cannot logout", e);
180 }
181 }
182
183 @Override
184 public void authChange(LoginContext loginContext) {
185 if (loginContext == null)
186 throw new CmsException("Login context cannot be null");
187 this.loginContext = loginContext;
188 Subject.doAs(subject, new PrivilegedAction<Void>() {
189
190 @Override
191 public Void run() {
192 try {
193 String currentPath = null;
194 if (node != null)
195 currentPath = node.getPath();
196 JcrUtils.logoutQuietly(session);
197
198 session = repository.login(workspace);
199 if (currentPath != null)
200 try {
201 node = session.getNode(currentPath);
202 } catch (Exception e) {
203 logout();
204 session = repository.login(workspace);
205 navigateTo("~");
206 throw e;
207 }
208
209 // refresh UI
210 doRefresh();
211 } catch (RepositoryException e) {
212 throw new CmsException("Cannot perform auth change", e);
213 }
214 return null;
215 }
216
217 });
218
219 }
220
221 @Override
222 public void exception(final Throwable e) {
223 AbstractCmsEntryPoint.this.exception = e;
224 log.error("Unexpected exception in CMS", e);
225 doRefresh();
226 }
227
228 protected void doRefresh() {
229 Subject.doAs(subject, new PrivilegedAction<Void>() {
230 @Override
231 public Void run() {
232 refresh();
233 return null;
234 }
235 });
236 }
237
238 /** Sets the state of the entry point and retrieve the related JCR node. */
239 protected synchronized String setState(String newState) {
240 String previousState = this.state;
241
242 node = null;
243 page = null;
244 this.state = newState;
245 if (newState.equals("~"))
246 this.state = "";
247
248 try {
249 int firstSlash = state.indexOf('/');
250 if (firstSlash == 0) {
251 if (session.nodeExists(state))
252 node = session.getNode(state);
253 else
254 throw new CmsException("Data " + state + " does not exist");
255 page = "";
256 } else if (firstSlash > 0) {
257 String prefix = state.substring(0, firstSlash);
258 String path = state.substring(firstSlash);
259 if (session.nodeExists(path))
260 node = session.getNode(path);
261 else
262 throw new CmsException("Data " + path + " does not exist");
263 page = prefix;
264 } else {
265 node = getDefaultNode(session);
266 page = state;
267 }
268
269 // Title
270 String title;
271 if (node.isNodeType(NodeType.MIX_TITLE)
272 && node.hasProperty(Property.JCR_TITLE))
273 title = node.getProperty(Property.JCR_TITLE).getString()
274 + " - " + getBaseTitle();
275 else
276 title = getBaseTitle();
277
278 publishMetaData(title);
279
280 if (log.isTraceEnabled())
281 log.trace("node=" + node + ", state=" + state + " (page="
282 + page + ", title=" + title + ")");
283
284 return title;
285 } catch (Exception e) {
286 log.error("Cannot set state '" + state + "'", e);
287 if (previousState.equals(""))
288 previousState = "~";
289 navigateTo(previousState);
290 throw new CmsException("Unexpected issue when accessing #"
291 + newState, e);
292 }
293 }
294
295 private void publishMetaData(String title) throws RepositoryException {
296 HttpServletRequest request = UiContext.getHttpRequest();
297 if (request == null)
298 return;
299 String url = CmsUtils.getCanonicalUrl(node, request);
300 String imgUrl = null;
301 for (NodeIterator it = node.getNodes(); it.hasNext();) {
302 Node child = it.nextNode();
303 if (child.isNodeType(CmsTypes.CMS_IMAGE))
304 imgUrl = CmsUtils.getDataUrl(child, request);
305 }
306
307 StringBuilder js = new StringBuilder();
308 js.append("document.title = '" + title + "';");
309 js.append("var metas = document.getElementsByTagName('meta');");
310 js.append("for (var i=0; i<metas.length; i++) {");
311 js.append(" if (metas[i].getAttribute('property'))");
312 js.append(" if(metas[i].getAttribute('property')=='og:title')");
313 js.append(" metas[i].setAttribute('content','" + title + "');");
314 js.append(" else if(metas[i].getAttribute('property')=='og:url')");
315 js.append(" metas[i].setAttribute('content','" + url + "');");
316 if (imgUrl != null) {
317 js.append(" else if(metas[i].getAttribute('property')=='og:image')");
318 js.append(" metas[i].setAttribute('content','" + imgUrl + "');");
319 } else {
320 // TODO reset default image
321 }
322 js.append(" };");
323 jsExecutor.execute(js.toString());
324 }
325
326 protected Node getNode() {
327 return node;
328 }
329
330 protected String getState() {
331 return state;
332 }
333
334 protected Throwable getException() {
335 return exception;
336 }
337
338 protected void resetException() {
339 exception = null;
340 }
341
342 protected Session getSession() {
343 return session;
344 }
345
346 private class CmsNavigationListener implements BrowserNavigationListener {
347 private static final long serialVersionUID = -3591018803430389270L;
348
349 @Override
350 public void navigated(BrowserNavigationEvent event) {
351 setState(event.getState());
352 refresh();
353 }
354 }
355 }