How to use delete method of Airborne Package

Best Airborne code snippet using Airborne.delete

Ozone_Api_Specific_Functions.rb

Source:Ozone_Api_Specific_Functions.rb

...54        response_code_validation("get")55      else56        #$log.info "Original headers: #{Airborne.configuration.headers} <br>"57        temp = Airborne.configuration.headers["Authorization"]58        Airborne.configuration.headers.delete("Authorization")59        Airborne.configuration.headers["Cookie"] = "#{$platform_session}"60        post "/web_setup/state",{"state" => "#{post_state}"}61        response_code_validation("get")62        #$log.info "Temp val: #{temp}"63        Airborne.configuration.headers["Authorization"] = temp64        Airborne.configuration.headers.delete("Cookie")65        $log.info "Val of header after restoring header to old val is: #{Airborne.configuration.headers} <br>"66      end67    end68  end69  def get_websetup_state(expected_state)70    it 'get state of web setup' do71      $log.info "Original headers: #{Airborne.configuration.headers} <br>"72      temp = Airborne.configuration.headers["Authorization"]73      Airborne.configuration.headers["Authorization"] = "Token token=#{$websetup_pin}"74      for i in 0..175        temp_headers = Airborne.configuration.headers76        # $log.info "global_etag: #{global_etag}"77        # etag_val = "#{global_etag}"78        # $log.info "etag_val: #{etag_val}"79        Airborne.configuration.headers["If-None-Match"] = "#{$etag}"80        #$log.info "Val of header is: #{Airborne.configuration.headers} <br>"81        api = '/web_setup/state'82        get api83        if $etag.empty?84          response_code_validation("get",api)85          expect_json('state',"#{expected_state}")86          #$log.info "Json response: #{json_body}"87          #$log.info "#{headers} <br>"88          $etag = headers["etag"]89          $log.info "$etag obtained is: #{$etag} <br>"90        else91          response_code_validation("notmod",api)92          $etag = ""93        end94        Airborne.configuration.headers.delete("If-None-Match")95        $log.info "Val of header after deleting 'if-none-match' is: #{Airborne.configuration.headers} <br>"96      end97      $log.info "Temp val: #{temp}"98      Airborne.configuration.headers["Authorization"] = temp99      #$log.info "Val of header after restoring header to old val is: #{Airborne.configuration.headers} <br>"100    end101  end102  def get_websetup_state_new(expected_state)103    it 'get state of web setup' do104      #$log.info "Original headers: #{Airborne.configuration.headers} <br>"105      temp = Airborne.configuration.headers["Authorization"]106      Airborne.configuration.headers.delete("Authorization")107      Airborne.configuration.headers["Cookie"] = "#{$platform_session}"108      for i in 0..1109        temp_headers = Airborne.configuration.headers110        # $log.info "global_etag: #{global_etag}"111        # etag_val = "#{global_etag}"112        # $log.info "etag_val: #{etag_val}"113        Airborne.configuration.headers["If-None-Match"] = "#{$etag}"114        puts "Val of header is: #{Airborne.configuration.headers} <br>"115        api = '/web_setup/state'116        get api117        if $etag.empty?118          response_code_validation("get",api)119          puts "Json response: #{json_body}"120          puts "#{headers} <br>"121          expect_json('state',"#{expected_state}")122          $etag = headers["etag"]123          puts "$etag obtained is: #{$etag} <br>"124        else125          response_code_validation("notmod",api)126          $etag = ""127        end128        Airborne.configuration.headers.delete("If-None-Match")129        puts "Val of header after deleting 'if-none-match' is: #{Airborne.configuration.headers} <br>"130      end131      #$log.info "Temp val: #{temp}"132      Airborne.configuration.headers["Authorization"] = temp133      Airborne.configuration.headers.delete("Cookie")134      puts "Val of header after restoring header to old val is: #{Airborne.configuration.headers} <br>"135    end136  end137  def get_tinyurl_from_cloud()138    it 'get tinyurl link from cloud(box call)' do139      api = '/switches/pin?shorten_url=true&'140      get api141      response_code_validation("get",api)142      puts "#{json_body} <br>"143      $tiny_url = json_body[:url]144      $websetup_pin = json_body[:pin]145      puts "Tinyurl obtained from cloud is: #{$tiny_url} <br>"146      #$log.info "#{headers} <br>"147    end148  end149  def launch_tinyurl(workflow)150    it 'launching websetup url' do151      if workflow == "negative"152        sleep(180)153        expected_response_code = 404154      else155        expected_response_code = 200156      end157      temp_base_url = Airborne.configuration.base_url158      temp_headers = Airborne.configuration.headers159      #$log.info "Airborne Base url is: #{Airborne.configuration.base_url} is stored temporarily. <br>"160      Airborne.configuration.base_url = nil161      Airborne.configuration.headers = nil162      #$log.info "Airborne Base url overwritten <br>"163      get $tiny_url164      response_code_validation("get", $tiny_url)165      # if workflow == "negative"166      #   expect_status("404")167      # else168      #   response_code_validation("get")169      # end170      Airborne.configuration.base_url = temp_base_url171      Airborne.configuration.headers = temp_headers172      #$log.info "Airborne Base url is restored <br>"173    end174  end175    def launch_setup(workflow)176    it 'launching websetup url' do177      if workflow == "negative"178        sleep(180)179        expected_response_code = 404180      else181        expected_response_code = 200182      end183      temp_base_url = Airborne.configuration.base_url184      temp_headers = Airborne.configuration.headers185      #$log.info "Airborne Base url is: #{Airborne.configuration.base_url} is stored temporarily. <br>"186      Airborne.configuration.base_url = nil187      Airborne.configuration.headers = nil188      #$log.info "Airborne Base url overwritten <br>"189      get $tiny_url190      response_code_validation("get", $tiny_url)191      #expect_status(expected_response_code)192      #puts "#{body}"193      #puts "#{headers}"194      #puts "#{headers["set_cookie"][0]}"195      $platform_session = headers["set_cookie"][0]196      puts "Cookie-Platform Session is: #{$platform_session}"197      #puts "#{json_body}"198      Airborne.configuration.base_url = temp_base_url199      Airborne.configuration.headers = temp_headers200      #$log.info "Airborne Base url is restored <br>"201    end202  end203  def post_pin_during_setup()204    it 'posts pin during websetup' do   205      #temp = Airborne.configuration.headers["Authorization"]206      Airborne.configuration.headers["Cookie"] = "#{$platform_session}"207      req_body = {"pin[pin]" => "#{$websetup_pin}"}208      puts "req body is: #{req_body}"209      post '/setup',req_body210      response_code_validation("get")211      puts "#{response}"212      puts "#{headers}"213      #puts "#{json_body}"214      Airborne.configuration.headers.delete("Cookie")215    end216  end217  def delete_all_extern_accs()218    it "should validate response of '/extern_account/delete_all' api" do219      delete '/extern_account/delete_all',{}220      # 1.Response Code Validation221      response_code_validation("get")222      #$log.info "Completed response code validation<br>"223    end224  end225  def post_services_switch_profile(services)226    it "should post services to switch which were selected during web setup" do227      req_body = ""228      #$log.info "Original headers: #{Airborne.configuration.headers} <br>"229      temp = Airborne.configuration.headers["Authorization"]230      Airborne.configuration.headers["Authorization"] = "Token token=#{$websetup_pin}"231      #Airborne.configuration.headers["Authorization"] = "Token token=da94"232      #$log.info "Val of header after modifying authorization key with the websetup pin' is: #{Airborne.configuration.headers}"233      if services == "all"234        $log.info "inside services=all"235        req_body = {"services" => ['amazon','hbogo','hulu','showtimeanytime','showtime','hbonow','vudu','youtube','netflixusa']}236      else237        req_body = {"services" => [services]}238      end239      post '/switches/profiles', req_body240      response_code_validation("get")241      #Airborne.configuration.headers.delete("Authorization")242      #$log.info "Temp val: #{temp}"243      Airborne.configuration.headers["Authorization"] = temp244      #$log.info "Val of header after restoring header to old val is: #{Airborne.configuration.headers} <br>"245    end246  end247  def post_services_switch_profile_new(services)248    it "should post services to switch which were selected during web setup" do249      req_body = ""250      #$log.info "Original headers: #{Airborne.configuration.headers} <br>"251      # temp = Airborne.configuration.headers["Authorization"]252      # Airborne.configuration.headers.delete("Authorization")253      # #Airborne.configuration.headers["Authorization"] = "Token token=#{$websetup_pin}"254      # Airborne.configuration.headers["Cookie"] = "#{$platform_session}"255      #Airborne.configuration.headers["Authorization"] = "Token token=da94"256      #$log.info "Val of header after modifying authorization key with the websetup pin' is: #{Airborne.configuration.headers}"257      if services == "all"258        $log.info "inside services=all"259        req_body = {"services" => ['amazon','hbogo','hulu','showtimeanytime','showtime','hbonow','vudu','youtube','netflixusa']}260      else261        req_body = {"services" => [services]}262      end263      post '/switches/profiles', req_body264      response_code_validation("get")265     # Airborne.configuration.headers.delete("Cookie")266      #$log.info "Temp val: #{temp}"267     # Airborne.configuration.headers["Authorization"] = temp268      #$log.info "Val of header after restoring header to old val is: #{Airborne.configuration.headers} <br>"269    end270  end271  def get_services_switch_profile(services)272    it "should get services selected during web setup" do273      api = '/switches/profiles'274      get api275      response_code_validation("get",api)276      #$log.info "#{json_body} <br>"277      if services == "all"278        expect_json("services",['amazon','hbogo','hulu','showtimeanytime','showtime','hbonow','vudu','youtube','netflixusa'])279      else280        req_body = {"services" => [services]}281      end282      #services_ = json_body[:services]283    end284  end285  def get_services_switch_profile_new(services)286    it "should get services selected during web setup" do287      get '/switches/profiles'288      response_code_validation("get")289      #$log.info "#{json_body} <br>"290      if services == "all"291        expect_json("services",['amazon','hbogo','hulu','showtimeanytime','showtime','hbonow','vudu','youtube','netflixusa'])292      else293        req_body = {"services" => [services]}294      end295      #services_ = json_body[:services]296    end297  end298  def post_externaccs_old(type)299    it "should post externaccs" do300        #Load the yml file which contains the test data301      test_data = YAML.load_file('spec/all_externacc_creation_spec/post_externaccs_testdata_old.yml')302      #Get the testdata303      completedata = test_data['testdata']304      reset_test_variables()305      datasets = completedata.keys306      if type == "websetup"307        #puts "Original headers: #{Airborne.configuration.headers} <br>"308        temp = Airborne.configuration.headers["Authorization"]309        Airborne.configuration.headers["Authorization"] = "Token token=#{$websetup_pin}"310        #puts "Val of header after modifying authorization key with the websetup pin' is: #{Airborne.configuration.headers}"311      elsif type == "websetup_new"312        temp = Airborne.configuration.headers["Authorization"]313        Airborne.configuration.headers.delete("Authorization")314        Airborne.configuration.headers["Cookie"] = "#{$platform_session}"315      end316      datasets.each do |individual_dataset|317 318        begin319          dataset = completedata[individual_dataset]320          service_name = dataset['service_name']321          #Form the complete api url322          api = dataset['api']323          api_url = $base_url + api324          #Get the request body325          req_body = dataset['request_body']326          req_body_class = req_body.class327          #puts "Request body class : #{req_body_class}<br>"328          #puts "Request body is : #{req_body}<br>"329          $total_count = $total_count + 1330          puts "Total count: #{$total_count}<br>"331          puts "The complete url to be tested is - #{api_url}<br>"332          post api, req_body333          # 1.Response Code Validation334          response_code_validation("post")335          puts "Completed response code validation<br>"336          $resp_code_validation_status = true337 338        rescue Exception => exp_err339            exception_handling(exp_err,dataset,api_url)340        ensure341            reset_iteration_variables()342        end343        pass_or_fail_test_based_on_exceptions_caught(api_url)344      end345      if type == "websetup"346        #puts "Temp val: #{temp}"347        Airborne.configuration.headers["Authorization"] = temp348        #puts "Val of header after restoring header to old val is: #{Airborne.configuration.headers} <br>"349      elsif type == "websetup_new"350        Airborne.configuration.headers.delete("Cookie")351        Airborne.configuration.headers["Authorization"] = temp352      end353    end354  end355  def post_externaccs(type)356    it "should post externaccs" do357        #Load the yml file which contains the test data358      test_data = YAML.load_file('spec/all_externacc_creation_spec/post_externaccs_testdata.yml')359      #Get the testdata360      completedata = test_data['testdata']361      reset_test_variables()362      datasets = completedata.keys363      if type == "websetup"364        #$log.info "Original headers: #{Airborne.configuration.headers} <br>"365        temp = Airborne.configuration.headers["Authorization"]366        Airborne.configuration.headers["Authorization"] = "Token token=#{$websetup_pin}"367        #$log.info "Val of header after modifying authorization key with the websetup pin' is: #{Airborne.configuration.headers}"368      elsif type == "websetup_new"369        temp = Airborne.configuration.headers["Authorization"]370        Airborne.configuration.headers.delete("Authorization")371        Airborne.configuration.headers["Cookie"] = "#{$platform_session}"372      end373      datasets.each do |individual_dataset|374 375        begin376          dataset = completedata[individual_dataset]377          service_name = dataset['service_name']378          #Form the complete api url379          api = dataset['api']380          api_url = $base_url + api381          #Get the request body382          req_body = dataset['request_body']383          req_body_class = req_body.class384          service_providers = req_body.keys385          if  service_providers.length == 1386          #$log.info "Request body class : #{req_body_class}<br>"387          #$log.info "Request body is : #{req_body}<br>"388            $total_count = $total_count + 1389            $log.info "Total count: #{$total_count}<br>"390            $log.info "The complete url to be tested is - #{api_url}<br>"391            post api, req_body392            # 1.Response Code Validation393            response_code_validation("post")394            $log.info "Completed response code validation<br>"395            $resp_code_validation_status = true396          elsif service_providers.length == 3397            service_providers.each do |serv_provider|398              $log.info "Service provider is: #{serv_provider}"399              req_body_individual = req_body[serv_provider]400              set_auth_token_in_req_header(serv_provider)401              $total_count = $total_count + 1402              $log.info "Total count: #{$total_count}<br>"403              $log.info "The complete url to be tested is - #{api_url}<br>"404              post api, req_body_individual405              # 1.Response Code Validation406              response_code_validation("post")407              $log.info "Completed response code validation<br>"408              $resp_code_validation_status = true409            end410            set_auth_token_in_req_header("directv")411          end412 413        rescue Exception => exp_err414            exception_handling(exp_err,dataset,api_url)415        ensure416            reset_iteration_variables()417        end418        pass_or_fail_test_based_on_exceptions_caught(api_url)419      end420      if type == "websetup"421        #$log.info "Temp val: #{temp}"422        Airborne.configuration.headers["Authorization"] = temp423        #$log.info "Val of header after restoring header to old val is: #{Airborne.configuration.headers} <br>"424      elsif type == "websetup_new"425        Airborne.configuration.headers.delete("Cookie")426        Airborne.configuration.headers["Authorization"] = temp427      end428    end429  end430  def retry_post_extern_acc_old(array_of_failed_login_attempts)431   # it 'retry posting extern account which failed previously' do432      #Load the yml file which contains the test data433      puts "Inside retry post, loading yaml file"434      test_data = YAML.load_file('spec/all_externacc_creation_spec/post_externaccs_testdata.yml')435      puts "Array of failed services login: #{array_of_failed_login_attempts}   "436      #Get the testdata437      completedata = test_data['testdata']438      reset_test_variables()439      datasets = completedata.keys440 441      datasets.each do |individual_dataset|442        puts "Inside each do loop"443        dataset = completedata[individual_dataset]444        service_name = dataset['service_name']445        puts "Current service to be posted is: #{service_name}"                                        446        if !array_of_failed_login_attempts.include? service_name447          puts "#{service_name} has been successfully logged into, hence going to next service without posting account once again"448          next449        else450          puts "#{service_name} had login failed status, hence going to post credentials once again"451        end452        #begin453 454        #Form the complete api url455        api = dataset['api']456        api_url = $base_url + api457        #Get the request body458        req_body = dataset['request_body']459        req_body_class = req_body.class460        #puts "Request body class : #{req_body_class}<br>"461        #puts "Request body is : #{req_body}<br>"462        $total_count = $total_count + 1463        puts "Total count: #{$total_count}<br>"464        puts "The complete url to be tested is - #{api_url}<br>"465        post api, req_body466        # 1.Response Code Validation467        response_code_validation("post")468        puts "Completed response code validation<br>"469        $resp_code_validation_status = true470 471        # rescue Exception => exp_err472        #     exception_handling(exp_err,dataset,api_url)473        # ensure474        #     reset_iteration_variables()475        # end476        # pass_or_fail_test_based_on_exceptions_caught(api_url)477      end478    #end479  end480  def retry_post_extern_acc(array_of_failed_login_attempts)481   # it 'retry posting extern account which failed previously' do482      #Load the yml file which contains the test data483      $log.info "Inside retry post, loading yaml file"484      test_data = YAML.load_file('spec/all_externacc_creation_spec/post_externaccs_testdata.yml')485      $log.info "Array of failed services login: #{array_of_failed_login_attempts}"486      #Get the testdata487      completedata = test_data['testdata']488      reset_test_variables()489      datasets = completedata.keys490 491      datasets.each do |individual_dataset|492        $log.info "Inside each do loop"493        dataset = completedata[individual_dataset]494        service_name = dataset['service_name']495        $log.info "Current service to be posted is: #{service_name}"                                        496        array_of_failed_login_attempts.each do |ind_hash|497          serv_prov = ind_hash.keys[0]498          arr_of_failed_logins = ind_hash[serv_prov]499          if !arr_of_failed_logins.include? service_name500            $log.info "#{service_name} has been successfully logged into, hence going to next service without posting account once again"501            next502          else503            $log.info "#{service_name} had login failed status, hence going to post credentials once again"504          end505          #begin506          $log.info "Service provider is: #{serv_prov}"507          req_body = dataset['request_body']508          req_body_individual = req_body[serv_provider]509          set_auth_token_in_req_header(serv_provider)510          #Form the complete api url511          api = dataset['api']512          api_url = $base_url + api513          $total_count = $total_count + 1514          $log.info "Total count: #{$total_count}<br>"515          $log.info "The complete url to be tested is - #{api_url}<br>"516          post api, req_body_individual517          # 1.Response Code Validation518          response_code_validation("post")519          $log.info "Completed response code validation<br>"520          $resp_code_validation_status = true521        end522        set_auth_token_in_req_header("directv")523        # rescue Exception => exp_err524        #     exception_handling(exp_err,dataset,api_url)525        # ensure526        #     reset_iteration_variables()527        # end528        # pass_or_fail_test_based_on_exceptions_caught(api_url)529      end530    #end531  end532  #   def retry_post_extern_acc(array_of_failed_login_attempts)533  #  # it 'retry posting extern account which failed previously' do534  #     #Load the yml file which contains the test data535  #     $log.info "Inside retry post, loading yaml file"536  #     test_data = YAML.load_file('spec/all_externacc_creation_spec/post_externaccs_testdata.yml')537  #     $log.info "Array of failed services login: #{array_of_failed_login_attempts}"538  #     #Get the testdata539  #     completedata = test_data['testdata']540  #     reset_test_variables()541  #     datasets = completedata.keys542 543  #     datasets.each do |individual_dataset|544  #       $log.info "Inside each do loop"545  #       dataset = completedata[individual_dataset]546  #       service_name = dataset['service_name']547  #       $log.info "Current service to be posted is: #{service_name}"                                        548  #       array_of_failed_login_attempts.each do |ind_hash|549  #         serv_prov = ind_hash.keys[0]550  #         arr_of_failed_logins = ind_hash[serv_prov]551  #         if !arr_of_failed_logins.include? service_name552  #           $log.info "#{service_name} has been successfully logged into, hence going to next service without posting account once again"553  #           next554  #         else555  #           $log.info "#{service_name} had login failed status, hence going to post credentials once again"556  #         end557  #         #begin558  #         $log.info "Service provider is: #{serv_prov}"559  #         req_body = dataset['request_body']560  #         req_body_individual = req_body[serv_provider]561  #         set_auth_token_in_req_header(serv_provider)562  #         #Form the complete api url563  #         api = dataset['api']564  #         api_url = $base_url + api565  #         $total_count = $total_count + 1566  #         $log.info "Total count: #{$total_count}<br>"567  #         $log.info "The complete url to be tested is - #{api_url}<br>"568  #         post api, req_body_individual569  #         # 1.Response Code Validation570  #         response_code_validation("post")571  #         $log.info "Completed response code validation<br>"572  #         $resp_code_validation_status = true573  #       end574  #       set_auth_token_in_req_header("directv")575  #       # rescue Exception => exp_err576  #       #     exception_handling(exp_err,dataset,api_url)577  #       # ensure578  #       #     reset_iteration_variables()579  #       # end580  #       # pass_or_fail_test_based_on_exceptions_caught(api_url)581  #     end582  #   #end583  # end584  def get_externacc_login_status_old()585    retry_attempt = 0586    it "should validate the login status of various services" do587      begin588        timestamp = Time.now.strftime("%d_%m_%Y_%H:%M")589        puts "#{timestamp}: Sleeping for 3 mins for login crawlers to complete<br>"590        sleep(180)591        api = '/extern_account'592        get api593        response_code_validation("get",api)594        puts "JSON response is: #{json_body} <br><br>"595        resp = json_body596        expect_json("*.login_status", "login_success")597      rescue Exception => exp598        puts "Increment of retry attempt"599        retry_attempt = retry_attempt + 1600        array_to_retry_extern_acc_post = populate_array_of_failed_services(resp)601        puts "Services to retry posting: #{array_to_retry_extern_acc_post}"602        retry_post_extern_acc(array_to_retry_extern_acc_post)603        sleep(20)604        if retry_attempt < 3605          puts "Retry attempt is lt 3, retrying again"606          retry607        else608          retry_attempt = 0609          raise "Extern acc login failure for the following services : #{array_to_retry_extern_acc_post}"610        end611      end612    end613  end614  def get_externacc_login_status()615    it "should validate the login status of various services" do616      timestamp = Time.now.strftime("%d_%m_%Y_%H:%M")617      array_to_retry_extern_acc_post = Array.new618      resp = nil619      wait_time = false620      (1..3).each do |i|621        $log.info "i try: #{i}"622        $all_service_providers.each do |serv_prov|623          begin624            if !wait_time625              $log.info "#{timestamp}: Sleeping for 3 mins for login crawlers to complete<br>"626              sleep(180)627              wait_time = true628            end629            set_auth_token_in_req_header(serv_prov)630            get '/extern_account'631            response_code_validation("get",'/extern_account')632            $log.info "JSON response is: #{json_body} <br><br>"633            resp = json_body634            expect_json("*.login_status", "login_success")635          rescue Exception => exp636            $log.info "Increment of retry attempt"637            populated_hash = populate_hash_of_failed_services(serv_prov,resp)638            if !populated_hash.empty?639              array_to_retry_extern_acc_post.push(populated_hash)640            end641          end642          $log.info "array_to_retry_extern_acc_post inside second loop: #{array_to_retry_extern_acc_post}"643          next644        end645        $log.info "array_to_retry_extern_acc_post inside first loop: #{array_to_retry_extern_acc_post}"646        if !array_to_retry_extern_acc_post.empty?647          retry_post_extern_acc(array_to_retry_extern_acc_post)648          $log.info "Services to retry posting: #{array_to_retry_extern_acc_post}"649          sleep(5)650          if i < 3651            $log.info "Retry attempt is lt 3, retrying again"652            wait_time = false653            timestamp = Time.now.strftime("%d_%m_%Y_%H:%M")654            array_to_retry_extern_acc_post = Array.new655            next656          else657            raise "Extern acc login failure for the following services : #{array_to_retry_extern_acc_post}"658          end659        else660          $log.info "Done with test"661          set_auth_token_in_req_header("directv")662          break663        end664      end665    end666  end667  def populate_hash_of_failed_services(serv_provider=nil,response)668    hash_of_failed_login_services = {}669    array_of_failed_login_services = Array.new670    resp_length = response.length671    for i in 0..resp_length-1672      status = response[i][:login_status]673      if status != "login_success"674        if status == "login_failed" or status == "captcha_asked"675          serv_name = response[i][:service]676          $log.info "Login status #{response[i][:login_status]} is seen for: #{serv_name} app with service provider #{serv_provider}"677          array_of_failed_login_services.push(serv_name)678        end679      end680    end681    if !array_of_failed_login_services.empty?682      hash_of_failed_login_services[serv_provider] = array_of_failed_login_services683    end684    hash_of_failed_login_services685  end686  def delete_tinyurl()687    it 'delete tinyurl link' do688     # $log.info "Original headers: #{Airborne.configuration.headers} <br>"689      temp = Airborne.configuration.headers["Authorization"]690      Airborne.configuration.headers["Authorization"] = "Token token=#{$websetup_pin}"691      #$log.info "Val of header after modifying authorization key with the websetup pin' is: #{Airborne.configuration.headers}"692      delete '/switches/pin'693      response_code_validation("get")694     # $log.info "Temp val: #{temp}"695      Airborne.configuration.headers["Authorization"] = temp696      #$log.info "Val of header after restoring header to old val is: #{Airborne.configuration.headers} <br>"697    end698  end699  def search_for_program_and_return_prog_id(program_name,log)700    begin701      search_api = "/voice_command?version=3&query=" + program_name702      get search_api703      #$log.info "Response is: #{json_body}"704      ott_search_index = get_index_of_ott_search_object(json_body)705      ott_search_resp = json_body[ott_search_index][:results]706      resp_len = ott_search_resp.length707      for i in 0..resp_len-1708        prog_obj = ott_search_resp[i][:object]709        if prog_obj[:long_title].casecmp(program_name).zero? and prog_obj[:show_type] == "SM"710          $log.info "Search successful and this series is available in cloud"711          prog_id = prog_obj[:id]712          break713        elsif i == resp_len-1714          $log.info "Program not available in cloud"715          prog_id = nil716        end717      end718      prog_id719    rescue Exception => ex720      #$log.info "Error!!!: #{ex} <br>"721      #log.error "Exception caught in iteration #{iter}!!!: #{ex} <br>"722      $log.info "Backtrace: #{ex.backtrace}<br>"723      log.error "Exception!!!: #{ex} <br"724    rescue Error => err725      #$log.info "Error!!!: #{ex} <br>"726      #log.error "Error in iteration #{iter}!!!: #{err} <br>"727      #$log.info "Backtrace: #{ex.backtrace}<br>"728      log.error "Error!!!: #{err} <br"729    end730  end731  def comprehensive_search_for_series_and_return_prog_id(program_name,service_name,year,seasons_on_portal,log)732    arr_matching_progs = Array.new733    search_term = program_name734    search_term=search_term.gsub(/[&]/, 'and')735    search_term=search_term.gsub(" ", '%20')736    search_term=search_term.gsub("'","%27")737    search_api = "/voice_search?q=" + search_term738    get search_api739    response_code_validation("get",search_api)740    program_name=program_name.downcase741    program_name = prepare_for_search_comparison(program_name)742    log.info "program_name after processing: #{program_name}"743 744    if !json_body.empty?745      log.info "Response is: #{json_body}"746      ott_search_index = get_index_of_ott_search_object(json_body,log)747      ott_search_resp = json_body[ott_search_index][:results]748      progids = Array.new749      resp_len = ott_search_resp.length750      for i in 0..resp_len-1751        log.info "For loop: To find matching programs by title"752        prog_obj = ott_search_resp[i][:object]753        long_title=prog_obj[:long_title].downcase754        long_title = prepare_for_search_comparison(long_title)755        log.info "long_title after processing: #{long_title}"756        original_title=prog_obj[:original_title].downcase757        original_title = prepare_for_search_comparison(original_title)758        log.info "original_title after processing: #{original_title}"759 760        alias_title=prog_obj[:alias_title].downcase761        alias_title = prepare_for_search_comparison(alias_title)762        log.info "alias_title after processing: #{alias_title}"763 764        show_type = prog_obj[:show_type]765        if (long_title.include? program_name or original_title.include? program_name or alias_title.include? program_name) and (show_type == "SM" or show_type == "SE")766          log.info "Search successful and this series is available in cloud"767          if show_type == "SM"768            prog_id = prog_obj[:id]769            rel_year = prog_obj[:release_year]770            seas_cnt = prog_obj[:season_cnt]771          elsif show_type == "SE"772            prog_id = prog_obj[:series_id]773            if progids.include? prog_id774              next775            end776            prog_api = "/programs/#{prog_id}"777            get prog_api778            response_code_validation("get",prog_api)779            rel_year = json_body[0][:release_year]780            seas_cnt = json_body[0][:season_cnt]781          end782          progids.push(prog_id)783          arr_matching_progs.push([prog_id,rel_year,seas_cnt])784          # if !arr_matching_progs.include? [prog_id,rel_year,seas_cnt]785          #   arr_matching_progs.push([prog_id,rel_year,seas_cnt])786          #   #break787          # end788        # elsif i == resp_len-1789        #   $log.info "Program not available in cloud"790        #   prog_id = nil791        end792      end793      log.info "END OF For loop: To find matching programs by title"794      matches_len = arr_matching_progs.length795      if matches_len == 0796        log.info "No matches found, prog id - nil"797        prog_id = nil798      elsif matches_len == 1799        log.info "Exactly 1 match found, program id to be returned is :#{arr_matching_progs[0][0]}"800        prog_id = arr_matching_progs[0][0]801      else802        log.info "More than one matching program by title, go deeper to find match"803        arr_matching_progs_after_rel_year_comp = Array.new804        for i in 0..matches_len-1805          log.info "For loop: To find matching programs by release year"806          # service_name807          # if series_name.include? "netflix"808          #   approx_release_year = year.to_i - seasons_on_portal.to_i + 1809          # elsif series_name =="showtime"810          #   approx_release_year = year.to_i811          # end812          if !service_name.nil? and service_name.include? "netflix"813            approx_release_year = year.to_i - seasons_on_portal.to_i + 1814          elsif !service_name.nil? and service_name =="showtime"815            approx_release_year = year.to_i816          else817            approx_release_year = year.to_i818          end819          approx_release_year_range = Array.new820          approx_release_year_range.push(approx_release_year)821          approx_release_year_range.push(approx_release_year+1)822          approx_release_year_range.push(approx_release_year-1)823          rel_year_of_match = arr_matching_progs[i][1]824          if approx_release_year_range.include? rel_year_of_match825            log.info "Approx release year match, push to array of programs matched by approx release year"826            arr_matching_progs_after_rel_year_comp.push(arr_matching_progs[i])827          end828        end829        log.info "END OF For loop: To find matching programs by release year"830        matches_after_rel_year_comp_len = arr_matching_progs_after_rel_year_comp.length831        if matches_after_rel_year_comp_len == 1832          log.info "1 program got after approx release year match, return prog if as #{arr_matching_progs_after_rel_year_comp[0][0]}"833          prog_id = arr_matching_progs_after_rel_year_comp[0][0]834        else835          if matches_after_rel_year_comp_len == 0836            log.info "No matches found by approx release year, proceed to approx season count check atleast"837            arr_matching_progs_after_seas_cnt_comp = Array.new838            approx_seas_cnt_range = Array.new839            for i in 0..matches_len-1840              #$log.info "For loop: To find matching programs by season count, if release year matches were not found"841              log.info "For loop: To find matching programs by season count, if release year matches were not found"842              sn_cnt = seasons_on_portal.to_i843              approx_seas_cnt_range.push(sn_cnt)844              approx_seas_cnt_range.push(sn_cnt+1)845              approx_seas_cnt_range.push(sn_cnt-1)846              seas_cnt_of_match = arr_matching_progs[i][2]847              if approx_seas_cnt_range.include? seas_cnt_of_match848                #$log.info "Approx season count match, push to array of programs matched by approx season count"849                log.info "Approx season count match, push to array of programs matched by approx season count"850                arr_matching_progs_after_seas_cnt_comp.push(arr_matching_progs[i])851              end852            end853            #$log.info "END OF For loop: To find matching programs by season count, if release year matches were not found"854            log.info "END OF For loop: To find matching programs by season count, if release year matches were not found"855            if arr_matching_progs_after_seas_cnt_comp.length > 0856              #$log.info "Programs matched by approx season count is 1 or more, take the first object as program id"857              log.info "Programs matched by approx season count is 1 or more, take the first object as program id"858              prog_id = arr_matching_progs_after_seas_cnt_comp[0][0]859            else860              #$log.info "Could match by season count too, even after no match was found by approx release year, return prog id as nil"861              log.info "Could'nt match by season count too, even after no match was found by approx release year, return prog id as nil"862              prog_id = nil863            end864          else865            log.info "More than 1 matches found by approx release year check, proceed to approx season count check."866            final_matching_progs = Array.new867            approx_seas_cnt_range = Array.new868            for i in 0..matches_after_rel_year_comp_len-1869              log.info "For loop: To find matching programs by season count, when more than 1 release year matches were found"870              sn_cnt = seasons_on_portal.to_i871              approx_seas_cnt_range.push(sn_cnt)872              approx_seas_cnt_range.push(sn_cnt+1)873              approx_seas_cnt_range.push(sn_cnt-1)874              seas_cnt_of_match = arr_matching_progs_after_rel_year_comp[i][2]875              if approx_seas_cnt_range.include? seas_cnt_of_match876                #$log.info "Match found with approx season count, push to array of final matching progs"877                log.info "Match found with approx season count, push to array of final matching progs"878                final_matching_progs.push(arr_matching_progs_after_rel_year_comp[i])879              end880            end881            #$log.info "END OF For loop: To find matching programs by season count, when more than 1 release year matches were found"882            log.info "END OF For loop: To find matching programs by season count, when more than 1 release year matches were found"883            if final_matching_progs.length > 0884              #$log.info "Final matching progs is 1 or more, take the first object as program id"885              log.info "Final matching progs is 1 or more, take the first object as program id"886              prog_id = final_matching_progs[0][0]887            else888              #$log.info "Take the first program which was matched with approx release year"889              log.info "Take the first program which was matched with approx release year"890              prog_id = arr_matching_progs_after_rel_year_comp[0][0]891            end892          end893        end894      end895    else896      $log.info "json body is empty, therefore return prog id-nil"897      log.info "json body is empty, therefore return prog id-nil"898      prog_id = nil899    end900    prog_id901  end902  def search_for_movie_and_return_prog_id(program_name,release_year,log)903    program_name=program_name.gsub(/[&]/, 'and')904    search_term=program_name905    search_term=search_term.gsub(" ","%20")906    search_term=search_term.gsub("'","%27")907    search_api = "/voice_command?version=3&query=" + search_term908    get search_api909    #$log.info "Response is: #{json_body}"910    log.info "Response is: #{json_body}"911    program_name = program_name.downcase912    program_name = prepare_for_search_comparison(program_name)913    #$log.info "program_name after processing: #{program_name}"914    log.info "program_name after processing: #{program_name}"915    ott_search_index = get_index_of_ott_search_object(json_body)916    ott_search_resp = json_body[ott_search_index][:results]917    resp_len = ott_search_resp.length918    release_year_range = Array.new919    release_year_range.push(release_year)920    release_year_range.push(release_year+1)921    release_year_range.push(release_year-1)922    for i in 0..resp_len-1923      prog_obj = ott_search_resp[i][:object]924      long_title=prog_obj[:long_title].downcase925      long_title = prepare_for_search_comparison(long_title)926     # $log.info "long_title after processing: #{long_title}"927      log.info "long_title after processing: #{long_title}"928      original_title=prog_obj[:original_title].downcase929      original_title = prepare_for_search_comparison(original_title)930     # $log.info "original_title after processing: #{original_title}"931      log.info "original_title after processing: #{original_title}"932 933      alias_title=prog_obj[:alias_title].downcase934      alias_title = prepare_for_search_comparison(alias_title)935      #$log.info "alias_title after processing: #{alias_title}"936      log.info "alias_title after processing: #{alias_title}"937     # if prog_obj[:long_title].casecmp(program_name).zero? and prog_obj[:show_type] == "MO" and release_year_range.include? prog_obj[:release_year]938      #if (program_name == long_title or program_name == original_title or program_name == alias_title) and prog_obj[:show_type] == "MO" and release_year_range.include? prog_obj[:release_year]939      if (long_title.include? program_name or original_title.include? program_name or alias_title.include? program_name) and prog_obj[:show_type] == "MO" and release_year_range.include? prog_obj[:release_year]940        #$log.info "Search successful and this movie is available in cloud"941        log.info "Search successful and this movie is available in cloud"942        prog_id = prog_obj[:id]943        break944      elsif i == resp_len-1945       # $log.info "Movie not available in cloud"946        log.info "Movie not available in cloud"947        prog_id = nil948      end949    end950    prog_id951  end952  def get_program_id_of_episode(prog_id,season_no,episode_no,log)953    begin954      api = "/programs/" + prog_id.to_s + "/episodes?season_number=" + season_no955      get api956      $log.info "Episode response is: #{json_body}"957      episode_obj_count = json_body.length958      for i in 0..episode_obj_count-1959        ep_obj = json_body[i]960        ep_no = episode_no.to_i961        #$log.info "Going to compare #{ep_obj[:episode_season_sequence]} and #{ep_no}"962        if ep_obj[:episode_season_sequence] == ep_no963          episode_program_id = ep_obj[:id]964          break965        else966          episode_program_id = nil967        end968      end969      episode_program_id970    rescue Exception => ex971      #$log.info "Error!!!: #{ex} <br>"972      #log.error "Exception caught in iteration #{iter}!!!: #{ex} <br>"973      #$log.info "Backtrace: #{ex.backtrace}<br>"974      log.error "Exception!!!: #{ex} <br"975      log.error "Backtrace: #{ex.backtrace}<br>"976    rescue Error => err977      #$log.info "Error!!!: #{ex} <br>"978      #log.error "Error in iteration #{iter}!!!: #{err} <br>"979      #$log.info "Backtrace: #{ex.backtrace}<br>"980      log.error "Error!!!: #{err} <br"981    end982  end983  def get_series_season_and_episode_number(prog_id,log)984    api = "/programs/" + prog_id.to_s985    get api986    expect_status('200')987    if !json_body.empty?988      resp = json_body[0]989      $log.info "Program response is: #{resp}"990      log.info "Program response is: #{resp}"991      show_type = resp[:show_type]992      if show_type == "SE"993        series_name = resp[:long_title]994        se_no = resp[:episode_season_number]995        ep_no = resp[:episode_season_sequence]996        ep_title = resp[:episode_title]997        arr = Array.new998        arr.push(series_name)999        arr.push(se_no)1000        arr.push(ep_no)1001        arr.push(ep_title)1002        $log.info "Array of series name,se no & episode no is: #{arr}"1003        log.info "Array of series name,se no & episode no is: #{arr}"1004      else1005        $log.info "Program not of type SE, but of type #{show_type}, hence give out an empty array"1006        log.error "Program not of type SE, but of type #{show_type}, hence give out an empty array"1007        arr = Array.new1008      end1009    else1010      $log.info "Program not available in cloud!!"1011      arr = Array.new1012    end1013    arr1014  end1015  def get_ott_links_from_mongo_db(client,prog,log)1016    #$log.info "Ozone Api Spec Functions::get_ott_links_from_mongo_db"1017    log.info "Ozone Api Spec Functions::get_ott_links_from_mongo_db"1018    index_pc_platform = nil1019    complete_video_list = nil1020    videos_list_got_from_rovi_dump = nil1021    dump_date = get_latest_rovi_ott_dump_date(client,log)1022    res_cnt = 01023    collection = client[:rovi_ott_links]1024    prog_id_query = prog.to_s1025    res = collection.find({:rovi_id => prog_id_query,:rovi_dump_date => { '$eq' => dump_date }}, {'availability' => 1}).limit(1).each do |doc|1026      res_cnt = res_cnt + 11027    1028        doc_json = doc.to_json1029        #$log.info doc_json1030        parsed_doc = JSON.parse(doc_json)1031        program_id = parsed_doc['rovi_id']1032 1033        #$log.info "Rovi Program id is: #{program_id}<br>"1034        log.info "Rovi Program id is: #{program_id}<br>"1035        videos = parsed_doc["availability"]["platform_availabilities"]1036        1037        for i in 0..videos.length1038          platform = videos[i]["platform_id"]1039          if platform == "pc"1040            #$log.info "PC platform videos appear in #{i}th index <br>"1041            log.info "PC platform videos appear in #{i}th index "1042            index_pc_platform = i1043            break1044          end1045        end1046        next if index_pc_platform.nil?1047 1048        if index_pc_platform && videos[index_pc_platform]["platform_id"] == "pc"1049          videos_list_got_from_rovi_dump = Array.new1050          complete_video_list = videos[index_pc_platform]['source_availabilities']1051          #$log.info "Complete video list is: #{complete_video_list} <br>"1052          for i in 0..complete_video_list.length-11053            video_obj = complete_video_list[i]1054            content_type = video_obj['content_form']1055            service_name = video_obj['source_id']1056            #$log.info content_type1057            if content_type == 'full' && service_name == $serv_name1058              #$log.info "inside if!!"1059          1060              video_obj.delete("cache_expiry_timestamp")1061              video_obj.delete("last_refreshed_timestamp")1062              video_obj.delete("updated_at")1063              video_obj.delete("refreshed_at")1064              video_obj.delete("content_expiry_timestamp")1065              video_obj.delete("price_currency")1066              video_obj.delete("source_program_id_space")1067              video_obj.delete("is_3d")1068              video_obj.delete("audio_languages")1069              video_obj.delete("subtitle_languages")1070              if video_obj["price"] == ""1071                  video_obj["price"] = "0.0"1072              end1073              vid_price = video_obj["price"]1074              cld_price = vid_price.to_f.to_s1075              video_obj["price"] = cld_price1076              if video_obj["source_id"] == "hulu"1077                video_obj.delete("source_program_id")1078              end1079              if($serv_name == "netflixusa")1080                  if !video_obj["link"]["uri"].include? "netflix"1081                  next1082                end1083              end1084              if($serv_name == "showtime")1085                if video_obj["link"]["uri"].include? "showtimeanytime"1086                  next1087              end1088              1089              if !video_obj["link"]["uri"].include? $serv_name1090                next1091              end1092              1093            end1094              1095              #$log.info "Video obj to be pushed is :#{video_obj}"1096              if !$hulu_vids_cloud.empty? and video_obj["source_id"] == "hulu"1097                log.info "Hulu links fetched from dump, skip it during the validation-don't add to array"1098                next1099              end1100              if !$vudu_vids_cloud.empty? and video_obj["source_id"] == "vudu"1101                log.info "Vudu links fetched from dump, skip it during the validation-don't add to array"1102                next1103              end1104              videos_list_got_from_rovi_dump.push(video_obj)1105            end1106          end1107          videos_list_got_from_rovi_dump = transform_keys_to_symbols(videos_list_got_from_rovi_dump)1108          #$log.info "Videos extracted from rovi dump: #{videos_list_got_from_rovi_dump} <br><br>"1109          log.info "Videos extracted from rovi dump: #{videos_list_got_from_rovi_dump}"1110        end1111      end1112    #end1113    if res_cnt == 01114      #$log.info "Program with rovi id #{prog} not available in rovi ott dump"1115      log.info "Program with rovi id #{prog} not available in rovi ott dump"1116      log.info "**************************************************************************************************************************************************************************************************************************************************************************"1117      videos_list_got_from_rovi_dump = Array.new1118    end1119    videos_list_got_from_rovi_dump1120  end1121  def get_rovi_ind_service_ott_links_from_mongo_db(client,prog,service_nm,log)1122    #$log.info "Ozone Api Spec Functions::get_ott_links_of_ind_services_from_mongo_db"1123    log.info "Ozone Api Spec Functions::get_ott_links_of_ind_services_from_mongo_db"1124    index_pc_platform = nil1125    complete_video_list = nil1126    dump_date = nil1127    ind_service_videos_list_got_from_rovi_dump = nil1128    prog_id = prog.to_s1129    coll_dump_date = client[:rovi_ott_links_dump_date]1130    query_dump_date = coll_dump_date.find({},{ "sort" =>{ "$natural" => -1}}).limit(1)1131    query_dump_date.each do |dt|1132      du_dt = dt.to_json1133      #$log.info du_dt1134      pars_dt = JSON.parse(du_dt)1135      date_str = pars_dt['ott_dump_date']1136      dump_date = Date.parse date_str1137      #$log.info dump_date.class1138      #$log.info "Last added dump date is: #{dump_date}<br>"1139      log.info "Last added dump date is: #{dump_date}<br>"1140    end1141    collection = client[:rovi_ott_links]1142    cnt = collection.count({:rovi_id => prog_id,:rovi_dump_date => { '$eq' => dump_date }}, {'availability' => 1})1143    if cnt == 01144      #$log.info "Program with rovi id #{prog} not available in rovi ott dump"1145      log.info "Program with rovi id #{prog} not available in rovi ott dump"1146      log.info "**************************************************************************************************************************************************************************************************************************************************************************"1147      log.info "**************************************************************************************************************************************************************************************************************************************************************************"1148    else1149      collection.find({:rovi_id => prog_id,:rovi_dump_date => { '$eq' => dump_date }}, {'availability' => 1}).each do |doc|1150        #=> Yields a BSON::Document.1151        #$log.info doc1152        doc_json = doc.to_json1153        #$log.info doc_json1154        parsed_doc = JSON.parse(doc_json)1155        program_id = parsed_doc['rovi_id']1156 1157        #$log.info "Rovi Program id is: #{program_id}<br>"1158        log.info "Rovi Program id is: #{program_id}<br>"1159        videos = parsed_doc["availability"]["platform_availabilities"]1160        #$log.info videos1161        #$log.info videos.class1162        for i in 0..videos.length1163          platform = videos[i]["platform_id"]1164          if platform == "pc"1165            #$log.info "PC platform videos appear in #{i}th index <br>"1166            log.info "PC platform videos appear in #{i}th index "1167            index_pc_platform = i1168            break1169          end1170        end1171        next if index_pc_platform.nil?1172 1173        if index_pc_platform && videos[index_pc_platform]["platform_id"] == "pc"1174          ind_service_videos_list_got_from_rovi_dump = Array.new1175          complete_video_list = videos[index_pc_platform]['source_availabilities']1176          #$log.info "Complete video list is: #{complete_video_list} <br>"1177          for i in 0..complete_video_list.length-11178            video_obj = complete_video_list[i]1179            content_type = video_obj['content_form']1180            service_name = video_obj['source_id']1181            #$log.info content_type1182            #$log.info service_name1183            if content_type == 'full' and $all_supported_services.include? service_name1184              if service_nm == service_name1185                #$log.info "Service match found for #{service_nm}"1186                log.info "Service match found for #{service_nm}"1187                video_obj.delete("cache_expiry_timestamp")1188                video_obj.delete("last_refreshed_timestamp")1189                video_obj.delete("updated_at")1190                video_obj.delete("refreshed_at")1191                video_obj.delete("content_expiry_timestamp")1192                video_obj.delete("price_currency")1193                video_obj.delete("source_program_id_space")1194                video_obj.delete("is_3d")1195                video_obj.delete("audio_languages")1196                video_obj.delete("subtitle_languages")1197                if video_obj["price"] == ""1198                    video_obj["price"] = "0.0"1199                end1200                vid_price = video_obj["price"]1201                cld_price = vid_price.to_f.to_s1202                video_obj["price"] = cld_price1203                if video_obj["source_id"] == "hulu"1204                  video_obj.delete("source_program_id")1205                end1206                if video_obj["link"]["uri"].include? "showtimeanytime"1207                  video_obj["source_id"] = "showtimeanytime"1208                end1209                if video_obj["link"]["uri"].include? "hbonow"1210                  video_obj["source_id"] = "hbonow"1211                end1212                #$log.info "Video obj to be pushed is :#{video_obj}"1213                ind_service_videos_list_got_from_rovi_dump.push(video_obj)1214              else1215                  #$log.info "#{service_name} is not of type #{service_nm}, moving to next"1216                  log.info "#{service_name} is not of type #{service_nm}, moving to next"1217                  next1218              end1219            end1220          end1221          ind_service_videos_list_got_from_rovi_dump = transform_keys_to_symbols(ind_service_videos_list_got_from_rovi_dump)1222          #$log.info "Videos extracted from rovi dump: #{videos_list_got_from_rovi_dump} <br><br>"1223          log.info "Videos extracted from rovi dump: #{ind_service_videos_list_got_from_rovi_dump}"1224        end1225      end1226    end1227    ind_service_videos_list_got_from_rovi_dump1228  end1229  def get_rovi_ott_links_from_cloud(prog_id,log)1230    #$log.info "Ozone Api Spec Functions::get_rovi_ott_links_from_cloud"1231    log.info "Ozone Api Spec Functions::get_rovi_ott_links_from_cloud"1232    rovi_videos_list_got_from_cloud = Array.new1233    get "/programs/#{prog_id}/videos"1234    expect_status('200')1235    #$log.info json_body1236    len = json_body.length1237    if len > 01238      #$log.info "Inside if len > O"1239      log.info "Inside if len > O"1240      for i in 0..len-11241        video_obj_from_cloud = json_body[i]1242        if video_obj_from_cloud[:fetched_from].nil?1243            video_obj_from_cloud.delete(:platform)1244            video_obj_from_cloud.delete(:last_refreshed_timestamp)1245            video_obj_from_cloud.delete(:content_expiry_timestamp)1246            video_obj_from_cloud.delete(:cache_expiry_timestamp)1247            video_obj_from_cloud.delete(:launch_id)1248            video_obj_from_cloud.delete(:created_at)1249            video_obj_from_cloud.delete(:updated_at)1250            video_obj_from_cloud.delete(:refreshed_at)1251            video_obj_from_cloud.delete(:with_subscription)1252            video_obj_from_cloud.delete(:subscription_type)1253            video_obj_from_cloud.delete(:audio_languages)1254            if video_obj_from_cloud[:run_time].nil?1255              video_obj_from_cloud.delete(:run_time)1256            else1257              video_obj_from_cloud[:content_runtime_s] = video_obj_from_cloud[:run_time]1258              video_obj_from_cloud.delete(:run_time)1259            end1260            if video_obj_from_cloud[:constraints].empty?1261              video_obj_from_cloud.delete(:constraints)1262            end1263            if video_obj_from_cloud[:quality].nil?1264              video_obj_from_cloud.delete(:quality)1265            end1266            if video_obj_from_cloud[:purchase_type] == ""1267              video_obj_from_cloud.delete(:purchase_type)1268            end1269            if video_obj_from_cloud[:source_id] == "hulu"1270              video_obj_from_cloud.delete(:source_program_id)1271            end1272            rovi_videos_list_got_from_cloud.push(video_obj_from_cloud)1273          end1274      end1275    else1276   #   $log.info "Inside else, empty cloud response"1277      log.info "Inside else, empty cloud response"1278    end1279    #$log.info "Rovi Videos got from cloud: #{rovi_videos_list_got_from_cloud}"1280    log.info "Rovi Videos got from cloud: #{rovi_videos_list_got_from_cloud}"1281    rovi_videos_list_got_from_cloud1282  end1283  def get_gracenote_ott_links_from_cloud(prog_id,log)1284    gn_videos_list_got_from_cloud = nil1285    begin1286     # $log.info "Ozone Api Spec Functions::get_gracenote_ott_links_from_cloud"1287      log.info "Ozone Api Spec Functions::get_gracenote_ott_links_from_cloud"1288      gn_videos_list_got_from_cloud = Array.new1289      get "/programs/#{prog_id}/videos"1290      expect_status('200')1291      #$log.info json_body1292      len = json_body.length1293      if len > 01294     #   $log.info "Inside if len > O"1295        log.info "Inside if len > O"1296        for i in 0..len-11297          video_obj_from_cloud = json_body[i]1298          if video_obj_from_cloud[:fetched_from] == 'gracenote'1299              video_obj_from_cloud.delete(:platform)1300              video_obj_from_cloud.delete(:last_refreshed_timestamp)1301              video_obj_from_cloud.delete(:content_expiry_timestamp)1302              video_obj_from_cloud.delete(:cache_expiry_timestamp)1303              video_obj_from_cloud.delete(:launch_id)1304              video_obj_from_cloud.delete(:created_at)1305              video_obj_from_cloud.delete(:updated_at)1306              video_obj_from_cloud.delete(:refreshed_at)1307              video_obj_from_cloud.delete(:with_subscription)1308              video_obj_from_cloud.delete(:subscription_type)1309              video_obj_from_cloud.delete(:audio_languages)1310              if video_obj_from_cloud[:run_time].nil?1311                video_obj_from_cloud.delete(:run_time)1312              else1313                video_obj_from_cloud[:content_runtime_s] = video_obj_from_cloud[:run_time]1314                video_obj_from_cloud.delete(:run_time)1315              end1316              if video_obj_from_cloud[:constraints].empty?1317                video_obj_from_cloud.delete(:constraints)1318              end1319              if video_obj_from_cloud[:quality].nil?1320                video_obj_from_cloud.delete(:quality)1321              end1322              if video_obj_from_cloud[:purchase_type] == ""1323                video_obj_from_cloud.delete(:purchase_type)1324              end1325              if video_obj_from_cloud[:source_id] == "hulu"1326                video_obj_from_cloud.delete(:source_program_id)1327              end1328              gn_videos_list_got_from_cloud.push(video_obj_from_cloud)1329            end1330        end1331      else1332        #$log.info "Inside else, empty cloud response"1333        log.info "Inside else, empty cloud response"1334      end1335      #$log.info "GN Videos got from cloud: #{gn_videos_list_got_from_cloud}"1336      log.info "GN Videos got from cloud: #{gn_videos_list_got_from_cloud}"1337 1338    rescue Exception => ex1339      #$log.info "Error!!!: #{ex} <br>"1340      #log.error "Exception caught in iteration #{iter}!!!: #{ex} <br>"1341      #$log.info "Backtrace: #{ex.backtrace}<br>"1342      log.error "Exception!!!: #{ex} <br"1343      gn_videos_list_got_from_cloud = []1344    rescue Error => err1345      #$log.info "Error!!!: #{ex} <br>"1346      #log.error "Error in iteration #{iter}!!!: #{err} <br>"1347      #$log.info "Backtrace: #{ex.backtrace}<br>"1348      log.error "Error!!!: #{err} <br"1349      gn_videos_list_got_from_cloud = []1350    end1351    gn_videos_list_got_from_cloud1352  end1353  def get_ott_links_from_cloud(prog_id,log)1354    log.info "Ozone Api Spec Functions::get_ott_links_from_cloud"1355    rovi_videos_list_got_from_cloud = Array.new1356    gracenote_videos_list_got_from_cloud = Array.new1357    hulu_videos_list_got_from_cloud = Array.new1358    vudu_videos_list_got_from_cloud = Array.new1359    crawler_videos_list_got_from_cloud = Array.new1360    all_videos_list_got_from_cloud = Array.new1361    videos_got_from_cloud = {"Rovi Videos"=> [],"Gracenote Videos"=> [],"Hulu Videos"=> [],"Vudu Videos"=> [],"Crawler Videos"=>[],"All Videos" => []}1362    #videos_got_from_cloud = nil1363    #rovi_videos_list_got_from_cloud = nil1364    #gracenote_videos_list_got_from_cloud = nil1365    api = "/programs/#{prog_id}/videos"+ "?service="+ $serv_name1366    get api1367    response_code_validation("get",api)1368    log.info "json_body: #{json_body}"1369    len = json_body.length1370    if len > 01371      #$log.info "Inside if len > O"1372      log.info "Inside if len > O"1373 1374      for i in 0..len-11375        video_obj_from_cloud = json_body[i]1376        log.info "video_obj_from_cloud:: #{video_obj_from_cloud}"1377        video_obj_from_cloud.delete(:platform)1378        video_obj_from_cloud.delete(:last_refreshed_timestamp)1379        video_obj_from_cloud.delete(:content_expiry_timestamp)1380        video_obj_from_cloud.delete(:cache_expiry_timestamp)1381        video_obj_from_cloud.delete(:launch_id)1382        video_obj_from_cloud.delete(:created_at)1383        video_obj_from_cloud.delete(:updated_at)1384        video_obj_from_cloud.delete(:refreshed_at)1385        video_obj_from_cloud.delete(:with_subscription)1386        video_obj_from_cloud.delete(:subscription_type)1387        video_obj_from_cloud.delete(:audio_languages)1388        if video_obj_from_cloud[:run_time].nil?1389          video_obj_from_cloud.delete(:run_time)1390        else1391          video_obj_from_cloud[:content_runtime_s] = video_obj_from_cloud[:run_time]1392          video_obj_from_cloud.delete(:run_time)1393        end1394        if video_obj_from_cloud[:constraints].nil? or video_obj_from_cloud[:constraints].empty?1395          video_obj_from_cloud.delete(:constraints)1396        end1397        if video_obj_from_cloud[:quality].nil?1398          video_obj_from_cloud.delete(:quality)1399        end1400        if video_obj_from_cloud[:purchase_type] == ""1401          video_obj_from_cloud.delete(:purchase_type)1402        end1403        if video_obj_from_cloud[:source_id] == "hulu"1404          video_obj_from_cloud.delete(:source_program_id)1405        end1406        if video_obj_from_cloud[:fetched_from].nil?1407          rovi_videos_list_got_from_cloud.push(video_obj_from_cloud)1408        elsif video_obj_from_cloud[:fetched_from] == "gracenote"1409          # gn_url = video_obj_from_cloud[:link][:uri]1410          # gracenote_videos_list_got_from_cloud.push(gn_url)1411          gracenote_videos_list_got_from_cloud.push(video_obj_from_cloud)1412        elsif video_obj_from_cloud[:fetched_from] == "hulu"1413          hulu_videos_list_got_from_cloud.push(video_obj_from_cloud)1414        elsif video_obj_from_cloud[:fetched_from] == "vudu"1415          vudu_videos_list_got_from_cloud.push(video_obj_from_cloud)1416        elsif video_obj_from_cloud[:fetched_from] == "crawler"1417          crawler_videos_list_got_from_cloud.push(video_obj_from_cloud)1418        end1419        all_videos_list_got_from_cloud.push(video_obj_from_cloud)1420      end1421    else1422      #$log.info "Inside else, empty cloud response"1423      log.info "Inside else, empty cloud response"1424    end1425    videos_got_from_cloud = {"Rovi Videos"=> rovi_videos_list_got_from_cloud,"Gracenote Videos"=> gracenote_videos_list_got_from_cloud,"Hulu Videos"=> hulu_videos_list_got_from_cloud,"Vudu Videos"=> vudu_videos_list_got_from_cloud,"Crawler Videos"=>crawler_videos_list_got_from_cloud,"All Videos"=> all_videos_list_got_from_cloud}1426     log.info "Videos got from Rovi cloud: #{rovi_videos_list_got_from_cloud}"1427     log.info "Videos got from Gn cloud: #{gracenote_videos_list_got_from_cloud}"1428    #$log.info "Videos got from cloud: #{videos_got_from_cloud}"1429    log.info "Videos got from cloud: #{videos_got_from_cloud}"1430    videos_got_from_cloud1431  end1432  def get_ott_links_of_individual_service_from_cloud(prog_id,service,log)1433    #$log.info "Ozone Api Spec Functions::get_ott_links_of_individual_service_from_cloud"1434    log.info "Ozone Api Spec Functions::get_ott_links_of_individual_service_from_cloud"1435    videos_got_from_cloud = {"Rovi Videos"=> [],"Gracenote Videos"=> []}1436    rovi_videos_list_got_from_cloud = Array.new1437    gracenote_videos_list_got_from_cloud = Array.new1438    get "/programs/#{prog_id}/videos"1439    expect_status('200')1440    #$log.info json_body1441    len = json_body.length1442    if len > 01443      #$log.info "Inside if len > O"1444      log.info "Inside if len > O"1445 1446      for i in 0..len-11447        video_obj_from_cloud = json_body[i]1448        ind_service_name = video_obj_from_cloud[:source_id]1449        if service == ind_service_name1450          #$log.info "#{ind_service_name} is of type #{service}, going to process"1451          log.info "#{ind_service_name} is of type #{service}, going to process"1452          if video_obj_from_cloud[:fetched_from].nil?1453            #$log.info "Rovi object, hence remove all dynamic key-value pairs"1454            log.info "Rovi object, hence remove all dynamic key-value pairs"1455            video_obj_from_cloud.delete(:platform)1456            video_obj_from_cloud.delete(:last_refreshed_timestamp)1457            video_obj_from_cloud.delete(:content_expiry_timestamp)1458            video_obj_from_cloud.delete(:cache_expiry_timestamp)1459            video_obj_from_cloud.delete(:launch_id)1460            video_obj_from_cloud.delete(:created_at)1461            video_obj_from_cloud.delete(:updated_at)1462            video_obj_from_cloud.delete(:refreshed_at)1463            video_obj_from_cloud.delete(:with_subscription)1464            video_obj_from_cloud.delete(:subscription_type)1465            video_obj_from_cloud.delete(:audio_languages)1466            if video_obj_from_cloud[:run_time].nil?1467              video_obj_from_cloud.delete(:run_time)1468            else1469              video_obj_from_cloud[:content_runtime_s] = video_obj_from_cloud[:run_time]1470              video_obj_from_cloud.delete(:run_time)1471            end1472            if video_obj_from_cloud[:constraints].empty?1473              video_obj_from_cloud.delete(:constraints)1474            end1475            if video_obj_from_cloud[:quality].nil?1476              video_obj_from_cloud.delete(:quality)1477            end1478            if video_obj_from_cloud[:purchase_type] == ""1479              video_obj_from_cloud.delete(:purchase_type)1480            end1481            if video_obj_from_cloud[:source_id] == "hulu"1482              video_obj_from_cloud.delete(:source_program_id)1483            end1484            rovi_videos_list_got_from_cloud.push(video_obj_from_cloud)1485          elsif video_obj_from_cloud[:fetched_from] == "gracenote"1486            #$log.info "GN object, hence adding only url to array"1487            log.info "GN object, hence adding only url to array"1488            gn_url = video_obj_from_cloud[:link][:uri]1489            gracenote_videos_list_got_from_cloud.push(gn_url)1490          end1491        else1492          #$log.info "#{ind_service_name} is not of type #{service}, moving to next"1493          log.info "#{ind_service_name} is not of type #{service}, moving to next"1494          next1495        end1496      end1497    else1498      #$log.info "Inside else, empty cloud response"1499      log.info "Inside else, empty cloud response"1500    end1501    videos_got_from_cloud = {"Rovi Videos"=> rovi_videos_list_got_from_cloud,"Gracenote Videos"=> gracenote_videos_list_got_from_cloud}1502 1503    #$log.info "Videos got from cloud for the service #{service}: #{videos_got_from_cloud}"1504    log.info "Videos got from cloud for the service #{service}: #{videos_got_from_cloud}"1505    videos_got_from_cloud1506  end1507  def check_for_index_of_array_element(arr_of_airdate_programs,series_nm,se_num,ep_num,log)1508    indx = nil1509    arr_len = arr_of_airdate_programs.length1510    for i in 0..arr_len-11511      array_elem = arr_of_airdate_programs[i]1512      #$log.info "Going to compare csv value(series name):#{array_elem[0]} with #{series_nm},csv value(season num): #{array_elem[1]} with #{se_num} & csv value(episode num): #{array_elem[2]} with #{ep_num}"1513      log.info "Going to compare csv value(series name):#{array_elem[0]} with #{series_nm},csv value(season num): #{array_elem[1]} with #{se_num} & csv value(episode num): #{array_elem[2]} with #{ep_num}"1514 1515      if array_elem[0].casecmp(series_nm).zero? and array_elem[1].to_i == se_num and array_elem[2].to_i == ep_num1516        #$log.info "We've found a match return index #{i}"1517        log.info "We've found a match return index #{i}"1518        indx = i1519        break1520      end1521    end1522    indx1523  end1524  def categorise_video_links(ott_links_from_cloud,log)1525    #$log.info "Api_spec_functions:: categorise_video_links"1526    log.info "Api_spec_functions:: categorise_video_links"1527    amazon = Array.new1528    hulu = Array.new1529    vudu = Array.new1530    netflixusa = Array.new1531    showtimeanytime = Array.new1532    showtime = Array.new1533    hbogo = Array.new1534    hbonow = Array.new1535    youtube = Array.new1536    itunes = Array.new1537    if !ott_links_from_cloud.empty?1538      no_of_ott_links = ott_links_from_cloud.length1539      for i in 0..no_of_ott_links-11540        video_obj = ott_links_from_cloud[i]1541        ind_service_name = video_obj[:source_id]1542        ind_service_url = video_obj[:link][:uri]1543        case ind_service_name1544        when "amazon"1545        amazon.push(ind_service_url)1546        when "hulu"1547        hulu.push(ind_service_url)1548        when "vudu"1549        vudu.push(ind_service_url)1550        when "netflixusa"1551        netflixusa.push(ind_service_url)1552        when "showtimeanytime"1553        showtimeanytime.push(ind_service_url)1554        when "showtime"1555        showtime.push(ind_service_url)1556        when "hbogo"1557        hbogo.push(ind_service_url)1558        when "hbonow"1559        hbonow.push(ind_service_url)1560        when "youtube"1561        youtube.push(ind_service_url)1562        when "itunes"1563        itunes.push(ind_service_url)1564        end1565      end1566    end1567    ott_links_by_category = {"amazon" => amazon,"hbogo" => hbogo,"hulu" => hulu,"netflixusa" => netflixusa,"showtimeanytime" => showtimeanytime,"showtime" => showtime,"hbonow" => hbonow,"vudu" => vudu,"youtube" => youtube,"itunes" => itunes}1568    #$log.info "Links got from cloud: #{ott_links_by_category}"1569    log.info "Links got from cloud: #{ott_links_by_category}"1570    ott_links_by_category1571  end1572  def categorise_launch_ids_based_on_service(ott_links_from_cloud,show_type,log)1573    #$log.info "Api_spec_functions:: categorise_video_links"1574    log.info "Api_spec_functions:: categorise_video_links"1575    amazon = Array.new1576    hulu = Array.new1577    vudu = Array.new1578    netflixusa = Array.new1579    showtimeanytime = Array.new1580    showtime = Array.new1581    hbogo = Array.new1582    hbonow = Array.new1583    youtube = Array.new1584    itunes = Array.new1585    launch_id = nil1586    if !ott_links_from_cloud.empty?1587      no_of_ott_links = ott_links_from_cloud.length1588      for i in 0..no_of_ott_links-11589        video_obj = ott_links_from_cloud[i]1590       # ind_service_name = video_obj[:source_id] serv_name1591       ind_service_name = video_obj[:source_id]1592        ind_service_url = video_obj[:link][:uri]1593        case ind_service_name1594        when "amazon"1595          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?amazon\.com\/([a-zA-Z\/]*)\/([A-Za-z0-9]+)/)[3]1596        amazon.push(launch_id)1597        when "hulu"1598          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?hulu\.com\/watch\/([A-Za-z0-9]+)/)[2]1599        hulu.push(launch_id)1600        when "vudu"1601          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?vudu\.com\/movies\/#!content\/([A-Za-z0-9]+)/)[2]1602        vudu.push(launch_id)1603        when "netflixusa"1604          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?netflix\.com\/([a-zA-Z]+)\/([0-9]+)/)[3]1605        netflixusa.push(launch_id)1606        when "showtimeanytime"1607          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?showtime(anytime)?\.com\/#\/([a-zA-Z]+)\/([A-Za-z0-9]+)/)[4]1608          showtimeanytime.push(launch_id)1609        when "showtime"1610          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?showtime(anytime)?\.com\/#\/([a-zA-Z]+)\/([A-Za-z0-9]+)/)[4]1611          showtime.push(launch_id)1612        when "hbogo"1613          #launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?hbogo\.com\/#home\/([a-zA-Z&]+)=([A-Za-z0-9]+)/)[3]1614          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?hbogo\.com\/#([a-z]+)\/([a-zA-Z&;]+)=([A-Za-z0-9]+)/)[4]1615          hbogo.push(launch_id)1616        when "hbonow"1617          #launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?hbogo\.com\/#home\/([a-zA-Z&;]+)=([A-Za-z0-9]+)/)[3]1618          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?hbonow\.com\/(.+)\/(.+)\/(.+)\/(.+)/)[5]1619          hbonow.push(launch_id)1620        when "youtube"1621          #launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?youtube\.com\/([a-zA-Z]+)\?v=([A-Za-z0-9]+)/)[3]1622          #                            match(/http[s]?:\/\/(www.)?youtube\.com\/([a-zA-Z]+)\?v=([A-Za-z0-9]+)/)[3]1623          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?youtube\.com\/([a-zA-Z]+)\?v=(.+)+/)[3]1624          youtube.push(launch_id)1625        when "itunes"1626          if show_type == "MO"1627            log.info "Show type - MO"1628            launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?itunes\.apple\.com\/us\/([a-zA-Z0-9\-\/]*)([a-zA-Z0-9\/\-\.]*)\/id([0-9]+)(\?i=)?([0-9]*)/)[4]1629          else1630            log.info "Show type - SE"1631            launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?itunes\.apple\.com\/us\/([a-zA-Z0-9\-\/]*)([a-zA-Z0-9\/\-\.]*)\/id([0-9]+)(\?i=)?([0-9]*)/)[6]1632          end1633          itunes.push(launch_id)1634        end1635      end1636    end1637    ott_links_by_category = {"amazon" => amazon,"hbogo" => hbogo,"hulu" => hulu,"netflixusa" => netflixusa,"showtimeanytime" => showtimeanytime,"showtime" => showtime,"hbonow" => hbonow,"vudu" => vudu,"youtube" => youtube,"itunes" => itunes}1638    #$log.info "Links got from cloud: #{ott_links_by_category}"1639    log.info "Links got from cloud: #{ott_links_by_category}"1640    ott_links_by_category1641  end1642  def categorise_ozone_launch_ids_based_on_service(ott_links_from_cloud,show_type,log)1643    log.info "Api_spec_functions:: categorise_ozone_launch_ids_based_on_service"1644    amazon = Array.new1645    hulu = Array.new1646    vudu = Array.new1647    netflixusa = Array.new1648    showtimeanytime = Array.new1649    showtime = Array.new1650    hbogo = Array.new1651    hbonow = Array.new1652    youtube = Array.new1653    itunes = Array.new1654    launch_id = nil1655    if !ott_links_from_cloud.empty?1656      no_of_ott_links = ott_links_from_cloud.length1657      for i in 0..no_of_ott_links-11658        video_obj = ott_links_from_cloud[i]1659        #ind_service_name = $serv_name1660        ind_service_name = video_obj[:source_id]1661        log.info "Service name: #{ind_service_name}"1662        ind_service_url = video_obj[:link][:uri]1663        log.info "Service url: #{ind_service_url}"1664        case ind_service_name1665        when "amazon"1666          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?amazon\.com\/([a-zA-Z\/]*)\/([A-Za-z0-9]+)/)[3]1667        amazon.push(launch_id)1668        when "hulu"1669          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?hulu\.com\/watch\/([A-Za-z0-9]+)/)[2]1670        hulu.push(launch_id)1671        when "vudu"1672          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?vudu\.com\/movies\/#!content\/([A-Za-z0-9]+)/)[2]1673        vudu.push(launch_id)1674        when "netflixusa"1675          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?netflix\.com\/([a-zA-Z]+)\/([0-9]+)/)[3]1676        netflixusa.push(launch_id)1677     # Service url: http://www.netflix.com/WiPlayer?movieid=702741081678        when "showtimeanytime"1679          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?showtime(anytime)?\.com\/#\/([a-zA-Z]+)\/([A-Za-z0-9]+)/)[4]1680          showtimeanytime.push(launch_id)1681        when "showtime"1682          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?showtime(anytime)?\.com\/#\/([a-zA-Z]+)\/([A-Za-z0-9]+)/)[4]1683          showtime.push(launch_id)1684        when "hbogo"1685          #launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?hbogo\.com\/#home\/([a-zA-Z&;]+)=([A-Za-z0-9]+)/)[3]1686          if ind_service_url.include?"play"1687          log.info "The URL has play in it"   1688          launch_id = ind_service_url.gsub("https://play.hbogo.com/episode/urn:hbo:episode:","")1689          else1690          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?hbogo\.com\/#([a-z]+)\/([a-zA-Z&;]+)=([A-Za-z0-9]+)/)[4]1691          end  1692          log.info "Launch id: #{launch_id}"1693          hbogo.push(launch_id)1694        when "hbonow"1695          #launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?hbogo\.com\/#home\/([a-zA-Z&;]+)=([A-Za-z0-9]+)/)[3]1696          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?hbonow\.com\/(.+)\/(.+)\/(.+)\/(.+)/)[5]1697          hbonow.push(launch_id)1698        when "youtube"1699          #launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?youtube\.com\/([a-zA-Z]+)\?v=([A-Za-z0-9]+)/)[3]1700          launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?youtube\.com\/([a-zA-Z]+)\?v=(.+)+/)[3]1701          youtube.push(launch_id)1702        when "itunes"1703          if show_type == "MO"1704            launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?itunes\.apple\.com\/us\/([a-zA-Z0-9\-\/]*)([a-zA-Z0-9\/\-\.]*)\/id([0-9]+)(\?i=)?([0-9]*)/)[4]1705          else1706            launch_id = ind_service_url.match(/http[s]?:\/\/(www.)?itunes\.apple\.com\/us\/([a-zA-Z0-9\-\/]*)([a-zA-Z0-9\/\-\.]*)\/id([0-9]+)(\?i=)?([0-9]*)/)[6]1707          end1708          itunes.push(launch_id)1709          #Service url: https://itunes.apple.com/us/tv-season/season-3-episode-1-no-m%C3%A1s/id940287472?i=9426915901710        end1711      end1712    end1713    ott_links_by_category = {"amazon" => amazon,"hbogo" => hbogo,"hulu" => hulu,"netflixusa" => netflixusa,"showtimeanytime" => showtimeanytime,"showtime" => showtime,"hbonow" => hbonow,"vudu" => vudu,"youtube" => youtube,"itunes" => itunes}1714    #$log.info "Links got from cloud: #{ott_links_by_category}"1715    log.info "Links got from cloud: #{ott_links_by_category}"1716    ott_links_by_category1717  end1718  def make_one_single_array(arr_of_arr)1719    single_arr = Array.new1720    len = arr_of_arr.length1721    for i in 0..len-11722      if !arr_of_arr[i].empty?1723        arr_of_arr[i].each do |arr_elem|1724          single_arr.push(arr_elem)1725        end1726      end1727    end1728    single_arr1729  end1730  def get_categorised_gn_launch_ids(hash_of_gn_links,show_type,log)1731    log.info "API Specs::get_categorised_gn_launch_ids"1732    gn_categorised_launch_id_hash = {}1733    links = nil1734    arr_launch_ids = nil1735    gn_services = hash_of_gn_links.keys1736    gn_services.each do |service|1737      links = hash_of_gn_links[service]1738      arr_launch_ids = Array.new1739      case service1740        when "amazon"1741          links.each do |link|1742            launch_id = link.match(/http[s]?:\/\/(www.)?amazon\.com\/([a-zA-Z\/]*)\/([A-Za-z0-9]+)/)[3]1743            arr_launch_ids.push(launch_id)1744          end1745        when "hulu"1746          links.each do |link|1747            launch_id = link.match(/http[s]?:\/\/(www.)?hulu\.com\/watch\/([A-Za-z0-9]+)/)[2]1748            arr_launch_ids.push(launch_id)1749          end1750        when "vudu"1751          links.each do |link|1752            launch_id = link.match(/http[s]?:\/\/(www.)?vudu\.com\/movies\/#!content\/([A-Za-z0-9]+)/)[2]1753            arr_launch_ids.push(launch_id)1754          end1755        when "netflixusa"1756          links.each do |link|1757            launch_id = link.match(/http[s]?:\/\/(www.)?netflix\.com\/([a-zA-Z]+)\/([0-9]+)/)[3]1758            arr_launch_ids.push(launch_id)1759          end1760        when "showtimeanytime"1761          links.each do |link|1762            launch_id = link.match(/http[s]?:\/\/(www.)?showtime(anytime)?\.com\/#\/([a-zA-Z]+)\/([A-Za-z0-9]+)/)[4]1763            arr_launch_ids.push(launch_id)1764          end1765        when "showtime"1766          links.each do |link|1767            launch_id = link.match(/http[s]?:\/\/(www.)?showtime(anytime)?\.com\/#\/([a-zA-Z]+)\/([A-Za-z0-9]+)/)[4]1768            arr_launch_ids.push(launch_id)1769          end1770        when "hbo"1771          links.each do |link|1772            #launch_id = link.match(/http[s]?:\/\/(www.)?hbogo\.com\/#home\/([a-zA-Z&;]+)=([A-Za-z0-9]+)/)[3]1773            launch_id = link.match(/http[s]?:\/\/(www.)?hbogo\.com\/#([a-z]+)\/([a-zA-Z&;]+)=([A-Za-z0-9]+)/)[4]1774            arr_launch_ids.push(launch_id)1775          end1776        when "hbonow"1777          links.each do |link|1778            #launch_id = link.match(/http[s]?:\/\/(www.)?hbonow\.com\/([a-zA-Z0-9]+)\/(.+)+\/0\/(.+)/)[4]1779            launch_id = link.match(/http[s]?:\/\/(www.)?hbonow\.com\/(.+)\/(.+)\/(.+)\/(.+)/)[5]1780            arr_launch_ids.push(launch_id)1781          end1782        when "youtube"1783          links.each do |link|1784            #launch_id = link.match(/http[s]?:\/\/(www.)?youtube\.com\/([a-zA-Z]+)\?v=([A-Za-z0-9]+)/)[3]1785            launch_id = link.match(/http[s]?:\/\/(www.)?youtube\.com\/([a-zA-Z]+)\?v=(.+)+/)[3]1786            arr_launch_ids.push(launch_id)1787          end1788        when "itunes"1789          links.each do |link|1790            if show_type == "MO"1791              log.info "Show type - MO"1792              launch_id = link.match(/http[s]?:\/\/(www.)?itunes\.apple\.com\/us\/([a-zA-Z0-9\-\/]*)([a-zA-Z0-9\/\-\.]*)\/id([0-9]+)(\?i=)?([0-9]*)/)[4]1793            else1794              log.info "Show type - SE"1795              launch_id = link.match(/http[s]?:\/\/(www.)?itunes\.apple\.com\/us\/([a-zA-Z0-9\-\/]*)([a-zA-Z0-9\/\-\.]*)\/id([0-9]+)(\?i=)?([0-9]*)/)[6]1796            end1797            # launch_id = link.match(/http[s]?:\/\/(www.)?itunes\.apple\.com\/us\/([a-zA-Z0-9\-\/]*)([a-zA-Z0-9\/\-\.]*)\/id([0-9]+)(\?i=)?([0-9]*)/)[4]1798            arr_launch_ids.push(launch_id)1799          end1800        end1801        gn_categorised_launch_id_hash[service] = arr_launch_ids1802        log.info "Launch ids for #{service}: arr_launch_ids"1803    end1804    log.info "gn_categorised_launch_id_hash: #{gn_categorised_launch_id_hash}"1805    gn_categorised_launch_id_hash1806  end1807  def query_gn_dump_and_check_for_availability_of_movie_for_a_particular_service(client,movie_name,release_year,serv_name,log)1808    gn_coll = client[:GN_ott_episodes_ott]1809    dump_date = Date.today - 11810    gn_mongo = nil1811    cnt = gn_coll.count({"title" => /#{movie_name}/i,"release_year" => release_year,"show_type" => "MO","gn_dump_date" => dump_date})1812    if cnt == 01813      #$log.info "Can't find movie: #{movie_name} in GN dump with release_year: #{release_year}"1814      log.info "Can't find movie: #{movie_name} in GN dump with release_year: #{release_year}"1815      $arr_prog_ids.push([movie_name,release_year,"Movie not available on Rovi","Movie not available on Gracenote","FAIL"])1816      $not_avail_on_rovi_and_gn_cnt = $not_avail_on_rovi_and_gn_cnt + 11817      #$log.info "$not_avail_on_rovi_and_gn_cnt: #{$not_avail_on_rovi_and_gn_cnt}"1818      log.info "$not_avail_on_rovi_and_gn_cnt: #{$not_avail_on_rovi_and_gn_cnt}"1819    else1820      gn_coll.find({"title" => /#{movie_name}/i,"release_year" => release_year,"show_type" => "MO","gn_dump_date" => dump_date}).limit(1).each do |doc|1821        gn_mongo = nil1822        doc_json = doc.to_json1823              #log.info "Value from mongo: #{doc_json} before processing"1824 1825        parsed_doc = JSON.parse(doc_json)1826        #$log.info parsed_doc1827        log.info "Resp from GN dump: #{parsed_doc}"1828        #array_elem.push(parsed_doc)1829        gn_links_from_mongo = parsed_doc["Videos"]1830        if !gn_links_from_mongo.empty?1831          services_from_mongo = gn_links_from_mongo.keys1832          #$log.info "Filter out the GN Mongo response to contain only supported services"1833          log.info "Filter out the GN Mongo response to contain only supported services"1834          services_from_mongo.each do |key|1835            if key.downcase == serv_name1836                next1837              else1838                gn_links_from_mongo.delete(key)1839            end1840          end1841          #$log.info "gn_links_from_mongo for movie-#{movie_name} for service-#{serv_name}: #{gn_links_from_mongo}"1842          log.info "gn_links_from_mongo for movie-#{movie_name} for service-#{serv_name}: #{gn_links_from_mongo}"1843          gn_links_from_mongo_final = gn_links_from_mongo.values1844          gn_mongo = make_one_single_array(gn_links_from_mongo_final)1845          #$log.info "Main: gn_mongo for movie-#{movie_name}: #{gn_mongo}"1846 1847        else1848            gn_mongo = []1849            #$log.info "Main: GN Metadata available, but no valid gn links for program in dump"1850            log.info "Main: GN Metadata available, but no valid gn links for program in dump"1851        end1852      end1853      if !gn_mongo.empty?1854        log.info "Main: gn_mongo for movie-#{movie_name}: #{gn_mongo}"1855        $not_avail_on_rovi_but_avail_on_gn_cnt = $not_avail_on_rovi_but_avail_on_gn_cnt + 11856        #$log.info "not_avail_on_rovi_but_avail_on_gn_cnt: #{not_avail_on_rovi_but_avail_on_gn_cnt}"1857        log.info "$not_avail_on_rovi_but_avail_on_gn_cnt: #{$not_avail_on_rovi_but_avail_on_gn_cnt}"1858        $arr_prog_ids.push([movie_name,"MO",release_year,"Movie not available on Rovi","But movie available on GN.","GN links: #{gn_mongo}"])1859      else1860        $not_avail_on_rovi_and_gn_cnt = $not_avail_on_rovi_and_gn_cnt + 11861        #$log.info "$not_avail_on_rovi_and_gn_cnt: #{$not_avail_on_rovi_and_gn_cnt}"1862        log.info "$not_avail_on_rovi_and_gn_cnt: #{$not_avail_on_rovi_and_gn_cnt}"1863        $arr_prog_ids.push([movie_name,"MO",release_year,"Movie not available on Rovi","Movie not available on Gracenote","FAIL"])1864      end1865    end1866  end1867  def check_for_ingestion_of_particular_service_rovi_or_gn_ott_links_in_movie(ott_links_cloud,client,prog_id,movie_name,release_year,serv_name,log)1868    dump_date = Date.today - 11869    rovi_vids_cloud = ott_links_cloud["Rovi Videos"]1870    gn_vids_cloud = ott_links_cloud["Gracenote Videos"]1871    #$log.info rovi_vids_cloud1872    log.info "#{rovi_vids_cloud}"1873    if !rovi_vids_cloud.empty?1874      rovi_vids_mongo = get_rovi_ind_service_ott_links_from_mongo_db(client,prog_id,serv_name,log)1875      diff1 = rovi_vids_mongo - rovi_vids_cloud1876      #$log.info "Few Mongo vids are missing in cloud :#{diff1}"1877      log.info "Few Mongo vids are missing in cloud :#{diff1}"1878      diff2 = rovi_vids_cloud - rovi_vids_mongo1879      #$log.info "Extra vids in cloud which were not there in rovi dump :#{diff2}"1880      log.info "Extra vids in cloud which were not there in rovi dump :#{diff2}"1881      if diff1.empty? and diff2.empty?1882        #$log.info "Rovi Ingestion Status for movie-#{movie_name}: PASS"1883        log.info "Rovi Ingestion Status for movie-#{movie_name}: PASS"1884        $rovi_ingestion_status = "Rovi Ingestion Status: PASS"1885        $rovi_ingest_success_cnt = $rovi_ingest_success_cnt + 11886        #$log.info "Rovi Ingesion-PASS count: #{$rovi_ingest_success_cnt}"1887        log.info "Rovi Ingesion-PASS count: #{$rovi_ingest_success_cnt}"1888      else1889        #$log.info "Rovi Ingestion Status for movie-#{movie_name}: FAIL"1890        log.info "Rovi Ingestion Status for movie-#{movie_name}: FAIL"1891        $rovi_ingestion_status = "Rovi Ingestion Status: FAIL"1892        $rovi_ingest_failures_cnt = $rovi_ingest_failures_cnt + 11893        #$log.info "Rovi Ingesion-FAIL count: #{$rovi_ingest_failures_cnt}"1894        log.info "Rovi Ingesion-FAIL count: #{$rovi_ingest_failures_cnt}"1895      end1896      $arr_prog_ids.push([movie_name,"MO",release_year,prog_id,"Rovi Video Links available on cloud",$rovi_ingestion_status])1897      $avail_on_rovi_cnt = $avail_on_rovi_cnt + 11898      #$log.info "avail_on_rovi_cnt: #{$avail_on_rovi_cnt}"1899      log.info "avail_on_rovi_cnt: #{$avail_on_rovi_cnt}"1900    elsif !gn_vids_cloud.empty?1901      #$log.info "avail_on_gracenote_after_mapping_cnt: #{$avail_on_gracenote_after_mapping_cnt}"1902      log.info "avail_on_gracenote_after_mapping_cnt: #{$avail_on_gracenote_after_mapping_cnt}"1903      #gn_vids_cloud = ott_links_cloud["Gracenote Videos"]1904      # $log.info gn_vids_cloud1905      # log.info gn_vids_cloud1906      gn_coll = client[:GN_ott_episodes_ott]1907      cnt = gn_coll.count({"title" => /#{movie_name}/i,"release_year" => release_year,"show_type" => "MO","gn_dump_date" => dump_date})1908      if cnt == 01909        #$log.info "Can't find movie: #{movie_name} in GN dump with release_year: #{release_year}"1910        log.info "Can't find movie: #{movie_name} in GN dump with release_year: #{release_year}"1911        $arr_prog_ids.push([movie_name,"MO",release_year,"GN Video Links available in cloud","Unable to map with Gracenote dump,hence cannot check ingestion status"])1912        $avail_on_gracenote_and_unable_to_map_cnt = $avail_on_gracenote_and_unable_to_map_cnt + 11913        #$log.info "avail_on_gracenote_and_unable_to_map_cnt: #{$avail_on_gracenote_and_unable_to_map_cnt}"1914        log.info "avail_on_gracenote_and_unable_to_map_cnt: #{$avail_on_gracenote_and_unable_to_map_cnt}"1915      else1916        gn_coll.find({"title" => /#{movie_name}/i,"release_year" => release_year,"show_type" => "MO","gn_dump_date" => dump_date}).limit(1).each do |doc|1917          gn_vids_mongo = nil1918          doc_json = doc.to_json1919          #log.info "Value from mongo: #{doc_json} before processing"1920 1921          parsed_doc = JSON.parse(doc_json)1922          #$log.info parsed_doc1923          log.info "Resp from GN dump: #{parsed_doc}"1924          #array_elem.push(parsed_doc)1925          gn_links_from_mongo = parsed_doc["Videos"]1926          if !gn_links_from_mongo.empty?1927            services_from_mongo = gn_links_from_mongo.keys1928            #$log.info "Filter out the GN Mongo response to contain only #{serv_name} service"1929            log.info "Filter out the GN Mongo response to contain only #{serv_name} service"1930            services_from_mongo.each do |key|1931              if key.downcase == serv_name or serv_name.include? key.downcase1932                next1933              else1934                gn_links_from_mongo.delete(key)1935              end1936            end1937          else1938            gn_vids_mongo = []1939            #$log.info "Main: GN Metadata available, but no valid gn links for program in dump"1940            log.info "Main: GN Metadata available, but no valid gn links for program in dump"1941          end1942          #$log.info "gn_links_from_mongo for movie-#{movie_name}: #{gn_links_from_mongo}"1943          log.info "gn_links_from_mongo for movie-#{movie_name}: #{gn_links_from_mongo}"1944          gn_links_from_mongo_final = gn_links_from_mongo.values1945          gn_vids_mongo = make_one_single_array(gn_links_from_mongo_final)1946          #$log.info "Main: gn_vids_mongofor movie-#{movie_name}: #{gn_vids_mongo}"1947          log.info "Main: gn_vids_mongo for movie-#{movie_name}: #{gn_vids_mongo}"1948          if !gn_vids_mongo.empty? and !gn_vids_cloud.empty?1949            $avail_on_gracenote_after_mapping_cnt = $avail_on_gracenote_after_mapping_cnt + 11950            #$log.info "inside if both gn_vids_mongo and gn_vids_cloud are not empty, proceed to ingestion validation"1951            log.info "inside if both gn_vids_mongo and gn_vids_cloud are not empty, proceed to ingestion validation"1952            #$log.info "gn_vids_cloud: #{gn_vids_cloud}"1953            log.info "gn_vids_cloud: #{gn_vids_cloud}"1954            diff1 = gn_vids_mongo - gn_vids_cloud1955            #$log.info "Few GN Mongo vids are missing in cloud :#{diff1}"1956            log.info "Few GN Mongo vids are missing in cloud :#{diff1}"1957            diff2 = gn_vids_cloud - gn_vids_mongo1958            #$log.info "Extra GN vids in cloud which were not there in rovi dump :#{diff2}"1959            log.info "Extra GN vids in cloud which were not there in rovi dump :#{diff2}"1960            if diff1.empty? and diff2.empty?1961              #$log.info "GN Ingestion Status for movie-#{movie_name}: PASS"1962              log.info "GN Ingestion Status for movie-#{movie_name}: PASS"1963              $gn_ingestion_status = "GN Ingestion Status: PASS"1964              $gn_ingest_success_cnt = $gn_ingest_success_cnt + 11965              #$log.info "GN Ingestion Status: PASS count: #{$gn_ingest_success_cnt}"1966              log.info "GN Ingestion Status: PASS count: #{$gn_ingest_success_cnt}"1967            else1968              #$log.info "GN Ingestion Status for movie-#{movie_name}: FAIL"1969              log.info "GN Ingestion Status for movie-#{movie_name}: FAIL"1970              $gn_ingestion_status = "GN Ingestion Status: FAIL"1971              $gn_ingest_failures_cnt = $gn_ingest_failures_cnt + 11972              #$log.info "GN Ingestion Status: FAIL count: #{$gn_ingest_failures_cnt}"1973              log.info "GN Ingestion Status: FAIL count: #{$gn_ingest_failures_cnt}"1974            end1975            $arr_prog_ids.push([movie_name,"MO",release_year,"GN Video Links available in cloud",$gn_ingestion_status])1976          else1977            if gn_vids_mongo.empty? and gn_vids_cloud.empty?1978              #$log.info "inside if both gn_vids_mongo and gn_vids_cloud are empty"1979              log.info "inside if both gn_vids_mongo and gn_vids_cloud are empty"1980              $arr_prog_ids.push([movie_name,"MO",release_year,"Not available for Movie in Rovi & GN Dumps","Overall Status: FAIL"])1981              $not_avail_on_rovi_and_gn_cnt = $not_avail_on_rovi_and_gn_cnt + 11982              #$log.info "$not_avail_on_rovi_and_gn_cnt: #{$not_avail_on_rovi_and_gn_cnt}"1983              log.info "$not_avail_on_rovi_and_gn_cnt: #{$not_avail_on_rovi_and_gn_cnt}"1984            elsif gn_vids_mongo.empty? or gn_vids_cloud.empty?1985              $avail_on_gracenote_after_mapping_cnt = $avail_on_gracenote_after_mapping_cnt + 11986              #$log.info "One of gn_vids_mongo and gn_vids_cloud are empty, gn ingestion error"1987              log.info "One of gn_vids_mongo and gn_vids_cloud are empty, gn ingestion error"1988              $gn_ingestion_status = "GN Ingestion Status: FAIL"1989              $gn_ingest_failures_cnt = $gn_ingest_failures_cnt + 11990              #$log.info "GN Ingestion Status: FAIL count: #{$gn_ingest_failures_cnt}"1991              log.info "GN Ingestion Status: FAIL count: #{$gn_ingest_failures_cnt}"1992              $arr_prog_ids.push([movie_name,"MO",release_year,"GN Video Links available in cloud",$gn_ingestion_status])1993            end1994          end1995        end1996      end1997      $real_gn_ingestion_cnt = $avail_on_gracenote_after_mapping_cnt - $avail_on_gracenote_and_unable_to_map_cnt1998    else1999      $arr_prog_ids.push([movie_name,"MO",release_year,prog_id,"No Video Links Available in Cloud,though metadata is available","Rovi Video not Links available on cloud","GN Video Links not available in cloud","FAIL"])2000    end2001  end2002  def check_for_ingestion_of_particular_service_rovi_or_gn_ott_links_in_series_episode(ott_links_from_cloud,client,prog_id,serv_name,series_name,season_no,episode_no,episode_title,log)2003    ###################################2004    ###################################2005    #$log.info "API Spec Functions:: check_for_ingestion_of_particular_service_rovi_or_gn_ott_links_in_series_episode"2006    log.info "API Spec Functions:: check_for_ingestion_of_particular_service_rovi_or_gn_ott_links_in_series_episode"2007    dump_date = Date.today - 12008    rovi_vids_cloud = ott_links_from_cloud["Rovi Videos"]2009    gn_vids_cloud = ott_links_from_cloud["Gracenote Videos"]2010    crawler_vids_cloud = ott_links_from_cloud["Crawlers"]2011    if !rovi_vids_cloud.empty?2012      #$log.info "Episode has ott links from Rovi, proceed to validate rovi ingestion"2013      log.info "Episode has ott links from Rovi, proceed to validate rovi ingestion"2014      rovi_vids_mongo = get_rovi_ind_service_ott_links_from_mongo_db(client,prog_id,serv_name,log)2015      diff1 = rovi_vids_mongo - rovi_vids_cloud2016      #$log.info "Few Mongo vids are missing in cloud :#{diff1}"2017      log.info "Few Mongo vids are missing in cloud :#{diff1}"2018      diff2 = rovi_vids_cloud - rovi_vids_mongo2019      #$log.info "Extra vids in cloud which were not there in rovi dump :#{diff2}"2020      log.info "Extra vids in cloud which were not there in rovi dump :#{diff2}"2021      if diff1.empty? and diff2.empty?2022        #$log.info "Rovi Ingestion Status for #{series_name}, Se #{season_no}, Ep #{episode_no}: PASS"2023        log.info "Rovi Ingestion Status for #{series_name}, Se #{season_no}, Ep #{episode_no}: PASS"2024        $rovi_ingestion_status = "Rovi Ingestion Status: PASS"2025        $rovi_ingest_success_cnt = $rovi_ingest_success_cnt + 12026        #$log.info "Rovi Ingesion-PASS count: #{$rovi_ingest_success_cnt}"2027        log.info "Rovi Ingesion-PASS count: #{$rovi_ingest_success_cnt}"2028      else2029        #$log.info "Rovi Ingestion Status for #{series_name}, Se #{season_no}, Ep #{episode_no}: FAIL"2030        log.info "Rovi Ingestion Status for #{series_name}, Se #{season_no}, Ep #{episode_no}: FAIL"2031        $rovi_ingestion_status = "Rovi Ingestion Status: FAIL"2032        $rovi_ingest_failures_cnt = $rovi_ingest_failures_cnt + 12033        $episodes_with_ott_errors_cnt = $episodes_with_ott_errors_cnt + 12034        #$log.info "Rovi Ingesion-FAIL count: #{$rovi_ingest_failures_cnt}"2035        log.info "Rovi Ingesion-FAIL count: #{$rovi_ingest_failures_cnt}"2036      end2037      $arr_episode_prog_ids.push([series_name,season_no,episode_no,prog_id,"Rovi Video Links available on cloud",$rovi_ingestion_status])2038      $avail_on_rovi_cnt = $avail_on_rovi_cnt + 12039      #$log.info "avail_on_rovi_cnt: #{avail_on_rovi_cnt}"2040      log.info "avail_on_rovi_cnt: #{$avail_on_rovi_cnt}"2041    elsif !gn_vids_cloud.empty?2042      #$log.info "Episode has ott links from GN, proceed to validate gracenote ingestion"2043      log.info "Episode has ott links from GN, proceed to validate gracenote ingestion"2044      $avail_on_gracenote_after_mapping_cnt = $avail_on_gracenote_after_mapping_cnt + 12045      #$log.info "avail_on_gracenote_after_mapping_cnt: #{$avail_on_gracenote_after_mapping_cnt}"2046      log.info "avail_on_gracenote_after_mapping_cnt: #{$avail_on_gracenote_after_mapping_cnt}"2047      #gn_vids_cloud = ott_links_from_cloud["Gracenote Videos"]2048      # $log.info gn_vids_cloud2049      # log.info gn_vids_cloud2050      gn_coll = client[:GN_ott_episodes_ott]2051      cnt = gn_coll.count({"title" => /#{series_name}/i,"season_number" => "#{season_no}","episode_number" => "#{episode_no}","episode_title" => "#{episode_title}","gn_dump_date" => dump_date})2052      if cnt == 02053        #$log.info "Can't find #{series_name}, Se #{season_no}, Ep #{episode_no} in GN dump"2054        log.info "Can't find #{series_name}, Se #{season_no}, Ep #{episode_no} in GN dump"2055        $arr_episode_prog_ids.push([series_name,season_no,episode_no,prog_id,"GN Video Links are shown in cloud","Unable to map, cannot check ingestion status"])2056        $avail_on_gracenote_and_unable_to_map_cnt = $avail_on_gracenote_and_unable_to_map_cnt + 12057        #$log.info "avail_on_gracenote_and_unable_to_map_cnt: #{avail_on_gracenote_and_unable_to_map_cnt}"2058        log.info "avail_on_gracenote_and_unable_to_map_cnt: #{$avail_on_gracenote_and_unable_to_map_cnt}"2059      else2060        gn_coll.find({"title" => /#{series_name}/i,"season_number" => "#{season_no}","episode_number" => "#{episode_no}","episode_title" => "#{episode_title}","gn_dump_date" => dump_date}).limit(1).each do |doc|2061        gn_vids_mongo = nil2062        doc_json = doc.to_json2063        #log.info "Value from mongo: #{doc_json} before processing"2064 2065        parsed_doc = JSON.parse(doc_json)2066        #$log.info parsed_doc2067        log.info "Resp from GN dump: #{parsed_doc}"2068        #array_elem.push(parsed_doc)2069        gn_links_from_mongo = parsed_doc["Videos"]2070        if !gn_links_from_mongo.empty?2071          services_from_mongo = gn_links_from_mongo.keys2072          #$log.info "Filter out the GN Mongo response to contain only #{serv_name} service"2073          log.info "Filter out the GN Mongo response to contain only #{serv_name} service"2074          services_from_mongo.each do |key|2075            if key.downcase == serv_name or serv_name.include? key.downcase2076              next2077            else2078              gn_links_from_mongo.delete(key)2079            end2080          end2081        else2082          gn_vids_mongo = []2083          #$log.info "Main: GN Metadata available, but no valid gn links for program in dump"2084          log.info "Main: GN Metadata available, but no valid gn links for program in dump"2085        end2086        #$log.info "gn_links_from_mongo for #{series_name}, Se #{season_no}, Ep #{episode_no}: #{gn_links_from_mongo}"2087        log.info "gn_links_from_mongo for #{series_name}, Se #{season_no}, Ep #{episode_no}: #{gn_links_from_mongo}"2088        gn_links_from_mongo_final = gn_links_from_mongo.values2089        gn_vids_mongo = make_one_single_array(gn_links_from_mongo_final)2090        #$log.info "Main: gn_vids_mongofor #{series_name}, Se #{season_no}, Ep #{episode_no}: #{gn_vids_mongo}"2091        log.info "Main: gn_vids_mongo for #{series_name}, Se #{season_no}, Ep #{episode_no}: #{gn_vids_mongo}"2092        #$log.info "gn_vids_cloud: #{gn_vids_cloud}"2093        log.info "gn_vids_cloud: #{gn_vids_cloud}"2094        diff1 = gn_vids_mongo - gn_vids_cloud2095        #$log.info "Few GN Mongo vids are missing in cloud :#{diff1}"2096        log.info "Few GN Mongo vids are missing in cloud :#{diff1}"2097        diff2 = gn_vids_cloud - gn_vids_mongo2098        #$log.info "Extra GN vids in cloud which were not there in rovi dump :#{diff2}"2099        log.info "Extra GN vids in cloud which were not there in rovi dump :#{diff2}"2100        if diff1.empty? and diff2.empty?2101          #$log.info "GN Ingestion Status for #{series_name}, Se #{season_no}, Ep #{episode_no}: PASS"2102          log.info "GN Ingestion Status for #{series_name}, Se #{season_no}, Ep #{episode_no}: PASS"2103          $gn_ingestion_status = "GN Ingestion Status: PASS"2104          $gn_ingest_success_cnt = $gn_ingest_success_cnt + 12105          #$log.info "GN Ingestion Status: PASS count: #{$gn_ingest_success_cnt}"2106          log.info "GN Ingestion Status: PASS count: #{$gn_ingest_success_cnt}"2107        else2108          #$log.info "GN Ingestion Status for #{series_name}, Se #{season_no}, Ep #{episode_no}: FAIL"2109          log.info "GN Ingestion Status for #{series_name}, Se #{season_no}, Ep #{episode_no}: FAIL"2110          $gn_ingestion_status = "GN Ingestion Status: FAIL"2111          $gn_ingest_failures_cnt = $gn_ingest_failures_cnt + 12112          $episodes_with_ott_errors_cnt = $episodes_with_ott_errors_cnt + 12113          #$log.info "GN Ingestion Status: FAIL count: #{$gn_ingest_failures_cnt}"2114          log.info "GN Ingestion Status: FAIL count: #{$gn_ingest_failures_cnt}"2115        end2116        $arr_episode_prog_ids.push([series_name,season_no,episode_no,"GN Video Links available in cloud",$gn_ingestion_status])2117      end2118    end2119    elsif !crawler_vids_cloud.empty?2120      $episodes_with_ott_links_from_crawler = $episodes_with_ott_links_from_crawler + 12121      $arr_episode_prog_ids.push([series_name,season_no,episode_no,"Video Links available in cloud got from crawler"])2122    end2123    $real_gn_ingestion_cnt = $avail_on_gracenote_after_mapping_cnt - $avail_on_gracenote_and_unable_to_map_cnt2124          ###################################2125          ###################################2126  end2127  def validate_individual_service_links_in_all_series_episodes(client,series_name,prog_id,serv_name,netflix_no_of_seasons,log)2128    #$log.info "Ozone_Api_Specific_Functions::validate_individual_service_links_in_all_series_episodes"2129    log.info "Ozone_Api_Specific_Functions::validate_individual_service_links_in_all_series_episodes"2130    videos_got_from_cloud = {"Rovi Videos" => [],"Gracenote Videos" => [],"Crawlers" => []}2131    $episodes_without_ott_links_cnt = 02132    $episodes_cnt = 02133    $episodes_with_ott_errors_cnt = 02134    $episodes_with_ott_links_from_crawler = 02135    $rovi_ingest_success_cnt = 02136    $rovi_ingest_failures_cnt = 02137    $gn_ingest_failures_cnt = 02138    $gn_ingest_success_cnt = 02139    episodes_api = "/programs/#{prog_id}/episodes?ott=true&service=" + $serv_name2140    get episodes_api2141    response_code_validation("get",episodes_api)2142    resp = json_body2143    resp_len = resp.length2144    for i in 0..resp_len-12145      #$log.info "For loop: #{i}th episode object"2146      log.info "For loop: #{i}th episode object"2147      #$log.info "Object: #{resp[i]}"2148      log.info "Object: #{resp[i]}"2149      ott_links_from_cloud_for_ind_service = resp[i][:videos]2150      episode_title = resp[i][:original_episode_title]2151      #$log.info "Episode title: #{episode_title}"2152      log.info "Episode title: #{episode_title}"2153      ser_name = resp[i][:long_title]2154      #$log.info "Series: #{ser_name}"2155      log.info "Series: #{ser_name}"2156      seas_no = resp[i][:episode_season_number]2157      #$log.info "Season no: #{seas_no}"2158      log.info "Season no: #{seas_no}"2159      episode_no = resp[i][:episode_season_sequence]2160      #$log.info "Episode no: #{episode_no}"2161      log.info "Episode no: #{episode_no}"2162      ep_prog_id = resp[i][:id]2163      #$log.info "Episode prog id: #{ep_prog_id}"2164      log.info "Episode prog id: #{ep_prog_id}"2165      #$log.info "Seas_no type: #{seas_no.class}"2166      log.info "Seas_no type: #{seas_no.class}"2167      #$log.info "netflix_no_of_seasons type: #{netflix_no_of_seasons.class}"2168      log.info "netflix_no_of_seasonstype: #{netflix_no_of_seasons.class}"2169      if seas_no <= netflix_no_of_seasons.to_i2170        $episodes_cnt = $episodes_cnt + 12171        len = ott_links_from_cloud_for_ind_service.length2172        rovi_videos_list_got_from_cloud = Array.new2173        gracenote_videos_list_got_from_cloud = Array.new2174        crawler_videos_list_got_from_cloud = Array.new2175        if len > 02176          ##$log.info "Inside if len > O"2177          log.info "Inside if len > O"2178 2179          for i in 0..len-12180            #$log.info "FOR Loop: To iterate through all #{serv_name} ott objects of a single episode"2181            log.info "FOR Loop: To iterate through all #{serv_name} ott objects of a single episode"2182            video_obj_from_cloud = ott_links_from_cloud_for_ind_service[i]2183            ind_service_name = video_obj_from_cloud[:source_id]2184            if $serv_name == ind_service_name2185              #$log.info "#{ind_service_name} is of type #{serv_name}, going to process"2186              log.info "#{ind_service_name} is of type #{serv_name}, going to process"2187              if video_obj_from_cloud[:fetched_from].nil?2188                #$log.info "Rovi object, hence remove all dynamic key-value pairs"2189                log.info "Rovi object, hence remove all dynamic key-value pairs"2190                video_obj_from_cloud.delete(:platform)2191                video_obj_from_cloud.delete(:last_refreshed_timestamp)2192                video_obj_from_cloud.delete(:content_expiry_timestamp)2193                video_obj_from_cloud.delete(:cache_expiry_timestamp)2194                video_obj_from_cloud.delete(:launch_id)2195                video_obj_from_cloud.delete(:created_at)2196                video_obj_from_cloud.delete(:updated_at)2197                video_obj_from_cloud.delete(:refreshed_at)2198                video_obj_from_cloud.delete(:with_subscription)2199                video_obj_from_cloud.delete(:subscription_type)2200                video_obj_from_cloud.delete(:audio_languages)2201                if video_obj_from_cloud[:run_time].nil?2202                  video_obj_from_cloud.delete(:run_time)2203                else2204                  video_obj_from_cloud[:content_runtime_s] = video_obj_from_cloud[:run_time]2205                  video_obj_from_cloud.delete(:run_time)2206                end2207                if video_obj_from_cloud[:constraints].empty?2208                  video_obj_from_cloud.delete(:constraints)2209                end2210                if video_obj_from_cloud[:quality].nil?2211                  video_obj_from_cloud.delete(:quality)2212                end2213                if video_obj_from_cloud[:purchase_type] == ""2214                  video_obj_from_cloud.delete(:purchase_type)2215                end2216                if video_obj_from_cloud[:source_id] == "hulu"2217                  video_obj_from_cloud.delete(:source_program_id)2218                end2219                rovi_videos_list_got_from_cloud.push(video_obj_from_cloud)2220              elsif video_obj_from_cloud[:fetched_from] == "gracenote"2221                #$log.info "GN object, hence adding only url to array"2222                log.info "GN object, hence adding only url to array"2223                gn_url = video_obj_from_cloud[:link][:uri]2224                gracenote_videos_list_got_from_cloud.push(gn_url)2225              elsif video_obj_from_cloud[:fetched_from] == "crawler"2226                #$log.info "Got from crawler, hence adding only url to array"2227                log.info "Got from crawler, hence adding only url to array"2228                crawler_url = video_obj_from_cloud[:link][:uri]2229                crawler_videos_list_got_from_cloud.push(crawler_url)2230              end2231              videos_got_from_cloud = {"Rovi Videos" => rovi_videos_list_got_from_cloud,"Gracenote Videos" => gracenote_videos_list_got_from_cloud,"Crawlers" => crawler_videos_list_got_from_cloud}2232    2233              #$log.info "Videos got from cloud for the service #{serv_name}: #{videos_got_from_cloud}"2234              log.info "Videos got from cloud for the service #{serv_name}: #{videos_got_from_cloud}"2235              #videos_got_from_cloud2236              #Addition of ingestion logic here2237              check_for_ingestion_of_particular_service_rovi_or_gn_ott_links_in_series_episode(videos_got_from_cloud,client,ep_prog_id,serv_name,ser_name,seas_no,episode_no,episode_title,log)2238            else2239              #$log.info "#{ind_service_name} is not of type #{serv_name}, moving to next"2240              log.info "#{ind_service_name} is not of type #{serv_name}, moving to next"2241     2242            end2243          end2244          #$log.info "END OF FOR Loop: To iterate through all #{serv_name} ott objects of a single episode"2245          log.info "END OF FOR Loop: To iterate through all #{serv_name} ott objects of a single episode"2246        else2247          #$log.info "Inside else, empty cloud response"2248          log.info "Inside else, empty cloud response"2249          #episodes_without_ott_links_cnt = episodes_without_ott_links_cnt + 12250          query_rovi_and_gn_dump_and_check_for_availability_of_episode_for_a_particular_service(client,ser_name,seas_no,episode_no,episode_title,ep_prog_id,serv_name,log)2251          #$arr_episode_prog_ids.push([ser_name,seas_no,episode_no,ep_prog_id,"No Video Links Available in Cloud"])2252        end2253      else2254        #$log.info "Exiting validation as #{netflix_no_of_seasons} is less than #{seas_no}"2255        log.info "Exiting validation as #{netflix_no_of_seasons} is less than #{seas_no}"2256      end2257 2258    end2259    #$log.info "END OF For loop which iterates across all episodes"2260    log.info "END OF For loop which iterates across all episodes"2261    if $episodes_without_ott_links_cnt > 02262      if $episodes_without_ott_links_cnt == $episodes_cnt2263        $arr_prog_ids.push([series_name,"SM",prog_id,"OTT Links not available on cloud for all episodes","Not available in Rovi Dump","Not available in GN dump","FAIL"])2264        #$log.info "#{$episodes_without_ott_links_cnt} episodes of Series #{ser_name} do not have #{serv_name} ott links at all."2265        log.info "#{$episodes_without_ott_links_cnt} episodes of Series #{ser_name} do not have #{serv_name} ott links at all."2266      else2267        $arr_prog_ids.push([series_name,"SM",prog_id,"OTT Links not available on cloud for some episodes","#{$episodes_with_ott_errors_cnt} out of #{$episodes_cnt} episodes have ott errors","FAIL"])2268        #$log.info "#{$episodes_without_ott_links_cnt} episodes of Series #{ser_name} do not have #{serv_name} ott links at all."2269        log.info "#{$episodes_without_ott_links_cnt} episodes of Series #{ser_name} do not have #{serv_name} ott links for some episodes."2270      end2271    else2272      if $rovi_ingest_failures_cnt == 0 and $gn_ingest_failures_cnt == 02273        if $rovi_ingest_success_cnt > 0 and $gn_ingest_success_cnt == 02274          $arr_prog_ids.push([series_name,"SM",prog_id,"OTT Links available on cloud for all episodes","Rovi Ingestion Status - PASS"])2275          #$log.info "#{$rovi_ingest_success_cnt} out of #{$episodes_cnt} have been ingested succesfully from rovi dump,hence ingestion -PASS"2276          log.info "#{$rovi_ingest_success_cnt} out of #{$episodes_cnt} have been ingested succesfully from rovi dump,hence Rovi Ingestion Status -PASS"2277        elsif $gn_ingest_success_cnt > 0 and $rovi_ingest_success_cnt == 02278          $arr_prog_ids.push([series_name,"SM",prog_id,"OTT Links available on cloud for all episodes","GN Ingestion Status - PASS"])2279          #$log.info "#{$gn_ingest_success_cnt} out of #{$episodes_cnt} have been ingested succesfully from gn dump,hence ingestion -PASS"2280          log.info "#{$gn_ingest_success_cnt} out of #{$episodes_cnt} have been ingested succesfully from gn dump,hence GN Ingestion Status -PASS"2281        else2282          $arr_prog_ids.push([series_name,"SM",prog_id,"OTT Links available on cloud for all episodes","Ingestion status from both Rovi & GN - PASS"])2283          #$log.info "#{$gn_ingest_success_cnt} out of #{$episodes_cnt} have been ingested succesfully from gn dump,hence ingestion -PASS"2284          log.info "#{$gn_ingest_success_cnt} out of #{$episodes_cnt} have been ingested succesfully from gn dump,hence GN Ingestion Status -PASS"2285        end2286      else2287        $arr_prog_ids.push([series_name,"SM",prog_id,"OTT Links available on cloud for all episodes,but there ingestion failures","#{$episodes_with_ott_errors_cnt} out of #{$episodes_cnt} episodes have ott errors","FAIL"])2288         #$log.info "#{$rovi_ingest_failures_cnt} out of #{$episodes_cnt} have ingestion failures,hence ingestion status -FAIL"2289        log.info "#{$rovi_ingest_failures_cnt} out of #{$episodes_cnt} have ingestion failures,hence ingestion status -FAIL"2290        #$log.info "#{$gn_ingest_failures_cnt} out of #{$episodes_cnt} have ingestion failures,hence ingestion status -FAIL"2291        log.info "#{$gn_ingest_failures_cnt} out of #{$episodes_cnt} have ingestion failures,hence ingestion status -FAIL"2292      end2293    end2294  end2295  def query_gn_dump_and_check_for_availability_of_series_for_a_particular_service(client,series_name,serv_name,netflix_year,netflix_no_of_seasons,log)2296    #$log.info "API Spec Functions::query_gn_dump_and_check_for_availability_of_series_for_a_particular_service"2297    log.info "API Spec Functions::query_gn_dump_and_check_for_availability_of_series_for_a_particular_service"2298    series_avail_on_gn_flag = false2299    dump_date = Date.today - 12300    gn_coll = client[:GN_ott_episodes_ott]2301    cnt = gn_coll.count({"title" => /#{series_name}/i,"show_type" => "SM","gn_dump_date" => dump_date})2302    if cnt == 02303      #$log.info "Can't find series: #{series_name} in GN dump"2304      log.info "Can't find series: #{series_name} in GN dump"2305      $arr_prog_ids.push([series_name,"SM",netflix_year,netflix_no_of_seasons,"Series not available on Rovi","Series not available on Gracenote","FAIL"])2306      $not_avail_on_rovi_and_gn_cnt = $not_avail_on_rovi_and_gn_cnt + 12307      #$log.info "not_avail_on_rovi_and_gn_cnt: #{$not_avail_on_rovi_and_gn_cnt}"2308      log.info "not_avail_on_rovi_and_gn_cnt: #{$not_avail_on_rovi_and_gn_cnt}"2309    else2310      #$log.info "There are #{cnt} docs returned by mongo db when querying #{series_name}, let's see more details"2311      log.info "There are #{cnt} docs returned by mongo db when querying #{series_name}, let's see more details"2312      gn_coll.find({"title" => /#{series_name}/i,"show_type" => "SM","gn_dump_date" => dump_date}).limit(1).each do |doc|2313        gn_mongo = nil2314        doc_json = doc.to_json2315        parsed_doc = JSON.parse(doc_json)2316        #$log.info parsed_doc2317        log.info "Resp from GN dump: #{parsed_doc}"2318        #array_elem.push(parsed_doc)2319        gn_links_from_mongo = parsed_doc["Videos"]2320        episode_title = parsed_doc["episode_title"]2321        season_number = parsed_doc["season_number"]2322        episode_number = parsed_doc["episode_number"]2323        if !gn_links_from_mongo.empty?2324          services_from_mongo = gn_links_from_mongo.keys2325          #$log.info "Filter out the GN Mongo response to contain only supported services"2326          log.info "Filter out the GN Mongo response to contain only supported services"2327          services_from_mongo.each do |key|2328            if key.downcase == serv_name or serv_name.include? key.downcase2329              next2330            else2331              gn_links_from_mongo.delete(key)2332            end2333          end2334          series_avail_on_gn_flag = true2335          #$log.info "gn_links_from_mongo for series-#{series_name}: #{gn_links_from_mongo}"2336          log.info "gn_links_from_mongo for series-#{series_name}: #{gn_links_from_mongo}"2337          gn_links_from_mongo_final = gn_links_from_mongo.values2338          gn_mongo = make_one_single_array(gn_links_from_mongo_final)2339          #$log.info "Main: gn mongo for movie-#{series_name}: #{gn_mongo}"2340          log.info "Main: gn mongo for series-#{series_name}: #{gn_mongo}"2341          $arr_episode_prog_ids.push([series_name,season_number,episode_number,episode_title,"Available on GN dump but not available in cloud","Links:#{gn_mongo}"])2342 2343        else2344          gn_mongo = []2345          #$log.info "Main: GN Metadata available, but no valid gn links for program in dump"2346          log.info "Main: GN Metadata available, but no valid gn links for program in dump"2347          $not_avail_on_rovi_and_gn_cnt = $not_avail_on_rovi_and_gn_cnt + 12348        end2349      end2350      if series_avail_on_gn_flag2351        $not_avail_on_rovi_but_avail_on_gn_cnt = $not_avail_on_rovi_but_avail_on_gn_cnt + 12352        #$log.info "not_avail_on_rovi_but_avail_on_gn_cnt: #{$not_avail_on_rovi_but_avail_on_gn_cnt}"2353        log.info "not_avail_on_rovi_but_avail_on_gn_cnt: #{$not_avail_on_rovi_but_avail_on_gn_cnt}"2354        $arr_prog_ids.push([series_name,"SM",netflix_year,netflix_no_of_seasons,"Series not available on Rovi","Series available on GN."])2355      end2356    end2357 2358  end2359  def query_rovi_and_gn_dump_and_check_for_availability_of_episode_for_a_particular_service(client,ser_name,seas_no,episode_no,episode_title,ep_prog_id,serv_name,log)2360    #$log.info "API spec: query_rovi_and_gn_dump_and_check_for_availability_of_episode_for_a_particular_service"2361    log.info "API spec: query_rovi_and_gn_dump_and_check_for_availability_of_episode_for_a_particular_service"2362    rovi_vids_mongo = get_rovi_ind_service_ott_links_from_mongo_db(client,ep_prog_id,serv_name,log)2363    if !rovi_vids_mongo.nil?2364      log.info "!rovi_vids_mongo.nil?"2365      if rovi_vids_mongo.empty?2366        log.info "rovi_vids_mongo.empty?"2367        rovi_vids_mongo = nil2368      end2369    end2370    gn_vids_mongo = query_gn_dump_for_availability_of_episode_and_return_links_if_any(client,ser_name,seas_no,episode_no,episode_title,serv_name,log)2371    if rovi_vids_mongo.nil? and gn_vids_mongo.nil?2372      log.info "rovi_vids_mongo.nil? and gn_vids_mongo.nil?"2373      rovi_vids_mongo = get_rovi_ind_service_ott_links_from_mongo_db(client,ep_prog_id,serv_name,log)2374      $episodes_without_ott_links_cnt = $episodes_without_ott_links_cnt + 12375      log.info "$episodes_without_ott_links_cnt up: #{$episodes_without_ott_links_cnt}"2376      $episodes_with_ott_errors_cnt = $episodes_with_ott_errors_cnt + 12377      log.info "$episodes_with_ott_errors_cnt up: #{$episodes_with_ott_errors_cnt}"2378      $arr_episode_prog_ids.push([ser_name,seas_no,episode_no,ep_prog_id,"No Video Links Available in Cloud,though metadata is available","No links available in Rovi Dump","No links available in GN Dump","FAIL"])2379    elsif !rovi_vids_mongo.nil? and !gn_vids_mongo.nil?2380      log.info "!rovi_vids_mongo.nil? and !gn_vids_mongo.nil?"2381      $episodes_with_ott_errors_cnt = $episodes_with_ott_errors_cnt + 12382      log.info "$episodes_with_ott_errors_cnt up: #{$episodes_with_ott_errors_cnt}"2383      $arr_episode_prog_ids.push([ser_name,seas_no,episode_no,ep_prog_id,"No Video Links Available in Cloud,though metadata is available","Links available in Rovi Dump","Links available in GN Dump","FAIL"])2384    elsif !rovi_vids_mongo.nil?2385      log.info "!rovi_vids_mongo.nil?"2386      $episodes_with_ott_errors_cnt = $episodes_with_ott_errors_cnt + 12387      log.info "$episodes_with_ott_errors_cnt up: #{$episodes_with_ott_errors_cnt}"2388      $rovi_ingest_failures_cnt = $rovi_ingest_failures_cnt + 12389      log.info "$rovi_ingest_failures_cnt up: #{$rovi_ingest_failures_cnt}"2390      $arr_episode_prog_ids.push([ser_name,seas_no,episode_no,ep_prog_id,"No Video Links Available in Cloud,though metadata is available","Links available in Rovi Dump","FAIL"])2391    elsif !gn_vids_mongo.nil?2392      log.info " !gn_vids_mongo.nil?"2393      $episodes_with_ott_errors_cnt = $episodes_with_ott_errors_cnt + 12394      log.info "$episodes_with_ott_errors_cnt up: #{$episodes_with_ott_errors_cnt}"2395      $gn_ingest_failures_cnt = $gn_ingest_failures_cnt + 12396      log.info "$gn_ingest_failures_cnt up: #{$gn_ingest_failures_cnt}"2397      $arr_episode_prog_ids.push([ser_name,seas_no,episode_no,ep_prog_id,"No Video Links Available in Cloud,though metadata is available","Links available in GN Dump","FAIL"])2398    end2399 2400  end2401  def query_gn_dump_for_availability_of_episode_and_return_links_if_any(client,series_name,season_no,episode_no,episode_title,serv_name,log)2402    gn_coll = client[:GN_ott_episodes_ott]2403    dump_date = Date.today - 12404    gn_vids_mongo = nil2405    cnt = gn_coll.count({"title" => /#{series_name}/i,"season_number" => "#{season_no}","episode_number" => "#{episode_no}","episode_title" => "#{episode_title}","gn_dump_date" => dump_date})2406    if cnt == 02407      #$log.info "Can't find #{series_name}, Se #{season_no}, Ep #{episode_no} in GN dump"2408      log.info "Can't find #{series_name}, Se #{season_no}, Ep #{episode_no}, #{episode_title} in GN dump"2409    else2410      gn_coll.find({"title" => /#{series_name}/i,"season_number" => "#{season_no}","episode_number" => "#{episode_no}","episode_title" => "#{episode_title}","gn_dump_date" => dump_date}).limit(1).each do |doc|2411        doc_json = doc.to_json2412        #log.info "Value from mongo: #{doc_json} before processing"2413        parsed_doc = JSON.parse(doc_json)2414        #$log.info parsed_doc2415        log.info "Resp from GN dump: #{parsed_doc}"2416        #array_elem.push(parsed_doc)2417        gn_links_from_mongo = parsed_doc["Videos"]2418        if !gn_links_from_mongo.empty?2419          services_from_mongo = gn_links_from_mongo.keys2420          #$log.info "Filter out the GN Mongo response to contain only #{serv_name} service"2421          log.info "Filter out the GN Mongo response to contain only #{serv_name} service"2422          services_from_mongo.each do |key|2423            if key.downcase == serv_name or serv_name.include? key.downcase2424              next2425            else2426              gn_links_from_mongo.delete(key)2427            end2428          end2429          #$log.info "gn_links_from_mongo for #{series_name}, Se #{season_no}, Ep #{episode_no}: #{gn_links_from_mongo}"2430          log.info "gn_links_from_mongo for #{series_name}, Se #{season_no}, Ep #{episode_no}: #{gn_links_from_mongo}"2431          gn_links_from_mongo_final = gn_links_from_mongo.values2432          gn_vids_mongo = make_one_single_array(gn_links_from_mongo_final)2433          #$log.info "Main: gn_vids_mongofor #{series_name}, Se #{season_no}, Ep #{episode_no}: #{gn_vids_mongo}"2434          log.info "Main: gn_vids_mongo for #{series_name}, Se #{season_no}, Ep #{episode_no}: #{gn_vids_mongo}"2435        else2436          gn_vids_mongo = []2437          #$log.info "Main: GN Metadata available, but no valid gn links for program in dump"2438          log.info "Main: GN Metadata available, but no valid gn links for program in dump"2439        end2440      end2441    end2442    if !gn_vids_mongo.nil?2443      if gn_vids_mongo.empty?2444        gn_vids_mongo = nil2445      end2446    end2447    gn_vids_mongo2448  end2449  def get_program_details(wl_obj)2450    prog_details = {}2451    prog_details["id"] = nil2452    prog_name = wl_obj[:long_title]2453    prog_details["name"] = prog_name2454    $log.info "prog_name: #{prog_name}"2455    show_type = wl_obj[:show_type]2456    prog_details["show_type"] = show_type2457    $log.info "show_type: #{show_type}"2458    case show_type2459    when "SE"2460      prog_id = wl_obj[:series_id]2461      prog_details["id"] = prog_id2462      $log.info "Series id: #{prog_id}"2463      # episode_title = wl_obj[:original_episode_title]2464      # prog_details["episode_title"] = episode_title2465      # $log.info "episode_title: #{episode_title}"2466      season_number = wl_obj[:episode_season_number]2467      prog_details["season_num"] = season_number2468      $log.info "season_number: #{season_number}"2469      episode_number = wl_obj[:episode_season_sequence]2470      prog_details["episode_num"] = episode_number2471      $log.info "episode_number: #{episode_number}"2472    when "SN"2473      prog_id = wl_obj[:series_id]2474      prog_details["id"] = prog_id2475      $log.info "Series id: #{prog_id}"2476      season_number = wl_obj[:season_number]2477      prog_details["season_num"] = season_number2478      $log.info "season_number: #{season_number}"2479      prog_details["episode_num"] = 12480      $log.info "Setting episode number to 1"2481      prog_details["show_type"] = "SE"2482    when "MO"2483      prog_id = wl_obj[:id]2484      prog_details["id"] = prog_id2485      $log.info "Movie id: #{prog_id}"2486      rel_year = wl_obj[:release_year]2487      prog_details["rel_year"] = rel_year2488      $log.info "rel_year: #{rel_year}"2489    end2490    $log.info "prog_details!!!: #{prog_details}"2491  prog_details2492  end2493  def watchlist_test(serv,serv_feed)2494    intent_arr = ["","play","watch","resume"]2495    for i in 0..22496      iteration = i+12497      $log.info "Iteration: #{iteration}, Service: #{serv}"2498      intent = intent_arr.sample2499      wl_obj = serv_feed.sample2500      prog_details = get_program_details(wl_obj)2501      prog_name = prog_details["name"]2502      api_part1 = "/voice_search?q="2503      api = api_part1 + intent + "%20" + prog_name2504      api_url = $base_url + api2505      $current_url = api_url2506      $log.info "The complete url to be tested is - #{api_url}<br>"2507      #Run the get api2508      get api2509      # 1.Response Code Validation2510      response_code_validation("get",api)2511      $log.info "Completed response code validation<br>"2512      $resp_code_validation_status = true2513      ott_search_index = get_index_of_ott_search_object(json_body)2514      $log.info "ott_search_index: #{ott_search_index}"2515      # 2.Schema Validation2516      program_search_schema_validation_new(api_url,json_body,ott_search_index)2517      $log.info  "Completed schema validation, proceeding to complete response validation for mandatory fields<br>"2518      $schema_validation_status = true2519      # 3. JSON response validation2520      watchlist_search_response_validation(serv,prog_details,json_body,ott_search_index)2521      $log.info  "Completed response validation"2522      $values_matching_validation_status = true2523    end2524  end2525  def post_device_details(type)2526    it 'posts device with details' do2527      $log.info "API Specs::post_device_details"2528      api = "/switches/devices"2529      devices = $conf["box_devices"]2530      devices_by_name = devices.keys2531      devices_by_id = devices.values2532      $log.info "Devices: #{devices}"2533      if type == "random"2534        $log.info "if :: random device to post"2535        rand_dev = devices_by_name.sample2536        rand_dev_id = devices[rand_dev]2537        rand_port = ports.sample2538        $random_device = {"port"=>rand_port, "device_id"=>rand_dev_id, "device_name"=>rand_dev}2539        $log.info "if :: random device-#{rand_dev}, id-#{rand_dev_id}"2540        req_body = { "port"=>rand_port, "device_id"=>rand_dev_id, "device_name"=>rand_dev, "scan_method"=>"" }2541        post api, req_body2542        response_code_validation("get")2543      elsif type == "all"2544        $log.info "elsif :: post all devices"2545        ports = [0,1,2,3,4,5,6,8]2546        i = 02547        devices_by_name.each do|dev|2548          dev_id = devices[dev]2549          port = ports[i]2550          req_body = { "port"=>port, "device_id"=>dev_id, "device_name"=>dev, "scan_method"=>"" }2551          $log.info "Req body to be posted is: #{req_body}"2552          retry_cnt = 02553          begin2554            post api, req_body2555            expect_status(200)2556          rescue Exception => exp_err2557            $log.info "Caught exception-'#{exp_err}' while trying to post data. Going to retry"2558            if retry_cnt < 32559              $log.info "Retry - #{retry_cnt}"2560              retry_cnt += 12561              retry2562            else2563              raise "Getting nil response for api:#{api} on 3 retry attempts"2564            end2565          end2566          i += 12567          sleep 0.52568        end2569      else2570        $log.info "else :: post specific device-#{type}"2571        if type == "Roku"2572          ports = [0,2,4,6]2573          port = ports.sample2574          $dev_port1 = port2575        else2576          ports = [1,3,5,7]2577          port = ports.sample2578          $dev_port2 = port2579        end2580        dev = type2581        dev_id = devices[dev]2582        $log.info "Port on which #{type} is posted: #{$dev_port}"2583        req_body = { "port"=>port, "device_id"=>dev_id, "device_name"=>dev, "scan_method"=>"" }2584        $log.info "Req body to be posted is: #{req_body}"2585        post api, req_body2586        retry_cnt = 02587        begin2588          post api, req_body2589          expect_status(200)2590        rescue Exception => exp_err2591          $log.info "Caught exception-'#{exp_err}' while trying to post data. Going to retry"2592          if retry_cnt < 32593            $log.info "Retry - #{retry_cnt}"2594            retry_cnt += 12595            retry2596          else2597            raise "Getting nil response for api:#{api} on 3 retry attempts"2598          end2599        end2600      end2601    end2602  end2603  def delete_all_devices_from_switch()2604    it 'deletes devices associated with switch' do2605      $log.info "API Specs::delete_all_devices_from_switch"2606      ports = [0,1,2,3,4,5,6,7,8]2607      api = "/switches/devices"2608      ports.each do |port|2609        $log.info "Deleting device at Port: #{port}"2610        req_body = { "port"=>port, "device_id"=>"not_conn", "device_name"=>"", "scan_method"=>"" }2611        retry_cnt = 02612        begin2613          post api, req_body2614          expect_status(200)2615        rescue Exception => exp_err2616          $log.info "Caught exception-'#{exp_err}' while trying to post data. Going to retry"2617          if retry_cnt < 32618            $log.info "Retry - #{retry_cnt}"2619            retry_cnt += 12620            retry2621          else2622            raise "Getting nil response for api:#{api} on 3 retry attempts"2623          end2624        end2625      end2626    end2627  end2628  def get_device_details(type,devs=nil)2629    it 'gets device details' do2630      $log.info "API Specs::get_device_details"2631      api = "/switches/devices"2632      devices = $conf["box_devices"]2633      devices_by_name = devices.keys2634      devices_by_id = devices.values2635      $log.info "Devices: #{devices}"2636      if type == "single"2637        $log.info "if :: seeing single device was added"2638        get api2639        response_code_validation("get",api)2640        $log.info "response - #{json_body}"2641        switches_device_schema_validation()2642        response_validation_switches_devices(type,devs)2643      elsif type == "many"2644        $log.info "elsif :: many cond - seeing the devices added"2645        get api2646        response_code_validation("get",api)2647        $log.info "response - #{json_body}"2648        switches_device_schema_validation()2649        response_validation_switches_devices(type,devs)2650      elsif type == "all"2651        $log.info "elsif :: see if all devices were posted succesfully"2652        get api2653        response_code_validation("get",api)2654        $log.info "response - #{json_body}"2655        switches_device_schema_validation(type)2656        response_validation_switches_devices(type,devs)2657      elsif type == "none"2658        $log.info "elsif :: see if no devices are available for box"2659        get api2660        response_code_validation("get",api)2661        $log.info "response - #{json_body}"2662        switches_device_schema_validation(type)2663        response_validation_switches_devices(type,devs)2664      else2665        $log.info "else::see if specific device-#{type} was posted"2666        get api2667        response_code_validation("get",api)2668        $log.info "response - #{json_body}"2669        switches_device_schema_validation()2670        response_validation_switches_devices(type)2671      end2672    end2673  end 2674  def get_app_details_for_devices(type,devs=nil)2675    it 'gets app details of a switch based on devices connected to it' do2676      $log.info "API Specs::get_app_details"2677      api = "/switches/apps"2678      devices = $conf["box_devices"]2679      devices_by_name = devices.keys2680      devices_by_id = devices.values2681      $log.info "Devices: #{devices}"2682      if type == "single"2683        $log.info "if :: single device case:"2684        dev_id = devices[devs]2685        get api2686        response_code_validation("get",api)2687        $log.info "response - #{json_body}"2688        switches_apps_schema_validation()2689        response_validation_switches_apps(type,devs)2690      elsif type == "many"2691        $log.info "if :: many devices case"2692        get api2693        response_code_validation("get",api)2694        $log.info "response - #{json_body}"2695        switches_apps_schema_validation()2696        response_validation_switches_apps(type,devs,json_body)2697      elsif type == "all"2698        $log.info "elsif :: see if all devices were posted succesfully"2699        get api2700        response_code_validation("get",api)2701        $log.info "response - #{json_body}"2702        switches_apps_schema_validation()2703        response_validation_switches_apps(type,devs,json_body)2704      else2705        $log.info "else::see if specific device-#{type} is available for apps in response"2706        dev = type2707        dev_id = devices[dev]2708        get api2709        response_code_validation("get",api)2710        $log.info "response - #{json_body}"2711        switches_apps_schema_validation()2712        response_validation_switches_apps(type)2713      end2714    end2715  end   2716  def select_apps_and_post()2717    it 'Select apps and post the ids to cloud - switches/profiles/apps' do2718      $log.info "API Specs :: select_apps_and_post"2719      api = "/switches/profiles/apps"2720      apps_selected = $conf["apps_selected_in_box"]2721      req_body = { "apps"=> apps_selected}2722      retry_cnt = 02723      begin2724        post api, req_body2725        expect_status(200)2726      rescue Exception => exp_err2727        $log.info "Caught exception-'#{exp_err}' while trying to post data. Going to retry"2728        if retry_cnt < 32729          $log.info "Retry - #{retry_cnt}"2730          retry_cnt += 12731          retry2732        else2733          raise "Getting nil response for api:#{api} on 3 retry attempts"2734        end2735      end2736    end2737  end2738  def post_corresponding_services_and_post()2739    it 'Post corresponding services to cloud - switches/profiles/profiles' do2740      $log.info "API Specs :: post_corresponding_services_and_post"2741      api = "/switches/profiles/services"2742      services_selected = $conf["services_selected_in_box"]2743      req_body = { "services" => services_selected }2744      retry_cnt = 02745      begin2746        post api, req_body2747        expect_status(200)2748      rescue Exception => exp_err2749        $log.info "Caught exception-'#{exp_err}' while trying to post data. Going to retry"2750        if retry_cnt < 32751          $log.info "Retry - #{retry_cnt}"2752          retry_cnt += 12753          retry2754        else2755          raise "Getting nil response for api:#{api} on 3 retry attempts"2756        end2757      end2758    end2759  end2760  def delete_switches_profiles_apps()2761    it "Deletes apps from switches/profiles" do2762      $log.info "API Specs :: delete_switches_profiles_apps"2763      api = "/switches/profiles/apps"2764      retry_cnt = 02765      begin2766        delete api2767        expect_status(200)2768      rescue Exception => exp_err2769        $log.info "Caught exception-'#{exp_err}' while trying to post data. Going to retry"2770        if retry_cnt < 32771          $log.info "Retry - #{retry_cnt}"2772          retry_cnt += 12773          retry2774        else2775          raise "Getting nil response for api:#{api} on 3 retry attempts"2776        end2777      end2778    end2779  end2780  def delete_switches_profiles_services()2781    it "Deletes services from switches/profiles" do2782      $log.info "API Specs :: delete_switches_profiles_services"2783      api = "/switches/profiles/services"2784      retry_cnt = 02785      begin2786        delete api2787        expect_status(200)2788      rescue Exception => exp_err2789        $log.info "Caught exception-'#{exp_err}' while trying to post data. Going to retry"2790        if retry_cnt < 32791          $log.info "Retry - #{retry_cnt}"2792          retry_cnt += 12793          retry2794        else2795          raise "Getting nil response for api:#{api} on 3 retry attempts"2796        end2797      end2798    end2799  end2800  def check_switches_profiles_updated_with_apps_and_services()2801    it "Checks switches/profiles is updated" do2802      $log.info "API Specs :: see_switches_profiles_updated_with_apps_and_services"2803      api = "/switches/profiles"2804      retry_cnt = 02805      apps_selected = $conf["apps_selected_in_box"]2806      services_selected = $conf["services_selected_in_box"]2807      get api2808      response_code_validation("get",api)2809      expect_json("apps",apps_selected)2810      expect_json("services",services_selected)2811    end2812  end2813  def arrange_ottlinks_from_cloud(json_body,log)2814    log.info "Ozone Api Spec Functions::arrange_ottlinks_from_cloud"2815    rovi_videos_list_got_from_cloud = Array.new2816    gracenote_videos_list_got_from_cloud = Array.new2817    hulu_videos_list_got_from_cloud = Array.new2818    vudu_videos_list_got_from_cloud = Array.new2819    crawler_videos_list_got_from_cloud = Array.new2820    all_videos_list_got_from_cloud = Array.new2821    videos_got_from_cloud = {"Rovi Videos"=> [],"Gracenote Videos"=> [],"Hulu Videos"=> [],"Vudu Videos"=> [],"Crawler Videos"=>[],"All Videos" => []}2822    2823    len = json_body.length2824    if len > 02825      #$log.info "Inside if len > O"2826      log.info "videos count from cloud for the episode: #{json_body.length}"2827 2828      for i in 0..len-12829        video_obj_from_cloud = json_body[i]2830        log.info "video_obj_from_cloud:: #{video_obj_from_cloud}"2831        video_obj_from_cloud.delete(:platform)2832        video_obj_from_cloud.delete(:last_refreshed_timestamp)2833        video_obj_from_cloud.delete(:content_expiry_timestamp)2834        video_obj_from_cloud.delete(:cache_expiry_timestamp)2835        video_obj_from_cloud.delete(:launch_id)2836        video_obj_from_cloud.delete(:created_at)2837        video_obj_from_cloud.delete(:updated_at)2838        video_obj_from_cloud.delete(:refreshed_at)2839        video_obj_from_cloud.delete(:with_subscription)2840        video_obj_from_cloud.delete(:subscription_type)2841        video_obj_from_cloud.delete(:audio_languages)2842        if video_obj_from_cloud[:run_time].nil?2843          video_obj_from_cloud.delete(:run_time)2844        else2845          video_obj_from_cloud[:content_runtime_s] = video_obj_from_cloud[:run_time]2846          video_obj_from_cloud.delete(:run_time)2847        end2848        if video_obj_from_cloud[:constraints].nil? or video_obj_from_cloud[:constraints].empty?2849          video_obj_from_cloud.delete(:constraints)2850        end2851        if video_obj_from_cloud[:quality].nil?2852          video_obj_from_cloud.delete(:quality)2853        end2854        if video_obj_from_cloud[:purchase_type] == ""2855          video_obj_from_cloud.delete(:purchase_type)2856        end2857        if video_obj_from_cloud[:source_id] == "hulu"2858          video_obj_from_cloud.delete(:source_program_id)2859        end2860        if video_obj_from_cloud[:fetched_from].nil?2861          rovi_videos_list_got_from_cloud.push(video_obj_from_cloud)2862        elsif video_obj_from_cloud[:fetched_from] == "gracenote"2863          # gn_url = video_obj_from_cloud[:link][:uri]2864          # gracenote_videos_list_got_from_cloud.push(gn_url)2865          gracenote_videos_list_got_from_cloud.push(video_obj_from_cloud)2866        elsif video_obj_from_cloud[:fetched_from] == "hulu"2867          hulu_videos_list_got_from_cloud.push(video_obj_from_cloud)2868        elsif video_obj_from_cloud[:fetched_from] == "vudu"2869          vudu_videos_list_got_from_cloud.push(video_obj_from_cloud)2870        elsif video_obj_from_cloud[:fetched_from] == "crawler"2871          crawler_videos_list_got_from_cloud.push(video_obj_from_cloud)2872        end2873        all_videos_list_got_from_cloud.push(video_obj_from_cloud)2874      end2875    else2876      #$log.info "Inside else, empty cloud response"2877      log.info "Inside else, empty cloud response"2878    end2879    videos_got_from_cloud = {"Rovi Videos"=> rovi_videos_list_got_from_cloud,"Gracenote Videos"=> gracenote_videos_list_got_from_cloud,"Hulu Videos"=> hulu_videos_list_got_from_cloud,"Vudu Videos"=> vudu_videos_list_got_from_cloud,"Crawler Videos"=>crawler_videos_list_got_from_cloud,"All Videos"=> all_videos_list_got_from_cloud}2880     log.info "Videos got from Rovi cloud: #{rovi_videos_list_got_from_cloud}"2881     log.info "Videos got from Gn cloud: #{gracenote_videos_list_got_from_cloud}"2882    #$log.info "Videos got from cloud: #{videos_got_from_cloud}"2883    log.info "Videos got from cloud: #{videos_got_from_cloud}"2884    videos_got_from_cloud2885  end2886 def get_all_ottlinks_from_cloud(prog_id,log)2887    log.info "Ozone Api Spec Functions::get_all_ottlinks_from_cloud"2888    rovi_videos_list_got_from_cloud = Array.new2889    gracenote_videos_list_got_from_cloud = Array.new2890    hulu_videos_list_got_from_cloud = Array.new2891    vudu_videos_list_got_from_cloud = Array.new2892    crawler_videos_list_got_from_cloud = Array.new2893    all_videos_list_got_from_cloud = Array.new2894    videos_got_from_cloud = {"Rovi Videos"=> [],"Gracenote Videos"=> [],"Hulu Videos"=> [],"Vudu Videos"=> [],"Crawler Videos"=>[],"All Videos" => []}2895    2896    get "/programs/#{prog_id}/videos"2897    expect_status('200')2898    #$log.info json_body2899    len = json_body.length2900    if len > 02901      #$log.info "Inside if len > O"2902      log.info "videos count from cloud for the episode: #{json_body.length}"2903 2904      for i in 0..len-12905        video_obj_from_cloud = json_body[i]2906        log.info "video_obj_from_cloud:: #{video_obj_from_cloud}"2907        video_obj_from_cloud.delete(:platform)2908        video_obj_from_cloud.delete(:last_refreshed_timestamp)2909        video_obj_from_cloud.delete(:content_expiry_timestamp)2910        video_obj_from_cloud.delete(:cache_expiry_timestamp)2911        video_obj_from_cloud.delete(:launch_id)2912        video_obj_from_cloud.delete(:created_at)2913        video_obj_from_cloud.delete(:updated_at)2914        video_obj_from_cloud.delete(:refreshed_at)2915        video_obj_from_cloud.delete(:with_subscription)2916        video_obj_from_cloud.delete(:subscription_type)2917        video_obj_from_cloud.delete(:audio_languages)2918        if video_obj_from_cloud[:run_time].nil?2919          video_obj_from_cloud.delete(:run_time)2920        else2921          video_obj_from_cloud[:content_runtime_s] = video_obj_from_cloud[:run_time]2922          video_obj_from_cloud.delete(:run_time)2923        end2924        if video_obj_from_cloud[:constraints].nil? or video_obj_from_cloud[:constraints].empty?2925          video_obj_from_cloud.delete(:constraints)2926        end2927        if video_obj_from_cloud[:quality].nil?2928          video_obj_from_cloud.delete(:quality)2929        end2930        if video_obj_from_cloud[:purchase_type] == ""2931          video_obj_from_cloud.delete(:purchase_type)2932        end2933        if video_obj_from_cloud[:source_id] == "hulu"2934          video_obj_from_cloud.delete(:source_program_id)2935        end2936        if video_obj_from_cloud[:fetched_from].nil?2937          rovi_videos_list_got_from_cloud.push(video_obj_from_cloud)2938        elsif video_obj_from_cloud[:fetched_from] == "gracenote"2939          # gn_url = video_obj_from_cloud[:link][:uri]2940          # gracenote_videos_list_got_from_cloud.push(gn_url)2941          gracenote_videos_list_got_from_cloud.push(video_obj_from_cloud)2942        elsif video_obj_from_cloud[:fetched_from] == "hulu"2943          hulu_videos_list_got_from_cloud.push(video_obj_from_cloud)2944        elsif video_obj_from_cloud[:fetched_from] == "vudu"2945          vudu_videos_list_got_from_cloud.push(video_obj_from_cloud)2946        elsif video_obj_from_cloud[:fetched_from] == "crawler"2947          crawler_videos_list_got_from_cloud.push(video_obj_from_cloud)2948        end...

debriefs_controller_test.rb

Source:debriefs_controller_test.rb

...30    assert_redirected_to debrief_url(@debrief)31  end32  test "should destroy debrief" do33    assert_difference('Debrief.count', -1) do34      delete debrief_url(@debrief)35    end36    assert_redirected_to debriefs_url37  end38end...

base.rb

Source:base.rb

...33  end34  def put(url, put_body = nil, headers = nil)35    @response = make_request(:put, url, body: put_body, headers: headers)36  end37  def delete(url, delete_body = nil, headers = nil)38    @response = make_request(:delete, url, body: delete_body, headers: headers)39  end40  def head(url, headers = nil)41    @response = make_request(:head, url, headers: headers)42  end43  def options(url, headers = nil)44    @response = make_request(:options, url, headers: headers)45  end46  def response47    @response48  end49  def headers50    HashWithIndifferentAccess.new(response.headers)51  end52  def body...

delete

Using AI Code Generation

1    expect_status(204)2    expect_status(204)3    expect_status(204)4    expect_status(204)5    expect_status(204)6    expect_status(204)7    expect_status(204)

delete

Using AI Code Generation

1 expet_sttu(204)2    expe2t_status(204)3/e expet_sttu(204)4exscribta'Dus(20'45 expet_sttu(204)6  expt_sttu(204)7    expect_status(204)8  expt_sttu(204)9  it 'Delete user' doatus(204)10  expt_sttu(204)11  expt_sttu(204)12    expect_status(204)13i expet_sttu(204)14 expet_sttu(204)15u   exp'c _status(204)o

delete

Using AI Code Generation

1   expct_staus(204)2Finihd in0.00757scns(l took 0.26687 seconds to load)3   'oFalure/Er: expt_sttu(204)    delete '/users/2'4  e pto(xpdc: d2eesps tohve tatu end204biw 2005Finihdin0.01749 scns(e dookt0 32353sensloa)6    Falue/Err:expet_sttu(204)7Finibhdin0.01674 scns(eook03215esescnrsbe 'loat)8  1) deleeee '/rusuldxtepehet_jsrowit( id:19i    Fatlu)e/Err:expet_sttu(204)10Finished ine0.01715 secentsh(dflolerooke0'32232 seitn sshodloae)11  1) eelxeet_j_rys(iuldidetxpehet_jsrdwi2) i 112   Falure/Er: expt_sttu(204)  end13    expect_json_types(id: :int)14    expect_json(id: 2)15    expect_json_types(id: :int)16    expect_json(id: 2)17_jsontype(id: :in)18    expect_json_typ(id: :int)19    expect_json(id:22)20  end_jsontype(id: :in)21    expect_status(2)22end_jsontype(id: :in)

delete

Using AI Code Generation

1    expect_status(204)2    expect_status(204)3    expect_status(204)4    expect_status(204)5    expect_status(204)6    expect_status(204)7    expect_status(204)8    expect_status(204)9    expect_status(204)10    expect_status(204)

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.