public
Rubygem
Description: Resource-oriented open source Ruby framework for Web apps.
Homepage: http://rubywaves.com/
Clone URL: git://github.com/dyoder/waves.git
Search Repo:
fix cluster tasks in framework; remove cluster from sample app
automatthew (author)
Fri May 16 07:42:33 -0700 2008
commit  6c248a07c06ea2e9b7f524ff65a3f3388c539d26
tree    2c80256a3766d1a776136768a354059ce92f28d0
parent  812ae93637e1aa6124b79d6c7ef5951bd03f1712
...
2
3
4
5
 
 
6
7
8
...
2
3
4
 
5
6
7
8
9
0
@@ -2,7 +2,8 @@
0
 
0
   desc 'Start a cluster of waves applications.'
0
   task :start do |task|
0
- script = USE_WAVES_SRC ? 'bin/waves-server' : 'waves-server'
0
+ using_waves_src = defined?(WAVES) || ENV['WAVES'] || File.exist( File.dirname(__FILE__) / :waves )
0
+ script = using_waves_src ? :bin / 'waves-server' : 'waves-server'
0
     ( Waves::Console.config.ports || [ Waves::Console.config.port ] ).each do |port|
0
       cmd = "#{script} -p #{port} -c #{ENV['mode']||'development'} -d"
0
       puts cmd ; `#{cmd}`
...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
...
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
0
@@ -1,25 +1 @@
0
-namespace :cluster do
0
-
0
- desc 'Start a cluster of waves applications.'
0
- task :start do |task|
0
- ( Waves::Console.config.ports || [ Waves::Console.config.port ] ).each do |port|
0
- cmd = "waves-server -p #{port} -c #{ENV['mode']||'development'} -d"
0
- puts cmd ; `#{cmd}`
0
- end
0
- end
0
-
0
- desc 'Stop a cluster of waves applications.'
0
- task :stop do |task|
0
- Dir[ :log / '*.pid' ].each do |path|
0
- pid = File.basename(path,'.pid').to_i
0
- puts "Stopping process #{pid} ..."
0
- Process.kill( 'INT', pid ) rescue nil
0
- end
0
- end
0
-
0
- desc 'Restart a cluster of waves applications.'
0
- task :restart => [ :stop, :start ] do |task|
0
- end
0
-
0
-end
...
1
2
3
4
5
6
7
8
9
...
 
 
 
 
 
 
 
 
 
0
@@ -1,10 +1 @@
0
-namespace :generate do
0
- desc 'Generate a new model'
0
- task :model do |task|
0
- template = File.read :models / 'default.rb'
0
- File.write( :models / ENV['name'] + '.rb',
0
- template.gsub('class Default < Sequel::Model',
0
- "class #{ENV['name'].camel_case} < Sequel::Model(:#{ENV['name'].plural})") )
0
- end
0
-end
...
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
...
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
0
@@ -1,29 +1 @@
0
-require 'sequel'
0
-namespace :schema do
0
-
0
- desc 'Create a new Sequel Migration using name.'
0
- task :migration do |task|
0
-
0
- version = ( ENV['version'].nil? ?
0
- Sequel::Migrator.get_current_migration_version( Blog.database ) :
0
- ENV['version'].to_i ) + 1
0
-
0
- name = ENV['name'] || 'migration'
0
- class_name = name.camel_case
0
-
0
- template = ( ENV['template'] || 'empty' ) + '.rb.erb'
0
- source = :schema / :migrations / :templates / template
0
- destination = :schema / :migrations / "#{'%03d' % version}_#{name}.rb"
0
- code = Erubis::Eruby.new( File.read( source ) ).result( binding )
0
- File.write( destination, code )
0
-
0
- end
0
-
0
- desc 'Performs migration from version, to version.'
0
- task :migrate do |task|
0
- version = ENV['version']; version = version.to_i unless version.nil?
0
- Sequel::Migrator.apply( Waves.application.database, :schema / :migrations , version )
0
- end
0
-
0
-end

Comments

    No one has commented yet.