X-Git-Url: https://git.notmuchmail.org/git?p=notmuch;a=blobdiff_plain;f=show-message.c;h=8768889efddd11ed665e84f788bf0864bd6da3c3;hp=b1b61be40c2618fddcc56c46e683e517f9101f7d;hb=d61cef374b3234c2f1327fa74b612b40c196a605;hpb=2e9c7aba99598eafd7b5fc52897da14ea13af216 diff --git a/show-message.c b/show-message.c index b1b61be4..8768889e 100644 --- a/show-message.c +++ b/show-message.c @@ -22,175 +22,81 @@ #include "notmuch-client.h" -static void -show_message_part (GMimeObject *part, int *part_count, - void (*show_part) (GMimeObject *part, int *part_count)) -{ - if (GMIME_IS_MULTIPART (part)) { - GMimeMultipart *multipart = GMIME_MULTIPART (part); - int i; - - for (i = 0; i < g_mime_multipart_get_count (multipart); i++) { - show_message_part (g_mime_multipart_get_part (multipart, i), - part_count, show_part); - } - return; - } - - if (GMIME_IS_MESSAGE_PART (part)) { - GMimeMessage *mime_message; - - mime_message = g_mime_message_part_get_message (GMIME_MESSAGE_PART (part)); - - show_message_part (g_mime_message_get_mime_part (mime_message), - part_count, show_part); - - return; - } - - if (! (GMIME_IS_PART (part))) { - fprintf (stderr, "Warning: Not displaying unknown mime part: %s.\n", - g_type_name (G_OBJECT_TYPE (part))); - return; - } +typedef struct show_message_state { + int part_count; +} show_message_state_t; - *part_count = *part_count + 1; - - (*show_part) (part, part_count); -} - -notmuch_status_t -show_message_body (const char *filename, - void (*show_part) (GMimeObject *part, int *part_count)) +static void +show_message_part (mime_node_t *node, + show_message_state_t *state, + const notmuch_show_format_t *format, + int first) { - GMimeStream *stream = NULL; - GMimeParser *parser = NULL; - GMimeMessage *mime_message = NULL; - notmuch_status_t ret = NOTMUCH_STATUS_SUCCESS; - FILE *file = NULL; - int part_count = 0; - - file = fopen (filename, "r"); - if (! file) { - fprintf (stderr, "Error opening %s: %s\n", filename, strerror (errno)); - ret = NOTMUCH_STATUS_FILE_ERROR; - goto DONE; - } - - stream = g_mime_stream_file_new (file); - g_mime_stream_file_set_owner (GMIME_STREAM_FILE (stream), FALSE); - - parser = g_mime_parser_new_with_stream (stream); - - mime_message = g_mime_parser_construct_message (parser); + /* Formatters expect the envelope for embedded message parts */ + GMimeObject *part = node->envelope_part ? + GMIME_OBJECT (node->envelope_part) : node->part; + int i; - show_message_part (g_mime_message_get_mime_part (mime_message), - &part_count, show_part); + if (!first) + fputs (format->part_sep, stdout); - DONE: - if (mime_message) - g_object_unref (mime_message); + /* Format this part */ + if (format->part_start) + format->part_start (part, &(state->part_count)); - if (parser) - g_object_unref (parser); + if (node->decrypt_attempted && format->part_encstatus) + format->part_encstatus (node->decrypt_success); - if (stream) - g_object_unref (stream); + if (node->verify_attempted && format->part_sigstatus) + format->part_sigstatus (node->sig_validity); - if (file) - fclose (file); + format->part_content (part); - return ret; -} - -static void -show_one_part_output (GMimeObject *part) -{ - GMimeStream *stream_filter = NULL; - GMimeDataWrapper *wrapper; - GMimeStream *stream_stdout = g_mime_stream_file_new (stdout); - - stream_filter = g_mime_stream_filter_new(stream_stdout); - wrapper = g_mime_part_get_content_object (GMIME_PART (part)); - if (wrapper && stream_filter) - g_mime_data_wrapper_write_to_stream (wrapper, stream_filter); - if (stream_filter) - g_object_unref(stream_filter); -} + if (node->envelope_part) { + fputs (format->header_start, stdout); + if (format->header_message_part) + format->header_message_part (GMIME_MESSAGE (node->part)); + fputs (format->header_end, stdout); -static void -show_one_part_worker (GMimeObject *part, int *part_count, int desired_part) -{ - if (GMIME_IS_MULTIPART (part)) { - GMimeMultipart *multipart = GMIME_MULTIPART (part); - int i; - - for (i = 0; i < g_mime_multipart_get_count (multipart); i++) { - show_one_part_worker (g_mime_multipart_get_part (multipart, i), - part_count, desired_part); - } - return; + fputs (format->body_start, stdout); } - if (GMIME_IS_MESSAGE_PART (part)) { - GMimeMessage *mime_message; - - mime_message = g_mime_message_part_get_message (GMIME_MESSAGE_PART (part)); + /* Recurse over the children */ + state->part_count += 1; + for (i = 0; i < node->nchildren; i++) + show_message_part (mime_node_child (node, i), state, format, i == 0); - show_one_part_worker (g_mime_message_get_mime_part (mime_message), - part_count, desired_part); - - return; - } + /* Finish this part */ + if (node->envelope_part) + fputs (format->body_end, stdout); - if (! (GMIME_IS_PART (part))) - return; - - *part_count = *part_count + 1; - - if (*part_count == desired_part) - show_one_part_output (part); + if (format->part_end) + format->part_end (part); } notmuch_status_t -show_one_part (const char *filename, int part) +show_message_body (notmuch_message_t *message, + const notmuch_show_format_t *format, + notmuch_show_params_t *params) { - GMimeStream *stream = NULL; - GMimeParser *parser = NULL; - GMimeMessage *mime_message = NULL; - notmuch_status_t ret = NOTMUCH_STATUS_SUCCESS; - FILE *file = NULL; - int part_count = 0; - - file = fopen (filename, "r"); - if (! file) { - fprintf (stderr, "Error opening %s: %s\n", filename, strerror (errno)); - ret = NOTMUCH_STATUS_FILE_ERROR; - goto DONE; - } - - stream = g_mime_stream_file_new (file); - g_mime_stream_file_set_owner (GMIME_STREAM_FILE (stream), FALSE); - - parser = g_mime_parser_new_with_stream (stream); + notmuch_status_t ret; + show_message_state_t state; + mime_node_t *root, *part; - mime_message = g_mime_parser_construct_message (parser); - - show_one_part_worker (g_mime_message_get_mime_part (mime_message), - &part_count, part); - - DONE: - if (mime_message) - g_object_unref (mime_message); + ret = mime_node_open (NULL, message, params->cryptoctx, params->decrypt, + &root); + if (ret) + return ret; - if (parser) - g_object_unref (parser); + /* The caller of show_message_body has already handled the + * outermost envelope, so skip it. */ + state.part_count = MAX (params->part, 1); - if (stream) - g_object_unref (stream); + part = mime_node_seek_dfs (root, state.part_count); + if (part) + show_message_part (part, &state, format, TRUE); - if (file) - fclose (file); + talloc_free (root); - return ret; + return NOTMUCH_STATUS_SUCCESS; }