in ddm-bpm-extension/src/main/java/com/epam/digital/data/platform/bpms/extension/delegate/connector/UserSettingsConnectorReadDelegate.java [57:82]
public void executeInternal(DelegateExecution execution) throws Exception {
log.debug("Start reading user settings");
responseVariable.on(execution).set(ConnectorResponse.builder().build());
var headers = headerBuilderFactory.builder()
.contentTypeJson()
.accessTokenHeader()
.build();
var settingsResponse = userSettingsFeignClient.performGet(headers);
log.debug("User settings successfully read");
var email = settingsResponse.getChannels().stream()
.filter(channel -> Channel.EMAIL.equals(channel.getChannel()))
.map(ChannelReadDto::getAddress)
.findFirst()
.orElse(null);
var connectorResponseBodyDto = DelegateOutputDto.builder()
.settingsId(settingsResponse.getSettingsId())
.email(email)
.build();
var connectorResponse =
ConnectorResponse.builder().responseBody(Spin.JSON(connectorResponseBodyDto)).build();
responseVariable.on(execution).set(connectorResponse);
}