Add api football files updater

2020-10-07 22:14:13 +02:00
parent bce0f3800c
commit f22f9a929b
18 changed files with 15808 additions and 1048 deletions
--- a/src/main/java/de/jeyp91/apifootball/APIFootballUpdater.java
+++ b/src/main/java/de/jeyp91/apifootball/APIFootballUpdater.java
@@ -0,0 +1,158 @@
+package de.jeyp91.apifootball;
+
+import com.google.common.io.Resources;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.ClientProtocolException;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.HttpClientBuilder;
+import org.json.simple.JSONArray;
+import org.json.simple.JSONObject;
+import org.json.simple.parser.JSONParser;
+import org.json.simple.parser.ParseException;
+
+import java.io.BufferedReader;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.net.URL;
+import java.nio.charset.StandardCharsets;
+import java.util.HashSet;
+
+public class APIFootballUpdater {
+
+    private int season;
+
+    public APIFootballUpdater(int season) {
+        this.season = season;
+    }
+
+    public void updateFixtures(int league) throws IOException {
+        String apiFootballUrl = "https://v2.api-football.com/fixtures/league/" + league + "?timezone=Europe/Berlin";
+        String content = getRawData(apiFootballUrl);
+        String resourcePath = this.season + "/API-Football/matches_league_" + league + ".json";
+        writeStringToFile(content, resourcePath);
+    }
+
+    public void updateAllFixtures(String configPath) throws IOException {
+        HashSet<Integer> leagues = getAllLeaguesFromLeagueConfig(configPath);
+        for (Integer league : leagues) {
+            updateFixtures(league);
+        }
+    }
+
+    private HashSet<Integer> getAllLeaguesFromLeagueConfig(String configPath) {
+
+        HashSet<Integer> leagues = new HashSet<>();
+
+        JSONParser jsonParser = new JSONParser();
+        URL url = Resources.getResource(season + "\\" + configPath);
+        String jsonConfig = null;
+        JSONObject configObject = null;
+        try {
+            jsonConfig = Resources.toString(url, StandardCharsets.UTF_8);
+            configObject = (JSONObject) jsonParser.parse(jsonConfig);
+        } catch (IOException | ParseException e) {
+            e.printStackTrace();
+        }
+
+        JSONArray matchdayConfigs = (JSONArray) configObject.get("matchdayConfig");
+        for (Object matchdayConfig : matchdayConfigs) {
+            JSONArray matchesConfig = (JSONArray) ((JSONObject) matchdayConfig).get("matchesConfig");
+            for (Object matchConfig : matchesConfig) {
+                if (((JSONObject) matchConfig).containsKey("matchesLeague")) {
+                    int league = Integer.parseInt(((JSONObject) matchConfig).get("matchesLeague").toString());
+                    leagues.add(league);
+                }
+                if (((JSONObject) matchConfig).containsKey("matchLeague")) {
+                    int league = Integer.parseInt(((JSONObject) matchConfig).get("matchLeague").toString());
+                    leagues.add(league);
+                }
+            }
+        }
+        return leagues;
+    }
+
+    private void writeStringToFile(String content, String resourcePath) throws IOException {
+        URL url = Resources.getResource(resourcePath);
+        FileWriter myWriter = new FileWriter(url.getPath());
+        myWriter.write(content);
+        myWriter.close();
+    }
+
+    private JSONArray getDataAsJSONArray(String requestUrl) {
+
+        String rawData = getRawData(requestUrl);
+        JSONParser parser = new JSONParser();
+        JSONArray data = null;
+        try {
+            data = (JSONArray) parser.parse(rawData);
+        } catch (ParseException e) {
+            /* TODO */
+            e.printStackTrace();
+        }
+        return data;
+    }
+
+    private JSONObject getDataAsJSONObject(String requestUrl) {
+
+        String rawData = getRawData(requestUrl);
+        JSONParser parser = new JSONParser();
+        JSONObject data = null;
+        try {
+            data = (JSONObject) parser.parse(rawData);
+        } catch (ParseException e) {
+            /* TODO */
+            e.printStackTrace();
+        }
+        return data;
+    }
+
+    String getRawData(String requestUrl) {
+
+        HttpClient client = HttpClientBuilder.create().build();
+        HttpGet request = new HttpGet(requestUrl);
+
+        // add request header
+        request.addHeader("X-RapidAPI-Key", "a607e6a7437d9d52f3ac73e0b2704d0b");
+
+        HttpResponse response = null;
+        try {
+            response = client.execute(request);
+        } catch (ClientProtocolException e) {
+            /* TODO */
+            e.printStackTrace();
+        } catch (IOException e) {
+            /* TODO */
+            e.printStackTrace();
+        }
+
+
+        BufferedReader rd = null;
+        try {
+            rd = new BufferedReader(
+                    new InputStreamReader(response.getEntity().getContent())
+            );
+        } catch (IOException e) {
+            /* TODO */
+            e.printStackTrace();
+        }
+
+        StringBuilder result = new StringBuilder();
+        String line = "";
+        while (true) {
+            try {
+                line = rd.readLine();
+            } catch (IOException e) {
+                /* TODO */
+                e.printStackTrace();
+            }
+
+            // Stop reading if last line was found.
+            if (line  == null) break;
+
+            result.append(line);
+        }
+        return result.toString();
+    }
+}