269 lines
7.8 KiB
Java
269 lines
7.8 KiB
Java
package model;
|
|
|
|
import java.io.UnsupportedEncodingException;
|
|
import java.text.ParseException;
|
|
import java.util.ArrayList;
|
|
import java.util.Date;
|
|
import java.util.HashMap;
|
|
|
|
import org.json.JSONArray;
|
|
import org.json.JSONException;
|
|
import org.json.JSONObject;
|
|
|
|
import Classes.ApiCall;
|
|
import Classes.Category;
|
|
import Classes.Event;
|
|
import Classes.SortTypes;
|
|
import Interfaces.Callback;
|
|
import Interfaces.DelayedCallback;
|
|
import Interfaces.EventObserver;
|
|
import Interfaces.Observable;
|
|
import javafx.util.Pair;
|
|
|
|
public class NewsListModel implements Observable{
|
|
|
|
//instance du singleton
|
|
private static NewsListModel instance;
|
|
|
|
//Clé d'API
|
|
private String APIKey;
|
|
//catégorie choise parl'utilisateur
|
|
private Category cat = Category.all;
|
|
//est ce que le modele est en train de récupérer les sources
|
|
private Boolean isRetreivingSources = false;
|
|
//est ce que l'api a rencontré une erreur
|
|
private Boolean apiError = false;
|
|
//liste des sources
|
|
private ArrayList<String> sources;
|
|
//liste des observers
|
|
private HashMap<String,EventObserver> observers;
|
|
//liste des news finale
|
|
private ArrayList<NewsModel> news;
|
|
//critère de tri
|
|
private SortTypes sortType = SortTypes.relevancy;
|
|
//critère de recherche de l'utilisateur
|
|
private String query = "";
|
|
|
|
private NewsListModel(String APIKey) {
|
|
this.APIKey = APIKey;
|
|
//comme la liste des sources retournée par l'API est de 20 éléments max, pas la peine de déclarer une arraylist sans borne
|
|
this.sources = new ArrayList<String>(20);
|
|
this.observers = new HashMap<String,EventObserver>();
|
|
this.news = new ArrayList<NewsModel>();
|
|
}
|
|
|
|
public static NewsListModel getInstance() {
|
|
if(NewsListModel.instance == null) {
|
|
NewsListModel.instance = new NewsListModel("0e72f765c5c84313ae31a5a7e9e61735");
|
|
}
|
|
|
|
return NewsListModel.instance;
|
|
}
|
|
|
|
public void setCategory(Category cat) {
|
|
|
|
if(cat == Category.all) {
|
|
this.sources = null;
|
|
this.cat = cat;
|
|
return;
|
|
}
|
|
|
|
//on vide la liste des sources
|
|
this.sources = new ArrayList<String>(20);
|
|
this.cat = cat;
|
|
//on créé l'URL d'appel de l'API
|
|
String lang = LangModel.getInstance().getToLang().name();
|
|
String URL = "http://beta.newsapi.org/v2/sources?language="+lang;
|
|
|
|
//on rajoute la catégorie
|
|
if(cat != Category.all) {
|
|
URL += "&category="+cat.name();
|
|
}
|
|
|
|
//on rajoute la clé d'api
|
|
URL += "&apiKey="+this.APIKey;
|
|
|
|
//création de l'appel
|
|
ApiCall api = new ApiCall(URL,"GET",new Callback() {
|
|
|
|
@Override
|
|
public void onSuccess(JSONObject response) {
|
|
//on récupère toutes les sources (dans la limite de 20 sources)
|
|
JSONArray arr = response.getJSONArray("sources");
|
|
for(int i = 0;i<arr.length() && i<20;i++) {
|
|
NewsListModel.this.sources.add(((JSONObject)arr.get(i)).getString("id"));
|
|
}
|
|
NewsListModel.this.isRetreivingSources = false;
|
|
NewsListModel.this.apiError = false;
|
|
//tout s'est bien passé, on peut notifier du succès
|
|
NewsListModel.this.notifyObservers(new Event("NewsModel","SourcesUpdated"));
|
|
|
|
}
|
|
|
|
@Override
|
|
public void onError() {
|
|
//on notifie de l'échec et on garde en mémoire le fait que l'on a échoué (afin d'annuler la recherche de news qui va suivre)
|
|
NewsListModel.this.isRetreivingSources = false;
|
|
NewsListModel.this.apiError = true;
|
|
NewsListModel.this.notifyObservers(new Event("NewsModel","SourcesUpdateFailed"));
|
|
|
|
}
|
|
|
|
});
|
|
this.isRetreivingSources = true;
|
|
api.send();
|
|
}
|
|
|
|
public Category getCategory() {
|
|
return this.cat;
|
|
}
|
|
|
|
public void query(String q) {
|
|
//si la recherche de source s'est fini avec une erreur, pas la peine de chercher des articles
|
|
if(this.apiError) {
|
|
NewsListModel.this.notifyObservers(new Event("NewsModel","NewsQueryFailed"));
|
|
this.apiError = false;
|
|
return;
|
|
}
|
|
|
|
final String encodedQuery;
|
|
try {
|
|
encodedQuery = java.net.URLEncoder.encode(q,"UTF-8");
|
|
} catch (UnsupportedEncodingException e1) {
|
|
this.notifyObservers(new Event("NewsModel","NewsQueryFailed"));
|
|
return;
|
|
}
|
|
//on créer l'URL de l'appel
|
|
String lang = LangModel.getInstance().getToLang().name();
|
|
String URL = "http://beta.newsapi.org/v2/everything?apiKey="+this.APIKey+"&language="+lang+"&q="+encodedQuery+"&sortBy="+this.sortType.name();
|
|
|
|
//on ajoute la liste des sources a l'URL de la requete
|
|
if(NewsListModel.this.sources != null && NewsListModel.this.sources.size() != 0) {
|
|
String sources = "&sources=";
|
|
for(String s : NewsListModel.this.sources) {
|
|
sources += s+",";
|
|
}
|
|
//on enlève la dernière virgule
|
|
sources = sources.replaceAll(",$", "");
|
|
URL += sources;
|
|
}
|
|
|
|
ApiCall api = new ApiCall(URL,"GET",new Callback() {
|
|
|
|
@Override
|
|
public void onSuccess(JSONObject response) {
|
|
//on parcours le JSON en créant les objets NewsModel corespondant
|
|
NewsListModel.this.news = new ArrayList<NewsModel>();
|
|
JSONArray arr = response.getJSONArray("articles");
|
|
for(int i = 0;i<arr.length();i++) {
|
|
JSONObject jsonNews = (JSONObject)arr.get(i);
|
|
NewsModel news = new NewsModel();
|
|
|
|
news.setAuthor(jsonNews.getString("author"))
|
|
.setDescription(jsonNews.getString("description"))
|
|
.setTitle(jsonNews.getString("title"))
|
|
.setNewsURL(jsonNews.getString("url"))
|
|
.setImageURL(jsonNews.getString("urlToImage"))
|
|
.setSource(jsonNews.getJSONObject("source").getString("name"))
|
|
.addTag(NewsListModel.this.cat);
|
|
|
|
try {
|
|
news.setDate(jsonNews.getString("publishedAt"));
|
|
}catch (ParseException e) {
|
|
news.setDate(new Date());
|
|
}
|
|
|
|
NewsListModel.this.news.add(news);
|
|
}
|
|
|
|
NewsListModel.this.query = q;
|
|
//ne pas oublier d'enlever l'api des observer, sinon il y a des risques de récurrence
|
|
NewsListModel.this.removeObserver("newsApiCall");
|
|
NewsListModel.this.notifyObservers(new Event("NewsModel","NewsQuerySuccess"));
|
|
|
|
}
|
|
|
|
@Override
|
|
public void onError() {
|
|
//L'appel a échoué :(
|
|
System.out.println("Error");
|
|
NewsListModel.this.removeObserver("newsApiCall");
|
|
NewsListModel.this.notifyObservers(new Event("NewsModel","NewsQueryFailed"));
|
|
}
|
|
|
|
});
|
|
|
|
//on delay uniquement si on est en train de récupérer les sources
|
|
if(this.isRetreivingSources) {
|
|
api.setAsDelayedCall("NewsModel", "SourcesUpdated", new DelayedCallback() {
|
|
|
|
@Override
|
|
public Pair<String, HashMap<String, String>> call() {
|
|
//si l'appel d'api précédent a échoué, on fait échouer l'appel actuel avec une URL vide
|
|
if(NewsListModel.this.apiError) {
|
|
//on reset la variable d'erreur pour que l'utilisateur puisse re-essayer plus tard
|
|
NewsListModel.this.apiError = false;
|
|
return new Pair<String,HashMap<String,String>>("",null);
|
|
}
|
|
|
|
String lang = LangModel.getInstance().getToLang().name();
|
|
String URL = "http://beta.newsapi.org/v2/everything?apiKey="+NewsListModel.this.APIKey+"&language="+lang
|
|
+"&q="+encodedQuery+"&sortBy="+NewsListModel.this.sortType.name();
|
|
|
|
//on ajoute la liste des sources a l'URL de la requete
|
|
if(NewsListModel.this.sources != null && NewsListModel.this.sources.size() != 0) {
|
|
String sources = "&sources=";
|
|
for(String s : NewsListModel.this.sources) {
|
|
sources += s+",";
|
|
}
|
|
//on enlève la dernière virgule
|
|
sources = sources.replaceAll(",$", "");
|
|
URL += sources;
|
|
}
|
|
|
|
return new Pair<String,HashMap<String,String>>(URL,null);
|
|
}
|
|
|
|
});
|
|
|
|
this.addObserver("newsApiCall",api);
|
|
}
|
|
|
|
api.send();
|
|
}
|
|
|
|
public void setSortType(SortTypes t) {
|
|
this.sortType = t;
|
|
this.query(this.query);
|
|
}
|
|
|
|
public void notifyObservers(Event e) {
|
|
for(Object key : this.observers.keySet().toArray()) {
|
|
this.observers.get(key).handleEvent(e);
|
|
}
|
|
}
|
|
|
|
|
|
public String getQuery() {
|
|
return this.query;
|
|
}
|
|
|
|
public ArrayList<NewsModel> getNews(){
|
|
return this.news;
|
|
}
|
|
|
|
@Override
|
|
public void addObserver(String key, EventObserver o) {
|
|
this.observers.put(key, o);
|
|
|
|
}
|
|
|
|
@Override
|
|
public void removeObserver(String key) {
|
|
this.observers.remove(key);
|
|
|
|
}
|
|
|
|
|
|
}
|