1 files changed, 109 insertions, 6 deletions

diff --git a/src/evanix.c b/src/evanix.c
index e83d0ea..64bd763 100644
--- a/src/evanix.c
+++ b/src/evanix.c
@@ -1,18 +1,40 @@
+#include <getopt.h>
 #include <stdlib.h>
 #include <string.h>
 
 #include "build.h"
+#include "evanix.h"
 #include "queue.h"
 #include "util.h"
 
-int main(void)
+static const char usage[] =
+	"Usage: evanix [options] expr\n"
+	"\n"
+	"  -h, --help                      Show help message and quit.\n"
+	"  -f, --flake                     Build a flake.\n"
+	"  -d, --dry-run                   Show what derivations would be "
+	"built.\n"
+	"  -p, --pipelined         <bool>  Use evanix build pipeline.\n"
+	"  -c, --close-stderr-exec <bool>  Close stderr on exec.\n"
+	"\n";
+
+struct evanix_opts_t evanix_opts = {
+	.close_stderr_exec = true,
+	.isflake = false,
+	.ispipelined = true,
+	.isdryrun = false,
+};
+
+static int evanix(char *expr);
+
+static int evanix(char *expr)
 {
 	struct queue_thread *queue_thread = NULL;
 	struct build_thread *build_thread = NULL;
 	FILE *stream = NULL;
 	int ret = 0;
 
-	ret = jobs_init(&stream);
+	ret = jobs_init(&stream, expr);
 	if (ret < 0)
 		goto out_free;
 
@@ -35,14 +57,21 @@ int main(void)
 		goto out_free;
 	}
 
-	ret = pthread_create(&build_thread->tid, NULL, build_thread_entry,
-			     build_thread);
+	if (evanix_opts.ispipelined)
+		ret = pthread_create(&build_thread->tid, NULL,
+				     build_thread_entry, build_thread);
+	else
+		ret = pthread_join(queue_thread->tid, NULL);
 	if (ret < 0) {
 		print_err("%s", strerror(ret));
 		goto out_free;
 	}
 
-	ret = pthread_join(queue_thread->tid, NULL);
+	if (evanix_opts.ispipelined)
+		ret = pthread_join(queue_thread->tid, NULL);
+	else
+		ret = pthread_create(&build_thread->tid, NULL,
+				     build_thread_entry, build_thread);
 	if (ret < 0) {
 		print_err("%s", strerror(ret));
 		goto out_free;
@@ -57,5 +86,79 @@ int main(void)
 out_free:
 	queue_thread_free(queue_thread);
 	free(build_thread);
-	exit(ret < 0 ? EXIT_FAILURE : EXIT_SUCCESS);
+	return ret;
+}
+
+int main(int argc, char *argv[])
+{
+	extern int optind, opterr, optopt;
+	extern char *optarg;
+	int ret, longindex;
+
+	static struct option longopts[] = {
+		{"help", no_argument, NULL, 'h'},
+		{"flake", no_argument, NULL, 'f'},
+		{"dry-run", no_argument, NULL, 'd'},
+		{"pipelined", required_argument, NULL, 'p'},
+		{"close-stderr-exec", required_argument, NULL, 'c'},
+		{NULL, 0, NULL, 0},
+	};
+
+	while ((ret = getopt_long(argc, argv, "", longopts, &longindex)) !=
+	       -1) {
+		switch (ret) {
+		case 'h':
+			printf("%s", usage);
+			exit(EXIT_SUCCESS);
+			break;
+		case 'f':
+			evanix_opts.isflake = true;
+			break;
+		case 'd':
+			evanix_opts.isdryrun = true;
+			break;
+		case 'p':
+			ret = atob(optarg);
+			if (ret < 0) {
+				fprintf(stderr,
+					"option --%s requires a bool argument\n"
+					"Try 'evanix --help' for more "
+					"information.\n",
+					longopts[longindex].name);
+				exit(EXIT_FAILURE);
+			}
+
+			evanix_opts.ispipelined = ret;
+			break;
+		case 'c':
+			ret = atob(optarg);
+			if (ret < 0) {
+				fprintf(stderr,
+					"option --%s requires a bool argument\n"
+					"Try 'evanix --help' for more "
+					"information.\n",
+					longopts[longindex].name);
+				exit(EXIT_FAILURE);
+			}
+
+			evanix_opts.close_stderr_exec = ret;
+			break;
+		default:
+			fprintf(stderr,
+				"Try 'evanix --help' for more information.\n");
+			exit(EXIT_FAILURE);
+			break;
+		}
+	}
+	if (optind != argc - 1) {
+		fprintf(stderr, "evanix: invalid expr operand\n"
+				"Try 'evanix --help' for more information.\n");
+		exit(EXIT_FAILURE);
+	}
+
+	ret = evanix(argv[optind]);
+	if (ret < 0)
+		exit(EXIT_FAILURE);
+
+	exit(EXIT_SUCCESS);
 }