package org.apache.torque.mojo.morph;

 import java.io.IOException;

 import java.io.InputStream;

 import java.io.OutputStream;

 import org.apache.commons.io.IOUtils;

 import org.apache.commons.logging.Log;

 import org.apache.commons.logging.LogFactory;

 public abstract class Morpher {

         private static final Log log = LogFactory.getLog(Morpher.class);

         MorphRequest morphRequest;

         String artifactId;

         public Morpher() {

                 this(null, null);

         }

         public Morpher(MorphRequest morphRequest, String artifactId) {

                 super();

                 this.morphRequest = morphRequest;

                 this.artifactId = artifactId;

         }

         protected abstract boolean isMorphNeeded(String contents);

         protected abstract String getMorphedContents(String contents);

         public void executeMorph() throws IOException {

                 // Read the "old" data into a string

                 InputStream in = morphRequest.getInputStream();

                 String contents = IOUtils.toString(in, morphRequest.getEncoding());

                 IOUtils.closeQuietly(in);

                 // May not need to morph

                 if (isMorphNeeded(contents)) {

                         contents = getMorphedContents(contents);

                 } else {

                         log.debug("Skipping morph on " + morphRequest.getName());

                 }

                 // Write the morphed data to the output stream

                 OutputStream out = morphRequest.getOutputStream();

                 IOUtils.write(contents, out, morphRequest.getEncoding());

                 IOUtils.closeQuietly(out);

         }

         public MorphRequest getMorphRequest() {

                 return morphRequest;

         }

         public void setMorphRequest(MorphRequest morphRequest) {

                 this.morphRequest = morphRequest;

         }

         public String getArtifactId() {

                 return artifactId;

         }

         public void setArtifactId(String schema) {

                 this.artifactId = schema;

         }

 }