Class: SportDb::EventReader
- Inherits:
-
Object
- Object
- SportDb::EventReader
- Includes:
- LogUtils::Logging, Models
- Defined in:
- lib/sportdb/readers/event.rb
Instance Attribute Summary collapse
-
#event ⇒ Object
readonly
returns event record; call read first.
-
#fixtures ⇒ Object
readonly
fixtures/sources entry from event config.
Class Method Summary collapse
- .from_file(path, more_attribs = {}) ⇒ Object
- .from_string(text, config, more_attribs = {}) ⇒ Object
- .from_zip(zip_file, entry_path, more_attribs = {}) ⇒ Object
Instance Method Summary collapse
-
#initialize(text, config, more_attribs = {}) ⇒ EventReader
constructor
A new instance of EventReader.
- #read ⇒ Object
Constructor Details
#initialize(text, config, more_attribs = {}) ⇒ EventReader
Returns a new instance of EventReader.
43 44 45 46 47 48 49 50 51 52 53 |
# File 'lib/sportdb/readers/event.rb', line 43 def initialize( text, config, more_attribs={} ) ## todo/fix: how to add opts={} ??? @text = text @more_attribs = more_attribs @config = config # name of event configuration (relative basename w/o path or string) @sources_default = config # note: use same a config for now @event = nil @fixtures = [] end |
Instance Attribute Details
#event ⇒ Object (readonly)
returns event record; call read first
14 15 16 |
# File 'lib/sportdb/readers/event.rb', line 14 def event @event end |
#fixtures ⇒ Object (readonly)
fixtures/sources entry from event config
15 16 17 |
# File 'lib/sportdb/readers/event.rb', line 15 def fixtures @fixtures end |
Class Method Details
.from_file(path, more_attribs = {}) ⇒ Object
29 30 31 32 33 34 35 36 37 |
# File 'lib/sportdb/readers/event.rb', line 29 def self.from_file( path, more_attribs={} ) ## note: assume/enfore utf-8 encoding (with or without BOM - byte order mark) ## - see textutils/utils.rb text = File.read_utf8( path ) config = File.basename( name ) # name a of .yml file self.from_string( text, config, more_attribs ) end |
.from_string(text, config, more_attribs = {}) ⇒ Object
39 40 41 |
# File 'lib/sportdb/readers/event.rb', line 39 def self.from_string( text, config, more_attribs={} ) EventReader.new( text, config, more_attribs ) end |
.from_zip(zip_file, entry_path, more_attribs = {}) ⇒ Object
17 18 19 20 21 22 23 24 25 26 27 |
# File 'lib/sportdb/readers/event.rb', line 17 def self.from_zip( zip_file, entry_path, more_attribs={} ) ## get text content from zip entry = zip_file.find_entry( entry_path ) text = entry.get_input_stream().read() text = text.force_encoding( Encoding::UTF_8 ) config = File.basename( entry_path ) # name a of .yml file self.from_string( text, config, more_attribs ) end |
Instance Method Details
#read ⇒ Object
56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 |
# File 'lib/sportdb/readers/event.rb', line 56 def read @fixtures = [] # reset cached fixtures @event = nil # reset cached event rec #### ## fix!!!!! ## use Event.create_or_update_from_hash or similar ## use Event.create_or_update_from_hash_reader?? or similar # move parsing code to model reader = HashReader.from_string( @text ) event_attribs = {} ## set default sources to basename by convention # e.g 2013_14/bl => bl # etc. # use fixtures/sources: to override default event_attribs[ 'sources' ] = @sources_default event_attribs[ 'config' ] = @config # name a of .yml file reader.each_typed do |key, value| ## puts "processing event attrib >>#{key}<< >>#{value}<<..." if key == 'league' league = League.find_by_key( value.to_s.strip ) ## check if it exists if league.present? event_attribs['league_id'] = league.id else logger.error "league with key >>#{value.to_s.strip}<< missing" exit 1 end elsif key == 'season' season = Season.find_by_key( value.to_s.strip ) ## check if it exists if season.present? event_attribs['season_id'] = season.id else logger.error "season with key >>#{value.to_s.strip}<< missing" exit 1 end elsif key == 'start_at' || key == 'begin_at' if value.is_a?(DateTime) || value.is_a?(Date) start_at = value else # assume it's a string start_at = DateTime.strptime( value.to_s.strip, '%Y-%m-%d' ) end event_attribs['start_at'] = start_at elsif key == 'end_at' || key == 'stop_at' if value.is_a?(DateTime) || value.is_a?(Date) end_at = value else # assume it's a string end_at = DateTime.strptime( value.to_s.strip, '%Y-%m-%d' ) end event_attribs['end_at'] = end_at elsif key == 'grounds' || key == 'stadiums' || key == 'venues' ## assume grounds value is an array ## ## note: for now we allow invalid ground keys ## will skip keys not found ground_ids = [] value.each do |item| ground_key = item.to_s.strip ground = Ground.find_by_key( ground_key ) if ground.nil? puts "[warn] ground/stadium w/ key >#{ground_key}< not found; skipping ground" else ground_ids << ground.id end end event_attribs['ground_ids'] = ground_ids elsif key == 'team3' ## note: check before teams (to avoid future gotchas) ## for now always assume false # todo: fix - use value and convert to boolean if not boolean event_attribs['team3'] = false elsif key == 'teams' || key.downcase =~ /teams/ ## assume teams value is an array ### check if key includes number of teams; if yes - use for checksum/assert if key =~ /(\d+)/ if value.size != $1.to_i puts "[fatal] event reader - team key - expecting #{$1.to_i} teams; got #{value.size}" exit 1 end end team_ids = [] value.each do |item| team_key = item.to_s.strip ## check if team_key includes uppercase letters if team_key =~ /[A-Z]/ ## assume team name (NOT team key); try to lookup team key in database ## todo/fix: ## remove subtitle from title e.g. everything in () ## SV Oberwart (RL Ost) => SV Oberwart team = Team.find_by( title: team_key ) if team.nil? ## next try synonyms team = Team.where( "synonyms LIKE ?", "%#{team_key}%" ).first end else ## assume "verbatim/literal" team_key (use as is 1:1) team = Team.find_by( key: team_key ) end if team.nil? ### print better error message than just ## *** error: Couldn't find SportDb::Model::Team puts "[fatal] event reader - team keys: #{value.inspect}" puts "[fatal] event reader - record for team key >#{team_key}< not found" exit 1 ### fix/todo: throw exception/error end team_ids << team.id end event_attribs['team_ids'] = team_ids elsif key == 'fixtures' || key == 'sources' ### todo: check for mulitiple fixtures/sources ?? allow disallow?? why? why not? if value.kind_of?(Array) event_attribs['sources'] = value.join(',') @fixtures += value else # assume plain (single fixture) string event_attribs['sources'] = value.to_s @fixtures << value.to_s end else ## todo: add a source location struct to_s or similar (file, line, col) logger.error "unknown event attrib #{key}; skipping attrib" end end # each key,value league_id = event_attribs['league_id'] season_id = event_attribs['season_id'] logger.debug "find event - league_id: #{league_id}, season_id: #{season_id}" event = Event.find_by_league_id_and_season_id( league_id, season_id ) ## check if it exists if event.present? logger.debug "*** update event #{event.id}-#{event.key}:" else logger.debug "*** create event:" event = Event.new end logger.debug event_attribs.to_json event.update_attributes!( event_attribs ) # keep a cached reference for later use @event = event end |