Class: Device::Notification

Inherits:
Object
  • Object
show all
Defined in:
lib/device/notification.rb

Constant Summary collapse

DEFAULT_TIMEOUT = 
20
DEFAULT_INTERVAL = 
10
DEFAULT_STREAM_TIMEOUT = 
0
DEFAULT_CREATION_INTERVAL = 
3600

Class Attribute Summary collapse

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(timeout = DEFAULT_TIMEOUT, interval = DEFAULT_INTERVAL, stream_timeout = DEFAULT_STREAM_TIMEOUT) ⇒ Notification

Returns a new instance of Notification.



63
64
65
66
67
68
69
 
# File 'lib/device/notification.rb', line 63

def initialize(timeout = DEFAULT_TIMEOUT, interval = DEFAULT_INTERVAL, stream_timeout = DEFAULT_STREAM_TIMEOUT)
  @timeout        = timeout
  @stream_timeout = stream_timeout
  @interval       = interval
  Device::Notification.current = self
  @fiber = create_fiber
end

Class Attribute Details

.callbacks ⇒ Object

Returns the value of attribute callbacks.



10
11
12
 
# File 'lib/device/notification.rb', line 10

def callbacks
  @callbacks
end

.creation_interval ⇒ Object

Returns the value of attribute creation_interval.



10
11
12
 
# File 'lib/device/notification.rb', line 10

def creation_interval
  @creation_interval
end

.current ⇒ Object

Returns the value of attribute current.



10
11
12
 
# File 'lib/device/notification.rb', line 10

def current
  @current
end

.last_creation ⇒ Object

Returns the value of attribute last_creation.



10
11
12
 
# File 'lib/device/notification.rb', line 10

def last_creation
  @last_creation
end

Instance Attribute Details

#fiber ⇒ Object (readonly)

Returns the value of attribute fiber.



16
17
18
 
# File 'lib/device/notification.rb', line 16

def fiber
  @fiber
end

#interval ⇒ Object (readonly)

Returns the value of attribute interval.



16
17
18
 
# File 'lib/device/notification.rb', line 16

def interval
  @interval
end

#last_check ⇒ Object (readonly)

Returns the value of attribute last_check.



16
17
18
 
# File 'lib/device/notification.rb', line 16

def last_check
  @last_check
end

#stream_timeout ⇒ Object (readonly)

Returns the value of attribute stream_timeout.



16
17
18
 
# File 'lib/device/notification.rb', line 16

def stream_timeout
  @stream_timeout
end

#timeout ⇒ Object (readonly)

Returns the value of attribute timeout.



16
17
18
 
# File 'lib/device/notification.rb', line 16

def timeout
  @timeout
end

Class Method Details

.check ⇒ Object 



18
19
20
 
# File 'lib/device/notification.rb', line 18

def self.check
  self.current.check if self.current
end

.config ⇒ Object 



35
36
37
38
39
40
41
 
# File 'lib/device/notification.rb', line 35

def self.config
  self.creation_interval      = Device::Setting.notification_socket_timeout.empty? ? DEFAULT_CREATION_INTERVAL : Device::Setting.notification_socket_timeout.to_i
  notification_timeout        = Device::Setting.notification_timeout.empty? ? DEFAULT_TIMEOUT : Device::Setting.notification_timeout.to_i
  notification_interval       = Device::Setting.notification_interval.empty? ? DEFAULT_INTERVAL : Device::Setting.notification_interval.to_i
  notification_stream_timeout = Device::Setting.notification_stream_timeout.empty? ? DEFAULT_STREAM_TIMEOUT : Device::Setting.notification_stream_timeout.to_i
  [notification_timeout, notification_interval, notification_stream_timeout]
end

.create_fiber?(force = false) ⇒ Boolean

Returns:

  • (Boolean) 


51
52
53
 
# File 'lib/device/notification.rb', line 51

def self.create_fiber?(force = false)
  (! Device::Setting.company_name.empty?) && (! Device::Setting.logical_number.empty?) && (force || self.valid_creation_interval?)
end

.execute(event) ⇒ Object 



22
23
24
25
26
27
28
 
# File 'lib/device/notification.rb', line 22

def self.execute(event)
  calls = self.callbacks[event.callback]
  return unless calls
  [:before, :on, :after].each do |moment|
    calls.each{|callback| callback.call(event, moment)}
  end
end

.schedule(callback) ⇒ Object 



30
31
32
33
 
# File 'lib/device/notification.rb', line 30

def self.schedule(callback)
  self.callbacks[callback.description] ||= []
  self.callbacks[callback.description] << callback
end

.start ⇒ Object 



43
44
45
46
47
48
49
 
# File 'lib/device/notification.rb', line 43

def self.start
  if create_fiber? && Device::Network.connected? == Device::Network::SUCCESS
    unless Device::Notification.current && Device::Notification.current.closed?
      self.new(*self.config)
    end
  end
end

.valid_creation_interval? ⇒ Boolean

Returns:

  • (Boolean) 


55
56
57
58
59
60
61
 
# File 'lib/device/notification.rb', line 55

def self.valid_creation_interval?
  if @last_creation
    (@last_creation + self.creation_interval) < Time.now
  else
    true
  end
end

Instance Method Details

#check ⇒ Object

Check if there is any notification



72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
 
# File 'lib/device/notification.rb', line 72

def check
  # TODO check if should execute this(because of connection exception)
  if valid_check_interval? && Device::Network.connected? == Device::Network::SUCCESS
    if @fiber.alive?
      if (notification = @fiber.resume)
        Notification.execute(NotificationEvent.new(notification))
      end
    else
      if Device::Notification.create_fiber?(true)
        self.close
        @fiber = create_fiber
      end
    end
    @last_check = Time.now
  end
end

#close ⇒ Object

Close socket and finish Fiber execution



90
91
92
93
94
95
96
 
# File 'lib/device/notification.rb', line 90

def close
  if closed?
    true
  else
    ! @fiber.resume "close"
  end
end

#closed? ⇒ Boolean

Returns:

  • (Boolean) 


98
99
100
 
# File 'lib/device/notification.rb', line 98

def closed?
  ! @fiber.alive?
end

#valid_check_interval? ⇒ Boolean

Returns:

  • (Boolean) 


102
103
104
105
106
107
108
 
# File 'lib/device/notification.rb', line 102

def valid_check_interval?
  if @last_check
    (@last_check + self.interval) < Time.now
  else
    true
  end
end