Код ошибки 400 при использовании RestTemplate для Rest API - PullRequest
Новая
       102

Код ошибки 400 при использовании RestTemplate для Rest API

0 голосов
/ 16 июня 2020

У меня есть REST API для вызова, и я написал клиент, используя шаблон rest. При выполнении я получаю код состояния 400. Тот же REST API работает нормально при использовании POSTMAN. Ниже приведены фрагменты кода для API и вызывающей стороны. Сообщите мне, если кто-нибудь что-нибудь поймает.

REST API для метода POST - 

@ApiOperation(value = "Download repository as zip")
    @ApiResponses({@ApiResponse(code = 200, message = ""), @ApiResponse(code = 400, message = "")})
    @PostMapping(value = "/download", produces = {MediaType.APPLICATION_OCTET_STREAM_VALUE})
    public ResponseEntity<StreamingResponseBody> downloadRepository(
            @RequestBody @Validated final RepositoriesRequest repositoriesRequest) {

        final Situation situation = this.situationsService.getSituationId(repositoriesRequest);
        if (isNull(situation)) {
            return ResponseEntity.notFound().build();
        } else {
            final ExtractionRequest extractionRequest = new ExtractionRequest(repositoriesRequest.getType(), situation,
                    repositoriesRequest.getDatabase());

            if (!this.validateRequest(extractionRequest)) {
                return ResponseEntity.badRequest().build();
            }
            final ExtractionResponse response = this.extractService.extractRepository(extractionRequest);

            if (null == response) {
                return ResponseEntity.notFound().build();
            }
            final InputStream inputStream = this.extractService.getFileFromS3(response.getRepositoryPath());

            if (null == inputStream) {
                return ResponseEntity.noContent().build();
            }

            final StreamingResponseBody bodyWriter = this.bodyWriter(inputStream);

            return ResponseEntity.ok()
                    .header("Content-Type", "application/zip")
                    .header(CONTENT_DISPOSITION, "attachment; filename=\"repository-" + situation.getId() + ".zip\"")
                    .body(bodyWriter);
        }
    }

REST CLIENT, использующий шаблон Rest с токеном аутентификации и текстом запроса в качестве входных данных - 

HttpEntity<MultiValueMap<String, Object>> buildLoadRepoRequest(
            final SimulationContext context,
            final List<String> tablesName,
            final String simulationId,
            final Integer offset) {
        final Token token = this.authenticateOkoye(simulationId, offset);
        LOGGER.info("Token Run: {}", token.getAccessToken());
        final String database = this.getDatabaseForEnvironment();

        final HttpHeaders httpHeaders = new HttpHeaders();
        httpHeaders.setContentType(APPLICATION_JSON_UTF8);
        httpHeaders.set(AUTHORIZATION, "Bearer " + token.getAccessToken());

        final MultiValueMap<String, Object> body = new LinkedMultiValueMap<>();
        body.add("database", database);
        body.add("monthlyClosingMonth", context.getMonthlyClosingDate());
        body.add("repositorySnapshot", context.getRepository());
        body.add("situationId", context.getSituationId());
        body.add("tableNames", tablesName);
        body.add("type", context.getRunType());

        return new HttpEntity<>(body, httpHeaders);
    }

Обработчик исключений - 

    @Override
    @ExceptionHandler(HttpClientErrorException.class)
    public void loadRepository(
            final SimulationContext context,
            final List<String> tablesName,
            final String simulationId,
            final Integer offset,
            final Path repositoryPath) throws IOException {
        LOGGER.info("[{}] [{}] repository tablesName: {}", simulationId, offset, tablesName);
        this.restTemplate.setRequestFactory(this.getClientHttpRequestFactory());
        final ClientHttpResponse response = this.restTemplate.postForObject(
                this.repositoriesUrl,
                this.buildLoadRepoRequest(context, tablesName, simulationId, offset),
                ClientHttpResponse.class);

        if (response != null && HttpStatus.OK == response.getStatusCode()) {
            LOGGER.info(
                    "response status on simulation : {}  - Context: {} - status: {}",
                    simulationId,
                    offset,
                    response.getStatusCode());
            //this.helper.copy(response.getBody(), repositoryPath);
        } else if (response != null && HttpStatus.NO_CONTENT != response.getStatusCode()) {
            throw new JarvisException(
                    "Can't retrieve RWA repository on simulation " + simulationId + " Context:" + offset);
        }
    }

Мы изучаем эту проблему со вчерашнего дня и до сих пор не имеем ни малейшего представления. До сих пор мы пробовали postForEntity, exchange, изменяя заголовки на подходящие методы установки, а также пытались передать параметры как объект. Ни один из них не работал.

У меня сильное предчувствие, что что-то не так на уровне заголовка при вызове API.

1 Ответ

0 голосов
/ 16 июня 2020

Вы пытались использовать httpHeaders.setContentType(MediaType.APPLICATION_JSON)

Или добавить потребление в аннотацию @PostMapping со значением APPLICATION_JSON_UTF8

...