package com.emer.beneficiary.endpoints.user_profile.repository;

import static com.emer.beneficiary.app.Urls.*;

import android.content.*;
import android.util.*;

import com.android.volley.*;
import com.android.volley.toolbox.*;
import com.emer.beneficiary.app.*;
import com.emer.beneficiary.endpoints.user_profile.callback.*;
import com.emer.beneficiary.model.*;

import org.json.*;

import java.util.*;

public class UserProfileRepositoryImpl implements UserProfileRepository {

    private final Context activity;
    private final ProviderPreferences preferences;

    public UserProfileRepositoryImpl(Context activity, ProviderPreferences preferences) {
        this.activity = activity;
        this.preferences = preferences;
    }

    @Override
    public void attemptGetData(UserProfileCallback callback)
    {
        RequestQueue queue = Volley.newRequestQueue(activity);

        StringRequest stringRequest = new StringRequest(Request.Method.GET, URL_getUserProfile, new Response.Listener<String>() {
            @Override
            public void onResponse(String rta)
            {
                try
                {
                    JSONArray jsonArray = new JSONArray(rta);
                    HashMap<String, UserProfile> map = new HashMap<>();
                    for (int i=0;i<jsonArray.length();i++)
                    {
                        JSONObject jsonObject = jsonArray.getJSONObject(i);
                        String key = jsonObject.keys().next().toString();
                        UserProfile userProfile = new UserProfile();
                        userProfile.setValue(jsonObject.getString(key));
                        userProfile.setStatus(Integer.parseInt(jsonObject.getString("id_status")));
                        map.put(key,userProfile);
                        Log.d("attemptGetData",key + " "+userProfile.toString());
                    }
                    callback.onGetDataSucceeded(map);
                }
                catch (Exception e)
                {
                    e.printStackTrace();
                    callback.onGetDataSucceeded(null);
                }
            }

            boolean isSingle(String key)
            {
                if ((key.equals("identification_type"))||(key.equals("health_insurance")))
                {
                    return false;
                }
                else
                {
                    return true;
                }
            }
        }, new Response.ErrorListener() {
            @Override
            public void onErrorResponse(VolleyError error)
            {
                error.printStackTrace();
                callback.onGetDataSucceeded(null);
            }
        })
        {
            @Override
            public Map<String, String> getHeaders() throws AuthFailureError
            {
                Map<String,String> params = new HashMap<String, String>();
                params.put(Params.authorization,preferences.getAccessTokenBearer());
                return params;
            }
        };

        queue.add(stringRequest);
    }

    @Override
    public void attemptPutData(UserProfileCallback callback, HashMap<String, UserProfile> map)
    {
        RequestQueue queue = Volley.newRequestQueue(activity);
        JSONArray ja = new JSONArray();

        try
            {
                JSONObject jsonObject = new JSONObject();
                jsonObject.put("first_use","true");
                ja.put(jsonObject);

                Iterator iterator = map.entrySet().iterator();
                while (iterator.hasNext())
                {
                    JSONObject jsonObject1 = new JSONObject();
                    Map.Entry<String, UserProfile> profileMap = (Map.Entry<String, UserProfile>) iterator.next();
                    jsonObject1.put(profileMap.getKey(),profileMap.getValue().getValor());
                    jsonObject1.put("id_status",profileMap.getValue().getStatus());
                    ja.put(jsonObject1);
                }

                Log.d("attemptPutData",ja.toString());
            }
            catch (Exception exception)
            {
                exception.printStackTrace();
            }


        JsonArrayRequest stringRequest = new JsonArrayRequest(Request.Method.PUT, URL_putUserProfile, ja, new Response.Listener<JSONArray>() {
            @Override
            public void onResponse(JSONArray rta)
            {
                try
                {
                    JSONObject jsonObject1 = rta.getJSONObject(0);
                    ServerResponseUser response = new ServerResponseUser(jsonObject1.toString());
                    if (response.getCode() == 201)
                    {
                        callback.onPutDataSucceeded(response.getMessage());
                    }
                    else
                    {
                        callback.onPutDataSucceeded(response.getCode()+" "+response.getError());
                    }
                }
                catch (Exception e)
                {
                    e.printStackTrace();
                    callback.onPutDataSucceeded("Error");
                }
            }

        }, new Response.ErrorListener() {
            @Override
            public void onErrorResponse(VolleyError error)
            {
                error.printStackTrace();
                NetworkResponse networkResponse = error.networkResponse;
                if (networkResponse != null && networkResponse.data != null)
                {
                    if (error.networkResponse.statusCode == 400)
                    {
                        String jsonError = new String(networkResponse.data);
                        ServerResponseUser serverResponseUser = new ServerResponseUser(jsonError);
                        callback.onPutDataSucceeded(serverResponseUser.getError()+" "+serverResponseUser.getMessage());
                    }
                    else
                    {
                        callback.onPutDataSucceeded(""+error.networkResponse.statusCode);
                    }
                }
            }
        })
        {
            @Override
            public Map<String, String> getHeaders() throws AuthFailureError
            {
                Map<String,String> params = new HashMap<String, String>();
                params.put(Params.authorization,preferences.getAccessTokenBearer());
                return params;
            }

            @Override
            protected Response<JSONArray> parseNetworkResponse(NetworkResponse response) {
                try
                {
                    String jsonString = new String(response.data, HttpHeaderParser.parseCharset(response.headers, PROTOCOL_CHARSET));
                    Log.d("data",jsonString);
                    JSONArray ja = new JSONArray();
                    ja.put(new JSONObject(jsonString));
                    return Response.success(ja, HttpHeaderParser.parseCacheHeaders(response));
                } catch (Exception e) {
                    return Response.error(new ParseError(e));

                }
            }

        };
        queue.add(stringRequest);
    }
}
package com.emer.beneficiary.endpoints.user_profile.repository;

import static com.emer.beneficiary.app.Urls.*;

import android.content.*;
import android.util.*;

import com.android.volley.*;
import com.android.volley.toolbox.*;
import com.emer.beneficiary.app.*;
import com.emer.beneficiary.endpoints.user_profile.callback.*;
import com.emer.beneficiary.model.*;

import org.json.*;

import java.util.*;

public class UserProfileRepositoryImpl implements UserProfileRepository {

    private final Context activity;
    private final ProviderPreferences preferences;

    public UserProfileRepositoryImpl(Context activity, ProviderPreferences preferences) {
        this.activity = activity;
        this.preferences = preferences;
    }

    @Override
    public void attemptGetData(UserProfileCallback callback)
    {
        RequestQueue queue = Volley.newRequestQueue(activity);

        StringRequest stringRequest = new StringRequest(Request.Method.GET, URL_getUserProfile, new Response.Listener<String>() {
            @Override
            public void onResponse(String rta)
            {
                try
                {
                    JSONArray jsonArray = new JSONArray(rta);
                    HashMap<String, UserProfile> map = new HashMap<>();
                    for (int i=0;i<jsonArray.length();i++)
                    {
                        JSONObject jsonObject = jsonArray.getJSONObject(i);
                        String key = jsonObject.keys().next().toString();
                        UserProfile userProfile = new UserProfile();
                        userProfile.setValue(jsonObject.getString(key));
                        userProfile.setStatus(Integer.parseInt(jsonObject.getString("id_status")));
                        map.put(key,userProfile);
                        Log.d("attemptGetData",key + " "+userProfile.toString());
                    }
                    callback.onGetDataSucceeded(map);
                }
                catch (Exception e)
                {
                    e.printStackTrace();
                    callback.onGetDataSucceeded(null);
                }
            }

            boolean isSingle(String key)
            {
                if ((key.equals("identification_type"))||(key.equals("health_insurance")))
                {
                    return false;
                }
                else
                {
                    return true;
                }
            }
        }, new Response.ErrorListener() {
            @Override
            public void onErrorResponse(VolleyError error)
            {
                error.printStackTrace();
                callback.onGetDataSucceeded(null);
            }
        })
        {
            @Override
            public Map<String, String> getHeaders() throws AuthFailureError
            {
                Map<String,String> params = new HashMap<String, String>();
                params.put(Params.authorization,preferences.getAccessTokenBearer());
                return params;
            }
        };

        queue.add(stringRequest);
    }

    @Override
    public void attemptPutData(UserProfileCallback callback, HashMap<String, UserProfile> map)
    {
        RequestQueue queue = Volley.newRequestQueue(activity);
        JSONArray ja = new JSONArray();

        try
            {
                JSONObject jsonObject = new JSONObject();
                jsonObject.put("first_use","true");
                ja.put(jsonObject);

                Iterator iterator = map.entrySet().iterator();
                while (iterator.hasNext())
                {
                    JSONObject jsonObject1 = new JSONObject();
                    Map.Entry<String, UserProfile> profileMap = (Map.Entry<String, UserProfile>) iterator.next();
                    jsonObject1.put(profileMap.getKey(),profileMap.getValue().getValor());
                    jsonObject1.put("id_status",profileMap.getValue().getStatus());
                    ja.put(jsonObject1);
                }

                Log.d("attemptPutData",ja.toString());
            }
            catch (Exception exception)
            {
                exception.printStackTrace();
            }


        JsonArrayRequest stringRequest = new JsonArrayRequest(Request.Method.PUT, URL_putUserProfile, ja, new Response.Listener<JSONArray>() {
            @Override
            public void onResponse(JSONArray rta)
            {
                try
                {
                    JSONObject jsonObject1 = rta.getJSONObject(0);
                    ServerResponseUser response = new ServerResponseUser(jsonObject1.toString());
                    if (response.getCode() == 201)
                    {
                        callback.onPutDataSucceeded(response.getMessage());
                    }
                    else
                    {
                        callback.onPutDataSucceeded(response.getCode()+" "+response.getError());
                    }
                }
                catch (Exception e)
                {
                    e.printStackTrace();
                    callback.onPutDataSucceeded("Error");
                }
            }

        }, new Response.ErrorListener() {
            @Override
            public void onErrorResponse(VolleyError error)
            {
                error.printStackTrace();
                NetworkResponse networkResponse = error.networkResponse;
                if (networkResponse != null && networkResponse.data != null)
                {
                    if (error.networkResponse.statusCode == 400)
                    {
                        String jsonError = new String(networkResponse.data);
                        ServerResponseUser serverResponseUser = new ServerResponseUser(jsonError);
                        callback.onPutDataSucceeded(serverResponseUser.getError()+" "+serverResponseUser.getMessage());
                    }
                    else
                    {
                        callback.onPutDataSucceeded(""+error.networkResponse.statusCode);
                    }
                }
            }
        })
        {
            @Override
            public Map<String, String> getHeaders() throws AuthFailureError
            {
                Map<String,String> params = new HashMap<String, String>();
                params.put(Params.authorization,preferences.getAccessTokenBearer());
                return params;
            }

            @Override
            protected Response<JSONArray> parseNetworkResponse(NetworkResponse response) {
                try
                {
                    String jsonString = new String(response.data, HttpHeaderParser.parseCharset(response.headers, PROTOCOL_CHARSET));
                    Log.d("data",jsonString);
                    JSONArray ja = new JSONArray();
                    ja.put(new JSONObject(jsonString));
                    return Response.success(ja, HttpHeaderParser.parseCacheHeaders(response));
                } catch (Exception e) {
                    return Response.error(new ParseError(e));

                }
            }

        };
        queue.add(stringRequest);
    }
}