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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
/*
* qtmaildir - a Qt6 mail client for notmuch-indexed Maildirs
* Copyright (C) 2026 Danilo M. <danix@danix.xyz>
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License version 2 as
* published by the Free Software Foundation.
*
* 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/
#include <QtTest>
#include <QFile>
#include <QSignalSpy>
#include <QTemporaryDir>
#include "calendarsync.h"
namespace {
/// A script that appends a line to `log` each run and exits with `code`.
///
/// \p sleepSeconds keeps the run alive long enough for a second schedule() to
/// land while it is still in progress, which is the queued-run path.
QString script(const QTemporaryDir &dir, int code, double sleepSeconds = 0)
{
const QString path = dir.filePath(QStringLiteral("sync.sh"));
const QString sleep = sleepSeconds > 0
? QStringLiteral("sleep %1\n").arg(sleepSeconds) : QString();
QFile f(path);
f.open(QIODevice::WriteOnly);
f.write(QStringLiteral("#!/bin/sh\necho run >> %1\n%2echo output\nexit %3\n")
.arg(dir.filePath(QStringLiteral("log")), sleep)
.arg(code).toUtf8());
f.close();
f.setPermissions(f.permissions() | QFileDevice::ExeOwner);
return path;
}
int runs(const QTemporaryDir &dir)
{
QFile f(dir.filePath(QStringLiteral("log")));
return f.open(QIODevice::ReadOnly) ? f.readAll().count('\n') : 0;
}
} // namespace
class TestCalendarSync : public QObject
{
Q_OBJECT
private slots:
void aBurstOfWritesRunsOnce();
void reportsFailureWithTheOutput();
void aWriteDuringARunQueuesOneMore();
void anEmptyCommandNeverRuns();
};
void TestCalendarSync::aBurstOfWritesRunsOnce()
{
QTemporaryDir dir;
CalendarSync sync(script(dir, 0), 50);
QSignalSpy finished(&sync, &CalendarSync::finished);
sync.schedule();
sync.schedule();
sync.schedule();
QVERIFY(finished.wait(5000));
QCOMPARE(finished.first().at(0).toBool(), true);
QTest::qWait(200); // nothing else is queued, so nothing else may run
QCOMPARE(runs(dir), 1);
}
void TestCalendarSync::reportsFailureWithTheOutput()
{
QTemporaryDir dir;
CalendarSync sync(script(dir, 3), 0);
QSignalSpy finished(&sync, &CalendarSync::finished);
sync.schedule();
QVERIFY(finished.wait(5000));
QCOMPARE(finished.first().at(0).toBool(), false);
QVERIFY(finished.first().at(1).toString().contains(QStringLiteral("output")));
}
void TestCalendarSync::aWriteDuringARunQueuesOneMore()
{
QTemporaryDir dir;
// The run sleeps, so the second schedule() below lands while it is still
// in progress and must queue exactly one more run, not drop the write and
// not run endlessly.
CalendarSync sync(script(dir, 0, 0.3), 0);
QSignalSpy started(&sync, &CalendarSync::started);
QSignalSpy finished(&sync, &CalendarSync::finished);
sync.schedule();
QVERIFY(started.wait(5000)); // positive wait: the first run is underway
sync.schedule(); // a write during that run
QVERIFY(finished.wait(5000)); // the first run finishes
QVERIFY(finished.wait(5000)); // the one queued run finishes
QCOMPARE(finished.count(), 2);
QTest::qWait(200); // nothing else is queued
QCOMPARE(runs(dir), 2);
}
void TestCalendarSync::anEmptyCommandNeverRuns()
{
CalendarSync sync(QString(), 0);
QSignalSpy started(&sync, &CalendarSync::started);
QSignalSpy finished(&sync, &CalendarSync::finished);
sync.schedule();
QTest::qWait(100);
QCOMPARE(started.count(), 0);
QCOMPARE(finished.count(), 0);
}
QTEST_MAIN(TestCalendarSync)
#include "test_calendarsync.moc"
|
