src/main/java/web/kubernetes/controllers/AuthController.java - master - timpson/k8_loader_vaadin

src/main/java/web/kubernetes/controllers/AuthController.java

58 строк2 KB

tim

first commit

21 май 2022, 20:05

21 май 2022, 20:05ad3050b

package web.kubernetes.controllers;

import com.google.gson.Gson;
import elemental.json.Json;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import web.kubernetes.model.Node;
import web.kubernetes.payloads.requests.LoginRequest;
import web.kubernetes.payloads.responses.JwtResponse;

import java.io.IOException;
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.util.HashMap;

@Component
public class AuthController {
    @Value("${k8s.url}")
    private  String SERVER;

    private final String LOGIN_URL_PATH = "/api/auth/signin";

    public JwtResponse login(String username, String password) {
        Gson gson = new Gson();
        String requestBody = gson.toJson(new LoginRequest(username, password)).toString();
        HttpClient client = HttpClient.newHttpClient();
        HttpRequest request = HttpRequest
                .newBuilder(URI.create(SERVER + LOGIN_URL_PATH))
                .header("Content-Type","application/json")
                .POST(HttpRequest.BodyPublishers.ofString(requestBody)).build();

        HttpResponse<String> response;
        JwtResponse jwtResponse ;
        try {
            response = client.send(request, HttpResponse.BodyHandlers.ofString());
            int status = response.statusCode();
            jwtResponse = new Gson().fromJson(response.body(), JwtResponse.class);
            jwtResponse.setStatus(status);
            if (status == 200){
            }else if (status == 401){
                jwtResponse = new JwtResponse("","","",status,"Authorization failed: Login and password incorrect.", null );
            }else {
                jwtResponse = new JwtResponse("","","",status, response.body(), null );
            }

        } catch (IOException e) {
            jwtResponse = new JwtResponse("","","",0,e.getMessage(), null );
        } catch (InterruptedException e) {
            jwtResponse = new JwtResponse("","","",0,e.getMessage(), null );
        }
        return jwtResponse;
    }



}