1 package org
.argeo
.slc
.repo
;
3 import java
.util
.ArrayList
;
4 import java
.util
.Arrays
;
8 import javax
.jcr
.Repository
;
9 import javax
.jcr
.RepositoryException
;
10 import javax
.jcr
.Session
;
11 import javax
.jcr
.observation
.Event
;
12 import javax
.jcr
.observation
.EventIterator
;
13 import javax
.jcr
.observation
.EventListener
;
15 import org
.argeo
.jcr
.JcrUtils
;
16 import org
.argeo
.slc
.SlcException
;
18 /** Repository backend, maintain the JCR repository, mainly through listeners */
19 public class RepoImpl
{
21 private Repository jcrRepository
;
22 private Session adminSession
;
24 private ArtifactListener artifactListener
;
26 /** order may be important */
27 private List
<NodeIndexer
> nodeIndexers
= new ArrayList
<NodeIndexer
>();
31 adminSession
= jcrRepository
.login();
32 artifactListener
= new ArtifactListener();
35 .getObservationManager()
36 .addEventListener(artifactListener
, Event
.NODE_ADDED
,
37 RepoConstants
.ARTIFACTS_BASE_PATH
, true, null,
40 String localrepoWorkspace
= "localrepo";
42 adminSession
.getWorkspace().getAccessibleWorkspaceNames())
43 .contains(localrepoWorkspace
))
44 adminSession
.getWorkspace().createWorkspace(localrepoWorkspace
);
45 } catch (RepositoryException e
) {
46 throw new SlcException("Cannot initialize repository backend", e
);
50 public void destroy() {
51 JcrUtils
.logoutQuietly(adminSession
);
54 public void setJcrRepository(Repository jcrRepository
) {
55 this.jcrRepository
= jcrRepository
;
58 public void setNodeIndexers(List
<NodeIndexer
> nodeIndexers
) {
59 this.nodeIndexers
= nodeIndexers
;
62 class ArtifactListener
implements EventListener
{
64 public void onEvent(EventIterator events
) {
65 while (events
.hasNext()) {
66 Event event
= events
.nextEvent();
68 String newNodePath
= event
.getPath();
70 for (NodeIndexer nodeIndexer
: nodeIndexers
) {
72 if (nodeIndexer
.support(newNodePath
)) {
74 newNode
= adminSession
.getNode(newNodePath
);
75 nodeIndexer
.index(newNode
);
77 } catch (RuntimeException e
) {
84 } catch (RepositoryException e
) {
85 throw new SlcException("Cannot process event " + event
, e
);
87 JcrUtils
.discardQuietly(adminSession
);