deploygridspheretck.java

GridSphere 门户 提供一个基于 portlet 的高级开放源代码门户。GridSphere 是在欧盟提供基金的 GridLab 项目下开发的

package org.gridsphere.tools;

import org.apache.tools.ant.BuildException;
import org.apache.tools.ant.Task;

import java.io.*;
import java.util.Enumeration;
import java.util.List;
import java.util.Vector;
import java.util.jar.JarEntry;
import java.util.jar.JarFile;
import java.util.jar.JarOutputStream;


public class DeployGridSphereTCK extends Task {

    private String warPath = null;
    private String buildDir = null;
    private String catalina = null;
    private List portlets = new Vector();
    private List portletapps = new Vector();

    private class WARFilenameFilter implements FilenameFilter {

        public boolean accept(File dir, String name) {
            if (name.endsWith(".war")) return true;
            return false;
        }
    }

    public void setWarDir(String warDir) {
        this.warPath = warDir;
        //System.out.println("Setting configdir to: "+this.configDir);
    }

    public void setBuildDir(String buildDir) {
        this.buildDir = buildDir;
    }

    public void setServer(String serverDir) {
        this.catalina = serverDir;
    }

    /**
     * Tool to transform Sun TCK portlet WAR's to GridSphere JSR model
     */
    public void execute() throws BuildException {

        System.out.println("GridSphere tool to deploy Sun TCK portlet WAR files as ");
        System.out.println(" GridSphere JSR portlet applications and create a test layout descriptor");

        try {
            loadWars(warPath);
            createLayout();
            deployPortlets();
        } catch (IOException e) {
            System.err.println("Error converting WARS:");
            e.printStackTrace();
        }
    }

    private void deployPortlets() throws IOException {
        String portletsDir = catalina + File.separator + "webapps" + File.separator + "gridsphere" + File.separator
                + "WEB-INF" + File.separator + "CustomPortal" + File.separator + "portlets" + File.separator;
        File tmp = null;
        for (int i = 0; i < portletapps.size(); i++) {
            tmp = new File(portletsDir + portletapps.get(i));
            tmp.createNewFile();
        }
    }


    private void createLayout() throws IOException {


        PrintWriter out = new PrintWriter(new BufferedWriter(new FileWriter("guest-layout-tck.xml")));

        out.println("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");
        out.println("<page-layout theme=\"xp\" title=\"GridSphere Portal\">");
        out.println("<portlet-header/>");
        out.print("<portlet-tabbed-pane selected=\"0\" style=\"menu\">\n" +
                "    <portlet-tab label=\"gridsphere\">\n" +
                "        <title lang=\"en\">GridSphere</title>");
        System.err.println("Number of portlets: " + portlets.size());
        for (int i = 0; i < portlets.size(); i++) {
            System.err.println((String) portlets.get(i));
            out.println("<portlet-frame>");
            out.println("<portlet-class>" + (String) portlets.get(i) + "</portlet-class>");
            out.println("</portlet-frame>");
        }
        out.println("</portlet-tab></portlet-tabbed-pane></page-layout");

        out.close();

    }

    private void loadWars(String warPath) throws IOException {

        File warDir = new File(warPath);

        if (!warDir.isDirectory()) {
            throw new IOException("Specified TCK directory not valid: " + warPath);
        }

        String[] warFiles = warDir.list(new WARFilenameFilter());

        byte[] buffer = new byte[1024];
        int bytesRead;

        // loop thru all WARs
        for (int i = 0; i < warFiles.length; i++) {
            //System.err.println(warPath + File.separator + warFiles[i].toString());

            String war = warFiles[i].substring(0, warFiles[i].indexOf(".war"));
            portletapps.add(war);
            JarFile jarFile = new JarFile(warPath + File.separator + warFiles[i]);
            JarOutputStream tempJar = new JarOutputStream(new FileOutputStream(System.getProperty("java.io.tmpdir") + File.separator + warFiles[i].toString()));

            addGridSphereJSRDescriptor(tempJar);
            addGridSphereTagLibs(tempJar);
            addLogProps(tempJar);

            // loop thru all jars
            Enumeration files = jarFile.entries();
            while (files.hasMoreElements()) {
                JarEntry entry = (JarEntry) files.nextElement();

                //System.err.println("\t\t" + entry.getName());
                if (entry.getName().equals("WEB-INF/web.xml")) {
                    InputStream entryStream = jarFile.getInputStream(entry);
                    modifyWebXML(entryStream, tempJar, warFiles[i]);
                    break;
                }
                if (entry.getName().equals("WEB-INF/portlet.xml")) {
                    InputStream entryStream = jarFile.getInputStream(entry);
                    collectPortletNames(war, entryStream);
                }

                tempJar.putNextEntry(entry);

                InputStream entryStream = jarFile.getInputStream(entry);

                // Read the entry and write it to the temp jar.
                while ((bytesRead = entryStream.read(buffer)) != -1) {
                    tempJar.write(buffer, 0, bytesRead);
                }

            }

            tempJar.close();
            jarFile.close();
        }

    }

    public synchronized void modifyWebXML(InputStream webxmlStream, JarOutputStream tempJar, String warname) throws IOException {
        BufferedReader bis = new BufferedReader(new InputStreamReader(webxmlStream));
        String line = null;
        String war = warname.substring(0, warname.indexOf(".war"));
        JarEntry entry = new JarEntry("WEB-INF" + File.separator + "web.xml");
        tempJar.putNextEntry(entry);

        PrintWriter out = new PrintWriter(new BufferedWriter(new FileWriter("tmp.xml")));
        boolean hasServletEntry = false;
        boolean domapping = false;
        while ((line = bis.readLine()) != null) {
            if (line.endsWith("<servlet-mapping>") && (!hasServletEntry)) {
                out.println("  <servlet>");
                out.println("    <servlet-name>PortletServlet</servlet-name>");
                out.println("    <servlet-class>org.gridsphere.provider.portlet.jsr.PortletServlet</servlet-class>");
                out.println("  </servlet>");
                out.println(line);
                domapping = true;
                hasServletEntry = true;
            } else if (line.endsWith("<session-config>") && (!hasServletEntry)) {
                out.println("  <servlet>");
                out.println("    <servlet-name>PortletServlet</servlet-name>");
                out.println("    <servlet-class>org.gridsphere.provider.portlet.jsr.PortletServlet</servlet-class>");
                out.println("  </servlet>");
                out.println("  <servlet-mapping>");
                out.println("    <servlet-name>PortletServlet</servlet-name>");
                out.println("    <url-pattern>/jsr/" + war + "</url-pattern>");
                out.println("  </servlet-mapping>");
                out.println(line);
                hasServletEntry = true;
            } else if ((line.endsWith("</web-app>")) && (!hasServletEntry)) {
                out.println("  <servlet>");
                out.println("    <servlet-name>PortletServlet</servlet-name>");
                out.println("    <servlet-class>org.gridsphere.provider.portlet.jsr.PortletServlet</servlet-class>");
                out.println("  </servlet>");
                out.println("  <servlet-mapping>");
                out.println("    <servlet-name>PortletServlet</servlet-name>");
                out.println("    <url-pattern>/jsr/" + war + "</url-pattern>");
                out.println("  </servlet-mapping>");
                out.println("</web-app>");
            } else if ((domapping) && (line.endsWith("<session-config>") || (line.endsWith("<web-app>")))) {
                out.println("  <servlet-mapping>");
                out.println("    <servlet-name>PortletServlet</servlet-name>");
                out.println("    <url-pattern>/jsr/" + war + "</url-pattern>");
                out.println("  </servlet-mapping>");
                out.println(line);
                hasServletEntry = true;
            } else {
                out.println(line);
            }
        }
        out.close();
        bis.close();

        // Open the given file.

        FileInputStream file = new FileInputStream("tmp.xml");
        byte[] buffer = new byte[1024];
        int bytesRead;

        try {

// Read the file and write it to the jar.

            while ((bytesRead = file.read(buffer)) != -1) {
                tempJar.write(buffer, 0, bytesRead);
            }

            System.out.println(entry.getName() + " added.");
        } finally {
            file.close();
        }

    }


    public void addGridSphereJSRDescriptor(JarOutputStream tempJar) throws IOException {

        String fileName = "config" + File.separator + "template" + File.separator + "gridsphere-portlet-jsr.xml";
        byte[] buffer = new byte[1024];
        int bytesRead;


        // Open the given file.

        FileInputStream file = new FileInputStream(fileName);

        try {
// Create a jar entry and add it to the temp jar.

            JarEntry entry = new JarEntry("WEB-INF" + File.separator + "gridsphere-portlet.xml");
            tempJar.putNextEntry(entry);

// Read the file and write it to the jar.

            while ((bytesRead = file.read(buffer)) != -1) {
                tempJar.write(buffer, 0, bytesRead);
            }

            System.out.println(entry.getName() + " added.");

        } finally {
            file.close();
        }
    }

    public void addLogProps(JarOutputStream tempJar) throws IOException {

        String fileName = "config" + File.separator + "log4j.properties";
        byte[] buffer = new byte[1024];
        int bytesRead;


        // Open the given file.

        FileInputStream file = new FileInputStream(fileName);

        try {
// Create a jar entry and add it to the temp jar.

            JarEntry entry = new JarEntry("WEB-INF" + File.separator + "classes" + File.separator + "log4j.properties");
            tempJar.putNextEntry(entry);

// Read the file and write it to the jar.

            while ((bytesRead = file.read(buffer)) != -1) {
                tempJar.write(buffer, 0, bytesRead);
            }

            System.out.println(entry.getName() + " added.");

        } finally {
            file.close();
        }
    }

    public void addGridSphereTagLibs(JarOutputStream tempJar) throws IOException {

        String fileName = buildDir + File.separator + "lib" + File.separator + "gridsphere-ui-tags-2.1.jar";
        byte[] buffer = new byte[1024];
        int bytesRead;


        // Open the given file.

        FileInputStream file = new FileInputStream(fileName);

        try {
// Create a jar entry and add it to the temp jar.

            JarEntry entry = new JarEntry("WEB-INF" + File.separator + "lib" + File.separator + "gridsphere-ui-tags-2.1.jar");
            tempJar.putNextEntry(entry);

// Read the file and write it to the jar.

            while ((bytesRead = file.read(buffer)) != -1) {
                tempJar.write(buffer, 0, bytesRead);
            }

            System.out.println(entry.getName() + " added.");

        } finally {
            file.close();
        }
    }

    public void collectPortletNames(String war, InputStream portletxmlStream) throws IOException {
        BufferedReader bis = new BufferedReader(new InputStreamReader(portletxmlStream));
        String line = null;
        String portlet = "";
        while ((line = bis.readLine()) != null) {
            //System.err.println("portlet= " + line);
            if (line.indexOf("<portlet-name>") > 0) {
                int d = line.indexOf("<portlet-name>");
                String p = line.substring(d + "<portlet-name>".length());
                int e = p.indexOf("</portlet-name>");
                portlet = p.substring(0, e);
                portlets.add(war + "#" + portlet);
            }
        }
        bis.close();
    }
}