Added "examples/common.inc" file that was ommited during initial import.

examples/common.inc

@@ -0,0 +1,312 @@
+//
+// VMime library (http://vmime.sourceforge.net)
+// Copyright (C) 2002-2004 Vincent Richard <vincent@vincent-richard.net>
+//
+// 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, write to the Free Software
+// Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+//
+
+#include <ctime>
+
+#include <unistd.h>
+#include <locale.h>
+#include <langinfo.h>
+
+#include <sys/socket.h>
+#include <arpa/inet.h>
+#include <sys/types.h>
+#include <netinet/in.h>
+#include <netdb.h>
+#include <fcntl.h>
+
+#include <pthread.h>
+
+#include <sched.h>
+
+#include "../src/vmime"
+
+
+class my_socket : public vmime::messaging::socket
+{
+private:
+
+	char m_buffer[65536];
+	int m_desc;
+
+public:
+
+	my_socket()
+		: m_desc(0)
+	{
+		if ((m_desc = ::socket(AF_INET, SOCK_STREAM, 0)) == -1)
+		{
+			// Error
+		}
+
+		//::fcntl(m_desc, F_SETFL, ::fcntl(m_desc, F_GETFL, 0) | O_NONBLOCK);
+	}
+
+	~my_socket()
+	{
+		::close(m_desc);
+	}
+
+	void connect(const vmime::string& address, const vmime::port_t port)
+	{
+		::sockaddr_in addr;
+
+		memset(&addr, 0, sizeof(addr));
+
+		addr.sin_family = AF_INET;
+		addr.sin_port = ::htons((unsigned short) port);
+		addr.sin_addr.s_addr = ::inet_addr(address.c_str());
+
+		std::cout << "Connecting to '" << address << "' port " << port << "..." << std::endl;
+
+		if (addr.sin_addr.s_addr == (::in_addr_t) -1)
+		{
+			::hostent* hostInfo = (hostent*) ::gethostbyname(address.c_str());
+
+			if (hostInfo == NULL)
+			{
+				// Error: cannot resolve address
+				throw vmime::exceptions::connection_error();
+			}
+
+			bcopy(hostInfo->h_addr, (char*) &addr.sin_addr, hostInfo->h_length);
+
+			std::cout << "Address resolved to " << inet_ntoa(addr.sin_addr) << std::endl;
+		}
+		else
+		{
+			// Error: cannot resolve address
+			throw vmime::exceptions::connection_error();
+		}
+
+		std::cout << std::endl;
+
+		if (::connect(m_desc, (sockaddr*) &addr, sizeof(addr)) == -1)
+		{
+			// Error
+			throw vmime::exceptions::connection_error();
+		}
+	}
+
+	const bool isConnected() const
+	{
+		return (m_desc != 0);
+	}
+
+	void disconnect()
+	{
+		::shutdown(m_desc, SHUT_RDWR);
+	}
+
+	void receive(vmime::string& buffer)
+	{
+		::ssize_t ret = ::recv(m_desc, m_buffer, sizeof(m_buffer), 0);
+
+		if (ret == -1)
+		{
+			// Error or no data
+			return;
+		}
+		else if (ret > 0)
+		{
+			buffer = vmime::string(m_buffer, ret);
+
+#if DEBUG_SOCKET_IO
+			std::cout << "S: " << buffer;
+			std::cout.flush();
+#endif
+		}
+	}
+
+	const int receiveRaw(char* buffer, const int count)
+	{
+		::ssize_t ret = ::recv(m_desc, buffer, count, 0);
+
+		if (ret == -1)
+		{
+			// Error or no data
+			return (0);
+		}
+		else
+		{
+#if DEBUG_SOCKET_IO
+			std::cout << "S: " << vmime::string(buffer, count);
+			std::cout.flush();
+#endif
+
+			return (ret);
+		}
+	}
+
+	void send(const vmime::string& buffer)
+	{
+#if DEBUG_SOCKET_IO
+		std::cout << "C: " << buffer;
+		std::cout.flush();
+#endif
+
+		::send(m_desc, buffer.data(), buffer.length(), 0);
+	}
+
+	void sendRaw(const char* buffer, const int count)
+	{
+#if DEBUG_SOCKET_IO
+		std::cout << "C: " << vmime::string(buffer, count);
+		std::cout.flush();
+#endif
+
+		::send(m_desc, buffer, count, 0);
+	}
+};
+
+
+class my_socket_factory : public vmime::messaging::socketFactory
+{
+public:
+
+	vmime::messaging::socket* create()
+	{
+		return (new my_socket);
+	}
+};
+
+
+
+/*
+
+TODO: file, fileSystemFactory
+
+
+
+#include <errno.h>
+
+
+
+Erreurs pour fileIterator [ opendir() ] :
+===> switch + exception appropriée (exceptions::fileIteratorException ?)
+
+* EACESS Permission denied.
+
+* EMFILE Too many file descriptors in use by process.
+
+* ENFILE Too many files are currently open in the system.
+
+* ENOENT Directory  does  not  exist,  or  name  is an empty string.
+
+* ENOMEM Insufficient memory to complete the operation.
+
+* ENOTDIR Name is not a directory.
+
+*/
+
+
+
+class my_handler : public vmime::platformDependant::handler
+{
+private:
+
+	my_socket_factory* m_sf;
+
+public:
+
+	my_handler()
+		: m_sf(new my_socket_factory)
+	{
+	}
+
+	~my_handler()
+	{
+		delete (m_sf);
+	}
+
+	const unsigned int getUnixTime() const
+	{
+		return ::std::time(NULL);
+	}
+
+	// WARNING: this is not thread-safe!
+	const vmime::datetime getCurrentLocalTime() const
+	{
+		const ::std::time_t t(::std::time(NULL));
+
+		// Get the local time
+		::std::tm local = *::std::localtime(&t);
+
+		// Get the UTC time
+		::std::tm gmt = *::std::gmtime(&t);
+
+		// "A negative value for tm_isdst causes mktime() to attempt
+		//  to determine whether Daylight Saving Time is in effect
+		//  for the specified time."
+		local.tm_isdst = -1;
+		gmt.tm_isdst = -1;
+
+		// Calculate the difference (in seconds)
+		const vmime::datetime::comp_t diff = ::std::mktime(&local) - ::std::mktime(&gmt);
+
+		// Return the date
+		return vmime::datetime(local.tm_year + 1900, local.tm_mon + 1, local.tm_mday,
+		                       local.tm_hour, local.tm_min, local.tm_sec, diff / 60);  // minutes needed
+	}
+
+	const vmime::charset getLocaleCharset() const
+	{
+		vmime::string prevLocale(::setlocale(::LC_ALL, ""));
+		vmime::charset ch(::nl_langinfo(::CODESET));
+		::setlocale(::LC_ALL, prevLocale.c_str());
+
+		return (ch);
+	}
+
+	const vmime::string getHostName() const
+	{
+		// TODO: you should return the real (unique) host name
+		return "localhost";
+	}
+
+	const unsigned int getProcessId() const
+	{
+		return getpid();
+	}
+
+	vmime::messaging::socketFactory* getSocketFactory(const vmime::string& name) const
+	{
+		return m_sf;
+	}
+
+	vmime::messaging::timeoutHandlerFactory* getTimeoutHandlerFactory(const vmime::string& name) const
+	{
+		// Not used for now
+		return NULL;
+	}
+
+	vmime::utility::fileSystemFactory* getFileSystemFactory() const
+	{
+		// TODO
+		return NULL;
+	}
+
+	void wait() const
+	{
+		//::sched_yield();
+		std::cout << "WAIT" << std::endl;
+		sleep(1);
+	}
+};
+
+