PEP on output stream

[michael-conway]

If you use the method, IRODSFileFactory.instanceIRODSFileOutputStream(file, DataObjInp.OpenFlags.WRITE_TRUNCATE), the acPostProcOnPut rule isn't fired.

via tony

[michael-conway]

seems to work here...

ref IRODSFileOutputStreamTest in jargon

core.re

acPostProcForPut {writeLine("serverLog","Post Proc! ---  File Path is "++$filePath);}

@Test
    public final void testIRODSFileOutputStreamOverwrite() throws Exception {
        String testFileName = "testIRODSFileOutputStreamOverwrite.txt";
        String string1 = "jfaijfjasidjfaisehfuaehfahfhudhfuashfuasfdhaisdfhaisdhfiaf";
        String string2 = "nvmzncvzmvnzx,mcv";
        String absPath = scratchFileUtils
                .createAndReturnAbsoluteScratchPath(IRODS_TEST_SUBDIR_PATH);
        String localFilePath = FileGenerator
                .generateFileOfFixedLengthGivenName(absPath, testFileName, 8);

        new File(localFilePath);
        String targetIrodsCollection = testingPropertiesHelper
                .buildIRODSCollectionAbsolutePathFromTestProperties(
                        testingProperties, IRODS_TEST_SUBDIR_PATH);

        IRODSAccount irodsAccount = testingPropertiesHelper
                .buildIRODSAccountFromTestProperties(testingProperties);

        IRODSAccessObjectFactory accessObjectFactory = irodsFileSystem
                .getIRODSAccessObjectFactory();
        IRODSFileFactory irodsFileFactory = accessObjectFactory
                .getIRODSFileFactory(irodsAccount);
        IRODSFile irodsFile = irodsFileFactory
                .instanceIRODSFile(targetIrodsCollection + '/' + testFileName);

        IRODSFileOutputStream irodsFileOutputStream = irodsFileFactory
                .instanceIRODSFileOutputStream(irodsFile);

        irodsFileOutputStream.write(string1.getBytes());
        irodsFileOutputStream.close();
        irodsFileOutputStream = irodsFileFactory.instanceIRODSFileOutputStream(
                irodsFile, OpenFlags.WRITE_TRUNCATE);

        irodsFileOutputStream.write(string2.getBytes());
        irodsFileOutputStream.close();

        IRODSFileInputStream irodsFileInputStream = irodsFileFactory
                .instanceIRODSFileInputStream(irodsFile);
        String actual = MiscIRODSUtils
                .convertStreamToString(irodsFileInputStream);
        irodsFileInputStream.close();

        Assert.assertEquals("should be second string", string2, actual);

    }

in test, these lines:

IRODSFileOutputStream irodsFileOutputStream = irodsFileFactory
                .instanceIRODSFileOutputStream(irodsFile);

        irodsFileOutputStream.write(string1.getBytes());
        irodsFileOutputStream.close();

yield

Aug 25 14:34:34 pid:9226 NOTICE: Agent process 9618 started for puser=test1 and cuser=test1 from 127.0.0.1
Aug 25 14:34:37 pid:9618 NOTICE: writeLine: inString = Post Proc! ---  File Path is /var/lib/irods/iRODS/Vault1/home/test1/jargon-scratch/IRODSFileOutputStreamTest/testIRODSFileOutputStreamOverwrite.txt

Then these subsequent lines

irodsFileOutputStream = irodsFileFactory.instanceIRODSFileOutputStream(
                irodsFile, OpenFlags.WRITE_TRUNCATE);

        irodsFileOutputStream.write(string2.getBytes());
        irodsFileOutputStream.close();

again yield

Aug 25 14:34:46 pid:9618 NOTICE: writeLine: inString = Post Proc! ---  File Path is /var/lib/irods/iRODS/Vault1/home/test1/jargon-scratch/IRODSFileOutputStreamTest/testIRODSFileOutputStreamOverwrite.txt

[tedgin]

If verified that if the file exists before the output stream is opened with WRITE_TRUNCATE flag, the acPostProcForPut rule will be called when the output stream is closed. If the file doesn't exist, the rule will not be called.

[michael-conway]

thanks! I'm on it.

[michael-conway]

this is linked to #146.

[michael-conway]

retest with 4.1.6 before release