128 lines
4.0 KiB
Java
128 lines
4.0 KiB
Java
package de.jeyp91.apifootball;
|
|
|
|
import de.jeyp91.ResourceProvider;
|
|
import de.jeyp91.S3Provider;
|
|
import org.apache.http.HttpResponse;
|
|
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 java.io.*;
|
|
import java.util.HashSet;
|
|
|
|
public class APIFootballUpdater {
|
|
|
|
public APIFootballUpdater() {
|
|
|
|
}
|
|
|
|
public void updateFixtures(int league) throws Exception {
|
|
String apiFootballUrl = "https://v2.api-football.com/fixtures/league/" + league + "?timezone=Europe/Berlin";
|
|
String content = getRawData(apiFootballUrl);
|
|
S3Provider prov = new S3Provider();
|
|
prov.writeFixturesToS3(league, content);
|
|
}
|
|
|
|
public void updateAllFixtures() throws Exception {
|
|
HashSet<Integer> leagues = getLeagues();
|
|
for (Integer league : leagues) {
|
|
updateFixtures(league);
|
|
}
|
|
}
|
|
|
|
public void updateAllRounds() throws Exception {
|
|
HashSet<Integer> leagues = getLeagues();
|
|
for (Integer league : leagues) {
|
|
updateRounds(league);
|
|
}
|
|
}
|
|
|
|
public void updateRounds(int league) throws Exception {
|
|
String apiFootballUrl = "https://v2.api-football.com/fixtures/rounds/" + league;
|
|
String content = getRawData(apiFootballUrl);
|
|
S3Provider prov = new S3Provider();
|
|
prov.writeRoundsToS3(league, content);
|
|
}
|
|
|
|
public String getRawData(String requestUrl) throws Exception {
|
|
|
|
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 (IOException e) {
|
|
/* TODO */
|
|
e.printStackTrace();
|
|
}
|
|
|
|
BufferedReader rd = null;
|
|
try {
|
|
assert response != null;
|
|
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);
|
|
}
|
|
checkErrors(requestUrl, result.toString());
|
|
return result.toString();
|
|
}
|
|
|
|
public HashSet<Integer> getLeagues() {
|
|
JSONArray leaguesArray = ResourceProvider.getLigenConfig();
|
|
HashSet<Integer> leagues = new HashSet<>();
|
|
for (Object leagueObject : leaguesArray) {
|
|
JSONObject leagueJSONObject = (JSONObject) leagueObject;
|
|
Integer leagueId = ((Long) leagueJSONObject.get("league_id")).intValue();
|
|
leagues.add(leagueId);
|
|
}
|
|
return leagues;
|
|
}
|
|
|
|
public void checkErrors(String requestUrl, String result) throws Exception {
|
|
JSONObject resultObject = stringToJSONObject(result);
|
|
if(((JSONObject) resultObject.get("api")).containsKey("error")) {
|
|
String errorMessage = ((JSONObject) resultObject.get("api")).get("error").toString();
|
|
throw new Exception(requestUrl + " returned error: '" + errorMessage + "'");
|
|
}
|
|
}
|
|
|
|
private JSONObject stringToJSONObject(String rawData) {
|
|
|
|
JSONParser parser = new JSONParser();
|
|
JSONObject data = null;
|
|
try {
|
|
data = (JSONObject) parser.parse(rawData);
|
|
} catch (Exception e) {
|
|
/* TODO */
|
|
e.printStackTrace();
|
|
}
|
|
return data;
|
|
}
|
|
}
|