client_soap.rb

require 'socket'
require 'timeout'
require 'net/https'
require 'net/http'

class ClientSoap
  def initialize(template,namespace,config) 
    @template=template
    @namespace=namespace
    p @namespace
    @config=config 
  end
  def format_https(server,request,hparam)
    data=format(request,hparam)
    action=data[/<.*?Action.*?>([^<]+)<\/.*?Action.*?>/,1]
    data         
  end
  def format(request,hparam) 
    buff= @template[:config][request][:req].dup
    @config.each { |k,value| buff.sub!(k,value.to_s) }
    buff.sub!(/<SOAP-ENV:Envelope\s+></,'<SOAP-ENV:Envelope '+@namespace+'><')
    buff.sub!(/<soap:Envelope\s+></,'<soap:Envelope '+@namespace+'><')
    buff.sub!(/(#{@config["HMESSID"]})/,"#{(Time.now.to_f*1000).round}")
    hparam.each { |k,value| buff.gsub!(k,value.to_s) }
    #buff.gsub!(/<wsa5:From>.*?<\/wsa5:From>/,"")    if @config["nonFrom"]
    puts "\n#{'='*80}\n#{buff.gsub("><",">\n<")}\n#{'='*80}\n" if $DEBUG
    buff
  end
  def format_http(server,request,hparam)
    data=format(request,hparam)
    action=data[/<.*?Action.*?>([^<]+)<\/.*?Action.*?>/,1]
    "POST #{server} HTTP/1.1\r\nAccept-Encoding: gzip,deflate\r\nContent-Type: application/soap+xml;charset=UTF-8;action=\"#{action}\"\r\n"+
         "Content-Length: #{data.size}\r\nHost: localhost:9999\r\nConnection: close\r\nUser-Agent: ocpp-simulator"+
         "\r\n\r\n#{data}"
         
  end
  def  https_post(server,buff)

    uri = URI(server)
    req = Net::HTTP::Post.new(uri.path, {'Content-Type' => "application/soap+xml;charset=UTF-8;"})
    req.body = buff
    
    http = Net::HTTP.new(uri.host, uri.port)
    http.use_ssl = true
    http.ssl_version = :TLSv1 
    http.verify_mode = OpenSSL::SSL::VERIFY_NONE # !!!
    
    response=nil
    r= http.start {|http| 
        resp=http.request(req)
        puts "Response: #{resp.inspect}"
        response=resp.read_body
    }
    response.showXmlData("Soap Response :")
    response
  end
  def http_post(server,buff)
    ip=server[/http:\/\/([^:]+):(\d+)\/.*/,1]
    port=server[/http:\/\/([^:]+):(\d+)\/.*/,2]
    puts "Connect to #{ip}  => #{port}  #{server}"
    puts "## #{Time.now} >> connection au serveur #{ip}  => #{port}  #{server}"
    so=TCPSocket.new(ip,port)
    so.sync=true
    puts "## #{Time.now} >> envoie data len=#{buff.size}"
    so.write(buff)
    buff.showXmlData("Soap Request:")
    reponse=""
    puts "## #{Time.now} >> attente reponse"
    timeout(120) { reponse=so.read() }
    puts "## #{Time.now} >> reponse recu len=#{reponse.size}"
    head,rep= reponse.split("\r\n\r\n",2)
    codeResponse=head[/^HTTP\/\d.\d (\d+)/,1].to_i
    if codeResponse!=200
      puts "\n\header received : \n" + head
      return ""
    end
    len= head[/Content-Length: (\d+)\s*\r\n/,1]
    ##rep=so.recv(len.to_i)
    #rep=nil
    #timeout(120) { rep=so.read(len) }
    puts " *** Content-Length =#{len} real=#{rep.size} <<\n#{head}\n>>\n"
    so.close rescue nil
    rep.showXmlData("Soap Response :")
    rep
  rescue Errno::ECONNREFUSED => e
    puts "Echec Connection => #{ip}:#{port} "
    nil
  rescue Exception => e
    puts "#{e} #{e.class} :\n   #{e.backtrace.join("\n   ")}"
    nil
  end
  def csend(server,request,hparam)
    raise("Unknown OCPP request : #{request}")  unless @template[:config][request]
    buff=format_http(server,request,hparam)
    if server =~ /^https:/
       buff=format_https(server,request,hparam)
       puts buff if $DEBUG
       rep=https_post(server,buff)
    else
       buff=format_http(server,request,hparam)
       puts buff if $DEBUG
       rep=http_post(server,buff)
    end
    rep ?  rep.extract_data(@template[:config][request][:ret]||{}) : rep
  end

end