1
2
3
4
5
6
7
8
9
10
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
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
103
104
105
106
107
108
109
|
#!/usr/local/bin/ruby -w
# $Id$
# our duck type interface -- if your object doesn't match this interface,
# it won't work
# all of our first-class objects (objects, attributes, and components) will
# respond to these methods
# although attributes don't inherit from Blink::Interface
# although maybe Blink::Attribute should...
# the default behaviour that this class provides is to just call a given
# method on each contained object, e.g., in calling 'sync', we just run:
# object.each { |subobj| subobj.sync() }
# to use this interface, just define an 'each' method and 'include Blink::Interface'
module Blink
class Interface
# each subclass of Blink::Interface must create a class-local @objects
# variable
@objects = Hash.new # this one won't be used, since this class is abstract
# this is a bit of a hack, but it'll work for now
attr_accessor :performoperation
#---------------------------------------------------------------
def evaluate
self.retrieve
unless self.insync?
if @performoperation == :sync
self.sync
else
# we, uh, don't do anything
end
end
end
#---------------------------------------------------------------
#---------------------------------------------------------------
# set up the "interface" methods
[:sync,:retrieve].each { |method|
self.send(:define_method,method) {
self.each { |subobj|
Blink.debug("sending '%s' to '%s'" % [method,subobj])
subobj.send(method)
}
}
}
#---------------------------------------------------------------
#---------------------------------------------------------------
# if all contained objects are in sync, then we're in sync
def insync?
insync = true
self.each { |obj|
unless obj.insync?
Blink.debug("%s is not in sync" % obj)
insync = false
end
}
Blink.debug("%s sync status is %s" % [self,insync])
return insync
end
#---------------------------------------------------------------
#---------------------------------------------------------------
# retrieve a named object
def Interface.[](name)
if @objects.has_key?(name)
return @objects[name]
else
raise "Object '#{name}' does not exist"
end
end
#---------------------------------------------------------------
#---------------------------------------------------------------
# this is special, because it can be equivalent to running new
# this allows cool syntax like Blink::File["/etc/inetd.conf"] = ...
def Interface.[]=(name,object)
newobj = nil
if object.is_a?(Blink::Interface)
newobj = object
else
raise "must pass a Blink::Interface object"
end
if @objects.has_key?(newobj.name)
puts @objects
raise "'#{newobj.name}' already exists in " +
"class '#{newobj.class}': #{@objects[newobj.name]}"
else
Blink.debug("adding %s of type %s to class list" %
[object.name,object.class])
@objects[newobj.name] = newobj
end
end
#---------------------------------------------------------------
#---------------------------------------------------------------
def Interface.has_key?(name)
return @objects.has_key?(name)
end
#---------------------------------------------------------------
end
end
|
