1 files changed, 144 insertions, 0 deletions
diff --git a/sqwebmail/filter.c b/sqwebmail/filter.c
new file mode 100644
index 0000000..fed2554
--- /dev/null
+++ b/sqwebmail/filter.c
@@ -0,0 +1,144 @@
+#include "config.h"
+
+/*
+** Copyright 1998 - 2011 Double Precision, Inc.  See COPYING for
+** distribution information.
+*/
+
+
+/*
+*/
+#include	"filter.h"
+#include	"buf.h"
+#include	"sqwebmail.h"
+#include	<string.h>
+
+static int converted_text(const char *buf,
+			  size_t size,
+			  void *arg)
+{
+	struct filter_info *info=(struct filter_info *)arg;
+
+	(*info->handler_func)(buf, size, info->func_arg);
+	return 0;
+}
+
+void	filter_start(struct filter_info *info,
+		     const char *charset,
+		     void (*handler)(const char *, size_t, void *),
+		     void *arg)
+{
+	info->conversion_error=0;
+	info->handle=libmail_u_convert_init(libmail_u_ucs4_native,
+					    charset,
+					    converted_text, info);
+
+	if (info->handle == NULL)
+		info->conversion_error=1;
+
+	info->handler_func=handler;
+	info->func_arg=arg;
+	info->u_w=0;
+
+	info->linesize=MYLINESIZE + 10;
+	info->prevchar='\n';
+}
+
+void	filter(struct filter_info *info,
+	       const unicode_char *ptr, size_t cnt)
+{
+	size_t i, prev;
+
+	if (!info->handle)
+		return;
+
+	i=prev=0;
+
+	while (1)
+	{
+		const char *p=0;
+		unicode_char prevchar=info->prevchar;
+
+		if (i < cnt)
+		{
+			info->prevchar=ptr[i];
+
+			if (ptr[i] == '\n')
+			{
+				info->u_w=0;
+			}
+			else
+			{
+				/* Force-break excessively long lines */
+
+				size_t uc_w=unicode_wcwidth(ptr[i]);
+
+				if (uc_w + info->u_w > info->linesize &&
+				    unicode_grapheme_break(prevchar, ptr[i]))
+				{
+					unicode_char nl='\n';
+
+					if (prev < i)
+						libmail_u_convert_uc
+							(info->handle,
+							 ptr+prev, i-prev);
+					prev=i;
+
+					libmail_u_convert_uc(info->handle,
+							     &nl, 1);
+					info->u_w=0;
+				}
+
+				info->u_w += uc_w;
+			}
+
+			switch (ptr[i]) {
+			case '<':
+				p="&lt;";
+				break;
+			case '>':
+				p="&gt;";
+				break;
+			case '&':
+				p="&amp;";
+				break;
+			case '"':
+				p="&quot;";
+				break;
+			default:
+				++i;
+				continue;
+			}
+		}
+
+		if (prev < i)
+			libmail_u_convert_uc(info->handle, ptr+prev, i-prev);
+		prev=++i;
+
+		if (!p)
+			break;
+
+		while (*p)
+		{
+			unicode_char uc= *p++;
+
+			libmail_u_convert_uc(info->handle, &uc, 1);
+		}
+	}
+}
+
+void	filter_passthru(struct filter_info *info,
+			const unicode_char *ptr, size_t cnt)
+{
+	libmail_u_convert_uc(info->handle, ptr, cnt);
+}
+
+void	filter_end(struct filter_info *info)
+{
+	if (info->handle)
+	{
+		libmail_u_convert_deinit(info->handle,
+					 &info->conversion_error);
+		info->handle=NULL;
+	}
+}