1 files changed, 142 insertions, 0 deletions
diff --git a/ldapaddressbook/abooksearch.c b/ldapaddressbook/abooksearch.c
new file mode 100644
index 0000000..7751445
--- /dev/null
+++ b/ldapaddressbook/abooksearch.c
@@ -0,0 +1,142 @@
+/*
+**
+** Copyright 2003-2006, Double Precision Inc.
+**
+** See COPYING for distribution information.
+*/
+
+#include	"config.h"
+#include	"ldapaddressbook.h"
+
+#include	<stdio.h>
+#include	<string.h>
+#include	<signal.h>
+#include	<stdlib.h>
+#include	<unistd.h>
+#include	<errno.h>
+#include	<sys/types.h>
+#if HAVE_SYS_WAIT_H
+#include	<sys/wait.h>
+#endif
+#ifndef WEXITSTATUS
+#define WEXITSTATUS(stat_val) ((unsigned)(stat_val) >> 8)
+#endif
+#ifndef WIFEXITED
+#define WIFEXITED(stat_val) (((stat_val) & 255) == 0)
+#endif
+
+#define exit(_a_) _exit(_a_)
+
+int ldapabook_search(const struct ldapabook *b,	/* Search this address book */
+		     const char *script,
+		     const char *search,
+		     int (*callback_func)(const char *utf8_name,
+					  const char *address,
+					  void *callback_arg),
+		     void (*callback_err)(const char *errmsg,
+					  void *callback_arg),
+		     void *callback_arg)
+{
+	int	pipefd[2];
+	pid_t	p;
+	const char *argv[40];
+	char	buf1[BUFSIZ];
+	char	buf2[BUFSIZ];
+	FILE	*t, *fp;
+	int	rc_code=0;
+	pid_t p2;
+	int waitstat;
+
+	signal(SIGCHLD, SIG_DFL);
+
+	if (pipe(pipefd) < 0)	return (-1);
+
+	if ((t=tmpfile()) == NULL)
+	{
+		close(pipefd[0]);
+		close(pipefd[1]);
+		return (-1);
+	}
+
+	if ((p=fork()) == -1)
+	{
+		fclose(t);
+		close(pipefd[0]);
+		close(pipefd[1]);
+		return (-1);
+	}
+
+	if (p == 0)
+	{
+		dup2(pipefd[1], 1);
+		close(pipefd[0]);
+		close(pipefd[1]);
+
+		dup2(fileno(t), 2);
+		fclose(t);
+
+		argv[0]=script;
+		argv[1]=b->host;
+		argv[2]=b->port;
+		argv[3]=b->suffix;
+		argv[4]=search;
+		argv[5]=NULL;
+
+		execvp(script, (char **)argv);
+		perror(script);
+		exit(1);
+	}
+
+	fp=fdopen(pipefd[0], "r");
+	close(pipefd[1]);
+
+	if (!fp)
+	{
+		sprintf(buf1, "%1.256s", strerror(errno));
+
+		close(pipefd[0]);
+
+		while ((p2=wait(NULL)) != p)
+			;
+		fclose(t);
+
+		(*callback_err)(buf1, callback_arg);
+		return -1;
+	}
+
+	while (fgets(buf1, sizeof(buf1), fp) != NULL &&
+	       fgets(buf2, sizeof(buf2), fp) != NULL)
+	{
+		char *p=strchr(buf1, '\n');
+
+		if (p) *p=0;
+
+		p=strchr(buf2, '\n');
+		if (p) *p=0;
+
+		if (rc_code == 0)
+			rc_code=(*callback_func)(buf1, buf2, callback_arg);
+	}
+
+	fclose(fp);
+	close(pipefd[0]);
+
+	while ((p2=wait(&waitstat)) != p)
+		;
+
+	if (waitstat && rc_code == 0)
+	{
+		rc_code= -1;
+		fseek(t, 0L, SEEK_SET);
+
+		if (fgets(buf1, sizeof(buf1), t))
+		{
+			char *p=strchr(buf1, '\n');
+			if (p) *p=0;
+
+			(*callback_err)(buf1, callback_arg);
+		}
+	}
+	fclose(t);
+	return rc_code;
+}