// Spectre 2
//
// Douglas Thrift
//
// $Id$

#include "Mounter.hpp"

#include <menes-api/environment.hpp>
#include <menes-api/socket.hpp>

#include <arpa/inet.h>

Mounter::Mounter(const api::Path& config) : Daemon(), config(config) {}

Mounter::~Mounter()
{
#ifdef __FreeBSD__
	api::Posix::CheckError(::unlink(secret.NullTerminate()));
#endif
}

#ifdef __FreeBSD__
ext::String Mounter::secret(api::TheEnvironment.Get("HOME") + "/.nsmbrc");
#endif

void Mounter::load()
{
	_synchronized (Spectre2::sharesLock)
		Spectre2::shares.Clear();

	_synchronized (Share::passwordsLock)
		Share::passwords.Clear();

	_H<xml::Document> document(xml::Parse(config.GetPath()));
	_H<xml::Node> spectre(*document/"spectre");
#ifdef __FreeBSD__
	SecretFileWriter out(secret);
	ios::FormatWriter fout(out);
#endif

	_foreach (const xml::NodeSet, host_, *spectre/"host")
	{
		ext::String host(**host_/"name");

		_foreach (const xml::NodeSet, share, **host_/"share")
		{
			ext::String name(**share/"name"), owner(**share/"owner"), user(**share/"user"), group(**share/"group");

			_synchronized (Spectre2::sharesLock)
				Spectre2::shares.Insert(Share(host, name, owner, user, group));
		}

#ifdef __FreeBSD__
		::addrinfo* info;

		api::Posix::CheckGaiError(::getaddrinfo(host.NullTerminate(), NULL, NULL, &info));

		::sockaddr_in& sock(*reinterpret_cast< ::sockaddr_in*>(info->ai_addr));
		ext::Buffer buffer(128);

		fout << "[" << host << "]" << ios::NewLine << "addr=" << ::inet_ntop(sock.sin_family, &sock.sin_addr, buffer.Begin(), buffer.GetSize()) << ios::NewLine;

		::freeaddrinfo(info);
#endif
	}

	_synchronized (Spectre2::sharesLock)
		Spectre2::shares.Output(api::Cout);
	
	loaded = true;
}

void Mounter::run()
{
	ext::ThreadSet<> workers;

	_synchronized (Spectre2::sharesLock) _foreach (const ext::RedBlackSet<Share>, share, Spectre2::shares) if (!share->mounted() && share->mountable())
	{
		api::Cerr << "STUB: mount " << *share << ios::NewLine;
	}

	workers.Join();

	::sleep(5);
}