Class: DRbFileClient

Inherits:
Object
  • Object
show all
Defined in:
lib/drb_fileclient.rb

Instance Method Summary collapse

Constructor Details

#initialize(location = nil, host: nil, port: '61010') ⇒ DRbFileClient 



11
12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'lib/drb_fileclient.rb', line 11

def initialize(location=nil, host: nil, port: '61010')
  
  if location then
    
    host = location[/(?<=^dfs:\/\/)[^\/:]+/]
    port = location[/(?<=^dfs:\/\/)[^:]+:(\d+)/,1]  || '61010'
    @directory = location[/(?<=^dfs:\/\/)[^\/]+\/(.*)/,1]
    
  end
  
  DRb.start_service
  
end

Instance Method Details

#chdir(raw_path) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/drb_fileclient.rb', line 25

def chdir(raw_path)
  
  return Dir.chdir raw_path unless @directory or raw_path =~ /^dfs:\/\//
  
  directory = if raw_path[0] == '/'  then
    raw_path[1..-1]
  elsif raw_path =~ /^dfs:\/\//
    parse_path(raw_path)
  else      
    File.join(@directory, raw_path)
  end    
  
  if @file.exists? directory then
    @directory = directory
  else
    'No such file or directory'
  end
  
end

#cp(raw_path, raw_path2) ⇒ Object 



45
46
47
48
49
50
51
52
53
54
55
56
57
58
 
# File 'lib/drb_fileclient.rb', line 45

def cp(raw_path, raw_path2)
  
  unless @directory or raw_path =~ /^dfs:\/\// then
    return FileUtils.cp raw_path, raw_path2 
  end
  
  path, path2 = if raw_path =~ /^dfs:\/\// then
    [parse_path(raw_path), parse_path(raw_path2)]
  else
    [File.join(@directory, raw_path), File.join(@directory, raw_path2)]
  end 
    
  @file.cp path, path2
end

#exists?(filename = @filename) ⇒ Boolean Also known as: exist? 



60
61
62
63
64
65
66
67
68
69
70
71
72
73
 
# File 'lib/drb_fileclient.rb', line 60

def exists?(filename=@filename)  
  
  return File.exists? filename unless @directory or filename =~ /^dfs:\/\//
  
  filename2 = if filename =~ /^dfs:\/\// then
    parse_path(filename)
  else

    File.join(@directory, filename)
  end

  @file.exists?(filename2)
  
end

#ls(raw_path) ⇒ Object 



77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
 
# File 'lib/drb_fileclient.rb', line 77

def ls(raw_path)
  
  return Dir[raw_path] unless @directory or raw_path =~ /^dfs:\/\//
  
  path = if raw_path[0] == '/'  then
    raw_path[1..-1]
  elsif raw_path =~ /^dfs:\/\//
    parse_path(raw_path)
  else      
    File.join(@directory, raw_path)
  end    
  
  @file.ls path
  
end

#mkdir(name) ⇒ Object 



93
94
95
96
97
98
99
 
# File 'lib/drb_fileclient.rb', line 93

def mkdir(name)
  
  return FileUtils.mkdir name unless @directory or name =~ /^dfs:\/\//
  
  path = parse_path(name)
  @file.mkdir path
end

#mkdir_p(raw_path) ⇒ Object 



101
102
103
104
105
106
107
108
109
110
111
112
113
114
 
# File 'lib/drb_fileclient.rb', line 101

def mkdir_p(raw_path)
  
  unless @directory or raw_path =~ /^dfs:\/\// then
    return FileUtils.mkdir_p raw_path 
  end    
  
  filepath = if raw_path =~ /^dfs:\/\// then
    parse_path(raw_path)
  else
    File.join(@directory, raw_path)
  end
  
  @file.mkdir_p filepath
end

#mv(raw_path, raw_path2) ⇒ Object 



116
117
118
119
120
121
122
123
124
125
126
127
128
129
 
# File 'lib/drb_fileclient.rb', line 116

def mv(raw_path, raw_path2)
  
  unless @directory or raw_path =~ /^dfs:\/\// then
    return FileUtils.mv raw_path, raw_path2  
  end
  
  path, path2 = if raw_path =~ /^dfs:\/\// then
    [parse_path(raw_path), parse_path(raw_path2)]
  else
    [File.join(@directory, raw_path), File.join(@directory, raw_path2)]
  end 
    
  @file.mv path, path2
end

#pwd ⇒ Object 



131
132
133
134
135
136
137
 
# File 'lib/drb_fileclient.rb', line 131

def pwd()
  
  return Dir.pwd unless @directory
  
  '/' + @directory if @file
  
end

#read(filename = @filename) ⇒ Object 



139
140
141
142
143
144
145
146
147
148
149
150
 
# File 'lib/drb_fileclient.rb', line 139

def read(filename=@filename)
  
  return File.read filename, s unless @directory or filename =~ /^dfs:\/\//
  
  path = if filename =~ /^dfs:\/\// then
    parse_path(filename)
  else
    File.join(@directory, filename)
  end
  
  @file.read path
end

#rm(path) ⇒ Object 



152
153
154
155
156
157
158
159
160
161
162
163
164
 
# File 'lib/drb_fileclient.rb', line 152

def rm(path)
  
  return FileUtils.rm path unless @directory or path =~ /^dfs:\/\//
  
  path2 = if path =~ /^dfs:\/\// then
    parse_path( path)
  else
    File.join(@directory, path)
  end
    
  @file.rm  path2
  
end

#write(filename = @filename, s) ⇒ Object 



166
167
168
169
170
171
172
173
174
175
176
177
178
179
 
# File 'lib/drb_fileclient.rb', line 166

def write(filename=@filename, s)
      
  return File.write filename, s unless @directory or filename =~ /^dfs:\/\//
  
  path = if filename =~ /^dfs:\/\// then
    parse_path(filename)
  else
    File.join(@directory, filename)
  end
  
  
  @file.write path, s     
  
end

#zip(filename_zip, a) ⇒ Object 



181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
 
# File 'lib/drb_fileclient.rb', line 181

def zip(filename_zip, a)
  
  puts '@directory: ' + @directory.inspect if @debug
  
  unless @directory or filename_zip =~ /^dfs:\/\// then
    
    Zip::File.open(zipfile_zip, Zip::File::CREATE) do |x|

      a.each do |filename, buffer| 
        x.get_output_stream(filename) {|os| os.write buffer }
      end

    end
    
  end
  
  filepath = if filename_zip =~ /^dfs:\/\// then
    parse_path(filename_zip)
  else
    File.join(@directory, filename_zip)
  end

  @file.zip filepath, a
  
end