Class: SlackRubyBotServer::Service

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

Class Method Summary collapse

Instance Method Summary collapse

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 



111
112
113
 
# File 'lib/slack-ruby-bot-server/service.rb', line 111

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 



97
98
99
100
101
102
103
104
105
106
107
108
109
 
# File 'lib/slack-ruby-bot-server/service.rb', line 97

def deactivate!(team)
  run_callbacks :deactivating, team
  team.deactivate!
  run_callbacks :deactivated, team
rescue Mongoid::Errors::Validations => e
  run_callbacks :error, team, e
  logger.error "#{team.name}: #{e.message}, error - #{e.document.class}, #{e.document.errors.to_hash}, ignored."
rescue StandardError => e
  run_callbacks :error, team, e
  logger.error "#{team.name}: #{e.class}, #{e.message}, ignored."
ensure
  team.server = nil
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, server, wait = 1) ⇒ Object 



62
63
64
65
66
 
# File 'lib/slack-ruby-bot-server/service.rb', line 62

def restart!(team, server, wait = 1)
  run_callbacks :restarting, team
  start_server! team, server, wait
  run_callbacks :restarted, team
end

#start!(team) ⇒ Object 



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

def start!(team)
  run_callbacks :starting, team
  logger.info "Starting team #{team}."
  options = { team: team }
  server = SlackRubyBotServer::Config.server_class.new(options)
  start_server! team, server
  run_callbacks :started, team
  server
rescue StandardError => e
  run_callbacks :error, team, e
  logger.error e
end

#start_from_database! ⇒ Object 



80
81
82
83
84
85
86
87
 
# File 'lib/slack-ruby-bot-server/service.rb', line 80

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 



89
90
91
92
93
94
95
 
# File 'lib/slack-ruby-bot-server/service.rb', line 89

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

#stop!(team) ⇒ Object 



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

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