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 java.lang.Object
implements DatasinkService

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	exportFileIntoDatasink(AbstractFileServerNodeDto fileDto, DatasinkDefinitionDto datasinkDto, java.lang.String filename, java.lang.String folder, boolean compressed)
void	exportIntoDatasink(CompiledReport cReport, java.lang.String name, boolean compress, DatasinkDefinition datasink, DatasinkConfiguration config)
void	exportIntoDatasink(java.lang.Object data, DatasinkDefinition datasinkDefinition, DatasinkConfiguration config) Sends a data to the specified datasink, defined in a given DatasinkDefinition datasink.
void	exportIntoDatasink(java.lang.Object data, DatasinkDefinition datasinkDefinition, java.lang.String fileEnding) Sends a data to the specified datasink, defined in a given DatasinkDefinition datasink.
void	exportIntoDatasink(java.lang.Object data, User user, DatasinkDefinition datasinkDefinition, DatasinkConfiguration config) Sends a data to the specified datasink, defined in a given DatasinkDefinition datasink.
void	exportIntoDatasink(ReportExecuteJob rJob, boolean compress, DatasinkDefinition datasink, DatasinkConfiguration config)
java.util.Optional<? extends DatasinkDefinition>	getDefaultDatasink(BasicDatasinkService basicDatasinkService)
java.lang.String	getDefaultFolder(FolderedDatasink datasink)
java.util.Map<StorageType,java.lang.Boolean>	getEnabledConfigs(BasicDatasinkService datasinkService) Summarizes #isEnabled(DatasinkDefinition)) and #isSchedulingEnabled(DatasinkDefinition)) in a map.
java.lang.String	getFilenameForDatasink(ReportExecuteJob rJob, boolean compress, java.lang.String filename)
java.lang.String	getFilenameForDatasink(java.lang.String name, CompiledReport cReport, boolean compress)
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 Detail

DatasinkServiceImpl

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

Method Detail

getDefaultFolder

public java.lang.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 java.util.Map<StorageType,java.lang.Boolean> getEnabledConfigs(BasicDatasinkService datasinkService)

Description copied from interface: DatasinkService

Summarizes #isEnabled(DatasinkDefinition)) and #isSchedulingEnabled(DatasinkDefinition)) in a map.

Specified by:

getEnabledConfigs in interface DatasinkService

Parameters:

datasinkService - the datasink service

Returns:

a map containing the enabling configuration for #isEnabled(DatasinkDefinition)) and #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(java.lang.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(java.lang.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(java.lang.Object data,
                               DatasinkDefinition datasinkDefinition,
                               java.lang.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 java.util.Optional<? extends DatasinkDefinition> getDefaultDatasink(BasicDatasinkService basicDatasinkService)

Specified by:

getDefaultDatasink in interface DatasinkService

exportFileIntoDatasink

public void exportFileIntoDatasink(AbstractFileServerNodeDto fileDto,
                                   DatasinkDefinitionDto datasinkDto,
                                   java.lang.String filename,
                                   java.lang.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,
                               java.lang.String name,
                               boolean compress,
                               DatasinkDefinition datasink,
                               DatasinkConfiguration config)
                        throws DatasinkExportException

Specified by:

exportIntoDatasink in interface DatasinkService

Throws:

DatasinkExportException

getFilenameForDatasink

public java.lang.String getFilenameForDatasink(ReportExecuteJob rJob,
                                               boolean compress,
                                               java.lang.String filename)

Specified by:

getFilenameForDatasink in interface DatasinkService

getFilenameForDatasink

public java.lang.String getFilenameForDatasink(java.lang.String name,
                                               CompiledReport cReport,
                                               boolean compress)

Specified by:

getFilenameForDatasink in interface DatasinkService