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	checkIfDownloadShouldBeForced(LocalDate date)	The Federation Batch Info stores information about which batches have already been processed to not download them again.
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.

checkIfDownloadShouldBeForced

public void checkIfDownloadShouldBeForced(LocalDate date)

The Federation Batch Info stores information about which batches have already been processed to not download them again. The batches for the current day might change constantly when national backends upload keys, hence there is the need to download the batches for today again. Hence, the entries in federation batch info with the current day need to be removed. There is a parameter 'efgs-repeat-download-offset-days' with default 0 for that.

Parameters:

date - The date the download was triggered for

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.