@RunWithCustomExecutor @Test public void successGetContainerObjectExecutionWhenFound() throws Exception { VitamThreadUtils.getVitamSession().setTenantId(TENANT_ID); when(mock.get()).thenReturn(Response.status(Status.OK).entity(StreamUtils.toInputStream("Vitam test")).build()); final InputStream stream = client.getContainerAsync("idStrategy", "guid", DataCategory.OBJECT, AccessLogUtils.getNoLogAccessLog()) .readEntity(InputStream.class); final InputStream stream2 = StreamUtils.toInputStream("Vitam test"); assertNotNull(stream); assertTrue(IOUtils.contentEquals(stream, stream2)); }
@Override public Response getContainerAsync(String strategyId, String guid, DataCategory type, AccessLogInfoModel logInfo) throws StorageServerClientException, StorageNotFoundException { Integer tenantId = ParameterHelper.getTenantParameter(); ParametersChecker.checkParameter(GUID_MUST_HAVE_A_VALID_VALUE, guid); VitamRequestBuilder request = get() .withPath(type.getCollectionName() + "/" + guid) .withHeader(GlobalDataRest.X_TENANT_ID, tenantId) .withHeader(GlobalDataRest.X_STRATEGY_ID, strategyId) .withBody(logInfo) .withContentType(MediaType.APPLICATION_JSON_TYPE) .withAccept(MediaType.APPLICATION_OCTET_STREAM_TYPE); try { Response response = make(request); return handleCommonResponseStatus(response); } catch (final VitamClientInternalException | StorageAlreadyExistsClientException e) { final String errorMessage = VitamCodeHelper.getMessageFromVitamCode(VitamCode.STORAGE_TECHNICAL_INTERNAL_ERROR); LOGGER.error(errorMessage, e); throw new StorageServerClientException(errorMessage, e); } catch (StorageNotFoundClientException e) { throw new StorageNotFoundException(e); } }
StorageClientRest extends DefaultClient implements StorageClient { @Override public Response getContainerAsync(String strategyId, String guid, DataCategory type, AccessLogInfoModel logInfo) throws StorageServerClientException, StorageNotFoundException { Integer tenantId = ParameterHelper.getTenantParameter(); ParametersChecker.checkParameter(GUID_MUST_HAVE_A_VALID_VALUE, guid); VitamRequestBuilder request = get() .withPath(type.getCollectionName() + "/" + guid) .withHeader(GlobalDataRest.X_TENANT_ID, tenantId) .withHeader(GlobalDataRest.X_STRATEGY_ID, strategyId) .withBody(logInfo) .withContentType(MediaType.APPLICATION_JSON_TYPE) .withAccept(MediaType.APPLICATION_OCTET_STREAM_TYPE); try { Response response = make(request); return handleCommonResponseStatus(response); } catch (final VitamClientInternalException | StorageAlreadyExistsClientException e) { final String errorMessage = VitamCodeHelper.getMessageFromVitamCode(VitamCode.STORAGE_TECHNICAL_INTERNAL_ERROR); LOGGER.error(errorMessage, e); throw new StorageServerClientException(errorMessage, e); } catch (StorageNotFoundClientException e) { throw new StorageNotFoundException(e); } } }
StorageClientRest extends DefaultClient implements StorageClient { @Override public Response getContainerAsync(String strategyId, String guid, DataCategory type, AccessLogInfoModel logInfo) throws StorageServerClientException, StorageNotFoundException { Integer tenantId = ParameterHelper.getTenantParameter(); ParametersChecker.checkParameter(GUID_MUST_HAVE_A_VALID_VALUE, guid); VitamRequestBuilder request = get() .withPath(type.getCollectionName() + "/" + guid) .withHeader(GlobalDataRest.X_TENANT_ID, tenantId) .withHeader(GlobalDataRest.X_STRATEGY_ID, strategyId) .withBody(logInfo) .withContentType(MediaType.APPLICATION_JSON_TYPE) .withAccept(MediaType.APPLICATION_OCTET_STREAM_TYPE); try { Response response = make(request); return handleCommonResponseStatus(response); } catch (final VitamClientInternalException | StorageAlreadyExistsClientException e) { final String errorMessage = VitamCodeHelper.getMessageFromVitamCode(VitamCode.STORAGE_TECHNICAL_INTERNAL_ERROR); LOGGER.error(errorMessage, e); throw new StorageServerClientException(errorMessage, e); } catch (StorageNotFoundClientException e) { throw new StorageNotFoundException(e); } } StorageClientRest(StorageClientFactory factory); }
StorageClientRest extends DefaultClient implements StorageClient { @Override public Response getContainerAsync(String strategyId, String guid, DataCategory type, AccessLogInfoModel logInfo) throws StorageServerClientException, StorageNotFoundException { Integer tenantId = ParameterHelper.getTenantParameter(); ParametersChecker.checkParameter(GUID_MUST_HAVE_A_VALID_VALUE, guid); VitamRequestBuilder request = get() .withPath(type.getCollectionName() + "/" + guid) .withHeader(GlobalDataRest.X_TENANT_ID, tenantId) .withHeader(GlobalDataRest.X_STRATEGY_ID, strategyId) .withBody(logInfo) .withContentType(MediaType.APPLICATION_JSON_TYPE) .withAccept(MediaType.APPLICATION_OCTET_STREAM_TYPE); try { Response response = make(request); return handleCommonResponseStatus(response); } catch (final VitamClientInternalException | StorageAlreadyExistsClientException e) { final String errorMessage = VitamCodeHelper.getMessageFromVitamCode(VitamCode.STORAGE_TECHNICAL_INTERNAL_ERROR); LOGGER.error(errorMessage, e); throw new StorageServerClientException(errorMessage, e); } catch (StorageNotFoundClientException e) { throw new StorageNotFoundException(e); } } StorageClientRest(StorageClientFactory factory); @Override JsonNode getStorageInformation(String strategyId); @Override List<String> getOffers(String strategyId); @Override StoredInfoResult storeFileFromWorkspace(String strategyId, DataCategory type, String guid,
        ObjectDescription description); @Override BulkObjectStoreResponse bulkStoreFilesFromWorkspace(String strategyId,
        BulkObjectStoreRequest bulkObjectStoreRequest); @Override boolean existsContainer(String strategyId); @Override Map<String, Boolean> exists(String strategyId, DataCategory type, String guid, List<String> offerIds); @Override JsonNode getInformation(String strategyId, DataCategory type, String guid, List<String> offerIds,
        boolean noCache); @Override RequestResponse<BatchObjectInformationResponse> getBatchObjectInformation(String strategyId,
        DataCategory type, Collection<String> offerIds,
        Collection<String> objectIds); @Override boolean delete(String strategyId, DataCategory type, String guid); @Override boolean delete(String strategyId, DataCategory type, String guid, List<String> offerIds); @Override Response getContainerAsync(String strategyId, String guid, DataCategory type, AccessLogInfoModel logInfo); @Override CloseableIterator<ObjectEntry> listContainer(String strategyId, DataCategory type); @Override RequestResponseOK storageAccessLogBackup(); @Override RequestResponseOK storageLogBackup(); @Override RequestResponseOK storageLogTraceability(); @Override RequestResponseOK copyObjectToOneOfferAnother(String objectId, DataCategory category, String source,
        String destination, String strategyId); @Override RequestResponseOK create(String strategyId, String objectId, DataCategory category, InputStream inputStream,
        Long inputStreamSize,
        List<String> offerIds); @Override RequestResponse<OfferLog> getOfferLogs(String strategyId, DataCategory type, Long offset, int limit,
        Order order); @Override RequestResponse<StorageStrategy> getStorageStrategies(); }
StorageClientRest extends DefaultClient implements StorageClient { @Override public Response getContainerAsync(String strategyId, String guid, DataCategory type, AccessLogInfoModel logInfo) throws StorageServerClientException, StorageNotFoundException { Integer tenantId = ParameterHelper.getTenantParameter(); ParametersChecker.checkParameter(GUID_MUST_HAVE_A_VALID_VALUE, guid); VitamRequestBuilder request = get() .withPath(type.getCollectionName() + "/" + guid) .withHeader(GlobalDataRest.X_TENANT_ID, tenantId) .withHeader(GlobalDataRest.X_STRATEGY_ID, strategyId) .withBody(logInfo) .withContentType(MediaType.APPLICATION_JSON_TYPE) .withAccept(MediaType.APPLICATION_OCTET_STREAM_TYPE); try { Response response = make(request); return handleCommonResponseStatus(response); } catch (final VitamClientInternalException | StorageAlreadyExistsClientException e) { final String errorMessage = VitamCodeHelper.getMessageFromVitamCode(VitamCode.STORAGE_TECHNICAL_INTERNAL_ERROR); LOGGER.error(errorMessage, e); throw new StorageServerClientException(errorMessage, e); } catch (StorageNotFoundClientException e) { throw new StorageNotFoundException(e); } } StorageClientRest(StorageClientFactory factory); @Override JsonNode getStorageInformation(String strategyId); @Override List<String> getOffers(String strategyId); @Override StoredInfoResult storeFileFromWorkspace(String strategyId, DataCategory type, String guid,
        ObjectDescription description); @Override BulkObjectStoreResponse bulkStoreFilesFromWorkspace(String strategyId,
        BulkObjectStoreRequest bulkObjectStoreRequest); @Override boolean existsContainer(String strategyId); @Override Map<String, Boolean> exists(String strategyId, DataCategory type, String guid, List<String> offerIds); @Override JsonNode getInformation(String strategyId, DataCategory type, String guid, List<String> offerIds,
        boolean noCache); @Override RequestResponse<BatchObjectInformationResponse> getBatchObjectInformation(String strategyId,
        DataCategory type, Collection<String> offerIds,
        Collection<String> objectIds); @Override boolean delete(String strategyId, DataCategory type, String guid); @Override boolean delete(String strategyId, DataCategory type, String guid, List<String> offerIds); @Override Response getContainerAsync(String strategyId, String guid, DataCategory type, AccessLogInfoModel logInfo); @Override CloseableIterator<ObjectEntry> listContainer(String strategyId, DataCategory type); @Override RequestResponseOK storageAccessLogBackup(); @Override RequestResponseOK storageLogBackup(); @Override RequestResponseOK storageLogTraceability(); @Override RequestResponseOK copyObjectToOneOfferAnother(String objectId, DataCategory category, String source,
        String destination, String strategyId); @Override RequestResponseOK create(String strategyId, String objectId, DataCategory category, InputStream inputStream,
        Long inputStreamSize,
        List<String> offerIds); @Override RequestResponse<OfferLog> getOfferLogs(String strategyId, DataCategory type, Long offset, int limit,
        Order order); @Override RequestResponse<StorageStrategy> getStorageStrategies();  }