*/
package org.vamsas.client.simpleclient;
+import java.io.BufferedOutputStream;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataInput;
import java.io.DataInputStream;
import java.io.DataOutput;
+import java.io.DataOutputStream;
import java.io.InputStream;
import java.util.Vector;
+import java.util.jar.JarEntry;
import java.util.jar.JarInputStream;
+import java.util.jar.JarOutputStream;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
*/
protected boolean accessedDocument = false;
/**
- * has the user datablock been modified ?
+ * has the user datablock been modified ?
+ * temporary file containing new user specific application data chunk
*/
- protected boolean modifiedUserData = false;
+ SessionFile newUserData=null;
+ JarOutputStream newUserDataStream = null;
/**
* has the apps global datablock been modified ?
+ * temporary file containing new global application data chunk
*/
- protected boolean modifiedAppData = false;
-
+ SessionFile newAppData=null;
+ JarOutputStream newAppDataStream=null;
ClientDocument clientdoc;
/**
* state flags
AppData clientdat = (AppData) apldataset.get(0);
if (clientdat instanceof ApplicationData) {
appsGlobal = (ApplicationData) clientdat;
- modifiedAppData = false;
if (apldataset.size()>1) {
clientdat = (AppData) apldataset.get(1);
if (clientdat instanceof User) {
usersData = (User) clientdat;
- modifiedUserData = false;
}
if (apldataset.size()>2)
log.info("Ignoring additional ("+(apldataset.size()-2)+") AppDatas returned by document appdata query.");
appdName = "User's Appdata";
}
log.debug("getting "+appdName+" as a byte array");
- extractAppData(clientdoc.getVamsasDocument());// TODO: get VamsasArchiveReader from sclient
+ extractAppData(clientdoc.getVamsasDocument());
AppData object;
if (!clientOrUser) {
object = appsGlobal;
/**
* methods for writing new AppData entries.
*/
-
+ private DataOutput _getAppdataOutputStream(boolean clientOrUser) {
+ String apdname;
+ SessionFile apdfile=null;
+ if (!clientOrUser) {
+ apdname = "clientAppData";
+ apdfile = newAppData;
+ } else {
+ apdname = "userAppData";
+ apdfile = newUserData;
+ }
+ try {
+ if (apdfile==null) {
+ apdfile=clientdoc.sclient._session.getTempSessionFile(apdname,".jar");
+ log.debug("Successfully made temp appData file for "+apdname);
+ } else {
+ // truncate to remove existing data.
+ apdfile.fileLock.rafile.setLength(0);
+ log.debug("Successfully truncated existing temp appData for "+apdname);
+ }
+ } catch (Exception e) {
+ log.error("Whilst opening temp file in directory "+clientdoc.sclient._session.sessionDir, e);
+ }
+ // we do not make another file for the new entry if one exists already
+ if (!clientOrUser) {
+ newAppData = apdfile;
+ } else {
+ newUserData = apdfile;
+ }
+ try {
+ apdfile.lockFile();
+ JarOutputStream dstrm =
+ new JarOutputStream(
+ new BufferedOutputStream(new java.io.FileOutputStream(apdfile.sessionFile)));
+ if (!clientOrUser) {
+ newAppDataStream = dstrm;
+ } else {
+ newUserDataStream = dstrm;
+ }
+ dstrm.putNextEntry(new JarEntry("appData_entry.dat"));
+ // LATER: there may be trouble ahead if an AppDataOutputStream is written to by one thread when another truncates the file. This situation should be prevented if possible
+ return new AppDataOutputStream(dstrm);
+ }
+ catch (Exception e) {
+ log.error("Whilst opening jar output stream for file "+apdfile.sessionFile);
+ }
+ // tidy up and return null
+ apdfile.unlockFile();
+ return null;
+ }
/* (non-Javadoc)
* @see org.vamsas.client.IClientAppdata#getClientOutputStream()
*/
public DataOutput getClientOutputStream() {
if (clientdoc==null)
throw new Error("Implementation error, Improperly initialized SimpleClientAppdata.");
- // TODO Auto-generated method stub
- return null;
+ if (log.isDebugEnabled())
+ log.debug("trying to getClientOutputStream for "+clientdoc.sclient.client.getClientUrn());
+ return _getAppdataOutputStream(false);
}
/* (non-Javadoc)
public DataOutput getUserOutputStream() {
if (clientdoc==null)
throw new Error("Implementation error, Improperly initialized SimpleClientAppdata.");
- // TODO Auto-generated method stub
- return null;
+ if (log.isDebugEnabled())
+ log.debug("trying to getUserOutputStream for ("
+ +clientdoc.sclient.getUserHandle().getFullName()+")"+clientdoc.sclient.client.getClientUrn());
+ return _getAppdataOutputStream(true);
}
/* (non-Javadoc)
public boolean hasClientAppdata() {
if (clientdoc==null)
throw new Error("Implementation error, Improperly initialized SimpleClientAppdata.");
- // TODO Auto-generated method stub
+ extractAppData(clientdoc.getVamsasDocument());
+ // LATER - check validity of a DataReference before we return true
+ if ((appsGlobal!=null) && (appsGlobal.getDataReference()!=null || appsGlobal.getData()!=null))
+ return true;
return false;
}
public boolean hasUserAppdata() {
if (clientdoc==null)
throw new Error("Implementation error, Improperly initialized SimpleClientAppdata.");
- // TODO Auto-generated method stub
+ extractAppData(clientdoc.getVamsasDocument());
+ // LATER - check validity of a DataReference before we return true
+ if ((appsGlobal!=null) && (appsGlobal.getDataReference()!=null || appsGlobal.getData()!=null))
+ return true;
+ return false;
+ }
+ private boolean _writeAppDataStream(JarOutputStream ostrm, byte[] data) {
+ try {
+ if (data!=null && data.length>0)
+ ostrm.write(data);
+ ostrm.closeEntry();
+ return true;
+ }
+ catch (Exception e) {
+ log.error("Serious! - IO error when writing AppDataStream to file "+newAppData.sessionFile, e);
+ }
return false;
}
-
/* (non-Javadoc)
* @see org.vamsas.client.IClientAppdata#setClientAppdata(byte[])
*/
public void setClientAppdata(byte[] data) {
if (clientdoc==null)
throw new Error("Implementation error, Improperly initialized SimpleClientAppdata.");
- // TODO Auto-generated method stub
-
+ _getAppdataOutputStream(false);
+ if (newAppDataStream==null) {
+ // LATER: define an exception for this ? - operation may fail even if file i/o not involved
+ log.error("Serious! - couldn't open new AppDataStream in session directory "+clientdoc.sclient._session.sessionDir);
+ } else {
+ _writeAppDataStream(newAppDataStream, data);
+ // LATER: deal with error case - do we make session read only, or what ?
+ }
}
/* (non-Javadoc)
public void setUserAppdata(byte[] data) {
if (clientdoc==null)
throw new Error("Implementation error, Improperly initialized SimpleClientAppdata.");
- // TODO Auto-generated method stub
-
+ _getAppdataOutputStream(true);
+ if (newUserDataStream==null) {
+ // LATER: define an exception for this ? - operation may fail even if file i/o not involved
+ log.error("Serious! - couldn't open new UserDataStream in session directory "+clientdoc.sclient._session.sessionDir);
+ } else {
+ _writeAppDataStream(newUserDataStream, data);
+ // LATER: deal with error case - do we make session read only, or what ?
+ }
}
/* (non-Javadoc)
* @see java.lang.Object#finalize()
*/
protected void finalize() throws Throwable {
- // TODO Auto-generated method stub
+ if (newAppDataStream!=null) {
+ newAppDataStream = null;
+ }
+ if (newAppDataStream!=null) {
+ newUserDataStream = null;
+ }
+ if (newAppData!=null) {
+ newAppData.eraseExistence();
+ newAppData = null;
+ }
+ if (newUserData!=null) {
+ newUserData.eraseExistence();
+ newUserData = null;
+ }
super.finalize();
}
git://source.jalview.org / vamsas.git / commitdiff