Class: Cellect::Server::Adapters::Default

Inherits:
Object
  • Object
show all
Defined in:
lib/cellect/server/adapters/default.rb

Direct Known Subclasses

Postgres

Instance Method Summary collapse

Instance Method Details

#load_data_for(workflow_name) ⇒ Object

Load the data for a workflow, this method:

Accepts a workflow
Returns an array of hashes in the form:
{
  'id' => 123,
  'priority' => 0.123,
  'group_id' => 456
}

Raises:

  • (NotImplementedError) 


25
26
27
 
# File 'lib/cellect/server/adapters/default.rb', line 25

def load_data_for(workflow_name)
  raise NotImplementedError
end

#load_user(workflow_name, id) ⇒ Object

Load seen ids for a user, this method:

Accepts a workflow_name, and a user id
Returns an array in the form:
[1, 2, 3]

Raises:

  • (NotImplementedError) 


33
34
35
 
# File 'lib/cellect/server/adapters/default.rb', line 33

def load_user(workflow_name, id)
  raise NotImplementedError
end

#load_workflow(args) ⇒ Object 



41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/cellect/server/adapters/default.rb', line 41

def load_workflow(args)
  info = if args.is_a?(Hash)
    args
  elsif args.is_a?(String)
    workflow_list.select{ |h| h['name'] == args }.first
  else
    raise ArgumentError
  end
  
  workflow_for info
end

#load_workflows ⇒ Object 



37
38
39
 
# File 'lib/cellect/server/adapters/default.rb', line 37

def load_workflows
  workflow_list.each{ |workflow_info| load_workflow workflow_info }
end

#workflow_for(opts = { }) ⇒ Object 



53
54
55
56
 
# File 'lib/cellect/server/adapters/default.rb', line 53

def workflow_for(opts = { })
  workflow_klass = opts.fetch('grouped', false) ? GroupedWorkflow : Workflow
  workflow_klass[opts['name'], pairwise: opts['pairwise'], prioritized: opts['prioritized']]
end

#workflow_list ⇒ Object

Return a list of workflows to load in the form:

[{
  'id' => 123,
  'name' => 'foo',
  'prioritized' => false,
  'pairwise' => false,
  'grouped' => false
}, ...]

Raises:

  • (NotImplementedError) 


13
14
15
 
# File 'lib/cellect/server/adapters/default.rb', line 13

def workflow_list
  raise NotImplementedError
end