repos/CCSFinger/CCSFinger.cpp

// Douglas Thrift
//
// CCS Computer Science
//
// Windows Finger Daemon

#include <windows.h>
#include <lm.h>
#include <signal.h>
#include <tchar.h>
#include <shlobj.h>
#include <wtsapi32.h>

#include <algorithm>
#include <cctype>
#include <cwctype>
#include <fstream>
#include <iomanip>
#include <iostream>
#include <map>
#include <sstream>
#include <string>
#include <vector>

std::ostream &operator<<(std::ostream &out, WTS_CONNECTSTATE_CLASS status)
{
        switch (status)
        {
        case WTSActive:
                return out << "Active";

        case WTSConnected:
                return out << "Connected";

        case WTSConnectQuery:
                return out << "Connecting";

        case WTSShadow:
                return out << "Shadowing";

        case WTSDisconnected:
                return out << "Disconnected";

        case WTSIdle:
                return out << "Idle";

        case WTSListen:
                return out << "Listening";

        case WTSReset:
                return out << "Reseting";

        case WTSDown:
                return out << "Down";

        case WTSInit:
                return out << "Initializing";

        default:
                return out << "Unknown";
        }
}

inline std::string Utf8(const std::wstring &wstring)
{
        std::string string(::WideCharToMultiByte(CP_UTF8, 0, wstring.data(), int(wstring.size()), NULL, 0, NULL, NULL), '\0');

        ::WideCharToMultiByte(CP_UTF8, 0, wstring.data(), int(wstring.size()), const_cast<LPSTR>(string.data()), int(string.size()), NULL, NULL);

        return string;
}

class Finger
{
        class Login
        {
                std::wstring login;
                mutable USER_INFO_11 *info;

                inline void GetInfo() const
                {
                        if (!info)
                                ::NetUserGetInfo(NULL, login.c_str(), 11, reinterpret_cast<LPBYTE *>(&info));
                }
        public:
                std::string session;
                DWORD id;
                WTS_CONNECTSTATE_CLASS status;

                Login(const std::wstring &login, DWORD id, const std::wstring &session, WTS_CONNECTSTATE_CLASS status) : login(login), info(NULL), id(id), session(Utf8(session)), status(status)
                {
                }

                ~Login()
                {
                        if (!info)
                                ::NetApiBufferFree(info);
                }

                std::string GetShortName() const
                {
                        GetInfo();

                        return Utf8(std::wstring(info->usri11_full_name).substr(0, 20));
                }

                std::string GetName() const
                {
                        GetInfo();

                        return Utf8(info->usri11_full_name);
                }

                std::string GetDirectory() const
                {
                        HANDLE token;

                        if (::WTSQueryUserToken(id, &token))
                        {
                                TCHAR directory[MAX_PATH];

                                ::SHGetFolderPath(NULL, CSIDL_PROFILE, token, SHGFP_TYPE_CURRENT, directory);
                                ::CloseHandle(token);

                                return Utf8(directory);
                        }
                        else
                        {
                                TCHAR directory_[MAX_PATH];

                                ::SHGetFolderPath(NULL, CSIDL_PROFILE, NULL, SHGFP_TYPE_CURRENT, directory_);

                                std::wstring directory(directory_);

                                directory.replace(directory.rfind('\\') + 1, std::wstring::npos, login);

                                return Utf8(directory);
                        }
                }
        };

        std::ostringstream stream;
        std::multimap<std::string, Login> logins;

        void Full()
        {
                for (std::multimap<std::string, Login>::const_iterator login(logins.begin()); login != logins.end(); login = logins.upper_bound(login->first))
                {
                        std::string directory(login->second.GetDirectory());

                        stream << "Login: " << login->first << std::string(33 - login->first.size(), ' ') << "Name: " << login->second.GetName() << "\r\nDirectory: " << directory << "\r\n";

                        for (std::multimap<std::string, Login>::const_iterator login_(logins.lower_bound(login->first)); login_ != logins.upper_bound(login->first); ++login_)
                                stream << login_->second.status << ' ' << login_->second.session << ' ' << login_->second.id << "\r\n";

                        std::string files[] = { "\\.project", "\\.plan" };

                        for (std::string *file(files); file != files + sizeof (files) / sizeof (*file); ++file)
                        {
                                file->insert(0, directory);

                                std::ifstream in(file->c_str());

                                if (!in.is_open())
                                        continue;

                                switch (file - files)
                                {
                                case 0:
                                        stream << "Project:\r\n";

                                        break;
                                case 1:
                                        stream << "Plan:\r\n";
                                }

                                std::string buffer;

                                while (std::getline(in, buffer))
                                        stream << buffer << std::endl;
                        }
                }
        }

public:
        Finger(bool full)
        {
                PWTS_SESSION_INFO sessions;
                DWORD count;

                ::WTSEnumerateSessions(WTS_CURRENT_SERVER_HANDLE, 0, 1, &sessions, &count);

                for (PWTS_SESSION_INFO session(sessions); session != sessions + count; ++session)
                {
                        LPTSTR name;
                        DWORD size;

                        ::WTSQuerySessionInformation(WTS_CURRENT_SERVER_HANDLE, session->SessionId, WTSUserName, &name, &size);

                        std::wstring name_(name);

                        ::WTSFreeMemory(name);

                        if (!name_.empty())
                        {
                                std::transform(name_.begin(), name_.end(), name_.begin(), std::towlower);

                                LPTSTR session_;

                                ::WTSQuerySessionInformation(WTS_CURRENT_SERVER_HANDLE, session->SessionId, WTSWinStationName, &session_, &size);

                                Login login(name_, session->SessionId, session_, session->State);

                                ::WTSFreeMemory(session_);

                                logins.insert(std::make_pair(Utf8(name_), login));
                        }
                }

                ::WTSFreeMemory(sessions);

                if (!full)
                {
                        stream << "Login" << std::string(11, ' ') << "Name" << std::string(17, ' ') << "Id     Session       Status\r\n";

                        for (std::multimap<std::string, Login>::const_iterator login(logins.begin()); login != logins.end(); ++login)
                                stream << login->first << std::string(16 - login->first.size(), ' ') << login->second.GetShortName() << std::string(21 - login->second.GetShortName().size(), ' ') << std::setw(5) << std::left << login->second.id << "  " << login->second.session << std::string(14 - login->second.session.size(), ' ') << login->second.status << "\r\n";
                }
                else
                        Full();
        }

        Finger(const std::string &name)
        {
                //NetQueryDisplayInformation
                //NetUserGetInfo
        }

        inline operator std::string()
        {
                return stream.str();
        }
};

LPTSTR name;
SERVICE_STATUS status;
SERVICE_STATUS_HANDLE handle;
HANDLE stop;
WSADATA data;
std::vector<HANDLE> threads;

void FingerDaemon();
DWORD WINAPI FingerListen(LPVOID server_);
DWORD WINAPI FingerDo(LPVOID client_);
void FingerStop(int);
void WINAPI FingerMain(DWORD argc, LPTSTR *argv);
void WINAPI FingerControl(DWORD control);

int _tmain(int argc, TCHAR *argv[])
{
        SERVICE_TABLE_ENTRY entry[] = { { TEXT("CCSFinger"), LPSERVICE_MAIN_FUNCTION(FingerMain) }, { NULL, NULL } };

        if (!::StartServiceCtrlDispatcher(entry))
        {
                DWORD error(::GetLastError());

                switch (error)
                {
                case ERROR_FAILED_SERVICE_CONTROLLER_CONNECT:
                        goto go;

                case ERROR_INVALID_DATA:
                        std::cerr << "ERROR_INVALID_DATA" << std::endl;

                        break;

                case ERROR_SERVICE_ALREADY_RUNNING:
                        std::cerr << "ERROR_SERVICE_ALREADY_RUNNING" << std::endl;

                        break;

                default:
                        std::cerr << error << std::endl;
                }

                return 1;
        }

        return 0;

go:
        for (int index(1); index != argc; ++index)
        {
                std::wstring arg(argv[index]);

                if (arg == TEXT("create"))
                {
                        TCHAR file[MAX_PATH];

                        ::GetModuleFileName(NULL, file, MAX_PATH);

                        SC_HANDLE manager(::OpenSCManager(NULL, SERVICES_ACTIVE_DATABASE, SC_MANAGER_CREATE_SERVICE)), service(::CreateService(manager, TEXT("CCSFinger"), TEXT("CCS Finger Daemon"), 0, SERVICE_WIN32_OWN_PROCESS, SERVICE_DEMAND_START, SERVICE_ERROR_NORMAL, file, NULL, NULL, TEXT("TermService\0"), NULL, TEXT("")));

                        if (!service)
                                std::cerr << ::GetLastError() << std::endl;
                        else
                                ::CloseServiceHandle(service);

                        ::CloseServiceHandle(manager);

                        return 0;
                }
                else if (arg == TEXT("delete"))
                {
                        SC_HANDLE manager(::OpenSCManager(NULL, SERVICES_ACTIVE_DATABASE, DELETE)), service(::OpenService(manager, TEXT("CCSFinger"), DELETE));

                        if (!::DeleteService(service))
                                std::cerr << ::GetLastError() << std::endl;

                        ::CloseServiceHandle(service);
                        ::CloseServiceHandle(manager);

                        return 0;
                }
        }

        stop = ::CreateEvent(NULL, TRUE, FALSE, NULL);

        ::signal(SIGINT, FingerStop);

        try
        {
                FingerDaemon();
        }
        catch (...) {}

        return 0;
}

void FingerDaemon()
{
        ::WSAStartup(MAKEWORD(2, 0), &data);

        //

        SOCKET server(::socket(PF_INET, SOCK_STREAM, IPPROTO_TCP));
        SOCKADDR_IN service;
        
        service.sin_family = AF_INET;
        service.sin_addr.s_addr = inet_addr("0.0.0.0");
        service.sin_port = htons(79);

        ::bind(server, (SOCKADDR *)(&service), sizeof (service));
        ::listen(server, SOMAXCONN);

        threads.push_back(::CreateThread(NULL, 0, FingerListen, &server, 0, NULL));

        while(::WaitForSingleObject(stop, 1000) != WAIT_OBJECT_0);

        //

        ::closesocket(server);

        ::WSACleanup();
}

DWORD WINAPI FingerListen(LPVOID server_)
{
        SOCKET &server(*reinterpret_cast<SOCKET *>(server_));

        while (true)
        {
                SOCKET client(accept(server, NULL, NULL));

                threads.push_back(::CreateThread(NULL, 0, FingerDo, &client, 0, NULL));
        }

        return 0;
}

DWORD WINAPI FingerDo(LPVOID client_)
{
        SOCKET &client(*reinterpret_cast<SOCKET *>(client_));
        char buffer[1024];
        std::istringstream stream(std::string(buffer, ::recv(client, buffer, sizeof buffer, 0)));
        std::string line;

        std::getline(stream, line);

        stream.str(line);

        std::getline(stream, line, '\r');

        stream.str(line);

        std::string name;
        bool full(false);

        while (stream >> line)
                if (line == "/W")
                        full = true;
                else
                        name = line;

        std::string finger(name.empty() ? Finger(full) : Finger(name));

        ::send(client, finger.data(), int(finger.size()), 0);
        ::closesocket(client);

        return 0;
}

void FingerStop(int)
{
        ::SetEvent(stop);
}

void WINAPI FingerMain(DWORD argc, LPTSTR *argv)
{
        name = argv[0];
        handle = RegisterServiceCtrlHandler(name, LPHANDLER_FUNCTION(FingerControl));
        stop = ::CreateEvent(NULL, TRUE, FALSE, NULL);

        //

        status.dwControlsAccepted = SERVICE_ACCEPT_STOP | SERVICE_ACCEPT_SHUTDOWN;
        status.dwServiceType = SERVICE_WIN32_OWN_PROCESS;
        status.dwServiceSpecificExitCode = 0;
        status.dwCurrentState = SERVICE_RUNNING;
        status.dwWin32ExitCode = NO_ERROR;
        status.dwCheckPoint = 0;
        status.dwWaitHint = 0;

        ::SetServiceStatus(handle, &status);

        try
        {
                FingerDaemon();
        }
        catch (...) {}

        status.dwCurrentState = SERVICE_STOPPED;
        status.dwWin32ExitCode = NO_ERROR;
        status.dwCheckPoint = 0;
        status.dwWaitHint = 0;

        ::SetServiceStatus(handle, &status);
}

void WINAPI FingerControl(DWORD control)
{
        switch (control)
        {
        case SERVICE_CONTROL_STOP:
        case SERVICE_CONTROL_SHUTDOWN:
                status.dwCurrentState = SERVICE_STOP_PENDING;

                ::SetEvent(stop);

                break;

        case SERVICE_CONTROL_INTERROGATE:
                break;
        }

        ::SetServiceStatus(handle, &status);
}
Revision:	618
Committed:	2005-12-13T02:23:55-08:00 (19 years, 6 months ago) by douglas
File size:	10606 byte(s)
Log Message:	That's enough for tonight.
#	User	Rev	Content
1	douglas	594	// Douglas Thrift
2			//
3			// CCS Computer Science
4			//
5			// Windows Finger Daemon
6
7			#include <windows.h>
8	douglas	618	#include <lm.h>
9			#include <signal.h>
10	douglas	594	#include <tchar.h>
11	douglas	618	#include <shlobj.h>
12	douglas	608	#include <wtsapi32.h>
13	douglas	594
14	douglas	616	#include <algorithm>
15	douglas	618	#include <cctype>
16			#include <cwctype>
17			#include <fstream>
18			#include <iomanip>
19	douglas	595	#include <iostream>
20	douglas	618	#include <map>
21			#include <sstream>
22	douglas	608	#include <string>
23	douglas	609	#include <vector>
24	douglas	595
25	douglas	615	std::ostream &operator<<(std::ostream &out, WTS_CONNECTSTATE_CLASS status)
26			{
27			switch (status)
28			{
29			case WTSActive:
30			return out << "Active";
31
32			case WTSConnected:
33			return out << "Connected";
34
35			case WTSConnectQuery:
36			return out << "Connecting";
37
38			case WTSShadow:
39			return out << "Shadowing";
40
41			case WTSDisconnected:
42			return out << "Disconnected";
43
44			case WTSIdle:
45			return out << "Idle";
46
47			case WTSListen:
48			return out << "Listening";
49
50			case WTSReset:
51			return out << "Reseting";
52
53			case WTSDown:
54			return out << "Down";
55
56			case WTSInit:
57			return out << "Initializing";
58
59			default:
60			return out << "Unknown";
61			}
62			}
63
64	douglas	610	inline std::string Utf8(const std::wstring &wstring)
65			{
66	douglas	613	std::string string(::WideCharToMultiByte(CP_UTF8, 0, wstring.data(), int(wstring.size()), NULL, 0, NULL, NULL), '\0');
67	douglas	610
68	douglas	613	::WideCharToMultiByte(CP_UTF8, 0, wstring.data(), int(wstring.size()), const_cast<LPSTR>(string.data()), int(string.size()), NULL, NULL);
69	douglas	610
70			return string;
71			}
72
73			class Finger
74			{
75	douglas	616	class Login
76	douglas	613	{
77	douglas	616	std::wstring login;
78			mutable USER_INFO_11 *info;
79
80			inline void GetInfo() const
81			{
82	douglas	617	if (!info)
83			::NetUserGetInfo(NULL, login.c_str(), 11, reinterpret_cast<LPBYTE *>(&info));
84	douglas	616	}
85			public:
86			std::string session;
87	douglas	615	DWORD id;
88			WTS_CONNECTSTATE_CLASS status;
89	douglas	616
90			Login(const std::wstring &login, DWORD id, const std::wstring &session, WTS_CONNECTSTATE_CLASS status) : login(login), info(NULL), id(id), session(Utf8(session)), status(status)
91	douglas	613	{
92	douglas	616	}
93	douglas	614
94	douglas	616	~Login()
95			{
96			if (!info)
97			::NetApiBufferFree(info);
98	douglas	613	}
99	douglas	615
100	douglas	617	std::string GetShortName() const
101	douglas	613	{
102	douglas	617	GetInfo();
103	douglas	616
104			return Utf8(std::wstring(info->usri11_full_name).substr(0, 20));
105	douglas	613	}
106	douglas	617
107			std::string GetName() const
108			{
109			GetInfo();
110
111			return Utf8(info->usri11_full_name);
112			}
113
114			std::string GetDirectory() const
115			{
116			HANDLE token;
117
118			if (::WTSQueryUserToken(id, &token))
119			{
120			TCHAR directory[MAX_PATH];
121
122			::SHGetFolderPath(NULL, CSIDL_PROFILE, token, SHGFP_TYPE_CURRENT, directory);
123			::CloseHandle(token);
124
125			return Utf8(directory);
126			}
127			else
128			{
129			TCHAR directory_[MAX_PATH];
130
131			::SHGetFolderPath(NULL, CSIDL_PROFILE, NULL, SHGFP_TYPE_CURRENT, directory_);
132
133			std::wstring directory(directory_);
134
135			directory.replace(directory.rfind('\\') + 1, std::wstring::npos, login);
136
137			return Utf8(directory);
138			}
139			}
140	douglas	613	};
141	douglas	616
142	douglas	610	std::ostringstream stream;
143	douglas	616	std::multimap<std::string, Login> logins;
144	douglas	610
145	douglas	616	void Full()
146			{
147			for (std::multimap<std::string, Login>::const_iterator login(logins.begin()); login != logins.end(); login = logins.upper_bound(login->first))
148			{
149	douglas	618	std::string directory(login->second.GetDirectory());
150
151			stream << "Login: " << login->first << std::string(33 - login->first.size(), ' ') << "Name: " << login->second.GetName() << "\r\nDirectory: " << directory << "\r\n";
152
153			for (std::multimap<std::string, Login>::const_iterator login_(logins.lower_bound(login->first)); login_ != logins.upper_bound(login->first); ++login_)
154			stream << login_->second.status << ' ' << login_->second.session << ' ' << login_->second.id << "\r\n";
155
156			std::string files[] = { "\\.project", "\\.plan" };
157
158			for (std::string file(files); file != files + sizeof (files) / sizeof (file); ++file)
159			{
160			file->insert(0, directory);
161
162			std::ifstream in(file->c_str());
163
164			if (!in.is_open())
165			continue;
166
167			switch (file - files)
168			{
169			case 0:
170			stream << "Project:\r\n";
171
172			break;
173			case 1:
174			stream << "Plan:\r\n";
175			}
176
177			std::string buffer;
178
179			while (std::getline(in, buffer))
180			stream << buffer << std::endl;
181			}
182	douglas	616	}
183			}
184
185	douglas	610	public:
186			Finger(bool full)
187			{
188			PWTS_SESSION_INFO sessions;
189			DWORD count;
190
191	douglas	613	::WTSEnumerateSessions(WTS_CURRENT_SERVER_HANDLE, 0, 1, &sessions, &count);
192	douglas	610
193	douglas	613	for (PWTS_SESSION_INFO session(sessions); session != sessions + count; ++session)
194	douglas	610	{
195			LPTSTR name;
196			DWORD size;
197
198	douglas	613	::WTSQuerySessionInformation(WTS_CURRENT_SERVER_HANDLE, session->SessionId, WTSUserName, &name, &size);
199	douglas	610
200	douglas	616	std::wstring name_(name);
201
202			::WTSFreeMemory(name);
203
204			if (!name_.empty())
205	douglas	613	{
206	douglas	616	std::transform(name_.begin(), name_.end(), name_.begin(), std::towlower);
207
208	douglas	613	LPTSTR session_;
209	douglas	610
210	douglas	613	::WTSQuerySessionInformation(WTS_CURRENT_SERVER_HANDLE, session->SessionId, WTSWinStationName, &session_, &size);
211	douglas	611
212	douglas	616	Login login(name_, session->SessionId, session_, session->State);
213	douglas	610
214	douglas	613	::WTSFreeMemory(session_);
215
216	douglas	616	logins.insert(std::make_pair(Utf8(name_), login));
217	douglas	613	}
218	douglas	610	}
219
220	douglas	613	::WTSFreeMemory(sessions);
221
222			if (!full)
223			{
224	douglas	616	stream << "Login" << std::string(11, ' ') << "Name" << std::string(17, ' ') << "Id Session Status\r\n";
225	douglas	613
226	douglas	616	for (std::multimap<std::string, Login>::const_iterator login(logins.begin()); login != logins.end(); ++login)
227	douglas	617	stream << login->first << std::string(16 - login->first.size(), ' ') << login->second.GetShortName() << std::string(21 - login->second.GetShortName().size(), ' ') << std::setw(5) << std::left << login->second.id << " " << login->second.session << std::string(14 - login->second.session.size(), ' ') << login->second.status << "\r\n";
228	douglas	613	}
229	douglas	616	else
230			Full();
231	douglas	610	}
232
233			Finger(const std::string &name)
234			{
235	douglas	612	//NetQueryDisplayInformation
236			//NetUserGetInfo
237	douglas	610	}
238
239			inline operator std::string()
240			{
241			return stream.str();
242			}
243			};
244
245	douglas	595	LPTSTR name;
246	douglas	594	SERVICE_STATUS status;
247			SERVICE_STATUS_HANDLE handle;
248	douglas	595	HANDLE stop;
249	douglas	594	WSADATA data;
250	douglas	609	std::vector<HANDLE> threads;
251	douglas	594
252	douglas	596	void FingerDaemon();
253	douglas	609	DWORD WINAPI FingerListen(LPVOID server_);
254			DWORD WINAPI FingerDo(LPVOID client_);
255	douglas	596	void FingerStop(int);
256	douglas	595	void WINAPI FingerMain(DWORD argc, LPTSTR *argv);
257			void WINAPI FingerControl(DWORD control);
258	douglas	594
259			int _tmain(int argc, TCHAR *argv[])
260			{
261	douglas	617	SERVICE_TABLE_ENTRY entry[] = { { TEXT("CCSFinger"), LPSERVICE_MAIN_FUNCTION(FingerMain) }, { NULL, NULL } };
262	douglas	594
263	douglas	613	if (!::StartServiceCtrlDispatcher(entry))
264	douglas	594	{
265	douglas	613	DWORD error(::GetLastError());
266	douglas	594
267			switch (error)
268			{
269			case ERROR_FAILED_SERVICE_CONTROLLER_CONNECT:
270	douglas	595	goto go;
271	douglas	594
272			case ERROR_INVALID_DATA:
273			std::cerr << "ERROR_INVALID_DATA" << std::endl;
274
275			break;
276
277			case ERROR_SERVICE_ALREADY_RUNNING:
278			std::cerr << "ERROR_SERVICE_ALREADY_RUNNING" << std::endl;
279
280			break;
281
282			default:
283			std::cerr << error << std::endl;
284			}
285
286			return 1;
287			}
288
289			return 0;
290	douglas	595
291			go:
292	douglas	617	for (int index(1); index != argc; ++index)
293			{
294			std::wstring arg(argv[index]);
295
296			if (arg == TEXT("create"))
297			{
298			TCHAR file[MAX_PATH];
299
300			::GetModuleFileName(NULL, file, MAX_PATH);
301
302			SC_HANDLE manager(::OpenSCManager(NULL, SERVICES_ACTIVE_DATABASE, SC_MANAGER_CREATE_SERVICE)), service(::CreateService(manager, TEXT("CCSFinger"), TEXT("CCS Finger Daemon"), 0, SERVICE_WIN32_OWN_PROCESS, SERVICE_DEMAND_START, SERVICE_ERROR_NORMAL, file, NULL, NULL, TEXT("TermService\0"), NULL, TEXT("")));
303
304			if (!service)
305			std::cerr << ::GetLastError() << std::endl;
306			else
307			::CloseServiceHandle(service);
308
309			::CloseServiceHandle(manager);
310
311			return 0;
312			}
313			else if (arg == TEXT("delete"))
314			{
315			SC_HANDLE manager(::OpenSCManager(NULL, SERVICES_ACTIVE_DATABASE, DELETE)), service(::OpenService(manager, TEXT("CCSFinger"), DELETE));
316
317			if (!::DeleteService(service))
318			std::cerr << ::GetLastError() << std::endl;
319
320			::CloseServiceHandle(service);
321			::CloseServiceHandle(manager);
322
323			return 0;
324			}
325			}
326
327	douglas	613	stop = ::CreateEvent(NULL, TRUE, FALSE, NULL);
328	douglas	608
329	douglas	613	::signal(SIGINT, FingerStop);
330	douglas	595
331	douglas	596	try
332			{
333			FingerDaemon();
334			}
335			catch (...) {}
336
337	douglas	609	return 0;
338	douglas	594	}
339
340	douglas	596	void FingerDaemon()
341	douglas	594	{
342	douglas	613	::WSAStartup(MAKEWORD(2, 0), &data);
343	douglas	594
344			//
345
346	douglas	613	SOCKET server(::socket(PF_INET, SOCK_STREAM, IPPROTO_TCP));
347	douglas	594	SOCKADDR_IN service;
348
349			service.sin_family = AF_INET;
350			service.sin_addr.s_addr = inet_addr("0.0.0.0");
351			service.sin_port = htons(79);
352
353	douglas	613	::bind(server, (SOCKADDR *)(&service), sizeof (service));
354			::listen(server, SOMAXCONN);
355	douglas	594
356	douglas	613	threads.push_back(::CreateThread(NULL, 0, FingerListen, &server, 0, NULL));
357	douglas	608
358	douglas	613	while(::WaitForSingleObject(stop, 1000) != WAIT_OBJECT_0);
359	douglas	594
360			//
361
362	douglas	613	::closesocket(server);
363	douglas	608
364	douglas	613	::WSACleanup();
365	douglas	596	}
366	douglas	594
367	douglas	609	DWORD WINAPI FingerListen(LPVOID server_)
368			{
369			SOCKET &server(reinterpret_cast<SOCKET >(server_));
370
371			while (true)
372			{
373			SOCKET client(accept(server, NULL, NULL));
374
375	douglas	613	threads.push_back(::CreateThread(NULL, 0, FingerDo, &client, 0, NULL));
376	douglas	609	}
377
378			return 0;
379			}
380
381			DWORD WINAPI FingerDo(LPVOID client_)
382			{
383			SOCKET &client(reinterpret_cast<SOCKET >(client_));
384	douglas	610	char buffer[1024];
385	douglas	613	std::istringstream stream(std::string(buffer, ::recv(client, buffer, sizeof buffer, 0)));
386	douglas	610	std::string line;
387	douglas	609
388	douglas	610	std::getline(stream, line);
389	douglas	609
390	douglas	610	stream.str(line);
391	douglas	609
392	douglas	610	std::getline(stream, line, '\r');
393	douglas	609
394	douglas	610	stream.str(line);
395	douglas	609
396	douglas	610	std::string name;
397			bool full(false);
398	douglas	609
399	douglas	610	while (stream >> line)
400			if (line == "/W")
401			full = true;
402			else
403			name = line;
404	douglas	609
405	douglas	610	std::string finger(name.empty() ? Finger(full) : Finger(name));
406	douglas	609
407	douglas	613	::send(client, finger.data(), int(finger.size()), 0);
408			::closesocket(client);
409	douglas	609
410			return 0;
411			}
412
413	douglas	596	void FingerStop(int)
414			{
415	douglas	613	::SetEvent(stop);
416	douglas	596	}
417
418			void WINAPI FingerMain(DWORD argc, LPTSTR *argv)
419			{
420			name = argv[0];
421			handle = RegisterServiceCtrlHandler(name, LPHANDLER_FUNCTION(FingerControl));
422	douglas	613	stop = ::CreateEvent(NULL, TRUE, FALSE, NULL);
423	douglas	596
424			//
425
426			status.dwControlsAccepted = SERVICE_ACCEPT_STOP \| SERVICE_ACCEPT_SHUTDOWN;
427			status.dwServiceType = SERVICE_WIN32_OWN_PROCESS;
428			status.dwServiceSpecificExitCode = 0;
429			status.dwCurrentState = SERVICE_RUNNING;
430			status.dwWin32ExitCode = NO_ERROR;
431			status.dwCheckPoint = 0;
432			status.dwWaitHint = 0;
433
434	douglas	613	::SetServiceStatus(handle, &status);
435	douglas	596
436			try
437			{
438			FingerDaemon();
439			}
440			catch (...) {}
441
442	douglas	595	status.dwCurrentState = SERVICE_STOPPED;
443	douglas	594	status.dwWin32ExitCode = NO_ERROR;
444			status.dwCheckPoint = 0;
445			status.dwWaitHint = 0;
446
447	douglas	613	::SetServiceStatus(handle, &status);
448	douglas	594	}
449
450			void WINAPI FingerControl(DWORD control)
451			{
452			switch (control)
453			{
454			case SERVICE_CONTROL_STOP:
455			case SERVICE_CONTROL_SHUTDOWN:
456			status.dwCurrentState = SERVICE_STOP_PENDING;
457
458	douglas	613	::SetEvent(stop);
459	douglas	594
460			break;
461
462			case SERVICE_CONTROL_INTERROGATE:
463			break;
464			}
465
466	douglas	613	::SetServiceStatus(handle, &status);
467	douglas	594	}