clock_manager.rb

require_relative './extracted_tweets'
require_relative './local_config'
require 'clockwork'
include Clockwork

class ClockManager

  @key      = ""
  @tag      = ""
  @csv_path = ""
  @start_time_list
  @extracted_tweets

  # |||||||||||||||||||||||||||||||||||||||||||||||||||||||||
  # TWEET_GET_NUM = 100    # 一度の検索で取得するツイート数
  # SLEEP_TIME    = 10     # 検索後の待機時間 (秒)
  # |||||||||||||||||||||||||||||||||||||||||||||||||||||||||

  def initialize(key , tag, startTimeList, csv_path)
    @key             = key
    @tag             = tag
    @start_time_list = startTimeList
    @csv_path        = csv_path
  end
  
  def setClock()
    # 動作
    handler do |job|
      case job
        when "extracted.job"
          
          abs_rootpath = File.expand_path("." + @csv_path, __FILE__) + "/"
          puts "abs_rootpath : " + abs_rootpath

          # @extracted_tweets.getTweetAll(@key, TWEET_GET_NUM, SLEEP_TIME, @tag, @csv_path) # ツイート収集開始
          # @extracted_tweets.getTweetAll(@key, TWEET_GET_NUM, SLEEP_TIME, @tag, abs_rootpath) # ツイート収集開始
          @extracted_tweets.getTweetAll(@key, 100, 10, @tag, abs_rootpath) # ツイート収集開始

          # test = File.expand_path(@csv_path)
          # test = File.expand_path(@csv_path, __FILE__)

          # root = File.expand_path(__FILE__)
          # root.sub!($0, "")
          # path = File.expand_path(@csv_path, root)


          
      end
    end

    # configure do |config|
    #   config[:max_threads] = 1
    # end

    @extracted_tweets = ExtractedTweets.new()

    # ----------------------------------------------- #
    # テスト用（インターバルによるジョブ発火）
    #
    
    # every(10.seconds, 'extracted.job', :thread => true) # ジョブの登録 (マルチスレッド対応)
    # every(1.day, 'extracted.job', :thread => true) # ジョブの登録 (マルチスレッド対応)


    # ----------------------------------------------- #
    # 本番（時間指定によるジョブ発火）
    #

    every(1.day, 'extracted.job', :at => @start_time_list, :thread => true) # ジョブの登録 (マルチスレッド対応)   


    # error_handler do |error|
    #   Airbrake.notify_or_ignore(error)
    # end

    
    
  end
end