From: Jani Nikula Date: Sat, 13 Aug 2016 11:37:26 +0000 (+0300) Subject: [PATCH v2 02/14] cli/reply: push notmuch reply format abstraction lower in the stack X-Git-Url: http://git.tremily.us/?a=commitdiff_plain;h=84366b34cb740b588b5855cf58e9e59eef3c3b64;p=notmuch-archives.git [PATCH v2 02/14] cli/reply: push notmuch reply format abstraction lower in the stack --- diff --git a/09/8d1253e749d12d0dcdee2409ab6843277f3008 b/09/8d1253e749d12d0dcdee2409ab6843277f3008 new file mode 100644 index 000000000..b88beb135 --- /dev/null +++ b/09/8d1253e749d12d0dcdee2409ab6843277f3008 @@ -0,0 +1,420 @@ +Return-Path: +X-Original-To: notmuch@notmuchmail.org +Delivered-To: notmuch@notmuchmail.org +Received: from localhost (localhost [127.0.0.1]) + by arlo.cworth.org (Postfix) with ESMTP id A0A4B6DE396E + for ; Sat, 13 Aug 2016 04:39:20 -0700 (PDT) +X-Virus-Scanned: Debian amavisd-new at cworth.org +X-Amavis-Alert: BAD HEADER SECTION, Duplicate header field: "References" +X-Spam-Flag: NO +X-Spam-Score: -0.573 +X-Spam-Level: +X-Spam-Status: No, score=-0.573 tagged_above=-999 required=5 tests=[AWL=0.147, + DKIM_SIGNED=0.1, DKIM_VALID=-0.1, RCVD_IN_DNSWL_LOW=-0.7, + RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01] autolearn=disabled +Received: from arlo.cworth.org ([127.0.0.1]) + by localhost (arlo.cworth.org [127.0.0.1]) (amavisd-new, port 10024) + with ESMTP id gmMDVdnOM9nr for ; + Sat, 13 Aug 2016 04:39:12 -0700 (PDT) +Received: from mail-wm0-f68.google.com (mail-wm0-f68.google.com + [74.125.82.68]) by arlo.cworth.org (Postfix) with ESMTPS id 8A1076DE38C3 for + ; Sat, 13 Aug 2016 04:39:06 -0700 (PDT) +Received: by mail-wm0-f68.google.com with SMTP id i138so2003901wmf.3 + for ; Sat, 13 Aug 2016 04:39:06 -0700 (PDT) +DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; + d=nikula-org.20150623.gappssmtp.com; s=20150623; + h=from:to:cc:subject:date:message-id:in-reply-to:references + :in-reply-to:references; + bh=0gTT1Cs2x5flbIL5lOKo8lgQoRdqG9bi3NSycpTh6/I=; + b=cG01yENNqs2IXTeaO6+h661JOurOsGj+j0sGc5a9TKmNyvc0kS/8hMMItDl0BEb0bU + tBXZQy/ZI2MFj6G50KLcoIbyVC+vd5srbqkMa7dI6nBtJ+BKCDPkrjCs6sR+1BjgQXQd + AndhrTnMXVLnFaXJ7zV2F7RzO1NWx2ysX+HeliR4DUMnc6rW7PGHMAPmtaKbgicOOUjY + w9FK0P6x3rioVsTdEupH+ZIbfTGWEgFTb+5e/EiILjBCjFdY8azr6lnTCABqb7UCSXxT + 5ZEw+b5QT6rqrxZTLyJJakacq3+oliw4QXkiIlKWg03UQshKctDHfC0QGiWktRy48UxQ + 53jg== +X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; + d=1e100.net; s=20130820; + h=x-gm-message-state:from:to:cc:subject:date:message-id:in-reply-to + :references:in-reply-to:references; + bh=0gTT1Cs2x5flbIL5lOKo8lgQoRdqG9bi3NSycpTh6/I=; + b=fQQi2gsnLDYi9SNsLYlxDjHlcwkec9mHlbJmtPSipAkYOQXE39Us5cgcQRaVQRhB1J + sRHfeVUB5kZQHjyotBFwJreJAPM0m3bF341W7UfgZBL9ns4MKe4XGnpf3NO3gq7td91X + behuh2AGhl6gxsY4bNcNcpjiHRUX22KuoWpPvYyeIll/GhRer4lS0Xzfuw+GahC/npYu + rI6hijHxsPB5VSWh3i+RAcl7h+mT08ojQU9djzt8pc0nAGxpD4NZHmoqj3NoHXB8DwyU + 0JE6sBFoGUTOks89w8ZMcHC+pMY/O24qUqS+pnPBVJYPUIyoqFDufFrh62ixX3+8JJX/ + 2Tng== +X-Gm-Message-State: + AEkoouuvpXgZBNZCpj2fWvO83qomQkvT6imaJyZOc5D9tCLZfUu8l30wy87qvqiZWngEug== +X-Received: by 10.194.41.194 with SMTP id h2mr23191319wjl.2.1471088345119; + Sat, 13 Aug 2016 04:39:05 -0700 (PDT) +Received: from localhost (mobile-access-bcee63-250.dhcp.inet.fi. + [188.238.99.250]) + by smtp.gmail.com with ESMTPSA id ly9sm11749251wjb.44.2016.08.13.04.39.04 + (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); + Sat, 13 Aug 2016 04:39:04 -0700 (PDT) +From: Jani Nikula +To: notmuch@notmuchmail.org +Cc: Daniel Kahn Gillmor , + jani@nikula.org +Subject: [PATCH v2 02/14] cli/reply: push notmuch reply format abstraction + lower in the stack +Date: Sat, 13 Aug 2016 14:37:26 +0300 +Message-Id: + <3760ff3cc6083d5f24c280a97121beccce8e0c5e.1471088022.git.jani@nikula.org> +X-Mailer: git-send-email 2.1.4 +In-Reply-To: +References: +In-Reply-To: +References: +X-BeenThere: notmuch@notmuchmail.org +X-Mailman-Version: 2.1.20 +Precedence: list +List-Id: "Use and development of the notmuch mail system." + +List-Unsubscribe: , + +List-Archive: +List-Post: +List-Help: +List-Subscribe: , + +X-List-Received-Date: Sat, 13 Aug 2016 11:39:20 -0000 + +There's quite a bit of duplication, and some consequent deviation, +between the various notmuch reply format code paths. Perform the query +and message iteration in common code, and make the format specific +functions operate on single messages. + +There should be no functional changes. +--- + notmuch-reply.c | 216 ++++++++++++++++++++++++++------------------------------ + 1 file changed, 101 insertions(+), 115 deletions(-) + +diff --git a/notmuch-reply.c b/notmuch-reply.c +index 49513732e620..847e306f94d2 100644 +--- a/notmuch-reply.c ++++ b/notmuch-reply.c +@@ -598,82 +598,42 @@ create_reply_message(void *ctx, + static int + notmuch_reply_format_default(void *ctx, + notmuch_config_t *config, +- notmuch_query_t *query, ++ notmuch_message_t *message, + notmuch_show_params_t *params, + notmuch_bool_t reply_all, + unused (sprinter_t *sp)) + { + GMimeMessage *reply; +- notmuch_messages_t *messages; +- notmuch_message_t *message; + mime_node_t *root; +- notmuch_status_t status; + +- status = notmuch_query_search_messages_st (query, &messages); +- if (print_status_query ("notmuch reply", query, status)) ++ reply = create_reply_message (ctx, config, message, reply_all); ++ if (!reply) + return 1; + +- for (; +- notmuch_messages_valid (messages); +- notmuch_messages_move_to_next (messages)) +- { +- message = notmuch_messages_get (messages); ++ show_reply_headers (reply); + +- reply = create_reply_message (ctx, config, message, reply_all); +- +- /* If reply creation failed, we're out of memory, so don't +- * bother trying any more messages. +- */ +- if (!reply) { +- notmuch_message_destroy (message); +- return 1; +- } +- +- show_reply_headers (reply); +- +- g_object_unref (G_OBJECT (reply)); +- reply = NULL; +- +- if (mime_node_open (ctx, message, &(params->crypto), &root) == NOTMUCH_STATUS_SUCCESS) { +- format_part_reply (root); +- talloc_free (root); +- } ++ g_object_unref (G_OBJECT (reply)); + +- notmuch_message_destroy (message); ++ if (mime_node_open (ctx, message, ¶ms->crypto, &root) == NOTMUCH_STATUS_SUCCESS) { ++ format_part_reply (root); ++ talloc_free (root); + } ++ + return 0; + } + + static int + notmuch_reply_format_sprinter(void *ctx, + notmuch_config_t *config, +- notmuch_query_t *query, ++ notmuch_message_t *message, + notmuch_show_params_t *params, + notmuch_bool_t reply_all, + sprinter_t *sp) + { + GMimeMessage *reply; +- notmuch_messages_t *messages; +- notmuch_message_t *message; + mime_node_t *node; +- unsigned count; +- notmuch_status_t status; +- +- status = notmuch_query_count_messages_st (query, &count); +- if (print_status_query ("notmuch reply", query, status)) +- return 1; +- +- if (count != 1) { +- fprintf (stderr, "Error: search term did not match precisely one message (matched %d messages).\n", count); +- return 1; +- } + +- status = notmuch_query_search_messages_st (query, &messages); +- if (print_status_query ("notmuch reply", query, status)) +- return 1; +- +- message = notmuch_messages_get (messages); +- if (mime_node_open (ctx, message, &(params->crypto), &node) != NOTMUCH_STATUS_SUCCESS) ++ if (mime_node_open (ctx, message, ¶ms->crypto, &node) != NOTMUCH_STATUS_SUCCESS) + return 1; + + reply = create_reply_message (ctx, config, message, reply_all); +@@ -686,7 +646,6 @@ notmuch_reply_format_sprinter(void *ctx, + sp->map_key (sp, "reply-headers"); + format_headers_sprinter (sp, reply, TRUE); + g_object_unref (G_OBJECT (reply)); +- reply = NULL; + + /* Start the original */ + sp->map_key (sp, "original"); +@@ -694,7 +653,6 @@ notmuch_reply_format_sprinter(void *ctx, + + /* End */ + sp->end (sp); +- notmuch_message_destroy (message); + + return 0; + } +@@ -703,65 +661,48 @@ notmuch_reply_format_sprinter(void *ctx, + static int + notmuch_reply_format_headers_only(void *ctx, + notmuch_config_t *config, +- notmuch_query_t *query, ++ notmuch_message_t *message, + unused (notmuch_show_params_t *params), + notmuch_bool_t reply_all, + unused (sprinter_t *sp)) + { + GMimeMessage *reply; +- notmuch_messages_t *messages; +- notmuch_message_t *message; + const char *in_reply_to, *orig_references, *references; + char *reply_headers; +- notmuch_status_t status; + +- status = notmuch_query_search_messages_st (query, &messages); +- if (print_status_query ("notmuch reply", query, status)) ++ /* The 0 means we do not want headers in a "pretty" order. */ ++ reply = g_mime_message_new (0); ++ if (reply == NULL) { ++ fprintf (stderr, "Out of memory\n"); + return 1; ++ } + +- for (; +- notmuch_messages_valid (messages); +- notmuch_messages_move_to_next (messages)) +- { +- message = notmuch_messages_get (messages); +- +- /* The 0 means we do not want headers in a "pretty" order. */ +- reply = g_mime_message_new (0); +- if (reply == NULL) { +- fprintf (stderr, "Out of memory\n"); +- return 1; +- } +- +- in_reply_to = talloc_asprintf (ctx, "<%s>", +- notmuch_message_get_message_id (message)); +- +- g_mime_object_set_header (GMIME_OBJECT (reply), +- "In-Reply-To", in_reply_to); ++ in_reply_to = talloc_asprintf (ctx, "<%s>", ++ notmuch_message_get_message_id (message)); + ++ g_mime_object_set_header (GMIME_OBJECT (reply), "In-Reply-To", in_reply_to); + +- orig_references = notmuch_message_get_header (message, "references"); ++ orig_references = notmuch_message_get_header (message, "references"); + +- /* We print In-Reply-To followed by References because git format-patch treats them +- * specially. Git does not interpret the other headers specially +- */ +- references = talloc_asprintf (ctx, "%s%s%s", +- orig_references ? orig_references : "", +- orig_references ? " " : "", +- in_reply_to); +- g_mime_object_set_header (GMIME_OBJECT (reply), +- "References", references); ++ /* ++ * We print In-Reply-To followed by References because git ++ * format-patch treats them specially. Git does not interpret the ++ * other headers specially. ++ */ ++ references = talloc_asprintf (ctx, "%s%s%s", ++ orig_references ? orig_references : "", ++ orig_references ? " " : "", ++ in_reply_to); ++ g_mime_object_set_header (GMIME_OBJECT (reply), "References", references); + +- (void)add_recipients_from_message (reply, config, message, reply_all); ++ (void)add_recipients_from_message (reply, config, message, reply_all); + +- reply_headers = g_mime_object_to_string (GMIME_OBJECT (reply)); +- printf ("%s", reply_headers); +- free (reply_headers); ++ reply_headers = g_mime_object_to_string (GMIME_OBJECT (reply)); ++ printf ("%s", reply_headers); ++ free (reply_headers); + +- g_object_unref (G_OBJECT (reply)); +- reply = NULL; ++ g_object_unref (G_OBJECT (reply)); + +- notmuch_message_destroy (message); +- } + return 0; + } + +@@ -772,6 +713,70 @@ enum { + FORMAT_HEADERS_ONLY, + }; + ++static int do_reply(notmuch_config_t *config, ++ notmuch_query_t *query, ++ notmuch_show_params_t *params, ++ int format, ++ notmuch_bool_t reply_all) ++{ ++ notmuch_messages_t *messages; ++ notmuch_message_t *message; ++ notmuch_status_t status; ++ struct sprinter *sp = NULL; ++ int ret = 0; ++ int (*reply_format_func) (void *ctx, ++ notmuch_config_t *config, ++ notmuch_message_t *message, ++ notmuch_show_params_t *params, ++ notmuch_bool_t reply_all, ++ struct sprinter *sp); ++ ++ if (format == FORMAT_JSON || format == FORMAT_SEXP) { ++ unsigned count; ++ ++ status = notmuch_query_count_messages_st (query, &count); ++ if (print_status_query ("notmuch reply", query, status)) ++ return 1; ++ ++ if (count != 1) { ++ fprintf (stderr, "Error: search term did not match precisely one message (matched %d messages).\n", count); ++ return 1; ++ } ++ } ++ ++ if (format == FORMAT_HEADERS_ONLY) { ++ reply_format_func = notmuch_reply_format_headers_only; ++ } else if (format == FORMAT_JSON) { ++ reply_format_func = notmuch_reply_format_sprinter; ++ sp = sprinter_json_create (config, stdout); ++ } else if (format == FORMAT_SEXP) { ++ reply_format_func = notmuch_reply_format_sprinter; ++ sp = sprinter_sexp_create (config, stdout); ++ } else { ++ reply_format_func = notmuch_reply_format_default; ++ } ++ ++ status = notmuch_query_search_messages_st (query, &messages); ++ if (print_status_query ("notmuch reply", query, status)) ++ return 1; ++ ++ for (; ++ notmuch_messages_valid (messages); ++ notmuch_messages_move_to_next (messages)) ++ { ++ message = notmuch_messages_get (messages); ++ ++ ret = reply_format_func(config, config, message, params, reply_all, sp); ++ ++ notmuch_message_destroy (message); ++ ++ if (ret) ++ break; ++ } ++ ++ return ret; ++} ++ + int + notmuch_reply_command (notmuch_config_t *config, int argc, char *argv[]) + { +@@ -779,12 +784,6 @@ notmuch_reply_command (notmuch_config_t *config, int argc, char *argv[]) + notmuch_query_t *query; + char *query_string; + int opt_index; +- int (*reply_format_func) (void *ctx, +- notmuch_config_t *config, +- notmuch_query_t *query, +- notmuch_show_params_t *params, +- notmuch_bool_t reply_all, +- struct sprinter *sp); + notmuch_show_params_t params = { + .part = -1, + .crypto = { +@@ -795,7 +794,6 @@ notmuch_reply_command (notmuch_config_t *config, int argc, char *argv[]) + }; + int format = FORMAT_DEFAULT; + int reply_all = TRUE; +- struct sprinter *sp = NULL; + + notmuch_opt_desc_t options[] = { + { NOTMUCH_OPT_KEYWORD, &format, "format", 'f', +@@ -820,18 +818,6 @@ notmuch_reply_command (notmuch_config_t *config, int argc, char *argv[]) + + notmuch_process_shared_options (argv[0]); + +- if (format == FORMAT_HEADERS_ONLY) { +- reply_format_func = notmuch_reply_format_headers_only; +- } else if (format == FORMAT_JSON) { +- reply_format_func = notmuch_reply_format_sprinter; +- sp = sprinter_json_create (config, stdout); +- } else if (format == FORMAT_SEXP) { +- reply_format_func = notmuch_reply_format_sprinter; +- sp = sprinter_sexp_create (config, stdout); +- } else { +- reply_format_func = notmuch_reply_format_default; +- } +- + notmuch_exit_if_unsupported_format (); + + query_string = query_string_from_args (config, argc-opt_index, argv+opt_index); +@@ -859,7 +845,7 @@ notmuch_reply_command (notmuch_config_t *config, int argc, char *argv[]) + return EXIT_FAILURE; + } + +- if (reply_format_func (config, config, query, ¶ms, reply_all, sp) != 0) ++ if (do_reply (config, query, ¶ms, format, reply_all) != 0) + return EXIT_FAILURE; + + notmuch_crypto_cleanup (¶ms.crypto); +-- +2.1.4 +