lib/space/ethers/slurp.cc

Go to the documentation of this file.

//
// nis-util - NIS Administration Utilities
// Copyright (C) 2001, 2008, 2009, 2011, 2012 Peter Miller
//
// 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 2 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/>.
//

#include <lib/ac/errno.h>
#include <lib/ac/sys/stat.h>
#include <lib/ac/unistd.h>

#include <lib/space/ethers/slurp.h>
#include <lib/space/hosts/slurp.h>


space_ethers_slurp::~space_ethers_slurp()
{
}


space_ethers_slurp::space_ethers_slurp(
    const rcstring &a_filename,
    const space_hosts_slurp::pointer &a_hosts
) :
    space_ethers(a_filename),
    hosts(a_hosts)
{
}


space_ethers_slurp::pointer
space_ethers_slurp::create(const rcstring &a_filename,
    const space_hosts_slurp::pointer &a_hosts)
{
    return pointer(new space_ethers_slurp(a_filename, a_hosts));
}


void
space_ethers_slurp::process(const record::pointer &rp0)
{
    record::pointer rp = rp0;

    //
    // Check MAC address.
    //
    {
        by_addr_t::iterator it = by_addr.find(rp->get_mac_address());
        if (it != by_addr.end())
        {
            error
            (
                rp->get_source_location(),
                "duplicate %s MAC address...",
                rp->get_mac_address().quote_c().c_str()
            );
            error
            (
                it->second->get_source_location(),
                "... here is the first %s MAC address",
                it->second->get_mac_address().quote_c().c_str()
            );
        }
        else
        {
            by_addr.insert(by_addr_t::value_type(rp->get_mac_address(), rp));
        }
    }

    //
    // Check IP address.
    //
    if (!rp->get_ip_address().empty())
    {
        if (hosts)
        {
            space_hosts::record::pointer hp =
                hosts->query_by_address(rp->get_ip_address());
            if (hp)
            {
                error
                (
                    rp->get_source_location(),
                    "some NIS clients do not expect an IP address, "
                        "replace %s with %s for maximum interoperability",
                    rp->get_ip_address().quote_c().c_str(),
                    hp->get_names().front().quote_c().c_str()
                );

                // re-write the record, using the correct name.
                rp =
                    record::create
                    (
                        rp->get_source_location(),
                        rp->get_mac_address(),
                        hp->get_names().front(),
                        rp->get_ip_address()
                    );
            }
            else
            {
                error
                (
                    rp->get_source_location(),
                    "some NIS clients do not expect an IP address, replace "
                    "the %s IP address with the host name for maximum "
                    "interoperability; and also add it to the hosts map",
                    rp->get_ip_address().quote_c().c_str()
                );
            }
        }

        by_ip_addr_t::iterator it = by_ip_addr.find(rp->get_ip_address());
        if (it != by_ip_addr.end())
        {
            assert(it->second);
            error
            (
                rp->get_source_location(),
                "duplicate %s ip address...",
                rp->get_ip_address().c_str()
            );
            if (it->second->get_ip_address().empty())
            {
                error
                (
                    it->second->get_source_location(),
                    "... here is the first reference"
                );
            }
            else
            {
                error
                (
                    it->second->get_source_location(),
                    "... here is the first %s ip address",
                    it->second->get_ip_address().quote_c().c_str()
                );
            }
        }
        else
        {
            by_name.insert
            (
                by_ip_addr_t::value_type(rp->get_ip_address(), rp)
            );
        }
    }

    //
    // Check host name.
    //
    if (!rp->get_name().empty())
    {
        if (hosts)
        {
            space_hosts::record::pointer hp =
                hosts->query_by_name(rp->get_name());
            if (!hp)
            {
                error
                (
                    rp->get_source_location(),
                    "host %s does not exist in the hosts map",
                    rp->get_name().quote_c().c_str()
                );
            }
            else if (rp->get_ip_address().empty())
            {
                // rewrite the record with the IP address
                rp =
                    space_ethers::record::create
                    (
                        rp->get_source_location(),
                        rp->get_mac_address(),
                        rp->get_name(),
                        hp->get_ip_address()
                    );
                by_ip_addr_t::iterator ipit =
                    by_ip_addr.find(hp->get_ip_address());
                if (ipit != by_ip_addr.end())
                {
                    error
                    (
                        rp->get_source_location(),
                        "duplicate %s ip address...",
                        rp->get_ip_address().quote_c().c_str()
                    );
                    if (ipit->second->get_ip_address().empty())
                    {
                        error
                        (
                            ipit->second->get_source_location(),
                            "... here is the first reference"
                        );
                    }
                    else
                    {
                        error
                        (
                            ipit->second->get_source_location(),
                            "... here is the first %s ip address",
                            rp->get_ip_address().quote_c().c_str()
                        );
                    }
                }
                else
                {
                    by_ip_addr.insert
                    (
                        by_ip_addr_t::value_type(rp->get_ip_address(), rp)
                    );
                }
            }
        }

        // We use a lower-case name intentionally,
        // because DNS things names are not case sensitive.
        by_name_t::iterator it = by_name.find(rp->get_name().downcase());
        if (it != by_name.end())
        {
            // but preserve case in the error messages
            error
            (
                rp->get_source_location(),
                "duplicate %s host name...",
                rp->get_name().c_str()
            );
            if (it->second->get_name().empty())
            {
                error
                (
                    it->second->get_source_location(),
                    "... here is the first reference"
                );
            }
            else
            {
                error
                (
                    it->second->get_source_location(),
                    "... here is the first %s host name",
                    it->second->get_name().quote_c().c_str()
                );
            }
        }
        else
        {
            // We use a lower-case name intentionally,
            // because DNS thinks host names are not case sensitive.
            by_name.insert
            (
                by_name_t::value_type(rp->get_name().downcase(), rp)
            );
        }
    }

    //
    // Check line length.
    //
    if (rp->representation().size() >= 512)
    {
        error
        (
            rp->get_source_location(),
            "line too long (NIS limits records to 511 bytes, NIS+ limits "
                "records to 1023 bytes)"
        );
    }
}


void
space_ethers_slurp::read_and_process(void)
{
    for (;;)
    {
        space_ethers::record::pointer rp = get();
        if (!rp)
            break;
        process(rp);
    }
    close();
}


space_ethers::record::pointer
space_ethers_slurp::query_by_name(const rcstring &name)
    const
{
    by_name_t::const_iterator it = by_name.find(name);
    if (it == by_name.end())
        return record::pointer();
    return it->second;
}


space_ethers::record::pointer
space_ethers_slurp::query_by_address(const rcstring &address)
    const
{
    by_addr_t::const_iterator it = by_addr.find(address);
    if (it == by_addr.end())
        return record::pointer();
    return it->second;
}


// vim: set ts=8 sw=4 et :