Page MenuHomePhorge
Files F120824349

No OneTemporary
Actions

Authored By
Unknown
Size
12 KB
Referenced Files
None
Subscribers
None

View Options

diff --git a/imap/mbpath.c b/imap/mbpath.c
index 152ade0c3..fe5086aef 100644
--- a/imap/mbpath.c
+++ b/imap/mbpath.c
@@ -1,279 +1,368 @@
/* mbpath.c -- help the sysadmin to find the path matching the mailbox
*
* Copyright (c) 1994-2008 Carnegie Mellon University. All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The name "Carnegie Mellon University" must not be used to
* endorse or promote products derived from this software without
* prior written permission. For permission or any legal
* details, please contact
* Carnegie Mellon University
* Center for Technology Transfer and Enterprise Creation
* 4615 Forbes Avenue
* Suite 302
* Pittsburgh, PA 15213
* (412) 268-7393, fax: (412) 268-7395
* innovation@andrew.cmu.edu
*
* 4. Redistributions of any form whatsoever must retain the following
* acknowledgment:
* "This product includes software developed by Computing Services
* at Carnegie Mellon University (http://www.cmu.edu/computing/)."
*
* CARNEGIE MELLON UNIVERSITY DISCLAIMS ALL WARRANTIES WITH REGARD TO
* THIS SOFTWARE, INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
* AND FITNESS, IN NO EVENT SHALL CARNEGIE MELLON UNIVERSITY BE LIABLE
* FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN
* AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
* OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*/
#include <config.h>
#ifdef HAVE_UNISTD_H
#include <unistd.h>
#endif
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sysexits.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/param.h>
+#include <jansson.h>
#include "util.h"
#include "global.h"
#include "mailbox.h"
#include "xmalloc.h"
#include "mboxlist.h"
+#include "strarray.h"
#include "user.h"
/* generated headers are not necessarily in current directory */
#include "imap/imap_err.h"
extern int optind;
extern char *optarg;
/* current namespace */
static struct namespace mbpath_namespace;
static int usage(const char *error)
{
fprintf(stderr,"usage: mbpath [-C <alt_config>] [-l] [-m] [-q] [-s] [-u] [-a|A|D|M|S|U] <mailbox name>...\n");
fprintf(stderr, "\n");
+ fprintf(stderr,"\t-j\tprint all values as a JSON object\n");
fprintf(stderr,"\t-a\tprint all values with prefixes\n");
fprintf(stderr,"\t-l\tlocal only (exit with error for remote/nonexistent)\n");
fprintf(stderr,"\t-m\toutput the path to the metadata files (if different from the message files)\n");
fprintf(stderr,"\t-q\tquietly drop any error messages\n");
fprintf(stderr,"\t-s\tstop on error\n");
fprintf(stderr,"\t-u\targuments are user, not mailbox\n");
fprintf(stderr,"\t-A\tpartition archive directory\n");
fprintf(stderr,"\t-D\tpartition data directory (*default*)\n");
fprintf(stderr,"\t-M\tpartition metadata file directory (duplicate of -m)\n");
fprintf(stderr,"\t-S\tsieve directory for the user\n");
fprintf(stderr,"\t-U\tuser files directory (seen, sub, etc)\n");
if (error) {
fprintf(stderr,"\n");
fprintf(stderr,"ERROR: %s", error);
}
exit(-1);
}
+static void find_tier(const char *key, const char *val __attribute__((unused)), void *rock)
+{
+ strarray_t *tiers = (strarray_t *)rock;
+ const char *partition = strstr(key, "searchpartition-");
+ if (!partition) return;
+ strarray_appendm(tiers, xstrndup(key, partition - key));
+}
+
+static void print_json(const mbname_t *mbname, const mbentry_t *mbentry)
+{
+ // we always print everything in JSON format
+ int i;
+
+ json_t *jres = json_object();
+
+ const char *userid = mbname_userid(mbname);
+
+ // mbname
+ json_t *jmbname = json_object();
+ if (mbname_userid(mbname))
+ json_object_set_new(jmbname, "userid", json_string(userid));
+ if (mbname_domain(mbname))
+ json_object_set_new(jmbname, "domain", json_string(mbname_domain(mbname)));
+ if (mbname_localpart(mbname))
+ json_object_set_new(jmbname, "localpart", json_string(mbname_localpart(mbname)));
+ if (mbname_isdeleted(mbname))
+ json_object_set_new(jmbname, "isdeleted", json_integer(mbname_isdeleted(mbname)));
+ json_t *jboxes = json_array();
+ const strarray_t *boxes = mbname_boxes(mbname);
+ for (i = 0; i < strarray_size(boxes); i++)
+ json_array_append_new(jboxes, json_string(strarray_nth(boxes, i)));
+ json_object_set_new(jmbname, "boxes", jboxes);
+ json_object_set_new(jmbname, "intname", json_string(mbname_intname(mbname)));
+ json_object_set_new(jres, "mbname", jmbname);
+
+ // we don't do quota paths because that's hard to extract from the quota db interface right now
+
+ if (userid) {
+ // user paths
+ json_t *juser = json_object();
+ json_object_set_new(juser, "conversations", json_string(user_hash_meta(userid, "conversations")));
+ json_object_set_new(juser, "counters", json_string(user_hash_meta(userid, "counters")));
+ json_object_set_new(juser, "dav", json_string(user_hash_meta(userid, "dav")));
+ json_object_set_new(juser, "sieve", json_string(user_sieve_path(userid)));
+ json_object_set_new(juser, "sub", json_string(user_hash_meta(userid, "sub")));
+ json_object_set_new(juser, "xapianactive", json_string(user_hash_meta(userid, "xapianactive")));
+
+ json_object_set_new(jres, "user", juser);
+
+ // xapian tiers
+ json_t *jxapian = json_object();
+ strarray_t tiers = STRARRAY_INITIALIZER;
+ config_foreachoverflowstring(find_tier, &tiers);
+ for (i = 0; i < strarray_size(&tiers); i++) {
+ const char *tier = strarray_nth(&tiers, i);
+ char *basedir = NULL;
+ xapian_basedir(tier, mbentry->name, mbentry->partition, NULL, &basedir);
+ if (basedir) {
+ json_object_set_new(jxapian, tier, json_string(basedir));
+ free(basedir);
+ }
+ }
+ strarray_fini(&tiers);
+
+ json_object_set_new(jres, "xapian", jxapian);
+ }
+
+ // mailbox paths
+ json_object_set_new(jres, "archive", json_string(mboxname_archivepath(mbentry->partition, mbentry->name, mbentry->uniqueid, 0)));
+ json_object_set_new(jres, "data", json_string(mboxname_datapath(mbentry->partition, mbentry->name, mbentry->uniqueid, 0)));
+ json_object_set_new(jres, "meta", json_string(mboxname_metapath(mbentry->partition, mbentry->name, mbentry->uniqueid, 0, 0)));
+
+ char *out = json_dumps(jres, JSON_INDENT(2)|JSON_SORT_KEYS);
+ printf("%s\n", out);
+ free(out);
+ json_decref(jres);
+}
+
int main(int argc, char **argv)
{
mbentry_t *mbentry = NULL;
int r, i;
int opt; /* getopt() returns an int */
char *alt_config = NULL;
// capture options
int quiet = 0;
int stop_on_error = 0;
int localonly = 0;
int usermode = 0;
int doall = 0;
int doA = 0;
int doD = 1; // default
int doM = 0;
int doS = 0;
int doU = 0;
int sel = 0;
+ int do_json = 0;
- while ((opt = getopt(argc, argv, "C:almqsuADMSU")) != EOF) {
+ while ((opt = getopt(argc, argv, "C:ajlmqsudADMSU")) != EOF) {
switch(opt) {
case 'C': /* alt config file */
alt_config = optarg;
break;
case 'a':
if (sel)
usage("Duplicate selectors given");
doall = 1;
doD = 0;
sel = 1;
break;
case 'l':
localonly = 1;
break;
+ case 'j':
+ do_json = 1;
+ break;
+
case 'm':
if (sel)
usage("Duplicate selectors given");
doM = 1;
doD = 0;
sel = 1;
break;
case 'q':
quiet = 1;
break;
case 's':
stop_on_error = 1;
break;
case 'u':
usermode = 1;
break;
case 'A':
if (sel)
usage("Duplicate selectors given");
doA = 1;
doD = 0;
sel = 1;
break;
case 'D':
if (sel)
usage("Duplicate selectors given");
sel = 1;
break;
case 'M':
if (sel)
usage("Duplicate selectors given");
doM = 1;
doD = 0;
sel = 1;
break;
case 'S':
if (sel)
usage("Duplicate selectors given");
doS = 1;
doD = 0;
sel = 1;
break;
case 'U':
if (sel)
usage("Duplicate selectors given");
doU = 1;
doD = 0;
sel = 1;
break;
default:
usage(NULL);
}
}
cyrus_init(alt_config, "mbpath", 0, 0);
r = mboxname_init_namespace(&mbpath_namespace, 1);
if (r) {
fatal(error_message(r), -1);
}
for (i = optind; i < argc; i++) {
/* Translate mailboxname */
mbname_t *mbname = NULL;
if (usermode) {
mbname = mbname_from_userid(argv[i]);
}
else {
mbname = mbname_from_extname(argv[i], &mbpath_namespace, NULL);
}
r = mboxlist_lookup(mbname_intname(mbname), &mbentry, NULL);
if (!r) {
if (mbentry->mbtype & MBTYPE_REMOTE) {
if (localonly) {
if (stop_on_error) {
if (quiet) {
fatal("", -1);
}
else {
fatal("Non-local mailbox. Stopping\n", -1);
}
}
}
else {
// ignore all selectors and just print this
printf("%s!%s\n", mbentry->server, mbentry->partition);
}
}
+ else if (do_json) {
+ print_json(mbname, mbentry);
+ }
else {
if (doall || doA) {
const char *path = mboxname_archivepath(mbentry->partition, mbentry->name, mbentry->uniqueid, 0);
if (doall) printf("Archive: ");
printf("%s\n", path);
}
if (doall || doD) {
const char *path = mboxname_datapath(mbentry->partition, mbentry->name, mbentry->uniqueid, 0);
if (doall) printf("Data: ");
printf("%s\n", path);
}
if (doall || doM) {
const char *path = mboxname_metapath(mbentry->partition, mbentry->name, mbentry->uniqueid, 0, 0);
if (doall) printf("Meta: ");
printf("%s\n", path);
}
if (doall || doS) {
const char *path = user_sieve_path(mbname_userid(mbname));
if (doall) printf("Sieve: ");
printf("%s\n", path);
}
if (doall || doU) {
// different interface - caller must free
char *path = mboxname_conf_getpath(mbname, NULL);
if (doall) printf("User: ");
printf("%s\n", path);
free(path);
}
}
}
else {
if (!quiet && (r == IMAP_MAILBOX_NONEXISTENT)) {
fprintf(stderr, "Invalid mailbox name: %s\n", argv[i]);
}
if (stop_on_error) {
if (quiet) {
fatal("", -1);
}
else {
fatal("Error in processing mailbox. Stopping\n", -1);
}
}
}
mbname_free(&mbname);
}
cyrus_done();
return 0;
}

File Metadata

Mime Type
text/x-diff
Expires
Fri, Apr 24, 10:21 AM (17 h, 40 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
18881013
Default Alt Text
(12 KB)

Event Timeline