March 2008 - Simexplorer-si-commits - mailman.cloud.codelutin.com

r1433 - trunk/simexplorer-is/src/site/fr/rst
by glandais＠users.labs.libre-entreprise.org March 20, 2008

March 20, 2008

Author: glandais Date: 2008-03-20 16:43:50 +0000 (Thu, 20 Mar 2008) New Revision: 1433 Modified: trunk/simexplorer-is/src/site/fr/rst/rules.rst Log: Rules document Modified: trunk/simexplorer-is/src/site/fr/rst/rules.rst =================================================================== --- trunk/simexplorer-is/src/site/fr/rst/rules.rst 2008-03-20 16:43:31 UTC (rev 1432) +++ trunk/simexplorer-is/src/site/fr/rst/rules.rst 2008-03-20 16:43:50 UTC (rev 1433) @@ -11,13 +11,34 @@ Droits sur un élément : + - owner : l'utilisateur est propriétaire, il a tous les droits + - admin : l'utilisateur peut gérer les droits sur l'élément. Il peut aussi le supprimer. Il peut bien sûr lire et écrire. + - write : l'utilisateur peut créer une nouvelle version, et le lire + - read : l'utilisateur peut uniquement lire l'élément (dans toutes ses versions) - le superadmin possède tous les droits sur tous les éléments - "atomique" : droits explicites ou d'admin ou propriétaire de l'Actor - global : droits atomique de l'Actor ou d'un de ses parents (memberOf récursif). Ainsi si l'utilisateur n'a pas les droits explicites, mais qu'un de ses groupes auxquels il apprtient les possède, l'utilisateur acquière ces droits. - - si un User est propriétaire d'un groupe sans en être membre, il n'a pas les droits du groupe + - si un User est propriétaire d'un groupe sans en être membre, il n'a pas les droits du groupe + - tout utilisateur a tous les droits sur un id non encore enregistré (permet l'enregistrement d'un nouvel élément) +Exemple : Si l'utilisateur a les droits d'écriture, il a aussi les droits de lecture. + ++--------+-------+-------+-------+-------+ +| | Owner | Admin | Write | Read | ++========+=======+=======+=======+=======+ +| Owner | O | X | X | X | ++--------+-------+-------+-------+-------+ +| Admin | O | O | X | X | ++--------+-------+-------+-------+-------+ +| Delete | O | O | X | X | ++--------+-------+-------+-------+-------+ +| Write | O | O | O | X | ++--------+-------+-------+-------+-------+ +| Read | O | O | O | O | ++--------+-------+-------+-------+-------+ + Sauvegarde d'un élément : - les droits associés sont mis à jour via cette méthode @@ -25,3 +46,110 @@ - une permission est créée si et seulement si aucune permission n'existe avec cet utilisateur. La permission créée a pour propriétaire l'utilisateur sauvant l'élément, donc tous les droits. +Storage +======= + +Config +------ + +Sera modifié prochainement (utilisation d'un fichier par défaut et/ou d'un fichier externe et/ou de la +configuration commandline). + +Stockage des "Attachments" +-------------------------- + +Les flux associés aux entités sont sauvées sur le disque par FileSystemAttachmentHandler. +Le dossier de base est retrouvé via la configuration. Afin de ne pas générer trop de dossiers dans +ce dossier, les données sont stockées dans une arborescence correspondant aux trois premiers caractères +de leur id. +Ainsi, l'élément avec l'id efjsisjd sera stocké dans le dossier /baseFolder/e/f/j/efjsisjd. +Si l'id a moins de trois caractères, le dossier est directement l'id. + +Le stockage des données (storeData) met à jour l'Attachment associé (hash et taille). + +Aucun contrôle métier n'est fait à ce niveau. + +Database +-------- + +Cette classe gère uniquement le stockage des données spécifiques à SimExplorer IS. De plus, elle doit +être en mesure d'indexer les données afin d'effecture les recherches. + +L'implémentation par défaut est LuceneDatabase. + +Le dossier où est stocké l'index est spécifié dans la configuration, ainsi que l'intervalle de +compactage de l'index (réduction du nombre de fichiers utilisés pour l'index). + +Un pool de searchers permet de traiter les requêtes en parallèle de l'insertion. Une insertion invalide +le pool et les searchers doivent être recréés à la requête suivante. + +Le filtrage des données (afin d'afficher uniquement les éléments que l'utilisateur peut lire) est détaché +du module de sécurité (les données étant stockées dans deux systèmes différents, JPA d'un côté, Lucene +de l'autre). +Il est maintenu en mémoire une liste de filtre sur les éléments visibles pour un utilisateur. Cette liste +est gérée par le service liant sécurité et persistence. La méthode updateFilter met à jour le filtre +d'un utilisateur en passant en paramètre la liste des ids des éléments qu'il a le droit de visualiser. +Un filtre Lucene est créé à partir de cette liste, avec de très bonnes performances (voir +http://www.nabble.com/Security-filtering-from-external-DB-td15630408.html). + +Deux types de données sont sauvées dans la base Lucene : + + - les MetaData : des méthodes permettent de transformer un Document lucene en MetaData et vice versa. + Ces méthodes ne sont appellées uniquement si c'est vraiment utile, pour l'affichage d'un élément ou le + chargement d'un élément. Tout Document d'un ensemble Hits (résultat de recherche) peut être converti, + mais c'est une opération coûteuse, nottament sur des milliers d'éléments... + - les hierarchies entre MetaData : on conserve dans l'index les relations d'un MetaData, avec ses parents + et ses enfants. Cela permettra d'appliquer les règles métiers durant les ajouts/suppressions. Lors + du clonage d'un élément, une méthode permet de dupliquer les associations des éléments utilisés par le cloné. + +Pour ces deux types de données, un champ composite avec l'id et la version est créé, afin de faciliter les +recherches. + +La base peut être explorée avec Luke (http://www.getopt.org/luke) + +Aucun contrôle métier n'est fait à ce niveau. + +StorageEngine +------------- + +Dans son implémentation de base, StorageEngineImpl, cette classe sert de liant entre les métadonnées et les fichiers. + +Elle délègue toutes ses méthodes aux implémentations de Database et AttachmentHandler. Elle permet tout de même de stocker +des fichiers temporaires avec un MetaData spécifique dédié. De plus, elle a en charge la conversion des Attachment en +données indexables, en passant par les ContentType des données (méthode saveElement). + +En mode serveur, cette classe est utilisée en EJB, via StorageEngineSecuImpl. Cela permet d'accéder à l'EJB CredentialManager. +Ainsi, on peut contrôler toutes les actions de l'utilisateur en vérifiant ses droits. + +Les règles évoquées dans la partie Security s'appliquent. + +Service +======= + +Authentification +---------------- + + - Droits d'administration sur un groupe : superadmin, admin du groupe ou d'un groupe parent + - Droits d'administration sur un utilisateur : superadmin, ou droits d'administration sur un groupe + des groupes de l'utilisateur + - Droits de suppression d'un groupe : droits d'administration sur le groupe + - Droits de suppression d'un utilisateur : droits d'administration sur l'utilisateur + - Droits de consultation d'un utilisateur/groupe : l'utilisateur doit être connecté (ie token valide) + - Droits de création d'un utilisateur/groupe : l'utilisateur doit être admin ou superadmin + - Droits de mise à jour = droits d'administration + +Création d'un utilisateur : un mail est envoyé à l'adresse spécifiée avec son mot de passe et son login. +Suppression d'un groupe/utilisateur : suppression logique (visible = false) +Mise à jour d'un groupe : la récursion est vérifiée et supprimée le cas échéant +Mise à jour d'un utilisateur : seul le super admin peut modifier le fait qu'il soit admin ou superadmin + +A la première connexion, on vérifie si le superadmin existe, sinon il est créé avec le mot de passe password. +Le paramètre password passée à la méthode de login n'est pas le mot de passe en clair, mais un hash (voir AuthenticationServiceHelper). +Au login, les token vieux de plus de 24h sont supprimés. +Chaque appel à getLoggedUser mets à jour la date de login à l'instant présent. + +La demande d'un compte envoie un mail au superadmin avec le login désiré et l'adresse mail de l'utilisateur. + +Un nouveau mot de passe peut être généré si l'administrateur possède les droits d'administration sur cet utilisateur. Un +mail est alors envoyé à l'adresse de l'utilisateur. +

1 0

r1432 - trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/database/lucene
by glandais＠users.labs.libre-entreprise.org March 20, 2008

March 20, 2008

Author: glandais Date: 2008-03-20 16:43:31 +0000 (Thu, 20 Mar 2008) New Revision: 1432 Modified: trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/database/lucene/LuceneDatabaseTestCase.java Log: Updating tests Modified: trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/database/lucene/LuceneDatabaseTestCase.java =================================================================== --- trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/database/lucene/LuceneDatabaseTestCase.java 2008-03-20 16:43:11 UTC (rev 1431) +++ trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/database/lucene/LuceneDatabaseTestCase.java 2008-03-20 16:43:31 UTC (rev 1432) @@ -36,7 +36,8 @@ import fr.cemagref.simexplorer.is.entities.metadata.Version; import fr.cemagref.simexplorer.is.storage.MetaDataGenerator; import fr.cemagref.simexplorer.is.storage.SearchColumn; -import fr.cemagref.simexplorer.is.storage.database.Database; +import fr.cemagref.simexplorer.is.storage.SortColumn; +import fr.cemagref.simexplorer.is.storage.SortOrder; import fr.cemagref.simexplorer.is.storage.util.Config; /** @@ -48,8 +49,8 @@ private static final Log log = LogFactory.getLog(LuceneDatabaseTestCase.class); /** The database. */ - private Database database; - // private ElementGenerator elementGenerator; + private LuceneDatabase database; + /** The mdg. */ private MetaDataGenerator mdg = new MetaDataGenerator(); @@ -65,7 +66,6 @@ Config.setPropertiesLocation("/properties/testConfig.properties"); database = new LuceneDatabase(); database.open(true); - // elementGenerator = new ElementGenerator(); } /* (non-Javadoc) @@ -86,10 +86,15 @@ MetaData me = mdg.generateMetaDataEntity(); database.insertElement(me, new ArrayList<Reader>(), new ArrayList<Attachment>(), new ArrayList<Descriptor>()); database.commit(); + MetaData me2 = database.getElement(me.getUuid(), me.getVersion()); - assertEquals(me.getDescription(), me2.getDescription()); + assertEquals(me, me2); + database.insertElement(me, new ArrayList<Reader>(), new ArrayList<Attachment>(), new ArrayList<Descriptor>()); database.commit(); + + me2 = database.getElement(me.getUuid(), me.getVersion()); + assertEquals(me, me2); } /** @@ -110,9 +115,12 @@ database.insertElement(me, readers, new ArrayList<Attachment>(), new ArrayList<Descriptor>()); database.commit(); - int mesCount = database.findElementsByContentSearchCount(keyphrase, SearchColumn.AllFields, true); + + List<MetaData> findElementsByContentSearch = database.findElementsByContentSearch(keyphrase, SearchColumn.AllFields, true, 0, 1, SortColumn.None, SortOrder.Ascending); - assertEquals(1, mesCount); + assertEquals(1, findElementsByContentSearch.size()); + assertEquals(me, findElementsByContentSearch.get(0)); + } /**

1 0

r1431 - trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage
by glandais＠users.labs.libre-entreprise.org March 20, 2008

March 20, 2008

Author: glandais Date: 2008-03-20 16:43:11 +0000 (Thu, 20 Mar 2008) New Revision: 1431 Modified: trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/VersionGenerator.java Log: Simplified Modified: trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/VersionGenerator.java =================================================================== --- trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/VersionGenerator.java 2008-03-20 16:42:48 UTC (rev 1430) +++ trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/VersionGenerator.java 2008-03-20 16:43:11 UTC (rev 1431) @@ -69,7 +69,7 @@ */ public Version generateVersion() { StringBuilder sb = new StringBuilder(); - for (int i = 0, size = generateNotNullAbsInt(MAX_SIZE); i < size; i++) { + for (int i = 0, size = generateAbsInt(MAX_SIZE); i < size; i++) { sb.append('.').append(generateAbsInt(MAX_VERSION_NUMBER)); } return Version.valueOf(sb.substring(1)); @@ -81,7 +81,7 @@ * @return the version[] */ public Version[] generateVersions() { - int nb = generateNotNullAbsInt(MAX_NB_VERSIONS); + int nb = generateAbsInt(MAX_NB_VERSIONS); return generateVersions(nb); } @@ -94,7 +94,7 @@ * @return the version[] */ public Version[] generateVersions(Version mandatory) { - int nb = generateNotNullAbsInt(MAX_NB_VERSIONS); + int nb = generateAbsInt(MAX_NB_VERSIONS); Version[] versions = generateVersions(nb); List<Version> list = new ArrayList<Version>(Arrays.asList(versions)); if (!list.contains(mandatory)) { @@ -125,7 +125,7 @@ } /** - * Generate abs int. + * Generate not null abs int. * * @param max * the max @@ -133,26 +133,10 @@ * @return the int */ protected int generateAbsInt(int max) { - return Math.abs(r.nextInt()) % max; + return 1 + r.nextInt(max - 1); } /** - * Generate not null abs int. - * - * @param max - * the max - * - * @return the int - */ - protected int generateNotNullAbsInt(int max) { - int nb = 0; - while (nb == 0) { - nb = generateAbsInt(max); - } - return nb; - } - - /** * Instantiates a new version generator. */ protected VersionGenerator() {

1 0

r1430 - trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage
by glandais＠users.labs.libre-entreprise.org March 20, 2008

March 20, 2008

Author: glandais Date: 2008-03-20 16:42:48 +0000 (Thu, 20 Mar 2008) New Revision: 1430 Modified: trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/MetaDataGenerator.java Log: Removed descriptors Modified: trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/MetaDataGenerator.java =================================================================== --- trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/MetaDataGenerator.java 2008-03-20 16:41:47 UTC (rev 1429) +++ trunk/simexplorer-is/simexplorer-is-storage/src/test/fr/cemagref/simexplorer/is/storage/MetaDataGenerator.java 2008-03-20 16:42:48 UTC (rev 1430) @@ -33,15 +33,6 @@ /** The r. */ java.util.Random r = new java.util.Random(); - /* - * private static boolean descriptorFieldsInit = false; private static - * String[] descriptorFields; - * - * private static void generateDescriptors() { descriptorFields = new - * String[10]; for (int i = 0; i < descriptorFields.length; i++) { - * descriptorFields[i] = "descriptor" + i; } } - */ - /** * Generate meta data entity. * @@ -83,13 +74,6 @@ me.setLatest(true); me.setCreationDate(new Date()); me.setHash(UUID.randomUUID().toString()); - - Map<String, String> descriptors = new HashMap<String, String>(); - descriptors.put("overallId", uuid); - int i = 5 + r.nextInt(10); - for (int j = 0; j < i; j++) { - descriptors.put("descriptor" + j, UUID.randomUUID().toString()); - } me.setParentUuid(null); me.setParentVersion((Version) null);

1 0

r1429 - trunk/simexplorer-is/simexplorer-is-storage/src/java/fr/cemagref/simexplorer/is/storage/database
by glandais＠users.labs.libre-entreprise.org March 20, 2008

March 20, 2008

Author: glandais Date: 2008-03-20 16:41:47 +0000 (Thu, 20 Mar 2008) New Revision: 1429 Modified: trunk/simexplorer-is/simexplorer-is-storage/src/java/fr/cemagref/simexplorer/is/storage/database/DatabaseConstants.java Log: useless constants Modified: trunk/simexplorer-is/simexplorer-is-storage/src/java/fr/cemagref/simexplorer/is/storage/database/DatabaseConstants.java =================================================================== --- trunk/simexplorer-is/simexplorer-is-storage/src/java/fr/cemagref/simexplorer/is/storage/database/DatabaseConstants.java 2008-03-20 16:41:37 UTC (rev 1428) +++ trunk/simexplorer-is/simexplorer-is-storage/src/java/fr/cemagref/simexplorer/is/storage/database/DatabaseConstants.java 2008-03-20 16:41:47 UTC (rev 1429) @@ -24,9 +24,6 @@ */ public interface DatabaseConstants { - /** The Constant DOT. */ - public static final String DOT = "."; - /** Field name for id. */ public static final String KEY_UUID = "simexplorer.uuid"; @@ -78,12 +75,4 @@ /** Field name for searchable content. */ public static final String KEY_SEARCHABLE_ATTACHMENTS_CONTENT = "simexplorer.searchable.attachments.content"; - /** No date sort. */ - public static final int SORT_NONE = 0; - - /** Sort element by date (ascending). */ - public static final int SORT_ASCENDING = 1; - - /** Sort element by date (descending). */ - public static final int SORT_DESCENDING = -1; }

1 0

r1428 - trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/storage/engine
by glandais＠users.labs.libre-entreprise.org March 20, 2008

March 20, 2008

Author: glandais Date: 2008-03-20 16:41:37 +0000 (Thu, 20 Mar 2008) New Revision: 1428 Modified: trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/storage/engine/StorageEngineSecuImpl.java Log: Full featured StorageEngineSecuImpl Modified: trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/storage/engine/StorageEngineSecuImpl.java =================================================================== --- trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/storage/engine/StorageEngineSecuImpl.java 2008-03-20 16:41:08 UTC (rev 1427) +++ trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/storage/engine/StorageEngineSecuImpl.java 2008-03-20 16:41:37 UTC (rev 1428) @@ -50,31 +50,90 @@ @EJB private CredentialManager credentialManager; - /* (non-Javadoc) - * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#deleteElement(java.lang.String, java.lang.String, fr.cemagref.simexplorer.is.entities.metadata.Version) + /** + * Gets the user filter. + * + * @param token the token + * + * @return the user filter + * + * @throws SimExplorerTechnicalException the sim explorer technical exception */ - @Override - public void deleteElement(String token, String uuid, Version version) throws SimExplorerException { + private String getUserFilter(String token) throws SimExplorerTechnicalException { + // unique id for user logged + String userFilter = credentialManager.getUserFilter(token); + // check if filter should be updated + if (!credentialManager.isCacheValidFor(userFilter)) { + // update filter in database + database.updateFilter(userFilter, credentialManager.getElementsVisibleBy(token)); + } + return userFilter; + } + + /** + * Can delete. + * + * @param token the token + * @param uuid the uuid + * + * @throws SimExplorerException the sim explorer exception + */ + private void canDelete(String token, String uuid) throws SimExplorerException { Permission permission = credentialManager.getPermission(token, uuid); - if (permission.isCanAdmin()) { - super.deleteElement(token, uuid, version); - } else { + if (!permission.isCanAdmin()) { throw new SimExplorerSecurityException(); } } - @Override - public void deleteData(String token, MetaData entity, Attachment attachment) throws SimExplorerException { - Permission permission = credentialManager.getPermission(token, entity.getUuid()); - if (permission.isCanAdmin()) { - super.deleteData(token, entity, attachment); - } else { + /** + * Can read. + * + * @param token the token + * @param uuid the uuid + * + * @throws SimExplorerException the sim explorer exception + */ + private void canRead(String token, String uuid) throws SimExplorerException { + Permission permission = credentialManager.getPermission(token, uuid); + if (!permission.isCanRead()) { throw new SimExplorerSecurityException(); } + } + /** + * Can write. + * + * @param token the token + * @param uuid the uuid + * + * @throws SimExplorerException the sim explorer exception + */ + private void canWrite(String token, String uuid) throws SimExplorerException { + Permission permission = credentialManager.getPermission(token, uuid); + if (!permission.isCanWrite()) { + throw new SimExplorerSecurityException(); + } } /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#deleteElement(java.lang.String, java.lang.String, fr.cemagref.simexplorer.is.entities.metadata.Version) + */ + @Override + public void deleteElement(String token, String uuid, Version version) throws SimExplorerException { + canDelete(token, uuid); + super.deleteElement(token, uuid, version); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#deleteData(java.lang.String, fr.cemagref.simexplorer.is.entities.metadata.MetaData, fr.cemagref.simexplorer.is.entities.attachment.Attachment) + */ + @Override + public void deleteData(String token, MetaData entity, Attachment attachment) throws SimExplorerException { + canDelete(token, entity.getUuid()); + super.deleteData(token, entity, attachment); + } + + /* (non-Javadoc) * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#findElementsByType(java.lang.String, java.lang.String, boolean, int, int, int) */ @Override @@ -117,36 +176,13 @@ return database.findElementsByContentSearchCount(query, searchColumn, onlyLatest, userFilter); } - /** - * Gets the user filter. - * - * @param token the token - * - * @return the user filter - * - * @throws SimExplorerTechnicalException the sim explorer technical exception - */ - private String getUserFilter(String token) throws SimExplorerTechnicalException { - String userFilter = credentialManager.getUserFilter(token); - if (!credentialManager.isCacheValidFor(userFilter)) { - database.updateFilter(userFilter, credentialManager.getElementsVisibleBy(token)); - } - return userFilter; - } - /* (non-Javadoc) * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#getMetadata(java.lang.String, java.lang.String, fr.cemagref.simexplorer.is.entities.metadata.Version) */ @Override public MetaData getMetadata(String token, String uuid, Version version) throws SimExplorerException { - MetaData mde; - Permission permission = credentialManager.getPermission(token, uuid); - if (permission.isCanRead()) { - mde = super.getMetadata(token, uuid, version); - } else { - throw new SimExplorerSecurityException(); - } - return mde; + canRead(token, uuid); + return super.getMetadata(token, uuid, version); } /* (non-Javadoc) @@ -154,14 +190,8 @@ */ @Override public MetaData getMetadata(String token, String uuid) throws SimExplorerException { - MetaData mde; - Permission permission = credentialManager.getPermission(token, uuid); - if (permission.isCanRead()) { - mde = super.getMetadata(token, uuid); - } else { - throw new SimExplorerSecurityException(); - } - return mde; + canRead(token, uuid); + return super.getMetadata(token, uuid); } /* (non-Javadoc) @@ -169,14 +199,8 @@ */ @Override public List<Version> getVersions(String token, String uuid) throws SimExplorerException { - List<Version> versions; - Permission permission = credentialManager.getPermission(token, uuid); - if (permission.isCanRead()) { - versions = super.getVersions(token, uuid); - } else { - throw new SimExplorerSecurityException(); - } - return versions; + canRead(token, uuid); + return super.getVersions(token, uuid); } /* (non-Javadoc) @@ -184,21 +208,15 @@ */ @Override public InputStream retrieveData(String token, MetaData entity, Attachment attachment) throws SimExplorerException { - InputStream stream; - Permission permission = credentialManager.getPermission(token, entity.getUuid()); - if (permission.isCanRead()) { - stream = super.retrieveData(token, entity, attachment); - } else { - throw new SimExplorerSecurityException(); - } - return stream; + canRead(token, entity.getUuid()); + return super.retrieveData(token, entity, attachment); } /* (non-Javadoc) * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#canCreateSubVersion(java.lang.String, java.lang.String) */ @Override - public boolean canCreateSubVersion(String token, String uuid) throws SimExplorerException { + public boolean canCreateSubVersion(String token, String uuid) { Permission permission = credentialManager.getPermission(token, uuid); return permission.isCanWrite(); } @@ -209,13 +227,136 @@ @Override public void saveElement(String token, LoggableElement element, Map<Attachment, InputStream> attachments) throws SimExplorerException { - Permission permission = credentialManager.getPermission(token, element.getMetaData().getUuid()); - if (permission.isCanWrite()) { - super.saveElement(token, element, attachments); - credentialManager.saveElement(token, element.getMetaData().getUuid()); - } else { - throw new SimExplorerSecurityException(); - } + canWrite(token, element.getMetaData().getUuid()); + credentialManager.saveElement(token, element.getMetaData().getUuid()); } + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#close() + */ + @Override + public void close() throws SimExplorerException { + // nothing to check + super.close(); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#commit() + */ + @Override + public void commit() throws SimExplorerException { + // nothing to check + super.commit(); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#convertList(java.util.Collection) + */ + @Override + protected MetaData[] convertList(Collection<MetaData> metadatas) { + // nothing to check + return super.convertList(metadatas); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#deleteTempData(java.lang.String) + */ + @Override + public void deleteTempData(String id) throws SimExplorerException { + // nothing to check + super.deleteTempData(id); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#duplicateElementHierarchy(java.lang.String, fr.cemagref.simexplorer.is.entities.metadata.MetaData, fr.cemagref.simexplorer.is.entities.metadata.MetaData) + */ + @Override + public void duplicateElementHierarchy(String token, MetaData fromElement, MetaData toElement) + throws SimExplorerException { + canRead(token, fromElement.getUuid()); + canWrite(token, toElement.getUuid()); + super.duplicateElementHierarchy(token, fromElement, toElement); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#getElementVersions(java.lang.String, java.lang.String) + */ + @Override + public List<MetaData> getElementVersions(String token, String uuid) throws SimExplorerException { + canRead(token, uuid); + return super.getElementVersions(token, uuid); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#getMetadatasUsedBy(java.lang.String, java.lang.String, fr.cemagref.simexplorer.is.entities.metadata.Version) + */ + @Override + public MetaData[] getMetadatasUsedBy(String token, String uuid, Version version) throws SimExplorerException { + canRead(token, uuid); + return super.getMetadatasUsedBy(token, uuid, version); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#getMetadatasUsedBy(java.lang.String, java.lang.String) + */ + @Override + public MetaData[] getMetadatasUsedBy(String token, String uuid) throws SimExplorerException { + canRead(token, uuid); + return super.getMetadatasUsedBy(token, uuid); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#getMetadatasUsing(java.lang.String, java.lang.String, fr.cemagref.simexplorer.is.entities.metadata.Version) + */ + @Override + public MetaData[] getMetadatasUsing(String token, String uuid, Version version) throws SimExplorerException { + canRead(token, uuid); + return super.getMetadatasUsing(token, uuid, version); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#getMetadatasUsing(java.lang.String, java.lang.String) + */ + @Override + public MetaData[] getMetadatasUsing(String token, String uuid) throws SimExplorerException { + canRead(token, uuid); + return super.getMetadatasUsing(token, uuid); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#open() + */ + @Override + public void open() throws SimExplorerException { + // nothing to check + super.open(); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#retrieveTempData(java.lang.String) + */ + @Override + public InputStream retrieveTempData(String id) throws SimExplorerException { + // nothing to check + return super.retrieveTempData(id); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#saveElementHierarchy(java.lang.String, fr.cemagref.simexplorer.is.entities.metadata.MetaData, fr.cemagref.simexplorer.is.entities.metadata.MetaData) + */ + @Override + public void saveElementHierarchy(String token, MetaData parent, MetaData child) throws SimExplorerException { + canWrite(token, parent.getUuid()); + super.saveElementHierarchy(token, parent, child); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.storage.engine.StorageEngineImpl#storeTempData(java.io.InputStream) + */ + @Override + public StreamInfo storeTempData(InputStream stream) throws SimExplorerException { + // nothing to check + return super.storeTempData(stream); + } + }

1 0

r1427 - trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service
by glandais＠users.labs.libre-entreprise.org March 20, 2008

March 20, 2008

Author: glandais Date: 2008-03-20 16:41:08 +0000 (Thu, 20 Mar 2008) New Revision: 1427 Modified: trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/AuthenticationServiceImpl.java Log: Cleanups and comments Modified: trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/AuthenticationServiceImpl.java =================================================================== --- trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/AuthenticationServiceImpl.java 2008-03-20 16:40:26 UTC (rev 1426) +++ trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/AuthenticationServiceImpl.java 2008-03-20 16:41:08 UTC (rev 1427) @@ -289,48 +289,37 @@ * * @param token the token * - * @return true, if successful - * * @throws SimExplorerException the sim explorer exception */ - private boolean canViewElements(String token) throws SimExplorerException { + private void canViewElements(String token) throws SimExplorerException { User loggedUser = getLoggedUser(token); - // boolean canView = loggedUser.isAdmin() || loggedUser.isSuperAdmin(); - // return canView; - return (loggedUser != null); + if (loggedUser == null) { + throw new SimExplorerSecurityException(); + } } /* (non-Javadoc) * @see fr.cemagref.simexplorer.is.service.AuthenticationService#getGroup(java.lang.String, java.lang.Integer) */ public Group getGroup(String token, Integer id) throws SimExplorerException { - if (canViewElements(token)) { - Group group = daoActor.getGroup(id); - return group; - } - throw new SimExplorerSecurityException(); + canViewElements(token); + return daoActor.getGroup(id); } /* (non-Javadoc) * @see fr.cemagref.simexplorer.is.service.AuthenticationService#getGroup(java.lang.String, java.lang.String) */ public Group getGroup(String token, String name) throws SimExplorerException { - if (canViewElements(token)) { - Group group = daoActor.getGroup(name); - return group; - } - throw new SimExplorerSecurityException(); + canViewElements(token); + return daoActor.getGroup(name); } /* (non-Javadoc) * @see fr.cemagref.simexplorer.is.service.AuthenticationService#getUser(java.lang.String, java.lang.Integer) */ public User getUser(String token, Integer id) throws SimExplorerException { - if (canViewElements(token)) { - User user = daoActor.getUser(id); - return user; - } - throw new SimExplorerSecurityException(); + canViewElements(token); + return daoActor.getUser(id); } /* (non-Javadoc) @@ -338,24 +327,36 @@ */ @Override public Actor getActor(String token, Integer id) throws SimExplorerException { - if (canViewElements(token)) { - Actor actor = daoActor.getActor(id); - return actor; - } - throw new SimExplorerSecurityException(); + canViewElements(token); + return daoActor.getActor(id); } /* (non-Javadoc) * @see fr.cemagref.simexplorer.is.service.AuthenticationService#getUser(java.lang.String, java.lang.String) */ public User getUser(String token, String login) throws SimExplorerException { - if (canViewElements(token)) { - User user = daoActor.getUser(login); - return user; - } - throw new SimExplorerSecurityException(); + canViewElements(token); + return daoActor.getUser(login); } + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.service.AuthenticationService#getGroups(java.lang.String) + */ + public Group[] getGroups(String token) throws SimExplorerException { + canViewElements(token); + Collection<Group> groups = daoActor.getGroups(); + return groups.toArray(new Group[groups.size()]); + } + + /* (non-Javadoc) + * @see fr.cemagref.simexplorer.is.service.AuthenticationService#getUsers(java.lang.String) + */ + public User[] getUsers(String token) throws SimExplorerException { + canViewElements(token); + Collection<User> users = daoActor.getUsers(); + return users.toArray(new User[users.size()]); + } + /** * Can save element. * @@ -377,6 +378,7 @@ public Group saveGroup(String token, String name) throws SimExplorerException { if (canSaveElement(token)) { Group oldGroup = daoActor.getGroup(name); + // FIXME visible = false if (oldGroup != null) { throw new SimExplorerBusinessException(_("simexplorer.service.business.groupexist")); } @@ -397,6 +399,7 @@ public User saveUser(String token, String login, String mail) throws SimExplorerException { if (canSaveElement(token)) { User oldUser = daoActor.getUser(login); + // FIXME visible = false if (oldUser != null) { throw new SimExplorerBusinessException(_("simexplorer.service.business.userexist")); } @@ -486,6 +489,7 @@ return null; } User loggedUser; + // FIXME cleanup getLoggedUser loggedUser = daoActor.getLoggedUser(token); if (loggedUser != null) { return loggedUser; @@ -574,28 +578,6 @@ } } - /* (non-Javadoc) - * @see fr.cemagref.simexplorer.is.service.AuthenticationService#getGroups(java.lang.String) - */ - public Group[] getGroups(String token) throws SimExplorerException { - if (canViewElements(token)) { - Collection<Group> groups = daoActor.getGroups(); - return groups.toArray(new Group[groups.size()]); - } - throw new SimExplorerSecurityException(); - } - - /* (non-Javadoc) - * @see fr.cemagref.simexplorer.is.service.AuthenticationService#getUsers(java.lang.String) - */ - public User[] getUsers(String token) throws SimExplorerException { - if (canViewElements(token)) { - Collection<User> users = daoActor.getUsers(); - return users.toArray(new User[users.size()]); - } - throw new SimExplorerSecurityException(); - } - /** * Checks if container contains contained. * @@ -616,7 +598,7 @@ } return false; } - + /** * Can admin permissions. * @@ -671,14 +653,13 @@ return credentialManager.getPermissionsOwnedByCount(user); } -/* - public Object debugQuery(String query, int type) { - return daoActor.debugQuery(query, type); - } -*/ + /* + public Object debugQuery(String query, int type) { + return daoActor.debugQuery(query, type); + } + */ - - { + { I18n.initISO88591("fr", "FR"); } }

1 0

r1426 - trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service
by glandais＠users.labs.libre-entreprise.org March 20, 2008

March 20, 2008

Author: glandais Date: 2008-03-20 16:40:26 +0000 (Thu, 20 Mar 2008) New Revision: 1426 Modified: trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/StorageServiceHelper.java Log: Format Modified: trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/StorageServiceHelper.java =================================================================== --- trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/StorageServiceHelper.java 2008-03-20 16:40:12 UTC (rev 1425) +++ trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/StorageServiceHelper.java 2008-03-20 16:40:26 UTC (rev 1426) @@ -24,10 +24,12 @@ import fr.cemagref.simexplorer.is.entities.data.LoggableElement; import fr.cemagref.simexplorer.is.entities.metadata.MetaData; -import fr.cemagref.simexplorer.is.entities.metadata.Version; import fr.cemagref.simexplorer.is.exceptions.SimExplorerException; import fr.cemagref.simexplorer.is.exceptions.SimExplorerTechnicalException; +/** + * The Class StorageServiceHelper. + */ public class StorageServiceHelper { /** @@ -45,67 +47,64 @@ */ public static MetaData exportElementTo(String token, StorageService fromService, StorageService toService, String uuid, String version) throws SimExplorerException { - + String currentUuid = uuid; String currentVersion = version; - + boolean sameElements; // Remote element LoggableElement toElement; - - do { + do { // Extract element from source service LoggableElement fromElement = fromService.getLoggableElement(token, currentUuid, currentVersion); InputStream fromElementStream = fromService.retrieveElementFull(token, currentUuid, currentVersion); // Store element in remote service try { if (fromElementStream instanceof SerializableInputStream) { - toElement = toService.saveElement(token, - (SerializableInputStream) fromElementStream); + toElement = toService.saveElement(token, (SerializableInputStream) fromElementStream); } else { - toElement = toService.saveElement(token, - new SerializableInputStream(fromElementStream)); + toElement = toService.saveElement(token, new SerializableInputStream(fromElementStream)); } } catch (IOException e) { throw new SimExplorerTechnicalException(e); } - + // Check if remote element is equal to local element sameElements = fromElement.equals(toElement); - + // If not - if (!sameElements) { + if (!sameElements) { // Resave localy remote element - + // Get new remote element - InputStream toElementStream = toService.retrieveElementFull( - token, toElement.getMetaData().getUuid(), toElement - .getMetaData().getVersion().toString()); - + InputStream toElementStream = toService.retrieveElementFull(token, toElement.getMetaData().getUuid(), + toElement.getMetaData().getVersion().toString()); + // Save new remote element try { if (toElementStream instanceof SerializableInputStream) { - fromElement = fromService.saveElement(token, - (SerializableInputStream) toElementStream); + fromElement = fromService.saveElement(token, (SerializableInputStream) toElementStream); } else { - fromElement = fromService.saveElement(token, - new SerializableInputStream(toElementStream)); + fromElement = fromService.saveElement(token, new SerializableInputStream(toElementStream)); } } catch (IOException e) { throw new SimExplorerTechnicalException(e); } - + currentUuid = fromElement.getMetaData().getUuid(); currentVersion = fromElement.getMetaData().getVersion().toString(); } - - } while (!sameElements); + } while (!sameElements); + return toElement.getMetaData(); } + /** + * Instantiates a new storage service helper. + */ protected StorageServiceHelper() { // not instanciable }

1 0

r1425 - trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service
by glandais＠users.labs.libre-entreprise.org March 20, 2008

March 20, 2008

Author: glandais Date: 2008-03-20 16:40:12 +0000 (Thu, 20 Mar 2008) New Revision: 1425 Modified: trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/AuthenticationService.java Log: Format Modified: trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/AuthenticationService.java =================================================================== --- trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/AuthenticationService.java 2008-03-20 16:38:30 UTC (rev 1424) +++ trunk/simexplorer-is/simexplorer-is-service/src/java/fr/cemagref/simexplorer/is/service/AuthenticationService.java 2008-03-20 16:40:12 UTC (rev 1425) @@ -82,12 +82,19 @@ * @param token the token * @param id the id * - * @return the user - * * @throws SimExplorerException the sim explorer service exception */ - // public void changePassword(String token, String password) - // throws SimExplorerException; + // public void changePassword(String token, String password) throws SimExplorerException; + /** + * Gets the actor. + * + * @param token the token + * @param id the id + * + * @return the actor + * + * @throws SimExplorerException the sim explorer exception + */ public Actor getActor(String token, Integer id) throws SimExplorerException; /** @@ -217,8 +224,7 @@ public Group[] getGroups(String token) throws SimExplorerException; /** - * Gets the logged user. - * Throws SimExplorerException if token is invalid (ie not logged) + * Gets the logged user. Throws SimExplorerException if token is invalid (ie not logged) * * @param token the token * @@ -273,6 +279,6 @@ */ public void setPermissions(String token, String uuid, Permission[] permissions) throws SimExplorerException; -// public Object debugQuery(String query, int type); - + // public Object debugQuery(String query, int type); + }

1 0

r1424 - trunk/simexplorer-is/simexplorer-is-security/src/java/fr/cemagref/simexplorer/is/security/dao
by glandais＠users.labs.libre-entreprise.org March 20, 2008

March 20, 2008

Author: glandais Date: 2008-03-20 16:38:30 +0000 (Thu, 20 Mar 2008) New Revision: 1424 Modified: trunk/simexplorer-is/simexplorer-is-security/src/java/fr/cemagref/simexplorer/is/security/dao/DaoActorImpl.java Log: Comment on possible NPE Modified: trunk/simexplorer-is/simexplorer-is-security/src/java/fr/cemagref/simexplorer/is/security/dao/DaoActorImpl.java =================================================================== --- trunk/simexplorer-is/simexplorer-is-security/src/java/fr/cemagref/simexplorer/is/security/dao/DaoActorImpl.java 2008-03-20 16:38:10 UTC (rev 1423) +++ trunk/simexplorer-is/simexplorer-is-security/src/java/fr/cemagref/simexplorer/is/security/dao/DaoActorImpl.java 2008-03-20 16:38:30 UTC (rev 1424) @@ -190,6 +190,7 @@ loginAction.setLoginDate((new Date()).getTime()); em.merge(loginAction); } + // TODO avoid NPE return loggedUser; }

1 0