summaryrefslogtreecommitdiffstats
path: root/libmail/tmpaccountadd.C
blob: cf6b805abb41f585c258e82518ead799e8b19bfd (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
/*
** Copyright 2003-2008, Double Precision Inc.
**
** See COPYING for distribution information.
*/
#include "tmpaccount.H"
#include <errno.h>
#include <cstring>

using namespace std;

mail::tmpaccount::add::add(tmpaccount *accountArg, mail::callback &cbArg)
	: addMessage(accountArg), newFile(tmpfile()),
	  rfc2045p(rfc2045_alloc()), account(accountArg),
	  cb(cbArg)
{
}

mail::tmpaccount::add::~add()
{
	if (newFile)
		fclose(newFile);
	if (rfc2045p)
		rfc2045_free(rfc2045p);
}

void mail::tmpaccount::add::saveMessageContents(string s)
{
	if (newFile)
		if (fwrite(&s[0], s.size(), 1, newFile) != 1)
			; // Ignore gcc warning
	if (rfc2045p)
		rfc2045_parse(rfc2045p, &s[0], s.size());
}

void mail::tmpaccount::add::fail(string errmsg)
{
	cb.fail(errmsg);
	delete this;
}

void mail::tmpaccount::add::go()
{
	if (!checkServer())
		return;

	if (!newFile || fflush(newFile) < 0 || ferror(newFile) || !rfc2045p)
	{
		fail(strerror(errno));
		return;
	}

	rfc2045_parse_partial(rfc2045p);

	if (account->f)
	{
		fclose(account->f);
		account->f=NULL;
		vector< pair<size_t, size_t> > dummy;

		dummy.push_back( make_pair( (size_t)0, (size_t)0));
		if (account->folder_callback)
			account->folder_callback->messagesRemoved(dummy);
	}

	if (account->rfc2045p)
		rfc2045_free(account->rfc2045p);

	account->rfc2045p=rfc2045p;
	account->f=newFile;
	rfc2045p=NULL;
	newFile=NULL;

	if (account->folder_callback)
		account->folder_callback->newMessages();

	cb.success("Ok.");
	delete this;
}