public class ServersRequests {
ProgressDialog progressDialog;
public static final int CONNECTION_TIMEOUT = 15000;
public static final String SERVER_ADDRESS="";
public ServersRequests(Context context){
progressDialog = new ProgressDialog(context);
progressDialog.setCancelable(false);
progressDialog.setTitle("Processing");
progressDialog.setMessage("Please wait..");
}
public void storeDataInBackground(User user, GetUserCallback callback){
progressDialog.show();
new StoreDataAsyncTask(user, callback).execute();
}
public void fetchDataInBackground (User user, GetUserCallback callback){
progressDialog.show();
new FetchDataAsyncTask(user,callback).execute();
}
public class StoreDataAsyncTask extends AsyncTask<Void, Void, Void> {
User user;
GetUserCallback callback;
public StoreDataAsyncTask (User user, GetUserCallback callback) {
this.user = user;
this.callback = callback;
}
@Override
protected Void doInBackground(Void... voids) {
ArrayList<NameValuePair> data_to_send= new ArrayList<>();
data_to_send.add(new BasicNameValuePair("Name", user.name));
data_to_send.add(new BasicNameValuePair("Last Name", user.last_name));
data_to_send.add(new BasicNameValuePair("Email", user.email));
data_to_send.add(new BasicNameValuePair("Password", user.password));
HttpParams httpRequestParams = new BasicHttpParams();
HttpConnectionParams.setConnectionTimeout(httpRequestParams, CONNECTION_TIMEOUT);
HttpConnectionParams.setSoTimeout(httpRequestParams, CONNECTION_TIMEOUT);
HttpClient client = new DefaultHttpClient(httpRequestParams);
HttpPost post = new HttpPost(SERVER_ADDRESS + "register.php" );
try {
post.setEntity(new UrlEncodedFormEntity(data_to_send));
client.execute(post);
}
catch (Exception e){
e.printStackTrace();
}
return null;
}
@Override
protected void onPostExecute(Void aVoid) {
progressDialog.dismiss();
callback.done(null);
super.onPostExecute(aVoid);
}
}
public class FetchDataAsyncTask extends AsyncTask<Void, Void, User>{
User user;
GetUserCallback callback;
public FetchDataAsyncTask (User user, GetUserCallback callback){
this.user=user;
this.callback=callback;
}
@Override
protected User doInBackground(Void... voids) {
ArrayList<NameValuePair> data_to_send= new ArrayList<>();
data_to_send.add(new BasicNameValuePair("Email", user.email));
data_to_send.add(new BasicNameValuePair("Password", user.password));
HttpParams httpRequestParams = new BasicHttpParams();
HttpConnectionParams.setConnectionTimeout(httpRequestParams, CONNECTION_TIMEOUT);
HttpConnectionParams.setSoTimeout(httpRequestParams, CONNECTION_TIMEOUT);
HttpClient client = new DefaultHttpClient(httpRequestParams);
HttpPost post = new HttpPost(SERVER_ADDRESS + "fetchUserData.php" );
User returnedUser = null;
try {
post.setEntity(new UrlEncodedFormEntity(data_to_send));
HttpResponse httpResponse = client.execute(post);
HttpEntity entity = httpResponse.getEntity();
String result= EntityUtils.toString(entity);
JSONObject jsonObject= new JSONObject(result);
if(jsonObject.length() == 0){
returnedUser = null;
}
else{
String name,last_name;
name=null;
last_name=null;
if(jsonObject.has("name"))
name=jsonObject.getString("name");
if(jsonObject.has("last_name"))
last_name=jsonObject.getString("last_name");
returnedUser = new User(name,last_name, user.email,user.password );
}
}
catch (Exception e){
e.printStackTrace();
}
return returnedUser;
}
@Override
protected void onPostExecute(User returnedUser) {
progressDialog.dismiss();
callback.done(returnedUser);
super.onPostExecute(returnedUser);
}
}
}