Class: Cnvrg::Flows

Inherits:
Object
  • Object
show all
Defined in:
lib/cnvrg/flow.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(flow_slug) ⇒ Flows

Returns a new instance of Flows.



3
4
5
6
7
8
9
10
11
12
13
 
# File 'lib/cnvrg/flow.rb', line 3

def initialize(flow_slug)
  @project = Cnvrg::Project.new(Cnvrg::CLI.get_project_home)
  @flow_slug = flow_slug
  @tasks = {}
  @relations = {}
  @title = nil
  @slug = nil
  @base_resource = @project.base_resource + "flows"

  # self.reload_flow
end

Class Method Details

.create_flow(path, flow) ⇒ Object 



15
16
17
 
# File 'lib/cnvrg/flow.rb', line 15

def self.create_flow(path, flow)
  File.open(path, "w"){|file| file.write flow.to_yaml}
end

Instance Method Details

#get_flow ⇒ Object 



19
20
21
22
23
24
 
# File 'lib/cnvrg/flow.rb', line 19

def get_flow
  unless File.exists? @fullpath
    raise StandardError.new("Cant find flow in #{@fullpath}")
  end
  YAML.load_file(@fullpath)
end

#reload_flow ⇒ Object 



36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/cnvrg/flow.rb', line 36

def reload_flow
  flow = self.get_flow
  @title = flow[:title]
  @slug = flow[:slug]
  @relations = flow[:relations]
  local_tasks = flow[:tasks] || {}
  @relations.each do |relation|
    relation.values.each do |task|
      if local_tasks[task].present?
        @tasks[task] = Cnvrg::Task.new(@project.local_path, content: local_tasks[task])
      else
        @tasks[task] = Cnvrg::Task.new(@project.local_path, path: task)
      end
    end
  end
end

#run ⇒ Object 



54
55
56
57
58
59
60
 
# File 'lib/cnvrg/flow.rb', line 54

def run
  resp = Cnvrg::API.request("#{@base_resource}/#{@flow_slug}/run", 'POST')
  if Cnvrg::CLI.is_response_success(resp)
    return resp
  end
  Cnvrg::CLI.log_message("Cant run flow #{@flow_slug}")
end

#set_flow(new_flow) ⇒ Object 



26
27
28
 
# File 'lib/cnvrg/flow.rb', line 26

def set_flow(new_flow)
  File.open(@fullpath, "w"){|file| file.write new_flow.to_yaml}
end

#set_flow_slug(slug) ⇒ Object 



30
31
32
33
34
 
# File 'lib/cnvrg/flow.rb', line 30

def set_flow_slug(slug)
  flow = self.get_flow
  flow[:slug] = slug
  self.set_flow(flow)
end