11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
# File 'lib/architect4r/has_node.rb', line 11
def has_node(attr_name, model_name, options={})
after_create :"architect4r_create_#{attr_name}"
after_update :"architect4r_sync_#{attr_name}"
after_destroy :"architect4r_destroy_#{attr_name}"
define_method("architect4r_create_#{attr_name}") do
return nil unless self.id
new_node = model_name.new
new_node.write_attribute(:architect4r_sync_id, self.id)
options[:sync].to_a.each do |prop|
new_node.send("#{prop}=", self.send(prop))
end
if new_node.save
new_node
else
nil
end
instance_variable_set("@#{attr_name}", new_node)
end
define_method(attr_name) do
return nil unless self.id
the_node = instance_variable_get("@#{attr_name}")
the_node ||= begin
linked_node = model_name.find_by_cypher("start s=node(#{model_name.model_root.id}) match s<-[:model_type]-d where d.architect4r_sync_id = #{self.id} return d", "d").first
linked_node ||= self.send("architect4r_create_#{attr_name}")
instance_variable_set("@#{attr_name}", linked_node)
end
end
define_method("architect4r_destroy_#{attr_name}") do
self.send("#{attr_name}").destroy
end
define_method("architect4r_sync_#{attr_name}") do
changed = false
options[:sync].to_a.each do |prop|
if self.node.send("#{prop}") != self.send(prop)
self.node.send("#{prop}=", self.send(prop))
changed = true
end
end
if changed
self.node.save
end
end
end
|