Class: SlackRubyBotServer::Service

Inherits:
Object
  • Object
show all
Includes:
Loggable
Defined in:
lib/slack-ruby-bot-server/service.rb

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Loggable

included

Constructor Details

#initialize ⇒ Service

Returns a new instance of Service.



16
17
18
19
 
# File 'lib/slack-ruby-bot-server/service.rb', line 16

def initialize
  @callbacks = Hash.new { |h, k| h[k] = [] }
  @intervals = Hash.new { |h, k| h[k] = [] }
end

Class Method Details

.instance ⇒ Object 



12
13
14
 
# File 'lib/slack-ruby-bot-server/service.rb', line 12

def self.instance
  @instance ||= SlackRubyBotServer::Config.service_class.new
end

.reset! ⇒ Object 



102
103
104
 
# File 'lib/slack-ruby-bot-server/service.rb', line 102

def self.reset!
  @instance = nil
end

.start! ⇒ Object 



5
6
7
8
9
10
 
# File 'lib/slack-ruby-bot-server/service.rb', line 5

def self.start!
  Thread.new do
    Thread.current.abort_on_exception = true
    instance.start_from_database!
  end
end

Instance Method Details

#create!(team, options = {}) ⇒ Object 



43
44
45
46
47
 
# File 'lib/slack-ruby-bot-server/service.rb', line 43

def create!(team, options = {})
  run_callbacks :creating, team, nil, options
  start!(team)
  run_callbacks :created, team, nil, options
end

#deactivate!(team) ⇒ Object 



93
94
95
96
97
98
99
100
 
# File 'lib/slack-ruby-bot-server/service.rb', line 93

def deactivate!(team)
  run_callbacks :deactivating, team
  team.deactivate!
  run_callbacks :deactivated, team
rescue StandardError => e
  run_callbacks :error, team, e
  logger.error "#{team.name}: #{e.class}, #{e.message}, ignored."
end

#every(*intervals, &block) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/slack-ruby-bot-server/service.rb', line 27

def every(*intervals, &block)
  Array(intervals).each do |interval|
    case interval
    when :minute
      interval = 60
    when :hour
      interval = 60 * 60
    when :day
      interval = 60 * 60 * 24
    end
    raise "Invalid interval \"#{interval}\"." unless interval.is_a?(Integer) && interval > 0

    @intervals[interval] << block
  end
end

#on(*types, &block) ⇒ Object 



21
22
23
24
25
 
# File 'lib/slack-ruby-bot-server/service.rb', line 21

def on(*types, &block)
  Array(types).each do |type|
    @callbacks[type.to_s] << block
  end
end

#restart!(team) ⇒ Object 



58
59
60
61
62
63
64
65
 
# File 'lib/slack-ruby-bot-server/service.rb', line 58

def restart!(team)
  logger.info "Restarting team #{team}."
  run_callbacks :restarting, team
  run_callbacks :restarted, team
rescue StandardError => e
  run_callbacks :error, team, e
  logger.error e
end

#start!(team) ⇒ Object 



49
50
51
52
53
54
55
56
 
# File 'lib/slack-ruby-bot-server/service.rb', line 49

def start!(team)
  logger.info "Starting team #{team}."
  run_callbacks :starting, team
  run_callbacks :started, team
rescue StandardError => e
  run_callbacks :error, team, e
  logger.error e
end

#start_from_database! ⇒ Object 



76
77
78
79
80
81
82
83
 
# File 'lib/slack-ruby-bot-server/service.rb', line 76

def start_from_database!
  Team.active.each do |team|
    run_callbacks :booting, team
    start!(team)
    run_callbacks :booted, team
  end
  start_intervals!
end

#start_intervals! ⇒ Object 



85
86
87
88
89
90
91
 
# File 'lib/slack-ruby-bot-server/service.rb', line 85

def start_intervals!
  @intervals.each_pair do |period, calls|
    _every period do
      calls.each(&:call)
    end
  end
end

#stop!(team) ⇒ Object 



67
68
69
70
71
72
73
74
 
# File 'lib/slack-ruby-bot-server/service.rb', line 67

def stop!(team)
  logger.info "Stopping team #{team}."
  run_callbacks :stopping, team
  run_callbacks :stopped, team
rescue StandardError => e
  run_callbacks :error, team, e
  logger.error e
end