summary refs log tree commit diff
diff options
context:
space:
mode:
authorJune McEnroe <june@causal.agency>2020-12-11 00:35:35 -0500
committerJune McEnroe <june@causal.agency>2020-12-11 00:35:35 -0500
commitfd6a4049039fe5191428dc2d37cee3274d65c94c (patch)
tree8b5b11825cd908f6edee773f77b46b3acdedbac4
parentAdd FILES section to README (diff)
downloadbubger-fd6a4049039fe5191428dc2d37cee3274d65c94c.tar.gz
bubger-fd6a4049039fe5191428dc2d37cee3274d65c94c.zip
Add imapIdle
Handles re-IDLE-ing every 29 minutes and returns the first response it
gets.
-rw-r--r--imap.c22
-rw-r--r--imap.h8
2 files changed, 30 insertions, 0 deletions
diff --git a/imap.c b/imap.c
index e21141d..e875595 100644
--- a/imap.c
+++ b/imap.c
@@ -28,6 +28,7 @@
 #include <err.h>
 #include <netdb.h>
 #include <netinet/in.h>
+#include <poll.h>
 #include <stdbool.h>
 #include <stdio.h>
 #include <stdlib.h>
@@ -265,3 +266,24 @@ struct Resp imapResp(struct IMAP *imap) {
 
 	return resp;
 }
+
+struct Resp imapIdle(struct IMAP *imap, enum Atom tag) {
+	for (;;) {
+		fprintf(imap->w, "%s IDLE\r\n", Atoms[tag]);
+		struct Resp resp = imapResp(imap);
+		if (resp.tag != AtomContinue) {
+			fprintf(imap->w, "DONE\r\n");
+			return resp;
+		}
+		respFree(resp);
+
+		struct pollfd pfd = { .fd = imap->sock, .events = POLLIN };
+		int ready = poll(&pfd, 1, 29 * 60 * 1000);
+		if (ready < 0) err(EX_IOERR, "poll");
+
+		fprintf(imap->w, "DONE\r\n");
+		resp = imapResp(imap);
+		if (ready || resp.tag != tag) return resp;
+		respFree(resp);
+	}
+}
diff --git a/imap.h b/imap.h
index 4cd7691..015c8b8 100644
--- a/imap.h
+++ b/imap.h
@@ -162,6 +162,13 @@ struct Resp {
 	const char *text;
 };
 
+static inline struct Resp respOk(struct Resp resp) {
+	if (resp.resp == AtomNo || resp.resp == AtomBad || resp.resp == AtomBye) {
+		errx(EX_CONFIG, "%s: %s", Atoms[resp.tag], resp.text);
+	}
+	return resp;
+}
+
 static inline void respFree(struct Resp resp) {
 	listFree(resp.code);
 	listFree(resp.data);
@@ -180,5 +187,6 @@ struct IMAP {
 
 struct IMAP imapOpen(const char *host, const char *port);
 struct Resp imapResp(struct IMAP *imap);
+struct Resp imapIdle(struct IMAP *imap, enum Atom tag);
 
 #endif /* IMAP_H */