load r/baseball game threads

Signed-off-by: Steven Hoffman <[email protected]>

config/schedule.rb

@@ -55,6 +55,8 @@ def cli(*command, **kwargs)
 
 every :day do
   cli :game_threads, :load
+  cli :game_threads, :load_r_baseball
+  cli :game_threads, :load_r_albeast
   cli :sync_moderators
 end
 

scripts/cli/flair.rb

@@ -0,0 +1,9 @@
+# frozen_string_literal: true
+
+# Copyright (c) Valencia Management Group
+# All rights reserved.
+
+require_relative 'subcommand'
+
+class Flair < Subcommand
+end

scripts/cli/game_threads.rb

@@ -20,6 +20,20 @@ def load
     puts "Added #{results[:created]}, Updated #{results[:updated]}"
   end
 
+  desc 'load_r_baseball', ''
+  def load_r_baseball
+    require_relative '../load_baseball_game_threads'
+
+    BaseballGameThreadLoader.new.run
+  end
+
+  desc 'load_r_albeast', ''
+  def load_r_albeast
+    require_relative '../load_albeast_game_threads'
+
+    ALEastGameThreadLoader.new.run
+  end
+
   desc 'load_postseason', ''
   def load_postseason
     require_relative '../load_postseason_game_threads'

scripts/load_albeast_game_threads.rb

@@ -33,5 +33,3 @@ def post_at
     @post_at ||= Baseballbot::Utility.adjust_time_proc(db.exec(POST_AT_QUERY)[0]['post_at'])
   end
 end
-
-ALEastGameThreadLoader.new.run

scripts/load_baseball_game_threads.rb

@@ -0,0 +1,28 @@
+# frozen_string_literal: true
+
+require_relative 'game_thread_loader'
+
+# /r/baseball is running a game thread for all games this season... for now.
+class BaseballGameThreadLoader < GameThreadLoader
+  SUBREDDIT_ID = 15
+
+  POST_AT_QUERY = <<~SQL.freeze
+    SELECT options#>>'{game_threads,post_at}' AS post_at
+    FROM subreddits
+    WHERE id = #{SUBREDDIT_ID}
+  SQL
+
+  def initialize
+    super(date: Date.new(Date.today.year, Date.today.month, 1))
+  end
+
+  def add_game(game)
+    starts_at = Time.parse(game['gameDate']) + @utc_offset
+
+    insert_game(SUBREDDIT_ID, game, post_at.call(starts_at), starts_at)
+  end
+
+  def post_at
+    @post_at ||= Baseballbot::Utility.adjust_time_proc(db.exec(POST_AT_QUERY)[0]['post_at'])
+  end
+end