Package energy.eddie.aiida.services

Class DataSourceService

java.lang.Object

energy.eddie.aiida.services.DataSourceService

@Service
public class DataSourceService
extends Object

Constructor Summary

Constructors

Constructor	Description
DataSourceService(DataSourceRepository repository, Aggregator aggregator, AuthService authService, MqttConfiguration mqttConfiguration, com.fasterxml.jackson.databind.ObjectMapper objectMapper, org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder bCryptPasswordEncoder, SinapsiAlfaConfiguration sinapsiAlfaConfiguration, AiidaEventPublisher aiidaEventPublisher)

Method Summary

Modifier and Type	Method	Description
DataSourceSecretsDto	addDataSource(DataSourceDto dto)
InboundDataSource	createInboundDataSource(Permission permission)
DataSource	dataSourceByIdOrThrow(UUID dataSourceId)
void	deleteDataSource(UUID dataSourceId)
Optional<DataSourceAdapter<? extends DataSource>>	findDataSourceAdapter(Predicate<DataSourceAdapter<? extends DataSource>> predicate)
Optional<DataSourceAdapter<? extends DataSource>>	findDataSourceAdapter(UUID dataSourceId)
List<DataSource>	getInboundDataSources()
List<DataSource>	getOutboundDataSources()
List<DataSourceType>	getOutboundDataSourceTypes()
DataSourceSecretsDto	regenerateSecrets(UUID dataSourceId)
void	startDataSource(DataSource dataSource)
void	startDataSources()
DataSource	updateDataSource(DataSourceDto dto)
void	updateEnabledState(UUID dataSourceId, boolean enabled)

Methods inherited from class java.lang.Object

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

Constructor Details

DataSourceService

@Autowired
public DataSourceService(DataSourceRepository repository,
 Aggregator aggregator,
 AuthService authService,
 MqttConfiguration mqttConfiguration,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder bCryptPasswordEncoder,
 SinapsiAlfaConfiguration sinapsiAlfaConfiguration,
 AiidaEventPublisher aiidaEventPublisher)

Method Details

startDataSources

@EventListener(org.springframework.context.event.ContextRefreshedEvent.class)
public void startDataSources()

startDataSource

public void startDataSource(DataSource dataSource)
                     throws ModbusConnectionException

Throws:

ModbusConnectionException

dataSourceByIdOrThrow

public DataSource dataSourceByIdOrThrow(UUID dataSourceId)
                                 throws DataSourceNotFoundException

Throws:

DataSourceNotFoundException

getOutboundDataSourceTypes

public List<DataSourceType> getOutboundDataSourceTypes()

getInboundDataSources

public List<DataSource> getInboundDataSources()
                                       throws InvalidUserException

Throws:

InvalidUserException

getOutboundDataSources

public List<DataSource> getOutboundDataSources()
                                        throws InvalidUserException

Throws:

InvalidUserException

addDataSource

public DataSourceSecretsDto addDataSource(DataSourceDto dto)
                                   throws InvalidUserException,
SinapsiAlflaEmptyConfigException

Throws:

InvalidUserException

SinapsiAlflaEmptyConfigException

deleteDataSource

public void deleteDataSource(UUID dataSourceId)

updateDataSource

public DataSource updateDataSource(DataSourceDto dto)
                            throws ModbusConnectionException,
DataSourceNotFoundException

Throws:

ModbusConnectionException

DataSourceNotFoundException

updateEnabledState

public void updateEnabledState(UUID dataSourceId,
 boolean enabled)
                        throws DataSourceNotFoundException

Throws:

DataSourceNotFoundException

regenerateSecrets

public DataSourceSecretsDto regenerateSecrets(UUID dataSourceId)
                                       throws DataSourceNotFoundException,
DataSourceSecretGenerationNotSupportedException

Throws:

DataSourceNotFoundException

DataSourceSecretGenerationNotSupportedException

findDataSourceAdapter

public Optional<DataSourceAdapter<? extends DataSource>> findDataSourceAdapter(UUID dataSourceId)

findDataSourceAdapter

public Optional<DataSourceAdapter<? extends DataSource>> findDataSourceAdapter(Predicate<DataSourceAdapter<? extends DataSource>> predicate)

createInboundDataSource

public InboundDataSource createInboundDataSource(Permission permission)