SAP PI UDF to unzip attachment

Business requirement is like:

• While triggering SAP-PI’s SOAP web-service from client system, zip attachments will be send along with SOAP Request Payload. Here, please note, one zip per web-service call is in scope.
• This zip attachments has multiple CSV files, which needs to be extracted in SAP’s application directory
• Once unzip is successful, return unzipped zip-File in SOAP-Response Message

To accomplish above business requirements, one Java UDF will be written in Request Message Mapping of SAP-PI’s respective (SOAP-to-File Synchronous Inbound) interface

Here, given example of SAP PI Java UDF (user defined function), has below functionalities:

• To read zip attachment from Request Payload
• Unzip attachment to one SAP application server directory
• Using Dynamic-configuration, return unzipped zip file name

UDF Imports:

• java.util.zip.*

  java.io.ByteArrayInputStream

public String UnZip(String upzipPath, Container container)
 throws StreamTransformationException{

/*
UDF to:
            1. Get ZipFile Attachment (i.e. get the input attachment from the source message)
            2. Unzip/extract ZipFile to SAP-Application directory
            3. Set unzipped attachment name to "FileName" variable using 'DynamicConfiguration'
*/

//File destDir = new File("/folde1/folde2/folde3/"); 
File destDir = new File(upzipPath); 
String resultStr = "";

//To add trace info
AbstractTrace trace;
trace = container.getTrace();
trace.addInfo("UDF to unzip ZipFile atatchment to the directory " + destDir );

//Get the input attachment from the source message)
GlobalContainer  globalContainer    = container.getGlobalContainer();
InputAttachments inputAttachments = globalContainer.getInputAttachments();
try
{
 //checks for the availability of attachments in the input message
 if(inputAttachments.areAttachmentsAvailable()){
 trace.addInfo("Attachments Available");
												 
 //Get the attachmentIds and store it in an Object array
 Collection<String> CollectionIDs = inputAttachments.getAllContentIds(true);
 Object[] arrayObj = CollectionIDs.toArray();
                  											
 String attachmentID = null;													
 String contentIDS = "";
												 
 //Loops at the input attachments to get the content of the attachment
 for(int i =0;i<arrayObj.length;i++){
  attachmentID =(String)arrayObj[i];   																				  
  resultStr = 	attachmentID;        //Get ZipAttachment Name

  //==============================================
  Attachment attachment = inputAttachments.getAttachment(attachmentID);      
  ZipInputStream zipIs = new ZipInputStream(new ByteArrayInputStream(attachment.getContent()));
  ZipEntry zEntry = null;
  try {
   while ((zEntry = zipIs.getNextEntry()) != null) {							
    // Write each file into directory -------------------------------
    trace.addInfo("zipFile content: " + zEntry.getName());  // Get each Zip content names		

    File destFile = new File(destDir, zEntry.getName());
    FileOutputStream fos = new FileOutputStream(destFile); // It creates blank file in dir
    OutputStream output = new BufferedOutputStream(fos);
    int len;
    byte[] buffer = new byte[2048];
    while ((len = zipIs.read(buffer)) > 0) {
     output.write(buffer, 0, len);
    }
    output.flush();
    output.close();
    // End of Write each file into directory ------------------------
   }
   zipIs.close();
  } catch (FileNotFoundException e) {
      //e.printStackTrace();
      trace.addInfo(" UnZip UDF Error: " +  e.getMessage());
  } catch (IOException e) {
      //e.printStackTrace();
      trace.addInfo(" UnZip UDF Error: " +  e.getMessage());
  }
  //=============================================
 }
 }          
}
catch (Exception e)
{
  //e.printStackTrace();
  trace.addInfo(" UnZip UDF Error: " +  e.getMessage());
}

//=====================================================================
//Return original name of unzipped attachment (zipFile name)
try
{
DynamicConfiguration conf = (DynamicConfiguration) container.getTransformationParameters().get(StreamTransformationConstants.DYNAMIC_CONFIGURATION);
DynamicConfigurationKey key = DynamicConfigurationKey.create("http://sap.com/xi/XI/System/File","FileName");
conf.put(key, resultStr);
}
catch (Exception e)
{
   //e.getMessage();
   trace.addInfo(" StoreAttachment UDF Error: " +  e.getMessage());
}
//=====================================================================
return   resultStr;
}//end of fn UnZip