/*
 * Copyright 2000-2014 JetBrains s.r.o.
 *
 * Licensed 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 com.intellij.errorreport.itn;

import com.intellij.diagnostic.DiagnosticBundle;
import com.intellij.errorreport.bean.ErrorBean;
import com.intellij.errorreport.error.InternalEAPException;
import com.intellij.errorreport.error.NoSuchEAPUserException;
import com.intellij.errorreport.error.UpdateAvailableException;
import com.intellij.openapi.application.Application;
import com.intellij.openapi.application.ApplicationInfo;
import com.intellij.openapi.application.ApplicationManager;
import com.intellij.openapi.application.ApplicationNamesInfo;
import com.intellij.openapi.application.ex.ApplicationInfoEx;
import com.intellij.openapi.diagnostic.Attachment;
import com.intellij.openapi.updateSettings.impl.UpdateSettings;
import com.intellij.openapi.util.Couple;
import com.intellij.openapi.util.text.StringUtil;
import com.intellij.util.SystemProperties;
import com.intellij.util.net.HttpConfigurable;
import org.jetbrains.annotations.NonNls;

import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Iterator;
import java.util.List;

/**
 * Created by IntelliJ IDEA.
 * User: stathik
 * Date: Aug 4, 2003
 * Time: 8:12:00 PM
 * To change this template use Options | File Templates.
 */
public class ITNProxy {
  @NonNls public static final String ENCODING = "UTF8";
  public static final String POST_DELIMITER = "&";

  @NonNls public static final String NEW_THREAD_URL = "http://www.intellij.net/trackerRpc/idea/createScr";

  @NonNls private static final String HTTP_CONTENT_LENGTH = "Content-Length";
  @NonNls private static final String HTTP_CONTENT_TYPE = "Content-Type";
  @NonNls private static final String HTTP_WWW_FORM = "application/x-www-form-urlencoded";
  @NonNls private static final String HTTP_POST = "POST";

  public static int postNewThread (String login, String password, ErrorBean error, String compilationTimestamp)
    throws IOException, NoSuchEAPUserException, InternalEAPException, UpdateAvailableException {

    @NonNls List<Couple<String>> params = createParametersFor(login,
                                                                    password,
                                                                    error,
                                                                    compilationTimestamp,
                                                                    ApplicationManager.getApplication(),
                                                                    (ApplicationInfoEx) ApplicationInfo.getInstance(),
                                                                    ApplicationNamesInfo.getInstance(),
                                                                    UpdateSettings.getInstance());

    HttpURLConnection connection = post(new URL(NEW_THREAD_URL), join(params));
    int responseCode = connection.getResponseCode();

    if (responseCode != HttpURLConnection.HTTP_OK) {
      throw new InternalEAPException(DiagnosticBundle.message("error.http.result.code", responseCode));
    }

    String reply;

    InputStream is = new BufferedInputStream(connection.getInputStream());
    try {
      reply = readFrom(is);
    } finally {
      is.close();
    }

    if ("unauthorized".equals(reply)) {
      throw new NoSuchEAPUserException(login);
    }

    if (reply.startsWith("update ")) {
      throw new UpdateAvailableException(reply.substring(7));
    }

    if (reply.startsWith("message ")) {
      throw new InternalEAPException(reply.substring(8));
    }

    try {
      return Integer.valueOf(reply.trim()).intValue();
    } catch (NumberFormatException ex) {
      // Tibor!!!! :-E
      throw new InternalEAPException(DiagnosticBundle.message("error.itn.returns.wrong.data"));
    }
  }

  private static List<Couple<String>> createParametersFor(String login,
                                                                String password,
                                                                ErrorBean error,
                                                                String compilationTimestamp, Application application, ApplicationInfoEx appInfo,
                                                                ApplicationNamesInfo namesInfo,
                                                                UpdateSettings updateSettings) {
    @NonNls List<Couple<String>> params = new ArrayList<Couple<String>>();

    params.add(Couple.of("protocol.version", "1"));

    params.add(Couple.of("user.login", login));
    params.add(Couple.of("user.password", password));

    params.add(Couple.of("os.name", SystemProperties.getOsName()));

    params.add(Couple.of("java.version", SystemProperties.getJavaVersion()));
    params.add(Couple.of("java.vm.vendor", SystemProperties.getJavaVmVendor()));

    params.add(Couple.of("app.name", namesInfo.getProductName()));
    params.add(Couple.of("app.name.full", namesInfo.getFullProductName()));
    params.add(Couple.of("app.name.version", appInfo.getVersionName()));
    params.add(Couple.of("app.eap", Boolean.toString(appInfo.isEAP())));
    params.add(Couple.of("app.internal", Boolean.toString(application.isInternal())));
    params.add(Couple.of("app.build", appInfo.getBuild().asString()));
    params.add(Couple.of("app.version.major", appInfo.getMajorVersion()));
    params.add(Couple.of("app.version.minor", appInfo.getMinorVersion()));
    params.add(Couple.of("app.build.date", format(appInfo.getBuildDate())));
    params.add(Couple.of("app.build.date.release", format(appInfo.getMajorReleaseBuildDate())));
    params.add(Couple.of("app.compilation.timestamp", compilationTimestamp));

    params.add(Couple.of("update.channel.status", updateSettings.getSelectedChannelStatus().getCode()));
    params.add(Couple.of("update.ignored.builds", StringUtil.join(updateSettings.getIgnoredBuildNumbers(), ",")));

    params.add(Couple.of("plugin.name", error.getPluginName()));
    params.add(Couple.of("plugin.version", error.getPluginVersion()));

    params.add(Couple.of("last.action", error.getLastAction()));
    params.add(Couple.of("previous.exception",
                         error.getPreviousException() == null ? null : Integer.toString(error.getPreviousException())));

    params.add(Couple.of("error.message", error.getMessage()));
    params.add(Couple.of("error.stacktrace", error.getStackTrace()));

    params.add(Couple.of("error.description", error.getDescription()));

    params.add(Couple.of("assignee.id", error.getAssigneeId() == null ? null : Integer.toString(error.getAssigneeId())));

    for (Attachment attachment : error.getAttachments()) {
      params.add(Couple.of("attachment.name", attachment.getName()));
      params.add(Couple.of("attachment.value", attachment.getEncodedBytes()));
    }

    return params;
  }

  private static String readFrom(InputStream is) throws IOException {
    ByteArrayOutputStream out = new ByteArrayOutputStream();
    int c;
    while ((c = is.read()) != -1) {
      out.write(c);
    }
    String s = out.toString();
    out.close();
    return s;
  }

  private static String format(Calendar calendar) {
    return calendar == null ?  null : Long.toString(calendar.getTime().getTime());
  }

  private static HttpURLConnection post(URL url, byte[] bytes) throws IOException {
    HttpURLConnection connection = (HttpURLConnection)HttpConfigurable.getInstance().openConnection(url.toString());

    connection.setReadTimeout(10 * 1000);
    connection.setConnectTimeout(10 * 1000);
    connection.setRequestMethod(HTTP_POST);
    connection.setDoInput(true);
    connection.setDoOutput(true);
    connection.setRequestProperty(HTTP_CONTENT_TYPE, String.format("%s; charset=%s", HTTP_WWW_FORM, ENCODING));
    connection.setRequestProperty(HTTP_CONTENT_LENGTH, Integer.toString(bytes.length));

    OutputStream out = new BufferedOutputStream(connection.getOutputStream());
    try {
      out.write(bytes);
      out.flush();
    } finally {
      out.close();
    }

    return connection;
  }

  private static byte[] join(List<Couple<String>> params) throws UnsupportedEncodingException {
    StringBuilder builder = new StringBuilder();

    Iterator<Couple<String>> it = params.iterator();

    while (it.hasNext()) {
      Couple<String> param = it.next();

      if (StringUtil.isEmpty(param.first))
        throw new IllegalArgumentException(param.toString());

      if (StringUtil.isNotEmpty(param.second))
        builder.append(param.first).append("=").append(URLEncoder.encode(param.second, ENCODING));

      if (it.hasNext())
        builder.append(POST_DELIMITER);
    }

    return builder.toString().getBytes();
  }
}