Skip to content
This repository has been archived by the owner on Dec 4, 2018. It is now read-only.

Commit

Permalink
Merge pull request #326 from crowbar/feature/chef_db_drop
Browse files Browse the repository at this point in the history
Feature/chef db drop
  • Loading branch information
bkutil committed Jul 9, 2015
2 parents 43e85fc + 0919f6a commit ed314d0
Showing 1 changed file with 14 additions and 13 deletions.
27 changes: 14 additions & 13 deletions crowbar_framework/app/models/network_service.rb
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ def allocate_ip_by_type(bc_instance, network, range, object, type, suggestion =
found = false
begin
f = acquire_ip_lock
db = ProposalObject.find_data_bag_item "crowbar/#{network}_network"
db = Chef::DataBag.load("crowbar/#{network}_network") rescue nil
net_info = build_net_info(network, name, db)

rangeH = db["network"]["ranges"][range]
Expand Down Expand Up @@ -164,7 +164,7 @@ def deallocate_ip_by_type(bc_instance, network, object, type)
@logger.error("Network deallocate ip from #{type}: No network data found: #{object} #{network}") if role.nil?
return [404, "No network data found"] if role.nil?

db = ProposalObject.find_data_bag_item "crowbar/#{network}_network"
db = Chef::DataBag.load("crowbar/#{network}_network") rescue nil

if type == :node
# If we already have on allocated, return success
Expand Down Expand Up @@ -242,7 +242,7 @@ def deallocate_ip(bc_instance, network, name)
end

def virtual_ip_assigned?(bc_instance, network, range, name)
db = ProposalObject.find_data_bag_item "crowbar/#{network}_network"
db = Chef::DataBag.load("crowbar/#{network}_network") rescue nil
!db["allocated_by_name"][name].nil?
rescue
false
Expand All @@ -260,16 +260,15 @@ def apply_role_pre_chef_call(old_role, role, all_nodes)
@logger.debug("Network apply_role_pre_chef_call: entering #{all_nodes.inspect}")

role.default_attributes["network"]["networks"].each do |k,net|
db = ProposalObject.find_data_bag_item "crowbar/#{k}_network"
db = Chef::DataBag.load("crowbar/#{k}_network") rescue nil
if db.nil?
@logger.debug("Network: creating #{k} in the network")
bc = Chef::DataBagItem.new
bc.data_bag "crowbar"
bc["id"] = "#{k}_network"
bc["network"] = net
bc["allocated"] = {}
bc["allocated_by_name"] = {}
db = ProposalObject.new bc
db = Chef::DataBagItem.new
db.data_bag "crowbar"
db["id"] = "#{k}_network"
db["network"] = net
db["allocated"] = {}
db["allocated_by_name"] = {}
db.save
end
end
Expand All @@ -282,7 +281,7 @@ def transition(inst, name, state)

if state == "discovered"

db = ProposalObject.find_proposal "network", inst
db = Proposal.where(barclamp: "network", name: inst).first
role = RoleObject.find_role_by_name "network-config-#{inst}"
if NodeObject.find_node_by_name(name).try(:[], 'crowbar').try(:[], 'admin_node')
@logger.info("Admin node transitioning to discovered state. Adding switch_config role.")
Expand Down Expand Up @@ -355,7 +354,9 @@ def enable_interface(bc_instance, network, name)


def build_net_info(network, name, db = nil)
db = ProposalObject.find_data_bag_item "crowbar/#{network}_network" unless db
unless db
db = Chef::DataBag.load("crowbar/#{network}_network") rescue nil
end

net_info = {}
db["network"].each { |k,v|
Expand Down

0 comments on commit ed314d0

Please sign in to comment.