Package app.coronawarn.server.services.download

Class FederationBatchProcessor

java.lang.Object

app.coronawarn.server.services.download.FederationBatchProcessor

@Component
public class FederationBatchProcessor
extends Object

Responsible for downloading and storing batch information from the federation gateway.

Constructor Summary

Constructors

Constructor	Description
FederationBatchProcessor(FederationBatchInfoService batchInfoService, DiagnosisKeyService diagnosisKeyService, FederationGatewayDownloadService federationGatewayDownloadService, DownloadServiceConfig config, ValidFederationKeyFilter federationKeyValidator)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	processErrorFederationBatches()	Downloads and processes all batches from the federation gateway that have previously been marked with the status value FederationBatchStatus.ERROR.
void	processUnprocessedFederationBatches()	Downloads and processes all batches from the federation gateway that have previously been marked with status value FederationBatchStatus.UNPROCESSED.
void	saveFirstBatchInfoForDate(LocalDate date)	Stores the batch info for the specified date.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FederationBatchProcessor

public FederationBatchProcessor(FederationBatchInfoService batchInfoService,
                                DiagnosisKeyService diagnosisKeyService,
                                FederationGatewayDownloadService federationGatewayDownloadService,
                                DownloadServiceConfig config,
                                ValidFederationKeyFilter federationKeyValidator)

Constructor.

Parameters:

batchInfoService - A FederationBatchInfoService for accessing diagnosis key batch information.

diagnosisKeyService - A DiagnosisKeyService for storing retrieved diagnosis keys.

federationGatewayDownloadService - A FederationGatewayDownloadService for retrieving federation diagnosis key batches.

config - A DownloadServiceConfig for retrieving federation configuration.

federationKeyValidator - A ValidFederationKeyFilter for validating keys in the downloaded batches

Method Detail

saveFirstBatchInfoForDate

public void saveFirstBatchInfoForDate(LocalDate date)

Stores the batch info for the specified date. Its status is set to FederationBatchStatus.UNPROCESSED.

Parameters:

date - The date for which the first batch info is stored.

processErrorFederationBatches

public void processErrorFederationBatches()

Downloads and processes all batches from the federation gateway that have previously been marked with the status value FederationBatchStatus.ERROR.

processUnprocessedFederationBatches

public void processUnprocessedFederationBatches()

Downloads and processes all batches from the federation gateway that have previously been marked with status value FederationBatchStatus.UNPROCESSED.