Module: Dam

Defined in:
lib/dam.rb,
lib/dam/stream.rb,
lib/dam/storage.rb,
lib/dam/version.rb,
lib/dam/activity.rb

Defined Under Namespace

Classes: Activity, ActivityType, Context, ParamsProxy, Storage, Stream, StreamDefinition, TemplatedStream, TypeProxy

Constant Summary collapse

PLACEHOLDER_PATTERN = 
%r{:[^:@/-]+}
Version = 
"0.3.0"

Class Method Summary collapse

Class Method Details

.activity(name, &block) ⇒ Object 



21
22
23
24
25
 
# File 'lib/dam.rb', line 21

def self.activity(name, &block)
  act = Dam::ActivityType.new(name, &block)
  Dam::ActivityType.register(name, act)
  act
end

.post(type, params = {}) ⇒ Object 



13
14
15
16
17
18
19
 
# File 'lib/dam.rb', line 13

def self.post(type, params = {})
  act = Dam::ActivityType.lookup(type.to_sym).apply(params)

  act.post!
  
  act
end

.push(activity) ⇒ Object 



9
10
11
 
# File 'lib/dam.rb', line 9

def self.push(activity)
  Dam::Storage.insert(activity, Dam::Stream.all.select {|stream| stream.matches? activity })
end

.stream(name, &block) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
 
# File 'lib/dam.rb', line 27

def self.stream(name, &block)
  definition = StreamDefinition.new
  definition.instance_eval(&block)
  
  stream = if Stream.has_placeholder? name
    TemplatedStream.new(name, definition)
  else
    Stream.new(name, definition)
  end
  Dam::Stream.register(name, stream)
end