+
+ if (stream_stdout)
+ g_object_unref(stream_stdout);
+}
+
+static void
+format_part_json (GMimeObject *part, int *part_count)
+{
+ GMimeContentType *content_type;
+ GMimeContentDisposition *disposition;
+ void *ctx = talloc_new (NULL);
+ GMimeStream *stream_memory = g_mime_stream_mem_new ();
+ GByteArray *part_content;
+
+ content_type = g_mime_object_get_content_type (GMIME_OBJECT (part));
+
+ if (*part_count > 1)
+ fputs (", ", stdout);
+
+ printf ("{\"id\": %d, \"content-type\": %s",
+ *part_count,
+ json_quote_str (ctx, g_mime_content_type_to_string (content_type)));
+
+ disposition = g_mime_object_get_content_disposition (part);
+ if (disposition &&
+ strcmp (disposition->disposition, GMIME_DISPOSITION_ATTACHMENT) == 0)
+ {
+ const char *filename = g_mime_part_get_filename (GMIME_PART (part));
+
+ printf (", \"filename\": %s", json_quote_str (ctx, filename));
+ }
+
+ if (g_mime_content_type_is_type (content_type, "text", "*") &&
+ !g_mime_content_type_is_type (content_type, "text", "html"))
+ {
+ show_part_content (part, stream_memory);
+ part_content = g_mime_stream_mem_get_byte_array (GMIME_STREAM_MEM (stream_memory));
+
+ printf (", \"content\": %s", json_quote_str (ctx, (char *) part_content->data));
+ }
+
+ fputs ("}", stdout);
+
+ talloc_free (ctx);
+ if (stream_memory)
+ g_object_unref (stream_memory);
+}
+
+static void
+show_message (void *ctx, const show_format_t *format, notmuch_message_t *message, int indent)
+{
+ fputs (format->message_start, stdout);
+ if (format->message)
+ format->message(ctx, message, indent);
+
+ fputs (format->header_start, stdout);
+ if (format->header)
+ format->header(ctx, message);
+ fputs (format->header_end, stdout);
+
+ fputs (format->body_start, stdout);
+ if (format->part)
+ show_message_body (notmuch_message_get_filename (message), format->part);
+ fputs (format->body_end, stdout);
+
+ fputs (format->message_end, stdout);
+}
+
+
+static void
+show_messages (void *ctx, const show_format_t *format, notmuch_messages_t *messages, int indent,
+ notmuch_bool_t entire_thread)
+{
+ notmuch_message_t *message;
+ notmuch_bool_t match;
+ int first_set = 1;
+ int next_indent;
+
+ fputs (format->message_set_start, stdout);
+
+ for (;
+ notmuch_messages_has_more (messages);
+ notmuch_messages_advance (messages))
+ {
+ if (!first_set)
+ fputs (format->message_set_sep, stdout);
+ first_set = 0;
+
+ fputs (format->message_set_start, stdout);
+
+ message = notmuch_messages_get (messages);
+
+ match = notmuch_message_get_flag (message, NOTMUCH_MESSAGE_FLAG_MATCH);
+
+ next_indent = indent;
+
+ if (match || entire_thread) {
+ show_message (ctx, format, message, indent);
+ next_indent = indent + 1;
+
+ fputs (format->message_set_sep, stdout);
+ }
+
+ show_messages (ctx, format, notmuch_message_get_replies (message),
+ next_indent, entire_thread);
+
+ notmuch_message_destroy (message);
+
+ fputs (format->message_set_end, stdout);
+ }
+
+ fputs (format->message_set_end, stdout);