@RunWithCustomExecutor @Test public void getOfferLogs() throws Exception { assertThatCode(() -> { simpleDistribution.getOfferLogs(VitamConfiguration.getDefaultStrategy(), DataCategory.OBJECT, 0L, 0, Order.ASC); }).isInstanceOf(IllegalArgumentException.class); VitamThreadUtils.getVitamSession().setTenantId(0); RequestResponse<OfferLog> result = simpleDistribution.getOfferLogs(VitamConfiguration.getDefaultStrategy(), DataCategory.OBJECT, 0L, 0, Order.ASC); assertNotNull(result); assertTrue(result.isOk()); assertThatCode(() -> { simpleDistribution.getOfferLogs(null, null, 0L, 0, Order.ASC); }).isInstanceOf(IllegalArgumentException.class); assertThatCode(() -> { simpleDistribution.getOfferLogs(VitamConfiguration.getDefaultStrategy(), null, 0L, 0, Order.ASC); }).isInstanceOf(IllegalArgumentException.class); }
@Override public RequestResponse<OfferLog> getOfferLogs(String strategyId, DataCategory category, Long offset, int limit, Order order) throws StorageException { return getOfferLogRequestResponse(strategyId, null, category, offset, limit, order); }
StorageDistributionImpl implements StorageDistribution { @Override public RequestResponse<OfferLog> getOfferLogs(String strategyId, DataCategory category, Long offset, int limit, Order order) throws StorageException { return getOfferLogRequestResponse(strategyId, null, category, offset, limit, order); } }
StorageDistributionImpl implements StorageDistribution { @Override public RequestResponse<OfferLog> getOfferLogs(String strategyId, DataCategory category, Long offset, int limit, Order order) throws StorageException { return getOfferLogRequestResponse(strategyId, null, category, offset, limit, order); } StorageDistributionImpl(StorageConfiguration configuration, StorageLog storageLogService); @VisibleForTesting  StorageDistributionImpl(WorkspaceClientFactory workspaceClientFactory, DigestType digestType,
        StorageLog storageLogService,
        ExecutorService batchExecutorService, int batchDigestComputationTimeout,
        BulkStorageDistribution bulkStorageDistribution); }
StorageDistributionImpl implements StorageDistribution { @Override public RequestResponse<OfferLog> getOfferLogs(String strategyId, DataCategory category, Long offset, int limit, Order order) throws StorageException { return getOfferLogRequestResponse(strategyId, null, category, offset, limit, order); } StorageDistributionImpl(StorageConfiguration configuration, StorageLog storageLogService); @VisibleForTesting  StorageDistributionImpl(WorkspaceClientFactory workspaceClientFactory, DigestType digestType,
        StorageLog storageLogService,
        ExecutorService batchExecutorService, int batchDigestComputationTimeout,
        BulkStorageDistribution bulkStorageDistribution); @Override StoredInfoResult copyObjectFromOfferToOffer(DataContext context, String sourceOffer, String destinationOffer); @Override StoredInfoResult storeDataInOffers(String strategyId, String objectId, DataCategory category,
        String requester,
        List<String> offerIds, Response response); @Override StoredInfoResult storeDataInOffers(String strategyId, StreamAndInfo streamAndInfo, String objectId,
        DataCategory category, String requester,
        List<String> offerIds); @Override StoredInfoResult storeDataInAllOffers(String strategyId, String objectId,
        ObjectDescription createObjectDescription, DataCategory category, String requester); @Override BulkObjectStoreResponse bulkCreateFromWorkspace(String strategyId,
        BulkObjectStoreRequest bulkObjectStoreRequest, String requester); @Override List<String> getOfferIds(String strategyId); @Override Map<String, StorageStrategy> getStrategies(); @Override JsonNode getContainerInformation(String strategyId); @Override CloseableIterator<ObjectEntry> listContainerObjects(String strategyId, DataCategory category); @Override CloseableIterator<ObjectEntry> listContainerObjectsForOffer(DataCategory category,
        String offerId, boolean includeDisabled); @Override RequestResponse<OfferLog> getOfferLogs(String strategyId, DataCategory category, Long offset, int limit,
        Order order); @Override RequestResponse<OfferLog> getOfferLogsByOfferId(String strategyId, String offerId,
        DataCategory category,
        Long offset, int limit, Order order); @Override Response getContainerByCategory(String strategyId, String objectId, DataCategory category,
        AccessLogInfoModel logInformation); @Override Response getContainerByCategory(String strategyId, String objectId, DataCategory category, String
        offerId); @Override JsonNode getContainerInformation(String strategyId, DataCategory type, String objectId,
        List<String> offerIds, boolean noCache); @Override Map<String, Boolean> checkObjectExisting(String strategyId, String objectId, DataCategory category,
        List<String> offerIds); @Override void deleteObjectInAllOffers(String strategyId, DataContext context); @Override void deleteObjectInOffers(String strategyId, DataContext context, List<String> offers); @Override List<BatchObjectInformationResponse> getBatchObjectInformation(String strategyId, DataCategory type,
        List<String> objectIds, List<String> offerIds); @Override void close(); }
StorageDistributionImpl implements StorageDistribution { @Override public RequestResponse<OfferLog> getOfferLogs(String strategyId, DataCategory category, Long offset, int limit, Order order) throws StorageException { return getOfferLogRequestResponse(strategyId, null, category, offset, limit, order); } StorageDistributionImpl(StorageConfiguration configuration, StorageLog storageLogService); @VisibleForTesting  StorageDistributionImpl(WorkspaceClientFactory workspaceClientFactory, DigestType digestType,
        StorageLog storageLogService,
        ExecutorService batchExecutorService, int batchDigestComputationTimeout,
        BulkStorageDistribution bulkStorageDistribution); @Override StoredInfoResult copyObjectFromOfferToOffer(DataContext context, String sourceOffer, String destinationOffer); @Override StoredInfoResult storeDataInOffers(String strategyId, String objectId, DataCategory category,
        String requester,
        List<String> offerIds, Response response); @Override StoredInfoResult storeDataInOffers(String strategyId, StreamAndInfo streamAndInfo, String objectId,
        DataCategory category, String requester,
        List<String> offerIds); @Override StoredInfoResult storeDataInAllOffers(String strategyId, String objectId,
        ObjectDescription createObjectDescription, DataCategory category, String requester); @Override BulkObjectStoreResponse bulkCreateFromWorkspace(String strategyId,
        BulkObjectStoreRequest bulkObjectStoreRequest, String requester); @Override List<String> getOfferIds(String strategyId); @Override Map<String, StorageStrategy> getStrategies(); @Override JsonNode getContainerInformation(String strategyId); @Override CloseableIterator<ObjectEntry> listContainerObjects(String strategyId, DataCategory category); @Override CloseableIterator<ObjectEntry> listContainerObjectsForOffer(DataCategory category,
        String offerId, boolean includeDisabled); @Override RequestResponse<OfferLog> getOfferLogs(String strategyId, DataCategory category, Long offset, int limit,
        Order order); @Override RequestResponse<OfferLog> getOfferLogsByOfferId(String strategyId, String offerId,
        DataCategory category,
        Long offset, int limit, Order order); @Override Response getContainerByCategory(String strategyId, String objectId, DataCategory category,
        AccessLogInfoModel logInformation); @Override Response getContainerByCategory(String strategyId, String objectId, DataCategory category, String
        offerId); @Override JsonNode getContainerInformation(String strategyId, DataCategory type, String objectId,
        List<String> offerIds, boolean noCache); @Override Map<String, Boolean> checkObjectExisting(String strategyId, String objectId, DataCategory category,
        List<String> offerIds); @Override void deleteObjectInAllOffers(String strategyId, DataContext context); @Override void deleteObjectInOffers(String strategyId, DataContext context, List<String> offers); @Override List<BatchObjectInformationResponse> getBatchObjectInformation(String strategyId, DataCategory type,
        List<String> objectIds, List<String> offerIds); @Override void close(); static final String DIGEST; }