Mix/Src/rem1.c

/* Mixmaster version 3  --  (C) 1999 Anonymizer Inc.

   Mixmaster may be redistributed and modified under certain conditions.
   This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF
   ANY KIND, either express or implied. See the file COPYRIGHT for
   details.

   Process Cypherpunk remailer messages
   $Id: rem1.c,v 1.1 2001/10/31 08:19:53 rabbi Exp $ */


#include "mix3.h"
#include <ctype.h>
#include <time.h>
#include <string.h>

static int t1msg(BUFFER *in, int hdr);

int isline(BUFFER *line, char *text)
{
  int i;

  if (!bufileft(line, text))
    return (0);

    for (i = strlen(text); i < line->length; i++)
      if (!isspace(line->data[i]))
        return(0);
    return(1);
}

int t1_decrypt(BUFFER *in)
{
  int ret;

  buf_rewind(in);
  if (TYPE1[0] == '\0')
    ret = t1msg(in, 1);
  else {
    FILE *f;

    f = openpipe(TYPE1);
    if (f == NULL)
      return -1;
    buf_write(in, f);
    ret = closepipe(f);
  }
  if (ret == 0)
    stats_log(1);
  return (ret);
}

#ifdef USE_IDEA
void t1_esub(BUFFER *esub, BUFFER *subject)
{
  BUFFER *iv, *out;
  char hex[33];

  iv = buf_new();
  out = buf_new();

  buf_appendrnd(iv, 8);
  id_encode(iv->data, hex);
  buf_append(out, hex, 16);

  digest_md5(esub, esub);
  digest_md5(subject, subject);
  buf_ideacrypt(subject, esub, iv, ENCRYPT);
  id_encode(subject->data, hex);
  buf_appends(out, hex);
  buf_move(subject, out);
  buf_free(iv);
  buf_free(out);
}
#endif

#define N(X) (isdigit(X) ? (X)-'0' : 0)

static int readnum(BUFFER *b, int f)
{
  int num = 0;

  if (b->length > 0)
    sscanf(b->data, "%d", &num);
  num *= f;
  if (strchr(b->data, 'r'))
    num = rnd_number(num) + 1;
  return (num);
}

static int t1msg(BUFFER *in, int hdr)
     /* hdr = 1: mail header, hdr = 2: pasted header, hdr = 0: ignore */
{
  BUFFER *field, *content, *line;
  BUFFER *cutmarks, *to, *newsgroups, *ek, *ekdes, *ekcast, *esub, *subject;
  BUFFER *temp, *header, *out;
  BUFFER *test, *testto, *remixto;
  int err = 0;
  int encrypted = 0;
  int type = -1;
  int latent = 0;
  int remix = 0;
  int inflate = 0;

  field = buf_new();
  content = buf_new();
  line = buf_new();
  to = buf_new();
  remixto = buf_new();
  cutmarks = buf_new();
  newsgroups = buf_new();
  ek = buf_new();
  ekdes = buf_new();
  ekcast = buf_new();
  esub = buf_new();
  subject = buf_new();
  temp = buf_new();
  header = buf_new();
  out = buf_new();
  test = buf_new();
  testto = buf_new();

  if (REMIX == 1)
    remix = 2;
  if (!UNENCRYPTED)
    encrypted = -1;

header:
  while (buf_getheader(in, field, content) == 0) {
    if (header->length == 0 && bufieq(content, ":"))    /* HDRMARK */
      hdr = 2;

    if (bufieq(field, "test-to"))
      buf_set(testto, content);
    else if (PGP && bufieq(field, "encrypted"))
      encrypted = 1;
    else if (bufieq(field, "remix-to")) {
      remix = 1;
      buf_set(remixto, content);
      if (type == -1)
        type = MSG_MAIL;
    } else if (bufieq(field, "anon-to") ||
               bufieq(field, "request-remailing-to") ||
               bufieq(field, "remail-to") ||
               bufieq(field, "anon-send-to")) {
      if (bufieq(field, "remail-to"))
        remix = 0;
      if (to->length > 0)
        buf_appendc(to, ',');
      buf_cat(to, content);
      if (type == -1)
        type = MSG_MAIL;
    } else if (bufieq(field, "anon-post-to") || bufieq(field, "post-to")) {
      if (newsgroups->length > 0)
        buf_appendc(newsgroups, ',');
      buf_cat(newsgroups, content);
      type = MSG_POST;
    } else if (bufieq(field, "cutmarks"))
      buf_set(cutmarks, content);
    else if (bufieq(field, "latent-time")) {
      byte *q;
      int l;

      q = content->data;
      l = strlen(q);
      latent = 0;
      if (q[0] == '+')
        q++;
      if (l >= 5 && q[2] == ':')
        latent = 600 * N(q[0]) + 60 * N(q[1]) + 10 * N(q[3]) + N(q[4]);
      else if (l >= 4 && q[1] == ':')
        latent = 60 * N(q[0]) + 10 * N(q[2]) + N(q[3]);
      else if (l >= 3 && q[0] == ':')
        latent = 10 * N(q[1]) + N(q[2]);
      if (!bufleft(content, "+")) {
        time_t now;

        time(&now);
        latent -= localtime(&now)->tm_hour * 60;
        if (latent < 0)
          latent += 24 * 60;
      }
      if (q[l - 1] == 'r')
        latent = rnd_number(latent);
    } else if (bufieq(field, "null"))
      type = MSG_NULL;
    else if (bufieq(field, "encrypt-key") || bufieq(field, "encrypt-idea"))
      buf_set(ek, content);
    else if (bufieq(field, "encrypt-des") || bufieq(field, "encrypt-3des"))
      buf_set(ekdes, content);
    else if (bufieq(field, "encrypt-cast") || bufieq(field, "encrypt-cast5"))
      buf_set(ekcast, content);
    else if (bufieq(field, "encrypt-subject"))
      buf_set(esub, content);
    else if (bufieq(field, "inflate")) {
      inflate = readnum(content, 1024);
      if (inflate > INFLATEMAX * 1024)
        inflate = INFLATEMAX * 1024;
    } else if (bufieq(field, "rand-hop")) {
      int randhops, i;
      randhops = readnum(content, 1);
      if (randhops > MAXRANDHOPS)
        randhops = MAXRANDHOPS;
      buf_clear(temp);
      if (remixto->length)
         buf_move(temp, remixto);
      for (i = 0; i < randhops; i++) {
        if (remixto->length > 0)
          buf_appendc(remixto, ',');
        buf_appendc(remixto, '*');
      }
      if (temp->length) {
        buf_appendc(remixto, ',');
        buf_cat(remixto, temp);
      }
    }
#if USE_NSUB
    else if (bufieq(field, "subject"))
      buf_set(subject, content);
#endif
  }

  if (cutmarks->length > 0) {
    BUFFER *cut;

    cut = buf_new();
    buf_clear(temp);

    while ((err = buf_getline(in, line)) != -1 && !buf_eq(line, cutmarks)) {
      buf_cat(temp, line);
      buf_nl(temp);
    }
    while (err != -1) {
      err = buf_getline(in, line);
      if (err == -1 || buf_eq(line, cutmarks)) {
        t1msg(cut, 0);
        buf_clear(cut);
      } else {
        buf_cat(cut, line);
        buf_nl(cut);
      }
    }
    buf_move(in, temp);
    buf_clear(cutmarks);
  }
  if (encrypted == 1) {
#ifdef USE_PGP
    err = pgp_dearmor(in, temp);
    if (err == 0) {
      BUFFER *pass;

      pass = buf_new();
      buf_sets(pass, PASSPHRASE);
      err = pgp_decrypt(temp, pass, NULL, NULL, NULL);
      buf_free(pass);
    }
    if (err != -1 && temp->length == 0) {
      errlog(ERRORMSG, "Empty PGP message.\n");
      err = -1;
      goto end;
    }
    if (err != -1) {
      buf_rest(temp, in);       /* dangerous, but required for reply blocks */
      buf_move(in, temp);
      encrypted = 0;
      hdr = 0;
      goto header;
    }
#endif
    if (testto->length == 0)
      errlog(ERRORMSG, "Can't decrypt PGP message.\n");
    buf_appends(test, "Can't decrypt PGP message.\n");
  }
  while ((err = buf_lookahead(in, line)) == 1)
    buf_getline(in, line);
#if 0
  if (err == -1)
    goto end;
#endif

  if (isline(line, HDRMARK) && (hdr == 0 || hdr == 1)) {
    buf_getline(in, NULL);
    hdr = 2;
    goto header;
  } else if (isline(line, HASHMARK)) {
    buf_getline(in, NULL);
    for (;;) {
      if (buf_lookahead(in, line) == 0 && bufileft(line, "subject:")) {
        buf_getheader(in, field, content);
        buf_set(subject, content);
      }
      if (buf_getline(in, line) != 0)
        break;
      buf_cat(header, line);
      buf_nl(header);
    }
  }
  if (encrypted == -1) {
    if (testto->length == 0)
      errlog(LOG, "Unencrypted message detected.\n");
    buf_appends(test, "Unencrypted message detected.\n");
    err = -2;
    goto end;
  }
  if (type == MSG_POST && subject->length == 0)
    buf_sets(subject, "(no subject)");

  if (to->length > 0)
    buf_appendf(out, "To: %b\n", to);
  else if (remixto->length > 0)
    buf_appendf(out, "To: %b\n", remixto);
  if (newsgroups->length > 0)
    buf_appendf(out, "Newsgroups: %b\n", newsgroups);
  if (subject->length > 0) {
#ifdef USE_IDEA
    if (esub->length > 0)
      t1_esub(esub, subject);
#endif
    buf_appendf(out, "Subject: %b\n", subject);
  }
  buf_cat(out, header);
  buf_nl(out);

#if 0
  inflate -= in->length;
#endif
  if (inflate > 0) {
    buf_setrnd(temp, inflate * 3 / 4);
    encode(temp, 64);
    buf_appends(in, "\n-----BEGIN GARBAGE-----\n");
    buf_cat(in, temp);
    buf_appends(in, "-----END GARBAGE-----\n");
  }

  if (!(ek->length || ekdes->length || ekcast->length))
    buf_rest(out, in);
  else {
    err = 0;
    buf_clear(temp);
    while (buf_getline(in, line) != -1) {
      if (isline(line, EKMARK)) {
        buf_cat(out, temp);
        buf_clear(temp);
        buf_rest(temp, in);
        break;
      }
      else {
        buf_cat(temp, line);
        buf_nl(temp);
      }
    }
#ifdef USE_PGP
    if (ekcast->length) {
      err = pgp_encrypt(PGP_CONVCAST | PGP_TEXT, temp, ekcast, NULL, NULL,
                        NULL, NULL);
      buf_clear(ekcast);
    }
    if (ekdes->length) {
      err = pgp_encrypt(PGP_CONV3DES | PGP_TEXT, temp, ekdes, NULL, NULL,
                        NULL, NULL);
      buf_clear(ekdes);
    }
    if (ek->length) {
      err = pgp_encrypt(PGP_CONVENTIONAL | PGP_TEXT, temp, ek, NULL, NULL,
                        NULL, NULL);
      buf_clear(ek);
    }
    buf_appends(out, EKMARK);
    buf_nl(out);
    buf_cat(out, temp);
#else
    err = -1;
#endif
  }

  if (type == -1) {
    buf_appends(test, "No destination.\n");
    err = -1;
  }

end:
  if (testto->length) {
    BUFFER *report;
    int i;

    report = buf_new();
    buf_sets(report,
             "Subject: remailer test report\n\nThis is an automated response to the test message you sent to ");
    buf_appends(report, SHORTNAME);
    buf_appends(report, ".\nYour test message results follow:\n\n");
    buf_appends(report, remailer_type);
    buf_appends(report, VERSION);
    buf_appends(report, "\n\n");
    if (err == 0) {
      err = filtermsg(out);
      if (err == -1)
        buf_appends(report, "This remailer cannot deliver the message.\n\n");
      else {
        buf_appends(report, "Valid ");
        buf_appends(report, type == MSG_POST ? "Usenet" : "mail");
        buf_appends(report, " message.\n");
        if (remixto->length) {
          if (remix && MIX)
            buf_appends(report, "Delivery via Mixmaster: ");
          else if (remix)
            buf_appends(report, "Error! Can't remix: ");
          else
            buf_appends(report, "Delivery via Cypherpunk remailer: ");
          buf_cat(report, remixto);
          buf_nl(report);
        }
        else if (type == MSG_POST && strchr(NEWS, '@') && !strchr(NEWS, ' ')) {
          buf_appendf(report, "News gateway: %s\n", NEWS);
        }
        buf_appends(report,
                    "\n=========================================================================\nThe first 20 lines of the message follow:\n");
        if (err != 1)
          buf_appendf(report, "From: %s\n", ANONNAME);
        if (type == MSG_POST && ORGANIZATION[0] != '\0')
          buf_appendf(report, "Organization: %s\n", ORGANIZATION);
      }
      for (i = 0; i < 20 && buf_getline(out, test) != -1; i++)
        buf_cat(report, test), buf_nl(report);
    } else {
      buf_appends(report, "The remailer message is invalid.\n\n");
      if (test->length) {
        buf_appends(report, "The following error occurred: ");
        buf_cat(report, test);
        buf_nl(report);
      }
    }
    buf_appends(report,
                "=========================================================================\nThe first 20 lines of your message to the remailer follow:\n");
    buf_rewind(in);
    for (i = 0; i < 20 && buf_getline(in, test) != -1; i++)
      buf_cat(report, test), buf_nl(report);

    sendmail(report, REMAILERNAME, testto);
    err = 0;
    buf_free(report);
  } else if (err == 0 && type != MSG_NULL) {
    err = 1;
    if (bufieq(to, REMAILERADDR)) /* don't remix to ourselves */
      remix = 0;
    if (remix && remixto->length == 0)
      buf_set(remixto, to);
    if (remix)
      err = mix_encrypt(type, out, remixto->data, 1, line);
    if (err != 0) {
      if (remix == 1)
        errlog(NOTICE, "Can't remix -- %b\n", line);
      else {
        if (remixto->length)
          err = t1_encrypt(type, out, remixto->data, 0, 0, line);
        if (err != 0)
          err = mix_pool(out, type, latent * 60);
      }
    }
  }

  buf_free(field);
  buf_free(content);
  buf_free(line);
  buf_free(to);
  buf_free(remixto);
  buf_free(newsgroups);
  buf_free(subject);
  buf_free(ek);
  buf_free(ekcast);
  buf_free(ekdes);
  buf_free(esub);
  buf_free(cutmarks);
  buf_free(temp);
  buf_free(out);
  buf_free(header);
  buf_free(test);
  buf_free(testto);
  return (err);
}
1	/* Mixmaster version 3 -- (C) 1999 Anonymizer Inc.
2
3	Mixmaster may be redistributed and modified under certain conditions.
4	This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF
5	ANY KIND, either express or implied. See the file COPYRIGHT for
6	details.
7
8	Process Cypherpunk remailer messages
9	$Id: rem1.c,v 1.1 2001/10/31 08:19:53 rabbi Exp $ */
10
11
12	#include "mix3.h"
13	#include <ctype.h>
14	#include <time.h>
15	#include <string.h>
16
17	static int t1msg(BUFFER *in, int hdr);
18
19	int isline(BUFFER line, char text)
20	{
21	int i;
22
23	if (!bufileft(line, text))
24	return (0);
25
26	for (i = strlen(text); i < line->length; i++)
27	if (!isspace(line->data[i]))
28	return(0);
29	return(1);
30	}
31
32	int t1_decrypt(BUFFER *in)
33	{
34	int ret;
35
36	buf_rewind(in);
37	if (TYPE1[0] == '\0')
38	ret = t1msg(in, 1);
39	else {
40	FILE *f;
41
42	f = openpipe(TYPE1);
43	if (f == NULL)
44	return -1;
45	buf_write(in, f);
46	ret = closepipe(f);
47	}
48	if (ret == 0)
49	stats_log(1);
50	return (ret);
51	}
52
53	#ifdef USE_IDEA
54	void t1_esub(BUFFER esub, BUFFER subject)
55	{
56	BUFFER iv, out;
57	char hex[33];
58
59	iv = buf_new();
60	out = buf_new();
61
62	buf_appendrnd(iv, 8);
63	id_encode(iv->data, hex);
64	buf_append(out, hex, 16);
65
66	digest_md5(esub, esub);
67	digest_md5(subject, subject);
68	buf_ideacrypt(subject, esub, iv, ENCRYPT);
69	id_encode(subject->data, hex);
70	buf_appends(out, hex);
71	buf_move(subject, out);
72	buf_free(iv);
73	buf_free(out);
74	}
75	#endif
76
77	#define N(X) (isdigit(X) ? (X)-'0' : 0)
78
79	static int readnum(BUFFER *b, int f)
80	{
81	int num = 0;
82
83	if (b->length > 0)
84	sscanf(b->data, "%d", &num);
85	num *= f;
86	if (strchr(b->data, 'r'))
87	num = rnd_number(num) + 1;
88	return (num);
89	}
90
91	static int t1msg(BUFFER *in, int hdr)
92	/* hdr = 1: mail header, hdr = 2: pasted header, hdr = 0: ignore */
93	{
94	BUFFER field, content, *line;
95	BUFFER cutmarks, to, newsgroups, ek, ekdes, ekcast, esub, subject;
96	BUFFER temp, header, *out;
97	BUFFER test, testto, *remixto;
98	int err = 0;
99	int encrypted = 0;
100	int type = -1;
101	int latent = 0;
102	int remix = 0;
103	int inflate = 0;
104
105	field = buf_new();
106	content = buf_new();
107	line = buf_new();
108	to = buf_new();
109	remixto = buf_new();
110	cutmarks = buf_new();
111	newsgroups = buf_new();
112	ek = buf_new();
113	ekdes = buf_new();
114	ekcast = buf_new();
115	esub = buf_new();
116	subject = buf_new();
117	temp = buf_new();
118	header = buf_new();
119	out = buf_new();
120	test = buf_new();
121	testto = buf_new();
122
123	if (REMIX == 1)
124	remix = 2;
125	if (!UNENCRYPTED)
126	encrypted = -1;
127
128	header:
129	while (buf_getheader(in, field, content) == 0) {
130	if (header->length == 0 && bufieq(content, ":")) /* HDRMARK */
131	hdr = 2;
132
133	if (bufieq(field, "test-to"))
134	buf_set(testto, content);
135	else if (PGP && bufieq(field, "encrypted"))
136	encrypted = 1;
137	else if (bufieq(field, "remix-to")) {
138	remix = 1;
139	buf_set(remixto, content);
140	if (type == -1)
141	type = MSG_MAIL;
142	} else if (bufieq(field, "anon-to") \|\|
143	bufieq(field, "request-remailing-to") \|\|
144	bufieq(field, "remail-to") \|\|
145	bufieq(field, "anon-send-to")) {
146	if (bufieq(field, "remail-to"))
147	remix = 0;
148	if (to->length > 0)
149	buf_appendc(to, ',');
150	buf_cat(to, content);
151	if (type == -1)
152	type = MSG_MAIL;
153	} else if (bufieq(field, "anon-post-to") \|\| bufieq(field, "post-to")) {
154	if (newsgroups->length > 0)
155	buf_appendc(newsgroups, ',');
156	buf_cat(newsgroups, content);
157	type = MSG_POST;
158	} else if (bufieq(field, "cutmarks"))
159	buf_set(cutmarks, content);
160	else if (bufieq(field, "latent-time")) {
161	byte *q;
162	int l;
163
164	q = content->data;
165	l = strlen(q);
166	latent = 0;
167	if (q[0] == '+')
168	q++;
169	if (l >= 5 && q[2] == ':')
170	latent = 600 * N(q[0]) + 60 * N(q[1]) + 10 * N(q[3]) + N(q[4]);
171	else if (l >= 4 && q[1] == ':')
172	latent = 60 * N(q[0]) + 10 * N(q[2]) + N(q[3]);
173	else if (l >= 3 && q[0] == ':')
174	latent = 10 * N(q[1]) + N(q[2]);
175	if (!bufleft(content, "+")) {
176	time_t now;
177
178	time(&now);
179	latent -= localtime(&now)->tm_hour * 60;
180	if (latent < 0)
181	latent += 24 * 60;
182	}
183	if (q[l - 1] == 'r')
184	latent = rnd_number(latent);
185	} else if (bufieq(field, "null"))
186	type = MSG_NULL;
187	else if (bufieq(field, "encrypt-key") \|\| bufieq(field, "encrypt-idea"))
188	buf_set(ek, content);
189	else if (bufieq(field, "encrypt-des") \|\| bufieq(field, "encrypt-3des"))
190	buf_set(ekdes, content);
191	else if (bufieq(field, "encrypt-cast") \|\| bufieq(field, "encrypt-cast5"))
192	buf_set(ekcast, content);
193	else if (bufieq(field, "encrypt-subject"))
194	buf_set(esub, content);
195	else if (bufieq(field, "inflate")) {
196	inflate = readnum(content, 1024);
197	if (inflate > INFLATEMAX * 1024)
198	inflate = INFLATEMAX * 1024;
199	} else if (bufieq(field, "rand-hop")) {
200	int randhops, i;
201	randhops = readnum(content, 1);
202	if (randhops > MAXRANDHOPS)
203	randhops = MAXRANDHOPS;
204	buf_clear(temp);
205	if (remixto->length)
206	buf_move(temp, remixto);
207	for (i = 0; i < randhops; i++) {
208	if (remixto->length > 0)
209	buf_appendc(remixto, ',');
210	buf_appendc(remixto, '*');
211	}
212	if (temp->length) {
213	buf_appendc(remixto, ',');
214	buf_cat(remixto, temp);
215	}
216	}
217	#if USE_NSUB
218	else if (bufieq(field, "subject"))
219	buf_set(subject, content);
220	#endif
221	}
222
223	if (cutmarks->length > 0) {
224	BUFFER *cut;
225
226	cut = buf_new();
227	buf_clear(temp);
228
229	while ((err = buf_getline(in, line)) != -1 && !buf_eq(line, cutmarks)) {
230	buf_cat(temp, line);
231	buf_nl(temp);
232	}
233	while (err != -1) {
234	err = buf_getline(in, line);
235	if (err == -1 \|\| buf_eq(line, cutmarks)) {
236	t1msg(cut, 0);
237	buf_clear(cut);
238	} else {
239	buf_cat(cut, line);
240	buf_nl(cut);
241	}
242	}
243	buf_move(in, temp);
244	buf_clear(cutmarks);
245	}
246	if (encrypted == 1) {
247	#ifdef USE_PGP
248	err = pgp_dearmor(in, temp);
249	if (err == 0) {
250	BUFFER *pass;
251
252	pass = buf_new();
253	buf_sets(pass, PASSPHRASE);
254	err = pgp_decrypt(temp, pass, NULL, NULL, NULL);
255	buf_free(pass);
256	}
257	if (err != -1 && temp->length == 0) {
258	errlog(ERRORMSG, "Empty PGP message.\n");
259	err = -1;
260	goto end;
261	}
262	if (err != -1) {
263	buf_rest(temp, in); /* dangerous, but required for reply blocks */
264	buf_move(in, temp);
265	encrypted = 0;
266	hdr = 0;
267	goto header;
268	}
269	#endif
270	if (testto->length == 0)
271	errlog(ERRORMSG, "Can't decrypt PGP message.\n");
272	buf_appends(test, "Can't decrypt PGP message.\n");
273	}
274	while ((err = buf_lookahead(in, line)) == 1)
275	buf_getline(in, line);
276	#if 0
277	if (err == -1)
278	goto end;
279	#endif
280
281	if (isline(line, HDRMARK) && (hdr == 0 \|\| hdr == 1)) {
282	buf_getline(in, NULL);
283	hdr = 2;
284	goto header;
285	} else if (isline(line, HASHMARK)) {
286	buf_getline(in, NULL);
287	for (;;) {
288	if (buf_lookahead(in, line) == 0 && bufileft(line, "subject:")) {
289	buf_getheader(in, field, content);
290	buf_set(subject, content);
291	}
292	if (buf_getline(in, line) != 0)
293	break;
294	buf_cat(header, line);
295	buf_nl(header);
296	}
297	}
298	if (encrypted == -1) {
299	if (testto->length == 0)
300	errlog(LOG, "Unencrypted message detected.\n");
301	buf_appends(test, "Unencrypted message detected.\n");
302	err = -2;
303	goto end;
304	}
305	if (type == MSG_POST && subject->length == 0)
306	buf_sets(subject, "(no subject)");
307
308	if (to->length > 0)
309	buf_appendf(out, "To: %b\n", to);
310	else if (remixto->length > 0)
311	buf_appendf(out, "To: %b\n", remixto);
312	if (newsgroups->length > 0)
313	buf_appendf(out, "Newsgroups: %b\n", newsgroups);
314	if (subject->length > 0) {
315	#ifdef USE_IDEA
316	if (esub->length > 0)
317	t1_esub(esub, subject);
318	#endif
319	buf_appendf(out, "Subject: %b\n", subject);
320	}
321	buf_cat(out, header);
322	buf_nl(out);
323
324	#if 0
325	inflate -= in->length;
326	#endif
327	if (inflate > 0) {
328	buf_setrnd(temp, inflate * 3 / 4);
329	encode(temp, 64);
330	buf_appends(in, "\n-----BEGIN GARBAGE-----\n");
331	buf_cat(in, temp);
332	buf_appends(in, "-----END GARBAGE-----\n");
333	}
334
335	if (!(ek->length \|\| ekdes->length \|\| ekcast->length))
336	buf_rest(out, in);
337	else {
338	err = 0;
339	buf_clear(temp);
340	while (buf_getline(in, line) != -1) {
341	if (isline(line, EKMARK)) {
342	buf_cat(out, temp);
343	buf_clear(temp);
344	buf_rest(temp, in);
345	break;
346	}
347	else {
348	buf_cat(temp, line);
349	buf_nl(temp);
350	}
351	}
352	#ifdef USE_PGP
353	if (ekcast->length) {
354	err = pgp_encrypt(PGP_CONVCAST \| PGP_TEXT, temp, ekcast, NULL, NULL,
355	NULL, NULL);
356	buf_clear(ekcast);
357	}
358	if (ekdes->length) {
359	err = pgp_encrypt(PGP_CONV3DES \| PGP_TEXT, temp, ekdes, NULL, NULL,
360	NULL, NULL);
361	buf_clear(ekdes);
362	}
363	if (ek->length) {
364	err = pgp_encrypt(PGP_CONVENTIONAL \| PGP_TEXT, temp, ek, NULL, NULL,
365	NULL, NULL);
366	buf_clear(ek);
367	}
368	buf_appends(out, EKMARK);
369	buf_nl(out);
370	buf_cat(out, temp);
371	#else
372	err = -1;
373	#endif
374	}
375
376	if (type == -1) {
377	buf_appends(test, "No destination.\n");
378	err = -1;
379	}
380
381	end:
382	if (testto->length) {
383	BUFFER *report;
384	int i;
385
386	report = buf_new();
387	buf_sets(report,
388	"Subject: remailer test report\n\nThis is an automated response to the test message you sent to ");
389	buf_appends(report, SHORTNAME);
390	buf_appends(report, ".\nYour test message results follow:\n\n");
391	buf_appends(report, remailer_type);
392	buf_appends(report, VERSION);
393	buf_appends(report, "\n\n");
394	if (err == 0) {
395	err = filtermsg(out);
396	if (err == -1)
397	buf_appends(report, "This remailer cannot deliver the message.\n\n");
398	else {
399	buf_appends(report, "Valid ");
400	buf_appends(report, type == MSG_POST ? "Usenet" : "mail");
401	buf_appends(report, " message.\n");
402	if (remixto->length) {
403	if (remix && MIX)
404	buf_appends(report, "Delivery via Mixmaster: ");
405	else if (remix)
406	buf_appends(report, "Error! Can't remix: ");
407	else
408	buf_appends(report, "Delivery via Cypherpunk remailer: ");
409	buf_cat(report, remixto);
410	buf_nl(report);
411	}
412	else if (type == MSG_POST && strchr(NEWS, '@') && !strchr(NEWS, ' ')) {
413	buf_appendf(report, "News gateway: %s\n", NEWS);
414	}
415	buf_appends(report,
416	"\n=========================================================================\nThe first 20 lines of the message follow:\n");
417	if (err != 1)
418	buf_appendf(report, "From: %s\n", ANONNAME);
419	if (type == MSG_POST && ORGANIZATION[0] != '\0')
420	buf_appendf(report, "Organization: %s\n", ORGANIZATION);
421	}
422	for (i = 0; i < 20 && buf_getline(out, test) != -1; i++)
423	buf_cat(report, test), buf_nl(report);
424	} else {
425	buf_appends(report, "The remailer message is invalid.\n\n");
426	if (test->length) {
427	buf_appends(report, "The following error occurred: ");
428	buf_cat(report, test);
429	buf_nl(report);
430	}
431	}
432	buf_appends(report,
433	"=========================================================================\nThe first 20 lines of your message to the remailer follow:\n");
434	buf_rewind(in);
435	for (i = 0; i < 20 && buf_getline(in, test) != -1; i++)
436	buf_cat(report, test), buf_nl(report);
437
438	sendmail(report, REMAILERNAME, testto);
439	err = 0;
440	buf_free(report);
441	} else if (err == 0 && type != MSG_NULL) {
442	err = 1;
443	if (bufieq(to, REMAILERADDR)) /* don't remix to ourselves */
444	remix = 0;
445	if (remix && remixto->length == 0)
446	buf_set(remixto, to);
447	if (remix)
448	err = mix_encrypt(type, out, remixto->data, 1, line);
449	if (err != 0) {
450	if (remix == 1)
451	errlog(NOTICE, "Can't remix -- %b\n", line);
452	else {
453	if (remixto->length)
454	err = t1_encrypt(type, out, remixto->data, 0, 0, line);
455	if (err != 0)
456	err = mix_pool(out, type, latent * 60);
457	}
458	}
459	}
460
461	buf_free(field);
462	buf_free(content);
463	buf_free(line);
464	buf_free(to);
465	buf_free(remixto);
466	buf_free(newsgroups);
467	buf_free(subject);
468	buf_free(ek);
469	buf_free(ekcast);
470	buf_free(ekdes);
471	buf_free(esub);
472	buf_free(cutmarks);
473	buf_free(temp);
474	buf_free(out);
475	buf_free(header);
476	buf_free(test);
477	buf_free(testto);
478	return (err);
479	}