zcl_adf_service.clas.abap

class ZCL_ADF_SERVICE definition
  public
  abstract
  create public .

public section.

  constants GC_SERVICE_BLOB type ZAZURE_DEST value 'BLOB' ##NO_TEXT.
  constants GC_SERVICE_AAD type ZAZURE_DEST value 'AAD' ##NO_TEXT.
  constants GC_SERVICE_KV type ZAZURE_DEST value 'KV' ##NO_TEXT.

  methods SEND
    importing
      value(REQUEST) type XSTRING
      !IT_HEADERS type TIHTTPNVP optional
    exporting
      value(RESPONSE) type STRING
      value(EV_HTTP_STATUS) type I
    raising
      ZCX_ADF_SERVICE .
  methods CONSTRUCTOR
    importing
      value(IV_INTERFACE_ID) type ZINTERFACE_ID
      value(IV_SERVICE_ID) type ZAZURE_DEST
      value(IV_BUSINESS_IDENTIFIER) type ZBUSINESSID optional
    raising
      ZCX_ADF_SERVICE
      ZCX_HTTP_CLIENT_FAILED
      ZCX_INTERACE_CONFIG_MISSING .
  methods FORMAT_DATA
    importing
      value(IV_FORMAT_TYPE) type ZADF_FORMAT_TYPE
      value(IT_DATA) type DATA
    returning
      value(RV_STRING) type STRING
    raising
      ZCX_ADF_SERVICE .
  methods FORMAT_DATA_TO_XML
    importing
      value(IT_DATA) type DATA
    returning
      value(RV_STRING) type STRING .
  methods FORMAT_DATA_TO_JSON
    importing
      value(IT_DATA) type DATA
    returning
      value(RV_STRING) type STRING .
  methods ADD_EXPIRY_TIME
    importing
      value(IV_EXPIRY_HOUR) type I
      value(IV_EXPIRY_MIN) type I default 30
      value(IV_EXPIRY_SEC) type I
    raising
      ZCX_ADF_SERVICE .
  methods URLENCODED_TO_HTTP_FIELDS
    importing
      !IV_RESPONSE_DATA type STRING
    returning
      value(ET_FIELDS) type TIHTTPNVP
    raising
      ZCX_ADF_SERVICE .
  methods JSON_TO_HTTP_FIELDS
    importing
      !IV_RESPONSE_DATA type STRING
    returning
      value(ET_FIELDS) type TIHTTPNVP
    raising
      ZCX_ADF_SERVICE .
protected section.

  constants GC_ERROR type CHAR1 value 'E' ##NO_TEXT.
  data GV_INTERFACE_ID type ZINTERFACE_ID .
  data GV_SAS_KEY type STRING .
  data GV_URI type STRING .
  data GO_REST_API type ref to ZCL_REST_FRAMEWORK .
  type-pools ABAP .
  data GV_ASYNCHRONOUS type ABAP_BOOL .
  data GV_IS_TRY type ABAP_BOOL .
  data GV_EXPIRY_HOUR type I .
  data GV_EXPIRY_MIN type I .
  data GV_EXPIRY_SEC type I .
  data GV_STRING_TO_SIGN type STRING .
  data GV_SERVICE_VERSION type STRING .
  data GV_RFC_DESTINATION type RFCDEST .
  data GV_PATH_PREFIX type STRING .
  data GV_HOST type STRING .

  methods ADD_REQUEST_HEADER
    importing
      value(IV_NAME) type STRING
      value(IV_VALUE) type STRING .
  methods GET_SAS_TOKEN
    importing
      value(IV_BASEADDRESS) type STRING
    returning
      value(RV_SAS_TOKEN) type STRING
    raising
      ZCX_ADF_SERVICE .
  methods GET_EPOCH_TIME
    returning
      value(RV_EXPIRY_TIME) type STRING
    raising
      ZCX_ADF_SERVICE .
  methods DECODE_SIGN
    returning
      value(RV_SECRET) type STRING
    raising
      ZCX_ADF_SERVICE .
  methods GET_TARGET_HOST
    importing
      !IV_DESTINATION type RFCDES-RFCDEST
      !IV_AUTHORITY_CHECK type RFCDISPLAY-RFCTRACE default ' '
      !IV_BYPASS_BUFF type CHAR1 optional
    exporting
      !EV_SERVER type RFCDISPLAY-RFCHOST
      !EV_PATH_PREFIX type STRING
    raising
      ZCX_ADF_SERVICE .
private section.

  constants GC_FORMAT_XML type ZADF_FORMAT_TYPE value 'XML' ##NO_TEXT.
  constants GC_FORMAT_JSON type ZADF_FORMAT_TYPE value 'JSON' ##NO_TEXT.
  constants GC_ASYNCHRONOUS type CHAR1 value 'A' ##NO_TEXT.
  constants GC_SYNCHRONOUS type CHAR1 value 'S' ##NO_TEXT.
  data GV_DESTINATION type ZAZURE_DEST .
  data GV_SERVICE_ID type ZAZURE_DEST .

  methods GET_INTERFACE_DETAILS
    raising
      ZCX_ADF_SERVICE .
  methods GET_REST_API_REF
    importing
      !IV_BUSINESS_IDENTIFIER type ZBUSINESSID optional
    raising
      ZCX_ADF_SERVICE
      ZCX_HTTP_CLIENT_FAILED
      ZCX_INTERACE_CONFIG_MISSING .
  methods CALL_STACK_CHECK
    raising
      ZCX_ADF_SERVICE .
ENDCLASS.



CLASS ZCL_ADF_SERVICE IMPLEMENTATION.


METHOD add_expiry_time.
  CLEAR: gv_expiry_hour,gv_expiry_min,gv_expiry_sec.
  gv_expiry_hour = iv_expiry_hour.
  gv_expiry_min  = iv_expiry_min.
  gv_expiry_sec  = iv_expiry_sec.
  IF ( gv_expiry_hour IS INITIAL ) AND
     ( gv_expiry_min IS INITIAL )  AND
     ( gv_expiry_sec IS INITIAL ).
    RAISE EXCEPTION TYPE zcx_adf_service
      EXPORTING
        textid       = zcx_adf_service=>expiry_time_not_set
        interface_id = gv_interface_id.
  ENDIF.
ENDMETHOD.


method ADD_REQUEST_HEADER.
 go_rest_api->zif_rest_framework~set_request_header( iv_name = iv_name iv_value = iv_value ).
endmethod.


METHOD call_stack_check.
  DATA : lt_abap_stack TYPE abap_callstack,
         lt_syst_stack TYPE sys_callst.
  CALL FUNCTION 'SYSTEM_CALLSTACK'
    IMPORTING
      callstack    = lt_abap_stack
      et_callstack = lt_syst_stack.
  READ TABLE lt_abap_stack TRANSPORTING NO FIELDS
             WITH KEY mainprogram = 'ZCL_ADF_SERVICE_FACTORY=======CP'
                      blocktype = 'METHOD'
                      blockname = 'CREATE'.
  IF sy-subrc NE 0.
    RAISE EXCEPTION TYPE zcx_adf_service
      EXPORTING
        textid       = zcx_adf_service=>execution_terminated
        interface_id = space.
  ENDIF.
ENDMETHOD.


METHOD constructor.
  call_stack_check( ).
  gv_interface_id = iv_interface_id.
  gv_service_id   = iv_service_id.
  get_interface_details( ).
  get_rest_api_ref( EXPORTING iv_business_identifier = iv_business_identifier ).
ENDMETHOD.


METHOD decode_sign.
*This Include is to encrypt secrets with SSL client ID from STRUST     *
*Framework Author : Krishna Chandra Dash                               *
*                   Sasidhar Puranam                                   *
*----------------------------------------------------------------------*
* Date      | USER ID  |Transport   | Remarks                          *
*-----------|----------|------------|------------|---------------------*
*11.07.2017 | KRDASH   |            |Logic chnaged related to encryption
*----------------------------------------------------------------------*
  CONSTANTS: lc_profile TYPE tvarvc-name VALUE 'SSL_CLIENT_ID'."KRDASH
  DATA : lv_rfc_destination TYPE zrest_config-destination,
         lv_srtfd           TYPE zadf_con_indx-srtfd,
         lw_indx            TYPE zadf_con_indx,
         lt_enveloped_data  TYPE TABLE OF ssfbin,
         lv_cert_string     TYPE xstring,
         lt_recipients      TYPE TABLE OF ssfinfo,
         lw_recipient       TYPE ssfinfo,
         lt_input_data      TYPE TABLE OF ssfbin,
         lw_input_data      TYPE ssfbin,
         lv_env_data_len    TYPE i,
         lv_env_len_total   TYPE i,
         lv_subject         TYPE string,
         lw_enveloped_data  TYPE ssfbin,
         lv_xstr_input      TYPE xstring,
         lv_len_output      TYPE i,
         lv_len_input       TYPE i,
         lt_decoded_bin     TYPE TABLE OF x,
         lv_decoded_str     TYPE string,
         lv_applic          TYPE rfcdisplay-sslapplic,
         lv_psename         TYPE ssfpsename,
         lv_flag_ssf        TYPE c, "Added by KRDASH
**Start of changes by KRDASH MS2K960975
         lv_profilename     TYPE localfile,
**End of changes by KRDASH MS2K960975
         lv_profile         TYPE ssfparms-pab.
  lv_srtfd = gv_interface_id.

  DEFINE decode_key.
*Import internal table as a cluster from INDX
    IMPORT tab  = lt_enveloped_data[]
           FROM DATABASE zadf_con_indx(zd)
           TO lw_indx
           ID lv_srtfd.
**Start of changes by KRDASH
**Fetching data using new encryption framework
    IF ( lt_enveloped_data[] IS INITIAL ) OR
       ( gv_sas_key IS INITIAL ).
      lv_flag_ssf = abap_true.
*Import internal table as a cluster from INDX
      IMPORT tab  = lt_enveloped_data[]
             FROM DATABASE zssf_con_indx(ze)
             TO lw_indx
             ID lv_srtfd.
    ENDIF.
**End of changes by KRDASH
    IF NOT lt_enveloped_data[] IS INITIAL.
**Old encryption framework
      IF lv_flag_ssf EQ abap_false. "Added by KRDASH
        CLEAR lv_rfc_destination.
        SELECT SINGLE destination FROM zrest_config
                                  INTO lv_rfc_destination
                                  WHERE interface_id EQ gv_interface_id.
        IF NOT lv_rfc_destination IS INITIAL .
          CALL FUNCTION 'RFC_READ_HTTP_DESTINATION'
            EXPORTING
              destination             = lv_rfc_destination
              authority_check         = ' '
            IMPORTING
              sslapplic               = lv_applic
            EXCEPTIONS
              authority_not_available = 1
              destination_not_exist   = 2
              information_failure     = 3
              internal_failure        = 4
              no_http_destination     = 5
              OTHERS                  = 6.
          IF sy-subrc NE 0.
            RAISE EXCEPTION TYPE zcx_adf_service
              EXPORTING
                textid       = zcx_adf_service=>read_error_rfc_destination
                interface_id = gv_interface_id.
          ENDIF.
**Start of changes by KRDASH
        ELSE.
          RAISE EXCEPTION TYPE zcx_adf_service
            EXPORTING
              textid       = zcx_adf_service=>rfc_destination_not_maintained
              interface_id = gv_interface_id.
        ENDIF.
      ELSE.
**New Encryption framework
**Fetching PSE profile name from TVARVC table
        CLEAR lv_applic.
        SELECT SINGLE low FROM tvarvc
                      INTO lv_applic
                      WHERE name EQ lc_profile.
        if sy-subrc <> 0.
          CLEAR lv_applic.
          SELECT SINGLE low FROM tvarvc
                        INTO lv_applic
                        WHERE name EQ 'DFAULT'.
        ENdif.
      ENDIF.
**End of changes by KRDASH
      CALL FUNCTION 'SSFPSE_FILENAME'
        EXPORTING
          mandt         = sy-mandt
          context       = 'SSLC'
          applic        = lv_applic
        IMPORTING
          psename       = lv_psename
          profile       = lv_profilename
        EXCEPTIONS
          pse_not_found = 1
          OTHERS        = 2.
      IF sy-subrc NE 0.
        RAISE EXCEPTION TYPE zcx_adf_service
          EXPORTING
            textid       = zcx_adf_service=>read_error_pse_filename
            interface_id = gv_interface_id.
      ENDIF.
      IF NOT lv_psename IS INITIAL.
        lv_profile = lv_psename.
        CALL FUNCTION 'SSFC_GET_CERTIFICATE'
          EXPORTING
            profile               = lv_profile
          IMPORTING
            certificate           = lv_cert_string
          EXCEPTIONS
            ssf_krn_error         = 1
            ssf_krn_nomemory      = 2
            ssf_krn_nossflib      = 3
            ssf_krn_invalid_par   = 4
            ssf_krn_nocertificate = 5
            OTHERS                = 6.
        IF sy-subrc NE 0.
**Start of chnages by KRDASH MS2K960975
**Addinng complete profile path for reading certificate instance
          lv_profile = lv_profilename.
          CALL FUNCTION 'SSFC_GET_CERTIFICATE'
            EXPORTING
              profile               = lv_profile
            IMPORTING
              certificate           = lv_cert_string
            EXCEPTIONS
              ssf_krn_error         = 1
              ssf_krn_nomemory      = 2
              ssf_krn_nossflib      = 3
              ssf_krn_invalid_par   = 4
              ssf_krn_nocertificate = 5
              OTHERS                = 6.
          IF sy-subrc NE 0.
**End of chnages by KRDASH MS2K960975
**Raise Exception
            RAISE EXCEPTION TYPE zcx_adf_service
              EXPORTING
                textid       = zcx_adf_service=>error_get_certificate_instance
                interface_id = gv_interface_id.
          ENDIF. "Added by KRDASH MS2K960975
        ENDIF.
        CALL FUNCTION 'SSFC_PARSE_CERTIFICATE'
          EXPORTING
            certificate         = lv_cert_string
          IMPORTING
            subject             = lv_subject
          EXCEPTIONS
            ssf_krn_error       = 1
            ssf_krn_nomemory    = 2
            ssf_krn_nossflib    = 3
            ssf_krn_invalid_par = 4
            OTHERS              = 5.
        IF sy-subrc NE 0.
**Raise Exception
          RAISE EXCEPTION TYPE zcx_adf_service
            EXPORTING
              textid       = zcx_adf_service=>error_attributes_certificate
              interface_id = gv_interface_id.
        ENDIF.
        lw_recipient-id      = lv_subject.
        lw_recipient-profile = lv_profile.
        APPEND lw_recipient TO lt_recipients.
        LOOP AT lt_enveloped_data INTO lw_enveloped_data.
          lv_env_data_len = xstrlen( lw_enveloped_data-bindata ).
          lv_env_len_total = lv_env_len_total + lv_env_data_len.
          CLEAR lw_enveloped_data.
        ENDLOOP.
        CALL FUNCTION 'SSF_KRN_DEVELOPE'
          EXPORTING
            ssftoolkit                   = 'SAPSECULIB'
            str_format                   = 'PKCS7'
*         B_OUTDEC                     = 'X'
*         IO_SPEC                      = 'T'
            ostr_enveloped_data_l        = lv_env_len_total
          IMPORTING
            ostr_output_data_l           = lv_len_input
*         CRC                          =
          TABLES
            ostr_enveloped_data          = lt_enveloped_data
            recipient                    = lt_recipients
            ostr_output_data             = lt_input_data
          EXCEPTIONS
            ssf_krn_error                = 1
            ssf_krn_noop                 = 2
            ssf_krn_nomemory             = 3
            ssf_krn_opinv                = 4
            ssf_krn_nossflib             = 5
            ssf_krn_recipient_error      = 6
            ssf_krn_input_data_error     = 7
            ssf_krn_invalid_par          = 8
            ssf_krn_invalid_parlen       = 9
            ssf_fb_input_parameter_error = 10
            OTHERS                       = 11.
        IF sy-subrc NE 0.
**Raise Exception
          RAISE EXCEPTION TYPE zcx_adf_service
            EXPORTING
              textid       = zcx_adf_service=>error_decode_sas_key
              interface_id = gv_interface_id.
        ENDIF.
        IF NOT lt_input_data[] IS INITIAL.
          CALL FUNCTION 'SCMS_BINARY_TO_STRING'
            EXPORTING
              input_length  = lv_len_input
            IMPORTING
              text_buffer   = lv_decoded_str
              output_length = lv_len_output
            TABLES
              binary_tab    = lt_input_data
            EXCEPTIONS
              failed        = 1
              OTHERS        = 2.
          IF lv_decoded_str IS INITIAL.
**Raise exception
            RAISE EXCEPTION TYPE zcx_adf_service
              EXPORTING
                textid       = zcx_adf_service=>error_con_saskey_string
                interface_id = gv_interface_id.
          ELSE.
            rv_secret = lv_decoded_str.
          ENDIF.
        ELSE.
**Raise exception
          RAISE EXCEPTION TYPE zcx_adf_service
            EXPORTING
              textid       = zcx_adf_service=>error_read_encoded_saskey
              interface_id = gv_interface_id.
        ENDIF.
      ENDIF.
**Start of comment by KRDASH
**Below lines of code validation have been moved to line no.74
*    ELSE.
*      RAISE EXCEPTION TYPE zcx_adf_service
*        EXPORTING
*          textid       = zcx_adf_service=>rfc_destination_not_maintained
*          interface_id = gv_interface_id.
*    ENDIF.
**End of comment by KRDASH
    ELSE.
**Raise Exception
      RAISE EXCEPTION TYPE zcx_adf_service
        EXPORTING
          textid       = zcx_adf_service=>error_import_sas_key
          interface_id = gv_interface_id.
    ENDIF.
    IF rv_secret IS INITIAL.
      RAISE EXCEPTION TYPE zcx_adf_service
        EXPORTING
          textid       = zcx_adf_service=>sas_key_not_maintained
          interface_id = gv_interface_id.
    ENDIF.
  END-OF-DEFINITION.
  decode_key.
ENDMETHOD.


METHOD format_data.
  CASE iv_format_type.
    WHEN gc_format_xml.
      rv_string = format_data_to_xml( it_data ).
    WHEN gc_format_json.
      rv_string = format_data_to_json( it_data ).
    WHEN OTHERS.
      RAISE EXCEPTION TYPE zcx_adf_service
        EXPORTING
          textid      = zcx_adf_service=>format_not_supported
          format_type = iv_format_type.
  ENDCASE.
ENDMETHOD.


METHOD format_data_to_json.

  DATA : lo_json TYPE REF TO cl_trex_json_serializer.

  CREATE OBJECT lo_json
    EXPORTING
      data = it_data.
  lo_json->serialize( ).
  rv_string  = lo_json->get_data( ).
ENDMETHOD.


METHOD format_data_to_xml.
  CALL TRANSFORMATION ('ID') SOURCE itab = it_data RESULT XML rv_string.
ENDMETHOD.


method GET_EPOCH_TIME.
DATA : lv_start_timestamp   TYPE timestampl,
       lv_current_timestamp TYPE timestampl,
       lv_seconds           TYPE p,
       lv_input_seconds     TYPE p,
       zcx_adf_service      TYPE REF TO zcx_adf_service.
  DATA: date TYPE datum,
        time TYPE uzeit.
*Get the current timestamp
  GET TIME STAMP FIELD  lv_current_timestamp .
*Get the time difference
  DATA zone TYPE sy-zonlo.
  CONVERT TIME STAMP lv_current_timestamp TIME ZONE zone INTO DATE date TIME time.
  TRY.
      CALL METHOD cl_abap_tstmp=>td_subtract
        EXPORTING
          date1    = date
          time1    = time
          date2    = '19700101'
          time2    = '000000'
        IMPORTING
          res_secs = lv_seconds.
* Add expiry time in seconds
      lv_input_seconds = ( ( gv_expiry_hour * 60 ) * 60  ) + ( gv_expiry_min * 60 ) +
                         ( gv_expiry_sec ).
      lv_seconds = lv_seconds + lv_input_seconds.
      rv_expiry_time = lv_seconds.
      CONDENSE rv_expiry_time.
    CATCH cx_parameter_invalid_type.
    RAISE EXCEPTION TYPE zcx_adf_service
      EXPORTING
        textid       = zcx_adf_service=>parameter_invalid_type
        interface_id = gv_interface_id.
    CATCH cx_parameter_invalid_range .
    RAISE EXCEPTION TYPE zcx_adf_service
      EXPORTING
        textid       = zcx_adf_service=>parameter_invalid_range
        interface_id = gv_interface_id.
  ENDTRY.
endmethod.


METHOD get_interface_details.

  DATA : ls_config      TYPE zadf_config,
         lv_host        TYPE rfcdisplay-rfchost,
         lv_host_s      TYPE string,
         lv_path_prefix TYPE string.

  SELECT SINGLE * FROM zadf_config
         INTO ls_config
         WHERE interface_id = gv_interface_id.
  IF sy-subrc <> 0.
    RAISE EXCEPTION TYPE zcx_adf_service
      EXPORTING
        textid       = zcx_adf_service=>interface_not_available
        interface_id = gv_interface_id.
  ENDIF.

  SELECT SINGLE destination FROM zrest_config INTO gv_rfc_destination
       WHERE interface_id = gv_interface_id.
  IF sy-subrc <> 0.
    RAISE EXCEPTION TYPE zcx_adf_service
      EXPORTING
        textid       = zcx_adf_service=>interface_not_available
        interface_id = gv_interface_id.
  ENDIF.

**Getting Target host of RFC destination
  get_target_host( EXPORTING iv_destination = gv_rfc_destination IMPORTING  ev_server = lv_host
                                                                  ev_path_prefix = lv_path_prefix ).
  gv_host = lv_host.
  gv_path_prefix = lv_path_prefix.
  lv_host_s = lv_host.
  CONCATENATE lv_host_s lv_path_prefix INTO gv_uri.
  IF gv_uri IS INITIAL.
    RAISE EXCEPTION TYPE zcx_adf_service
      EXPORTING
        textid       = zcx_adf_service=>uri_not_maintained
        interface_id = gv_interface_id.
  ENDIF.
  IF ls_config-service_type IS INITIAL.
    RAISE EXCEPTION TYPE zcx_adf_service
      EXPORTING
        textid       = zcx_adf_service=>call_type_not_maintained
        interface_id = gv_interface_id.
  ELSE.
    IF ls_config-service_type EQ gc_synchronous.
      gv_asynchronous = abap_false.
    ELSEIF ls_config-service_type EQ gc_asynchronous.
      gv_asynchronous = abap_true.
    ENDIF.
  ENDIF.
  gv_is_try = ls_config-is_try.
  gv_sas_key = ls_config-sas_key. "Added by KRDASH
ENDMETHOD.


METHOD get_rest_api_ref.
  DATA : lcx_interface TYPE REF TO zcx_interace_config_missing,
         lcx_http      TYPE REF TO zcx_http_client_failed,
         lv_method     TYPE char20.
  IF go_rest_api IS INITIAL.
    CLEAR lv_method.
    SELECT SINGLE method FROM zrest_conf_misc
                         INTO lv_method
                         WHERE interface_id EQ gv_interface_id.
    IF lv_method IS INITIAL.
      RAISE EXCEPTION TYPE zcx_adf_service
        EXPORTING
          textid       = zcx_adf_service=>method_not_maintained
          interface_id = gv_interface_id.
    ENDIF.
    TRY.
        CREATE OBJECT go_rest_api
          EXPORTING
            interface_name      = gv_interface_id       "Mandatory
            business_identifier = iv_business_identifier
            method              = lv_method.               "For troubleshooting
      CATCH zcx_interace_config_missing INTO lcx_interface.
        RAISE EXCEPTION lcx_interface.
      CATCH zcx_http_client_failed INTO lcx_http .
        RAISE EXCEPTION lcx_http.
    ENDTRY.
    IF go_rest_api IS BOUND.
*Optional - To help developer understand the origin of call
      go_rest_api->set_callingmethod( EXPORTING zimethodname = 'SEND' ).
*Optional - To help developer understand the origin of call
      go_rest_api->set_callingprogram( EXPORTING ziclassname = 'ZCL_ADF_SERVICE' ).
    ELSE.
      RAISE EXCEPTION TYPE zcx_adf_service
        EXPORTING
          textid       = zcx_adf_service=>error_rest_api_instance
          interface_id = gv_interface_id.
    ENDIF.
  ENDIF.
ENDMETHOD.


METHOD get_sas_token.
  DATA : lv_string_to_sign       TYPE string,
         encoded_base_address    TYPE string,
         body_xstring            TYPE xstring,
         sign                    TYPE string,
         final_token             TYPE string,
         decoded                 TYPE xstring,
         conv                    TYPE REF TO cl_abap_conv_out_ce,
         conv_in                 TYPE REF TO cl_abap_conv_in_ce,
         format                  TYPE i,
         new_expiry              TYPE string,
         lv_sas_key              TYPE string,
         lv_expiry_time          TYPE string.
  get_epoch_time( RECEIVING rv_expiry_time =  lv_expiry_time ).
  format = 18.
  encoded_base_address = escape( val = iv_baseaddress format = format  ).
  CONCATENATE encoded_base_address  cl_abap_char_utilities=>newline lv_expiry_time INTO lv_string_to_sign.

  conv = cl_abap_conv_out_ce=>create( encoding = 'UTF-8' ).
  conv->convert( EXPORTING data = lv_string_to_sign IMPORTING buffer = body_xstring ).
  DEFINE encrypt_key.
    decode_sign( receiving rv_secret = lv_sas_key ).
    conv = cl_abap_conv_out_ce=>create( encoding = 'UTF-8' ).
    conv->convert( exporting data = lv_sas_key importing buffer = decoded ).

    call method cl_abap_hmac=>calculate_hmac_for_raw
      exporting
        if_algorithm     = 'sha-256'
        if_key           = decoded
        if_data          = body_xstring
        if_length        = 0
      importing
        ef_hmacb64string = sign.
    clear : lv_sas_key, decoded.
  END-OF-DEFINITION.
  encrypt_key.
  new_expiry = lv_expiry_time.
  CONDENSE new_expiry.
  IF NOT sign IS INITIAL.
    sign = escape( val = sign format = format  ).
    CONCATENATE 'SharedAccessSignature sr=' encoded_base_address  '&sig=' sign '&se=' new_expiry '&skn=' 'edit' INTO final_token.
    rv_sas_token = final_token.
  ELSE.
    RAISE EXCEPTION TYPE zcx_adf_service
      EXPORTING
        textid       = zcx_adf_service=>sas_key_not_generated
        interface_id = gv_interface_id.
  ENDIF.
ENDMETHOD.


  method GET_TARGET_HOST.
     CALL FUNCTION 'RFC_READ_HTTP_DESTINATION'
    EXPORTING
      destination             = iv_destination
      authority_check         = ' '
      bypass_buf              = iv_bypass_buff
    IMPORTING
      server                  = ev_server
      path_prefix             = ev_path_prefix
    EXCEPTIONS
      authority_not_available = 1
      destination_not_exist   = 2
      information_failure     = 3
      internal_failure        = 4
      no_http_destination     = 5
      OTHERS                  = 6.
  IF sy-subrc <> 0.
* Implement suitable error handling here
    RAISE EXCEPTION TYPE zcx_adf_service
      EXPORTING
        textid       = zcx_adf_service=>read_error_rfc_destination
        interface_id = gv_interface_id.
  ENDIF.
  endmethod.


METHOD json_to_http_fields.
  DATA: ls_fields         TYPE ihttpnvp,
          l_node          TYPE REF TO if_sxml_node,
          l_error         TYPE string,
          lr_open_element TYPE REF TO  if_sxml_open_element,
          lt_attributes   TYPE if_sxml_attribute=>attributes,
          ls_attribute    LIKE LINE OF lt_attributes,
          lr_value_node   TYPE REF TO if_sxml_value_node,
          json            TYPE xstring,
          reader          TYPE REF TO if_sxml_reader,
          parse_error     TYPE REF TO cx_sxml_parse_error.
  TRY .
      json = cl_abap_codepage=>convert_to( iv_response_data ).
      reader = cl_sxml_string_reader=>create( json ).
      " after parse, the json response should look like following

      DO.
        CLEAR ls_fields.
        l_node = reader->read_next_node( ).

        IF l_node IS INITIAL.
          EXIT.
        ENDIF.
        CASE l_node->type.
          WHEN if_sxml_node=>co_nt_element_open.
            lr_open_element ?= l_node.
            lt_attributes  = lr_open_element->get_attributes( ).
            IF lt_attributes IS NOT INITIAL.
              " get name
              READ TABLE lt_attributes INDEX 1 INTO ls_attribute.
              ls_fields-name = ls_attribute->get_value( ).
              " get value
              l_node = reader->read_next_node( ).
              IF l_node->type = if_sxml_node=>co_nt_value..
                lr_value_node ?= l_node .
                ls_fields-value = lr_value_node->get_value( ).
                " add field into the result table
                APPEND ls_fields TO et_fields.
              ENDIF.
            ENDIF.
          WHEN OTHERS.
            " do nothing
        ENDCASE.
      ENDDO.
    CATCH cx_sxml_parse_error INTO parse_error.
      RAISE EXCEPTION TYPE zcx_adf_service
        EXPORTING
          textid       = zcx_adf_service=>parse_error
          interface_id = gv_interface_id.
  ENDTRY.
ENDMETHOD.


METHOD send.
  DATA : lo_response     TYPE REF TO if_rest_entity,
         lo_request      TYPE REF TO if_rest_entity,
         lv_expiry       TYPE string,
         lv_sas_token    TYPE string,
         lv_msg          TYPE string,
         lcx_adf_service TYPE REF TO zcx_adf_service.
  IF go_rest_api IS BOUND.
    TRY.
        get_sas_token( EXPORTING iv_baseaddress = gv_uri
                       RECEIVING rv_sas_token  = lv_sas_token ).
      CATCH zcx_adf_service INTO lcx_adf_service.
        lv_msg =  lcx_adf_service->get_text( ).
        MESSAGE lv_msg TYPE 'I'.
    ENDTRY.
    add_request_header( iv_name = 'Content-Type' iv_value = 'application/json; charset=utf-8' ).
    add_request_header( iv_name = 'Authorization' iv_value = lv_sas_token ).
    go_rest_api->zif_rest_framework~set_binary_body( request ).
    IF NOT it_headers[] IS INITIAL.
      go_rest_api->zif_rest_framework~set_request_headers( it_header_fields = it_headers[] ).
    ENDIF.
**Rest API call to get response from Azure Destination
    lo_response = go_rest_api->zif_rest_framework~execute( io_entity = lo_request async = gv_asynchronous is_retry = gv_is_try ).
    ev_http_status = go_rest_api->get_status( ).
    go_rest_api->close( ).
    IF lo_response IS BOUND.
      response = lo_response->get_string_data( ).
    ELSE.
      RAISE EXCEPTION TYPE zcx_adf_service
        EXPORTING
          textid       = zcx_adf_service=>restapi_response_not_found
          interface_id = gv_interface_id.
    ENDIF.
  ENDIF.
ENDMETHOD.


METHOD urlencoded_to_http_fields.
  DATA:  lt_params  TYPE STANDARD TABLE OF string,
         ls_response_field LIKE LINE OF et_fields.
  FIELD-SYMBOLS:  <l_param> LIKE LINE OF lt_params.
  SPLIT iv_response_data AT `&` INTO TABLE lt_params.
  LOOP AT lt_params ASSIGNING <l_param>.
    SPLIT <l_param> AT `=` INTO ls_response_field-name
                                ls_response_field-value.
    APPEND ls_response_field TO et_fields.
  ENDLOOP.
ENDMETHOD.
ENDCLASS.