Class: OpenC3::ScriptStatusModel

Inherits:
Model show all
Defined in:
lib/openc3/models/script_status_model.rb

Constant Summary collapse

RUNNING_PRIMARY_KEY =

Note: ScriptRunner only has permissions for keys that start with running-script

'running-script'
COMPLETED_PRIMARY_KEY = 
'running-script-completed'

Instance Attribute Summary collapse

Attributes inherited from Model

#name, #plugin, #scope, #updated_at

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Model

#check_disable_erb, #deploy, #destroyed?, filter, find_all_by_plugin, from_json, get_all_models, get_model, handle_config, set, store, store_queued, #undeploy

Constructor Details

#initialize(name:, state:, shard: 0, filename:, current_filename: nil, line_no: 0, start_line_no: 1, end_line_no: nil, username:, user_full_name:, start_time:, end_time: nil, disconnect: false, environment: nil, suite_runner: nil, errors: nil, pid: nil, log: nil, report: nil, updated_at: nil, scope:) ⇒ ScriptStatusModel

Returns a new instance of ScriptStatusModel.



112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
 
# File 'lib/openc3/models/script_status_model.rb', line 112

def initialize(
  name:, # id
  state:, # spawning, init, running, paused, waiting, error, breakpoint, crashed, stopped, completed, completed_errors, killed
  shard: 0, # Future enhancement of script runner shards
  filename:, # The initial filename
  current_filename: nil, # The current filename
  line_no: 0, # The current line number
  start_line_no: 1, # The line number to start the script at
  end_line_no: nil, # The line number to end the script at
  username:, # The username of the person who started the script
  user_full_name:, # The full name of the person who started the script
  start_time:, # The time the script started ISO format
  end_time: nil, # The time the script ended ISO format
  disconnect: false,
  environment: nil,
  suite_runner: nil,
  errors: nil,
  pid: nil,
  log: nil,
  report: nil,
  updated_at: nil,
  scope:
)
  @state = state
  if is_complete?()
    super("#{COMPLETED_PRIMARY_KEY}__#{scope}", name: name, updated_at: updated_at, plugin: nil, scope: scope)
  else
    super("#{RUNNING_PRIMARY_KEY}__#{scope}", name: name, updated_at: updated_at, plugin: nil, scope: scope)
  end
  @shard = shard.to_i
  @filename = filename
  @current_filename = current_filename
  @line_no = line_no
  @start_line_no = start_line_no
  @end_line_no = end_line_no
  @username = username
  @user_full_name = user_full_name
  @start_time = start_time
  @end_time = end_time
  @disconnect = disconnect
  @environment = environment
  @suite_runner = suite_runner
  @errors = errors
  @pid = pid
  @log = log
  @report = report
end

Instance Attribute Details

#current_filename ⇒ Object

Returns the value of attribute current_filename.



33
34
35
 
# File 'lib/openc3/models/script_status_model.rb', line 33

def current_filename
  @current_filename
end

#disconnect ⇒ Object

Returns the value of attribute disconnect.



41
42
43
 
# File 'lib/openc3/models/script_status_model.rb', line 41

def disconnect
  @disconnect
end

#end_line_no ⇒ Object

Returns the value of attribute end_line_no.



36
37
38
 
# File 'lib/openc3/models/script_status_model.rb', line 36

def end_line_no
  @end_line_no
end

#end_time ⇒ Object

Returns the value of attribute end_time.



40
41
42
 
# File 'lib/openc3/models/script_status_model.rb', line 40

def end_time
  @end_time
end

#environment ⇒ Object

Returns the value of attribute environment.



42
43
44
 
# File 'lib/openc3/models/script_status_model.rb', line 42

def environment
  @environment
end

#errors ⇒ Object

Returns the value of attribute errors.



44
45
46
 
# File 'lib/openc3/models/script_status_model.rb', line 44

def errors
  @errors
end

#filename ⇒ Object

Returns the value of attribute filename.



32
33
34
 
# File 'lib/openc3/models/script_status_model.rb', line 32

def filename
  @filename
end

#line_no ⇒ Object

Returns the value of attribute line_no.



34
35
36
 
# File 'lib/openc3/models/script_status_model.rb', line 34

def line_no
  @line_no
end

#log ⇒ Object

Returns the value of attribute log.



46
47
48
 
# File 'lib/openc3/models/script_status_model.rb', line 46

def log
  @log
end

#pid ⇒ Object

Returns the value of attribute pid.



45
46
47
 
# File 'lib/openc3/models/script_status_model.rb', line 45

def pid
  @pid
end

#report ⇒ Object

Returns the value of attribute report.



47
48
49
 
# File 'lib/openc3/models/script_status_model.rb', line 47

def report
  @report
end

#shard ⇒ Object

Returns the value of attribute shard.



31
32
33
 
# File 'lib/openc3/models/script_status_model.rb', line 31

def shard
  @shard
end

#start_line_no ⇒ Object

Returns the value of attribute start_line_no.



35
36
37
 
# File 'lib/openc3/models/script_status_model.rb', line 35

def start_line_no
  @start_line_no
end

#start_time ⇒ Object

Returns the value of attribute start_time.



39
40
41
 
# File 'lib/openc3/models/script_status_model.rb', line 39

def start_time
  @start_time
end

#state ⇒ Object

spawning, init, running, paused, waiting, breakpoint, error, crashed, stopped, completed, completed_errors, killed



30
31
32
 
# File 'lib/openc3/models/script_status_model.rb', line 30

def state
  @state
end

#suite_runner ⇒ Object

Returns the value of attribute suite_runner.



43
44
45
 
# File 'lib/openc3/models/script_status_model.rb', line 43

def suite_runner
  @suite_runner
end

#user_full_name ⇒ Object

Returns the value of attribute user_full_name.



38
39
40
 
# File 'lib/openc3/models/script_status_model.rb', line 38

def user_full_name
  @user_full_name
end

#username ⇒ Object

Returns the value of attribute username.



37
38
39
 
# File 'lib/openc3/models/script_status_model.rb', line 37

def username
  @username
end

Class Method Details

.all(scope:, offset: 0, limit: 10, type: "running") ⇒ Object 



68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
 
# File 'lib/openc3/models/script_status_model.rb', line 68

def self.all(scope:, offset: 0, limit: 10, type: "running")
  if type == "running"
    keys = self.store.zrevrange("#{RUNNING_PRIMARY_KEY}__#{scope}__LIST", offset.to_i, offset.to_i + limit.to_i - 1)
    return [] if keys.empty?
    result = self.store.redis_pool.pipelined do
      keys.each do |key|
        self.store.hget("#{RUNNING_PRIMARY_KEY}__#{scope}", key)
      end
    end
    result = result.map do |r|
      if r.nil?
        nil
      else
        JSON.parse(r, :allow_nan => true, :create_additions => true)
      end
    end
    return result
  else
    keys = self.store.zrevrange("#{COMPLETED_PRIMARY_KEY}__#{scope}__LIST", offset.to_i, offset.to_i + limit.to_i - 1)
    return [] if keys.empty?
    result = self.store.redis_pool.pipelined do
      keys.each do |key|
        self.store.hget("#{COMPLETED_PRIMARY_KEY}__#{scope}", key)
      end
    end
    result = result.map do |r|
      if r.nil?
        nil
      else
        JSON.parse(r, :allow_nan => true, :create_additions => true)
      end
    end
    return result
  end
end

.count(scope:, type: "running") ⇒ Object 



104
105
106
107
108
109
110
 
# File 'lib/openc3/models/script_status_model.rb', line 104

def self.count(scope:, type: "running")
  if type == "running"
    return self.store.zcount("#{RUNNING_PRIMARY_KEY}__#{scope}__LIST", 0, Float::INFINITY)
  else
    return self.store.zcount("#{COMPLETED_PRIMARY_KEY}__#{scope}__LIST", 0, Float::INFINITY)
  end
end

.get(name:, scope:, type: "auto") ⇒ Object

NOTE: The following three class methods are used by the ModelController and are reimplemented to enable various Model class methods to work



51
52
53
54
55
56
57
58
 
# File 'lib/openc3/models/script_status_model.rb', line 51

def self.get(name:, scope:, type: "auto")
  if type == "auto" or type == "running"
    # Check for running first
    running = super("#{RUNNING_PRIMARY_KEY}__#{scope}", name: name)
    return running if running
  end
  return super("#{COMPLETED_PRIMARY_KEY}__#{scope}", name: name)
end

.names(scope:, type: "running") ⇒ Object 



60
61
62
63
64
65
66
 
# File 'lib/openc3/models/script_status_model.rb', line 60

def self.names(scope:, type: "running")
  if type == "running"
    return super("#{RUNNING_PRIMARY_KEY}__#{scope}")
  else
    return super("#{COMPLETED_PRIMARY_KEY}__#{scope}")
  end
end

Instance Method Details

#as_json(*a) ⇒ Object 



216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
 
# File 'lib/openc3/models/script_status_model.rb', line 216

def as_json(*a)
  {
    'name' => @name,
    'state' => @state,
    'shard' => @shard,
    'filename' => @filename,
    'current_filename' => @current_filename,
    'line_no' => @line_no,
    'start_line_no' => @start_line_no,
    'end_line_no' => @end_line_no,
    'username' => @username,
    'user_full_name' => @user_full_name,
    'start_time' => @start_time,
    'end_time' => @end_time,
    'disconnect' => @disconnect,
    'environment' => @environment,
    'suite_runner' => @suite_runner,
    'errors' => @errors,
    'pid' => @pid,
    'log' => @log,
    'report' => @report,
    'updated_at' => @updated_at,
    'scope' => @scope
  }
end

#create(update: false, force: false, queued: false, isoformat: true) ⇒ Object

Update the Redis hash at primary_key and set the field “name” to the JSON generated via calling as_json



178
179
180
181
182
183
184
185
186
187
188
189
190
 
# File 'lib/openc3/models/script_status_model.rb', line 178

def create(update: false, force: false, queued: false, isoformat: true)
  @updated_at = Time.now.utc.to_nsec_from_epoch

  if queued
    write_store = self.class.store_queued
  else
    write_store = self.class.store
  end
  write_store.hset(@primary_key, @name, JSON.generate(self.as_json(:allow_nan => true), :allow_nan => true))

  # Also add to ordered set on create
  write_store.zadd(@primary_key + "__LIST", @name.to_i, @name) if not update
end

#destroy ⇒ Object

Delete the model from the Store



208
209
210
211
212
213
214
 
# File 'lib/openc3/models/script_status_model.rb', line 208

def destroy
  @destroyed = true
  undeploy()
  self.class.store.hdel(@primary_key, @name)
  # Also remove from ordered set
  self.class.store.zremrangebyscore(@primary_key + "__LIST", @name.to_i, @name.to_i)
end

#id ⇒ Object 



27
28
29
 
# File 'lib/openc3/models/script_status_model.rb', line 27

def id
  return @name
end

#is_complete? ⇒ Boolean

Returns:

  • (Boolean) 


160
161
162
 
# File 'lib/openc3/models/script_status_model.rb', line 160

def is_complete?
  return (@state == 'completed' or @state == 'completed_errors' or @state == 'stopped' or @state == 'crashed' or @state == 'killed')
end

#update(force: false, queued: false) ⇒ Object 



192
193
194
195
196
197
198
199
200
201
202
203
204
205
 
# File 'lib/openc3/models/script_status_model.rb', line 192

def update(force: false, queued: false)
  # Magically handle the change from running to completed
  if is_complete?() and @primary_key == "#{RUNNING_PRIMARY_KEY}__#{@scope}"
    # Destroy the running key
    destroy()
    @destroyed = false

    # Move to completed
    @primary_key = "#{COMPLETED_PRIMARY_KEY}__#{@scope}"
    create(update: false, force: force, queued: queued, isoformat: true)
  else
    create(update: true, force: force, queued: queued, isoformat: true)
  end
end