package osm.jp.api;

import java.net.*;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import java.io.*;

/**
 * Java HTTP クライアントサンプル - HttpURLConnection 版 -
 *
 * @author 68user http://X68000.q-e-d.net/~68user/
 */
public class HttpPOST {
    //public static String host = "http://api06.dev.openstreetmap.org";
    //public static String host = "http://api.openstreetmap.org";
    public static String host = "http://overpass-api.de";
    public static final String EXIST_FILE = "exist.osm.xml";

    public static void main(String[] args) throws MalformedURLException, ProtocolException, IOException {
        double minlat = 35.13d;
        double maxlat = 35.66d;
        double minlon = 138.99d;
        double maxlon = 139.79d;
        //getCapabilities(new File("output.xml"), "highway", "bus_stop", minlat, maxlat, minlon, maxlon);
        //getCapabilities(new File("output.xml"), "highway", "disused:bus_stop", minlat, maxlat, minlon, maxlon);
        //getCapabilities(new File("output.xml"), "amenity", "bus_station", minlat, maxlat, minlon, maxlon);
        //getCapabilities(new File("output.xml"), "public_transport", "platform", minlat, maxlat, minlon, maxlon);
        getCapabilities("public_transport", "stop_position", minlat, maxlat, minlon, maxlon, "node");
        getCapabilities("amenity", "fuel", minlat, maxlat, minlon, maxlon, "way");
    }
	
    public static void getCapabilities(String key, String value, double minLat, double maxLat, double minLon, double maxLon) throws MalformedURLException, ProtocolException, IOException {
        getCapabilities(key, value, minLat, maxLat, minLon, maxLon, "node");
    }

    public static void getCapabilities(String key, String value, double minLat, double maxLat, double minLon, double maxLon, String type) throws MalformedURLException, ProtocolException, IOException {
        StringBuilder queryText = new StringBuilder();
        queryText.append("<osm-script timeout=\"900\" element-limit=\"1073741824\">");
        queryText.append(" <union>");
        queryText.append("  <query type=\""+ type +"\">");
        queryText.append("   <has-kv k=\""+ key +"\" v=\""+ value +"\"/>");
        queryText.append("   <bbox-query s=\"" + minLat + "\" n=\"" + maxLat + "\" w=\"" + minLon + "\" e=\"" + maxLon + "\"/>");
        queryText.append("  </query>");
        queryText.append(" </union>");
        queryText.append(" <print/>");
        queryText.append("</osm-script>");
        getQuery(queryText.toString());
    }

    /**
     *
     * @param queryText クエリテキスト（Overpass_API/Overpass_QL）
     * @throws MalformedURLException
     * @throws ProtocolException
     * @throws IOException
     */
    public static void getQuery(String queryText) throws MalformedURLException, ProtocolException, IOException {
        System.out.println(host + "/api/interpreter");
        URL url = new URL(host + "/api/interpreter");
        int responsecode = 0;

        do {
            HttpURLConnection urlconn = (HttpURLConnection)url.openConnection();
            urlconn.setRequestMethod("POST");
            urlconn.setDoOutput(true);              		// POSTのデータを後ろに付ける
            urlconn.setInstanceFollowRedirects(false);		// 勝手にリダイレクトさせない
            urlconn.setRequestProperty("Accept-Language", "ja;q=0.7,en;q=0.3");
            urlconn.setRequestProperty("Content-Type","text/xml;charset=utf-8");
            urlconn.connect();

            try (PrintWriter pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(urlconn.getOutputStream(), "utf-8")))) {
                outputWriter(pw, queryText);
                pw.flush();
            }

            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {}

            responsecode = urlconn.getResponseCode();
            System.out.println("レスポンスコード[" + responsecode + "] " +
                               "レスポンスメッセージ[" + urlconn.getResponseMessage() + "]");
            Map<String,List<String>> headers = urlconn.getHeaderFields();
            for (Map.Entry<String, List<String>> bar : headers.entrySet()) {
                System.out.print("\t" + bar.getKey() +"\t: ");  // キーを取得
                List<String> vals = bar.getValue();  // 値を取得
                for(String str : vals) {
                    System.out.print("["+ str +"],");
                }
                System.out.println();
            }
            if ((responsecode == 429) || (responsecode == 504) || (responsecode == 500)) {
                // レスポンスコード[429] レスポンスメッセージ[Too Many Requests]
                // レスポンスコード[500] レスポンスメッセージ[Internal server error]
                // レスポンスコード[504] レスポンスメッセージ[Gateway Timeout]
                try {
                    TimeUnit.MINUTES.sleep(5);
                } catch (InterruptedException e) {}
            }
            else {
                System.out.println("\n---- ボディ ----");
                
                File oFile = new File(HttpPOST.EXIST_FILE);
                oFile.deleteOnExit();
                try (BufferedWriter hw = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(oFile), "UTF-8"))) {
                    try (BufferedReader reader = new BufferedReader(new InputStreamReader(urlconn.getInputStream(), "UTF-8"))) {
                        while (true) {
                            String line = reader.readLine();
                            if (line == null) {
                                break;
                            }
                            hw.write(line);
                            hw.newLine();
                        }
                        hw.flush();
                    }
                }
            }
            urlconn.disconnect();
            try {
                TimeUnit.SECONDS.sleep(5);
            } catch (InterruptedException e) {}
        }
        while ((responsecode == 429) || (responsecode == 504));
    }
	
    public static void outputWriter(PrintWriter pw, String text) {
        System.out.println("\t" + text);
        pw.print(text);
    }
}