| /************************************************************** |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| *************************************************************/ |
| |
| |
| |
| package complex.writer; |
| |
| import complexlib.ComplexTestCase; |
| import com.sun.star.uno.UnoRuntime; |
| import com.sun.star.uno.AnyConverter; |
| import com.sun.star.uno.XComponentContext; |
| import com.sun.star.lang.WrappedTargetException; |
| import com.sun.star.lang.WrappedTargetRuntimeException; |
| import com.sun.star.lang.EventObject; |
| import com.sun.star.lang.XMultiServiceFactory; |
| import com.sun.star.lang.XComponent; |
| import com.sun.star.lang.XServiceInfo; |
| import com.sun.star.beans.XPropertySet; |
| import com.sun.star.beans.PropertyValue; |
| import com.sun.star.beans.Pair; |
| import com.sun.star.util.XCloseable; |
| import com.sun.star.frame.XStorable; |
| import com.sun.star.document.DocumentEvent; |
| import com.sun.star.document.XDocumentEventBroadcaster; |
| import com.sun.star.document.XDocumentEventListener; |
| import com.sun.star.text.XTextDocument; |
| |
| import java.util.List; |
| import java.util.ArrayList; |
| import java.io.File; |
| |
| /** |
| * a small program to load documents from one directory (recursively) |
| * and store them in another, implemented as a complex test. |
| */ |
| public class LoadSaveTest extends ComplexTestCase |
| { |
| private XMultiServiceFactory m_xMSF = null; |
| private XComponentContext m_xContext = null; |
| private XDocumentEventBroadcaster m_xGEB = null; |
| private String m_TmpDir = null; |
| |
| private String m_fileURL = "file://"; |
| // these should be parameters or something? |
| private String m_SourceDir = "FIXME"; |
| private String m_TargetDir = "/tmp/out"; |
| |
| public String[] getTestMethodNames() { |
| return new String[] { "testLoadStore" }; |
| } |
| |
| public void before() throws Exception |
| { |
| m_xMSF = (XMultiServiceFactory) param.getMSF(); |
| XPropertySet xPropertySet = (XPropertySet) |
| UnoRuntime.queryInterface(XPropertySet.class, m_xMSF); |
| Object defaultCtx = xPropertySet.getPropertyValue("DefaultContext"); |
| m_xContext = (XComponentContext) |
| UnoRuntime.queryInterface(XComponentContext.class, defaultCtx); |
| assure("could not get component context.", m_xContext != null); |
| Object oGEB = m_xMSF.createInstance( |
| "com.sun.star.frame.GlobalEventBroadcaster"); |
| m_xGEB = (XDocumentEventBroadcaster) |
| UnoRuntime.queryInterface(XDocumentEventBroadcaster.class, oGEB); |
| assure("could not get global event broadcaster.", m_xGEB != null); |
| m_TmpDir = util.utils.getOfficeTemp/*Dir*/(m_xMSF); |
| log.println("tempdir: " + m_TmpDir); |
| log.println("sourcedir: " + m_SourceDir); |
| log.println("targetdir: " + m_TargetDir); |
| } |
| |
| /* |
| public void after() |
| { |
| } |
| */ |
| |
| public void testLoadStore() throws Exception |
| { |
| Pair<List<String>, List<String>> dirsFiles = |
| getDirAndFileNames(m_SourceDir); |
| makeDirs(m_TargetDir, dirsFiles.First); |
| for (String fileName : dirsFiles.Second) |
| { |
| try { |
| testDoc(fileName); |
| } catch (Exception e) { |
| report(e); |
| } |
| } |
| } |
| |
| public void testDoc(String fileName) throws Exception |
| { |
| XComponent xDoc = null; |
| EventListener xListener = new EventListener(); |
| try { |
| m_xGEB.addDocumentEventListener(xListener); |
| |
| log.println("Loading document: " + fileName + " ..."); |
| |
| PropertyValue[] loadProps = new PropertyValue[1]; |
| loadProps[0] = new PropertyValue(); |
| loadProps[0].Name = "ReadOnly"; |
| loadProps[0].Value = new Boolean(true); |
| |
| String sourceFile = m_fileURL + m_SourceDir + fileName; |
| |
| xDoc = util.DesktopTools.loadDoc(m_xMSF, sourceFile, loadProps); |
| |
| log.println("... done"); |
| |
| { |
| // apparently OnLayoutFinished is not sent for every doc??? |
| // 10 seconds is evidently not enough for large documents |
| int time = 0; |
| while (!xListener.IsLayoutFinished() && (time < 30000)) { |
| Thread.sleep(100); |
| time += 100; |
| } |
| if (time >= 30000) { |
| log.println("timeout: no OnLayoutFinished received!"); |
| } |
| } |
| |
| log.println("Storing document: " + fileName + " ..."); |
| |
| XStorable xStor = (XStorable) UnoRuntime.queryInterface( |
| XStorable.class, xDoc); |
| |
| String targetFile = m_fileURL + m_TargetDir + fileName; |
| |
| xStor.storeToURL(targetFile, new PropertyValue[0]); |
| |
| log.println("... done"); |
| |
| } finally { |
| if (xDoc != null) { |
| util.DesktopTools.closeDoc(xDoc); |
| } |
| if (xListener != null) { |
| m_xGEB.removeDocumentEventListener(xListener); |
| } |
| } |
| } |
| |
| class EventListener implements XDocumentEventListener |
| { |
| boolean m_isLayoutFinished = false; |
| boolean IsLayoutFinished() { return m_isLayoutFinished; } |
| public void documentEventOccured(DocumentEvent Event) |
| { |
| // log.println("event: " + Event.EventName); |
| if ("OnLayoutFinished".equals(Event.EventName)) |
| { |
| // we only have one doc at any time, so no need to check |
| m_isLayoutFinished = true; |
| // log.println("received OnLayoutFinished"); |
| } |
| } |
| public void disposing(EventObject Event) { } |
| } |
| |
| void report2(Exception e) |
| { |
| if (e instanceof WrappedTargetException) |
| { |
| log.println("Cause:"); |
| Exception cause = (Exception) |
| (((WrappedTargetException)e).TargetException); |
| log.println(cause.toString()); |
| report2(cause); |
| } else if (e instanceof WrappedTargetRuntimeException) { |
| log.println("Cause:"); |
| Exception cause = (Exception) |
| (((WrappedTargetRuntimeException)e).TargetException); |
| log.println(cause.toString()); |
| report2(cause); |
| } |
| } |
| |
| void report(Exception e) { |
| log.println("Exception occurred:"); |
| log.println(e.toString()); |
| e.printStackTrace((java.io.PrintWriter) log); |
| report2(e); |
| // failed(); |
| } |
| |
| Pair<List<String>, List<String>> getDirAndFileNames(String dir) |
| { |
| List<String> dirs = new ArrayList<String>(); |
| List<String> files = new ArrayList<String>(); |
| File root = new File(dir); |
| getDirAndFileNames(root, "", dirs, files); |
| return new Pair<List<String>, List<String>>(dirs, files); |
| } |
| |
| void getDirAndFileNames(File file, String relPath, |
| List<String> dirs, List<String> files) |
| { |
| assure("does not exist: " + relPath, file.exists()); |
| if (file.isDirectory()) { |
| dirs.add(relPath); |
| File[] subfiles = file.listFiles(); |
| for (File subfile : subfiles) |
| { |
| String subfileName = |
| relPath + File.separator + subfile.getName(); |
| getDirAndFileNames(subfile, subfileName, dirs, files); |
| } |
| } |
| else if (file.isFile()) { |
| if (file.getName().endsWith(".odt")) { |
| files.add(relPath); |
| } |
| } |
| } |
| |
| void makeDirs(String target, List<String> dirs) throws Exception |
| { |
| for (String dir : dirs) { |
| File f = new File(target + dir); |
| if (!f.exists()) { |
| if (!f.mkdir()) { |
| throw new Exception("cannot mkdir: " + target + dir); |
| } |
| } |
| } |
| } |
| } |
| |