Spark Java: Как я могу проверить токен OAuth в моем фильтре before ()? - PullRequest
Новая
       72

Spark Java: Как я могу проверить токен OAuth в моем фильтре before ()?

2 голосов
/ 11 февраля 2020

У меня очень простой веб-сервер, написанный на Spark- java (Not Apache Spark), и я хотел бы извлечь токен аутентификации из первоначального запроса и отправить его на дополнительный URL-адрес для аутентификации на основе аутентификации моей компании база данных. Я изучил документацию и не уверен, как это сделать. Мне также нужно знать, как установить параметр запроса для запроса к серверу авторизации. Ниже мой код: 

/*
 * This Java source file was generated by the Gradle 'init' task.
 */
package c2c_server;

import static spark.Spark.*;

public class HelloWorld {
   public static void main(String[] args) {

      before((before_req, before_res) -> {
         System.out.println("I'm in before");
         String token = before_req.headers("Authorization");

         // No token, reject
         if (token == null) {
            halt(401, "Unauthorized");
         }
         else if (token != null) {
            System.out.println("Token is : " + token);
            String url = "https://my-auth-url";

         }
      });

      get("/command/:command", (req, res) -> {
         System.out.println("You sent the command: " + req.params(":command") + " and the headers: " + req.headers());
         if (req.params(":command").equals("run")) {
            res.status(200);
            return "You'll run the Java app to push data to S3!";
         }
         else {
            res.status(400);
            return "I don't understand that command";
         }
      });
      System.out.println("Server listening");
   }
}

1 Ответ

0 голосов
/ 12 февраля 2020

Проведя некоторые исследования, похоже, что у проекта JavaSpark нет способа сделать это самому. Мне нужно было использовать библиотеку Apache HttpClient, чтобы создать этот фрагмент кода для обработки второго запроса на аутентификацию токена: 

import org.apache.http.Header;
import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.util.EntityUtils;
import org.apache.http.impl.client.HttpClients;

    private static boolean IsAuthenticated(final String environment, final String token) throws Exception {
          String url = "";
          if (environment.equalsIgnoreCase("DEV")) {
             url = "https://dev-oauth2-internal.com/validate/AppIdClaimsTrust";
          }
          else if (environment.equalsIgnoreCase("QA")) {
             url = "https://qa-oauth2-internal.com/validate/AppIdClaimsTrust";
          }
          else if (environment.equalsIgnoreCase("PROD")) {
             url = "https://oauth2-internal.com/validate/AppIdClaimsTrust";
          }
          else {
             throw new Exception("Environment not supported");
          }
          HttpGet request = new HttpGet(url + "?token=" + token);
          try (CloseableHttpResponse response = httpClient.execute(request)) {
             int statusCode = response.getStatusLine().getStatusCode();
             return (statusCode == 200);
          }
...