a7c811f38f645fda68b63b36739138a0cefd6110
[phpeclipse.git] / 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 }