ViewVC Help

View File | Revision Log | Show Annotations | Download File | View Changeset | Root Listing

root/proj/trunk/WinXPFAQPoll/Poller.cpp

Comparing trunk/WinXPFAQPoll/Poller.cpp (file contents):
Revision 120 by douglas, 2003-04-01T17:18:37-08:00 vs.
Revision 231 by douglas, 2003-08-05T20:36:00-07:00

#	Line 19 | Line 19 | Poller::Poller()
19		}
20		}
21
22	<	void Poller::poll(bool nodelete, const string& file)
22	>	Poller::~Poller()
23	>	{
24	>	if (!nodelete)
25	>	{
26	>	session->expunge();
27	>	}
28	>	}
29	>
30	>	void Poller::poll(bool nodelete, const string& file, bool approve)
31		{
32		this->nodelete = nodelete;
33		this->file = file;
34
35		load();
36
37	<	//
37	>	session->select('\"' + account.getMailbox() + '\"');
38
39	<	//      save();
39	>	if (!approve)
40	>	{
41	>	ballots();
42	>	}
43	>	else
44	>	{
45	>	approvals();
46	>	}
47	>
48	>	save();
49		}
50
51		void Poller::load()
#	Line 36 | Line 53 | void Poller::load()
53		ifstream fin(file.c_str());
54		if (!fin.is_open())
55		{
56	+	fin.clear();
57	+
58		ofstream fout(file.c_str());
59
60		fout << "_find_\n"
#	Line 62 | Line 81 | void Poller::load()
81		fin.open(file.c_str());
82		}
83
84	<	do
84	>	while (fin.good())
85		{
86		enum { FIND, HELP, IMPROVE } type;
87		string vote;
88		unsigned count;
89		string text;
90
91	<	getline(fin, vote, '=');
91	>	fin.peek() != '_' ? getline(fin, vote, '=') : getline(fin, vote);
92		if (debug) cerr << "vote = " << vote << "\n";
93
94		if (vote == "_find_")
#	Line 97 | Line 116 | void Poller::load()
116		fin.get();
117		}
118
119	+	if (fin.peek() == EOF) fin.get();
120	+
121		switch (type)
122		{
123		case FIND:
#	Line 183 | Line 204 | void Poller::load()
204		break;
205		}
206		}
186	–	while (fin.good());
207
208		fin.close();
209		}
#	Line 235 | Line 255 | void Poller::save()
255
256		fout.close();
257		}
258	+
259	+	void Poller::ballots()
260	+	{
261	+	istringstream search(session->search(string("ALL HEADER X-Mailer \"WinXPFA")
262	+	+ "QPoll 1.0 (Perl)\" SUBJECT \"Windows XP FAQ | Poll Ballot\" FROM \"W"
263	+	+ "indows XP FAQ | Poll\""));
264	+
265	+	while (search.good())
266	+	{
267	+	char next = search.peek();
268	+
269	+	if (isdigit(next)) break;
270	+
271	+	search.get();
272	+	}
273	+
274	+	while (search.good())
275	+	{
276	+	unsigned message;
277	+	search >> message;
278	+
279	+	if (debug) cerr << "message = " << message << "\n";
280	+	messages.push(message);
281	+
282	+	search.get();
283	+
284	+	while (!isdigit(search.peek()) && search.good())
285	+	{
286	+	search.get();
287	+	}
288	+	}
289	+
290	+	if (!messages.empty())
291	+	{
292	+	unsigned message = messages.front();
293	+	messages.pop();
294	+
295	+	ballot(message);
296	+	}
297	+
298	+	if (submits.size() > 0)
299	+	{
300	+	cout << "Sending submits..." << flush;
301	+
302	+	for (unsigned index = 0; index < submits.size(); index++)
303	+	{
304	+	submit(submits[index].first, submits[index].second);
305	+	}
306	+
307	+	submits.clear();
308	+
309	+	cout << "done.\n";
310	+	}
311	+	}
312	+
313	+	void Poller::ballot(unsigned message)
314	+	{
315	+	cout << "Checking message: " << message << "..." << flush;
316	+
317	+	ostringstream number;
318	+	number << message;
319	+
320	+	string junk;
321	+	istringstream buffer(session->fetch(number.str() + " BODY.PEEK[2]"));
322	+
323	+	if (session->successful() && buffer.str() == "* " + number.str() + " FETCH"
324	+	+ " (BODY[2] \"\")\n")
325	+	{
326	+	buffer.str(session->fetch(number.str() + " BODY.PEEK[TEXT]"));
327	+
328	+	for (unsigned index = 0; index < 25; index++)
329	+	{
330	+	getline(buffer, junk);
331	+	}
332	+	}
333	+
334	+	if (session->successful() && session->fetch(number.str() + " FLAGS").find(
335	+	"\\Deleted") == string::npos)
336	+	{
337	+	getline(buffer, junk);
338	+
339	+	bool approved = session->fetch(number.str() + " FLAGS").find("\\Flagge"
340	+	+ string("d")) != string::npos;
341	+
342	+	while (buffer.peek() != '\n' && buffer.good())
343	+	{
344	+	enum { FIND, HELP, IMPROVE } type;
345	+	string vote;
346	+
347	+	getline(buffer, vote);
348	+	if (debug) cerr << "vote = " << vote << "\n";
349	+
350	+	if (vote == "_find_")
351	+	{
352	+	type = FIND;
353	+	continue;
354	+	}
355	+	else if (vote == "_help_")
356	+	{
357	+	type = HELP;
358	+	continue;
359	+	}
360	+	else if (vote == "_improve_")
361	+	{
362	+	type = IMPROVE;
363	+	continue;
364	+	}
365	+
366	+	buffer.peek();
367	+
368	+	switch (type)
369	+	{
370	+	case FIND:
371	+	if (vote == "reply")
372	+	{
373	+	find.reply++;
374	+	}
375	+	else if (vote == "news")
376	+	{
377	+	find.news++;
378	+	}
379	+	else if (vote == "sig")
380	+	{
381	+	find.sig++;
382	+	}
383	+	else if (vote == "search")
384	+	{
385	+	find.search++;
386	+	}
387	+	else if (vote == "link")
388	+	{
389	+	find.link++;
390	+	}
391	+	else if (vote == "browse")
392	+	{
393	+	find.browse++;
394	+	}
395	+	else if (vote == "other")
396	+	{
397	+	find.other++;
398	+
399	+	string text;
400	+	getline(buffer, text);
401	+
402	+	if (approved)
403	+	{
404	+	find.approved.push_back(text);
405	+	}
406	+	else
407	+	{
408	+	find.approve.push_back(text);
409	+
410	+	submits.push_back(pair<string, string>("find", text));
411	+	}
412	+	}
413	+	break;
414	+	case HELP:
415	+	if (vote == "solved")
416	+	{
417	+	help.solved++;
418	+	}
419	+	else if (vote == "note")
420	+	{
421	+	help.note++;
422	+	}
423	+	else if (vote == "link")
424	+	{
425	+	help.link++;
426	+	}
427	+	else if (vote == "news")
428	+	{
429	+	help.news++;
430	+	}
431	+	else if (vote == "lazy")
432	+	{
433	+	help.lazy++;
434	+	}
435	+	break;
436	+	case IMPROVE:
437	+	if (vote == "nothing")
438	+	{
439	+	improve.nothing++;
440	+	}
441	+	else if (vote == "links")
442	+	{
443	+	improve.links++;
444	+	}
445	+	else if (vote == "suggest")
446	+	{
447	+	improve.suggest++;
448	+
449	+	string text;
450	+	getline(buffer, text);
451	+
452	+	if (approved)
453	+	{
454	+	improve.approved.push_back(text);
455	+	}
456	+	else
457	+	{
458	+	improve.approve.push_back(text);
459	+
460	+	submits.push_back(pair<string, string>("improve",
461	+	text));
462	+	}
463	+	}
464	+	break;
465	+	}
466	+	}
467	+
468	+	session->store(number.str() + " +FLAGS (\\Deleted)");
469	+
470	+	cout << "done.\n";
471	+	}
472	+	else
473	+	{
474	+	cout << "cancelled.\n";
475	+	}
476	+
477	+	if (!messages.empty())
478	+	{
479	+	unsigned message = messages.front();
480	+	messages.pop();
481	+
482	+	ballot(message);
483	+	}
484	+	}
485	+
486	+	void Poller::submit(const string& type, const string& text)
487	+	{
488	+	ostringstream message;
489	+
490	+	message << "From: \"Windows XP FAQ | Poll\" <" << account.getEmail()
491	+	<< ">\n"
492	+	<< "To: \"" << account.getName() << "\" <" << account.getEmail()
493	+	<< ">\n"
494	+	<< "Subject: Windows XP FAQ | Poll Submit\n"
495	+	<< "Content-Type: text/plain charset=\"us-ascii\"\n"
496	+	<< "Content-Transfer-Encoding: 7bit\n"
497	+	<< "X-Mailer: WinXPFAQPoll 1.0\n"
498	+	<< "X-WinXPFAQPoll-Submit-Type: " << type << "\n"
499	+	<< "X-WinXPFAQPoll-Submit-Text: " << text << "\n\n";
500	+
501	+	if (type == "find")
502	+	{
503	+	message << "How did you find this page?\n"
504	+	<< "    I arrived here by entirely different means:\n";
505	+	}
506	+	else if (type == "improve")
507	+	{
508	+	message << "How could I improve this site?\n"
509	+	<< "    I have my own completely insane suggestion:\n";
510	+	}
511	+
512	+	message << "    " << text << "\n\n"
513	+	<< "Flag this message to approve the voter\'s possibly objectionable\n"
514	+	<< "input or delete it to disapprove.\n\n"
515	+	<< "This message will be marked deleted when it is processed.\n";
516	+
517	+	ostringstream length;
518	+	length << (message.str().length() + 16);
519	+
520	+	session->append('\"' + account.getMailbox() + "\" {" + length.str() + '}',
521	+	message.str());
522	+
523	+	session->noop();
524	+	}
525	+
526	+	void Poller::approvals()
527	+	{
528	+	session->check();
529	+
530	+	unsigned index;
531	+
532	+	for (index = find.approve.size(); index > 0; index--)
533	+	{
534	+	cout << "Checking find: " << index << "..." << flush;
535	+
536	+	switch (approval("find", find.approve[index - 1]))
537	+	{
538	+	case true:
539	+	find.approved.push_back(find.approve[index - 1]);
540	+	case false:
541	+	find.approve.erase(find.approve.begin() + (index - 1));
542	+	break;
543	+	default:
544	+	break;
545	+	}
546	+	}
547	+
548	+	for (index = improve.approve.size(); index > 0; index--)
549	+	{
550	+	cout << "Checking improve: " << index << "..." << flush;
551	+
552	+	switch (approval("improve", improve.approve[index - 1]))
553	+	{
554	+	case true:
555	+	improve.approved.push_back(improve.approve[index - 1]);
556	+	case false:
557	+	improve.approve.erase(improve.approve.begin() + (index - 1));
558	+	break;
559	+	default:
560	+	break;
561	+	}
562	+	}
563	+
564	+	if (find.disapprove.size() > 0 || improve.disapprove.size() > 0)
565	+	{
566	+	cout << "Sending disapprovals..." << flush;
567	+
568	+	ostringstream message;
569	+
570	+	message << "From: \"Windows XP FAQ | Poll\" <" << account.getEmail()
571	+	<< ">\n"
572	+	<< "To: \"" << account.getName() << "\" <" << account.getEmail()
573	+	<< ">\n"
574	+	<< "Subject: Windows XP FAQ | Poll Disapprovals\n"
575	+	<< "Content-Type: multipart/mixed;\n"
576	+	<< "    boundary=\"----=_NextPart_WinXPFAQPoll_0\"\n"
577	+	<< "Content-Transfer-Encoding: 7bit\n"
578	+	<< "X-Mailer: WinXPFAQPoll 1.0\n\n"
579	+	<< "This is a multi-part message in MIME format.\n\n"
580	+	<< "------=_NextPart_WinXPFAQPoll_0\n"
581	+	<< "Content-Type: text/plain charset=\"us-ascii\"\n"
582	+	<< "Content-Transfer-Encoding: 7bit\n\n"
583	+	<< "Apparently these answers where disapproved:\n\n";
584	+
585	+	unsigned extra = 0;
586	+
587	+	for (index = 0; index < find.disapprove.size(); index++, extra += 4)
588	+	{
589	+	message << "How did you find this page?\n"
590	+	<< "    I arrived here by entirely different means:\n"
591	+	<< "    " << find.disapprove[index] << "\n\n";
592	+	}
593	+
594	+	for (index = 0; index < improve.disapprove.size(); index++, extra += 4)
595	+	{
596	+	message << "How could I improve this site?\n"
597	+	<< "    I have my own completely insane suggestion:\n"
598	+	<< "    " << improve.disapprove[index] << "\n\n";
599	+	}
600	+
601	+	message << "Make sure there were no errors.\n\n"
602	+	<< "------=_NextPart_WinXPFAQPoll_0\n"
603	+	<< "Content-Type: text/plain;\n"
604	+	<< "    name=\"disapprove.dat\"\n"
605	+	<< "Content-Transfer-Encoding: 7bit\n"
606	+	<< "Content-Disposition: attachment;\n"
607	+	<< "    filename=\"disapprove.dat\"\n\n";
608	+
609	+	if (find.disapprove.size() > 0)
610	+	{
611	+	message << "_find_\n";
612	+	extra++;
613	+	}
614	+
615	+	for (index = 0; index < find.disapprove.size(); index++, extra += 1)
616	+	{
617	+	message << find.disapprove[index] << "\n";
618	+	}
619	+
620	+	if (improve.disapprove.size() > 0)
621	+	{
622	+	message << "_improve_\n";
623	+	extra++;
624	+	}
625	+
626	+	for (index = 0; index < improve.disapprove.size(); index++, extra += 1)
627	+	{
628	+	message << improve.disapprove[index] << "\n";
629	+	}
630	+
631	+	message << "\n------=_NextPart_WinXPFAQPoll_0--\n";
632	+
633	+	ostringstream length;
634	+	length << (message.str().length() + 26 + extra);
635	+
636	+	session->append('\"' + account.getMailbox() + "\" {" + length.str() +
637	+	'}', message.str());
638	+
639	+	session->noop();
640	+
641	+	cout << "done.\n";
642	+	}
643	+	}
644	+
645	+	short Poller::approval(const string& type, const string& text)
646	+	{
647	+	short answer = -1;
648	+
649	+	istringstream search(session->search(string("ALL HEADER X-Mailer \"WinXPF")
650	+	+ "AQPoll 1.0\" SUBJECT \"Windows XP FAQ | Poll Submit\" FROM \"Window"
651	+	+ "s XP FAQ | Poll\" HEADER X-WinXPFAQPoll-Submit-Type \"" + type
652	+	+ "\" HEADER X-WinXPFAQPoll-Submit-Text \"" + text + '\"'));
653	+
654	+	while (search.good())
655	+	{
656	+	char next = search.peek();
657	+
658	+	if (isdigit(next)) break;
659	+
660	+	search.get();
661	+	}
662	+
663	+	if (search.good())
664	+	{
665	+	unsigned message;
666	+	search >> message;
667	+
668	+	if (debug) cerr << "message = " << message << "\n";
669	+
670	+	ostringstream number;
671	+	number << message;
672	+
673	+	if (session->fetch(number.str() + " FLAGS").find("\\Deleted") !=
674	+	string::npos)
675	+	{
676	+	answer = false;
677	+	}
678	+	else if (session->fetch(number.str() + " FLAGS").find("\\Flagged") !=
679	+	string::npos)
680	+	{
681	+	answer = true;
682	+
683	+	session->store(number.str() + " +FLAGS (\\Deleted)");
684	+	}
685	+	}
686	+	else
687	+	{
688	+	answer = false;
689	+	}
690	+
691	+	switch (answer)
692	+	{
693	+	case true:
694	+	cout << "approved.\n";
695	+	break;
696	+	case false:
697	+	if (type == "find")
698	+	{
699	+	find.disapprove.push_back(text);
700	+	}
701	+	else if (type == "improve")
702	+	{
703	+	improve.disapprove.push_back(text);
704	+	}
705	+	cout << "disapproved.\n";
706	+	break;
707	+	default:
708	+	cout << "cancelled.\n";
709	+	break;
710	+	}
711	+
712	+	return answer;
713	+	}

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines