gistfile1.kt

    private class AccesoRemoto extends AsyncTask<Void, Void, String> {

        private MaterialDialog a;
        private Context context;
        private static final String SINGULARITY_HOST = "https://cloud.careyou.cl/api/";
        private RequestFuture<JSONObject> futureRequest = RequestFuture.newFuture();
        public AccesoRemoto(Context context) {
            this.context = context;
        }

        @Override
        protected void onPreExecute() {
            super.onPreExecute();


            a = new MaterialDialog(context);
            a.setCancelable(false);
            a.title(R.string.loading, context.getResources().getString(R.string.loading));
            a.message(R.string.loading, "     " + context.getResources().getString(R.string.loading) + "     ", false, 1.0f);

            int llPadding = 30;
            LinearLayout ll = new LinearLayout(context);
            ll.setOrientation(LinearLayout.HORIZONTAL);
            ll.setPadding(llPadding, llPadding, llPadding, llPadding);
            ll.setGravity(Gravity.CENTER);
            LinearLayout.LayoutParams llParam = new LinearLayout.LayoutParams(
                    LinearLayout.LayoutParams.WRAP_CONTENT,
                    LinearLayout.LayoutParams.WRAP_CONTENT);
            llParam.gravity = Gravity.CENTER;
            ll.setLayoutParams(llParam);

            ProgressBar progressBar = new  ProgressBar(context);
            progressBar.setIndeterminate(true);
            progressBar.setPadding(0, 0, llPadding, 0);
            progressBar.setLayoutParams( llParam);

            LinearLayout.LayoutParams  llParam_ = new LinearLayout.LayoutParams(
                    ViewGroup.LayoutParams.WRAP_CONTENT,
                    ViewGroup.LayoutParams.WRAP_CONTENT);
            llParam_.gravity = Gravity.CENTER;
            TextView tvText = new TextView(context);
            tvText.setText(context.getResources().getString(R.string.loading) + " ...");
            tvText.setTextColor(Color.parseColor("#000000"));
            tvText.setTextSize(18f);
            tvText.setLayoutParams(llParam_);

            ll.addView(progressBar);
            ll.addView(tvText);

            a.setContentView(ll);
                a.show();
        }

        protected String doInBackground(Void... argumentos) {
            String rut_final = numbers + dig_verification;


            try {
                if (numbers.length() == 0) {
                    Log.d("rut", "cero");
                }


            }catch ( java.lang.NullPointerException e){

                return "";
            }

            Log.d("rut",rut_final.replace(".", "").replace("-", ""));
            SharedPreference sharedPreference = SharedPreference.Companion.newInstance(context);
            LoadInfo loadInfo = LoadInfo.Companion.newInstance(context);

            String token = loadInfo.get_login_or_register_token();//StorageHandler.getAuthToken(context);

            futureRequest = RequestFuture.newFuture();
            RequestQueue   mQueue_ = CustomVolleyRequestQueue.Companion.getInstance(context.getApplicationContext()).getRequestQueue();
            JSONObject  jsonBody_ = new JSONObject();
            try {
                String first_name = nameTxt.getText().toString();
                String last_name = surnameTxt.getText().toString();
                int age = Integer.valueOf(ageTxt.getText().toString());
                String rut = rutTxt.getText().toString();
                jsonBody_.put("rut", rut_final.replace(".", "").replace("-", ""));
                jsonBody_.put("requestType", "REQUEST_EXISTING_USER");
                jsonBody_.put("region_name", region_name);
                jsonBody_.put("comuna_name", comuna_name);
                jsonBody_.put("serial", n_serie);
                jsonBody_.put("first_name", first_name);
                jsonBody_.put("last_name", last_name);
                jsonBody_.put("age", age);
                jsonBody_.put("rut", rut.replace(".", "").replace("-", ""));
                jsonBody_.put("serial",n_serie);
                jsonBody_.put("region_name", region_name);
                jsonBody_.put("comuna_name", comuna_name);
                Spinner genderSpn = findViewById(R.id.gender);
                jsonBody_.put("gender", genderSpn.getSelectedItem().toString());


            } catch (JSONException enn) {
                enn.printStackTrace();
            }
            Log.d("CHECK_EXIST",jsonBody_.toString());

            JsonObjectRequest jsonRequest = new JsonObjectRequest(Request.Method.POST, SINGULARITY_HOST + "rule-engine/", jsonBody_, futureRequest, futureRequest) {
                @Override
                public HashMap<String, String> getHeaders() {
                    //String token = chatService.get_token();
                    HashMap<String, String> params = new HashMap<>();
                    if (token.length() > 0) {
                        params.put("X-Authorization", "Bearer " + token);
                    }
                    params.put("Content-Type", "application/json;charset=UTF-8");
                    params.put("Charset", "UTF-8");
                    params.put("Accept", "application/json");

                    return params;
                }
            };
            jsonRequest.setTag("REQUEST_EXISTING_USER");

                JSONObject response =  ServerRestHandler.httpRequest_sync("POST", SINGULARITY_HOST + "rule-engine/", jsonBody_.toString(), token, false);//futureRequest.get(15, TimeUnit.SECONDS);
                Log.d("response",response.toString());


                try {
                    String status = response.getString("status");

                    if (status.equals("ERROR")) {
                        String reason = response.getString("reason");


                        if (reason.equals("Incorrect RUT or Serial N°")) {

                        } else if (reason.equals("User device not found")) {

                            futureRequest = RequestFuture.newFuture();
                            RequestQueue mQueue__ = CustomVolleyRequestQueue.Companion.getInstance(context.getApplicationContext()).getRequestQueue();
                            JSONObject jsonBody__ = new JSONObject();
                            try {
                                jsonBody__.put("rut", rut_final.replace(".", "").replace("-", ""));
                                jsonBody__.put("requestType", "CREATE_COVID_USER");
                                jsonBody__.put("serial",n_serie);
                                jsonBody__.put("region_name", region_name);
                                jsonBody__.put("comuna_name", comuna_name);
                            } catch (JSONException enn) {
                                enn.printStackTrace();
                            }
                            Log.d("REGISTER_USER", jsonBody__.toString());
                            JsonObjectRequest jsonRequest_ = new JsonObjectRequest(Request.Method.POST, SINGULARITY_HOST + "rule-engine/", jsonBody__, futureRequest, futureRequest) {
                                @Override
                                public HashMap<String, String> getHeaders() {
                                    //String token = chatService.get_token();
                                    HashMap<String, String> params = new HashMap<>();
                                    if (token.length() > 0) {
                                        params.put("X-Authorization", "Bearer " + token);
                                    }
                                    params.put("Content-Type", "application/json;charset=UTF-8");
                                    params.put("Charset", "UTF-8");
                                    params.put("Accept", "application/json");

                                    return params;
                                }
                            };
                            jsonRequest_.setTag("REQUEST_EXISTING_USER");
                            // jsonRequest.retryPolicy = DefaultRetryPolicy(15000, DefaultRetryPolicy.DEFAULT_MAX_RETRIES, DefaultRetryPolicy.DEFAULT_BACKOFF_MULT)
                            mQueue__.add(jsonRequest_);
                            try {

                                JSONObject response_exist_user = futureRequest.get(15, TimeUnit.SECONDS);
                                Log.d("response_create_user", response_exist_user.toString());
                                JSONObject customerId = response_exist_user.getJSONObject("customerId");
                                String id = customerId.getString("id");
                                StorageHandler.storeUserId(context, id);
                                sharedPreference.set_informatin_user(customerId.getString("id"), TAG_INFO.KEY_ID_USER);
                                UserProfile new_user = new UserProfile(id, rut_final.replace(".", "").replace("-", ""), nameTxt.getText().toString(), comuna_name, true, new JSONObject());
                                ArrayList<UserProfile> a_new_user = new ArrayList<UserProfile>();
                                a_new_user.add(new_user);
                                sharedPreference.set_list_users(TAG.INFO_USERS, a_new_user);
                                loadInfo.set_list_user(a_new_user);





                                StorageHandler.storeUserId(context, id);
                                String   access_token =  loadInfo.getUserCredentials();
                                Log.d("access_token",access_token);



                                Log.d("acces_token",sharedPreference.get_token_web(TAG.TOKEN_USER));



                                sharedPreference.set_token_web("credentialsId",access_token);

                                loadInfo.set_access_token_instance(access_token);

                                JSONObject o = new JSONObject();

                                try {

                                    String first_name = nameTxt.getText().toString();
                                    String last_name = surnameTxt.getText().toString();
                                    int age = Integer.valueOf(ageTxt.getText().toString());
                                    String rut = rutTxt.getText().toString();
                                    o.put("first_name", first_name);
                                    o.put("last_name", last_name);
                                    o.put("age", age);
                                    o.put("rut", rut.replace(".", "").replace("-", ""));
                                    o.put("serial",n_serie);
                                    o.put("region_name", region_name);
                                    o.put("comuna_name", comuna_name);
                                    o.put("address",address);
                                    Spinner genderSpn = findViewById(R.id.gender);
                                    o.put("gender", genderSpn.getSelectedItem().toString());
                                } catch (Exception e) {
                                    e.printStackTrace();
                                }


                                Log.d("envio attributos",o.toString());
                                JSONObject result_create_user_Atribute =   ServerRestHandler.pushAttributes(o.toString(), null, "DEVICE");
                                 Log.d("result_create_user_Atribute",result_create_user_Atribute.toString());

                                 if(result_create_user_Atribute.getString("status").equals("ERROR")){


                                     return "";

                                 }else {


                                     String token_ = loadInfo.getUserCredentials();
                                     //  String token__ =   ServerRestHandler.getUserCredentials();;
                                     Log.d("token_", token_);
                                     // loadInfo.set_token_instance(token_);
                                     sharedPreference.set_token_web(TAG.TOKEN_USER, token_);
                                     sharedPreference.set_user_id(TAG.USER_ID, customerId.getString("id"));

                                     sharedPreference.set_isUserLoggedIn(true);
                                     return customerId.getString("id");

                                 }
                            } catch (InterruptedException ec) {
                                ec.printStackTrace();
                                return "ERROR_INTERNET";
                            } catch (TimeoutException ec) {
                                ec.printStackTrace();
                                return "ERROR_INTERNET";
                            } catch (ExecutionException be) {
                                be.printStackTrace();
                                return "ERROR_INTERNET";
                            } catch (JSONException bbe) {
                                bbe.printStackTrace();
                                return "ERROR_INTERNET";
                            }

                        }
                    }

                }catch ( JSONException bbe) {
                        bbe.printStackTrace();


                  try {



                      Log.d("aqui error","probando");
                      JSONObject customerId = response.getJSONObject("id");

                      String first_name = nameTxt.getText().toString();
                      String last_name = surnameTxt.getText().toString();
                      int age = Integer.valueOf(ageTxt.getText().toString());
                      String rut = rutTxt.getText().toString();

                      UserProfile new_user = new UserProfile(customerId.getString("id"), rut_final.replace(".", "").replace("-", ""), nameTxt.getText().toString(), comuna_name, true, new JSONObject());

                      ArrayList<UserProfile> a_new_user = new ArrayList<UserProfile>();
                      a_new_user.add(new_user);

                      sharedPreference.set_list_users(TAG.INFO_USERS, a_new_user);
                      loadInfo.set_list_user(a_new_user);

                      // loadInfo.set_isUserLoggedIn(true);
                      sharedPreference.set_isUserLoggedIn(true);
                      StorageHandler.storeUserId(context,  customerId.getString("id"));

                      String token_ =   loadInfo.getUserCredentials();



                      JSONObject o = new JSONObject();
                      try {
                          o.put("first_name", first_name);
                          o.put("last_name", last_name);
                          o.put("age", age);
                          o.put("rut", rut.replace(".", "").replace("-", ""));
                          o.put("serial",n_serie);
                          o.put("region_name", region_name);
                          o.put("comuna_name", comuna_name);
                          o.put("address",address);
                          Spinner genderSpn = findViewById(R.id.gender);
                          o.put("gender", genderSpn.getSelectedItem().toString());
                      } catch (Exception e) {
                          e.printStackTrace();
                      }


                      Log.d("register",o.toString());

                      ServerRestHandler.pushAttributes(o.toString(), token_, "DEVICE");
                     // loadInfo.fifo_sendPatiendSample(new sendPatiendSample(o, 1, TAG._SEND_ATRIBUTTES));

                      return customerId.getString("id");
                  }catch ( JSONException rr) {
                      rr.printStackTrace();
                  }
                }
/**
            } catch (InterruptedException ec) {
                ec.printStackTrace();
                return "ERROR_INTERNET";
            } catch (TimeoutException ec) {
                ec.printStackTrace();
                return "ERROR_INTERNET";
            } catch ( ExecutionException be) {
                be.printStackTrace();
                return "ERROR_INTERNET";
            }**/

    return "";
         //   return "result";
        }

        protected void onPostExecute(String mensaje) {
            Log.d("mensaje",mensaje);

            a.cancel();
            if(mensaje.equals("TRUE")){
                StorageHandler.storeUserId(context, "");
                StorageHandler.storeUserToken(context, "");
                UToast.show(context, "Registro falló, usuario ya existe", Toast.LENGTH_LONG);
            }else if(mensaje.equals("ERROR_INTERNET")){

                UToast.show(context, "Registro falló - Ingrese Edad", Toast.LENGTH_LONG);

            }else if(mensaje.length()==0){
                UToast.show(context, "Registro falló, intentarlo denuevo", Toast.LENGTH_LONG);
            }else{
                try {
                    StorageHandler.storeUserId(context, mensaje);

                 //   String token = ServerRestHandler.getUserCredentials();
                 //   Log.d("token",token);

                 //   if (!token.equals("")) {
                 //       StorageHandler.storeUserToken(context, token);
                 //   }


                    ActivityHelper.launcher(context, BasicInfoActivity.class);
                }catch (NumberFormatException ee){
                    UToast.show(context, "Registro falló - Ingrese Edad", Toast.LENGTH_LONG);
                }
            }
        }

     }

    }

 fun getUserCredentials(): String {
        Log.d("*****","getUserCredentials")
        val _user_id_ = sharedPreference.get_informatin_user(TAG_INFO.KEY_ID_USER)
        val token_web = sharedPreference.get_token_web(TAG.TOKEN_USER)
        Log.d("id",_user_id_);

        //val token = StorageHandler.getAuthToken(context)
        val address = SINGULARITY_HOST + "device/" + _user_id_ + "/credentials"
        Log.d("token",token_web)
        Log.d("address", address)

        val futureRequest = RequestFuture.newFuture<JSONObject>()
        val mQueue_ = CustomVolleyRequestQueue.getInstance(context!!.applicationContext).requestQueue
        val jsonRequest: JsonObjectRequest = object : JsonObjectRequest(
            Request.Method.GET,
            address,
            JSONObject(),
            futureRequest,
            futureRequest
        ) {
            override fun getHeaders(): HashMap<String, String> {

                val params = HashMap<String, String>()
                if (token_web.length > 0) {
                    params["X-Authorization"] = "Bearer $token_web"
                }
                params["Content-Type"] = "application/json;charset=UTF-8"
                params["Accept"] = "application/json"
                return params
            }
        }

        jsonRequest.tag = TAG.GET_CREDENTIAL
        jsonRequest.retryPolicy = DefaultRetryPolicy(
            20000,
            DefaultRetryPolicy.DEFAULT_MAX_RETRIES,
            DefaultRetryPolicy.DEFAULT_BACKOFF_MULT
        )

        mQueue_.add(jsonRequest)
        try {
            val response = futureRequest.get(20, TimeUnit.SECONDS)

            Log.d("response_credencial",response.toString());
            val msg = response.getString("credentialsType")
            if (msg == "ACCESS_TOKEN") {
                Log.d("aqui dentro","aqui")
                set_access_token_instance(response.getString("credentialsId"))
                sharedPreference.set_token_web(KEY_CREDENTIAL, response.getString("credentialsId"))

                StorageHandler.storeUserToken(context, response.getString("credentialsId"))
                return response.getString("credentialsId")
            }
        } catch (e: JSONException) {
            e.printStackTrace()
            return ""
        } catch (e: InterruptedException) {
            e.printStackTrace()
            return ""
        } catch (e: ExecutionException) {
            e.printStackTrace()
            return ""
        } catch (e: TimeoutException) {
            e.printStackTrace()
            return ""
        } catch (e: ExecutionException) {
            if (e.message == "com.android.volley.AuthFailureError") {
                Log.d("error", "Necesita TOKEN")
            }
        }
        return ""
    }