Quelle  cleanup.h

/*++
/* NAME
/* cleanup 3h
/* SUMMARY
/* canonicalize and enqueue message
/* SYNOPSIS
/* #include "cleanup.h"
/* DESCRIPTION
/* .nf

 /*
  * System library.
  */
#include <sys/time.h>
#include <stdint.h>   /* C99 uint64_t */

 /*
  * Utility library.
  */
#include <vstring.h>
#include <vstream.h>
#include <argv.h>
#include <nvtable.h>

 /*
  * Global library.
  */
#include <maps.h>
#include <tok822.h>
#include <been_here.h>
#include <mail_stream.h>
#include <mail_conf.h>
#include <mime_state.h>
#include <string_list.h>
#include <cleanup_user.h>
#include <header_body_checks.h>
#include <dsn_mask.h>

 /*
  * Milter library.
  */
#include <milter.h>

 /*
  * These state variables are accessed by many functions, and there is only
  * one instance of each per message.
  */
typedef struct CLEANUP_STATE {
    VSTRING *attr_buf;   /* storage for named attribute */
    VSTRING *temp1;   /* scratch buffer, local use only */
    VSTRING *temp2;   /* scratch buffer, local use only */
    VSTRING *temp3;   /* scratch buffer, local use only */
    VSTRING *stripped_buf;  /* character stripped input */
    VSTREAM *src;   /* current input stream */
    VSTREAM *dst;   /* current output stream */
    MAIL_STREAM *handle;  /* mail stream handle */
    char   *queue_name;   /* queue name */
    char   *queue_id;   /* queue file basename */
    struct timeval arrival_time; /* arrival time */
    char   *fullname;   /* envelope sender full name */
    char   *sender;   /* envelope sender address */
    char   *recip;   /* envelope recipient address */
    char   *orig_rcpt;   /* original recipient address */
    char   *return_receipt;  /* return-receipt address */
    char   *errors_to;   /* errors-to address */
    ARGV   *auto_hdrs;   /* MTA's own header(s) */
    ARGV   *hbc_rcpt;   /* header/body checks BCC addresses */
    int     flags;   /* processing options, status flags */
    int     tflags;   /* User- or MTA-requested tracing */
    int     qmgr_opts;   /* qmgr processing options */
    int     errs;   /* any badness experienced */
    int     err_mask;   /* allowed badness */
    uint64_t headers_seen;  /* which headers were seen */
    int     hop_count;   /* count of received: headers */
    char   *resent;   /* any resent- header seen */
    BH_TABLE *dups;   /* recipient dup filter */
    void    (*action) (struct CLEANUP_STATE *, int, const char *, ssize_t);
    off_t   data_offset;  /* start of message content */
    off_t   body_offset;  /* start of body content */
    off_t   xtra_offset;  /* start of extra segment */
    off_t   cont_length;  /* length including Milter edits */
    off_t   sender_pt_offset;  /* replace sender here */
    off_t   sender_pt_target;  /* record after sender address */
    off_t   append_rcpt_pt_offset; /* append recipient here */
    off_t   append_rcpt_pt_target; /* target of above record */
    off_t   append_hdr_pt_offset; /* append header here */
    off_t   append_hdr_pt_target; /* target of above record */
    off_t   append_meta_pt_offset; /* append meta record here */
    off_t   append_meta_pt_target; /* target of above record */
    ssize_t rcpt_count;   /* recipient count */
    char   *reason;   /* failure reason */
    char   *smtp_reply;   /* failure reason, SMTP-style */
    NVTABLE *attr;   /* queue file attribute list */
    MIME_STATE *mime_state;  /* MIME state engine */
    int     mime_errs;   /* MIME error flags */
    char   *hdr_rewrite_context; /* header rewrite context */
    char   *filter;   /* from header/body patterns */
    char   *redirect;   /* from header/body patterns */
    char   *message_id;   /* from Message-ID header */
    char   *dsn_envid;   /* DSN envelope ID */
    int     dsn_ret;   /* DSN full/hdrs */
    int     dsn_notify;   /* DSN never/delay/fail/success */
    char   *dsn_orcpt;   /* DSN original recipient */
    char   *verp_delims;  /* VERP delimiters (optional) */
#ifdef DELAY_ACTION
    int     defer_delay;  /* deferred delivery */
#endif

    /*
     * Miscellaneous Milter support.
     */
    MILTERS *milters;   /* mail filters */
    const char *client_name;  /* real or ersatz client */
    const char *reverse_name;  /* real or ersatz client */
    const char *client_addr;  /* real or ersatz client */
    int     client_af;   /* real or ersatz client */
    const char *client_port;  /* real or ersatz client */
    const char *server_addr;  /* real or ersatz server */
    const char *server_port;  /* real or ersatz server */
    VSTRING *milter_ext_from;  /* externalized sender */
    VSTRING *milter_ext_rcpt;  /* externalized recipient */
    VSTRING *milter_err_text;  /* milter call-back reply */
    VSTRING *milter_dsn_buf;  /* Milter DSN parsing buffer */

    /*
     * Support for Milter body replacement requests.
     */
    struct CLEANUP_REGION *free_regions;/* unused regions */
    struct CLEANUP_REGION *body_regions;/* regions with body content */
    struct CLEANUP_REGION *curr_body_region;

    /*
     * Internationalization, RequireTLS, etc.
     */
    int     sendopts;   /* what support is desired */
    int     reqtls_esmtp_hdr_seen; /* valid Require-TLS-ESMTP header */
} CLEANUP_STATE;

 /*
  * Status flags. Flags 0-15 are reserved for cleanup_user.h.
  */
#define CLEANUP_FLAG_INRCPT (1<<16) /* Processing recipient records */
#define CLEANUP_FLAG_WARN_SEEN (1<<17) /* REC_TYPE_WARN record seen */
#define CLEANUP_FLAG_END_SEEN (1<<18) /* REC_TYPE_END record seen */

 /*
  * Bit mask for the CLEANUP_STATE.headers_seen member.
  */
#define HDRS_SEEN_MASK(hval)  ((uint64_t) 1 << (hval))

 /*
  * Mappings.
  */
extern MAPS *cleanup_comm_canon_maps;
extern MAPS *cleanup_send_canon_maps;
extern MAPS *cleanup_rcpt_canon_maps;
extern int cleanup_comm_canon_flags;
extern int cleanup_send_canon_flags;
extern int cleanup_rcpt_canon_flags;
extern MAPS *cleanup_header_checks;
extern MAPS *cleanup_mimehdr_checks;
extern MAPS *cleanup_nesthdr_checks;
extern MAPS *cleanup_body_checks;
extern MAPS *cleanup_virt_alias_maps;
extern ARGV *cleanup_masq_domains;
extern STRING_LIST *cleanup_masq_exceptions;
extern int cleanup_masq_flags;
extern MAPS *cleanup_send_bcc_maps;
extern MAPS *cleanup_rcpt_bcc_maps;

 /*
  * Character filters.
  */
extern VSTRING *cleanup_reject_chars;
extern VSTRING *cleanup_strip_chars;

 /*
  * Milters.
  */
extern MILTERS *cleanup_milters;

 /*
  * Address canonicalization fine control.
  */
#define CLEANUP_CANON_FLAG_ENV_FROM (1<<0) /* envelope sender */
#define CLEANUP_CANON_FLAG_ENV_RCPT (1<<1) /* envelope recipient */
#define CLEANUP_CANON_FLAG_HDR_FROM (1<<2) /* header sender */
#define CLEANUP_CANON_FLAG_HDR_RCPT (1<<3) /* header recipient */

 /*
  * Address masquerading fine control.
  */
#define CLEANUP_MASQ_FLAG_ENV_FROM (1<<0) /* envelope sender */
#define CLEANUP_MASQ_FLAG_ENV_RCPT (1<<1) /* envelope recipient */
#define CLEANUP_MASQ_FLAG_HDR_FROM (1<<2) /* header sender */
#define CLEANUP_MASQ_FLAG_HDR_RCPT (1<<3) /* header recipient */

 /*
  * Restrictions on extension propagation.
  */
extern int cleanup_ext_prop_mask;

 /*
  * Saved queue file names, so the files can be removed in case of a fatal
  * run-time error.
  */
extern char *cleanup_path;
extern VSTRING *cleanup_trace_path;
extern VSTRING *cleanup_bounce_path;

 /*
  * cleanup_state.c
  */
extern CLEANUP_STATE *cleanup_state_alloc(VSTREAM *);
extern void cleanup_state_free(CLEANUP_STATE *);

 /*
  * cleanup_api.c
  */
extern CLEANUP_STATE *cleanup_open(VSTREAM *);
extern void cleanup_control(CLEANUP_STATE *, int);
extern int cleanup_flush(CLEANUP_STATE *);
extern void cleanup_free(CLEANUP_STATE *);
extern void cleanup_all(void);
extern void cleanup_sig(int);
extern void cleanup_pre_jail(char *, char **);
extern void cleanup_post_jail(char *, char **);
extern const CONFIG_INT_TABLE cleanup_int_table[];
extern const CONFIG_BOOL_TABLE cleanup_bool_table[];
extern const CONFIG_NBOOL_TABLE cleanup_nbool_table[];
extern const CONFIG_STR_TABLE cleanup_str_table[];
extern const CONFIG_TIME_TABLE cleanup_time_table[];

#define CLEANUP_RECORD(s, t, b, l) ((s)->action((s), (t), (b), (l)))

 /*
  * cleanup_out.c
  */
extern void cleanup_out(CLEANUP_STATE *, int, const char *, ssize_t);
extern void cleanup_out_string(CLEANUP_STATE *, int, const char *);
extern void PRINTFLIKE(3, 4) cleanup_out_format(CLEANUP_STATE *, int, const char *,...);
extern void cleanup_out_header(CLEANUP_STATE *, VSTRING *);

#define CLEANUP_OUT_BUF(s, t, b) \
 cleanup_out((s), (t), vstring_str((b)), VSTRING_LEN((b)))

#define CLEANUP_OUT_OK(s) \
 (!((s)->errs & (s)->err_mask) && !((s)->flags & CLEANUP_FLAG_DISCARD))

 /*
  * cleanup_envelope.c
  */
extern void cleanup_envelope(CLEANUP_STATE *, int, const char *, ssize_t);

 /*
  * cleanup_message.c
  */
extern void cleanup_message(CLEANUP_STATE *, int, const char *, ssize_t);

 /*
  * cleanup_extracted.c
  */
extern void cleanup_extracted(CLEANUP_STATE *, int, const char *, ssize_t);

 /*
  * cleanup_final.c
  */
extern void cleanup_final(CLEANUP_STATE *);

 /*
  * cleanup_rewrite.c
  */
extern int cleanup_rewrite_external(const char *, VSTRING *, const char *);
extern int cleanup_rewrite_internal(const char *, VSTRING *, const char *);
extern int cleanup_rewrite_tree(const char *, TOK822 *);

 /*
  * cleanup_map11.c
  */
extern int cleanup_map11_external(CLEANUP_STATE *, VSTRING *, MAPS *, int);
extern int cleanup_map11_internal(CLEANUP_STATE *, VSTRING *, MAPS *, int);
extern int cleanup_map11_tree(CLEANUP_STATE *, TOK822 *, MAPS *, int);

 /*
  * cleanup_map1n.c
  */
ARGV   *cleanup_map1n_internal(CLEANUP_STATE *, const char *, MAPS *, int);

 /*
  * cleanup_masquerade.c
  */
extern int cleanup_masquerade_external(CLEANUP_STATE *, VSTRING *, ARGV *);
extern int cleanup_masquerade_internal(CLEANUP_STATE *, VSTRING *, ARGV *);
extern int cleanup_masquerade_tree(CLEANUP_STATE *, TOK822 *, ARGV *);

 /*
  * cleanup_recipient.c
  */
extern void cleanup_out_recipient(CLEANUP_STATE *, const char *, int, const char *, const char *);

 /*
  * cleanup_addr.c.
  */
extern off_t cleanup_addr_sender(CLEANUP_STATE *, const char *);
extern void cleanup_addr_recipient(CLEANUP_STATE *, const char *);
extern void cleanup_addr_bcc_dsn(CLEANUP_STATE *, const char *, const char *, int);

#define NO_DSN_ORCPT ((char *) 0)
#define NO_DSN_NOTIFY DSN_NOTIFY_NEVER
#define DEF_DSN_NOTIFY (0)

#define cleanup_addr_bcc(state, addr) \
    cleanup_addr_bcc_dsn((state), (addr), NO_DSN_ORCPT, NO_DSN_NOTIFY)

 /*
  * cleanup_bounce.c.
  */
extern int cleanup_bounce(CLEANUP_STATE *);

 /*
  * MSG_STATS compatibility.
  */
#define CLEANUP_MSG_STATS(stats, state) \
    MSG_STATS_INIT1(stats, incoming_arrival, state->arrival_time)

 /*
  * cleanup_milter.c.
  */
extern void cleanup_milter_header_checks_init(void);
extern void cleanup_milter_receive(CLEANUP_STATE *, int);
extern void cleanup_milter_inspect(CLEANUP_STATE *, MILTERS *);
extern void cleanup_milter_emul_mail(CLEANUP_STATE *, MILTERS *, const char *);
extern void cleanup_milter_emul_rcpt(CLEANUP_STATE *, MILTERS *, const char *);
extern void cleanup_milter_emul_data(CLEANUP_STATE *, MILTERS *);

#define CLEANUP_MILTER_OK(s) \
    (((s)->flags & CLEANUP_FLAG_MILTER) != 0 \
 && (s)->errs == 0 && ((s)->flags & CLEANUP_FLAG_DISCARD) == 0)

 /*
  * cleanup_body_edit.c
  */
typedef struct CLEANUP_REGION {
    off_t   start;   /* start of region */
    off_t   len;   /* length or zero (open-ended) */
    off_t   write_offs;   /* write offset */
    struct CLEANUP_REGION *next; /* linkage */
} CLEANUP_REGION;

extern void cleanup_region_init(CLEANUP_STATE *);
extern CLEANUP_REGION *cleanup_region_open(CLEANUP_STATE *, ssize_t);
extern void cleanup_region_close(CLEANUP_STATE *, CLEANUP_REGION *);
extern CLEANUP_REGION *cleanup_region_return(CLEANUP_STATE *, CLEANUP_REGION *);
extern void cleanup_region_done(CLEANUP_STATE *);

extern int cleanup_body_edit_start(CLEANUP_STATE *);
extern int cleanup_body_edit_write(CLEANUP_STATE *, int, VSTRING *);
extern int cleanup_body_edit_finish(CLEANUP_STATE *);
extern void cleanup_body_edit_free(CLEANUP_STATE *);

 /*
  * From: header formatting.
  */
extern int cleanup_hfrom_format;

 /*
  * How to handle garbage at end of the primary message header.
  */
#define NON_EMPTY_EOH_CODE_ERROR -1 /* sentinel */
#define NON_EMPTY_EOH_CODE_FIX_QUIETLY 0
#define NON_EMPTY_EOH_CODE_ADD_HDR 1
#define NON_EMPTY_EOH_CODE_REJECT 2

extern int cleanup_non_empty_eoh_action;

/* LICENSE
/* .ad
/* .fi
/* The Secure Mailer license must be distributed with this software.
/* AUTHOR(S)
/* Wietse Venema
/* IBM T.J. Watson Research
/* P.O. Box 704
/* Yorktown Heights, NY 10598, USA
/*
/* Wietse Venema
/* Google, Inc.
/* 111 8th Avenue
/* New York, NY 10011, USA
/*
/* Wietse Venema
/* porcupine.org
/*--*/