public void executeInternal()

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);
  }