index-mail-headers.c revision bb92096bdd934cc19def61b5fb4644af6351b62d
/* Copyright (C) 2003 Timo Sirainen */
#include "lib.h"
#include "istream.h"
#include "buffer.h"
#include "str.h"
#include "message-date.h"
#include "message-parser.h"
#include "istream-header-filter.h"
#include "imap-envelope.h"
#include "imap-bodystructure.h"
#include "index-storage.h"
#include "index-mail.h"
#include <stdlib.h>
struct index_header_lookup_ctx {
struct mailbox_header_lookup_ctx ctx;
unsigned int count;
unsigned int *idx;
const char **name;
};
{
int diff;
}
{
struct index_mail_line *lines;
int noncontiguous;
t_push();
/* sort it first so fields are grouped together and ordered by
line number */
/* go through all the header lines we found */
/* matches and header lines are both sorted, all matches
until lines[i] weren't found */
match_idx < match_count) {
/* if match[] doesn't have header_match_value,
it belongs to some older header parsing and we
just want to ignore it. */
/* this header doesn't exist. remember that. */
NULL, 0);
}
match_idx++;
}
if (match_idx < match_count) {
/* save index to first header line */
j = i + 1;
match_idx++;
}
/* buffer contains: { uint32_t line_num[], 0, header texts }
noncontiguous is just a small optimization.. */
buffer_set_used_size(buf, 0);
for (j = i+1; j < count; j++) {
break;
}
if (noncontiguous) {
for (; i < j; i++) {
}
i--;
} else {
}
}
/* this header doesn't exist. remember that. */
}
}
t_pop();
}
struct mailbox_header_lookup_ctx *_headers)
{
struct index_header_lookup_ctx *headers =
(struct index_header_lookup_ctx *)_headers;
size_t i;
struct index_mail_line, 32);
unsigned int, 32);
} else {
}
if (mail->header_match_value == 0) {
/* @UNSAFE: wrapped, we'll have to clear the buffer */
}
}
}
}
}
}
{
}
struct message_header_line *hdr,
struct index_mail *mail)
{
const char *cache_field_name;
int timezone;
data->parse_line_num++;
if (data->save_bodystructure_header) {
}
if (data->save_envelope) {
}
/* end of headers */
if (data->save_sent_date) {
/* not found */
}
}
return TRUE;
}
else {
&timezone)) {
/* 0 == parse error */
timezone = 0;
}
}
}
t_push();
t_pop();
}
if (field_idx == (unsigned int)-1) {
/* we don't want this field */
return TRUE;
}
(decision & ~MAIL_CACHE_DECISION_FORCED) !=
/* already cached */
}
}
/* first header */
/* we don't need to do anything with this header */
return TRUE;
}
}
if (!hdr->no_newline)
}
return TRUE;
}
static void
{
}
struct mailbox_header_lookup_ctx *headers)
{
return -1;
/* initialize bodystructure parsing in case we read the whole
message. */
data->parser_ctx =
} else {
/* just read the header */
}
return 0;
}
static void
{
}
{
struct mailbox_header_lookup_ctx *header_ctx;
/* we got the headers from cache - parse them to get the
envelope */
}
}
static unsigned int
{
struct mail_cache_field header_field = {
NULL, 0, MAIL_CACHE_FIELD_HEADER, 0,
};
const char *cache_field_name;
unsigned int field_idx;
t_push();
if (field_idx == (unsigned int)-1) {
}
t_pop();
return field_idx;
}
{
const unsigned char *data;
if (data[i] == '\n') {
if (i+1 == size ||
return i - pos;
}
}
}
unsigned int field_idx)
{
unsigned int count;
return -1;
return 0;
return 1;
return -1;
}
{
const unsigned char *p = *data;
size_t i;
for (i = 0; i < len; i++) {
if (p[i] == ':')
break;
}
if (i == len)
return FALSE;
for (i++; i < len; i++) {
if (!IS_LWSP(p[i]))
break;
}
*data = p + i;
return TRUE;
}
static const char *const *
{
const struct index_mail_line *lines;
const unsigned int *line_idx;
const char *value;
unsigned int i, lines_count, first_line_idx;
for (i = first_line_idx; i < lines_count; i++) {
break;
/* skip header: and drop ending LF */
value_end--;
value_end - value_start);
}
}
return array_idx(&header_values, 0);
}
{
struct mailbox_header_lookup_ctx *headers_ctx;
unsigned char *data;
unsigned int field_idx;
int ret;
/* not in cache / error - first see if it's already parsed */
if (ret != -1) {
}
}
/* parse */
headers);
if (ret < 0)
return NULL;
}
if (len == 0) {
/* cached as non-existing. */
}
/* cached. skip "header name: " parts in dest. */
for (i = 0; i < len; i++) {
if (data[i] == ':') {
/* @UNSAFE */
i += len + 1;
}
}
return array_idx(&header_values, 0);
}
{
}
{
}
struct istream *
struct mailbox_header_lookup_ctx *_headers)
{
struct index_header_lookup_ctx *headers =
(struct index_header_lookup_ctx *)_headers;
/* we have to parse the header. */
return NULL;
}
}
/* not in cache / error */
return NULL;
}
struct mailbox_header_lookup_ctx *
{
NULL, 0, MAIL_CACHE_FIELD_HEADER, 0,
};
struct index_header_lookup_ctx *ctx;
const char *const *name;
const char **sorted_headers;
unsigned int i, count;
count++;
t_push();
if (count > 0) {
/* @UNSAFE: headers need to be sorted for filter stream. */
count * sizeof(*sorted_headers));
}
/* @UNSAFE */
for (i = 0; i < count; i++) {
fields[i] = header_field;
}
if (count > 0) {
/* @UNSAFE */
for (i = 0; i < count; i++) {
}
}
t_pop();
}
{
struct index_header_lookup_ctx *ctx =
(struct index_header_lookup_ctx *)_ctx;
}