Initial version. 0.1.0 Release

Author: pushmatrix

.gitignore

@@ -0,0 +1 @@
+*DS_STORE

README.md

@@ -1,2 +1,13 @@
-allthethings
-============
+TODO
+====
+
+- fix textfield style
+- tests
+- Create a better readme!
+- Add data fetching capabilities
+- Turn into its own gem
+- Come up with a default style
+- Create example widgets
+- investigate if Dir.pwd is the best approach to get the local directory
+- Create githubpages
+- Open source!

bin/att

@@ -0,0 +1,66 @@
+#!/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 => AllTheThings::CLI.auth_token))
+  res = Net::HTTP.new('localhost', 3000).start { |http| http.request(req) }
+  puts "Data Sent to #{id}: #{data}"
+end
+
+SCHEDULER = MockScheduler.new
+
+module AllTheThings
+
+  class CLI < Thor
+    include Thor::Actions
+
+    class << self
+      attr_accessor :auth_token
+    end
+
+    attr_accessor :name
+
+    def self.source_root
+      File.expand_path('../../templates', __FILE__)
+    end
+
+    desc "install PROJECT_NAME", "Sets up ALL THE THINGS needed for your dashboard project structure."
+    def install(name)
+      @name = Thor::Util.snake_case(name)
+      directory :project, @name
+    end
+
+    desc "new_widget WIDGET_NAME", "Creates a new widget with all the fixins'"
+    def new_widget(name)
+      @name = Thor::Util.snake_case(name)
+      directory :widget, File.join('widgets', @name)
+    end 
+
+    desc "start", "Starts the server in style!"
+    def start(*args)
+      args = args.join(" ")
+      system("bundle exec thin -R config.ru start #{args}")
+    end
+
+    desc "job JOB_NAME AUTH_TOKEN(optional)", "Runs the specified job."
+    def job(name, auth_token = "")
+      self.class.auth_token = auth_token
+      f = File.join(Dir.pwd, "jobs", "#{name}.rb")
+      require f
+    end
+  
+  end
+end
+
+AllTheThings::CLI.start

lib/allthethings.rb

@@ -0,0 +1,119 @@
+require 'sinatra'
+require 'sinatra/content_for'
+require 'rufus/scheduler'
+require 'coffee-script'
+require 'sass'
+require 'json'
+
+Dir[File.join(Dir.pwd, 'lib/**/*.rb')].each {|file| require file }
+
+SCHEDULER = Rufus::Scheduler.start_new
+
+set server: 'thin', connections: [], history: {}
+helpers Sinatra::ContentFor
+
+def configure(&block)
+  set :public_folder, Dir.pwd + '/public'
+  set :views, Dir.pwd + '/dashboards'
+  set :default_dashboard, nil
+  instance_eval(&block)
+end
+
+get '/events', provides: 'text/event-stream' do
+  stream :keep_open do |out|
+    settings.connections << out
+    out << latest_events
+    out.callback { settings.connections.delete(out) }
+  end
+end
+
+get '/' do
+  begin
+  redirect "/" + (settings.default_dashboard || first_dashboard).to_s
+  rescue NoMethodError => e
+    raise Exception.new("There are no dashboards in your dashboard directory.")
+  end
+end
+
+get '/:dashboard' do
+  erb params[:dashboard].to_sym
+end
+
+get '/views/:widget?.html' do
+  widget = params[:widget]
+  send_file File.join(Dir.pwd, "widgets/#{widget}/#{widget}.html")
+end
+
+post '/widgets/:id' do
+  request.body.rewind
+  body =  JSON.parse(request.body.read)
+  auth_token = body.delete("auth_token")
+  if auth_token == settings.auth_token
+    send_event(params['id'], body)
+    204 # response without entity body
+  else
+    status 401
+    "Invalid API key\n"
+  end
+end
+
+def framework_javascripts
+  ['jquery.js', 'es5-shim.js', 'batman.js', 'batman.jquery.js', 'application.coffee', 'widget.coffee'].collect do |f|
+    File.join(File.expand_path("../../vendor/javascripts", __FILE__), f)
+  end
+end
+
+def widget_javascripts
+  asset_paths("/widgets/**/*.coffee")
+end
+
+def javascripts
+  (framework_javascripts + widget_javascripts).collect do |f|
+    if File.extname(f) == ".coffee"
+      begin
+      CoffeeScript.compile(File.read(f))
+      rescue ExecJS::ProgramError => e
+        message = e.message + ": in #{f}"
+        raise ExecJS::ProgramError.new(message)
+      end
+    else
+      File.read(f)
+    end
+  end.join("\n")
+end
+
+def stylesheets
+  asset_paths("/public/**/*.scss", "/widgets/**/*.scss").collect do |f|
+    Sass.compile File.read(f)
+  end.join("\n")
+end
+
+def asset_paths(*paths)
+  paths.inject([]) { |arr, path| arr + Dir[File.join(Dir.pwd, path)] }
+end
+
+def send_event(id, body)
+  body["id"] = id
+  event = format_event(JSON.unparse(body))
+  settings.history[id] = event
+  settings.connections.each { |out| out << event }
+end
+
+def format_event(body)
+  "data: #{body}\n\n"
+end
+
+def latest_events
+  settings.history.inject("") do |str, (id, body)|
+    str << body
+  end
+end
+
+def first_dashboard
+  files = Dir[settings.views  + "/*.erb"].collect { |f| f.match(/(\w*).erb/)[1] }
+  files -= ['layout']
+  files.first
+end
+
+files = Dir[Dir.pwd + '/jobs/*.rb']
+files.each { |job| require(job) } 

templates/project/README.md

@@ -0,0 +1 @@
+Here lies instructions on how to set this thing up.

templates/project/config.ru

@@ -0,0 +1,7 @@
+require 'allthethings'
+
+configure do
+  set :auth_token, 'YOUR_AUTH_TOKEN'
+end
+
+run Sinatra::Application

templates/project/dashboards/layout.erb

@@ -0,0 +1,21 @@
+<!DOCTYPE html>
+<html>
+<head>
+  <meta charset="utf-8"/>
+  <meta http-equiv="X-UA-Compatible" content="IE=edge,chrome=1">
+
+  <title><%= yield_content(:title) %></title>
+
+  <script type="text/javascript"><%= javascripts %></script>
+  <style><%= stylesheets %></style>
+
+  <meta name="viewport" content="width=device-width, initial-scale=1"/> 
+</head>
+<body>
+
+  <div class="wrapper">
+    <%= yield %>
+  </div>
+
+</body>
+</html>

templates/project/dashboards/main.erb

@@ -0,0 +1 @@
+<div data-id="sample" data-view="Sample"></div>

templates/project/jobs/sample.rb

@@ -0,0 +1,12 @@
+SCHEDULER.every '5s' do
+  sayings = [
+      "That's one trouble with dual identities, Robin. Dual responsibilities.",
+      "You know your neosauruses well, Robin. Peanut butter sandwiches it is.",
+      "You're far from mod, Robin. And many hippies are older than you are.",
+      "We're still over land, Robin, and a seal is an aquatic, marine mammal.",
+      "True. You owe your life to dental hygiene.",
+      "This money goes to building better roads. We all must do our part."
+    ]
+
+    send_event('sample', { quote: sayings.sample })
+end

templates/project/lib/.empty_directory

@@ -0,0 +1 @@
+.empty_directory

templates/project/public/images/.empty_directory

@@ -0,0 +1 @@
+.empty_directory

templates/project/public/javascripts/.empty_directory

@@ -0,0 +1 @@
+.empty_directory

templates/project/public/stylesheets/.empty_directory

@@ -0,0 +1 @@
+.empty_directory

templates/project/widgets/.empty_directory

@@ -0,0 +1 @@
+.empty_directory

templates/project/widgets/sample/sample.coffee

@@ -0,0 +1,2 @@
+class AllTheThings.Sample extends AllTheThings.Widget
+  source: 'sample'

templates/project/widgets/sample/sample.html

@@ -0,0 +1,4 @@
+<p>w00t! w00t! You've setup your first dashboard!</p>
+<p>To celebrate, enjoy some of these fun Batman quotes!</p>
+<span data-bind="quote"></span>
+

templates/project/widgets/sample/sample.scss

@@ -0,0 +1,2 @@
+class AllTheThings.<%= Thor::Util.camel_case(name) %> extends AllTheThings.Widget
+  source: '<%= name %>'

templates/widget/%name%.coffee.tt

@@ -0,0 +1,51 @@
+Batman.Filters.PrettyNumber = (num) ->
+  num.toString().replace(/\B(?=(\d{3})+(?!\d))/g, ",") unless isNaN(num)
+
+class window.AllTheThings extends Batman.App
+  @root -> 
+
+Batman.Property.EasingSetter =
+  get: Batman.Property.defaultAccessor.get
+  set: (k, to) ->
+    if isNaN(to)
+      @[k] = to
+    else
+      timer = "interval_#{k}"
+      num = if !isNaN(@[k]) then @[k] else 0
+      unless @[timer] || num == to
+        up = to > num
+        num_interval = Math.abs(num - to) / 90
+        @[timer] = 
+          setInterval =>
+            num = if up then Math.ceil(num+num_interval) else Math.floor(num-num_interval)
+            if (up && num > to) || (!up && num < to)
+              num = to
+              clearInterval(@[timer])
+              @[timer] = null
+              delete @[timer]
+            @[k] = num
+            @set k, to
+      @[k] = num    
+
+AllTheThings.widgets = widgets = {}
+AllTheThings.lastEvents = lastEvents = {}
+
+source = new EventSource('/events')
+source.addEventListener 'open', (e)->
+  console.log("Connection opened")
+
+source.addEventListener 'error', (e)->
+  console.log("Connection error")
+  if (e.readyState == EventSource.CLOSED)
+    console.log("Connection closed")
+
+source.addEventListener 'message', (e) =>
+  data = JSON.parse(e.data)
+  lastEvents[data.id] = data
+  if widgets[data.id]?.length > 0
+    for widget in widgets[data.id]
+      widget.onData(data)
+
+
+$(document).ready ->
+  AllTheThings.run()