match.rb in sportradar-api-0.13.5

- old
+ new

@@ -4,16 +4,19 @@
       class Match < Data
         attr_reader :id, :league_group, :scheduled, :start_time_tbd, :status, :tournament_round, :match_status, :venue
         attr_reader :home_score, :away_score, :winner_id, :aggregate_home_score, :aggregate_away_score, :aggregate_winner_id
         attr_reader :referee, :weather_info, :coverage_info, :probabilities
         attr_reader :home, :away, :tournament_id
-        attr_reader :clock, :period, :score, :scoring, :broadcast, :coverage # these are for consistency with other sports
+        attr_reader :period, :score, :broadcast, :coverage # these are for consistency with other sports
+        attr_reader :match_time, :stoppage_time
 
         def initialize(data = {}, league_group: nil, **opts)
           @response     = data
           @id           = data['id']
           @api          = opts[:api]
+          @updates      = {}
+          @changes      = {}
 
           @league_group = league_group || data['league_group'] || @api&.league_group
 
           @timeline_hash = {}
           @lineups_hash  = {}
@@ -47,11 +50,10 @@
           end
           if (stats = data.dig('statistics', 'teams'))
             update_teams(stats)
           end
 
-
           @scheduled        = Time.parse(data['scheduled'])         if data['scheduled']
           @start_time_tbd   = data['start_time_tbd']                if data.key?('start_time_tbd')
           @status           = data['status']                        if data['status']
           @match_status     = data['match_status']                  if data['match_status']
           @tournament_round = data['tournament_round']              if data['tournament_round']
@@ -60,37 +62,119 @@
           @referee          = OpenStruct.new(data["referee"])       if data["referee"]
           @coverage_info    = OpenStruct.new(data["coverage_info"]) if data["coverage_info"]
 
           @home_score       = data['home_score']                    if data['home_score']
           @away_score       = data['away_score']                    if data['away_score']
+          @period           = data['period']                        if data['period']
+          @match_time       = data.dig('clock', 'match_time')       if data.dig('clock', 'match_time')
+          @stoppage_time    = data.dig('clock', 'stoppage_time')    if data.dig('clock', 'stoppage_time')
+          @ball_locations   = data['ball_locations']                if data['ball_locations']
           @winner_id        = data['winner_id']                     if data['winner_id']
 
           @aggregate_home_score = data['aggregate_home_score']      if data['aggregate_home_score']
           @aggregate_away_score = data['aggregate_away_score']      if data['aggregate_away_score']
           @aggregate_winner_id  = data['aggregate_winner_id']       if data['aggregate_winner_id']
+          @scoring_raw.update(data, source: opts[:source])
           create_data(@timeline_hash, data['timeline'], klass: Event, api: api)
-          # @season
-          # @tournament
+
           if data['competitors']
             update_teams(data['competitors'])
           end
 
           # parse_nested_data(data)
         end
 
         def title
           [@home, @away].compact.map(&:name).join(' vs ')
         end
+        def scoring
+          @scoring_raw.scores.each { |period, hash| hash[@home.id] = hash['home']; hash[@away.id] = hash['away'] }
+        end
+        def score
+          {@home.id => @home_score, @away.id => @away_score}
+        end
 
+        # status helpers
+        def realtime_state_short
+          if future?
+            'Scheduled' # ??
+          elsif finished?
+            'FT'
+          elsif postponed?
+            'PPD'
+          elsif halftime?
+            'HT'
+          else
+            clock_display
+          end
+        end
+
         def realtime_state
-          
+          if future?
+            'Scheduled'
+          elsif finished?
+            'Final'
+          elsif postponed?
+            'Postponed'
+          elsif halftime?
+            'Halftime'
+          else
+            clock_display
+          end
         end
 
-        def scoring
-          @scoring_raw.scores
+        def halftime?
+          @match_status == "halftime"
         end
 
+        def postponed?
+          'postponed' == status
+        end
+        def unnecessary?
+          'unnecessary' == status
+        end
+        def cancelled?
+          ['unnecessary', 'postponed'].include? status
+        end
+        def future?
+          ['not_started', 'scheduled', 'delayed', 'created', 'time-tbd', 'if-necessary'].include? status
+        end
+        def started?
+          ['live'].include?(@status) || ['halftime', '1st_half', '2nd_half'].include?(@match_status)
+        end
+        def finished?
+          ['complete', 'closed'].include?(@status) || ['ended'].include?(@match_status)
+        end
+        def completed?
+          'complete' == status
+        end
+        def closed?
+          'closed' == status
+        end
+
+        def clock_display
+          if @match_time == '45:00' || @match_time == '90:00' # stoppage time
+            @match_time.split(':').first + ?'
+          else
+            @match_time.split(':').first + ?'
+          end
+        end
+        alias :clock :clock_display
+
+        def match_seconds
+          return nil unless @match_time
+          mm, ss = @match_time.split(':').map(&:to_i)
+          time = mm * 60 + ss
+          if @match_time == '45:00' || @match_time == '90:00' # stoppage time
+            mm, ss = @stoppage_time.split(':').map(&:to_i)
+            stop_time = mm * 60 + ss
+            time += stop_time
+          end
+          time
+        end
+        alias :game_seconds :match_seconds
+
         def update_teams(data)
           home_hash = data.detect { |team_hash| team_hash["qualifier"] == "home" || team_hash["team"] == "home" }
           away_hash = (data - [home_hash]).first
           if home_hash && away_hash
             @home.update(home_hash, match: self)
@@ -212,18 +296,35 @@
         def get_timeline
           data = api.get_data(path_timeline).to_h
           ingest_timeline(data)
         end
         def ingest_timeline(data)
-          update(data)
+          update(data, source: :pbp)
+          check_newness(:pbp, timeline.last&.updated)
+          check_newness(:clock, self.match_seconds.to_s)
           data
         end
         def queue_timeline
           url, headers, options, timeout = api.get_request_info(path_timeline)
           {url: url, headers: headers, params: options, timeout: timeout, callback: method(:ingest_timeline)}
         end
 
+        # tracking updates
+        def remember(key, object)
+          @updates[key] = object&.dup
+        end
+        def not_updated?(key, object)
+          @updates[key] == object
+        end
+        def changed?(key)
+          @changes[key]
+        end
+        def check_newness(key, new_object)
+          @changes[key] = !not_updated?(key, new_object)
+          remember(key, new_object)
+        end
+
       end
     end
   end
 end
 
@@ -237,9 +338,20 @@
 "season"=>{"id"=>"sr:season:42720", "name"=>"Serie A 17/18", "start_date"=>"2017-08-19", "end_date"=>"2018-05-21", "year"=>"17/18", "tournament_id"=>"sr:tournament:23"},
 "tournament"=>{"id"=>"sr:tournament:23", "name"=>"Serie A", "sport"=>{"id"=>"sr:sport:1", "name"=>"Soccer"}, "category"=>{"id"=>"sr:category:31", "name"=>"Italy", "country_code"=>"ITA"}},
 "competitors"=>
  [{"id"=>"sr:competitor:2793", "name"=>"US Sassuolo", "country"=>"Italy", "country_code"=>"ITA", "abbreviation"=>"SAS", "qualifier"=>"home"},
   {"id"=>"sr:competitor:2702", "name"=>"AS Roma", "country"=>"Italy", "country_code"=>"ITA", "abbreviation"=>"ROM", "qualifier"=>"away"}]
+
+"sport_event_status"=>
+ {"status"=>"live",
+  "match_status"=>"1st_half",
+  "home_score"=>1,
+  "away_score"=>0,
+  "period"=>1,
+  "clock"=>{"match_time"=>"19:25"},
+  "clock"=>{"match_time"=>"45:00", "stoppage_time"=>"00:05"}
+  "ball_locations"=>[{"x"=>"95", "y"=>"50", "team"=>"away"}, {"x"=>"80", "y"=>"62", "team"=>"home"}, {"x"=>"82", "y"=>"60", "team"=>"home"}, {"x"=>"79", "y"=>"58", "team"=>"home"}]},
+
 
 
 m = Sportradar::Api::Soccer::Match.new({"id"=>"sr:match:12090446"}, league_group: 'eu')
 res = m.get_summary
 res = m.get_lineups