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	prepareDownload()	Checks if the date-based download logic is enabled and prepares the FederationBatchInfo Repository accordingly.
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.
protected 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

prepareDownload

public void prepareDownload()
                     throws FatalFederationGatewayException

Checks if the date-based download logic is enabled and prepares the FederationBatchInfo Repository accordingly. The Federation Batch Info stores information about which batches have already been processed to not download them again. If the date-based download is enabled, the entries for the specified date need to be removed. Stores the first FederationBatchTag for the specified date as a starting point for further processing.

Throws:

FatalFederationGatewayException

saveFirstBatchInfoForDate

protected void saveFirstBatchInfoForDate(LocalDate date)
                                  throws FatalFederationGatewayException

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.

Throws:

FatalFederationGatewayException

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()
                                         throws FatalFederationGatewayException

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

Throws:

FatalFederationGatewayException