Module: Sequel::Plugins::Bitemporal::InstanceMethods

Defined in:
lib/sequel/plugins/bitemporal.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#pending_version ⇒ Object (readonly)

Returns the value of attribute pending_version.



277
278
279
 
# File 'lib/sequel/plugins/bitemporal.rb', line 277

def pending_version
  @pending_version
end

Instance Method Details

#after_create ⇒ Object 



335
336
337
338
339
340
341
 
# File 'lib/sequel/plugins/bitemporal.rb', line 335

def after_create
  super
  if @create_version
    @create_version = nil
    return false unless save_pending_version
  end
end

#after_save ⇒ Object 



351
352
353
354
 
# File 'lib/sequel/plugins/bitemporal.rb', line 351

def after_save
  super
  _refresh_set_values @values
end

#attributes ⇒ Object 



299
300
301
302
303
304
305
306
307
 
# File 'lib/sequel/plugins/bitemporal.rb', line 299

def attributes
  if pending_version
    pending_version.values
  elsif current_version
    current_version.values
  else
    initial_version.values
  end
end

#attributes=(attributes) ⇒ Object 



309
310
311
312
313
314
315
316
317
318
319
 
# File 'lib/sequel/plugins/bitemporal.rb', line 309

def attributes=(attributes)
  @pending_version ||= begin
    current_attributes = {master_id: id}
    current_version.keys.each do |key|
      next if excluded_columns.include? key
      current_attributes[key] = current_version.send key
    end if current_version?
    model.version_class.new current_attributes
  end
  pending_version.set_all attributes
end

#audited? ⇒ Boolean

Returns:

  • (Boolean) 


279
280
281
 
# File 'lib/sequel/plugins/bitemporal.rb', line 279

def audited?
  !!self.class.audit_class
end

#before_create ⇒ Object 



330
331
332
333
 
# File 'lib/sequel/plugins/bitemporal.rb', line 330

def before_create
  @create_version = pending_version_holds_changes?
  super
end

#before_update ⇒ Object 



343
344
345
346
347
348
349
 
# File 'lib/sequel/plugins/bitemporal.rb', line 343

def before_update
  if pending_version_holds_changes?
    expire_previous_versions
    return false unless save_pending_version
  end
  super
end

#before_validation ⇒ Object 



283
284
285
286
 
# File 'lib/sequel/plugins/bitemporal.rb', line 283

def before_validation
  prepare_pending_version
  super
end

#deleted? ⇒ Boolean

Returns:

  • (Boolean) 


390
391
392
 
# File 'lib/sequel/plugins/bitemporal.rb', line 390

def deleted?
  !new? && !current_version
end

#destroy ⇒ Object 



356
357
358
359
 
# File 'lib/sequel/plugins/bitemporal.rb', line 356

def destroy
  point_in_time = ::Sequel::Plugins::Bitemporal.point_in_time
  versions_dataset.where(expired_at: nil).where("valid_to>valid_from").update expired_at: point_in_time
end

#destroy_version(version, expand_previous_version) ⇒ Object 



361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
 
# File 'lib/sequel/plugins/bitemporal.rb', line 361

def destroy_version(version, expand_previous_version)
  now = ::Sequel::Plugins::Bitemporal.now
  point_in_time = ::Sequel::Plugins::Bitemporal.point_in_time
  return false if version.valid_to.to_datetime<=now
  associations.delete :current_version
  model.db.transaction do
    success = true
    version_was_valid = now>=version.valid_from.to_datetime
    if expand_previous_version
      previous = versions_dataset.where({
        expired_at: nil,
        valid_to: version.valid_from,
      }).where("valid_to>valid_from").first
      if previous
        if version_was_valid
          success &&= save_fossil previous, created_at: point_in_time, valid_from: now, valid_to: version.valid_to
        else
          success &&= save_fossil previous, created_at: point_in_time, valid_to: version.valid_to
          success &&= previous.update expired_at: point_in_time
        end
      end
    end
    success &&= save_fossil version, created_at: point_in_time, valid_to: now if version_was_valid
    success &&= version.update expired_at: point_in_time
    raise Sequel::Rollback unless success
    success
  end
end

#last_version ⇒ Object 



394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
 
# File 'lib/sequel/plugins/bitemporal.rb', line 394

def last_version
  @last_version ||= begin
    return if new?
    t = ::Sequel::Plugins::Bitemporal.point_in_time
    n = ::Sequel::Plugins::Bitemporal.now
    if use_ranges = self.class.use_ranges
      range_conditions = self.class.existence_range_contains t
    end
    versions_dataset.where do
      if use_ranges
        range_conditions
      else
        (created_at <= t) &
        Sequel.|({expired_at=>nil}, expired_at > t)
      end & (valid_from <= n)
    end.order(Sequel.desc(:valid_to), Sequel.desc(:created_at)).first
  end
end

#next_version ⇒ Object 



413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
 
# File 'lib/sequel/plugins/bitemporal.rb', line 413

def next_version
  @next_version ||= begin
    return if new?
    t = ::Sequel::Plugins::Bitemporal.point_in_time
    n = ::Sequel::Plugins::Bitemporal.now
    if use_ranges = self.class.use_ranges
      range_conditions = self.class.existence_range_contains t
    end
    versions_dataset.where do
      if use_ranges
        range_conditions
      else
        (created_at <= t) &
        Sequel.|({expired_at=>nil}, expired_at > t)
      end & (valid_from > n)
    end.order(Sequel.asc(:valid_to), Sequel.desc(:created_at)).first
  end
end

#pending_or_current_version ⇒ Object 



295
296
297
 
# File 'lib/sequel/plugins/bitemporal.rb', line 295

def pending_or_current_version
  pending_version || current_version || initial_version
end

#propagated_during_last_save ⇒ Object 



455
456
457
 
# File 'lib/sequel/plugins/bitemporal.rb', line 455

def propagated_during_last_save
  @propagated_during_last_save ||= []
end

#reload ⇒ Object 



447
448
449
450
451
452
453
 
# File 'lib/sequel/plugins/bitemporal.rb', line 447

def reload
  @last_version = nil
  @current_version_values = nil
  @pending_version = nil
  @initial_version = nil
  super
end

#restore(attrs = {}) ⇒ Object 



432
433
434
435
436
437
438
439
440
441
442
443
444
445
 
# File 'lib/sequel/plugins/bitemporal.rb', line 432

def restore(attrs={})
  return false unless deleted?
  last_version_attributes = if last_version
    last_version.columns.each_with_object({}) do |column, hash|
      unless excluded_columns.include? column
        hash[column] = last_version.send column
      end
    end
  else
    {}
  end
  update_attributes last_version_attributes.merge attrs
  @last_version = nil
end

#update_attributes(attributes = {}) ⇒ Object 



321
322
323
324
325
326
327
328
 
# File 'lib/sequel/plugins/bitemporal.rb', line 321

def update_attributes(attributes={})
  self.attributes = attributes
  if save raise_on_failure: false
    self
  else
    false
  end
end

#validate ⇒ Object 



288
289
290
291
292
293
 
# File 'lib/sequel/plugins/bitemporal.rb', line 288

def validate
  super
  pending_version.errors.each do |key, key_errors|
    key_errors.each{|error| errors.add key, error}
  end if pending_version_holds_changes? && !pending_version.valid?
end