Changeset 348:d91f6bd7d381
- Timestamp:
- 09/20/11 03:16:11 (5 months ago)
- Branch:
- default
- Convert:
- svn:7c3792e6-d75b-4784-96a6-b298f655ee64/trunk@2782
- Location:
- kraken-dom
- Files:
-
- 1 deleted
- 32 edited
-
pom.xml (modified) (1 diff)
-
src/main/java/org/krakenapps/dom/api/AdminApi.java (modified) (1 diff)
-
src/main/java/org/krakenapps/dom/api/AdminSettingApi.java (modified) (1 diff)
-
src/main/java/org/krakenapps/dom/api/ApplicationApi.java (modified) (4 diffs)
-
src/main/java/org/krakenapps/dom/api/AreaApi.java (modified) (2 diffs)
-
src/main/java/org/krakenapps/dom/api/AreaEventCallback.java (deleted)
-
src/main/java/org/krakenapps/dom/api/HostApi.java (modified) (1 diff)
-
src/main/java/org/krakenapps/dom/api/LdapOrganizationalUnitApi.java (modified) (1 diff)
-
src/main/java/org/krakenapps/dom/api/NetworkAddressApi.java (modified) (2 diffs)
-
src/main/java/org/krakenapps/dom/api/OrganizationApi.java (modified) (2 diffs)
-
src/main/java/org/krakenapps/dom/api/OrganizationParameterApi.java (modified) (1 diff)
-
src/main/java/org/krakenapps/dom/api/OrganizationUnitApi.java (modified) (1 diff)
-
src/main/java/org/krakenapps/dom/api/ProgramApi.java (modified) (1 diff)
-
src/main/java/org/krakenapps/dom/api/TimetableApi.java (modified) (1 diff)
-
src/main/java/org/krakenapps/dom/api/UserApi.java (modified) (1 diff)
-
src/main/java/org/krakenapps/dom/api/WidgetApi.java (modified) (2 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/AdminApiImpl.java (modified) (8 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/AdminSettingApiImpl.java (modified) (4 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/ApplicationApiImpl.java (modified) (12 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/AreaApiImpl.java (modified) (9 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/HostApiImpl.java (modified) (11 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/LdapOrganizationalUnitApiImpl.java (modified) (5 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/NetworkAddressApiImpl.java (modified) (6 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/OrganizationApiImpl.java (modified) (5 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/OrganizationParameterApiImpl.java (modified) (6 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/OrganizationUnitApiImpl.java (modified) (3 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/ProgramApiImpl.java (modified) (2 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/TimetableApiImpl.java (modified) (5 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/UserApiImpl.java (modified) (4 diffs)
-
src/main/java/org/krakenapps/dom/api/impl/WidgetApiImpl.java (modified) (5 diffs)
-
src/main/java/org/krakenapps/dom/msgbus/AdminSettingPlugin.java (modified) (3 diffs)
-
src/main/java/org/krakenapps/dom/msgbus/HostPlugin.java (modified) (1 diff)
-
src/main/java/org/krakenapps/dom/msgbus/OrganizationPlugin.java (modified) (4 diffs)
Legend:
- Unmodified
- Added
- Removed
-
kraken-dom/pom.xml
r344 r348 11 11 <groupId>org.krakenapps</groupId> 12 12 <artifactId>kraken-dom</artifactId> 13 <version>1. 2.18</version>13 <version>1.3.0</version> 14 14 <packaging>bundle</packaging> 15 15 <name>Kraken DOM</name> -
kraken-dom/src/main/java/org/krakenapps/dom/api/AdminApi.java
r323 r348 39 39 Admin getAdminByUser(int organizationId, int userId); 40 40 41 voidcreateAdmin(int organizationId, Integer requestAdminId, Admin admin);41 Admin createAdmin(int organizationId, Integer requestAdminId, Admin admin); 42 42 43 voidupdateAdmin(int organizationId, Integer requestAdminId, Admin admin);43 Admin updateAdmin(int organizationId, Integer requestAdminId, Admin admin); 44 44 45 voidremoveAdmin(int organizationId, Integer requestAdminId, int adminId);45 Admin removeAdmin(int organizationId, Integer requestAdminId, int adminId); 46 46 47 47 boolean matchPassword(int organizationId, int adminId, String password); -
kraken-dom/src/main/java/org/krakenapps/dom/api/AdminSettingApi.java
r2 r348 21 21 22 22 public interface AdminSettingApi { 23 List<AdminSetting> get UserSettings(int organizationId, int userId);23 List<AdminSetting> getAdminSettings(int organizationId, int userId); 24 24 25 String get UserSetting(int organizationId, int userId, String name);25 String getAdminSetting(int organizationId, int userId, String name); 26 26 27 void updateAdminSetting(int organizationId, int userId, String name, String value);27 void setAdminSetting(int organizationId, int userId, String name, String value); 28 28 29 void removeUserSetting(int organizationId, int userId, String name);29 void unsetAdminSetting(int organizationId, int userId, String name); 30 30 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/ApplicationApi.java
r178 r348 23 23 import org.krakenapps.dom.model.Vendor; 24 24 25 public interface ApplicationApi {25 public interface ApplicationApi extends EntityEventProvider<Application> { 26 26 Collection<Vendor> getVendors(); 27 27 … … 30 30 Vendor createVendor(String name); 31 31 32 voidupdateVendor(String guid, String name);32 Vendor updateVendor(String guid, String name); 33 33 34 voidremoveVendor(String guid);34 Vendor removeVendor(String guid); 35 35 36 36 Collection<Application> getApplications(); … … 46 46 Application createApplication(String vendorGuid, String name, String platform, Map<String, String> props); 47 47 48 voidupdateApplication(String guid, String name, Map<String, String> props);48 Application updateApplication(String guid, String name, Map<String, String> props); 49 49 50 voidremoveApplication(String guid);50 Application removeApplication(String guid); 51 51 52 52 Collection<ApplicationVersion> getApplicationVersions(String vendorName, String appName); … … 54 54 ApplicationVersion createApplicationVersion(String vendorName, String appName, String version); 55 55 56 voidupdateApplicationVersion(String guid, String version);56 ApplicationVersion updateApplicationVersion(String guid, String version); 57 57 58 voidremoveApplicationVersion(String guid);58 ApplicationVersion removeApplicationVersion(String guid); 59 59 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/AreaApi.java
r2 r348 33 33 Collection<Area> getSubAreas(int organizationId, int areaId); 34 34 35 voidmoveArea(int organizationId, int newParentId, int id) throws AreaNotFoundException;35 Area moveArea(int organizationId, int newParentId, int id) throws AreaNotFoundException; 36 36 37 37 Area createArea(int organizationId, int parentId, String name, String description) throws AreaNotFoundException; … … 39 39 Area updateArea(int organizationId, int areaId, String name, String description) throws AreaNotFoundException; 40 40 41 void removeArea(int organizationId, int areaId) throws AreaNotFoundException, UndeletableAreaException; 42 43 void registerCallback(AreaEventCallback callback); 44 45 void unregisterCallback(AreaEventCallback callback); 41 Area removeArea(int organizationId, int areaId) throws AreaNotFoundException, UndeletableAreaException; 46 42 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/HostApi.java
r2 r348 42 42 List<Host> getHostsRecursively(int organizationId, int rootAreaId); 43 43 44 int createHost(int organizationId, int hostTypeId, int areaId, String name, String description);44 Host createHost(int organizationId, int hostTypeId, int areaId, String name, String description); 45 45 46 voidupdateHost(int organizationId, int hostId, String name, String description);46 Host updateHost(int organizationId, int hostId, String name, String description); 47 47 48 voidupdateHostGuid(int organizationId, int hostId, String guid);48 Host updateHostGuid(int organizationId, int hostId, String guid); 49 49 50 voidremoveHost(int organizationId, int hostId);50 Host removeHost(int organizationId, int hostId); 51 51 52 voidmoveHost(int organizationId, int hostId, int areaId);52 Host moveHost(int organizationId, int hostId, int areaId); 53 53 54 voidmapHostExtensions(int organizationId, int hostId, Set<String> hostExtensionNames);54 Host mapHostExtensions(int organizationId, int hostId, Set<String> hostExtensionNames); 55 55 56 voidunmapHostExtensions(int organizationId, int hostId, Set<String> hostExtensionNames);56 Host unmapHostExtensions(int organizationId, int hostId, Set<String> hostExtensionNames); 57 57 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/LdapOrganizationalUnitApi.java
r136 r348 21 21 import org.krakenapps.dom.model.OrganizationUnit; 22 22 23 public interface LdapOrganizationalUnitApi {23 public interface LdapOrganizationalUnitApi extends EntityEventProvider<LdapOrganizationalUnit> { 24 24 Collection<LdapOrganizationalUnit> getLdapOrganizationalUnits(); 25 25 26 26 LdapOrganizationalUnit getLdapOrganizationalUnit(int id); 27 27 28 voidcreateLdapOrganizationalUnit(LdapOrganizationalUnit unit);28 LdapOrganizationalUnit createLdapOrganizationalUnit(LdapOrganizationalUnit unit); 29 29 30 voidupdateLdapOrganizationalUnit(LdapOrganizationalUnit unit);30 LdapOrganizationalUnit updateLdapOrganizationalUnit(LdapOrganizationalUnit unit); 31 31 32 voidremoveLdapOrganizationalUnit(int id);33 34 voidremoveLdapOrganizationalUnit(OrganizationUnit unit);32 LdapOrganizationalUnit removeLdapOrganizationalUnit(int id); 33 34 LdapOrganizationalUnit removeLdapOrganizationalUnit(OrganizationUnit unit); 35 35 36 36 void sync(); -
kraken-dom/src/main/java/org/krakenapps/dom/api/NetworkAddressApi.java
r2 r348 20 20 import org.krakenapps.dom.model.NetworkAddress; 21 21 22 public interface NetworkAddressApi {22 public interface NetworkAddressApi extends EntityEventProvider<NetworkAddress> { 23 23 Collection<NetworkAddress> getNetworkAddresses(int organizationId); 24 24 … … 27 27 NetworkAddress createNetworkAddress(int organizationId, String name, int type, String address1, String address2); 28 28 29 void updateNetworkAddress(int organizationId, int id, String name, int type, String address1, String address2); 29 NetworkAddress updateNetworkAddress(int organizationId, int id, String name, int type, String address1, 30 String address2); 30 31 31 voidremoveNetworkAddress(int organizationId, int id);32 NetworkAddress removeNetworkAddress(int organizationId, int id); 32 33 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/OrganizationApi.java
r2 r348 20 20 import org.krakenapps.dom.model.Organization; 21 21 22 public interface OrganizationApi {22 public interface OrganizationApi extends EntityEventProvider<Organization> { 23 23 Collection<Organization> getOrganizations(); 24 24 … … 27 27 Organization getOrganizationForUser(int userId); 28 28 29 voidcreateOrganization(Organization organization);29 Organization createOrganization(Organization organization); 30 30 31 voidupdateOrganization(Organization organization);31 Organization updateOrganization(Organization organization); 32 32 33 voidremoveOrganization(int id);33 Organization removeOrganization(int id); 34 34 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/OrganizationParameterApi.java
r317 r348 16 16 package org.krakenapps.dom.api; 17 17 18 import java.util.Collection; 19 20 import org.krakenapps.dom.model.OrganizationParameter; 18 import java.util.Map; 21 19 22 20 public interface OrganizationParameterApi { 23 Collection<OrganizationParameter> getOrganizationParameters(int orgId);21 Map<String, String> getOrganizationParameters(int orgId); 24 22 25 OrganizationParametergetOrganizationParameter(int orgId, String name);23 String getOrganizationParameter(int orgId, String name); 26 24 27 25 void setOrganizationParameter(int orgId, String name, String value); -
kraken-dom/src/main/java/org/krakenapps/dom/api/OrganizationUnitApi.java
r147 r348 27 27 28 28 OrganizationUnit getOrganizationUnit(int id); 29 29 30 30 Collection<OrganizationUnit> getParents(int orgId, int id); 31 31 32 voidcreateOrganizationUnit(OrganizationUnit orgUnit);32 OrganizationUnit createOrganizationUnit(OrganizationUnit orgUnit); 33 33 34 voidupdateOrganizationUnit(OrganizationUnit orgUnit);34 OrganizationUnit updateOrganizationUnit(OrganizationUnit orgUnit); 35 35 36 voidremoveOrganizationUnit(int id);36 OrganizationUnit removeOrganizationUnit(int id); 37 37 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/ProgramApi.java
r41 r348 32 32 List<Program> getAvailablePrograms(int organizationId, int adminId) throws AdminNotFoundException; 33 33 34 voidcreateProgramProfile(ProgramProfile profile);34 ProgramProfile createProgramProfile(ProgramProfile profile); 35 35 36 voidupdateProgramProfile(ProgramProfile profile);36 ProgramProfile updateProgramProfile(ProgramProfile profile); 37 37 38 voidremoveProgramProfile(int programProfileId);38 ProgramProfile removeProgramProfile(int programProfileId); 39 39 40 40 Program getProgram(int programId); -
kraken-dom/src/main/java/org/krakenapps/dom/api/TimetableApi.java
r2 r348 29 29 Timetable createTimetable(int organizationId, String name, List<Schedule> schedules); 30 30 31 voidupdateTimetable(int organizationId, int id, String name, List<Schedule> schedules);31 Timetable updateTimetable(int organizationId, int id, String name, List<Schedule> schedules); 32 32 33 voidremoveTimetable(int organizationId, int id);33 Timetable removeTimetable(int organizationId, int id); 34 34 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/UserApi.java
r278 r348 39 39 User getUserByLoginName(String loginName); 40 40 41 voidcreateUser(User user);41 User createUser(User user); 42 42 43 voidupdateUser(User user);43 User updateUser(User user); 44 44 45 voidremoveUser(int id);45 User removeUser(int id); 46 46 47 47 boolean verifyPassword(String id, String password); -
kraken-dom/src/main/java/org/krakenapps/dom/api/WidgetApi.java
r2 r348 22 22 import org.krakenapps.dom.exception.WidgetNotFoundException; 23 23 import org.krakenapps.dom.model.Widget; 24 import org.krakenapps.dom.model.WidgetConfig; 24 25 25 26 public interface WidgetApi extends EntityEventProvider<Widget> { … … 28 29 Widget createWidget(int organizationId, int userId, int programId) throws AdminNotFoundException; 29 30 30 void removeWidget(int userId, int widgetId) throws WidgetNotFoundException; 31 Widget removeWidget(int userId, int widgetId) throws WidgetNotFoundException; 32 33 WidgetConfig setConfig(int userId, int widgetId, String key, String value) throws WidgetNotFoundException; 31 34 32 void setConfig(int userId, int widgetId, String key, String value) throws WidgetNotFoundException; 33 34 void unsetConfig(int userId, int widgetId, String key) throws WidgetConfigNotFoundException; 35 35 WidgetConfig unsetConfig(int userId, int widgetId, String key) throws WidgetConfigNotFoundException; 36 36 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/AdminApiImpl.java
r340 r348 49 49 import org.krakenapps.dom.model.Organization; 50 50 import org.krakenapps.dom.model.Admin; 51 import org.krakenapps.dom.model.OrganizationParameter;52 51 import org.krakenapps.dom.model.Role; 53 52 import org.krakenapps.jpa.ThreadLocalEntityManagerService; … … 92 91 93 92 if (hash.equals(Sha1.hash(password + session.getString("nonce")))) { 94 OrganizationParameter param= orgParamApi.getOrganizationParameter(admin.getUser().getOrganization().getId(),93 String maxSession = orgParamApi.getOrganizationParameter(admin.getUser().getOrganization().getId(), 95 94 "max_sessions"); 96 if ( param!= null) {95 if (maxSession != null) { 97 96 try { 98 int maxSessions = Integer.parseInt( param.getValue());97 int maxSessions = Integer.parseInt(maxSession); 99 98 if (maxSessions > 0) { 100 99 if (force) { … … 116 115 for (LoginCallback callback : callbacks) 117 116 callback.onLoginSuccess(admin, session); 118 loggedIn.add(new LoggedInAdmin(admin.getRole().getLevel(), new Date(), session, admin.getUser().getLoginName())); 117 loggedIn.add(new LoggedInAdmin(admin.getRole().getLevel(), new Date(), session, admin.getUser() 118 .getLoginName())); 119 119 return admin; 120 120 } else { … … 269 269 270 270 @Override 271 public void createAdmin(int organizationId, Integer requestAdminId, Admin admin) { 272 createAdminInternal(organizationId, requestAdminId, admin); 273 fireEntityAdded(admin); 274 } 275 276 @Transactional 277 private void createAdminInternal(int organizationId, Integer requestAdminId, Admin admin) { 271 public Admin createAdmin(int organizationId, Integer requestAdminId, Admin admin) { 272 Admin a = createAdminInternal(organizationId, requestAdminId, admin); 273 fireEntityAdded(a); 274 return a; 275 } 276 277 @Transactional 278 private Admin createAdminInternal(int organizationId, Integer requestAdminId, Admin admin) { 278 279 EntityManager em = entityManagerService.getEntityManager(); 279 280 Organization organization = em.find(Organization.class, organizationId); … … 300 301 em.persist(host); 301 302 } 303 304 return admin; 302 305 } 303 306 … … 323 326 Admin admin = (Admin) em.createQuery("SELECT a FROM Admin a LEFT JOIN a.user u WHERE u.loginName = ?") 324 327 .setParameter(1, loginName).getSingleResult(); 325 328 326 329 admin.getRole().getPermissions().size(); 327 330 admin.getTrustHosts().size(); 328 331 329 332 return admin; 330 333 } … … 379 382 380 383 @Override 381 public void removeAdmin(int organizationId, Integer requestAdminId, int adminId) { 382 Admin admin = removeAdminInternal(organizationId, requestAdminId, adminId); 383 fireEntityRemoved(admin); 384 } 385 386 @Transactional 387 private Admin removeAdminInternal(int organizationId, Integer requestAdminId, int adminId) { 388 EntityManager em = entityManagerService.getEntityManager(); 389 390 Admin admin = (Admin) em.find(Admin.class, adminId); 391 if (admin.getUser().getOrganization().getId() != organizationId) 392 throw new AdminNotFoundException(adminId); 393 394 if (requestAdminId != null) { 395 Admin requestAdmin = em.find(Admin.class, requestAdminId); 396 if (requestAdmin == null) 397 throw new AdminNotFoundException(requestAdminId); 398 399 if (requestAdmin.getRole().getLevel() < admin.getRole().getLevel()) 400 throw new SecurityException("remove admin"); 401 402 if (requestAdminId == adminId) { 403 throw new CannotRemoveRequestingAdminException(requestAdminId); 404 } 405 } 406 407 em.remove(admin); 408 409 return admin; 410 } 411 412 @Override 413 public void updateAdmin(int organizationId, Integer requestAdminId, Admin targetAdmin) { 384 public Admin updateAdmin(int organizationId, Integer requestAdminId, Admin targetAdmin) { 414 385 Admin admin = updateAdminInternal(organizationId, requestAdminId, targetAdmin); 415 386 fireEntityUpdated(admin); 387 return admin; 416 388 } 417 389 … … 477 449 } 478 450 451 @Override 452 public Admin removeAdmin(int organizationId, Integer requestAdminId, int adminId) { 453 Admin admin = removeAdminInternal(organizationId, requestAdminId, adminId); 454 fireEntityRemoved(admin); 455 return admin; 456 } 457 458 @Transactional 459 private Admin removeAdminInternal(int organizationId, Integer requestAdminId, int adminId) { 460 EntityManager em = entityManagerService.getEntityManager(); 461 462 Admin admin = (Admin) em.find(Admin.class, adminId); 463 if (admin.getUser().getOrganization().getId() != organizationId) 464 throw new AdminNotFoundException(adminId); 465 466 if (requestAdminId != null) { 467 Admin requestAdmin = em.find(Admin.class, requestAdminId); 468 if (requestAdmin == null) 469 throw new AdminNotFoundException(requestAdminId); 470 471 if (requestAdmin.getRole().getLevel() < admin.getRole().getLevel()) 472 throw new SecurityException("remove admin"); 473 474 if (requestAdminId == adminId) { 475 throw new CannotRemoveRequestingAdminException(requestAdminId); 476 } 477 } 478 479 em.remove(admin); 480 481 return admin; 482 } 483 479 484 private static final char[] chars = new char[62]; 480 485 static { -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/AdminSettingApiImpl.java
r141 r348 46 46 @Transactional 47 47 @Override 48 public List<AdminSetting> get UserSettings(int organizationId, int userId) {48 public List<AdminSetting> getAdminSettings(int organizationId, int userId) { 49 49 Admin user = userApi.getAdminByUser(organizationId, userId); 50 50 if (user == null) … … 57 57 @Transactional 58 58 @Override 59 public String get UserSetting(int organizationId, int userId, String name) {59 public String getAdminSetting(int organizationId, int userId, String name) { 60 60 EntityManager em = entityManagerService.getEntityManager(); 61 61 AdminSetting setting = getUserSetting(em, userId, name); … … 65 65 @Transactional 66 66 @Override 67 public void updateAdminSetting(int organizationId, int userId, String name, String value) {67 public void setAdminSetting(int organizationId, int userId, String name, String value) { 68 68 EntityManager em = entityManagerService.getEntityManager(); 69 69 Admin user = userApi.getAdminByUser(organizationId, userId); … … 86 86 @Transactional 87 87 @Override 88 public void removeUserSetting(int organizationId, int userId, String name) {88 public void unsetAdminSetting(int organizationId, int userId, String name) { 89 89 EntityManager em = entityManagerService.getEntityManager(); 90 90 Admin user = userApi.getAdminByUser(organizationId, userId); -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/ApplicationApiImpl.java
r182 r348 63 63 } 64 64 65 @Transactional66 65 @Override 67 66 public Vendor createVendor(String name) { 67 Vendor vendor = createVendorInternal(name); 68 return vendor; 69 } 70 71 @Transactional 72 private Vendor createVendorInternal(String name) { 68 73 EntityManager em = entityManagerService.getEntityManager(); 69 74 Vendor vendor = new Vendor(); … … 77 82 } 78 83 79 @Transactional 80 @Override 81 public void updateVendor(String guid, String name) { 84 @Override 85 public Vendor updateVendor(String guid, String name) { 86 Vendor vendor = updateVendorInternal(guid, name); 87 return vendor; 88 } 89 90 @Transactional 91 private Vendor updateVendorInternal(String guid, String name) { 82 92 EntityManager em = entityManagerService.getEntityManager(); 83 93 … … 90 100 91 101 em.merge(vendor); 92 } 93 94 @Transactional 95 @Override 96 public void removeVendor(String guid) { 102 103 return vendor; 104 } 105 106 @Override 107 public Vendor removeVendor(String guid) { 108 Vendor vendor = removeVendorInternal(guid); 109 return vendor; 110 } 111 112 @Transactional 113 private Vendor removeVendorInternal(String guid) { 97 114 EntityManager em = entityManagerService.getEntityManager(); 98 115 Vendor vendor = em.find(Vendor.class, guid); … … 102 119 103 120 em.remove(vendor); 121 122 return vendor; 104 123 } 105 124 … … 157 176 } 158 177 159 @Transactional160 178 @Override 161 179 public Application createApplication(String vendorGuid, String name, String platform, Map<String, String> props) { 180 Application app = createApplicationInternal(vendorGuid, name, platform, props); 181 fireEntityAdded(app); 182 return app; 183 } 184 185 @Transactional 186 private Application createApplicationInternal(String vendorGuid, String name, String platform, 187 Map<String, String> props) { 162 188 EntityManager em = entityManagerService.getEntityManager(); 163 189 … … 181 207 } 182 208 183 @Transactional 184 @Override 185 public void updateApplication(String guid, String name, Map<String, String> props) { 209 @Override 210 public Application updateApplication(String guid, String name, Map<String, String> props) { 211 Application app = updateApplicationInternal(guid, name, props); 212 fireEntityUpdated(app); 213 return app; 214 } 215 216 @Transactional 217 private Application updateApplicationInternal(String guid, String name, Map<String, String> props) { 186 218 EntityManager em = entityManagerService.getEntityManager(); 187 219 Application app = em.find(Application.class, guid); … … 197 229 em.remove(d); 198 230 } 199 231 200 232 app.getMetadatas().clear(); 201 233 setAppMetadatas(em, app, props); 202 234 203 235 em.merge(app); 236 237 return app; 204 238 } 205 239 … … 217 251 } 218 252 219 @Transactional 220 @Override 221 public void removeApplication(String guid) { 253 @Override 254 public Application removeApplication(String guid) { 255 Application app = removeApplicationInternal(guid); 256 fireEntityRemoved(app); 257 return app; 258 } 259 260 @Transactional 261 private Application removeApplicationInternal(String guid) { 222 262 EntityManager em = entityManagerService.getEntityManager(); 223 263 Application app = em.find(Application.class, guid); … … 226 266 227 267 em.remove(app); 268 269 return app; 228 270 } 229 271 … … 241 283 } 242 284 243 @Transactional244 285 @Override 245 286 public ApplicationVersion createApplicationVersion(String vendorName, String appName, String version) { 287 ApplicationVersion appVersion = createApplicationVersionIntenal(vendorName, appName, version); 288 return appVersion; 289 } 290 291 @Transactional 292 private ApplicationVersion createApplicationVersionIntenal(String vendorName, String appName, String version) { 246 293 EntityManager em = entityManagerService.getEntityManager(); 247 294 Vendor vendor = getVendor(vendorName); … … 264 311 } 265 312 266 @Transactional 267 @Override 268 public void updateApplicationVersion(String guid, String version) { 313 @Override 314 public ApplicationVersion updateApplicationVersion(String guid, String version) { 315 ApplicationVersion appVersion = updateApplicationVersionInternal(guid, version); 316 return appVersion; 317 } 318 319 @Transactional 320 private ApplicationVersion updateApplicationVersionInternal(String guid, String version) { 269 321 EntityManager em = entityManagerService.getEntityManager(); 270 322 ApplicationVersion appVersion = em.find(ApplicationVersion.class, guid); … … 276 328 277 329 em.merge(appVersion); 278 } 279 280 @Transactional 281 @Override 282 public void removeApplicationVersion(String guid) { 330 331 return appVersion; 332 } 333 334 @Override 335 public ApplicationVersion removeApplicationVersion(String guid) { 336 ApplicationVersion appVersion = removeApplicationVersionInternal(guid); 337 return appVersion; 338 } 339 340 @Transactional 341 private ApplicationVersion removeApplicationVersionInternal(String guid) { 283 342 EntityManager em = entityManagerService.getEntityManager(); 284 343 ApplicationVersion version = em.find(ApplicationVersion.class, guid); 285 344 if (version == null) 286 return ;345 return null; 287 346 288 347 em.remove(version); 348 349 return version; 289 350 } 290 351 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/AreaApiImpl.java
r2 r348 20 20 import java.util.HashSet; 21 21 import java.util.Set; 22 import java.util.WeakHashMap;23 22 24 23 import javax.persistence.EntityManager; … … 30 29 import org.krakenapps.dom.api.AbstractApi; 31 30 import org.krakenapps.dom.api.AreaApi; 32 import org.krakenapps.dom.api.AreaEventCallback;33 31 import org.krakenapps.dom.exception.AreaNotFoundException; 34 32 import org.krakenapps.dom.exception.OrganizationNotFoundException; … … 46 44 @Requires 47 45 private ThreadLocalEntityManagerService entityManagerService; 48 49 private WeakHashMap<AreaEventCallback, Integer> callbacks;50 51 public AreaApiImpl() {52 callbacks = new WeakHashMap<AreaEventCallback, Integer>();53 }54 46 55 47 @SuppressWarnings("unchecked") … … 108 100 } 109 101 110 @Transactional 111 @Override 112 public void moveArea(int organizationId, int newParentId, int id) throws AreaNotFoundException { 102 @Override 103 public Area moveArea(int organizationId, int newParentId, int id) throws AreaNotFoundException { 104 Area area = moveAreaInternal(organizationId, newParentId, id); 105 fireEntityUpdated(area); 106 return area; 107 } 108 109 @Transactional 110 private Area moveAreaInternal(int organizationId, int newParentId, int id) throws AreaNotFoundException { 113 111 EntityManager em = entityManagerService.getEntityManager(); 114 112 Area area = em.find(Area.class, id); … … 125 123 126 124 em.merge(area); 127 } 128 129 @Transactional 125 126 return area; 127 } 128 130 129 @Override 131 130 public Area createArea(int organizationId, int parentId, String name, String description) 131 throws AreaNotFoundException { 132 Area area = createAreaInternal(organizationId, parentId, name, description); 133 fireEntityAdded(area); 134 return area; 135 } 136 137 @Transactional 138 private Area createAreaInternal(int organizationId, int parentId, String name, String description) 132 139 throws AreaNotFoundException { 133 140 EntityManager em = entityManagerService.getEntityManager(); … … 147 154 em.persist(newArea); 148 155 149 for (AreaEventCallback callback : callbacks.keySet()) {150 if (callback != null)151 callback.onCreateCallback(newArea);152 }153 154 156 return newArea; 155 157 } … … 160 162 EntityManager em = entityManagerService.getEntityManager(); 161 163 try { 162 return (Area) em.createQuery("FROM Area a WHERE a.organization.id = ? AND a.parent IS NULL") .setParameter(163 1, organizationId).getSingleResult();164 return (Area) em.createQuery("FROM Area a WHERE a.organization.id = ? AND a.parent IS NULL") 165 .setParameter(1, organizationId).getSingleResult(); 164 166 } catch (NoResultException e) { 165 167 return null; … … 167 169 } 168 170 169 @Transactional170 @Override171 public void removeArea(int organizationId, int areaId) throws AreaNotFoundException, UndeletableAreaException {172 EntityManager em = entityManagerService.getEntityManager();173 174 Area area = getArea(organizationId, areaId, em);175 176 if (area.getParent() == null)177 throw new UndeletableAreaException();178 179 // node means all sub areas including parent180 for (Area node : getSubAreas(organizationId, areaId)) {181 for (AreaEventCallback callback : callbacks.keySet()) {182 if (callback != null)183 callback.onRemoveCallback(node);184 }185 }186 187 em.remove(area);188 }189 190 @Transactional191 171 @Override 192 172 public Area updateArea(int organizationId, int areaId, String name, String description) 173 throws AreaNotFoundException { 174 Area area = updateAreaInternal(organizationId, areaId, name, description); 175 fireEntityUpdated(area); 176 return area; 177 } 178 179 @Transactional 180 private Area updateAreaInternal(int organizationId, int areaId, String name, String description) 193 181 throws AreaNotFoundException { 194 182 EntityManager em = entityManagerService.getEntityManager(); … … 199 187 em.merge(area); 200 188 201 for (AreaEventCallback callback : callbacks.keySet()) { 202 if (callback != null) 203 callback.onUpdateCallback(area); 204 } 205 206 return area; 207 } 208 209 @Override 210 public void registerCallback(AreaEventCallback callback) { 211 callbacks.put(callback, null); 212 } 213 214 @Override 215 public void unregisterCallback(AreaEventCallback callback) { 216 callbacks.remove(callback); 189 return area; 190 } 191 192 @Override 193 public Area removeArea(int organizationId, int areaId) throws AreaNotFoundException, UndeletableAreaException { 194 Area area = removeAreaInternal(organizationId, areaId); 195 fireEntityRemoved(area); 196 return area; 197 } 198 199 @Transactional 200 private Area removeAreaInternal(int organizationId, int areaId) throws AreaNotFoundException, 201 UndeletableAreaException { 202 EntityManager em = entityManagerService.getEntityManager(); 203 204 Area area = getArea(organizationId, areaId, em); 205 206 if (area.getParent() == null) 207 throw new UndeletableAreaException(); 208 209 em.remove(area); 210 211 return area; 217 212 } 218 213 -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/HostApiImpl.java
r2 r348 59 59 EntityManager em = entityManagerService.getEntityManager(); 60 60 try { 61 return (HostExtension) em.createQuery("FROM HostExtension e WHERE e.className = ?") .setParameter(1,62 className).getSingleResult();61 return (HostExtension) em.createQuery("FROM HostExtension e WHERE e.className = ?") 62 .setParameter(1, className).getSingleResult(); 63 63 } catch (NoResultException e) { 64 64 return null; … … 83 83 84 84 @Override 85 public int createHost(int organizationId, int hostTypeId, int areaId, String name, String description) {85 public Host createHost(int organizationId, int hostTypeId, int areaId, String name, String description) { 86 86 Host host = createHostInternal(organizationId, hostTypeId, areaId, name, description); 87 87 fireEntityAdded(host); 88 return host .getId();88 return host; 89 89 } 90 90 … … 129 129 130 130 @Override 131 public voidupdateHost(int organizationId, int hostId, String name, String description) {131 public Host updateHost(int organizationId, int hostId, String name, String description) { 132 132 Host host = updateHostInternal(organizationId, hostId, name, description); 133 133 fireEntityUpdated(host); 134 return host; 134 135 } 135 136 … … 154 155 } 155 156 156 @ Transactional157 @Override158 public void updateHostGuid(int organizationId, int hostId, String guid) {159 EntityManager em = entityManagerService.getEntityManager();160 161 try {162 Host host = getHost(organizationId, hostId); 163 if (host == null)164 throw new HostNotFoundException();165 166 host.setGuid(guid);167 em.merge(host);168 169 fireEntityUpdated(host); 170 } catch (NoResultException e) {171 throw new HostNotFoundException();172 }157 @Override 158 public Host updateHostGuid(int organizationId, int hostId, String guid) { 159 Host host = updateHostGuidInternal(organizationId, hostId, guid); 160 fireEntityUpdated(host); 161 return host; 162 } 163 164 @Transactional 165 private Host updateHostGuidInternal(int organizationId, int hostId, String guid) { 166 EntityManager em = entityManagerService.getEntityManager(); 167 Host host = getHost(organizationId, hostId); 168 if (host == null) 169 throw new HostNotFoundException(); 170 171 host.setGuid(guid); 172 em.merge(host); 173 return host; 173 174 } 174 175 … … 206 207 EntityManager em = entityManagerService.getEntityManager(); 207 208 try { 208 Host host = (Host) em.createNamedQuery("Host.findById").setParameter(1, organizationId) .setParameter(2,209 hostId).getSingleResult();209 Host host = (Host) em.createNamedQuery("Host.findById").setParameter(1, organizationId) 210 .setParameter(2, hostId).getSingleResult(); 210 211 211 212 host.getExtensions().size(); // force loading … … 225 226 } 226 227 227 @Transactional 228 @Override 229 public void moveHost(int organizationId, int hostId, int areaId) { 228 @Override 229 public Host moveHost(int organizationId, int hostId, int areaId) { 230 Host host = moveHostInternal(organizationId, hostId, areaId); 231 fireEntityUpdated(host); 232 return host; 233 } 234 235 @Transactional 236 private Host moveHostInternal(int organizationId, int hostId, int areaId) { 230 237 EntityManager em = entityManagerService.getEntityManager(); 231 238 … … 238 245 239 246 em.merge(host); 240 }241 242 @Override 243 public void removeHost(int organizationId, int hostId) {244 Host host = getHost(organizationId, hostId);245 if (host == null)246 throw new HostNotFoundException();247 247 return host; 248 } 249 250 @Override 251 public Host removeHost(int organizationId, int hostId) { 252 Host host = getHost(organizationId, hostId); 253 if (host == null) 254 throw new HostNotFoundException(); 248 255 fireEntityRemoving(host); 249 256 removeHostInternal(organizationId, hostId); 250 257 fireEntityRemoved(host); 258 return host; 251 259 } 252 260 … … 255 263 EntityManager em = entityManagerService.getEntityManager(); 256 264 Host host = getHost(organizationId, hostId); 257 258 265 host.getExtensions().clear(); 259 260 266 em.remove(host); 261 267 } 262 268 263 @Transactional 264 @Override 265 public void mapHostExtensions(int organizationId, int hostId, Set<String> hostExtensionNames) { 269 @Override 270 public Host mapHostExtensions(int organizationId, int hostId, Set<String> hostExtensionNames) { 271 Host host = mapHostExtensionsInternal(organizationId, hostId, hostExtensionNames); 272 fireEntityUpdated(host); 273 return host; 274 } 275 276 @Transactional 277 private Host mapHostExtensionsInternal(int organizationId, int hostId, Set<String> hostExtensionNames) { 266 278 EntityManager em = entityManagerService.getEntityManager(); 267 279 Host host = getHost(organizationId, hostId); … … 280 292 em.merge(host); 281 293 } 294 295 return host; 282 296 } 283 297 … … 292 306 } 293 307 294 @Transactional 295 @Override 296 public void unmapHostExtensions(int organizationId, int hostId, Set<String> hostExtensionNames) { 308 @Override 309 public Host unmapHostExtensions(int organizationId, int hostId, Set<String> hostExtensionNames) { 310 Host host = unmapHostExtensionsInternal(organizationId, hostId, hostExtensionNames); 311 fireEntityUpdated(host); 312 return host; 313 } 314 315 @Transactional 316 private Host unmapHostExtensionsInternal(int organizationId, int hostId, Set<String> hostExtensionNames) { 297 317 EntityManager em = entityManagerService.getEntityManager(); 298 318 Host host = getHost(organizationId, hostId); … … 311 331 em.merge(host); 312 332 } 333 334 return host; 313 335 } 314 336 -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/LdapOrganizationalUnitApiImpl.java
r136 r348 71 71 72 72 @Override 73 public voidcreateLdapOrganizationalUnit(LdapOrganizationalUnit unit) {73 public LdapOrganizationalUnit createLdapOrganizationalUnit(LdapOrganizationalUnit unit) { 74 74 createLdapOrganizationalUnitInternal(unit); 75 75 fireEntityAdded(unit); 76 return unit; 76 77 } 77 78 … … 84 85 85 86 @Override 86 public voidupdateLdapOrganizationalUnit(LdapOrganizationalUnit unit) {87 public LdapOrganizationalUnit updateLdapOrganizationalUnit(LdapOrganizationalUnit unit) { 87 88 updateLdapOrganizationalUnitInternal(unit); 88 89 fireEntityUpdated(unit); 90 return unit; 89 91 } 90 92 … … 102 104 103 105 @Override 104 public voidremoveLdapOrganizationalUnit(int id) {106 public LdapOrganizationalUnit removeLdapOrganizationalUnit(int id) { 105 107 LdapOrganizationalUnit unit = removeLdapOrganizationalUnitInternal(id); 106 108 fireEntityRemoved(unit); 109 return unit; 107 110 } 108 111 … … 116 119 117 120 @Override 118 public void removeLdapOrganizationalUnit(OrganizationUnit orgUnit) { 119 LdapOrganizationalUnit ldapUnit = removeLdapOrganizationalUnitInternal(orgUnit); 120 fireEntityRemoved(ldapUnit); 121 public LdapOrganizationalUnit removeLdapOrganizationalUnit(OrganizationUnit orgUnit) { 122 LdapOrganizationalUnit unit = removeLdapOrganizationalUnitInternal(orgUnit); 123 fireEntityRemoved(unit); 124 return unit; 121 125 } 122 126 … … 127 131 .createQuery("FROM LdapOrganizationalUnit l WHERE l.organizationUnit.id = ?") 128 132 .setParameter(1, orgUnit.getId()).getSingleResult(); 129 133 130 134 em.remove(ldapUnit); 131 135 return ldapUnit; -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/NetworkAddressApiImpl.java
r2 r348 25 25 import org.apache.felix.ipojo.annotations.Provides; 26 26 import org.apache.felix.ipojo.annotations.Requires; 27 import org.krakenapps.dom.api.AbstractApi; 27 28 import org.krakenapps.dom.api.NetworkAddressApi; 28 29 import org.krakenapps.dom.api.OrganizationApi; … … 36 37 @Provides 37 38 @JpaConfig(factory = "dom") 38 public class NetworkAddressApiImpl implements NetworkAddressApi { 39 39 public class NetworkAddressApiImpl extends AbstractApi<NetworkAddress> implements NetworkAddressApi { 40 40 @Requires 41 41 private ThreadLocalEntityManagerService entityManagerService; … … 65 65 } 66 66 67 @Transactional68 67 @Override 69 68 public NetworkAddress createNetworkAddress(int organizationId, String name, int type, String address1, 69 String address2) { 70 NetworkAddress addr = createNetworkAddressInternal(organizationId, name, type, address1, address2); 71 fireEntityAdded(addr); 72 return addr; 73 } 74 75 @Transactional 76 private NetworkAddress createNetworkAddressInternal(int organizationId, String name, int type, String address1, 70 77 String address2) { 71 78 EntityManager em = entityManagerService.getEntityManager(); … … 88 95 } 89 96 97 @Override 98 public NetworkAddress updateNetworkAddress(int organizationId, int id, String name, int type, String address1, 99 String address2) { 100 NetworkAddress addr = updateNetworkAddressInternal(organizationId, id, name, type, address1, address2); 101 fireEntityUpdated(addr); 102 return addr; 103 } 104 90 105 @Transactional 91 @Override92 public void updateNetworkAddress(int organizationId, int id, String name, int type,String address1, String address2) {106 private NetworkAddress updateNetworkAddressInternal(int organizationId, int id, String name, int type, 107 String address1, String address2) { 93 108 EntityManager em = entityManagerService.getEntityManager(); 94 109 … … 104 119 105 120 em.merge(addr); 121 return addr; 122 } 123 124 @Override 125 public NetworkAddress removeNetworkAddress(int organizationId, int id) { 126 NetworkAddress addr = removeNetworkAddressInternal(organizationId, id); 127 fireEntityRemoved(addr); 128 return addr; 106 129 } 107 130 108 131 @Transactional 109 @Override 110 public void removeNetworkAddress(int organizationId, int id) { 132 private NetworkAddress removeNetworkAddressInternal(int organizationId, int id) { 111 133 EntityManager em = entityManagerService.getEntityManager(); 112 134 … … 116 138 117 139 em.remove(addr); 140 return addr; 118 141 } 119 142 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/OrganizationApiImpl.java
r317 r348 57 57 58 58 @Transactional 59 @Override 59 60 public Organization getOrganization(int id) { 60 61 EntityManager em = entityManagerService.getEntityManager(); … … 63 64 64 65 @Transactional 66 @Override 65 67 public Organization getOrganizationForUser(int userId) { 66 68 EntityManager em = entityManagerService.getEntityManager(); … … 72 74 } 73 75 74 public void createOrganization(Organization organization) { 75 createOrganizationInternal(organization); 76 fireEntityAdded(organization); 76 @Override 77 public Organization createOrganization(Organization organization) { 78 Organization org = createOrganizationInternal(organization); 79 fireEntityAdded(org); 80 return org; 77 81 } 78 82 79 83 @Transactional 80 private voidcreateOrganizationInternal(Organization organization) {84 private Organization createOrganizationInternal(Organization organization) { 81 85 EntityManager em = entityManagerService.getEntityManager(); 82 86 organization.setCreateDateTime(new Date()); … … 91 95 orgParameterApi.setOrganizationParameter(organization.getId(), "default_program_profile_id", 92 96 String.valueOf(profile.getId())); 97 return organization; 93 98 } 94 99 95 public void updateOrganization(Organization organization) { 96 updateOrganizationInternal(organization); 97 fireEntityUpdated(organization); 100 @Override 101 public Organization updateOrganization(Organization organization) { 102 Organization org = updateOrganizationInternal(organization); 103 fireEntityUpdated(org); 104 return org; 98 105 } 99 106 100 107 @Transactional 101 private voidupdateOrganizationInternal(Organization organization) {108 private Organization updateOrganizationInternal(Organization organization) { 102 109 EntityManager em = entityManagerService.getEntityManager(); 103 110 if (organization.getId() == 0) … … 112 119 org.setBackupDomainController(organization.getBackupDomainController()); 113 120 em.merge(org); 121 return org; 114 122 } 115 123 116 public void removeOrganization(int id) { 124 @Override 125 public Organization removeOrganization(int id) { 117 126 Organization org = removeOrganizationInternal(id); 118 127 fireEntityRemoved(org); 128 return org; 119 129 } 120 130 -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/OrganizationParameterApiImpl.java
r318 r348 16 16 package org.krakenapps.dom.api.impl; 17 17 18 import java.util.Collection; 18 import java.util.HashMap; 19 import java.util.List; 20 import java.util.Map; 19 21 20 22 import javax.persistence.EntityManager; … … 43 45 @Override 44 46 @Transactional 45 public Collection<OrganizationParameter> getOrganizationParameters(int orgId) {47 public Map<String, String> getOrganizationParameters(int orgId) { 46 48 EntityManager em = entityManagerService.getEntityManager(); 47 return em.createQuery("FROM OrganizationParameter o WHERE o.organization.id = ?").setParameter(1, orgId) 49 List<OrganizationParameter> orgParameters = em 50 .createQuery("FROM OrganizationParameter o WHERE o.organization.id = ?").setParameter(1, orgId) 48 51 .getResultList(); 52 53 Map<String, String> m = new HashMap<String, String>(); 54 for (OrganizationParameter orgParameter : orgParameters) 55 m.put(orgParameter.getName(), orgParameter.getValue()); 56 return m; 49 57 } 50 58 51 59 @Transactional 52 60 @Override 53 public OrganizationParametergetOrganizationParameter(int orgId, String name) {61 public String getOrganizationParameter(int orgId, String name) { 54 62 EntityManager em = entityManagerService.getEntityManager(); 55 63 try { … … 58 66 .setParameter(1, orgId).setParameter(2, name).getSingleResult(); 59 67 60 return op ;68 return op.getValue(); 61 69 } catch (NoResultException e) { 62 70 return null; … … 76 84 @Transactional 77 85 private OrganizationParameter setOrganizationParameterInternal(int orgId, String name, String value) { 78 OrganizationParameter orgParameter = getOrg anizationParameter(orgId, name);86 OrganizationParameter orgParameter = getOrgParameter(orgId, name); 79 87 if (orgParameter == null) { 80 88 EntityManager em = entityManagerService.getEntityManager(); … … 104 112 private OrganizationParameter unsetOrganizationParameterInternal(int orgId, String name) { 105 113 EntityManager em = entityManagerService.getEntityManager(); 106 OrganizationParameter op = getOrg anizationParameter(orgId, name);114 OrganizationParameter op = getOrgParameter(orgId, name); 107 115 if (op.getOrganization().getId() == orgId) { 108 116 em.remove(op); … … 111 119 return null; 112 120 } 121 122 @Transactional 123 public OrganizationParameter getOrgParameter(int orgId, String name) { 124 EntityManager em = entityManagerService.getEntityManager(); 125 OrganizationParameter op = (OrganizationParameter) em 126 .createQuery("FROM OrganizationParameter o WHERE o.organization.id = ? AND o.name = ?") 127 .setParameter(1, orgId).setParameter(2, name).getSingleResult(); 128 129 return op; 130 } 113 131 } -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/OrganizationUnitApiImpl.java
r162 r348 83 83 84 84 @Override 85 public void createOrganizationUnit(OrganizationUnit orgUnit) { 86 createOrganizationUnitInternal(orgUnit); 87 fireEntityAdded(orgUnit); 85 public OrganizationUnit createOrganizationUnit(OrganizationUnit orgUnit) { 86 OrganizationUnit ou = createOrganizationUnitInternal(orgUnit); 87 fireEntityAdded(ou); 88 return ou; 88 89 } 89 90 90 91 @Transactional 91 private voidcreateOrganizationUnitInternal(OrganizationUnit orgUnit) {92 private OrganizationUnit createOrganizationUnitInternal(OrganizationUnit orgUnit) { 92 93 EntityManager em = entityManagerService.getEntityManager(); 93 94 orgUnit.setCreateDateTime(new Date()); 94 95 em.persist(orgUnit); 96 return orgUnit; 95 97 } 96 98 97 99 @Override 98 public void updateOrganizationUnit(OrganizationUnit orgUnit) { 99 updateOrganizationUnitInternal(orgUnit); 100 fireEntityUpdated(orgUnit); 100 public OrganizationUnit updateOrganizationUnit(OrganizationUnit orgUnit) { 101 OrganizationUnit ou = updateOrganizationUnitInternal(orgUnit); 102 fireEntityUpdated(ou); 103 return ou; 101 104 } 102 105 103 106 @Transactional 104 private voidupdateOrganizationUnitInternal(OrganizationUnit orgUnit) {107 private OrganizationUnit updateOrganizationUnitInternal(OrganizationUnit orgUnit) { 105 108 EntityManager em = entityManagerService.getEntityManager(); 106 109 if (orgUnit.getId() == 0) … … 112 115 ou.setDomainController(orgUnit.getDomainController()); 113 116 em.merge(ou); 117 return ou; 114 118 } 115 119 116 120 @Override 117 public voidremoveOrganizationUnit(int id) {121 public OrganizationUnit removeOrganizationUnit(int id) { 118 122 // remove all related users 119 123 OrganizationUnit ou = getOrganizationUnit(id); … … 128 132 OrganizationUnit orgUnit = removeOrganizationUnitInternal(id); 129 133 fireEntityRemoved(orgUnit); 134 return orgUnit; 130 135 } 131 136 -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/ProgramApiImpl.java
r41 r348 97 97 98 98 @Override 99 public void createProgramProfile(ProgramProfile profile) { 100 createProgramProfileInternal(profile); 101 fireEntityAdded(profile); 99 public ProgramProfile createProgramProfile(ProgramProfile profile) { 100 ProgramProfile pp = createProgramProfileInternal(profile); 101 fireEntityAdded(pp); 102 return pp; 102 103 } 103 104 104 105 @Transactional 105 private voidcreateProgramProfileInternal(ProgramProfile profile) {106 private ProgramProfile createProgramProfileInternal(ProgramProfile profile) { 106 107 EntityManager em = entityManagerService.getEntityManager(); 107 108 em.persist(profile); 109 return profile; 108 110 } 109 111 110 112 @Override 111 public void updateProgramProfile(ProgramProfile profile) { 112 updateProgramProfileInternal(profile); 113 fireEntityUpdated(profile); 113 public ProgramProfile updateProgramProfile(ProgramProfile profile) { 114 ProgramProfile pp = updateProgramProfileInternal(profile); 115 fireEntityUpdated(pp); 116 return pp; 114 117 } 115 118 116 119 @Transactional 117 private voidupdateProgramProfileInternal(ProgramProfile profile) {120 private ProgramProfile updateProgramProfileInternal(ProgramProfile profile) { 118 121 EntityManager em = entityManagerService.getEntityManager(); 119 122 if (profile.getId() == 0) … … 124 127 pp.setDescription(profile.getDescription()); 125 128 em.merge(pp); 129 return pp; 126 130 } 127 131 128 132 @Override 129 public voidremoveProgramProfile(int programProfileId) {133 public ProgramProfile removeProgramProfile(int programProfileId) { 130 134 ProgramProfile profile = removeProgramProfileInternal(programProfileId); 131 135 fireEntityRemoved(profile); 136 return profile; 132 137 } 133 138 -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/TimetableApiImpl.java
r2 r348 27 27 import org.apache.felix.ipojo.annotations.Provides; 28 28 import org.apache.felix.ipojo.annotations.Requires; 29 import org.krakenapps.dom.api.AbstractApi; 29 30 import org.krakenapps.dom.api.OrganizationApi; 30 31 import org.krakenapps.dom.api.TimetableApi; … … 39 40 @Provides 40 41 @JpaConfig(factory = "dom") 41 public class TimetableApiImpl implements TimetableApi {42 public class TimetableApiImpl extends AbstractApi<Timetable> implements TimetableApi { 42 43 @Requires 43 44 private OrganizationApi orgApi; … … 62 63 } 63 64 64 @Transactional65 65 @Override 66 66 public Timetable createTimetable(int organizationId, String name, List<Schedule> schedules) { 67 Timetable t = createTimetableInternal(organizationId, name, schedules); 68 fireEntityAdded(t); 69 return t; 70 } 71 72 @Transactional 73 private Timetable createTimetableInternal(int organizationId, String name, List<Schedule> schedules) { 67 74 EntityManager em = entityManagerService.getEntityManager(); 68 75 Long count = (Long) em … … 94 101 } 95 102 103 @Override 104 public Timetable updateTimetable(int organizationId, int id, String name, List<Schedule> schedules) { 105 Timetable t = updateTimetableInternal(organizationId, id, name, schedules); 106 fireEntityUpdated(t); 107 return t; 108 } 109 96 110 @Transactional 97 @Override 98 public void updateTimetable(int organizationId, int id, String name, List<Schedule> schedules) { 111 private Timetable updateTimetableInternal(int organizationId, int id, String name, List<Schedule> schedules) { 99 112 EntityManager em = entityManagerService.getEntityManager(); 100 113 Long count = (Long) em … … 124 137 125 138 em.merge(t); 139 return t; 140 } 141 142 @Override 143 public Timetable removeTimetable(int organizationId, int id) { 144 Timetable t = removeTimetableInternal(organizationId, id); 145 fireEntityRemoved(t); 146 return t; 126 147 } 127 148 128 149 @Transactional 129 @Override 130 public void removeTimetable(int organizationId, int id) { 150 private Timetable removeTimetableInternal(int organizationId, int id) { 131 151 EntityManager em = entityManagerService.getEntityManager(); 132 152 Timetable t = get(em, organizationId, id); 133 153 em.remove(t); 154 return t; 134 155 } 135 156 -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/UserApiImpl.java
r305 r348 172 172 173 173 @Override 174 public void createUser(User user) { 175 createUserInternal(user); 176 fireEntityAdded(user); 177 } 178 179 @Transactional 180 private void createUserInternal(User user) { 174 public User createUser(User user) { 175 User u = createUserInternal(user); 176 fireEntityAdded(u); 177 return u; 178 } 179 180 @Transactional 181 private User createUserInternal(User user) { 181 182 EntityManager em = entityManagerService.getEntityManager(); 182 183 user.setPassword(hashPassword(user.getSalt(), user.getPassword())); … … 184 185 user.setUpdateDateTime(new Date()); 185 186 em.persist(user); 186 } 187 188 @Override 189 public void updateUser(User user) { 190 updateUserInternal(user); 191 fireEntityUpdated(user); 192 } 193 194 @Transactional 195 private void updateUserInternal(User user) { 187 return user; 188 } 189 190 @Override 191 public User updateUser(User user) { 192 User u = updateUserInternal(user); 193 fireEntityUpdated(u); 194 return u; 195 } 196 197 @Transactional 198 private User updateUserInternal(User user) { 196 199 EntityManager em = entityManagerService.getEntityManager(); 197 200 if (user.getId() == 0) … … 203 206 u.setName(user.getName()); 204 207 u.setDescription(user.getDescription()); 205 if (user.getPassword() != null )208 if (user.getPassword() != null && !user.getPassword().isEmpty()) 206 209 u.setPassword(hashPassword(user.getSalt(), user.getPassword())); 207 210 u.setTitle(user.getTitle()); … … 212 215 u.setAdmin(user.getAdmin()); 213 216 em.merge(u); 214 } 215 216 @Override 217 public void removeUser(int id) { 217 return u; 218 } 219 220 @Override 221 public User removeUser(int id) { 218 222 User user = removeUserInternal(id); 219 223 fireEntityRemoved(user); 224 return user; 220 225 } 221 226 -
kraken-dom/src/main/java/org/krakenapps/dom/api/impl/WidgetApiImpl.java
r2 r348 45 45 @Requires 46 46 private ThreadLocalEntityManagerService entityManagerService; 47 47 48 @Requires 48 49 private ProgramApi programApi; 50 49 51 @Requires 50 52 private AdminApi adminApi; … … 82 84 83 85 @Override 84 public voidremoveWidget(int adminId, int widgetId) throws WidgetNotFoundException {86 public Widget removeWidget(int adminId, int widgetId) throws WidgetNotFoundException { 85 87 Widget widget = removeWidgetInternal(adminId, widgetId); 86 88 fireEntityRemoved(widget); 89 return widget; 87 90 } 88 91 … … 98 101 } 99 102 103 @Override 104 public WidgetConfig setConfig(int adminId, int widgetId, String name, String value) throws WidgetNotFoundException { 105 WidgetConfig config = setConfigInternal(adminId, widgetId, name, value); 106 Widget widget = config.getWidget(); 107 widget.getWidgetConfigs().size(); 108 fireEntityUpdated(widget); 109 return config; 110 } 111 100 112 @Transactional 101 @Override102 public void setConfig(int adminId, int widgetId, String name, String value)throws WidgetNotFoundException {113 private WidgetConfig setConfigInternal(int adminId, int widgetId, String name, String value) 114 throws WidgetNotFoundException { 103 115 EntityManager em = entityManagerService.getEntityManager(); 104 116 … … 121 133 em.persist(config); 122 134 } 135 return config; 123 136 } 124 137 … … 132 145 } 133 146 147 @Override 148 public WidgetConfig unsetConfig(int adminId, int widgetId, String key) throws WidgetConfigNotFoundException { 149 WidgetConfig config = unsetConfigInternal(adminId, widgetId, key); 150 Widget widget = config.getWidget(); 151 widget.getWidgetConfigs().size(); 152 fireEntityUpdated(widget); 153 return config; 154 } 155 134 156 @Transactional 135 @Override136 public void unsetConfig(int adminId, int widgetId, String key)throws WidgetConfigNotFoundException {157 private WidgetConfig unsetConfigInternal(int adminId, int widgetId, String key) 158 throws WidgetConfigNotFoundException { 137 159 EntityManager em = entityManagerService.getEntityManager(); 138 160 try { 139 WidgetConfig config = (WidgetConfig) em .createQuery(140 "FROM WidgetConfig c WHERE c.widget.id = ? AND c.name = ?").setParameter(1, widgetId).setParameter(141 2, key).getSingleResult();161 WidgetConfig config = (WidgetConfig) em 162 .createQuery("FROM WidgetConfig c WHERE c.widget.id = ? AND c.name = ?").setParameter(1, widgetId) 163 .setParameter(2, key).getSingleResult(); 142 164 if (config.getWidget().getAdmin().getId() != adminId) 143 165 throw new WidgetConfigNotFoundException(); 144 166 145 167 em.remove(config); 168 return config; 146 169 } catch (NoResultException e) { 147 170 throw new WidgetConfigNotFoundException(); -
kraken-dom/src/main/java/org/krakenapps/dom/msgbus/AdminSettingPlugin.java
r2 r348 35 35 int adminId = req.getSession().getAdminId(); 36 36 String name = req.getString("name"); 37 String value = adminSettingApi.get UserSetting(organizationId, adminId, name);37 String value = adminSettingApi.getAdminSetting(organizationId, adminId, name); 38 38 resp.put("setting", value); 39 39 } … … 46 46 String value = req.getString("value"); 47 47 48 adminSettingApi. updateAdminSetting(organizationId, adminId, name, value);48 adminSettingApi.setAdminSetting(organizationId, adminId, name, value); 49 49 } 50 50 … … 55 55 String name = req.getString("name"); 56 56 57 adminSettingApi. removeUserSetting(organizationId, adminId, name);57 adminSettingApi.unsetAdminSetting(organizationId, adminId, name); 58 58 } 59 59 } -
kraken-dom/src/main/java/org/krakenapps/dom/msgbus/HostPlugin.java
r2 r348 91 91 String description = req.getString("description"); 92 92 93 int id= hostApi.createHost(organizationId, hostTypeId, areaId, name, description);94 resp.put("id", id);93 Host host = hostApi.createHost(organizationId, hostTypeId, areaId, name, description); 94 resp.put("id", host.getId()); 95 95 } 96 96 -
kraken-dom/src/main/java/org/krakenapps/dom/msgbus/OrganizationPlugin.java
r317 r348 16 16 package org.krakenapps.dom.msgbus; 17 17 18 import java.util. Collection;18 import java.util.Map; 19 19 20 20 import org.apache.felix.ipojo.annotations.Component; … … 24 24 import org.krakenapps.dom.exception.OrganizationNotFoundException; 25 25 import org.krakenapps.dom.model.Organization; 26 import org.krakenapps.dom.model.OrganizationParameter;27 import org.krakenapps.msgbus.Marshaler;28 26 import org.krakenapps.msgbus.Request; 29 27 import org.krakenapps.msgbus.Response; … … 88 86 @MsgbusPermission(group = "dom.org", code = "manage") 89 87 public void getOrganizationParameters(Request req, Response resp) { 90 Collection<OrganizationParameter> parameters = organizationParameterApi.getOrganizationParameters(req 91 .getOrgId()); 92 resp.put("result", Marshaler.marshal(parameters)); 88 Map<String, String> parameters = organizationParameterApi.getOrganizationParameters(req.getOrgId()); 89 resp.put("result", parameters); 93 90 } 94 91 … … 96 93 @MsgbusPermission(group = "dom.org", code = "manage") 97 94 public void getOrganizationParameter(Request req, Response resp) { 98 OrganizationParameter parameter = null; 99 parameter = organizationParameterApi.getOrganizationParameter(req.getOrgId(), req.getString("name")); 100 resp.put("result", parameter.marshal()); 95 String value = organizationParameterApi.getOrganizationParameter(req.getOrgId(), req.getString("name")); 96 resp.put("result", value); 101 97 } 102 98
Note: See TracChangeset
for help on using the changeset viewer.
