Class: FC::Item

Inherits:
DbBase show all
Defined in:
lib/fc/item.rb

Instance Attribute Summary

Attributes inherited from DbBase

#database_fields, #id

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from DbBase

create_from_fiels, #delete, find, #initialize, #reload, #save, set_table, where

Constructor Details

This class inherits a constructor from FC::DbBase

Class Method Details

.create_from_local(local_path, item_name, policy, options = {}) ⇒ Object

Create item by local path. Additional options:

:replace=true - replace item if it exists

If item_name is part of local_path it processed as inplace - local_path is valid path to the item for policy



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
 
# File 'lib/fc/item.rb', line 11

def self.create_from_local(local_path, item_name, policy, options={})
  raise 'Path not exists' unless File.exists?(local_path)
  raise 'Policy is not FC::Policy' unless policy.instance_of?(FC::Policy)
  item_params = options.merge({
    :name => item_name.to_s.gsub('//', '/').sub(/\/$/, '').sub(/^\//, '').strip,
    :policy_id => policy.id,
    :dir => File.directory?(local_path),
    :size => `du -sb #{local_path}`.to_i
  })
  item_params.delete(:replace)
  item_params.delete(:inplace)
  raise 'Name is empty' if item_params[:name].empty?
  raise 'Zero size path' if item_params[:size] == 0
  
  if local_path.include?(item_name)
    storage = policy.get_create_storages.detect do |s| 
      s.host == FC::Storage.curr_host && local_path.index(s.path) == 0 && local_path.sub(s.path, '') == item_params[:name]
    end
    FC::Error.raise "local_path #{local_path} is not valid path for policy ##{policy.id}" unless storage
  end
  
  # new item?
  item = FC::Item.where('name=? AND policy_id=?', item_params[:name], policy.id).first
  if item
    if options[:replace] || storage
      # mark delete item_storages on replace
      FC::DB.query("UPDATE #{FC::ItemStorage.table_name} SET status='delete' WHERE item_id = #{item.id}") if options[:replace] && !storage
      # replace all fields
      item_params.each{|key, val| item.send("#{key}=", val)}
    else
      FC::Error.raise 'Item already exists', :item_id => item.id
    end
  else
    item = FC::Item.new(item_params)
  end
  item.save
  
  if storage
    item_storage = item.make_item_storage(storage, 'ready')
    item.reload
  else 
    storage = policy.get_proper_storage_for_create(item.size)
    FC::Error.raise 'No available storage', :item_id => item.id unless storage
    item_storage = item.make_item_storage(storage)
    item.copy_item_storage(local_path, storage, item_storage)
  end
  
  return item
end

Instance Method Details

#copy_item_storage(src, storage, item_storage) ⇒ Object 



71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
 
# File 'lib/fc/item.rb', line 71

def copy_item_storage(src, storage, item_storage)
  begin
    if src.instance_of?(FC::Storage)
      src.copy_to_local(name, "#{storage.path}#{name}")
    else
      storage.copy_path(src, name)
    end
    size_on_storage = storage.file_size(name)
  rescue Exception => e
    item_storage.status = 'error'
    item_storage.save
    FC::Error.raise "Copy error: #{e.message}", :item_id => id, :item_storage_id => item_storage.id
  else
    begin
      item_storage.reload
    rescue Exception => e
      FC::Error.raise "After copy error: #{e.message}", :item_id => id, :item_storage_id => item_storage.id
    else
      if size_on_storage != size
        item_storage.status = 'error'
        item_storage.save
        FC::Error.raise "Check size after copy error", :item_id => id, :item_storage_id => item_storage.id
      else
        item_storage.status = 'ready'
        item_storage.save
        reload
      end
    end
  end
end

#dir? ⇒ Boolean

Returns:

  • (Boolean) 


109
110
111
 
# File 'lib/fc/item.rb', line 109

def dir?
  dir.to_i == 1
end

#get_available_storages ⇒ Object 



117
118
119
120
121
 
# File 'lib/fc/item.rb', line 117

def get_available_storages
  r = FC::DB.query("SELECT st.* FROM #{FC::Storage.table_name} as st, #{FC::ItemStorage.table_name} as ist WHERE 
    ist.item_id = #{id} AND ist.status='ready' AND ist.storage_name = st.name")
  r.map{|data| FC::Storage.create_from_fiels(data)}.select {|storage| storage.up? }
end

#get_item_storages ⇒ Object 



113
114
115
 
# File 'lib/fc/item.rb', line 113

def get_item_storages
  FC::ItemStorage.where("item_id = #{id}")
end

#make_item_storage(storage, status = 'new') ⇒ Object 



61
62
63
64
65
66
67
68
69
 
# File 'lib/fc/item.rb', line 61

def make_item_storage(storage, status = 'new')
  # new storage_item?
  item_storage = FC::ItemStorage.where('item_id=? AND storage_name=?', id, storage.name).first
  item_storage.delete if item_storage
  
  item_storage = FC::ItemStorage.new({:item_id => id, :storage_name => storage.name, :status => status})
  item_storage.save
  item_storage
end

#mark_deleted ⇒ Object

mark items_storages for delete



103
104
105
106
107
 
# File 'lib/fc/item.rb', line 103

def mark_deleted
  FC::DB.query("UPDATE #{FC::ItemStorage.table_name} SET status='delete' WHERE item_id = #{id}")
  self.status = 'delete'
  save
end