zcore: move autoreply/OOF handling to exmdb

Updated zcore to fetch and update Out of Office properties
exclusively via these new RPC calls, eliminating its direct disk
interactions.

References: GXL-216

Author: grammmike

exch/zcore/store_object.cpp

@@ -471,119 +471,15 @@ BOOL store_object::get_all_proptags(PROPTAG_ARRAY *pproptags)
 	return TRUE;
 }
 
-static constexpr struct cfg_directive oof_defaults[] = {
-	{"allow_external_oof", "0", CFG_BOOL},
-	{"external_audience", "0", CFG_BOOL},
-	{"oof_state", "0"},
-	CFG_TABLE_END,
-};
-
 static void *store_object_get_oof_property(const char *maildir,
-    proptag_t proptag) try
+    proptag_t proptag)
 {
-	int offset;
-	char *pbuff;
-	int buff_len;
-	void *pvalue;
-	const char *str_value;
-	char subject[1024];
-	MIME_FIELD mime_field;
-	struct stat node_stat;
-	static constexpr uint8_t fake_true = true;
-	static constexpr uint8_t fake_false = false;
-	std::string path;
-
-	switch (proptag) {
-	case PR_EC_OUTOFOFFICE:
-	case PR_EC_OUTOFOFFICE_FROM:
-	case PR_EC_OUTOFOFFICE_UNTIL:
-	case PR_EC_ALLOW_EXTERNAL:
-	case PR_EC_EXTERNAL_AUDIENCE:
-		path = maildir + "/config/autoreply.cfg"s;
-		break;
-	case PR_EC_OUTOFOFFICE_MSG:
-	case PR_EC_OUTOFOFFICE_SUBJECT:
-		path = maildir + "/config/internal-reply"s;
-		break;
-	case PR_EC_EXTERNAL_REPLY:
-	case PR_EC_EXTERNAL_SUBJECT:
-		path = maildir + "/config/external-reply"s;
-		break;
-	}
-
-	switch (proptag) {
-	case PR_EC_OUTOFOFFICE: {
-		auto oofstate = cu_alloc<uint32_t>();
-		if (oofstate == nullptr)
-			return NULL;
-		pvalue = oofstate;
-		auto pconfig = config_file_init(path.c_str(), oof_defaults);
-		*oofstate = pconfig != nullptr ? pconfig->get_ll("oof_state") : 0;
-		return pvalue;
-	}
-	case PR_EC_OUTOFOFFICE_MSG:
-	case PR_EC_EXTERNAL_REPLY: {
-		wrapfd fd = open(path.c_str(), O_RDONLY);
-		if (fd.get() < 0 || fstat(fd.get(), &node_stat) != 0)
-			return nullptr;
-		buff_len = node_stat.st_size;
-		pbuff = cu_alloc<char>(buff_len + 1);
-		if (pbuff == nullptr || read(fd.get(), pbuff, buff_len) != buff_len)
-			return NULL;
-		pbuff[buff_len] = '\0';
-		auto ptr = strstr(pbuff, "\r\n\r\n");
-		return ptr != nullptr ? ptr + 4 : nullptr;
-	}
-	case PR_EC_OUTOFOFFICE_SUBJECT:
-	case PR_EC_EXTERNAL_SUBJECT: {
-		wrapfd fd = open(path.c_str(), O_RDONLY);
-		if (fd.get() < 0 || fstat(fd.get(), &node_stat) != 0)
-			return NULL;
-		buff_len = node_stat.st_size;
-		pbuff = cu_alloc<char>(buff_len);
-		if (pbuff == nullptr || read(fd.get(), pbuff, buff_len) != buff_len)
-			return NULL;
-		offset = 0;
-		size_t parsed_length;
-		while ((parsed_length = parse_mime_field(pbuff + offset, buff_len - offset, &mime_field)) != 0) {
-			offset += parsed_length;
-			if (strcasecmp(mime_field.name.c_str(), "Subject") == 0 &&
-			    mime_field.value.size() < std::size(subject) &&
-			    mime_string_to_utf8("utf-8", mime_field.value.c_str(), subject,
-			    std::size(subject)))
-					return common_util_dup(subject);
-			if (pbuff[offset] == '\r' && pbuff[offset+1] == '\n')
-				return NULL;
-		}
-		return NULL;
-	}
-	case PR_EC_OUTOFOFFICE_FROM:
-	case PR_EC_OUTOFOFFICE_UNTIL: {
-		auto pconfig = config_file_init(path.c_str(), oof_defaults);
-		if (pconfig == nullptr)
-			return NULL;
-		pvalue = cu_alloc<uint64_t>();
-		if (pvalue == nullptr)
-			return NULL;
-		str_value = pconfig->get_value(proptag == PR_EC_OUTOFOFFICE_FROM ? "START_TIME" : "END_TIME");
-		if (str_value == nullptr)
-			return NULL;
-		*static_cast<uint64_t *>(pvalue) = rop_util_unix_to_nttime(strtoll(str_value, nullptr, 0));
-		return pvalue;
-	}
-	case PR_EC_ALLOW_EXTERNAL:
-	case PR_EC_EXTERNAL_AUDIENCE: {
-		auto pconfig = config_file_init(path.c_str(), oof_defaults);
-		if (pconfig == nullptr)
-			return deconst(&fake_false);
-		auto key = proptag == PR_EC_ALLOW_EXTERNAL ? "allow_external_oof" : "external_audience";
-		pvalue = deconst(pconfig->get_ll(key) == 0 ? &fake_false : &fake_true);
-		return pvalue;
-	}
-	}
-	return NULL;
-} catch (const std::bad_alloc &) {
-	return nullptr;
+	const PROPTAG_ARRAY tags = {1, &proptag};
+	TPROPVAL_ARRAY props{};
+	if (!exmdb_client->autoreply_getprop(maildir, CP_UTF8, &tags, &props) ||
+	    props.count == 0 || props[0].proptag != proptag)
+		return nullptr;
+	return props[0].pvalue;
 }
 
 static BOOL store_object_get_calculated_property(store_object *pstore,
@@ -1060,140 +956,10 @@ BOOL store_object::get_properties(const PROPTAG_ARRAY *pproptags,
 static BOOL store_object_set_oof_property(const char *maildir,
     proptag_t proptag, const void *pvalue)
 {
-	char *pbuff;
-	int buff_len;
-	char *ptoken;
-	std::string autoreply_path;
-	
-	try {
-		autoreply_path = maildir + "/config/autoreply.cfg"s;
-	} catch (const std::bad_alloc &) {
-		mlog(LV_ERR, "E-1483: ENOMEM");
-		return false;
-	}
-	/* Ensure file exists for config_file_prg */
-	auto fdtest = open(autoreply_path.c_str(), O_CREAT | O_WRONLY, FMODE_PUBLIC);
-	if (fdtest < 0)
-		return false;
-	close(fdtest);
-	switch (proptag) {
-	case PR_EC_OUTOFOFFICE: {
-		auto pconfig = config_file_init(autoreply_path.c_str(), oof_defaults);
-		if (pconfig == nullptr)
-			return FALSE;
-		auto v = *static_cast<const uint32_t *>(pvalue);
-		pconfig->set_value("OOF_STATE", v == 1 ? "1" : v == 2 ? "2" : "0");
-		return pconfig->save();
-	}
-	case PR_EC_OUTOFOFFICE_FROM:
-	case PR_EC_OUTOFOFFICE_UNTIL: {
-		auto pconfig = config_file_init(autoreply_path.c_str(), oof_defaults);
-		if (pconfig == nullptr)
-			return FALSE;
-		long long t = rop_util_nttime_to_unix(*static_cast<const uint64_t *>(pvalue));
-		pconfig->set_value(proptag == PR_EC_OUTOFOFFICE_FROM ?
-			"START_TIME" : "END_TIME", std::to_string(t).c_str());
-		return pconfig->save();
-	}
-	case PR_EC_OUTOFOFFICE_MSG:
-	case PR_EC_EXTERNAL_REPLY: {
-		try {
-			autoreply_path = maildir;
-			autoreply_path += proptag == PR_EC_OUTOFOFFICE_MSG ?
-			             "/config/internal-reply" : "/config/external-reply";
-		} catch (const std::bad_alloc &) {
-			mlog(LV_ERR, "E-1484: ENOMEM");
-			return false;
-		}
-		wrapfd fd = open(autoreply_path.c_str(), O_RDONLY);
-		struct stat node_stat;
-		if (fd.get() < 0 || fstat(fd.get(), &node_stat) != 0) {
-			buff_len = strlen(static_cast<const char *>(pvalue));
-			pbuff = cu_alloc<char>(buff_len + 256);
-			if (pbuff == nullptr)
-				return FALSE;
-			buff_len = gx_snprintf(pbuff, buff_len + 256,
-			           "Content-Type: text/html; charset=\"utf-8\"\r\n\r\n%s",
-			           static_cast<const char *>(pvalue));
-		} else {
-			buff_len = node_stat.st_size;
-			pbuff = cu_alloc<char>(buff_len + strlen(static_cast<const char *>(pvalue)) + 1);
-			if (pbuff == nullptr || read(fd.get(), pbuff, buff_len) != buff_len)
-				return FALSE;
-			pbuff[buff_len] = '\0';
-			ptoken = strstr(pbuff, "\r\n\r\n");
-			if (NULL != ptoken) {
-				strcpy(ptoken + 4, static_cast<const char *>(pvalue));
-				buff_len = strlen(pbuff);
-			} else {
-				buff_len = sprintf(pbuff, "Content-Type: text/html;\r\n"
-				           "\tcharset=\"utf-8\"\r\n\r\n%s",
-				           static_cast<const char *>(pvalue));
-			}
-		}
-		fd = open(autoreply_path.c_str(), O_CREAT | O_TRUNC | O_WRONLY, FMODE_PUBLIC);
-		if (fd.get() < 0 || write(fd.get(), pbuff, buff_len) != buff_len)
-			return FALSE;
-		return TRUE;
-	}
-	case PR_EC_OUTOFOFFICE_SUBJECT:
-	case PR_EC_EXTERNAL_SUBJECT: {
-		try {
-			autoreply_path = maildir;
-			autoreply_path += proptag == PR_EC_OUTOFOFFICE_SUBJECT ?
-			             "/config/internal-reply" : "/config/external-reply";
-		} catch (const std::bad_alloc &) {
-			mlog(LV_ERR, "E-1485: ENOMEM");
-			return false;
-		}
-		struct stat node_stat;
-		wrapfd fd = open(autoreply_path.c_str(), O_RDONLY);
-		if (fd.get() < 0 || fstat(fd.get(), &node_stat) != 0) {
-			buff_len = strlen(static_cast<const char *>(pvalue));
-			pbuff = cu_alloc<char>(buff_len + 256);
-			if (pbuff == nullptr)
-				return FALSE;
-			buff_len = sprintf(pbuff, "Content-Type: text/html;\r\n\t"
-			           "charset=\"utf-8\"\r\nSubject: %s\r\n\r\n",
-			           static_cast<const char *>(pvalue));
-		} else {
-			buff_len = node_stat.st_size;
-			pbuff = cu_alloc<char>(buff_len + strlen(static_cast<const char *>(pvalue)) + 16);
-			if (pbuff == nullptr)
-				return FALSE;
-			ptoken = cu_alloc<char>(buff_len + 1);
-			if (ptoken == nullptr)
-				return FALSE;
-			if (read(fd.get(), ptoken, buff_len) != buff_len)
-				return FALSE;
-			ptoken[buff_len] = '\0';
-			ptoken = strstr(ptoken, "\r\n\r\n");
-			if (ptoken == nullptr)
-				buff_len = sprintf(pbuff, "Content-Type: text/html;\r\n\t"
-				           "charset=\"utf-8\"\r\nSubject: %s\r\n\r\n",
-				           static_cast<const char *>(pvalue));
-			else
-				buff_len = sprintf(pbuff, "Content-Type: text/html;\r\n\t"
-				           "charset=\"utf-8\"\r\nSubject: %s%s",
-				           static_cast<const char *>(pvalue), ptoken);
-		}
-		fd = open(autoreply_path.c_str(), O_CREAT | O_TRUNC | O_WRONLY, FMODE_PUBLIC);
-		if (fd.get() < 0 || write(fd.get(), pbuff, buff_len) != buff_len)
-			return FALSE;
-		return TRUE;
-	}
-	case PR_EC_ALLOW_EXTERNAL:
-	case PR_EC_EXTERNAL_AUDIENCE: {
-		auto pconfig = config_file_init(autoreply_path.c_str(), oof_defaults);
-		if (pconfig == nullptr)
-			return FALSE;
-		pconfig->set_value(proptag == PR_EC_ALLOW_EXTERNAL ?
-		                      "ALLOW_EXTERNAL_OOF" : "EXTERNAL_AUDIENCE",
-		                      *static_cast<const uint8_t *>(pvalue) == 0 ? "0" : "1");
-		return pconfig->save();
-	}
-	}
-	return FALSE;
+	const TAGGED_PROPVAL pv = {proptag, deconst(pvalue)};
+	const TPROPVAL_ARRAY vals = {1, deconst(&pv)};
+	PROBLEM_ARRAY status{};
+	return exmdb_client->autoreply_setprop(maildir, CP_UTF8, &vals, &status);
 }
 
 static BOOL store_object_set_folder_name(store_object *pstore,