Как запросить токен аутентификации у API StreamSets Control Hub? - PullRequest
Новая
       6

Как запросить токен аутентификации у API StreamSets Control Hub?

0 голосов
/ 09 мая 2018

Я пытаюсь собрать клиент JAVA для POST в RESTApi, однако при этом я получаю сообщение об ошибке «Пользователь не аутентифицирован».

При просмотре службы «Документация для API» я обнаружилМне нужно получить токен аутентификации, прежде чем я сделаю вызов API, как сказано в шаге 1, а затем использую токен в любых последующих вызовах API.

Это то, что сказано в документе: 

1)
sessionToken=$(curl -s -X POST -d '{"userName":"NAME", "password": "xxxxx"}' https://host:18641/security/public-rest/v1/authentication/login -H "Content-Type:application/json" -H "X-Requested-By:SDC" -c - | grep SSO | grep -o '\S*$')
2)
curl -X POST https://host:18641/jobrunner/rest/v1/job/681c449d-7c22-48d6-9532-2e6ef74971bc/start  --header "Content-Type:application/json" --header "X-Requested-By:SDC" --header "X-SS-REST-CALL:true" --header "X-SS-User-Auth-Token:$sessionToken" -i

Теперь я не могу добиться того же в JAVA.

Я использую библиотеку Джерси, и это мой код до сих пор, 

public static String testUploadService(String httpURL, File filePath,String User,String Pass,Processing processing)  throws Exception {

  // Thread.sleep(500);

    // local variables
    ClientConfig clientConfig = null;
    Client client = null;
    WebTarget webTarget = null;
    Invocation.Builder invocationBuilder = null;
    Response response = null;
    FileDataBodyPart fileDataBodyPart = null;
    FormDataMultiPart formDataMultiPart = null;
    int responseCode;
    String responseMessageFromServer = null;
    String responseString = null;
      String name = User;
    String password = Pass;
    String authString = name + ":" + password;
    String sdc="sdc";
    byte[] encoding = Base64.getEncoder().encode(authString.getBytes());
    byte[] encoding2 = Base64.getEncoder().encode(sdc.getBytes());
    String USER_PASS = new String(encoding);
    String auth2=new String(encoding2);
    String boundary = "=-=" + System.currentTimeMillis() + "=-=";


  // Thread.sleep(500);
    try{
        // invoke service after setting necessary parameters

        ClientConfig cc = new ClientConfig();
        cc.register(MultiPartFeature.class);

        try {
        client = new JerseywithSSL().initClient(cc);
        } catch (KeyManagementException e) {
            e.printStackTrace();
        } catch (NoSuchAlgorithmException e) { 
        e.printStackTrace();
        }
        webTarget = client.target(httpURL);
        // set file upload values
        fileDataBodyPart = new FileDataBodyPart("file", filePath, MediaType.APPLICATION_OCTET_STREAM_TYPE);
        formDataMultiPart = new FormDataMultiPart();

        formDataMultiPart.bodyPart(fileDataBodyPart);


        invocationBuilder = webTarget.request();//.header("Authorization", "Basic " + authString);
                  invocationBuilder.header("Authorization", "Basic " + USER_PASS);
                  invocationBuilder.header("X-Requested-By","SDC");
                 invocationBuilder.header("Content-type", "multipart/form-data; boundary=" + boundary);
        try{response = invocationBuilder.post(Entity.entity(formDataMultiPart, MediaType.MULTIPART_FORM_DATA));}
        catch(Exception ex){
        ex.printStackTrace();
        }

        responseCode = response.getStatus();
        System.out.println("Response code: " + responseCode);

        if (response.getStatus() != 200) {
        //    throw new RuntimeException("Failed with HTTP error code : " + responseCode);
        }
    System.out.println("Check 6");
        // get response message
        responseMessageFromServer = 
 response.getStatusInfo().getReasonPhrase();
        System.out.println("ResponseMessageFromServer: " + 
     responseMessageFromServer);
 System.out.println("Check 7");
    processing.setlabel("Finished");
   processing.setprogress(100);

        // get response string
        responseString = response.readEntity(String.class);
             processing.finished("Server Response Code - "+responseCode + "\n ResponseMessageFromServer: "+ responseString);
    }
    catch(Exception ex) {
        ex.printStackTrace();
        JOptionPane.showMessageDialog(null, "Error!! \n Make sure you are connected to Dell Internal Network");
        processing.dispose();
    }
    finally{
        // release resources, if any
        fileDataBodyPart.cleanup();
        formDataMultiPart.cleanup();
        formDataMultiPart.close();
        response.close();
        client.close();
    }
    return responseString;
}

Мне нужна помощь с фетингомAuth Token, как это делается в первой команде Curl, я могу создать вторую команду Post.

Ответы [ 2 ]

0 голосов
/ 09 мая 2018

Ключом к этому является то, что первая команда curl выбирает токен, но возвращается в файлах cookie - отсюда и аргумент -c -, указывающий curl записывать файлы cookie в стандартный вывод. Остальная часть этой строки извлекает значение соответствующего файла cookie. Ознакомьтесь с документами на Джерси, чтобы узнать, как получить доступ к файлам cookie после отправки запроса.

0 голосов
/ 09 мая 2018

Разберите заголовки ваших ответов и получите токен аутентификации. Посмотрите на номер строки 192 кода, которым вы поделились 

String userAuthToken = response.getHeaderString(SSOConstants.X_USER_AUTH_TOKEN);

И используйте это userAuthToken в заголовках запросов при вызове других веб-сервисов. Вы можете сохранить этот AuthToken в активном сеансе. Номер строки проверки 206 

.header(SSOConstants.X_USER_AUTH_TOKEN, userAuthToken)

Ключ для получения токена авторизации: 

String X_USER_AUTH_TOKEN = "X-SS-User-Auth-Token";
...