Sutty/trabajo-afectivo
5
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Improved file handling.

Browse source
This commit is contained in:
Martin Edenhofer 2012-08-04 01:35:21 +02:00
parent d15728f779
commit 7e7885343e
1 changed files with 22 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

45
lib/web_socket.rb
View file

@ -33,31 +33,25 @@ module Session
end end
def self.transaction( client_id, data ) def self.transaction( client_id, data )
filename = @path + '/' + client_id.to_s + '/transaction-' + Time.new().to_i.to_s path = @path + '/' + client_id.to_s + '/'
if File::exists?( filename ) filename = 'transaction-' + Time.new().to_i.to_s + '-' + rand(999999).to_s
filename = @path + '/' + client_id.to_s + '/transaction-' + Time.new().to_i.to_s + '-1' if File::exists?( path + filename )
if File::exists?( filename ) filename = filename + '-1'
filename = @path + '/' + client_id.to_s + '/transaction-' + Time.new().to_i.to_s + '-2' if File::exists?( path + filename )
if File::exists?( filename ) filename = filename + '-1'
filename = @path + '/' + client_id.to_s + '/transaction-' + Time.new().to_i.to_s + '-3' if File::exists?( path + filename )
if File::exists?( filename ) filename = filename + '-1'
filename = @path + '/' + client_id.to_s + '/transaction-' + Time.new().to_i.to_s + '-4' if File::exists?( path + filename )
if File::exists?( filename ) filename = filename + '-' + rand(999999).to_s
filename = @path + '/' + client_id.to_s + '/transaction-' + Time.new().to_i.to_s + '-5'
if File::exists?( filename )
filename = @path + '/' + client_id.to_s + '/transaction-' + Time.new().to_i.to_s + '-6'
if File::exists?( filename )
filename = @path + '/' + client_id.to_s + '/transaction-' + Time.new().to_i.to_s + '-7'
end end
end end
end end
end end
end return false if !File.directory? path
end File.open( path + 'a-' + filename, 'w' ) { |file|
end
File.open( filename, 'w' ) { |file|
file.puts data.to_json file.puts data.to_json
} }
FileUtils.mv( path + 'a-' + filename, path + filename)
return true return true
end end
@ -114,22 +108,25 @@ module Session
data = [] data = []
Dir.foreach( path ) do |entry| Dir.foreach( path ) do |entry|
if /^transaction/.match( entry ) if /^transaction/.match( entry )
data.push Session.queue_file( path + entry ) data.push Session.queue_file( path, entry )
end end
end end
return data return data
end end
def self.queue_file( filename ) def self.queue_file( path, filename )
file_old = path + filename
file_new = path + 'a-' + filename
FileUtils.mv( file_old, file_new )
data = nil data = nil
File.open( filename, 'r' ) { |file|
all = '' all = ''
File.open( file_new, 'r' ) { |file|
while line = file.gets while line = file.gets
all = all + line all = all + line
end end
data = JSON.parse( all )
} }
File.delete( filename ) File.delete( file_new )
data = JSON.parse( all )
return data return data
end end