package net.sourceforge.phpeclipse.wiki.actions.mediawiki;

import java.io.ByteArrayInputStream;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;

import net.sourceforge.phpeclipse.wiki.actions.ProblemConsole;
import net.sourceforge.phpeclipse.wiki.actions.mediawiki.config.IWikipedia;
import net.sourceforge.phpeclipse.wiki.actions.mediawiki.connect.MediaWikiConnector;
import net.sourceforge.phpeclipse.wiki.actions.mediawiki.connect.Parsed;
import net.sourceforge.phpeclipse.wiki.actions.mediawiki.exceptions.MethodException;
import net.sourceforge.phpeclipse.wiki.actions.mediawiki.exceptions.UnexpectedAnswerException;
import net.sourceforge.phpeclipse.wiki.editor.WikiEditorPlugin;
import net.sourceforge.phpeclipse.wiki.preferences.Util;
import net.sourceforge.phpeclipse.wiki.xml.Page;
import net.sourceforge.phpeclipse.wiki.xml.XStreamManager;

import org.eclipse.core.resources.IContainer;
import org.eclipse.core.resources.IFile;
import org.eclipse.core.resources.IFolder;
import org.eclipse.core.resources.ResourcesPlugin;
import org.eclipse.core.resources.WorkspaceJob;
import org.eclipse.core.runtime.CoreException;
import org.eclipse.core.runtime.IPath;
import org.eclipse.core.runtime.IProgressMonitor;
import org.eclipse.core.runtime.IStatus;
import org.eclipse.core.runtime.Path;
import org.eclipse.core.runtime.Status;
import org.eclipse.core.runtime.jobs.Job;
import org.eclipse.ui.progress.IProgressConstants;

public class RefreshJob extends WorkspaceJob {
  IFile[] files;

  IWikipedia configuration;

  String actionURL;

  public RefreshJob(IWikipedia configuration, IFile[] files, String actionURL) {
    super("Refresh Job");
    this.files = files;
    this.configuration = configuration;
    this.actionURL = actionURL;
  }

  public IStatus runInWorkspace(IProgressMonitor monitor) {
    ProblemConsole console = new ProblemConsole();
    IFile file = null;
    try {
      monitor.beginTask("Download Wiki Articles: ", 100);
      //      ArrayList wikiTitles = new ArrayList();
      //      for (int i = 0; i < files.length; i++) {
      //        wikiTitles.add( Util.getReadableWikiName(files[i]) );
      //      }
      StringBuffer buffer = new StringBuffer();
      HashMap map = new HashMap();
      String wikiTitle;
      for (int i = 0; i < files.length; i++) {
        file = files[i];
        wikiTitle = createWikiTitle(file, i);
        buffer.append(wikiTitle);
        map.put(wikiTitle, file);
        if (i != files.length - 1) {
          buffer.append("\n");
        }
      }
      MediaWikiConnector mwConnector = new MediaWikiConnector();
      String url = actionURL;
      if (url == null) {
        url = configuration.getActionUrl() + "/" + configuration.getSpecialNs() + ":Export";
      }
      // get a list of Parsed elements
      monitor.subTask("Downloading (XML Import)");
      ArrayList list = mwConnector.loadXML(configuration, url, buffer.toString());
      String body;

      if (list.size() == 0&&files.length>0) {
        console.println("File: " + file.getLocation().toString() + " not available on the server.");
      } else {
        if (list.size() < files.length) {
          console.println("Not all requested files are available on the server.");
        }
        for (int i = 0; i < list.size(); i++) {
          Parsed parsed = (Parsed) list.get(i);
          wikiTitle = parsed.getTitle();
          if (wikiTitle != null) {
            body = parsed.getBody();
            if (body != null) {
              file = (IFile) map.get(wikiTitle);
              if (file != null) {
                // rearrange parsed data into a page for XStream hamdling:
                Page page = new Page(parsed.getDateTimestamp(), wikiTitle, body);
                monitor.subTask("Modify file: " + file.getLocation().toString());
                updateFileContent(console, file, page, body, configuration, monitor);
              }
            }
          }
          if (monitor.isCanceled()) {
            return Status.CANCEL_STATUS;
          }
        }
      }
      if (isModal(this)) {
        // The progress dialog is still open show the message
        console.reportError();
      } else {
        //        setProperty(IProgressConstants.KEEP_PROPERTY, Boolean.TRUE);
        //            setProperty(IProgressConstants.ACTION_PROPERTY, getWikisCompletedAction());
      }
      return Status.OK_STATUS;
      //        } catch(CoreException e) {
      //          return e.getStatus();
    } catch (UnexpectedAnswerException e) {
      if (file != null) {
        console.println("File: " + file.getLocation().toString() + "\n==>UnexpectedAnswerException: " + e.getMessage());
      } else {
        console.println("UnexpectedAnswerException: " + e.getMessage());
      }
    } catch (MethodException e) {
      if (file != null) {
        console.println("File: " + file.getLocation().toString() + "\n==>HTTP-MethodException: " + e.getMessage());
      } else {
        console.println("HTTP-MethodException: " + e.getMessage());
      }
    } finally {
      monitor.done();
    }
    if (isModal(this)) {
      // The progress dialog is still open show the message
      console.reportError();
    }
    return Status.OK_STATUS;
  }

  /**
   * @param file
   * @param wikiTitle
   * @param i
   * @return
   */
  private String createWikiTitle(IFile file, int i) {
    String wikiTitle = null;
    String srcBasePath = Util.getWikiTextsPath(file);
    String binBasePath = Util.getProjectsWikiOutputPath(file.getProject(), WikiEditorPlugin.HTML_OUTPUT_PATH);

    String fileXMLName = Util.getXMLFileName(file, binBasePath, srcBasePath);
    IPath path = new Path(fileXMLName);
    IFile xmlFile = ResourcesPlugin.getWorkspace().getRoot().getFileForLocation(path);
    if (xmlFile.exists()) {
      try {
        Page page = XStreamManager.fromXML(xmlFile.getContents());
        if (page != null) {
          wikiTitle = page.getTitle();
        }
        //                timestamp = XMLReader.getDateTimestamp(xmlFile.getContents());
      } catch (Exception e2) {
      }
    }
    if (wikiTitle == null) {
      // if no XML file exists we create the name from the filename
      wikiTitle = Util.getReadableWikiName(files[i]);
    }
    return wikiTitle;
  }

  public boolean isModal(Job job) {
    Boolean isModal = (Boolean) job.getProperty(IProgressConstants.PROPERTY_IN_DIALOG);
    if (isModal == null) {
      return false;
    }
    return isModal.booleanValue();
  }

  private static void updateFileContent(ProblemConsole console, IFile file, Page page, String body, IWikipedia wp,
      IProgressMonitor monitor) {
    try {
      if (file.exists()) {
        if (wp == null) {
          file.setContents(new ByteArrayInputStream(body.getBytes()), true, false, null);
        } else {
          file.setContents(new ByteArrayInputStream(body.getBytes(wp.getCharSet())), true, false, null);
          file.setCharset(wp.getCharSet(), monitor);
        }
      } else {
        if (wp == null) {
          file.create(new ByteArrayInputStream(body.getBytes()), false, null);
        } else {
          file.create(new ByteArrayInputStream(body.getBytes(wp.getCharSet())), false, null);
          file.setCharset(wp.getCharSet(), monitor);
        }
      }
      String srcBasePath = Util.getWikiTextsPath(file);
      String binBasePath = Util.getProjectsWikiOutputPath(file.getProject(), WikiEditorPlugin.HTML_OUTPUT_PATH);

      String filename = Util.getXMLFileName(file, binBasePath, srcBasePath);
      IPath path = new Path(filename);
      IFile xmlFile = ResourcesPlugin.getWorkspace().getRoot().getFileForLocation(path);
      IContainer parent = xmlFile.getParent();
      if (parent instanceof IFolder && (!((IFolder) parent).exists())) {
        Util.createFolder((IFolder) parent, monitor);
      }
      try {
        //        String xmlData = parsed.getXmlData();
        //        String charSet = "UTF-8";
        //        StringBuffer buf = new StringBuffer();
        //        int index = xmlData.indexOf("<page>");
        //        if (index<0) {
        //          console.println("File: " + xmlFile.getLocation().toString() + "\n==>Couldn't create xml file - <page> tag not found");
        //          return;
        //        }
        //        xmlData = xmlData.substring(index);
        //        buf.append(WikiEditorPlugin.XML_START_1);
        //        buf.append(charSet);
        //        buf.append(WikiEditorPlugin.XML_START_2);
        //        buf.append(xmlData);
        //        buf.append(WikiEditorPlugin.XML_END);

        //        byte[] buffer = buf.toString().getBytes();
        byte[] buffer = XStreamManager.toXML(page).getBytes();
        ByteArrayInputStream source = new ByteArrayInputStream(buffer);
        if (!xmlFile.exists()) {
          xmlFile.create(source, true, monitor);
        } else {
          xmlFile.setContents(source, true, true, monitor);
        }
      } catch (CoreException e) {
        if (file != null) {
          console.println("File: " + xmlFile.getLocation().toString() + "\n==>CoreException: " + e.getMessage());
        }
      }
    } catch (UnsupportedEncodingException e) {
      console.println("File: " + file.getLocation().toString() + "\n==>UnsupportedEncodingException: " + e.getMessage());
    } catch (Exception e) {
      console.println("File: " + file.getLocation().toString() + "\n==>Exception: " + e.getMessage());
    }
  }
}