1 package org.argeo.cms.e4.users;
2
3 import java.util.ArrayList;
4 import java.util.Collections;
5 import java.util.HashMap;
6 import java.util.Hashtable;
7 import java.util.LinkedHashMap;
8 import java.util.List;
9 import java.util.Map;
10
11 import javax.transaction.Status;
12 import javax.transaction.UserTransaction;
13
14 import org.argeo.api.NodeConstants;
15 import org.argeo.cms.CmsException;
16 import org.argeo.osgi.useradmin.UserAdminConf;
17 import org.argeo.osgi.useradmin.UserDirectory;
18 import org.osgi.service.useradmin.UserAdmin;
19 import org.osgi.service.useradmin.UserAdminEvent;
20 import org.osgi.service.useradmin.UserAdminListener;
21
22
23 public class UserAdminWrapper {
24
25 private UserAdmin userAdmin;
26
27
28 private Map<UserDirectory, Hashtable<String, String>> userDirectories = Collections
29 .synchronizedMap(new LinkedHashMap<>());
30 private UserTransaction userTransaction;
31
32
33 public final static boolean COMMIT_ON_SAVE = true;
34
35
36 List<UserAdminListener> listeners = new ArrayList<UserAdminListener>();
37
38
39
40
41
42
43 public UserTransaction beginTransactionIfNeeded() {
44 try {
45
46 if (userTransaction.getStatus() == Status.STATUS_NO_TRANSACTION) {
47 userTransaction.begin();
48
49 }
50 return userTransaction;
51 } catch (Exception e) {
52 throw new CmsException("Unable to begin transaction", e);
53 }
54 }
55
56
57
58
59
60
61 public void commitOrNotifyTransactionStateChange() {
62 try {
63
64 if (userTransaction.getStatus() == Status.STATUS_NO_TRANSACTION)
65 return;
66
67 if (UserAdminWrapper.COMMIT_ON_SAVE)
68 userTransaction.commit();
69 else
70 UiAdminUtils.notifyTransactionStateChange(userTransaction);
71 } catch (Exception e) {
72 throw new CmsException("Unable to clean transaction", e);
73 }
74 }
75
76
77 public void addListener(UserAdminListener userAdminListener) {
78 if (!listeners.contains(userAdminListener))
79 listeners.add(userAdminListener);
80 }
81
82 public void removeListener(UserAdminListener userAdminListener) {
83 if (listeners.contains(userAdminListener))
84 listeners.remove(userAdminListener);
85 }
86
87 public void notifyListeners(UserAdminEvent event) {
88 for (UserAdminListener listener : listeners)
89 listener.roleChanged(event);
90 }
91
92 public Map<String, String> getKnownBaseDns(boolean onlyWritable) {
93 Map<String, String> dns = new HashMap<String, String>();
94 for (UserDirectory userDirectory : userDirectories.keySet()) {
95 Boolean readOnly = userDirectory.isReadOnly();
96 String baseDn = userDirectory.getBaseDn().toString();
97
98 if (onlyWritable && readOnly)
99 continue;
100 if (baseDn.equalsIgnoreCase(NodeConstants.ROLES_BASEDN))
101 continue;
102 if (baseDn.equalsIgnoreCase(NodeConstants.TOKENS_BASEDN))
103 continue;
104 dns.put(baseDn, UserAdminConf.propertiesAsUri(userDirectories.get(userDirectory)).toString());
105
106 }
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122 return dns;
123 }
124
125 public UserAdmin getUserAdmin() {
126 return userAdmin;
127 }
128
129 public UserTransaction getUserTransaction() {
130 return userTransaction;
131 }
132
133
134 public void setUserAdmin(UserAdmin userAdmin, Map<String, String> properties) {
135 this.userAdmin = userAdmin;
136
137 }
138
139 public void setUserTransaction(UserTransaction userTransaction) {
140 this.userTransaction = userTransaction;
141 }
142
143 public void addUserDirectory(UserDirectory userDirectory, Map<String, String> properties) {
144 userDirectories.put(userDirectory, new Hashtable<>(properties));
145 }
146
147 public void removeUserDirectory(UserDirectory userDirectory, Map<String, String> properties) {
148 userDirectories.remove(userDirectory);
149 }
150
151
152
153
154
155 }