Module: Taskinator::Persistence
- Included in:
- Process, Task
- Defined in:
- lib/taskinator/persistence.rb
Defined Under Namespace
Modules: ClassMethods, InstanceMethods
Classes: LazyLoader, RedisCleanupVisitor, RedisDeserializationVisitor, RedisSerializationVisitor, XmlSerializationVisitor
Class Method Summary
collapse
Class Method Details
.add_process_to_list(process) ⇒ Object
9
10
11
12
13
|
# File 'lib/taskinator/persistence.rb', line 9
def add_process_to_list(process)
Taskinator.redis do |conn|
conn.sadd processes_list_key(process.scope), process.uuid
end
end
|
.deserialize(yaml) ⇒ Object
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
|
# File 'lib/taskinator/persistence.rb', line 656
def deserialize(yaml)
values = YAML.load(yaml)
if values.is_a?(Array)
values = values.collect {|value|
(value.respond_to?(:model_id) && value.respond_to?(:find)) ? value.find : value
}
elsif values.is_a?(Hash)
values.each {|key, value|
values[key] = value.find if value.respond_to?(:model_id) && value.respond_to?(:find)
}
elsif values.respond_to?(:model_id) && values.respond_to?(:find)
values = values.find
end
values
end
|
.included(klass) ⇒ Object
17
18
19
20
21
22
|
# File 'lib/taskinator/persistence.rb', line 17
def self.included(klass)
klass.class_eval do
extend ClassMethods
include InstanceMethods
end
end
|
.processes_list_key(scope = :shared) ⇒ Object
5
6
7
|
# File 'lib/taskinator/persistence.rb', line 5
def processes_list_key(scope=:shared)
"taskinator:#{scope}:processes"
end
|
.serialize(values) ⇒ Object
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
|
# File 'lib/taskinator/persistence.rb', line 640
def serialize(values)
if values.is_a?(Array)
values = values.collect {|value|
value.respond_to?(:to_global_id) ? value.to_global_id : value
}
elsif values.is_a?(Hash)
values.each {|key, value|
values[key] = value.to_global_id if value.respond_to?(:to_global_id)
}
elsif values.respond_to?(:to_global_id)
values = values.to_global_id
end
YAML.dump(values)
end
|