Revision 849a61fb
Added by Marc Dequènes almost 14 years ago
- ID 849a61fbc6316122e796c45804ce367dfe50f3dd
bin/librarian | ||
---|---|---|
# to allow in-place run for test
|
||
$: << File.join(File.dirname(__FILE__), "..", "lib")
|
||
|
||
require 'needle'
|
||
require 'cyborghood/cyborg'
|
||
|
||
|
||
module CyborgHood
|
||
module LibrarianHome
|
||
module LibrarianLand
|
||
include I18nTranslation
|
||
bindtextdomain("cyborghood_librarian", {:path => Config::L10N_DIR, :charset => "UTF-8"})
|
||
|
||
... | ... | |
def setup
|
||
super
|
||
|
||
define_interface "0.1~" do
|
||
node "Gruik" do
|
||
node ["g1", "g2", "g3"] do
|
||
on_request do |request|
|
||
request.reply.results = {
|
||
:plouf => ">>> #{node_name} <<<"
|
||
}
|
||
end
|
||
end
|
||
end
|
||
end
|
||
define_interface "0.1~"
|
||
end
|
||
end
|
||
end
|
||
end # LibrarianLand
|
||
end
|
||
|
||
bot = CyborgHood::LibrarianHome::Librarian.new
|
||
|
||
reg = Needle::Registry.new
|
||
reg.define do |b|
|
||
b.require 'cyborghood', CyborgHood
|
||
b.require 'cyborghood-librarian/land', CyborgHood::LibrarianLand
|
||
|
||
b.bot { CyborgHood::LibrarianLand::Librarian.new(b.librarian_land) }
|
||
end
|
||
|
||
ldap_config = reg.config.ldap.marshal_dump
|
||
ldap_config[:logger] = reg.logger
|
||
|
||
begin
|
||
ActiveLdap::Base.setup_connection(ldap_config)
|
||
# force testing a connection NOW (by default ActiveLdap is doing lazy connections)
|
||
# (the loaded schema will be useful soon anyway)
|
||
# it also tests search parameters (provided to setup_connection)
|
||
ActiveLdap::Base.find(:first)
|
||
rescue
|
||
reg.logger.fatal "LDAP failure: " + $!
|
||
exit 1
|
||
end
|
||
|
||
bot = reg.bot
|
||
|
||
trap('INT') do
|
||
bot.ask_to_stop
|
bin/postman | ||
---|---|---|
end
|
||
end
|
||
|
||
# setup LDAP
|
||
ldap_config = @config.ldap.marshal_dump
|
||
ldap_config[:logger] = logger
|
||
begin
|
||
ActiveLdap::Base.setup_connection(ldap_config)
|
||
# force testing a connection NOW (by default ActiveLdap is doing lazy connections)
|
||
# (the loaded schema will be useful soon anyway)
|
||
# it also tests search parameters (provided to setup_connection)
|
||
ActiveLdap::Base.find(:first)
|
||
rescue
|
||
logger.fatal "LDAP failure: " + $!
|
||
exit 1
|
||
end
|
||
|
||
@imap = IMAP.new(@config.imap, @config.imap.min_check_interval)
|
||
|
||
logger.info "Bot '#{self.human_name}' loaded"
|
bin/test_client | ||
---|---|---|
task "compare stuff" do
|
||
ask "MapMaker", :info1, "/_cyborg_"
|
||
ask "Librarian", :info2, "/_cyborg_"
|
||
ask "MapMaker", :zones, "/Zones"
|
||
ask "Librarian", :library, "/Records"
|
||
ask "Librarian", :persons, "/Records/persons"
|
||
ask "Librarian", :dns_domains, "/Records/dns_domains"
|
||
#ask "MapMaker", :zones, "/Zones"
|
||
#ask "MapMaker", :wanted_failure, "/prout"
|
||
ask "MapMaker", :dns, "/Services/DNS"
|
||
ask "MapMaker", :dnssec, "/Services/DNSSEC"
|
||
ask "MapMaker", :zone_mp, "/Zones/milkypond.org"
|
||
ask "MapMaker", :dns_check, "/Services/DNS/check_config"
|
||
#ask "MapMaker", :dns, "/Services/DNS"
|
||
#ask "MapMaker", :dnssec, "/Services/DNSSEC"
|
||
#ask "MapMaker", :zone_mp, "/Zones/milkypond.org"
|
||
#ask "MapMaker", :dns_check, "/Services/DNS/check_config"
|
||
#ask "MapMaker", :search, "/Zones/?"
|
||
#ask "MapMaker", :search_master, "/Zones/?", {:master => true}
|
||
#ask "MapMaker", :search_slave, "/Zones/?", {:master => false}
|
data/cyborghood/default_config/global.yaml | ||
---|---|---|
botnet:
|
||
connection_type: unix_socket
|
||
params: {}
|
||
ldap:
|
||
host: localhost
|
||
port: 389
|
||
scope: sub
|
data/cyborghood/default_config/librarian.yaml | ||
---|---|---|
---
|
||
|
||
ldap:
|
||
host: localhost
|
||
port: 389
|
||
scope: sub
|
data/cyborghood/schema/global.yaml | ||
---|---|---|
mapping:
|
||
=:
|
||
type: any
|
||
# temporary location
|
||
"ldap":
|
||
type: map
|
||
required: true
|
||
name: LdapMapping
|
||
mapping:
|
||
=:
|
||
type: any
|
||
|
data/cyborghood/schema/librarian.yaml | ||
---|---|---|
---
|
||
type: map
|
||
mapping:
|
||
zzz: { type: str }
|
||
"ldap":
|
||
type: map
|
||
required: true
|
||
name: LdapMapping
|
||
mapping:
|
||
=:
|
||
type: any
|
lib/cyborghood-librarian/interface/0_base.rb | ||
---|---|---|
node 'Records' do
|
||
node ['persons', 'dns_domains'] do
|
||
on_request do |request|
|
||
request.reply.results = bot.services.records.send(node_name)
|
||
end
|
||
end
|
||
end
|
lib/cyborghood-librarian/interface_dsl_addons.rb | ||
---|---|---|
|
||
-> ldap search /?
|
lib/cyborghood-librarian/land.rb | ||
---|---|---|
#--
|
||
# CyborgHood, a distributed system management software.
|
||
# Copyright (c) 2009-2010 Marc Dequènes (Duck) <Duck@DuckCorp.org>
|
||
#
|
||
# This program is free software: you can redistribute it and/or modify
|
||
# it under the terms of the GNU General Public License as published by
|
||
# the Free Software Foundation, either version 3 of the License, or
|
||
# (at your option) any later version.
|
||
#
|
||
# This program is distributed in the hope that it will be useful,
|
||
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||
# GNU General Public License for more details.
|
||
#
|
||
# You should have received a copy of the GNU General Public License
|
||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||
#++
|
||
|
||
require 'active_ldap'
|
||
|
||
|
||
module CyborgHood
|
||
module LibrarianLand
|
||
def register_services(container)
|
||
container.namespace_define(:librarian_land) do |b|
|
||
b.records do
|
||
require 'cyborghood-librarian/records'
|
||
Records.new
|
||
end
|
||
end
|
||
end
|
||
|
||
module_function :register_services
|
||
end # LibrarianLand
|
||
end
|
lib/cyborghood-librarian/records.rb | ||
---|---|---|
#--
|
||
# CyborgHood, a distributed system management software.
|
||
# Copyright (c) 2009-2010 Marc Dequènes (Duck) <Duck@DuckCorp.org>
|
||
#
|
||
# This program is free software: you can redistribute it and/or modify
|
||
# it under the terms of the GNU General Public License as published by
|
||
# the Free Software Foundation, either version 3 of the License, or
|
||
# (at your option) any later version.
|
||
#
|
||
# This program is distributed in the hope that it will be useful,
|
||
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||
# GNU General Public License for more details.
|
||
#
|
||
# You should have received a copy of the GNU General Public License
|
||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||
#++
|
||
|
||
Dir.glob(File.join(File.dirname(__FILE__), "records", "*.rb")).each do |f|
|
||
logger.debug "Loading record definition '#{f}'"
|
||
require f
|
||
end
|
||
|
||
|
||
module CyborgHood
|
||
module LibrarianLand
|
||
class Records
|
||
def persons
|
||
LdapPerson.find(:all, :attributes => ['uid']).collect{|i| i.uid }
|
||
end
|
||
|
||
def dns_domains
|
||
LdapDnsDomain.find(:all, :attributes => ['cn']).collect{|i| i.cn }
|
||
end
|
||
end
|
||
end # LibrarianLand
|
||
end
|
lib/cyborghood-librarian/records/dns_domain.rb | ||
---|---|---|
#--
|
||
# CyborgHood, a distributed system management software.
|
||
# Copyright (c) 2009-2010 Marc Dequènes (Duck) <Duck@DuckCorp.org>
|
||
#
|
||
# This program is free software: you can redistribute it and/or modify
|
||
# it under the terms of the GNU General Public License as published by
|
||
# the Free Software Foundation, either version 3 of the License, or
|
||
# (at your option) any later version.
|
||
#
|
||
# This program is distributed in the hope that it will be useful,
|
||
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||
# GNU General Public License for more details.
|
||
#
|
||
# You should have received a copy of the GNU General Public License
|
||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||
#++
|
||
|
||
|
||
module CyborgHood
|
||
module LibrarianLand
|
||
class LdapDnsDomain < ActiveLdap::Base
|
||
ldap_mapping :dn_attribute => 'cn', :prefix => '', :classes => ['genericDomain']
|
||
|
||
def managers
|
||
list = self.manager
|
||
return [] if list.nil?
|
||
return list.collect{|dn| dn.to_s } if list.is_a? Array
|
||
return [list.to_s]
|
||
end
|
||
end
|
||
end # LibrarianLand
|
||
end
|
lib/cyborghood-librarian/records/person.rb | ||
---|---|---|
#--
|
||
# CyborgHood, a distributed system management software.
|
||
# Copyright (c) 2009-2010 Marc Dequènes (Duck) <Duck@DuckCorp.org>
|
||
#
|
||
# This program is free software: you can redistribute it and/or modify
|
||
# it under the terms of the GNU General Public License as published by
|
||
# the Free Software Foundation, either version 3 of the License, or
|
||
# (at your option) any later version.
|
||
#
|
||
# This program is distributed in the hope that it will be useful,
|
||
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||
# GNU General Public License for more details.
|
||
#
|
||
# You should have received a copy of the GNU General Public License
|
||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||
#++
|
||
|
||
|
||
module CyborgHood
|
||
module LibrarianLand
|
||
class LdapPerson < ActiveLdap::Base
|
||
ldap_mapping :dn_attribute => 'uid', :prefix => '', :classes => ['individual']
|
||
end
|
||
end # LibrarianLand
|
||
end
|
lib/cyborghood.rb | ||
---|---|---|
b.config do
|
||
Config.instance
|
||
end
|
||
|
||
b.logger do
|
||
Logger.instance
|
||
end
|
||
end
|
||
end
|
||
|
lib/cyborghood/objects/ldap.rb | ||
---|---|---|
#--
|
||
# CyborgHood, a distributed system management software.
|
||
# Copyright (c) 2009-2010 Marc Dequènes (Duck) <Duck@DuckCorp.org>
|
||
#
|
||
# This program is free software: you can redistribute it and/or modify
|
||
# it under the terms of the GNU General Public License as published by
|
||
# the Free Software Foundation, either version 3 of the License, or
|
||
# (at your option) any later version.
|
||
#
|
||
# This program is distributed in the hope that it will be useful,
|
||
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||
# GNU General Public License for more details.
|
||
#
|
||
# You should have received a copy of the GNU General Public License
|
||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||
#++
|
||
|
||
require 'active_ldap'
|
||
|
||
module CyborgHood
|
||
class LdapDnsDomain < ActiveLdap::Base
|
||
ldap_mapping :dn_attribute => 'cn', :prefix => '', :classes => ['genericDomain']
|
||
|
||
def managers
|
||
list = self.manager
|
||
return [] if list.nil?
|
||
return list.collect{|dn| dn.to_s } if list.is_a? Array
|
||
return [list.to_s]
|
||
end
|
||
end
|
||
|
||
class LdapPerson < ActiveLdap::Base
|
||
ldap_mapping :dn_attribute => 'uid', :prefix => '', :classes => ['individual']
|
||
end
|
||
end
|
Also available in: Unified diff
[evol] Librarian API work §1, using DI too