source: message.c @ f511c1e

Last change on this file since f511c1e was e38cc20, checked in by Jason Gross <jgross@mit.edu>, 8 years ago
Scrapped the last bits of C code dealing with jabber. We still have an OWL_PROTOCOL_JABBER in owl.h, but it does no harm being there, and we don't use any of the other ones except for AIM. I figure there's no harm in waiting and ripping all of them out at the same time in perl/AIM
  • Property mode set to 100644
File size: 24.6 KB
Line 
1#include "owl.h"
2#include "filterproc.h"
3#include <sys/socket.h>
4#include <arpa/inet.h>
5
6static owl_fmtext_cache fmtext_cache[OWL_FMTEXT_CACHE_SIZE];
7static owl_fmtext_cache * fmtext_cache_next = fmtext_cache;
8
9void owl_message_init_fmtext_cache(void)
10{
11    int i;
12    for(i = 0; i < OWL_FMTEXT_CACHE_SIZE; i++) {
13        owl_fmtext_init_null(&(fmtext_cache[i].fmtext));
14        fmtext_cache[i].message = NULL;
15    }
16}
17
18static owl_fmtext_cache *owl_message_next_fmtext(void)
19{
20    owl_fmtext_cache * f = fmtext_cache_next;
21    if(fmtext_cache_next->message != NULL) {
22        owl_message_invalidate_format(fmtext_cache_next->message);
23    }
24    fmtext_cache_next++;
25    if(fmtext_cache_next - fmtext_cache == OWL_FMTEXT_CACHE_SIZE)
26        fmtext_cache_next = fmtext_cache;
27    return f;
28}
29
30void owl_message_init(owl_message *m)
31{
32  m->id=owl_global_get_nextmsgid(&g);
33  owl_message_set_direction_none(m);
34  m->delete=0;
35
36#ifdef HAVE_LIBZEPHYR
37  m->has_notice = false;
38#endif
39
40  owl_message_set_hostname(m, "");
41  m->attributes = g_ptr_array_new();
42 
43  /* save the time */
44  m->time = time(NULL);
45  m->timestr = g_strdup(ctime(&m->time));
46  m->timestr[strlen(m->timestr)-1] = '\0';
47
48  m->fmtext = NULL;
49}
50
51/* add the named attribute to the message.  If an attribute with the
52 * name already exists, replace the old value with the new value
53 */
54void owl_message_set_attribute(owl_message *m, const char *attrname, const char *attrvalue)
55{
56  int i;
57  owl_pair *p = NULL, *pair = NULL;
58
59  attrname = g_intern_string(attrname);
60
61  /* look for an existing pair with this key, */
62  for (i = 0; i < m->attributes->len; i++) {
63    p = m->attributes->pdata[i];
64    if (owl_pair_get_key(p) == attrname) {
65      g_free(owl_pair_get_value(p));
66      pair = p;
67      break;
68    }
69  }
70
71  if(pair ==  NULL) {
72    pair = g_slice_new(owl_pair);
73    owl_pair_create(pair, attrname, NULL);
74    g_ptr_array_add(m->attributes, pair);
75  }
76  owl_pair_set_value(pair, owl_validate_or_convert(attrvalue));
77}
78
79/* return the value associated with the named attribute, or NULL if
80 * the attribute does not exist
81 */
82const char *owl_message_get_attribute_value(const owl_message *m, const char *attrname)
83{
84  int i;
85  owl_pair *p;
86  GQuark quark;
87
88  quark = g_quark_try_string(attrname);
89  if (quark == 0)
90    /* don't bother inserting into string table */
91    return NULL;
92  attrname = g_quark_to_string(quark);
93
94  for (i = 0; i < m->attributes->len; i++) {
95    p = m->attributes->pdata[i];
96    if (owl_pair_get_key(p) == attrname) {
97      return(owl_pair_get_value(p));
98    }
99  }
100
101  /*
102  owl_function_debugmsg("No attribute %s found for message %i",
103                        attrname,
104                        owl_message_get_id(m));
105  */
106  return(NULL);
107}
108
109/* We cheat and indent it for now, since we really want this for
110 * the 'info' function.  Later there should just be a generic
111 * function to indent fmtext.
112 */
113void owl_message_attributes_tofmtext(const owl_message *m, owl_fmtext *fm) {
114  int i;
115  owl_pair *p;
116  char *buff, *tmpbuff;
117
118  owl_fmtext_init_null(fm);
119
120  for (i = 0; i < m->attributes->len; i++) {
121    p = m->attributes->pdata[i];
122
123    buff = g_strdup(owl_pair_get_value(p));
124    if (buff) {
125      tmpbuff = owl_text_indent(buff, 19, false);
126      g_free(buff);
127      buff = g_strdup_printf("  %-15.15s: %s\n", owl_pair_get_key(p), tmpbuff);
128      g_free(tmpbuff);
129    }
130
131    if(buff == NULL) {
132      buff = g_strdup_printf("  %-15.15s: %s\n", owl_pair_get_key(p), "<error>");
133      if(buff == NULL)
134        buff=g_strdup("   <error>\n");
135    }
136    owl_fmtext_append_normal(fm, buff);
137    g_free(buff);
138  }
139}
140
141void owl_message_invalidate_format(owl_message *m)
142{
143  if(m->fmtext) {
144    m->fmtext->message = NULL;
145    owl_fmtext_clear(&(m->fmtext->fmtext));
146    m->fmtext=NULL;
147  }
148}
149
150owl_fmtext *owl_message_get_fmtext(owl_message *m)
151{
152  owl_message_format(m);
153  return(&(m->fmtext->fmtext));
154}
155
156void owl_message_format(owl_message *m)
157{
158  const owl_style *s;
159  const owl_view *v;
160
161  if (!m->fmtext) {
162    m->fmtext = owl_message_next_fmtext();
163    m->fmtext->message = m;
164    /* for now we assume there's just the one view and use that style */
165    v=owl_global_get_current_view(&g);
166    s=owl_view_get_style(v);
167
168    owl_style_get_formattext(s, &(m->fmtext->fmtext), m);
169  }
170}
171
172void owl_message_set_class(owl_message *m, const char *class)
173{
174  owl_message_set_attribute(m, "class", class);
175}
176
177const char *owl_message_get_class(const owl_message *m)
178{
179  const char *class;
180
181  class=owl_message_get_attribute_value(m, "class");
182  if (!class) return("");
183  return(class);
184}
185
186void owl_message_set_instance(owl_message *m, const char *inst)
187{
188  owl_message_set_attribute(m, "instance", inst);
189}
190
191const char *owl_message_get_instance(const owl_message *m)
192{
193  const char *instance;
194
195  instance=owl_message_get_attribute_value(m, "instance");
196  if (!instance) return("");
197  return(instance);
198}
199
200void owl_message_set_sender(owl_message *m, const char *sender)
201{
202  owl_message_set_attribute(m, "sender", sender);
203}
204
205const char *owl_message_get_sender(const owl_message *m)
206{
207  const char *sender;
208
209  sender=owl_message_get_attribute_value(m, "sender");
210  if (!sender) return("");
211  return(sender);
212}
213
214void owl_message_set_zsig(owl_message *m, const char *zsig)
215{
216  owl_message_set_attribute(m, "zsig", zsig);
217}
218
219const char *owl_message_get_zsig(const owl_message *m)
220{
221  const char *zsig;
222
223  zsig=owl_message_get_attribute_value(m, "zsig");
224  if (!zsig) return("");
225  return(zsig);
226}
227
228void owl_message_set_recipient(owl_message *m, const char *recip)
229{
230  owl_message_set_attribute(m, "recipient", recip);
231}
232
233const char *owl_message_get_recipient(const owl_message *m)
234{
235  /* this is stupid for outgoing messages, we need to fix it. */
236
237  const char *recip;
238
239  recip=owl_message_get_attribute_value(m, "recipient");
240  if (!recip) return("");
241  return(recip);
242}
243
244void owl_message_set_realm(owl_message *m, const char *realm)
245{
246  owl_message_set_attribute(m, "realm", realm);
247}
248
249const char *owl_message_get_realm(const owl_message *m)
250{
251  const char *realm;
252 
253  realm=owl_message_get_attribute_value(m, "realm");
254  if (!realm) return("");
255  return(realm);
256}
257
258void owl_message_set_body(owl_message *m, const char *body)
259{
260  owl_message_set_attribute(m, "body", body);
261}
262
263const char *owl_message_get_body(const owl_message *m)
264{
265  const char *body;
266
267  body=owl_message_get_attribute_value(m, "body");
268  if (!body) return("");
269  return(body);
270}
271
272
273void owl_message_set_opcode(owl_message *m, const char *opcode)
274{
275  owl_message_set_attribute(m, "opcode", opcode);
276}
277
278const char *owl_message_get_opcode(const owl_message *m)
279{
280  const char *opcode;
281
282  opcode=owl_message_get_attribute_value(m, "opcode");
283  if (!opcode) return("");
284  return(opcode);
285}
286
287
288void owl_message_set_islogin(owl_message *m)
289{
290  owl_message_set_attribute(m, "loginout", "login");
291}
292
293
294void owl_message_set_islogout(owl_message *m)
295{
296  owl_message_set_attribute(m, "loginout", "logout");
297}
298
299int owl_message_is_loginout(const owl_message *m)
300{
301  const char *res;
302
303  res=owl_message_get_attribute_value(m, "loginout");
304  if (!res) return(0);
305  return(1);
306}
307
308int owl_message_is_login(const owl_message *m)
309{
310  const char *res;
311
312  res=owl_message_get_attribute_value(m, "loginout");
313  if (!res) return(0);
314  if (!strcmp(res, "login")) return(1);
315  return(0);
316}
317
318
319int owl_message_is_logout(const owl_message *m)
320{
321  const char *res;
322
323  res=owl_message_get_attribute_value(m, "loginout");
324  if (!res) return(0);
325  if (!strcmp(res, "logout")) return(1);
326  return(0);
327}
328
329void owl_message_set_isprivate(owl_message *m)
330{
331  owl_message_set_attribute(m, "isprivate", "true");
332}
333
334int owl_message_is_private(const owl_message *m)
335{
336  const char *res;
337
338  res=owl_message_get_attribute_value(m, "isprivate");
339  if (!res) return(0);
340  return !strcmp(res, "true");
341}
342
343const char *owl_message_get_timestr(const owl_message *m)
344{
345  if (m->timestr) return(m->timestr);
346  return("");
347}
348
349CALLER_OWN char *owl_message_format_time(const owl_message *m)
350{
351  return owl_util_format_time(localtime(&m->time));
352}
353
354void owl_message_set_type_admin(owl_message *m)
355{
356  owl_message_set_attribute(m, "type", "admin");
357}
358
359void owl_message_set_type_loopback(owl_message *m)
360{
361  owl_message_set_attribute(m, "type", "loopback");
362}
363
364void owl_message_set_type_zephyr(owl_message *m)
365{
366  owl_message_set_attribute(m, "type", "zephyr");
367}
368
369void owl_message_set_type_aim(owl_message *m)
370{
371  owl_message_set_attribute(m, "type", "AIM");
372}
373
374void owl_message_set_type(owl_message *m, const char* type)
375{
376  owl_message_set_attribute(m, "type", type);
377}
378
379int owl_message_is_type(const owl_message *m, const char *type) {
380  const char * t = owl_message_get_attribute_value(m, "type");
381  if(!t) return 0;
382  return !strcasecmp(t, type);
383}
384                                               
385int owl_message_is_type_admin(const owl_message *m)
386{
387  return owl_message_is_type(m, "admin");
388}
389
390int owl_message_is_type_zephyr(const owl_message *m)
391{
392  return owl_message_is_type(m, "zephyr");
393}
394
395int owl_message_is_type_aim(const owl_message *m)
396{
397  return owl_message_is_type(m, "aim");
398}
399
400int owl_message_is_type_loopback(const owl_message *m)
401{
402  return owl_message_is_type(m, "loopback");
403}
404
405int owl_message_is_pseudo(const owl_message *m)
406{
407  if (owl_message_get_attribute_value(m, "pseudo")) return(1);
408  return(0);
409}
410
411const char *owl_message_get_text(owl_message *m)
412{
413  owl_message_format(m);
414  return(owl_fmtext_get_text(&(m->fmtext->fmtext)));
415}
416
417void owl_message_set_direction_in(owl_message *m)
418{
419  m->direction=OWL_MESSAGE_DIRECTION_IN;
420}
421
422void owl_message_set_direction_out(owl_message *m)
423{
424  m->direction=OWL_MESSAGE_DIRECTION_OUT;
425}
426
427void owl_message_set_direction_none(owl_message *m)
428{
429  m->direction=OWL_MESSAGE_DIRECTION_NONE;
430}
431
432void owl_message_set_direction(owl_message *m, int direction)
433{
434  m->direction=direction;
435}
436
437int owl_message_is_direction_in(const owl_message *m)
438{
439  if (m->direction==OWL_MESSAGE_DIRECTION_IN) return(1);
440  return(0);
441}
442
443int owl_message_is_direction_out(const owl_message *m)
444{
445  if (m->direction==OWL_MESSAGE_DIRECTION_OUT) return(1);
446  return(0);
447}
448
449int owl_message_is_direction_none(const owl_message *m)
450{
451  if (m->direction==OWL_MESSAGE_DIRECTION_NONE) return(1);
452  return(0);
453}
454
455int owl_message_get_numlines(owl_message *m)
456{
457  if (m == NULL) return(0);
458  owl_message_format(m);
459  return(owl_fmtext_num_lines(&(m->fmtext->fmtext)));
460}
461
462void owl_message_mark_delete(owl_message *m)
463{
464  if (m == NULL) return;
465  m->delete=1;
466}
467
468void owl_message_unmark_delete(owl_message *m)
469{
470  if (m == NULL) return;
471  m->delete=0;
472}
473
474const char *owl_message_get_zwriteline(const owl_message *m)
475{
476  const char *z = owl_message_get_attribute_value(m, "zwriteline");
477  if (!z) return "";
478  return z;
479}
480
481void owl_message_set_zwriteline(owl_message *m, const char *line)
482{
483  owl_message_set_attribute(m, "zwriteline", line);
484}
485
486int owl_message_is_delete(const owl_message *m)
487{
488  if (m == NULL) return(0);
489  if (m->delete==1) return(1);
490  return(0);
491}
492
493#ifdef HAVE_LIBZEPHYR
494const ZNotice_t *owl_message_get_notice(const owl_message *m)
495{
496  return m->has_notice ? &m->notice : NULL;
497}
498#else
499void *owl_message_get_notice(const owl_message *m)
500{
501  return(NULL);
502}
503#endif
504
505void owl_message_set_hostname(owl_message *m, const char *hostname)
506{
507  m->hostname = g_intern_string(hostname);
508}
509
510const char *owl_message_get_hostname(const owl_message *m)
511{
512  return(m->hostname);
513}
514
515void owl_message_curs_waddstr(owl_message *m, WINDOW *win, int aline, int bline, int acol, int bcol, int fgcolor, int bgcolor)
516{
517  owl_fmtext a, b;
518
519  /* this will ensure that our cached copy is up to date */
520  owl_message_format(m);
521
522  owl_fmtext_init_null(&a);
523  owl_fmtext_init_null(&b);
524 
525  owl_fmtext_truncate_lines(&(m->fmtext->fmtext), aline, bline-aline, &a);
526  owl_fmtext_truncate_cols(&a, acol, bcol, &b);
527
528  owl_fmtext_curs_waddstr(&b, win, OWL_FMTEXT_ATTR_NONE, fgcolor, bgcolor);
529
530  owl_fmtext_cleanup(&a);
531  owl_fmtext_cleanup(&b);
532}
533
534int owl_message_is_personal(const owl_message *m)
535{
536  const owl_filter * f = owl_global_get_filter(&g, "personal");
537  if(!f) {
538      owl_function_error("personal filter is not defined");
539      return (0);
540  }
541  return owl_filter_message_match(f, m);
542}
543
544int owl_message_is_question(const owl_message *m)
545{
546  if(!owl_message_is_type_admin(m)) return 0;
547  if(owl_message_get_attribute_value(m, "question") != NULL) return 1;
548  return 0;
549}
550
551int owl_message_is_answered(const owl_message *m) {
552  const char *q;
553  if(!owl_message_is_question(m)) return 0;
554  q = owl_message_get_attribute_value(m, "question");
555  if(!q) return 0;
556  return !strcmp(q, "answered");
557}
558
559void owl_message_set_isanswered(owl_message *m) {
560  owl_message_set_attribute(m, "question", "answered");
561}
562
563int owl_message_is_mail(const owl_message *m)
564{
565  if (owl_message_is_type_zephyr(m)) {
566    if (!strcasecmp(owl_message_get_class(m), "mail") && owl_message_is_private(m)) {
567      return(1);
568    } else {
569      return(0);
570    }
571  }
572  return(0);
573}
574
575/* caller must free return value. */
576CALLER_OWN char *owl_message_get_cc(const owl_message *m)
577{
578  const char *cur;
579  char *out, *end;
580
581  cur = owl_message_get_body(m);
582  while (*cur && *cur==' ') cur++;
583  if (strncasecmp(cur, "cc:", 3)) return(NULL);
584  cur+=3;
585  while (*cur && *cur==' ') cur++;
586  out = g_strdup(cur);
587  end = strchr(out, '\n');
588  if (end) end[0] = '\0';
589  return(out);
590}
591
592/* caller must free return value */
593CALLER_OWN GList *owl_message_get_cc_without_recipient(const owl_message *m)
594{
595  char *cc, *shortuser, *recip;
596  const char *user;
597  GList *out = NULL;
598
599  cc = owl_message_get_cc(m);
600  if (cc == NULL)
601    return NULL;
602
603  recip = short_zuser(owl_message_get_recipient(m));
604
605  user = strtok(cc, " ");
606  while (user != NULL) {
607    shortuser = short_zuser(user);
608    if (strcasecmp(shortuser, recip) != 0) {
609      out = g_list_prepend(out, g_strdup(user));
610    }
611    g_free(shortuser);
612    user = strtok(NULL, " ");
613  }
614
615  g_free(recip);
616  g_free(cc);
617
618  return(out);
619}
620
621int owl_message_get_id(const owl_message *m)
622{
623  return(m->id);
624}
625
626const char *owl_message_get_type(const owl_message *m) {
627  const char * type = owl_message_get_attribute_value(m, "type");
628  if(!type) {
629    return "generic";
630  }
631  return type;
632}
633
634const char *owl_message_get_direction(const owl_message *m) {
635  switch (m->direction) {
636  case OWL_MESSAGE_DIRECTION_IN:
637    return("in");
638  case OWL_MESSAGE_DIRECTION_OUT:
639    return("out");
640  case OWL_MESSAGE_DIRECTION_NONE:
641    return("none");
642  default:
643    return("unknown");
644  }
645}
646
647int owl_message_parse_direction(const char *d) {
648  if(!strcmp(d, "in")) {
649    return OWL_MESSAGE_DIRECTION_IN;
650  } else if(!strcmp(d, "out")) {
651    return OWL_MESSAGE_DIRECTION_OUT;
652  } else {
653    return OWL_MESSAGE_DIRECTION_NONE;
654  }
655}
656
657
658const char *owl_message_get_login(const owl_message *m) {
659  if (owl_message_is_login(m)) {
660    return "login";
661  } else if (owl_message_is_logout(m)) {
662    return "logout";
663  } else {
664    return "none";
665  }
666}
667
668
669const char *owl_message_get_header(const owl_message *m) {
670  return owl_message_get_attribute_value(m, "adminheader");
671}
672
673/* return 1 if the message contains "string", 0 otherwise.  This is
674 * case insensitive because the functions it uses are
675 */
676int owl_message_search(owl_message *m, const owl_regex *re)
677{
678
679  owl_message_format(m); /* is this necessary? */
680 
681  return owl_fmtext_search(&(m->fmtext->fmtext), re, 0) >= 0;
682}
683
684
685/* if loginout == -1 it's a logout message
686 *                 0 it's not a login/logout message
687 *                 1 it's a login message
688 */
689void owl_message_create_aim(owl_message *m, const char *sender, const char *recipient, const char *text, int direction, int loginout)
690{
691  owl_message_init(m);
692  owl_message_set_body(m, text);
693  owl_message_set_sender(m, sender);
694  owl_message_set_recipient(m, recipient);
695  owl_message_set_type_aim(m);
696
697  if (direction==OWL_MESSAGE_DIRECTION_IN) {
698    owl_message_set_direction_in(m);
699  } else if (direction==OWL_MESSAGE_DIRECTION_OUT) {
700    owl_message_set_direction_out(m);
701  }
702
703  /* for now all messages that aren't loginout are private */
704  if (!loginout) {
705    owl_message_set_isprivate(m);
706  }
707
708  if (loginout==-1) {
709    owl_message_set_islogout(m);
710  } else if (loginout==1) {
711    owl_message_set_islogin(m);
712  }
713}
714
715void owl_message_create_admin(owl_message *m, const char *header, const char *text)
716{
717  owl_message_init(m);
718  owl_message_set_type_admin(m);
719  owl_message_set_body(m, text);
720  owl_message_set_attribute(m, "adminheader", header); /* just a hack for now */
721}
722
723/* caller should set the direction */
724void owl_message_create_loopback(owl_message *m, const char *text)
725{
726  owl_message_init(m);
727  owl_message_set_type_loopback(m);
728  owl_message_set_body(m, text);
729  owl_message_set_sender(m, "loopsender");
730  owl_message_set_recipient(m, "looprecip");
731  owl_message_set_isprivate(m);
732}
733
734void owl_message_save_ccs(owl_message *m) {
735  GList *cc;
736  char *tmp;
737
738  cc = owl_message_get_cc_without_recipient(m);
739
740  if (cc != NULL) {
741    GString *recips = g_string_new("");
742    cc = g_list_prepend(cc, short_zuser(owl_message_get_sender(m)));
743    cc = g_list_prepend(cc, short_zuser(owl_message_get_recipient(m)));
744    cc = g_list_sort(cc, (GCompareFunc)strcasecmp);
745
746    while(cc != NULL) {
747      /* Collapse any identical entries */
748      while (cc->next && strcasecmp(cc->data, cc->next->data) == 0) {
749        g_free(cc->data);
750        cc = g_list_delete_link(cc, cc);
751      }
752
753      tmp = short_zuser(cc->data);
754      g_string_append(recips, tmp);
755
756      g_free(tmp);
757      g_free(cc->data);
758      cc = g_list_delete_link(cc, cc);
759
760      if (cc)
761        g_string_append_c(recips, ' ');
762    }
763
764    owl_message_set_attribute(m, "zephyr_ccs", recips->str);
765    g_string_free(recips, true);
766  }
767}
768
769#ifdef HAVE_LIBZEPHYR
770void owl_message_create_from_znotice(owl_message *m, const ZNotice_t *n)
771{
772#ifdef ZNOTICE_SOCKADDR
773  char hbuf[NI_MAXHOST];
774#else /* !ZNOTICE_SOCKADDR */
775  struct hostent *hent;
776#endif /* ZNOTICE_SOCKADDR */
777  char *tmp, *tmp2;
778  int len;
779
780  owl_message_init(m);
781 
782  owl_message_set_type_zephyr(m);
783  owl_message_set_direction_in(m);
784 
785  /* first save the full notice */
786  m->notice = *n;
787  m->has_notice = true;
788
789  /* a little gross, we'll replace \r's with ' ' for now */
790  owl_zephyr_hackaway_cr(&(m->notice));
791 
792  /* save the time, we need to nuke the string saved by message_init */
793  if (m->timestr) g_free(m->timestr);
794  m->time = n->z_time.tv_sec;
795  m->timestr = g_strdup(ctime(&m->time));
796  m->timestr[strlen(m->timestr)-1] = '\0';
797
798  /* set other info */
799  owl_message_set_sender(m, n->z_sender);
800  owl_message_set_class(m, n->z_class);
801  owl_message_set_instance(m, n->z_class_inst);
802  owl_message_set_recipient(m, n->z_recipient);
803  if (n->z_opcode) {
804    owl_message_set_opcode(m, n->z_opcode);
805  } else {
806    owl_message_set_opcode(m, "");
807  }
808  owl_message_set_zsig(m, owl_zephyr_get_zsig(n, &len));
809
810  owl_message_set_realm(m, zuser_realm(n->z_recipient));
811
812  /* Set the "isloginout" attribute if it's a login message */
813  if (!strcasecmp(n->z_class, "login") || !strcasecmp(n->z_class, OWL_WEBZEPHYR_CLASS)) {
814    if (!strcasecmp(n->z_opcode, "user_login") || !strcasecmp(n->z_opcode, "user_logout")) {
815      tmp=owl_zephyr_get_field(n, 1);
816      owl_message_set_attribute(m, "loginhost", tmp);
817      g_free(tmp);
818
819      tmp=owl_zephyr_get_field(n, 3);
820      owl_message_set_attribute(m, "logintty", tmp);
821      g_free(tmp);
822    }
823
824    if (!strcasecmp(n->z_opcode, "user_login")) {
825      owl_message_set_islogin(m);
826    } else if (!strcasecmp(n->z_opcode, "user_logout")) {
827      owl_message_set_islogout(m);
828    }
829  }
830
831 
832  /* set the "isprivate" attribute if it's a private zephyr. */
833  if (owl_zwrite_recip_is_personal(n->z_recipient)) {
834    owl_message_set_isprivate(m);
835  }
836
837  /* set the "isauto" attribute if it's an autoreply */
838  if (!strcasecmp(n->z_message, "Automated reply:") ||
839      !strcasecmp(n->z_opcode, "auto")) {
840    owl_message_set_attribute(m, "isauto", "");
841  }
842
843  /* save the hostname */
844#ifdef ZNOTICE_SOCKADDR
845  owl_function_debugmsg("About to do getnameinfo");
846  if (getnameinfo(&n->z_sender_sockaddr.sa, sizeof(n->z_sender_sockaddr), hbuf, sizeof(hbuf), NULL, 0, 0) == 0)
847    owl_message_set_hostname(m, hbuf);
848#else /* !ZNOTICE_SOCKADDR */
849  owl_function_debugmsg("About to do gethostbyaddr");
850  hent = gethostbyaddr(&n->z_uid.zuid_addr, sizeof(n->z_uid.zuid_addr), AF_INET);
851  if (hent && hent->h_name)
852    owl_message_set_hostname(m, hent->h_name);
853  else
854    owl_message_set_hostname(m, inet_ntoa(n->z_sender_addr));
855#endif /* ZNOTICE_SOCKADDR */
856
857  /* set the body */
858  tmp=owl_zephyr_get_message(n, m);
859  if (owl_global_is_newlinestrip(&g)) {
860    tmp2=owl_util_stripnewlines(tmp);
861    owl_message_set_body(m, tmp2);
862    g_free(tmp2);
863  } else {
864    owl_message_set_body(m, tmp);
865  }
866  g_free(tmp);
867
868  /* if zcrypt is enabled try to decrypt the message */
869  if (owl_global_is_zcrypt(&g) && !strcasecmp(n->z_opcode, "crypt")) {
870    const char *argv[] = {
871      NULL,
872      "-D",
873      "-c", owl_message_get_class(m),
874      "-i", owl_message_get_instance(m),
875      NULL
876    };
877    char *out = NULL;
878    int rv;
879    int status;
880    char *zcrypt;
881
882    zcrypt = g_build_filename(owl_get_bindir(), "zcrypt", NULL);
883    argv[0] = zcrypt;
884
885    rv = call_filter(argv, owl_message_get_body(m), &out, &status);
886    g_free(zcrypt);
887
888    if(!rv && !status) {
889      int len = strlen(out);
890      if(len >= 8 && !strcmp(out + len - 8, "**END**\n")) {
891        out[len - 8] = 0;
892      }
893      owl_message_set_body(m, out);
894    } else {
895      /* Replace the opcode. Otherwise the UI and other bits of code think the
896       * message was encrypted. */
897      owl_message_set_opcode(m, "failed-decrypt");
898    }
899    g_free(out);
900  }
901
902  owl_message_save_ccs(m);
903}
904#else
905void owl_message_create_from_znotice(owl_message *m, const void *n)
906{
907}
908#endif
909
910/* If 'direction' is '0' it is a login message, '1' is a logout message. */
911void owl_message_create_pseudo_zlogin(owl_message *m, int direction, const char *user, const char *host, const char *time, const char *tty)
912{
913  char *longuser;
914
915#ifdef HAVE_LIBZEPHYR
916  memset(&(m->notice), 0, sizeof(ZNotice_t));
917#endif
918 
919  longuser=long_zuser(user);
920 
921  owl_message_init(m);
922 
923  owl_message_set_type_zephyr(m);
924  owl_message_set_direction_in(m);
925
926  owl_message_set_attribute(m, "pseudo", "");
927  owl_message_set_attribute(m, "loginhost", host ? host : "");
928  owl_message_set_attribute(m, "logintty", tty ? tty : "");
929
930  owl_message_set_sender(m, longuser);
931  owl_message_set_class(m, "LOGIN");
932  owl_message_set_instance(m, longuser);
933  owl_message_set_recipient(m, "");
934  if (direction==0) {
935    owl_message_set_opcode(m, "USER_LOGIN");
936    owl_message_set_islogin(m);
937  } else if (direction==1) {
938    owl_message_set_opcode(m, "USER_LOGOUT");
939    owl_message_set_islogout(m);
940  }
941
942  owl_message_set_realm(m, zuser_realm(longuser));
943
944  owl_message_set_body(m, "<uninitialized>");
945
946  /* save the hostname */
947  owl_function_debugmsg("create_pseudo_login: host is %s", host ? host : "");
948  owl_message_set_hostname(m, host ? host : "");
949  g_free(longuser);
950}
951
952void owl_message_create_from_zwrite(owl_message *m, const owl_zwrite *z, const char *body, int recip_index)
953{
954  char *replyline;
955 
956  owl_message_init(m);
957
958  /* set things */
959  owl_message_set_direction_out(m);
960  owl_message_set_type_zephyr(m);
961  owl_message_set_sender(m, owl_zephyr_get_sender());
962  owl_message_set_class(m, owl_zwrite_get_class(z));
963  owl_message_set_instance(m, owl_zwrite_get_instance(z));
964  if (recip_index < owl_zwrite_get_numrecips(z)) {
965    char *zuser = owl_zwrite_get_recip_n_with_realm(z, recip_index);
966    char *longzuser = long_zuser(zuser);
967    owl_message_set_recipient(m, longzuser);
968    owl_message_set_realm(m, zuser_realm(longzuser));
969    g_free(longzuser);
970    g_free(zuser);
971  } else {
972    /* TODO: We should maybe munge this into the case above, as that comparison
973     * is a little overly clever. It's also not clear this codepath ever runs
974     * anyway. */
975    const char *realm = owl_zwrite_get_realm(z);
976    owl_message_set_realm(m, realm[0] ? realm : owl_zephyr_get_realm());
977  }
978  owl_message_set_opcode(m, owl_zwrite_get_opcode(z));
979
980  /* Although not strictly the zwriteline, anyone using the unsantized version
981   * of it probably has a bug. */
982  replyline = owl_zwrite_get_replyline(z, recip_index);
983  owl_message_set_zwriteline(m, replyline);
984  g_free(replyline);
985
986  owl_message_set_body(m, body);
987  owl_message_set_zsig(m, owl_zwrite_get_zsig(z));
988 
989  /* save the hostname */
990  owl_message_set_hostname(m, g_get_host_name());
991
992  /* set the "isprivate" attribute if it's a private zephyr. */
993  if (owl_zwrite_is_personal(z)) {
994    owl_message_set_isprivate(m);
995  }
996
997  owl_message_save_ccs(m);
998}
999
1000void owl_message_cleanup(owl_message *m)
1001{
1002  int i;
1003  owl_pair *p;
1004#ifdef HAVE_LIBZEPHYR   
1005  if (m->has_notice) {
1006    ZFreeNotice(&(m->notice));
1007  }
1008#endif
1009  if (m->timestr) g_free(m->timestr);
1010
1011  /* free all the attributes */
1012  for (i = 0; i < m->attributes->len; i++) {
1013    p = m->attributes->pdata[i];
1014    g_free(owl_pair_get_value(p));
1015    g_slice_free(owl_pair, p);
1016  }
1017
1018  g_ptr_array_free(m->attributes, true);
1019 
1020  owl_message_invalidate_format(m);
1021}
1022
1023void owl_message_delete(owl_message *m)
1024{
1025  owl_message_cleanup(m);
1026  g_slice_free(owl_message, m);
1027}
Note: See TracBrowser for help on using the repository browser.