Package net.datenwerke.rs.core.service.datasinkmanager

Class DatasinkServiceImpl

java.lang.Object

net.datenwerke.rs.core.service.datasinkmanager.DatasinkServiceImpl

All Implemented Interfaces:

DatasinkService

public class DatasinkServiceImpl
extends Object
implements DatasinkService

Constructor Summary

Constructors

Constructor	Description
DatasinkServiceImpl(<any> configServiceProvider, DtoService dtoService, ZipUtilsService zipUtilsService, <any> authenticatorServiceProvider, <any> hookHandlerServiceProvider)

Method Summary

Modifier and Type	Method	Description
void	exportFileIntoDatasink(AbstractFileServerNodeDto fileDto, DatasinkDefinitionDto datasinkDto, String filename, String folder, boolean compressed)
void	exportIntoDatasink(Object data, DatasinkDefinition datasinkDefinition, String fileEnding)	Sends a data to the specified datasink, defined in a given DatasinkDefinition datasink.
void	exportIntoDatasink(Object data, DatasinkDefinition datasinkDefinition, DatasinkConfiguration config)	Sends a data to the specified datasink, defined in a given DatasinkDefinition datasink.
void	exportIntoDatasink(Object data, User user, DatasinkDefinition datasinkDefinition, DatasinkConfiguration config)	Sends a data to the specified datasink, defined in a given DatasinkDefinition datasink.
void	exportIntoDatasink(CompiledReport cReport, String name, boolean compress, DatasinkDefinition datasink, DatasinkConfiguration config)
void	exportIntoDatasink(ReportExecuteJob rJob, boolean compress, DatasinkDefinition datasink, DatasinkConfiguration config)
Optional<? extends DatasinkDefinition>	getDefaultDatasink(BasicDatasinkService basicDatasinkService)
String	getDefaultFolder(FolderedDatasink datasink)
Map<StorageType,Boolean>	getEnabledConfigs(BasicDatasinkService datasinkService)	Summarizes invalid @link {@link #isEnabled(DatasinkDefinition)) } and invalid @link {@link #isSchedulingEnabled(DatasinkDefinition)) } in a map.
String	getFilenameForDatasink(String name, CompiledReport cReport, boolean compress)
String	getFilenameForDatasink(ReportExecuteJob rJob, boolean compress, String filename)
boolean	isEnabled(BasicDatasinkService datasinkService)	Returns the current configuration value of datasink enabling.
boolean	isSchedulingEnabled(BasicDatasinkService datasinkService)	Returns the current configuration value of scheduling enabling.
void	testDatasink(DatasinkDefinition datasinkDefinition, DatasinkConfiguration config)	Issues a datasink test request by creating a simple text file and sending it to the specified directory in the specified datasink.

Methods inherited from class java.lang.Object

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

Constructor Details

DatasinkServiceImpl

public DatasinkServiceImpl(<any> configServiceProvider,
 DtoService dtoService,
 ZipUtilsService zipUtilsService,
 <any> authenticatorServiceProvider,
 <any> hookHandlerServiceProvider)

Method Details

getDefaultFolder

public String getDefaultFolder(FolderedDatasink datasink)

Specified by:

getDefaultFolder in interface DatasinkService

isEnabled

public boolean isEnabled(BasicDatasinkService datasinkService)

Description copied from interface: DatasinkService

Returns the current configuration value of datasink enabling. Has to be true in order for reports to be sent to the specified datasink type.

Specified by:

isEnabled in interface DatasinkService

Parameters:

datasinkService - the datasink service

Returns:

true if the datasink type is enabled

isSchedulingEnabled

public boolean isSchedulingEnabled(BasicDatasinkService datasinkService)

Description copied from interface: DatasinkService

Returns the current configuration value of scheduling enabling. Reports can only be sent to the specified datasink type inside a scheduling job if this is true.

Specified by:

isSchedulingEnabled in interface DatasinkService

Parameters:

datasinkService - the datasink service

Returns:

true if datasink's scheduling is enabled

getEnabledConfigs

public Map<StorageType,Boolean> getEnabledConfigs(BasicDatasinkService datasinkService)

Description copied from interface: DatasinkService

Summarizes

invalid @link

{@link #isEnabled(DatasinkDefinition))

} and

invalid @link

{@link #isSchedulingEnabled(DatasinkDefinition))

} in a map.

Specified by:

getEnabledConfigs in interface DatasinkService

Parameters:

datasinkService - the datasink service

Returns:

a map containing the enabling configuration for

invalid @link

{@link #isEnabled(DatasinkDefinition))

} and

invalid @link

{@link #isSchedulingEnabled(DatasinkDefinition))

}

testDatasink

public void testDatasink(DatasinkDefinition datasinkDefinition,
 DatasinkConfiguration config)
                  throws DatasinkExportException

Description copied from interface: DatasinkService

Issues a datasink test request by creating a simple text file and sending it to the specified directory in the specified datasink.

Specified by:

testDatasink in interface DatasinkService

Parameters:

datasinkDefinition - the DatasinkDefinition to test

config - the datasink export configuration

Throws:

DatasinkExportException - if an error occurs during datasink export

exportIntoDatasink

public void exportIntoDatasink(Object data,
 User user,
 DatasinkDefinition datasinkDefinition,
 DatasinkConfiguration config)
                        throws DatasinkExportException

Description copied from interface: DatasinkService

Sends a data to the specified datasink, defined in a given DatasinkDefinition datasink.

Specified by:

exportIntoDatasink in interface DatasinkService

Parameters:

data - the data to send. May be a String, a byte array or a TableDBDataSource

user - the User

datasinkDefinition - the DatasinkDefinition to send

config - configuration of the export

Throws:

DatasinkExportException - if an error occurs during datasink export

exportIntoDatasink

public void exportIntoDatasink(Object data,
 DatasinkDefinition datasinkDefinition,
 DatasinkConfiguration config)
                        throws DatasinkExportException

Description copied from interface: DatasinkService

Sends a data to the specified datasink, defined in a given DatasinkDefinition datasink.

Specified by:

exportIntoDatasink in interface DatasinkService

Parameters:

data - the data to send. May be a String, a byte array or a TableDBDataSource

datasinkDefinition - the DatasinkDefinition to send

config - configuration of the export

Throws:

DatasinkExportException - if an error occurs during datasink export

exportIntoDatasink

public void exportIntoDatasink(Object data,
 DatasinkDefinition datasinkDefinition,
 String fileEnding)
                        throws DatasinkExportException

Description copied from interface: DatasinkService

Sends a data to the specified datasink, defined in a given DatasinkDefinition datasink. Uses datasink default configuration.

Specified by:

exportIntoDatasink in interface DatasinkService

Parameters:

data - the data to send. May be a String, a byte array or a TableDBDataSource

datasinkDefinition - the DatasinkDefinition to send

fileEnding - the ending of the file to export, e.g. ".txt" for text files

Throws:

DatasinkExportException - if an error occurs during datasink export

getDefaultDatasink

public Optional<? extends DatasinkDefinition> getDefaultDatasink(BasicDatasinkService basicDatasinkService)

Specified by:

getDefaultDatasink in interface DatasinkService

exportFileIntoDatasink

public void exportFileIntoDatasink(AbstractFileServerNodeDto fileDto,
 DatasinkDefinitionDto datasinkDto,
 String filename,
 String folder,
 boolean compressed)
                            throws ServerCallFailedException

Specified by:

exportFileIntoDatasink in interface DatasinkService

Throws:

ServerCallFailedException

exportIntoDatasink

public void exportIntoDatasink(ReportExecuteJob rJob,
 boolean compress,
 DatasinkDefinition datasink,
 DatasinkConfiguration config)
                        throws ActionExecutionException

Specified by:

exportIntoDatasink in interface DatasinkService

Throws:

ActionExecutionException

exportIntoDatasink

public void exportIntoDatasink(CompiledReport cReport,
 String name,
 boolean compress,
 DatasinkDefinition datasink,
 DatasinkConfiguration config)
                        throws DatasinkExportException

Specified by:

exportIntoDatasink in interface DatasinkService

Throws:

DatasinkExportException

getFilenameForDatasink

public String getFilenameForDatasink(ReportExecuteJob rJob,
 boolean compress,
 String filename)

Specified by:

getFilenameForDatasink in interface DatasinkService

getFilenameForDatasink

public String getFilenameForDatasink(String name,
 CompiledReport cReport,
 boolean compress)

Specified by:

getFilenameForDatasink in interface DatasinkService