emotionhero/app/src/main/java/com/rubenvandeven/emotionhero/ApiRestClient.java

package com.rubenvandeven.emotionhero;

import android.content.Context;
import android.util.Log;

import com.loopj.android.http.AsyncHttpClient;
import com.loopj.android.http.AsyncHttpResponseHandler;
import com.loopj.android.http.JsonHttpResponseHandler;
import com.loopj.android.http.RequestParams;
import com.loopj.android.http.SyncHttpClient;

import org.json.JSONException;
import org.json.JSONObject;

import cz.msebera.android.httpclient.Header;
import cz.msebera.android.httpclient.HeaderElement;
import cz.msebera.android.httpclient.ParseException;

/**
 * Created by ruben on 01/09/16.
 *
 * A way to interact with api.emotionhero.com
 */

public class ApiRestClient {
    private static final String BASE_URL = "http://api.emotionhero.com"; // TODO: https!

    private static AsyncHttpClient client = new AsyncHttpClient();
    private static SyncHttpClient syncClient = new SyncHttpClient();

    private String jwt;

    private Player player;

    public ApiRestClient(Player player) {
        this.player = player;
    }

    public void registerIfNeeded() {
        if(player.getJWT() == null) {
            requestWithJWT(null, null, null, null);
        }
    }

    /**
     * For now call register endpoint. Given JWT should have a long enough lifetime (for now)
     * @todo However, custom token endpoint should be used eventually
     * @param method
     * @param url
     * @param params
     * @param responseHandler
     */
    public void requestWithJWT(final String method, final String url, final RequestParams params, final AsyncHttpResponseHandler responseHandler) {
        // sync call, so we can return a value!
        client.post(BASE_URL + "/api/register", null, new JsonHttpResponseHandler() {
            @Override
            public void onSuccess(int statusCode, Header[] headers, JSONObject response) {
                // If the response is JSONObject instead of expected JSONArray
                try {
                    String token = response.getString("jwt");
                    String remoteId = response.getString("id");
                    Log.d("API", "Token " + token);
                    Log.d("API", "RemoteId" + remoteId);
                    getPlayer().setJWT(token);
                    getPlayer().setRemoteId(remoteId);

                    if(method != null) {
                        ApiRestClient.this.request( method, url, params, responseHandler);
                    }
                } catch (JSONException e) {
//                    responseHandler.sendFailureMessage(500, null, null);
                    // failure!!
                    // retrying later probably....
                    Log.e("API", "Failed request");
                    e.printStackTrace();
                }
            }
        });
    }

    public Player getPlayer() {
        return player;
    }

    class TokenHeader implements Header {
        /**
         * Get the name of the Header.
         *
         * @return the name of the Header,  never {@code null}
         */
        @Override
        public String getName() {
            return "X-Access-Token";
        }

        /**
         * Get the value of the Header.
         *
         * @return the value of the Header,  may be {@code null}
         */
        @Override
        public String getValue() {
            return "Bearer " + player.getJWT();
        }

        /**
         * Parses the value.
         *
         * @return an array of {@link HeaderElement} entries, may be empty, but is never {@code null}
         * @throws ParseException
         */
        @Override
        public HeaderElement[] getElements() throws ParseException {
            return new HeaderElement[]{};
        }
    }

    public void request(String method, String url, RequestParams params, AsyncHttpResponseHandler responseHandler) {
        Header[] headers = new Header[]{new TokenHeader()};
        Log.d("API", "Do request to: " + url);
        if(method == "post") {
            client.post(player.getContext(), url, headers,params,"application/json", responseHandler);
        } else {
            client.get(player.getContext(), url, headers, params, responseHandler);
        }
    }

    public void get(String url, RequestParams params, AsyncHttpResponseHandler responseHandler) {
        String jwt = player.getJWT();
        if(jwt != null) {
            request("get", getAbsoluteUrl(url), params, responseHandler);
        } else {
            requestWithJWT("get", getAbsoluteUrl(url), params, responseHandler);
        }
    }

    public void post(String url, RequestParams params, AsyncHttpResponseHandler responseHandler) {
        String jwt = player.getJWT();
        if(jwt != null) {
            request("post", getAbsoluteUrl(url), params, responseHandler);
        } else {
            requestWithJWT("post", getAbsoluteUrl(url), params, responseHandler);
        }
    }

    private static String getAbsoluteUrl(String relativeUrl) {
        return BASE_URL + relativeUrl;
    }
}