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
|
#!/usr/bin/env ruby
require 'thor'
require 'net/http'
require 'json'
class MockScheduler
def method_missing(*args)
yield
end
end
def send_event(id, data)
req = Net::HTTP::Post.new("/widgets/#{id}")
req["content-type"] = "application/json"
req.body = JSON.unparse(data.merge(:auth_token => Dashing::CLI.auth_token))
res = Net::HTTP.new('localhost', 3030).start { |http| http.request(req) }
puts "Data Sent to #{id}: #{data}"
end
SCHEDULER = MockScheduler.new
module Dashing
class CLI < Thor
include Thor::Actions
class << self
attr_accessor :auth_token
end
attr_accessor :name
no_tasks do
['widget', 'dashboard', 'job'].each do |type|
define_method "generate_#{type}" do |name|
@name = Thor::Util.snake_case(name)
directory type.to_sym, File.join("#{type}s")
end
end
end
def self.source_root
File.expand_path('../../templates', __FILE__)
end
desc "new PROJECT_NAME", "Sets up ALL THE THINGS needed for your dashboard project."
def new(name)
@name = Thor::Util.snake_case(name)
directory :project, @name
end
desc "generate (widget/dashboard/job) NAME", "Creates a new widget, dashboard, or job."
def generate(type, name)
send("generate_#{type}".to_sym, name)
rescue NoMethodError => e
puts "Invalid generator. Either use widget, dashboard, or job"
end
map "g" => :generate
desc "start", "Starts the server in style!"
method_option :job_path, :desc => "Specify the directory where jobs are stored"
def start(*args)
port_option = args.include?('-p')? '' : ' -p 3030'
args = args.join(" ")
command = "bundle exec thin -R config.ru start #{port_option} #{args}"
command.prepend "export JOB_PATH=#{options[:job_path]}; " if options[:job_path]
system(command)
end
map "s" => :start
desc "job JOB_NAME AUTH_TOKEN(optional)", "Runs the specified job. Make sure to supply your auth token if you have one set."
def job(name, auth_token = "")
Dir[File.join(Dir.pwd, 'lib/**/*.rb')].each {|file| require file }
self.class.auth_token = auth_token
f = File.join(Dir.pwd, "jobs", "#{name}.rb")
require f
end
end
end
Dashing::CLI.start
|
