From 254ee6f47eebfc00462c10756a92066e82cc1a96 Mon Sep 17 00:00:00 2001
From: Andrew Branson <andrew@andrewbranson.net>
Date: Tue, 21 Jun 2011 15:46:02 +0200
Subject: Initial commit

---
 .../c2kernel/persistency/LDAPClusterStorage.java   | 163 +++++++++++++++++++++
 1 file changed, 163 insertions(+)
 create mode 100755 source/com/c2kernel/persistency/LDAPClusterStorage.java

(limited to 'source/com/c2kernel/persistency/LDAPClusterStorage.java')

diff --git a/source/com/c2kernel/persistency/LDAPClusterStorage.java b/source/com/c2kernel/persistency/LDAPClusterStorage.java
new file mode 100755
index 0000000..8e159e0
--- /dev/null
+++ b/source/com/c2kernel/persistency/LDAPClusterStorage.java
@@ -0,0 +1,163 @@
+package com.c2kernel.persistency;
+import java.util.ArrayList;
+import java.util.StringTokenizer;
+
+import com.c2kernel.common.ObjectNotFoundException;
+import com.c2kernel.entity.C2KLocalObject;
+import com.c2kernel.lookup.EntityPath;
+import com.c2kernel.lookup.InvalidEntityPathException;
+import com.c2kernel.lookup.LDAPPropertyManager;
+import com.c2kernel.process.Gateway;
+import com.c2kernel.property.Property;
+import com.c2kernel.utils.Logger;
+
+public class LDAPClusterStorage extends ClusterStorage {
+    LDAPPropertyManager ldapStore;
+
+    public void open() throws ClusterStorageException {
+	    ldapStore = Gateway.getLDAPLookup().getPropManager();
+
+    }
+
+    public void close() throws ClusterStorageException {
+    }
+
+    // introspection
+    public short queryClusterSupport(String clusterType) {
+        if (clusterType.equals(PROPERTY))
+            return READWRITE;
+        else
+            return NONE;
+    }
+
+    public String getName() {
+        return "LDAP Cluster Storage";
+    }
+    
+    public String getId() {
+        return "LDAP";
+    }
+
+    // retrieve object by path
+    public C2KLocalObject get(Integer sysKey, String path) throws ClusterStorageException {
+    	Logger.msg(6, "LDAPClusterStorage.get() - "+sysKey+"/"+path);
+		StringTokenizer tok = new StringTokenizer(path, "/");
+		int pathLength = tok.countTokens();
+		if (pathLength != 2)
+			throw new ClusterStorageException("Path length was invalid: "+path);
+		String type = tok.nextToken();
+
+		EntityPath thisEntity;
+		try {
+			thisEntity = new EntityPath(sysKey.intValue());
+		} catch (InvalidEntityPathException e) {
+			throw new ClusterStorageException("Invalid Syskey:"+sysKey);
+		}
+
+		String objName = tok.nextToken();
+		C2KLocalObject newObj;
+
+		if (type.equals(PROPERTY)) {
+            try {
+                String value = ldapStore.getPropertyValue(thisEntity, objName);
+    		    Property newProperty = new Property();
+    		    newProperty.setName(objName);
+    		    newProperty.setValue(value);
+                newObj = newProperty;
+            } catch (ObjectNotFoundException ex) {
+                throw new ClusterStorageException("Property "+objName+" not found in "+sysKey);
+            }
+
+		}
+		else
+			throw new ClusterStorageException("Cluster type "+type+" not supported.");
+
+		return newObj;
+    }
+    // store object by path
+    public void put(Integer sysKey, C2KLocalObject obj) throws ClusterStorageException {
+    	Logger.msg(6, "LDAPClusterStorage.put() - "+sysKey+"/"+ClusterStorage.getPath(obj));
+
+		String type = obj.getClusterType();
+
+		EntityPath thisEntity;
+		try {
+			thisEntity = new EntityPath(sysKey.intValue());
+		} catch (InvalidEntityPathException e) {
+			throw new ClusterStorageException("Invalid Syskey:"+sysKey);
+		}
+
+		if (type.equals(PROPERTY)) {
+			try {
+                ldapStore.setProperty(thisEntity, (Property)obj);
+            } catch (Exception e1) {
+                Logger.error(e1);
+                throw new ClusterStorageException("LDAPClusterStorage - could not write property");
+            }
+		}
+		else
+			throw new ClusterStorageException("Cluster type "+type+" not supported.");
+
+    }
+    // delete cluster
+    public void delete(Integer sysKey, String path) throws ClusterStorageException {
+		StringTokenizer tok = new StringTokenizer(path, "/");
+		int pathLength = tok.countTokens();
+		if (pathLength != 2)
+			throw new ClusterStorageException("Path length was invalid: "+path);
+		String type = tok.nextToken();
+
+		EntityPath thisEntity;
+		try {
+			thisEntity = new EntityPath(sysKey.intValue());
+		} catch (InvalidEntityPathException e) {
+			throw new ClusterStorageException("Invalid Syskey:"+sysKey);
+		}
+
+		if (type.equals(PROPERTY)) {
+			try {
+                ldapStore.deleteProperty(thisEntity, tok.nextToken());
+            } catch (Exception e1) {
+                Logger.error(e1);
+                throw new ClusterStorageException("LDAPClusterStorage - could not delete property");
+            }    
+		}
+		else
+			throw new ClusterStorageException("Cluster type "+type+" not supported.");
+
+    }
+
+    /* navigation */
+
+    // directory listing
+    public String[] getClusterContents(Integer sysKey, String path) throws ClusterStorageException {
+    	Logger.msg(6, "LDAPClusterStorage.getClusterContents() - "+sysKey+"/"+path);
+        StringTokenizer tok = new StringTokenizer(path, "/");
+        int pathLength = tok.countTokens();
+        if (pathLength > 1)
+            return new String[0];
+            
+        String type = getClusterType(path);
+        try 
+        {
+        	EntityPath thisEntity = new EntityPath(sysKey.intValue());
+         if (type.equals(PROPERTY))
+        	return ldapStore.getPropertyNames(thisEntity);
+       	 else 
+       	 if (type.equals("")) { // root query
+       	 	String[] allClusters = new String[0];
+       	 	ArrayList clusterList = new ArrayList();
+   	 		if (ldapStore.hasProperties(thisEntity))
+   	 			clusterList.add(PROPERTY);
+   	 		allClusters = (String[])clusterList.toArray(allClusters);
+       	 	return allClusters;
+       	 }
+       	 else
+       	 	throw new ClusterStorageException("Cluster type "+type+" not supported.");
+        } catch (InvalidEntityPathException e) {
+			throw new ClusterStorageException("Invalid Syskey:"+sysKey);
+		} catch (ObjectNotFoundException e) {
+            throw new ClusterStorageException("Entity "+sysKey+" does not exist");
+        }
+    }
+}
-- 
cgit v1.2.3