Shut Up and Pipe! Unix-style Object Collaboration in Rack and Vagrant

Transcript

1. Shut up and pipe! Unix-style Object Collaboration in Rack and Vagrant
5. paulh Paul Hinze jbelser Jeff Belser liz Liz Abinante nomitch Mike Nomitch jstern Jennifer Stern z Mike Ziwisky illstructure
6. Design
7. A B
8. A B
9. A B A B
10. But How?
11. Giving a Crap Mostly just by
12. Other People's Code
15. Patterns
21. Ceci n'est pas une pipe
22. Output interface = Input interface
24. Composition
25. "Write programs to handle text streams, because that is a universal interface."
26. cat /var/log/system.log
27. cat /var/log/system.log |
28. cat /var/log/system.log | grep '^Jan'
29. cat /var/log/system.log | grep '^Jan' | awk '{ print $5 }'
30. cat /var/log/system.log | grep '^Jan' | awk '{ print $5 }' | sort | uniq -c
31. cat /var/log/system.log | grep '^Jan' | awk '{ print $5 }' | sort | uniq -c | sort -n
35. an Object that responds to #call #call accepts one Hash argument #call returns an Array with [status, headers, body] where and
37. app = ->(env) { [200, {}, 'Hello, World!'] } ! Rack::Handler::Thin.run(app) It's Simple!
39. app = ->(env) { [200, {}, 'Hello, World!'] } Rack::Handler.const_get( %i[ Thin WEBrick Unicorn Puma ].sample ).run(app) Any Server
40. app = [ BigOle::RailsApp.new, TinyClassInSameFile.new ].sample ! Rack::Handler::Thin.run(app) Any Application
41. Middleware
42. class YellIt def initialize(app) @app = app end ! def call(env) status, headers, body = @app.call(env) [status, headers, body.upcase] end end ! app = ->(env) {[200, {}, 'Hello, World!']} ! Rack::Handler::Thin.run(YellIt.new(app))
43. class YellIt def initialize(app) @app = app end ! def call(env) status, headers, body = @app.call(env) [status, headers, body.upcase] end end ! app = ->(env) {[200, {}, 'Hello, World!']} ! Rack::Handler::Thin.run(YellIt.new(app))
44. class YellIt def initialize(app) @app = app end ! def call(env) status, headers, body = @app.call(env) [status, headers, body.upcase] end end ! app = ->(env) {[200, {}, 'Hello, World!']} ! Rack::Handler::Thin.run(YellIt.new(app))
45. class YellIt def initialize(app) @app = app end ! def call(env) status, headers, body = @app.call(env) [status, headers, body.upcase] end end ! app = ->(env) {[200, {}, 'Hello, World!']} ! Rack::Handler::Thin.run(YellIt.new(app))
46. class YellIt def initialize(app) @app = app end ! def call(env) status, headers, body = @app.call(env) [status, headers, body.upcase] end end ! app = ->(env) {[200, {}, 'Hello, World!']} ! Rack::Handler::Thin.run(YellIt.new(app))
47. class YellIt def initialize(app) @app = app end ! def call(env) status, headers, body = @app.call(env) [status, headers, body.upcase] end end ! app = ->(env) {[200, {}, 'Hello, World!']} ! Rack::Handler::Thin.run(YellIt.new(app))
48. class YellIt def initialize(app) @app = app end ! def call(env) status, headers, body = @app.call(env) [status, headers, body.upcase] end end ! app = ->(env) {[200, {}, 'Hello, World!']} ! Rack::Handler::Thin.run(YellIt.new(app))
51. This is very Powerful!
52. class Rack::Logger def initialize(app, logger=Logger.new(STDOUT)) @app = app @logger = logger end ! def call(env) status, headers, body = @app.call(env) @logger.info("[#{Time.now}] #{status}") [status, headers, body] end end A logger
53. class Rack::ContentLength def initialize(app) @app = app end ! def call(env) status, headers, body = @app.call(env) ! if !headers['Content-Length'] headers['Content-Length'] = body.length end ! [status, headers, body] end end A header
54. class Rack::Runtime def initialize(app) @app = app end ! def call(env) start_time = Time.now status, headers, body = @app.call(env) request_time = Time.now - start_time ! headers['X-Runtime'] = "%0.6f" % request_time ! [status, headers, body] end end A timer
56. class Rack::Auth::Basic def initialize(app, user, pass) @app, @user, @pass = app, user, pass end ! def call(env) if authenticated?(env['HTTP_AUTHORIZATION']) @app.call(env) else [403, {}, "Go Away!"] end end ! def authenticated?(auth) return false unless auth _, token = auth.split(' ') user, pass = token.unpack('m*').first.split(':') (user == @user && pass == @pass) end end ! app = ->(env) {[200, {}, 'Hello, World!']} with_auth = Rack::Auth::Basic.new(app, 'paulh', 'hello') Rack::Handler::Thin.run(with_auth) A auth!
57. class Rack::Auth::Basic def initialize(app, user, pass) @app, @user, @pass = app, user, pass end ! def call(env) if authenticated?(env['HTTP_AUTHORIZATION']) @app.call(env) else [403, {}, "Go Away!"] end end ! def authenticated?(auth) return false unless auth _, token = auth.split(' ') user, pass = token.unpack('m*').first.split(':') (user == @user && pass == @pass) end end ! app = ->(env) {[200, {}, 'Hello, World!']} with_auth = Rack::Auth::Basic.new(app, 'paulh', 'hello') Rack::Handler::Thin.run(with_auth)
58. class Rack::Auth::Basic def initialize(app, user, pass) @app, @user, @pass = app, user, pass end ! def call(env) if authenticated?(env['HTTP_AUTHORIZATION']) @app.call(env) else [403, {}, "Go Away!"] end end ! def authenticated?(auth) return false unless auth _, token = auth.split(' ') user, pass = token.unpack('m*').first.split(':') (user == @user && pass == @pass) end end ! app = ->(env) {[200, {}, 'Hello, World!']} with_auth = Rack::Auth::Basic.new(app, 'paulh', 'hello') Rack::Handler::Thin.run(with_auth)
59. class Rack::Auth::Basic def initialize(app, user, pass) @app, @user, @pass = app, user, pass end ! def call(env) if authenticated?(env['HTTP_AUTHORIZATION']) @app.call(env) else [403, {}, "Go Away!"] end end ! def authenticated?(auth) return false unless auth _, token = auth.split(' ') user, pass = token.unpack('m*').first.split(':') (user == @user && pass == @pass) end end ! app = ->(env) {[200, {}, 'Hello, World!']} with_auth = Rack::Auth::Basic.new(app, 'paulh', 'hello') Rack::Handler::Thin.run(with_auth)
60. class Rack::Auth::Basic def initialize(app, user, pass) @app, @user, @pass = app, user, pass end ! def call(env) if authenticated?(env['HTTP_AUTHORIZATION']) @app.call(env) else [403, {}, "Go Away!"] end end ! def authenticated?(auth) return false unless auth _, token = auth.split(' ') user, pass = token.unpack('m*').first.split(':') (user == @user && pass == @pass) end end ! app = ->(env) {[200, {}, 'Hello, World!']} with_auth = Rack::Auth::Basic.new(app, 'paulh', 'hello') Rack::Handler::Thin.run(with_auth)
61. class Rack::Auth::Basic def initialize(app, user, pass) @app, @user, @pass = app, user, pass end ! def call(env) if authenticated?(env['HTTP_AUTHORIZATION']) @app.call(env) else [403, {}, "Go Away!"] end end ! def authenticated?(auth) return false unless auth _, token = auth.split(' ') user, pass = token.unpack('m*').first.split(':') (user == @user && pass == @pass) end end ! app = ->(env) {[200, {}, 'Hello, World!']} with_auth = Rack::Auth::Basic.new(app, 'paulh', 'hello') Rack::Handler::Thin.run(with_auth)
62. class Rack::Auth::Basic def initialize(app, user, pass) @app, @user, @pass = app, user, pass end ! def call(env) if authenticated?(env['HTTP_AUTHORIZATION']) @app.call(env) else [403, {}, "Go Away!"] end end ! def authenticated?(auth) return false unless auth _, token = auth.split(' ') user, pass = token.unpack('m*').first.split(':') (user == @user && pass == @pass) end end ! app = ->(env) {[200, {}, 'Hello, World!']} with_auth = Rack::Auth::Basic.new(app, 'paulh', 'hello') Rack::Handler::Thin.run(with_auth) Our app doesn't need to care about Authentication
63. class Rack::Auth::Basic def initialize(app, user, pass) @app, @user, @pass = app, user, pass end ! def call(env) if authenticated?(env['HTTP_AUTHORIZATION']) @app.call(env) else [403, {}, "Go Away!"] end end ! def authenticated?(auth) return false unless auth _, token = auth.split(' ') user, pass = token.unpack('m*').first.split(':') (user == @user && pass == @pass) end end ! app = ->(env) {[200, {}, 'Hello, World!']} with_auth = Rack::Auth::Basic.new(app, 'paulh', 'hello') Rack::Handler::Thin.run(with_auth) Amazing!
64. Composition
65. Rack::Logger.new( Rack::Auth::Basic.new( Rack::Runtime.new( Rack::ContentLength.new( app ) ), 'paulh', 'hello'), Logger.new(STDERR) )
67. Rack::Logger.new( Rack::Auth::Basic.new( Rack::Runtime.new( Rack::ContentLength.new( app ) ), 'paulh', 'hello'), Logger.new(STDERR) )
68. class Rack::Builder def initialize(app, &block) @use = [] @app = app instance_eval(&block) end ! def use(middleware) @use.push ->(app) { middleware.new(app) } end ! def call(env) @use.reverse.inject(@app) { |app, middleware_builder| middleware_builder.call(app) }.call(env) end end ! built = Rack::Builder.new(app) do use Rack::Logger use Rack::ContentLength use Rack::Runtime end ! Rack::Handler::Thin.run(built)
70. rake middleware
72. def self.action_boot Vagrant::Action::Builder.new.tap do |b| b.use CheckAccessible b.use CleanMachineFolder b.use SetName b.use ClearForwardedPorts b.use Provision b.use EnvSet, :port_collision_repair => true b.use PrepareForwardedPortCollisionParams b.use HandleForwardedPortCollisions b.use PrepareNFSValidIds b.use SyncedFolderCleanup b.use SyncedFolders b.use PrepareNFSSettings b.use ClearNetworkInterfaces b.use Network b.use ForwardPorts b.use SetHostname b.use SaneDefaults b.use Customize, "pre-boot" b.use Boot b.use Customize, "post-boot" b.use WaitForCommunicator, [:starting, :running] b.use CheckGuestAdditions end end
73. Vagrant::Action::Builder#insert_before ! Vagrant::Action::Builder#insert_after Extensibility!
74. def self.action_boot Vagrant::Action::Builder.new.tap do |b| b.use CheckAccessible b.use CleanMachineFolder b.use SetName b.use ClearForwardedPorts b.use Provision b.use EnvSet, :port_collision_repair => true b.use PrepareForwardedPortCollisionParams b.use HandleForwardedPortCollisions b.use PrepareNFSValidIds b.use SyncedFolderCleanup b.use SyncedFolders b.use PrepareNFSSettings b.use ClearNetworkInterfaces b.use Network b.use ForwardPorts b.use SetHostname b.use SaneDefaults b.use Customize, "pre-boot" b.use Boot b.use Customize, "post-boot" b.use WaitForCommunicator, [:starting, :running] b.use CheckGuestAdditions end end Extensibility!
75. def self.action_boot Vagrant::Action::Builder.new.tap do |b| b.use CheckAccessible b.use CleanMachineFolder b.use SetName b.use ClearForwardedPorts b.use Provision b.use EnvSet, :port_collision_repair => true b.use PrepareForwardedPortCollisionParams b.use HandleForwardedPortCollisions b.use PrepareNFSValidIds b.use SyncedFolderCleanup b.use SyncedFolders b.use PrepareNFSSettings b.use ClearNetworkInterfaces b.use Network b.use ForwardPorts b.use SetHostname b.use SaneDefaults b.use Customize, "pre-boot" b.use Boot b.use Customize, "post-boot" b.use WaitForCommunicator, [:starting, :running] b.use CheckGuestAdditions end end 1. 2. 3. 4. 5. 6. wait...
76. def self.action_boot Vagrant::Action::Builder.new.tap do |b| b.use CheckAccessible b.use CleanMachineFolder b.use SetName b.use ClearForwardedPorts b.use Provision b.use EnvSet, :port_collision_repair => true b.use PrepareForwardedPortCollisionParams b.use HandleForwardedPortCollisions b.use PrepareNFSValidIds b.use SyncedFolderCleanup b.use SyncedFolders b.use PrepareNFSSettings b.use ClearNetworkInterfaces b.use Network b.use ForwardPorts b.use SetHostname b.use SaneDefaults b.use Customize, "pre-boot" b.use Boot b.use Customize, "post-boot" b.use WaitForCommunicator, [:starting, :running] b.use CheckGuestAdditions end end Complexity escalate quickly can
77. B def self.action_boot Vagrant::Action::Builder.new.tap do |b| b.use CheckAccessible b.use CleanMachineFolder b.use SetName b.use ClearForwardedPorts b.use Provision b.use EnvSet, :port_collision_repair => true b.use PrepareForwardedPortCollisionParams b.use HandleForwardedPortCollisions b.use PrepareNFSValidIds b.use SyncedFolderCleanup b.use SyncedFolders b.use PrepareNFSSettings b.use ClearNetworkInterfaces b.use Network b.use ForwardPorts b.use SetHostname b.use SaneDefaults b.use Customize, "pre-boot" b.use Boot b.use Customize, "post-boot" b.use WaitForCommunicator, [:starting, :running] b.use CheckGuestAdditions end end A
78. Every tool has sharp edges
79. Ceci n'est pas une panacea
80. Design is worthwhile
81. Wild code can bring joy
82. Simplicity can be powerful
83. PIPE!