require 'itcm_test_harness'
require 'socket'

#Create model for topology
  defaults = {
    :log_severity=>6,
    :log_facility=>3,
    :fragment_size=>1024,
    :itcm_version=>ENV["ITCM_VERSION"] ? ENV["ITCM_VERSION"] : "1.2",
    :dynamic_ag_port_range=>5000...6000,
    :stop_before_uninstall=>true,
    :restart_after_upgrade=>false,
    :version=>ENV["ITCM_VERSION"] ? ENV["ITCM_VERSION"] : "1.2",
    #:qpid_use_ssl=>true, :local_qpid_ssl_cert_db=>File.dirname(__FILE__) + "/SSL_Dbs/host_db", :local_qpid_ssl_password_file=>File.dirname(__FILE__) + "/SSL_Dbs/password_file.txt", :qpid_ssl_cert_name=>"testhost"
    :disable_rpm_deps=>ENV['SOURCE_RUN'] ? true : false
  }
  sma_class_d_defaults = {
    :data_ack_enabled=>false,
    :data_ack_timeout=>1000,
    :data_nak_retry_limit=>5,
    :keep_alive_interval=>3000,
    :ack_retransmit_delay=>100,
    :server_keep_alive_interval=>5000,
    :keep_alive_ack_timeout=>10,
    :connection_attempt_timeout=>100,
    :connection_delay=>10,
    :connection_retry_limit=>5,
    :reconnection_limit=>2
  }
  class_d_defaults = {
    :keep_alive_interval=>0,
    :keep_alive_ack_timeout=>5000,
    :data_ack_enabled=>true,
    :data_ack_timeout=>5000,
    :data_nak_retry_limit=>0,
    :connection_attempt_timeout=>1000,
    :connection_delay=>500,
    :reconnection_limit=>1
  }
  sma_conf_defaults = {
    :SMADebugLevel=>7,
    :SMAEventNotificationLevel=>7,
    :SMAAlertNotificationLevel=>7,
    :agentRoutingQos=>0,
    :timeToLive=>10,
    :batchResponseTimeout=>10,
    :batchResponseCount=>3,
    :fragmentCleanupTimeout=>60,
    :duplicateCheckMessageDepth=>1000
  }
  sma_identity_conf_defaults = {
    :SMSID=>"SMS:ID"
  }
  adapter_options = {
    :poll_interval=>1,
    :qpid_heartbeat=>3
  }

  base_release_version='1.1.3'
  versions = {
    :ag_default_component_version=>base_release_version,
    :asa_default_component_version=>base_release_version,
    :bem_default_component_version=>base_release_version,
    :bf_default_component_version=>base_release_version,
    :cm_default_component_version=>base_release_version,
    :elm_default_component_version=>base_release_version,
    :fh_default_setup_version=>base_release_version,
    :fr_default_component_version=>base_release_version,
    :fs_default_component_version=>base_release_version,
    :ml_default_component_version=>base_release_version,
    :mr_default_component_version=>base_release_version,
    :rmu_default_component_version=>base_release_version
  }

  b.root(defaults+versions) {
    b.transports(:broadcast_class=>7){
      b.transport("Wi-Fi", :cost=>150, :classes=>[0,1,2,3,4,5,6])
      b.transport("Satellite", :cost=>150, :classes=>[0,1,2,3,4,5,6])
      b.transport("Cell", :cost=>150, :classes=>[0,1,2,3,4,5,6])
      b.transport("Cell0", :cost=>150, :classes=>[0,1,2,3,4,5,6])
      b.transport("Cell1", :cost=>150, :classes=>[0,1,2,3,4,5,6])
      b.radio_transport("Radio220", :cost=>150, :classes=>[0,1,2,3,4,5,6])
    }
    b.trace_and_usage {
      b.trace(:enabled=>false)
      b.performance(:enabled=>false)
      b.ag {
        b.system_latency(:enabled=>false)
      }
      b.tnb_ml {
        b.inbound_transport(:enabled=>false)
        b.outbound_transport(:enabled=>false)
      }
      b.bf {
        b.inbound(:enabled=>false)
        b.outbound(:enabled=>false)
      }
    }
    b.host("testhost", :ssh_user=>"tester", :ssh_password=>"tester", :asa_username=>"tester", :asa_password=>"tester")
    b.host("locohost", :ssh_user=>"tester", :ssh_password=>"tester", :asa_username=>"tester", :asa_password=>"tester")
    b.rns(:host=>"rnshost")
    b.company("ARR", :host=>"testhost"){
      b.back_office{
        b.default_as("AS.1"){
          b.default_bob("BR.0", :port=>10001)
          b.systems_management_util
        }
        b.default_is("IS.1", :include_first_router=>true){
          b.default_ib("BR.0", :port=>10002)
          b.message_router('MR.0', :log_severity=>7)
        }
        b.default_frs("FRS.1"){
          b.default_fb("BR.0",:port=>10007)
        }
        b.application_gateway("AG.0", :clusters=>["AS.1"])
        b.application("DefaultApp"){
          b.classd_connection("Connection1", "AG.0", :keep_alive_interval=>1, :keep_alive_ack_timeout=>0, :data_ack_enabled=>false)
        }
        b.asa("ASA.0", :sma_conf=>sma_conf_defaults, :sma_identity_conf=>sma_identity_conf_defaults, :am_topic=>"AMTOPIC", :cluster=>"AS.1"){
          b.classd_connection("AG.0", sma_class_d_defaults)
        }
        b.default_tns("TNS.1"){
          b.default_tnb("BR.0", :port=>10003)
          b.broker("BR.0"){
            b.interface(IPSocket.getaddress("testhost"))
          }
          b.elm('ELM.0', :connected_base_radios=>["v.123456"])
          b.message_router('MR.0', :log_severity=>7)
        }
      }
      b.virtual("v.123456"){
        b.base_station_radio("Base", :port=>50001){
          b.classd(class_d_defaults)
        }
      }
      b.virtual("v.654321"){
        b.base_station_radio("Base", :port=>50002){
          b.classd(class_d_defaults)
        }
      }
      b.default_loco("l.ARR.123456", :host=>"locohost"){
        b.default_rb("BR.0", :port=>10005)
        b.application("DefaultApp"){
          b.classd_connection("Connection1", :keep_alive_interval=>1, :keep_alive_ack_timeout=>0, :data_ack_enabled=>false)
        }
        b.asa("ASA.0", :sma_conf=>sma_conf_defaults, :sma_identity_conf=>sma_identity_conf_defaults, :am_topic=>"AMTOPIC"){
          b.classd_connection(sma_class_d_defaults)
        }
        b.connection_manager("CM.0", :task_pool_size=>1){
          b.amqp_adapter("Wi-Fi",
            adapter_options.merge(:addresses=>["ARR.l.ARR.123456_ARR.b.TNS.1_Wi-Fi:10003"]))
        }
        b.message_router('MR.0', :log_severity=>7)

        b.radio("Radio220", :port=>50003){
          b.classd(class_d_defaults)
        }

        b.app_broker("APP.0", :port=>10019)
        b.app_broker("APP.1", :port=>10020)

        b.application("AppBroker0App",:topics=>["topic0"]){
          b.amqp_connection("Connection0",:broker=>"ARR.l.ARR.123456.APP.0")
        }

        b.application("AppBroker1App", :topics=>["topic1"]){
          b.amqp_connection("Connection1",:broker=>"ARR.l.ARR.123456.APP.1")
        }
      }
    }
    b.company("ALL", :host=>"testhost"){
      b.loco("l.ALL.9000")
      b.wayside("w.900000")
    }
  }