Mercurial > hg > AnnotationManagerN4J
annotate src/main/java/de/mpiwg/itgroup/annotations/restlet/BaseRestlet.java @ 72:4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
author | casties |
---|---|
date | Tue, 11 Mar 2014 17:43:00 +0100 |
parents | 326369d4bc4d |
children | 4b8c909cabf3 |
rev | line source |
---|---|
18 | 1 package de.mpiwg.itgroup.annotations.restlet; |
2 | |
70 | 3 /* |
4 * #%L | |
5 * AnnotationManager | |
6 * %% | |
7 * Copyright (C) 2012 - 2014 MPIWG Berlin | |
8 * %% | |
9 * This program is free software: you can redistribute it and/or modify | |
10 * it under the terms of the GNU Lesser General Public License as | |
11 * published by the Free Software Foundation, either version 3 of the | |
12 * License, or (at your option) any later version. | |
13 * | |
14 * This program is distributed in the hope that it will be useful, | |
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of | |
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
17 * GNU General Lesser Public License for more details. | |
18 * | |
19 * You should have received a copy of the GNU General Lesser Public | |
20 * License along with this program. If not, see | |
21 * <http://www.gnu.org/licenses/lgpl-3.0.html>. | |
22 * #L% | |
23 * Author: Robert Casties (casties@mpiwg-berlin.mpg.de) | |
24 */ | |
25 | |
18 | 26 import java.io.File; |
27 import java.io.FileInputStream; | |
28 import java.io.FileNotFoundException; | |
29 import java.io.IOException; | |
30 import java.io.InputStream; | |
31 import java.util.Hashtable; | |
32 import java.util.Properties; | |
71 | 33 import java.util.concurrent.ConcurrentMap; |
18 | 34 |
35 import javax.naming.NamingEnumeration; | |
36 import javax.naming.NamingException; | |
37 import javax.naming.directory.Attribute; | |
38 import javax.naming.directory.DirContext; | |
39 import javax.naming.directory.InitialDirContext; | |
40 import javax.naming.directory.SearchControls; | |
41 import javax.naming.directory.SearchResult; | |
42 import javax.servlet.ServletContext; | |
43 | |
44 import org.apache.log4j.BasicConfigurator; | |
45 import org.apache.log4j.Logger; | |
46 import org.neo4j.graphdb.GraphDatabaseService; | |
66
5b568de5ee0d
updated to new Neo4J version 2.0. doesn't use new features. problems with neo4j admin web ui.
casties
parents:
60
diff
changeset
|
47 import org.neo4j.graphdb.factory.GraphDatabaseBuilder; |
18 | 48 import org.neo4j.graphdb.factory.GraphDatabaseFactory; |
66
5b568de5ee0d
updated to new Neo4J version 2.0. doesn't use new features. problems with neo4j admin web ui.
casties
parents:
60
diff
changeset
|
49 import org.neo4j.graphdb.factory.GraphDatabaseSettings; |
5b568de5ee0d
updated to new Neo4J version 2.0. doesn't use new features. problems with neo4j admin web ui.
casties
parents:
60
diff
changeset
|
50 import org.neo4j.kernel.GraphDatabaseAPI; |
18 | 51 import org.neo4j.server.WrappingNeoServerBootstrapper; |
52 import org.restlet.Application; | |
53 import org.restlet.Context; | |
71 | 54 import org.restlet.Restlet; |
55 import org.restlet.data.LocalReference; | |
18 | 56 |
57 import de.mpiwg.itgroup.annotations.neo4j.AnnotationStore; | |
58 | |
59 public abstract class BaseRestlet extends Application { | |
60 | |
61 public static Logger logger = Logger.getLogger(BaseRestlet.class); | |
62 | |
63 /** | |
57
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
64 * Properties holding consumer keys and secrets. |
18 | 65 */ |
66 protected Properties consumerKeys; | |
71 | 67 public String CONSUMER_KEYS_PATH = "consumerkeys.property"; |
18 | 68 public static final String CONSUMERKEYS_KEY = "annotationmanager.consumerkeys"; |
69 | |
57
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
70 /** |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
71 * Properties holding server config. |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
72 */ |
18 | 73 protected Properties serverConfig; |
71 | 74 public String CONFIG_PROPS_PATH = "serverconfig.property"; |
18 | 75 public static final String SERVERCONFIG_KEY = "annotationmanager.serverconfig"; |
76 | |
57
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
77 /** |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
78 * database instance; |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
79 */ |
18 | 80 protected GraphDatabaseService graphDb; |
81 public static final String GRAPHDB_KEY = "annotationmanager.graphdb"; | |
82 public static final String GRAPHDB_PATH_KEY = "annotationmanager.graphdb.path"; | |
71 | 83 public String graphdbPath = "neo4j-annotation-db"; |
18 | 84 |
57
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
85 /** |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
86 * database interface server instance. |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
87 */ |
18 | 88 protected WrappingNeoServerBootstrapper srv; |
89 public static final String GRAPHDBSRV_KEY = "annotationmanager.graphdb.srv"; | |
90 | |
57
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
91 /** |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
92 * annotation store instance. |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
93 */ |
18 | 94 protected AnnotationStore store; |
95 public static final String ANNSTORE_KEY = "annotationmanager.store"; | |
96 | |
57
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
97 /** |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
98 * LDAP server URI (for looking up full user names). |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
99 */ |
18 | 100 protected String ldapServerUrl; |
101 public static final String LDAP_SERVER_KEY = "annotationmanager.ldapserver.url"; | |
102 | |
50 | 103 public static final String ADMIN_USER_KEY = "annotationmanager.admin.user"; |
104 public static final String ADMIN_PASSWORD_KEY = "annotationmanager.admin.password"; | |
105 | |
18 | 106 /** |
57
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
107 * run in authorization mode i.e. with tokens. |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
108 */ |
58 | 109 protected boolean authorizationMode = false; |
57
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
110 public static final String AUTHORIZATION_MODE_KEY = "annotationmanager.authorization"; |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
111 |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
112 /** |
58 | 113 * prefix to create uris for tags in store. |
114 */ | |
115 public static String TAGS_URI_PREFIX = ""; | |
116 public static final String TAGS_URI_KEY = "annotationmanager.uris.tags"; | |
117 | |
118 /** | |
119 * prefix to create uris for persons in store. | |
120 */ | |
121 public static String PERSONS_URI_PREFIX = ""; | |
122 public static final String PERSONS_URI_KEY = "annotationmanager.uris.persons"; | |
123 | |
124 /** | |
125 * prefix to create uris for groups in store. | |
126 */ | |
127 public static String GROUPS_URI_PREFIX = ""; | |
128 public static final String GROUPS_URI_KEY = "annotationmanager.uris.groups"; | |
129 | |
59
e2f86ef9b871
make annotation uri in store configurable. fix npe with no tags.
casties
parents:
58
diff
changeset
|
130 public static final String ANNOTATIONS_URI_KEY = "annotationmanager.uris.annotations"; |
e2f86ef9b871
make annotation uri in store configurable. fix npe with no tags.
casties
parents:
58
diff
changeset
|
131 |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
132 |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
133 /* (non-Javadoc) |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
134 * @see org.restlet.Application#start() |
18 | 135 */ |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
136 @Override |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
137 public synchronized void start() throws Exception { |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
138 configure(getContext()); |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
139 super.start(); |
18 | 140 } |
141 | |
142 /** | |
143 * Configures the restlet. | |
144 * Reads serverConfig, consumerKeys and graphDb config from config files and starts graphDb. | |
145 * Uses config from webapp context if already initialized. | |
71 | 146 * @param context |
18 | 147 */ |
71 | 148 protected void configure(Context context) { |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
149 ConcurrentMap<String, Object> attrs = context.getAttributes(); |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
150 ServletContext sc = (ServletContext) attrs.get("org.restlet.ext.servlet.ServletContext"); |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
151 if (sc != null) { |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
152 if (sc.getAttribute("annotationserver.log4j.configured") == null) { |
18 | 153 // TODO: is this the right place to run the log4j configurator? |
154 BasicConfigurator.configure(); | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
155 sc.setAttribute("annotationserver.log4j.configured", "done"); |
18 | 156 } |
157 logger.info(getVersion() + " starting..."); | |
158 | |
159 /* | |
160 * read config from webapp | |
161 */ | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
162 serverConfig = (Properties) sc.getAttribute(SERVERCONFIG_KEY); |
18 | 163 if (serverConfig == null) { |
164 serverConfig = new Properties(); | |
165 InputStream ps = getResourceAsStream(sc, CONFIG_PROPS_PATH); | |
166 if (ps != null) { | |
167 logger.debug("loading config from " + CONFIG_PROPS_PATH); | |
168 try { | |
169 serverConfig.load(ps); | |
170 /* | |
171 * read serverconfig options | |
172 */ | |
173 graphdbPath = serverConfig.getProperty(GRAPHDB_PATH_KEY, graphdbPath); | |
174 ldapServerUrl = serverConfig.getProperty(LDAP_SERVER_KEY, null); | |
60
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
175 /* |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
176 * uri prefixes |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
177 */ |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
178 if (serverConfig.containsKey(PERSONS_URI_KEY)) { |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
179 BaseRestlet.PERSONS_URI_PREFIX = serverConfig.getProperty(PERSONS_URI_KEY); |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
180 } |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
181 if (serverConfig.containsKey(GROUPS_URI_KEY)) { |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
182 BaseRestlet.GROUPS_URI_PREFIX = serverConfig.getProperty(GROUPS_URI_KEY); |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
183 } |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
184 if (serverConfig.containsKey(TAGS_URI_KEY)) { |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
185 BaseRestlet.TAGS_URI_PREFIX = serverConfig.getProperty(TAGS_URI_KEY); |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
186 } |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
187 if (serverConfig.containsKey(ANNOTATIONS_URI_KEY)) { |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
188 AnnotationStore.ANNOTATION_URI_PREFIX = serverConfig.getProperty(ANNOTATIONS_URI_KEY); |
99d9afcfd04d
configuration of uri prefixes was completely broken.
casties
parents:
59
diff
changeset
|
189 } |
18 | 190 } catch (IOException e) { |
191 logger.warn("Error loading server config: ", e); | |
192 } | |
193 logger.debug("config: " + serverConfig); | |
194 } else { | |
195 logger.error("Unable to get resource " + CONFIG_PROPS_PATH); | |
196 } | |
197 // store config | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
198 sc.setAttribute(SERVERCONFIG_KEY, serverConfig); |
18 | 199 } |
200 // look for database service in context | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
201 graphDb = (GraphDatabaseService) sc.getAttribute(GRAPHDB_KEY); |
18 | 202 if (graphDb == null) { |
203 /* | |
204 * open database | |
205 */ | |
206 String dbFn = getResourcePath(sc, graphdbPath); | |
207 if (dbFn != null) { | |
208 logger.debug("opening DB " + dbFn); | |
66
5b568de5ee0d
updated to new Neo4J version 2.0. doesn't use new features. problems with neo4j admin web ui.
casties
parents:
60
diff
changeset
|
209 GraphDatabaseBuilder graphDbBuilder = new GraphDatabaseFactory().newEmbeddedDatabaseBuilder(dbFn); |
5b568de5ee0d
updated to new Neo4J version 2.0. doesn't use new features. problems with neo4j admin web ui.
casties
parents:
60
diff
changeset
|
210 graphDbBuilder.setConfig(GraphDatabaseSettings.allow_store_upgrade, "true"); |
5b568de5ee0d
updated to new Neo4J version 2.0. doesn't use new features. problems with neo4j admin web ui.
casties
parents:
60
diff
changeset
|
211 graphDb = graphDbBuilder.newGraphDatabase(); |
18 | 212 registerShutdownHook(graphDb); |
213 // store in context | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
214 sc.setAttribute(GRAPHDB_KEY, graphDb); |
18 | 215 // AnnotationStore |
216 store = new AnnotationStore(graphDb); | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
217 sc.setAttribute(ANNSTORE_KEY, store); |
18 | 218 // admin server |
66
5b568de5ee0d
updated to new Neo4J version 2.0. doesn't use new features. problems with neo4j admin web ui.
casties
parents:
60
diff
changeset
|
219 srv = new WrappingNeoServerBootstrapper((GraphDatabaseAPI) graphDb); |
18 | 220 logger.debug("Starting DB admin server..."); |
221 // store in context | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
222 sc.setAttribute(GRAPHDBSRV_KEY, srv); |
18 | 223 srv.start(); |
224 } else { | |
225 logger.error("Unable to get resource " + dbFn); | |
226 } | |
22 | 227 } else { |
228 // get existing AnnotationStore | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
229 store = (AnnotationStore) sc.getAttribute(ANNSTORE_KEY); |
18 | 230 } |
231 /* | |
232 * read consumerKeys from webapp | |
233 */ | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
234 consumerKeys = (Properties) sc.getAttribute(CONSUMERKEYS_KEY); |
18 | 235 if (consumerKeys == null) { |
236 consumerKeys = new Properties(); | |
237 InputStream ps = getResourceAsStream(sc, CONSUMER_KEYS_PATH); | |
238 if (ps != null) { | |
239 logger.debug("loading consumer keys from " + CONSUMER_KEYS_PATH); | |
240 try { | |
241 consumerKeys.load(ps); | |
242 } catch (IOException e) { | |
243 // TODO Auto-generated catch block | |
244 e.printStackTrace(); | |
245 } | |
246 logger.debug("consumer keys: " + consumerKeys); | |
247 } else { | |
248 logger.error("Unable to get resource " + CONSUMER_KEYS_PATH); | |
249 } | |
250 // store config | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
251 sc.setAttribute(CONSUMERKEYS_KEY, consumerKeys); |
18 | 252 } |
253 } else { | |
254 logger.error("Unable to get ServletContext!"); | |
255 } | |
256 } | |
257 | |
258 public abstract String getVersion(); | |
259 | |
260 /** | |
57
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
261 * @return the authorizationMode |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
262 */ |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
263 public boolean isAuthorizationMode() { |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
264 return authorizationMode; |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
265 } |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
266 |
4efb21cf0ce0
new non-authorized mode without tokens. enabled by default. configured with annotationmanager.authorization=false property.
casties
parents:
50
diff
changeset
|
267 /** |
19 | 268 * @return the store |
269 */ | |
270 public AnnotationStore getAnnotationStore() { | |
271 return store; | |
272 } | |
273 | |
274 /** | |
18 | 275 * returns consumer secret for consumer key. returns null if consumer key |
276 * doesn't exist. | |
277 * | |
278 * @param consumerKey | |
279 * @return | |
280 */ | |
281 public String getConsumerSecret(String consumerKey) { | |
282 return consumerKeys.getProperty(consumerKey); | |
283 } | |
284 | |
285 /** | |
286 * Hole den vollen Benutzernamen aus dem LDAP | |
287 * | |
288 * @param creator | |
289 * @return | |
290 */ | |
291 public String getFullNameFromLdap(String creator) { | |
292 String retString = creator; // falls nichts gefunden wird einfach den | |
293 // creator zurueckgeben | |
294 if (ldapServerUrl == null) { | |
295 return retString; | |
296 } | |
297 Hashtable<String, String> env = new Hashtable<String, String>(); | |
298 String sp = "com.sun.jndi.ldap.LdapCtxFactory"; | |
299 env.put(javax.naming.Context.INITIAL_CONTEXT_FACTORY, sp); | |
300 env.put(javax.naming.Context.PROVIDER_URL, ldapServerUrl); | |
301 | |
302 DirContext dctx; | |
303 try { | |
304 dctx = new InitialDirContext(env); | |
305 } catch (NamingException e) { | |
306 logger.error("Error in getFullNameFromLDAP!", e); | |
307 return retString; | |
308 } | |
309 | |
310 String base = "ou=people"; | |
311 | |
312 SearchControls sc = new SearchControls(); | |
313 String[] attributeFilter = { "cn", "mail" }; | |
314 sc.setReturningAttributes(attributeFilter); | |
315 sc.setSearchScope(SearchControls.SUBTREE_SCOPE); | |
316 | |
317 String filter = "(uid=" + creator + ")"; | |
318 | |
319 try { | |
320 NamingEnumeration<SearchResult> results = dctx.search(base, filter, sc); | |
321 while (results.hasMore()) { | |
322 SearchResult sr = (SearchResult) results.next(); | |
323 javax.naming.directory.Attributes attrs = sr.getAttributes(); | |
324 | |
325 Attribute attr = attrs.get("cn"); | |
326 retString = (String) attr.get(); | |
327 } | |
328 } catch (NamingException e) { | |
329 logger.error("Error in getFullNameFromLDAP!", e); | |
330 } | |
331 | |
332 try { | |
333 dctx.close(); | |
334 } catch (NamingException e) { | |
335 logger.error("Error in getFullNameFromLDAP!", e); | |
336 } | |
337 return retString; | |
338 } | |
339 | |
340 /** | |
341 * returns resource from path (in webapp) as InputStream. | |
342 * | |
343 * @param sc | |
344 * @param path | |
345 * @return | |
346 */ | |
347 protected InputStream getResourceAsStream(ServletContext sc, String path) { | |
71 | 348 InputStream ps = null; |
349 if (sc == null) { | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
350 // no servlet context -> use class loader |
71 | 351 ps = Thread.currentThread().getContextClassLoader().getResourceAsStream(path); |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
352 /* Request request = new Request(Method.GET, "riap://component/ping"); |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
353 Response response = getContext().getClientDispatcher().handle(request); |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
354 Representation repr = response.getEntity(); */ |
71 | 355 } else { |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
356 // try path in webapp first |
71 | 357 ps = sc.getResourceAsStream(path); |
358 if (ps == null) { | |
359 // try as file | |
360 File pf = new File(sc.getRealPath(path)); | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
361 if (pf.canRead()) { |
71 | 362 logger.debug("trying file for: " + pf); |
363 try { | |
364 ps = new FileInputStream(pf); | |
365 } catch (FileNotFoundException e) { | |
366 logger.error(e); | |
367 } | |
72
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
368 } else { |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
369 // use class loader |
4c2cea836bc0
restlet 2.1 works now. (it's the start() method, stupid!)
casties
parents:
71
diff
changeset
|
370 ps = Thread.currentThread().getContextClassLoader().getResourceAsStream(path); |
18 | 371 } |
372 } | |
373 } | |
374 return ps; | |
375 } | |
376 | |
377 /** | |
378 * get a real file name for a web app file pathname. | |
379 * | |
380 * If filename starts with "/" its treated as absolute else the path is | |
381 * appended to the base directory of the web-app. | |
382 * | |
383 * @param filename | |
384 * @param sc | |
385 * @return | |
386 */ | |
387 public static String getResourcePath(ServletContext sc, String filename) { | |
388 File f = new File(filename); | |
389 // is the filename absolute? | |
71 | 390 if (!f.isAbsolute() && sc != null) { |
18 | 391 // relative path -> use getRealPath to resolve in webapp |
392 filename = sc.getRealPath(filename); | |
393 } | |
394 return filename; | |
395 } | |
396 | |
397 /* | |
398 * (non-Javadoc) | |
399 * | |
400 * @see org.restlet.Application#stop() | |
401 */ | |
402 @Override | |
403 public synchronized void stop() throws Exception { | |
404 /* | |
405 * trying to clean up databases, not sure if this is the right way... | |
406 */ | |
407 if (srv != null) { | |
408 logger.debug("Stopping DB admin server..."); | |
409 srv.stop(); | |
410 srv = null; | |
411 } | |
412 if (graphDb != null) { | |
413 logger.debug("Stopping DB..."); | |
414 graphDb.shutdown(); | |
415 graphDb = null; | |
416 } | |
417 super.stop(); | |
418 } | |
419 | |
420 private static void registerShutdownHook(final GraphDatabaseService graphDb) { | |
421 // Registers a shutdown hook for the Neo4j instance so that it | |
422 // shuts down nicely when the VM exits (even if you "Ctrl-C" the | |
423 // running example before it's completed) | |
424 Runtime.getRuntime().addShutdownHook(new Thread() { | |
425 @Override | |
426 public void run() { | |
427 graphDb.shutdown(); | |
428 } | |
429 }); | |
430 } | |
431 | |
432 } |