Skip to content

Commit 65e8eaf

Browse files
grammmikejengelh
grammmike
authored and
jengelh
committed
exmdb: add autoreply/OOF RPC endpoints
Introduced new RPC endpoints ``autoreply_getprop`` and ``autoreply_setprop``, enabling remote retrieval and storage of Out of Office settings without direct filesystem access. Implemented server-side handlers that read and write the autoreply configuration files for the requested property tags. References: GXL-216
1 parent 3aaad5f commit 65e8eaf

File tree

6 files changed

+293
-4
lines changed

6 files changed

+293
-4
lines changed

‎exch/exmdb/names.cpp‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -157,6 +157,8 @@ static constexpr const char *exmdb_rpc_names[] = {
157157
E(cgkreset),
158158
E(write_message),
159159
E(set_maintenance),
160+
E(autoreply_getprop),
161+
E(autoreply_setprop),
160162
};
161163
#undef E
162164

@@ -165,7 +167,7 @@ namespace exmdb {
165167
const char *exmdb_rpc_idtoname(exmdb_callid i)
166168
{
167169
auto j = static_cast<uint8_t>(i);
168-
static_assert(std::size(exmdb_rpc_names) == static_cast<uint8_t>(exmdb_callid::set_maintenance) + 1);
170+
static_assert(std::size(exmdb_rpc_names) == static_cast<uint8_t>(exmdb_callid::autoreply_setprop) + 1);
169171
auto s = j < std::size(exmdb_rpc_names) ? exmdb_rpc_names[j] : nullptr;
170172
return znul(s);
171173
}

‎exch/exmdb/store2.cpp‎

Lines changed: 272 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,8 @@
2323
#include <gromox/exmdb_common_util.hpp>
2424
#include <gromox/exmdb_server.hpp>
2525
#include <gromox/fileio.h>
26+
#include <gromox/config_file.hpp>
27+
#include <gromox/mail_func.hpp>
2628
#include <gromox/mapi_types.hpp>
2729
#include <gromox/mapidefs.h>
2830
#include <gromox/mysql_adaptor.hpp>
@@ -43,6 +45,13 @@ struct sql_del {
4345

4446
}
4547

48+
static constexpr cfg_directive oof_defaults[] = {
49+
{"allow_external_oof", "0", CFG_BOOL},
50+
{"external_audience", "0", CFG_BOOL},
51+
{"oof_state", "0"},
52+
CFG_TABLE_END,
53+
};
54+
4655
BOOL exmdb_server::vacuum(const char *dir)
4756
{
4857
return db_engine_vacuum(dir);
@@ -569,6 +578,269 @@ BOOL exmdb_server::autoreply_tsupdate(const char *dir, const char *peer) try
569578
return false;
570579
}
571580

581+
static std::string autoreply_fspath(const char *dir, proptag_t proptag)
582+
{
583+
switch (proptag) {
584+
case PR_EC_OUTOFOFFICE:
585+
case PR_EC_OUTOFOFFICE_FROM:
586+
case PR_EC_OUTOFOFFICE_UNTIL:
587+
case PR_EC_ALLOW_EXTERNAL:
588+
case PR_EC_EXTERNAL_AUDIENCE:
589+
return dir + "/config/autoreply.cfg"s;
590+
case PR_EC_OUTOFOFFICE_MSG:
591+
case PR_EC_OUTOFOFFICE_SUBJECT:
592+
return dir + "/config/internal-reply"s;
593+
case PR_EC_EXTERNAL_REPLY:
594+
case PR_EC_EXTERNAL_SUBJECT:
595+
return dir + "/config/external-reply"s;
596+
default:
597+
return {};
598+
}
599+
}
600+
601+
static ec_error_t autoreply_getprop1(const char *dir,
602+
proptag_t proptag, void *&value)
603+
{
604+
char subject[1024];
605+
MIME_FIELD mime_field;
606+
auto path = autoreply_fspath(dir, proptag);
607+
608+
switch (proptag) {
609+
case PR_EC_OUTOFOFFICE: {
610+
auto oofstate = cu_alloc<uint32_t>();
611+
if (oofstate == nullptr)
612+
return ecServerOOM;
613+
auto cfg = config_file_init(path.c_str(), oof_defaults);
614+
*oofstate = cfg != nullptr ? cfg->get_ll("oof_state") : 0;
615+
value = oofstate;
616+
return ecSuccess;
617+
}
618+
case PR_EC_OUTOFOFFICE_MSG:
619+
case PR_EC_EXTERNAL_REPLY: {
620+
struct stat st;
621+
wrapfd fd = open(path.c_str(), O_RDONLY);
622+
if (fd.get() < 0 || fstat(fd.get(), &st) != 0)
623+
return ecNotFound;
624+
auto buf = cu_alloc<char>(st.st_size + 1);
625+
if (buf == nullptr)
626+
return ecServerOOM;
627+
if (read(fd.get(), buf, st.st_size) != st.st_size)
628+
return ecReadFault;
629+
buf[st.st_size] = '\0';
630+
auto ptr = strstr(buf, "\r\n\r\n");
631+
value = ptr != nullptr ? ptr + 4 : nullptr;
632+
return ecSuccess;
633+
}
634+
case PR_EC_OUTOFOFFICE_SUBJECT:
635+
case PR_EC_EXTERNAL_SUBJECT: {
636+
struct stat st;
637+
wrapfd fd = open(path.c_str(), O_RDONLY);
638+
if (fd.get() < 0 || fstat(fd.get(), &st) != 0)
639+
return ecNotFound;
640+
auto buf = cu_alloc<char>(st.st_size);
641+
if (buf == nullptr)
642+
return ecServerOOM;
643+
if (buf == nullptr || read(fd.get(), buf, st.st_size) != st.st_size)
644+
return ecReadFault;
645+
size_t offset = 0;
646+
while (auto parsed = parse_mime_field(&buf[offset], st.st_size - offset, &mime_field)) {
647+
offset += parsed;
648+
if (strcasecmp(mime_field.name.c_str(), "Subject") == 0 &&
649+
mime_field.value.size() < sizeof(subject) &&
650+
mime_string_to_utf8("utf-8", mime_field.value.c_str(), subject, sizeof(subject))) {
651+
value = common_util_dup(subject);
652+
return value != nullptr ? ecSuccess : ecServerOOM;
653+
}
654+
if (buf[offset] == '\r' && buf[offset+1] == '\n')
655+
break;
656+
}
657+
return ecSuccess;
658+
}
659+
case PR_EC_OUTOFOFFICE_FROM:
660+
case PR_EC_OUTOFOFFICE_UNTIL: {
661+
auto cfg = config_file_init(path.c_str(), oof_defaults);
662+
if (cfg == nullptr)
663+
return ecNotFound;
664+
auto ts = cu_alloc<mapitime_t>();
665+
if (ts == nullptr)
666+
return ecServerOOM;
667+
auto key = proptag == PR_EC_OUTOFOFFICE_FROM ? "START_TIME" : "END_TIME";
668+
auto sval = cfg->get_value(key);
669+
if (sval == nullptr)
670+
return ecNotFound;
671+
*ts = rop_util_unix_to_nttime(strtoll(sval, nullptr, 0));
672+
value = ts;
673+
return ecSuccess;
674+
}
675+
case PR_EC_ALLOW_EXTERNAL:
676+
case PR_EC_EXTERNAL_AUDIENCE: {
677+
static constexpr uint8_t fake_true = true, fake_false = false;
678+
auto cfg = config_file_init(path.c_str(), oof_defaults);
679+
if (cfg == nullptr) {
680+
value = deconst(&fake_false);
681+
return ecSuccess;
682+
}
683+
auto key = proptag == PR_EC_ALLOW_EXTERNAL ? "allow_external_oof" : "external_audience";
684+
value = deconst(cfg->get_ll(key) == 0 ? &fake_false : &fake_true);
685+
return ecSuccess;
686+
}
687+
}
688+
return ecNotFound;
689+
}
690+
691+
BOOL exmdb_server::autoreply_getprop(const char *dir, cpid_t cpid,
692+
const PROPTAG_ARRAY *pproptags, TPROPVAL_ARRAY *ppropvals) try
693+
{
694+
ppropvals->count = 0;
695+
ppropvals->ppropval = cu_alloc<TAGGED_PROPVAL>(pproptags->count);
696+
if (ppropvals->ppropval == nullptr)
697+
return false;
698+
for (proptag_t tag : *pproptags) {
699+
void *value = nullptr;
700+
auto err = autoreply_getprop1(dir, tag, value);
701+
if (err == ecSuccess) {
702+
ppropvals->emplace_back(tag, value);
703+
continue;
704+
}
705+
auto erp = cu_alloc<uint32_t>();
706+
if (erp == nullptr)
707+
return false;
708+
*erp = err;
709+
ppropvals->emplace_back(CHANGE_PROP_TYPE(PT_ERROR, tag), erp);
710+
}
711+
return true;
712+
} catch (const std::bad_alloc &) {
713+
mlog(LV_ERR, "E-2227: ENOMEM");
714+
return false;
715+
}
716+
717+
static BOOL autoreply_setprop1(const char *dir, const TAGGED_PROPVAL &pv)
718+
{
719+
auto path = autoreply_fspath(dir, pv.proptag);
720+
721+
switch (pv.proptag) {
722+
case PR_EC_OUTOFOFFICE: {
723+
auto cfg = config_file_init(path.c_str(), oof_defaults);
724+
if (cfg == nullptr)
725+
return false;
726+
auto v = *static_cast<const uint32_t *>(pv.pvalue);
727+
cfg->set_value("OOF_STATE", v == 1 ? "1" : v == 2 ? "2" : "0");
728+
return cfg->save();
729+
}
730+
case PR_EC_OUTOFOFFICE_FROM:
731+
case PR_EC_OUTOFOFFICE_UNTIL: {
732+
auto cfg = config_file_init(path.c_str(), oof_defaults);
733+
if (cfg == nullptr)
734+
return false;
735+
auto ts = rop_util_nttime_to_unix(*static_cast<const mapitime_t *>(pv.pvalue));
736+
cfg->set_value(pv.proptag == PR_EC_OUTOFOFFICE_FROM ?
737+
"START_TIME" : "END_TIME", std::to_string(ts).c_str());
738+
return cfg->save();
739+
}
740+
case PR_EC_OUTOFOFFICE_MSG:
741+
case PR_EC_EXTERNAL_REPLY: {
742+
wrapfd fd = open(path.c_str(), O_RDONLY);
743+
struct stat st{};
744+
ssize_t buff_len = 0;
745+
char *buf = nullptr;
746+
747+
if (fd.get() < 0 || fstat(fd.get(), &st) != 0) {
748+
buff_len = strlen(static_cast<const char *>(pv.pvalue));
749+
buf = cu_alloc<char>(buff_len + 256);
750+
if (buf == nullptr)
751+
return false;
752+
buff_len = gx_snprintf(buf, buff_len + 256,
753+
"Content-Type: text/html; charset=\"utf-8\"\r\n\r\n%s",
754+
static_cast<const char *>(pv.pvalue));
755+
} else {
756+
buff_len = st.st_size;
757+
buf = cu_alloc<char>(buff_len + strlen(static_cast<const char *>(pv.pvalue)) + 1);
758+
if (buf == nullptr || read(fd.get(), buf, buff_len) != buff_len)
759+
return false;
760+
buf[buff_len] = '\0';
761+
auto token = strstr(buf, "\r\n\r\n");
762+
if (token != nullptr) {
763+
strcpy(&token[4], static_cast<const char *>(pv.pvalue));
764+
buff_len = strlen(buf);
765+
} else {
766+
buff_len = sprintf(buf,
767+
"Content-Type: text/html;\r\n\tcharset=\"utf-8\"\r\n\r\n%s",
768+
static_cast<const char *>(pv.pvalue));
769+
}
770+
}
771+
gromox::tmpfile tf;
772+
auto fdw = tf.open_linkable((dir + "/config"s).c_str(), O_WRONLY, FMODE_PUBLIC);
773+
if (fdw < 0 || HXio_fullwrite(fdw, buf, buff_len) != buff_len)
774+
return false;
775+
return tf.link_to(path.c_str()) == 0;
776+
}
777+
case PR_EC_OUTOFOFFICE_SUBJECT:
778+
case PR_EC_EXTERNAL_SUBJECT: {
779+
wrapfd fd = open(path.c_str(), O_RDONLY);
780+
struct stat st{};
781+
ssize_t buff_len = 0;
782+
char *buf = nullptr;
783+
784+
if (fd.get() < 0 || fstat(fd.get(), &st) != 0) {
785+
buff_len = strlen(static_cast<const char *>(pv.pvalue));
786+
buf = cu_alloc<char>(buff_len + 256);
787+
if (buf == nullptr)
788+
return false;
789+
buff_len = sprintf(buf,
790+
"Content-Type: text/html;\r\n\tcharset=\"utf-8\"\r\nSubject: %s\r\n\r\n",
791+
static_cast<const char *>(pv.pvalue));
792+
} else {
793+
buff_len = st.st_size;
794+
buf = cu_alloc<char>(buff_len + strlen(static_cast<const char *>(pv.pvalue)) + 16);
795+
if (buf == nullptr)
796+
return false;
797+
auto token = cu_alloc<char>(buff_len + 1);
798+
if (token == nullptr ||
799+
read(fd.get(), token, buff_len) != buff_len)
800+
return false;
801+
token[buff_len] = '\0';
802+
auto body = strstr(token, "\r\n\r\n");
803+
if (body == nullptr)
804+
buff_len = sprintf(buf,
805+
"Content-Type: text/html;\r\n\tcharset=\"utf-8\"\r\nSubject: %s\r\n\r\n",
806+
static_cast<const char *>(pv.pvalue));
807+
else
808+
buff_len = sprintf(buf,
809+
"Content-Type: text/html;\r\n\tcharset=\"utf-8\"\r\nSubject: %s%s",
810+
static_cast<const char *>(pv.pvalue), body);
811+
}
812+
gromox::tmpfile tf;
813+
auto fdw = tf.open_linkable((dir + "/config"s).c_str(), O_WRONLY, FMODE_PUBLIC);
814+
if (fdw < 0 || HXio_fullwrite(fdw, buf, buff_len) != buff_len)
815+
return false;
816+
return tf.link_to(path.c_str()) == 0;
817+
}
818+
case PR_EC_ALLOW_EXTERNAL:
819+
case PR_EC_EXTERNAL_AUDIENCE: {
820+
auto cfg = config_file_init(path.c_str(), oof_defaults);
821+
if (cfg == nullptr)
822+
return false;
823+
auto key = pv.proptag == PR_EC_ALLOW_EXTERNAL ?
824+
"ALLOW_EXTERNAL_OOF" : "EXTERNAL_AUDIENCE";
825+
cfg->set_value(key, *static_cast<const uint8_t *>(pv.pvalue) ? "1" : "0");
826+
return cfg->save();
827+
}
828+
}
829+
return false;
830+
}
831+
832+
BOOL exmdb_server::autoreply_setprop(const char *dir, cpid_t cpid,
833+
const TPROPVAL_ARRAY *ppropvals, PROBLEM_ARRAY *pproblems) try
834+
{
835+
for (const auto &p : *ppropvals)
836+
if (!autoreply_setprop1(dir, p))
837+
return false;
838+
return true;
839+
} catch (const std::bad_alloc &) {
840+
mlog(LV_ERR, "E-2229: ENOMEM");
841+
return false;
842+
}
843+
572844
BOOL exmdb_server::recalc_store_size(const char *dir, uint32_t flags)
573845
{
574846
auto db = db_engine_get_db(dir);

‎include/gromox/exmdb_idef.hpp‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -141,3 +141,5 @@ EXMIDL(imapfile_write, (const char *dir, const std::string &type, const std::str
141141
EXMIDL(imapfile_delete, (const char *dir, const std::string &type, const std::string &mid))
142142
EXMIDL(cgkreset, (const char *dir, uint32_t flags))
143143
EXMIDL(set_maintenance, (const char *dir, uint32_t mode))
144+
EXMIDL(autoreply_getprop, (const char *dir, cpid_t cpid, const PROPTAG_ARRAY *pproptags, IDLOUT TPROPVAL_ARRAY *propvals))
145+
EXMIDL(autoreply_setprop, (const char *dir, cpid_t cpid, const TPROPVAL_ARRAY *ppropvals, IDLOUT PROBLEM_ARRAY *problems))

‎include/gromox/exmdb_rpc.hpp‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,8 @@ enum class exmdb_callid : uint8_t {
173173
cgkreset = 0x91,
174174
write_message /* v3 */ = 0x92,
175175
set_maintenance = 0x93,
176+
autoreply_getprop = 0x94,
177+
autoreply_setprop = 0x95,
176178
/* update exch/exmdb/names.cpp:exmdb_rpc_idtoname! */
177179
};
178180

@@ -220,6 +222,10 @@ struct exreq_set_store_properties final : public exreq {
220222
TPROPVAL_ARRAY *ppropvals;
221223
};
222224

225+
/* @cpid fields unused, always CP_UTF8 */
226+
using exreq_autoreply_getprop = exreq_get_store_properties;
227+
using exreq_autoreply_setprop = exreq_set_store_properties;
228+
223229
struct exreq_remove_store_properties final : public exreq {
224230
PROPTAG_ARRAY *pproptags;
225231
};
@@ -932,6 +938,9 @@ struct exresp_set_store_properties final : public exresp {
932938
PROBLEM_ARRAY problems;
933939
};
934940

941+
using exresp_autoreply_getprop = exresp_get_store_properties;
942+
using exresp_autoreply_setprop = exresp_set_store_properties;
943+
935944
struct exresp_get_mbox_perm final : public exresp {
936945
uint32_t permission;
937946
};

‎include/gromox/mapierr.hpp‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -362,7 +362,7 @@ enum ec_error_t
362362
ecUnableToAbort = 0x80040114, /* MAPI_E_UNABLE_TO_ABORT */
363363
ecRpcFailed = 0x80040115,
364364
ecNetwork = 0x80040115, /* MAPI_E_NETWORK_ERROR */
365-
// ecReadFault = 0x80040116, /* ecWriteFault, MAPI_E_DISK_ERROR */
365+
ecReadFault = 0x80040116, /* ecWriteFault, MAPI_E_DISK_ERROR */
366366
ecTooComplex = 0x80040117, /* MAPI_E_TOO_COMPLEX */
367367
// MAPI_E_BAD_COLUMN = 0x80040118,
368368
// MAPI_E_EXTENDED_ERROR = 0x80040119,

‎lib/exmdb_ext.cpp‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2419,7 +2419,9 @@ static pack_result exmdb_push(EXT_PUSH &x, const exreq_set_maintenance &d)
24192419
E(imapfile_write) \
24202420
E(imapfile_delete) \
24212421
E(cgkreset) \
2422-
E(set_maintenance)
2422+
E(set_maintenance) \
2423+
E(autoreply_getprop) \
2424+
E(autoreply_setprop)
24232425

24242426
/**
24252427
* This uses *& because we do not know which request type we are going to get
@@ -3856,7 +3858,9 @@ static pack_result exmdb_push(EXT_PUSH &x, const exresp_imapfile_read &d)
38563858
E(get_public_folder_unread_count) \
38573859
E(store_eid_to_user) \
38583860
E(autoreply_tsquery) \
3859-
E(imapfile_read)
3861+
E(imapfile_read) \
3862+
E(autoreply_getprop) \
3863+
E(autoreply_setprop)
38603864

38613865
/* exmdb_callid::connect, exmdb_callid::listen_notification not included */
38623866
/*

0 commit comments

Comments
 (0)