/*
 * Copyright (c) 2016-2017 by OpenText Corporation. All Rights Reserved.
 */
package com.opentext.ia.sdk.sample.assemble;

import java.io.File;
import java.io.IOException;
import java.net.URI;
import java.nio.file.Files;
import java.util.Collections;
import java.util.Map;

import com.opentext.ia.sdk.sip.ContentInfo;
import com.opentext.ia.sdk.sip.DigitalObject;
import com.opentext.ia.sdk.sip.DigitalObjectsExtraction;
import com.opentext.ia.sdk.sip.PackagingInformation;
import com.opentext.ia.sdk.sip.PdiAssembler;
import com.opentext.ia.sdk.sip.SipAssembler;
import com.opentext.ia.sdk.sip.SipMetrics;
import com.opentext.ia.sdk.sip.XmlPdiAssembler;
import com.opentext.ia.sdk.support.io.Encoding;
import com.opentext.ia.sdk.support.io.FileBuffer;
import com.opentext.ia.sdk.support.io.HashAssembler;
import com.opentext.ia.sdk.support.io.HashFunction;
import com.opentext.ia.sdk.support.io.RuntimeIoException;
import com.opentext.ia.sdk.support.io.SingleHashAssembler;


@SuppressWarnings("PMD")
public class FileArchiver {

  /**
   * Build a SIP archive from all files in a given directory tree.
   * @param args The command line args:<ol>
   * <li>The path to the directory to be archived. The default value is the current directory.</li>
   * <li>The path to the SIP archive to be built. The default value is <code>build/files.zip</code></li>
   * </ol>
   */
  public static void main(String[] args) {
    try {
      Arguments arguments = new Arguments(args);
      File root = new File(arguments.next("content"));
      if (!root.isDirectory()) {
        root = new File(".");
      }
      String rootPath = root.getCanonicalPath();
      String sip = arguments.next("build/files.zip");
      new FileArchiver().run(rootPath, sip);
    } catch (IOException e) {
      e.printStackTrace();
      System.exit(1);
    }
  }

  private void run(String rootPath, String sip) throws IOException {
    File sipFile = new File(sip).getCanonicalFile();
    sipFile.getParentFile().mkdirs();
    System.out.printf("\nSample 2: Archiving files from %s into %s%n", rootPath, sipFile.getPath());
    // Tell InfoArchive where and how to archive the data
    URI entityUri = URI.create("urn:com.opentext.ia.sdk.sample.file:1.0");
    String entityName = "file";
    PackagingInformation prototype = PackagingInformation.builder()
        .dss()
            .application("fileApplication")
            .holding("fileHolding")
            .producer("SIP SDK")
            .entity(entityName)
            .schema(entityUri.toString())
        .end()
    .build();

    // Define a mapping from our domain object to the PDI XML
    PdiAssembler<File> pdiAssembler = new XmlPdiAssembler<File>(entityUri, entityName) {
      @Override
      protected void doAdd(File file, Map<String, ContentInfo> contentInfo) {
        try {
          String path = relativePath(file, rootPath);
          getBuilder()
              .element("path", path)
              .element("size", Long.toString(file.length()))
              .element("permissions", permissionsOf(file))
              .element("contentType", Files.probeContentType(file.toPath()))
              .elements("hashes", "hash", contentInfo.get(path).getContentHashes(), (hash, builder) -> {
                builder
                    .attribute("algorithm", hash.getHashFunction())
                    .attribute("encoding", hash.getEncoding())
                    .attribute("value", hash.getValue());
              });
        } catch (IOException e) {
          throw new RuntimeIoException(e);
        }
      }
    };
    DigitalObjectsExtraction<File> contentAssembler = file -> Collections.singleton(
        DigitalObject.fromFile(relativePath(file, rootPath), file)
    ).iterator();
    HashAssembler contentHashAssembler = new SingleHashAssembler(HashFunction.SHA256, Encoding.BASE64);

    // Assemble the SIP
    SipAssembler<File> assembler = SipAssembler.forPdiAndContentWithContentHashing(prototype, pdiAssembler,
        contentAssembler, contentHashAssembler);
    assembler.start(new FileBuffer(sipFile));
    try {
      addFilesIn(new File(rootPath), rootPath, relativePath(sipFile, rootPath), assembler);
    } finally {
      assembler.end();
    }
    SipMetrics metrics = assembler.getMetrics();
    System.out.printf("  Added %d files to SIP of %d bytes in %d ms%n", metrics.numDigitalObjects(),
        metrics.sipFileSize(), metrics.assemblyTime());
  }

  private String relativePath(File file, String rootPath) {
    return file.getAbsolutePath().substring(rootPath.length() + 1);
  }

  private String permissionsOf(File file) {
    return String.format("%c%c%c", file.canRead() ? 'r' : '-', file.canWrite() ? 'w' : '-',
        file.canExecute() ? 'x' : '-');
  }

  private void addFilesIn(File parent, String rootPath, String skipPath, SipAssembler<File> assembler) {
    File[] children = parent.listFiles();
    if (children != null) {
      for (File child : children) {
        if (child.isDirectory()) {
          addFilesIn(child, rootPath, skipPath, assembler);
        } else if (child.isFile() && !relativePath(child, rootPath).equals(skipPath)) {
          assembler.add(child);
        }
      }
    }
  }


  public static class Arguments {

    private final String[] args;
    private int index;

    public Arguments(String[] args) {
      this.args = args;
    }

    public String next(String defaultValue) {
      return index < args.length ? args[index++] : defaultValue;
    }

  }

}

@@ -2063,24 +2063,31 @@
  %25s%25n%22, 
+escape(
 rootPath
 , sipFil
@@ -2078,18 +2078,34 @@
 rootPath
-, 
+),%0A        escape(
 sipFile.
@@ -2114,17 +2114,19 @@
 tPath())
-;
+);%0A
 %0A    // 
@@ -4235,24 +4235,72 @@
 end();%0A    %7D
+%0A%0A    // Show metrics about the assembly process
 %0A    SipMetr
@@ -4491,32 +4491,134 @@
 lyTime());%0A  %7D%0A%0A
+  private String escape(String path) %7B%0A    // For Windows%0A    return path.replace(%22%5C%5C%22, %22%5C%5C%5C%5C%22);%0A  %7D%0A%0A
   private String

Make the sample run on Windows