Repackage to org.cristalise

1 files changed, 0 insertions, 176 deletions

diff --git a/src/main/java/com/c2kernel/entity/transfer/TransferItem.java b/src/main/java/com/c2kernel/entity/transfer/TransferItem.java
deleted file mode 100644
index 0e8123b..0000000
--- a/src/main/java/com/c2kernel/entity/transfer/TransferItem.java
+++ /dev/null
@@ -1,176 +0,0 @@
-/**

- * 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.entity.transfer;

-

-import java.io.File;

-import java.util.ArrayList;

-import java.util.Iterator;

-

-import com.c2kernel.collection.Collection;

-import com.c2kernel.collection.CollectionArrayList;

-import com.c2kernel.common.ObjectNotFoundException;

-import com.c2kernel.entity.C2KLocalObject;

-import com.c2kernel.entity.TraceableEntity;

-import com.c2kernel.lifecycle.instance.Workflow;

-import com.c2kernel.lookup.AgentPath;

-import com.c2kernel.lookup.DomainPath;

-import com.c2kernel.lookup.InvalidItemPathException;

-import com.c2kernel.lookup.ItemPath;

-import com.c2kernel.lookup.Path;

-import com.c2kernel.persistency.ClusterStorage;

-import com.c2kernel.persistency.outcome.Outcome;

-import com.c2kernel.process.Gateway;

-import com.c2kernel.property.Property;

-import com.c2kernel.property.PropertyArrayList;

-import com.c2kernel.utils.FileStringUtility;

-import com.c2kernel.utils.Logger;

-

-public class TransferItem {

-    private ArrayList<String> domainPaths;

-    protected ItemPath itemPath;

-    static AgentPath importAgentId;

-

-    public TransferItem() throws Exception {

-        try {

-            importAgentId = Gateway.getLookup().getAgentPath("system");

-        } catch (ObjectNotFoundException e) {

-            Logger.error("TransferItem - System user not found!");

-            throw e;

-        }

-    }

-

-    public TransferItem(ItemPath itemPath) throws Exception {

-        this.itemPath = itemPath;

-        domainPaths = new ArrayList<String>();

-        Iterator<Path> paths = Gateway.getLookup().searchAliases(itemPath);

-        while (paths.hasNext()) {

-            DomainPath thisPath = (DomainPath)paths.next();

-            domainPaths.add(thisPath.toString());

-        }

-    }

-    

-    public ArrayList<String> getDomainPaths() {

-		return domainPaths;

-	}

-

-	public void setDomainPaths(ArrayList<String> domainPaths) {

-		this.domainPaths = domainPaths;

-	}

-

-	public void setUUID( String uuid ) throws InvalidItemPathException

-    {

-    	itemPath = new ItemPath(uuid);

-    }

-    

-    public String getUUID() {

-    	return itemPath.getUUID().toString();

-    }

-    

-    public void exportItem(File dir, String path) throws Exception {

-        Logger.msg("Path " + path + " in " + itemPath);

-        String[] contents = Gateway.getStorage().getClusterContents(itemPath, path);

-        if (contents.length > 0) {

-            FileStringUtility.createNewDir(dir.getCanonicalPath());

-            for (String content : contents) {

-                exportItem(new File(dir, content), path + "/" + content);

-            }

-        } else { //no children, try to dump object

-            try {

-                C2KLocalObject obj = Gateway.getStorage().get(itemPath, path, null);

-                Logger.msg("Dumping object " + path + " in " + itemPath);

-                File dumpPath = new File(dir.getCanonicalPath() + ".xml");

-                FileStringUtility.string2File(dumpPath, Gateway.getMarshaller().marshall(obj));

-                return;

-            } catch (ObjectNotFoundException ex) {

-            } // not an object

-        }

-    }

-

-    public void importItem(File dir) throws Exception {

-        // check if already exists

-        try {

-            Property name = (Property)Gateway.getStorage().get(itemPath, ClusterStorage.PROPERTY + "/Name", null);

-            throw new Exception("Entity " + itemPath + " already in use as " + name.getValue());

-        } catch (Exception ex) {

-        }

-

-        // retrieve objects

-        ArrayList<String> objectFiles = FileStringUtility.listDir(dir.getCanonicalPath(), false, true);

-        ArrayList<C2KLocalObject> objects = new ArrayList<C2KLocalObject>();

-        for (String element : objectFiles) {

-            String xmlFile = FileStringUtility.file2String(element);

-            C2KLocalObject newObj;

-            String choppedPath = element.substring(dir.getCanonicalPath().length()+1, element.length()-4);

-            Logger.msg(choppedPath);

-            if (choppedPath.startsWith(ClusterStorage.OUTCOME))

-                newObj = new Outcome(choppedPath, xmlFile);

-            else

-                newObj = (C2KLocalObject)Gateway.getMarshaller().unmarshall(xmlFile);

-

-            objects.add(newObj);

-        }

-

-        // create item

-        TraceableEntity newItem = Gateway.getCorbaServer().createItem(itemPath);

-        Gateway.getLookupManager().add(itemPath);

-

-        PropertyArrayList props = new PropertyArrayList();

-        CollectionArrayList colls = new CollectionArrayList();

-        Workflow wf = null;

-        // put objects

-        for (C2KLocalObject obj : objects) {

-            if (obj instanceof Property)

-                props.list.add((Property)obj);

-            else if (obj instanceof Collection)

-            	colls.list.add((Collection<?>)obj);

-            else if (obj instanceof Workflow)

-                wf = (Workflow)obj;

-        }

-

-        if (wf == null)

-            throw new Exception("No workflow found in import for "+itemPath);

-

-        // init item

-        newItem.initialise(importAgentId.getSystemKey(), 

-        		Gateway.getMarshaller().marshall(props), 

-        		Gateway.getMarshaller().marshall(wf.search("workflow/domain")),

-        		Gateway.getMarshaller().marshall(colls));

-

-        // store objects

-        importByType(ClusterStorage.HISTORY, objects);

-        importByType(ClusterStorage.OUTCOME, objects);

-        importByType(ClusterStorage.VIEWPOINT, objects);

-        Gateway.getStorage().commit(this);

-        // add domPaths

-        for (String element : domainPaths) {

-            DomainPath newPath = new DomainPath(element, itemPath);

-            Gateway.getLookupManager().add(newPath);

-        }

-    }

-

-    private void importByType(String type, ArrayList<C2KLocalObject> objects) throws Exception {

-        for (C2KLocalObject element : objects) {

-            if (element.getClusterType().equals(type))

-                Gateway.getStorage().put(itemPath, element, this);

-        }

-

-    }

-}
\ No newline at end of file