archive/net.sourceforge.phpeclipse.wiki/src/net/sourceforge/phpeclipse/wiki/actions/mediawiki/post/PostJob.java

   1 package net.sourceforge.phpeclipse.wiki.actions.mediawiki.post;
   2
   3 import java.io.IOException;
   4 import java.io.InputStream;
   5 import java.io.InputStreamReader;
   6 import java.io.StringWriter;
   7 import java.util.HashMap;
   8
   9 import net.sourceforge.phpeclipse.wiki.actions.ProblemConsole;
  10 import net.sourceforge.phpeclipse.wiki.actions.mediawiki.config.IWikipedia;
  11 import net.sourceforge.phpeclipse.wiki.actions.mediawiki.connect.Content;
  12 import net.sourceforge.phpeclipse.wiki.actions.mediawiki.connect.MediaWikiConnector;
  13 import net.sourceforge.phpeclipse.wiki.actions.mediawiki.exceptions.MethodException;
  14 import net.sourceforge.phpeclipse.wiki.actions.mediawiki.exceptions.PageNotEditableException;
  15 import net.sourceforge.phpeclipse.wiki.actions.mediawiki.exceptions.UnexpectedAnswerException;
  16 import net.sourceforge.phpeclipse.wiki.editor.WikiEditorPlugin;
  17 import net.sourceforge.phpeclipse.wiki.internal.Configuration;
  18 import net.sourceforge.phpeclipse.wiki.preferences.Util;
  19 import net.sourceforge.phpeclipse.wiki.velocity.EditorText;
  20 import net.sourceforge.phpeclipse.wiki.xml.Page;
  21 import net.sourceforge.phpeclipse.wiki.xml.XStreamManager;
  22
  23 import org.apache.velocity.VelocityContext;
  24 import org.apache.velocity.app.Velocity;
  25 import org.eclipse.core.resources.IFile;
  26 import org.eclipse.core.resources.ResourcesPlugin;
  27 import org.eclipse.core.resources.WorkspaceJob;
  28 import org.eclipse.core.runtime.CoreException;
  29 import org.eclipse.core.runtime.IPath;
  30 import org.eclipse.core.runtime.IProgressMonitor;
  31 import org.eclipse.core.runtime.IStatus;
  32 import org.eclipse.core.runtime.Path;
  33 import org.eclipse.core.runtime.Status;
  34 import org.eclipse.core.runtime.jobs.Job;
  35 import org.eclipse.ui.progress.IProgressConstants;
  36
  37 public class PostJob extends WorkspaceJob {
  38   IFile[] files;
  39
  40   IWikipedia wikipedia;
  41
  42   Configuration configuration;
  43
  44   String user;
  45
  46   String password;
  47
  48   public PostJob(Configuration configuration, IWikipedia wikipedia, String user, String password, IFile[] files) {
  49     super("Refresh Job");
  50     this.files = files;
  51     this.wikipedia = wikipedia;
  52     this.user = user;
  53     this.password = password;
  54     this.configuration = configuration;
  55   }
  56
  57   public String generateUrl(String template, String wikiname) {
  58     EditorText text = new EditorText(null);
  59     /* first, we init the runtime engine. Defaults are fine. */
  60
  61     try {
  62       Velocity.init();
  63
  64       /* lets make a Context and put data into it */
  65
  66       VelocityContext context = new VelocityContext();
  67
  68       context.put("config", configuration);
  69       text.clear();
  70       text.setWikiname(wikiname);
  71       context.put("text", text);
  72
  73       /* lets make our own string to render */
  74       StringWriter w = new StringWriter();
  75       w = new StringWriter();
  76       Velocity.evaluate(context, w, "mystring", template);
  77       return w.toString();
  78
  79     } catch (Exception e) {
  80       // TODO Auto-generated catch block
  81       e.printStackTrace();
  82     }
  83     return template;
  84   }
  85
  86   private void uploadWiki(String timestamp, String body, MediaWikiConnector connector, String actionUrl, String wikiName)
  87       throws UnexpectedAnswerException, MethodException, PageNotEditableException, InterruptedException {
  88
  89     String url = generateUrl(configuration.getURL(), wikiName);
  90     //      System.out.println(timestamp);
  91     Content content = new Content(timestamp, body);
  92
  93     connector.store(wikipedia, actionUrl, wikiName, content, "", false, false);
  94
  95   }
  96
  97   public IStatus runInWorkspace(IProgressMonitor monitor) {
  98     boolean success = false;
  99     IFile file = null;
 100     MediaWikiConnector connector = null;
 101     InputStream is = null;
 102     ProblemConsole console = new ProblemConsole();
 103     String actionUrl = configuration.getURL();
 104     if (actionUrl == null || actionUrl.equals("")) {
 105       // fall back to default settings
 106       actionUrl = wikipedia.getActionUrl();
 107     }
 108     try {
 109       if (files.length > 0) {
 110         // prefetch for error messages
 111         file = files[0];
 112       }
 113       monitor.beginTask("Upload Wiki Articles: ", 100);
 114       int partWork = 100 / files.length;
 115       int work = 0;
 116       StringBuffer buffer = new StringBuffer();
 117       HashMap map = new HashMap();
 118       String wikiURLTitle;
 119
 120       monitor.subTask("Login user:" + user);
 121       connector = new MediaWikiConnector();
 122       success = connector.login(wikipedia, actionUrl, user, password, false);
 123       if (success) {
 124         for (int i = 0; i < files.length; i++) {
 125           try {
 126             file = files[i];
 127             is = file.getContents();
 128             wikiURLTitle = Util.getURLWikiName(file);
 129             String body = StoreWikipediaAction.getInputStreamAsString(is, wikipedia.getCharSet());
 130             char ch;
 131             boolean noContent = checkNoContent(body);
 132             String srcBasePath = Util.getWikiTextsPath(file);
 133             String binBasePath = Util.getProjectsWikiOutputPath(file.getProject(), WikiEditorPlugin.HTML_OUTPUT_PATH);
 134
 135             String fileXMLName = Util.getXMLFileName(file, binBasePath, srcBasePath);
 136             IPath path = new Path(fileXMLName);
 137             IFile xmlFile = ResourcesPlugin.getWorkspace().getRoot().getFileForLocation(path);
 138
 139             String timestamp = "";
 140             if (xmlFile.exists()) {
 141               try {
 142                 Page page = XStreamManager.fromXML(xmlFile.getContents());
 143                 if (page != null) {
 144                   // we've stored information about the article at download time which
 145                   // may be more exactly as the standard information
 146                   if (!page.isEmpty()) {
 147                     // at least one revision exists:
 148                     timestamp = page.get(0).getTimestamp();
 149                   }
 150                   wikiURLTitle = page.getURLTitle();
 151                 }
 152                 //                timestamp = XMLReader.getDateTimestamp(xmlFile.getContents());
 153               } catch (Exception e2) {
 154               }
 155             }
 156
 157             if (noContent) {
 158               console.println("File: " + file.getLocation().toString() + "\n==>upload not allowed; Wiki text contains no content");
 159             } else {
 160               monitor.subTask("Upload: " + file.getLocation().toString());
 161               uploadWiki(timestamp, body, connector, actionUrl, wikiURLTitle);
 162             }
 163
 164           } catch (CoreException e1) {
 165             if (file != null) {
 166               console.println("File: " + file.getLocation().toString() + "\n==>CoreException: " + e1.getMessage());
 167             }
 168           }
 169           if (monitor.isCanceled()) {
 170             return Status.CANCEL_STATUS;
 171           }
 172           work += partWork;
 173           monitor.worked(work);
 174         }
 175       }
 176
 177       if (isModal(this)) {
 178         // The progress dialog is still open show the message
 179         console.reportError();
 180       } else {
 181         setProperty(IProgressConstants.KEEP_PROPERTY, Boolean.TRUE);
 182         //            setProperty(IProgressConstants.ACTION_PROPERTY, getWikisCompletedAction());
 183       }
 184       return Status.OK_STATUS;
 185       //        } catch(CoreException e) {
 186       //          return e.getStatus();
 187     } catch (IOException e) {
 188       if (file != null) {
 189         console.println("File: " + file.getLocation().toString());
 190       }
 191       console.println("==>IOException: " + e.getMessage());
 192     } catch (UnexpectedAnswerException e) {
 193       console.println("==>UnexpectedAnswerException: " + e.getMessage());
 194     } catch (InterruptedException e) {
 195       if (file != null) {
 196         console.println("File: " + file.getLocation().toString());
 197       }
 198       console.println("==>InterruptedException: " + e.getMessage());
 199     } catch (PageNotEditableException e) {
 200       if (file != null) {
 201         console.println("File: " + file.getLocation().toString());
 202       }
 203       console.println("==>PageNotEditableException: " + e.getMessage());
 204     } catch (MethodException e) {
 205       if (file != null) {
 206         console.println("File: " + file.getLocation().toString());
 207       }
 208       console.println("==>HTTP-MethodException: " + e.getMessage());
 209     } finally {
 210       monitor.done();
 211       if (success && connector != null) {
 212         try {
 213           monitor.subTask("Logout!");
 214           connector.logout(wikipedia, actionUrl);
 215         } catch (UnexpectedAnswerException e1) {
 216           console.println("==>UnexpectedAnswerException: " + e1.getMessage());
 217         } catch (MethodException e1) {
 218           console.println("==>HTTP-MethodException: " + e1.getMessage());
 219         }
 220       }
 221       if (is != null) {
 222         try {
 223           is.close();
 224         } catch (IOException e1) {
 225         }
 226       }
 227     }
 228     if (isModal(this)) {
 229       // The progress dialog is still open show the message
 230       console.reportError();
 231     }
 232     return Status.CANCEL_STATUS;
 233   }
 234
 235   /**
 236    * @param body
 237    * @param j
 238    * @return
 239    */
 240   private boolean checkNoContent(String body) {
 241     char ch;
 242     boolean noContent = true;
 243     int j = 0;
 244     try {
 245       while (true) {
 246         ch = body.charAt(j++);
 247         if (!Character.isWhitespace(ch)) {
 248           if (ch == '<' && body.charAt(j) == '!' && body.charAt(j + 1) == '-' && body.charAt(j + 2) == '-') {
 249             //<!-- ... -->
 250             j += 3;
 251             while (true) {
 252               ch = body.charAt(j++);
 253               if (ch == '-' && body.charAt(j) == '-' && body.charAt(j + 1) == '>') {
 254                 j += 2;
 255                 break;
 256               }
 257             }
 258           } else if (ch == '<' && body.charAt(j) == 'b' && body.charAt(j + 1) == 'r' && body.charAt(j + 2) == '>') {
 259             // <br>
 260           } else {
 261             noContent = false;
 262             break;
 263           }
 264         }
 265       }
 266     } catch (IndexOutOfBoundsException e) {
 267
 268     }
 269     return noContent;
 270   }
 271
 272   public boolean isModal(Job job) {
 273     Boolean isModal = (Boolean) job.getProperty(IProgressConstants.PROPERTY_IN_DIALOG);
 274     if (isModal == null) {
 275       return false;
 276     }
 277     return isModal.booleanValue();
 278   }
 279
 280 }