From 275d0bbf555c8917be82ce4cc21eb4cabb00f4c5 Mon Sep 17 00:00:00 2001
From: Andrew Branson <andrew.branson@cern.ch>
Date: Fri, 3 Oct 2014 17:30:41 +0200
Subject: Huge exception overhaul: Merged ClusterStorageException with
 PersistencyException. Replaced MembershipException with
 InvalidCollectionModification CORBA Exception. Made all predef steps throw
 more accurate exceptions when they go wrong, and let more exceptions bubble
 through from underneath.

---
 .../predefined/AddNewCollectionDescription.java    | 109 +++++++++++++++++++++
 1 file changed, 109 insertions(+)
 create mode 100644 src/main/java/com/c2kernel/lifecycle/instance/predefined/AddNewCollectionDescription.java

(limited to 'src/main/java/com/c2kernel/lifecycle/instance/predefined/AddNewCollectionDescription.java')

diff --git a/src/main/java/com/c2kernel/lifecycle/instance/predefined/AddNewCollectionDescription.java b/src/main/java/com/c2kernel/lifecycle/instance/predefined/AddNewCollectionDescription.java
new file mode 100644
index 0000000..6eb69f3
--- /dev/null
+++ b/src/main/java/com/c2kernel/lifecycle/instance/predefined/AddNewCollectionDescription.java
@@ -0,0 +1,109 @@
+/**
+ * This file is part of the CRISTAL-iSE kernel.
+ * Copyright (c) 2001-2014 The CRISTAL Consortium. All rights reserved.
+ *
+ * This library is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as published
+ * by the Free Software Foundation; either version 3 of the License, or (at
+ * your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; with out even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
+ * License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this library; if not, write to the Free Software Foundation,
+ * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
+ *
+ * http://www.fsf.org/licensing/licenses/lgpl.html
+ */
+package com.c2kernel.lifecycle.instance.predefined;
+
+
+import java.util.Arrays;
+
+import com.c2kernel.collection.AggregationDescription;
+import com.c2kernel.collection.CollectionDescription;
+import com.c2kernel.collection.DependencyDescription;
+import com.c2kernel.common.InvalidData;
+import com.c2kernel.common.ObjectAlreadyExists;
+import com.c2kernel.common.ObjectNotFound;
+import com.c2kernel.common.PersistencyException;
+import com.c2kernel.lookup.AgentPath;
+import com.c2kernel.lookup.ItemPath;
+import com.c2kernel.persistency.ClusterStorage;
+import com.c2kernel.process.Gateway;
+import com.c2kernel.utils.Logger;
+
+/**************************************************************************
+ *
+ * @author $Author: abranson $ $Date: 2004/10/21 08:02:19 $
+ * @version $Revision: 1.8 $
+ **************************************************************************/
+public class AddNewCollectionDescription extends PredefinedStep
+{
+    /**************************************************************************
+    * Constructor for Castor
+    **************************************************************************/
+    public AddNewCollectionDescription()
+    {
+        super();
+    }
+
+
+    /**
+     * Generates a new empty collection description. Collection instances should
+     * be added by an Admin, who can do so using AddC2KObject.
+     * 
+     * Params:
+     * 0 - collection name
+     * 1 - collection type (Aggregation, Dependency)
+     * @throws PersistencyException 
+     */
+    @Override
+	protected String runActivityLogic(AgentPath agent, ItemPath item,
+			int transitionID, String requestData) throws InvalidData, ObjectAlreadyExists, PersistencyException {
+    	
+        String collName;
+        String collType;
+
+        // extract parameters
+        String[] params = getDataList(requestData);
+        if (Logger.doLog(3)) Logger.msg(3, "AddNewCollectionDescription: called by "+agent+" on "+item+" with parameters "+Arrays.toString(params));
+        if (params.length != 2)
+        	throw new InvalidData("AddNewCollectionDescription: Invalid parameters "+Arrays.toString(params));
+
+        collName = params[0];
+        collType = params[1];
+
+        // check if collection already exists
+		try {
+			Gateway.getStorage().get(item, ClusterStorage.COLLECTION+"/"+collName+"/last", null);
+			throw new ObjectAlreadyExists("Collection '"+collName+"' already exists");
+		} catch (ObjectNotFound ex) {
+			// collection doesn't exist
+		} catch (PersistencyException ex) {
+			Logger.error(ex);
+			throw new PersistencyException("AddNewCollectionDescription: Error checking for collection '"+collName+"': "+ex.getMessage());
+		}
+        
+        
+        CollectionDescription<?> newCollDesc;
+        
+        if (collType.equals("Aggregation"))
+        	newCollDesc = new AggregationDescription(collName);
+        if (collType.equals("Dependency"))
+        	newCollDesc = new DependencyDescription(collName);
+        else
+        	throw new InvalidData("AddNewCollectionDescription: Invalid collection type specified: '"+collType+"'. Must be Aggregation or Dependency.");
+        
+        // store it
+		try {
+            Gateway.getStorage().put(item, newCollDesc, null);
+        } catch (PersistencyException e) {
+        	throw new PersistencyException("AddNewCollectionDescription: Error saving new collection '"+collName+"': "+e.getMessage());
+        }
+        return requestData;
+    }
+}
-- 
cgit v1.2.3