aboutsummaryrefslogblamecommitdiff
path: root/src/util.c
blob: 001180ea93d086771456c1b1db6b3e48272f6203 (plain) (tree) 
8dfff06













































































1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77













































































                                                               
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#include <cjson/cJSON.h>

#include "util.h"

int json_streaming_read(FILE *stream, cJSON **json)
{
	int ret;
	size_t n;
	char *line = NULL;

	ret = getline(&line, &n, stream);
	if (ret < 0) {
		if (errno != 0) {
			print_err("%s", strerror(errno));
			return -errno;
		}

		return -EOF;
	}

	*json = cJSON_Parse(line);
	free(line);
	if (cJSON_IsInvalid(*json)) {
		print_err("%s", "Invalid JSON");
		return -EPERM;
	}

	return 0;
}

int vpopen(FILE **stream, const char *file, char *const argv[])
{
	int fd[2];
	int ret;

	ret = pipe(fd);
	if (ret < 0) {
		print_err("%s", strerror(errno));
		return -errno;
	}

	ret = fork();
	if (ret < 0) {
		print_err("%s", strerror(errno));

		close(fd[0]);
		close(fd[1]);
		return -errno;
	} else if (ret > 0) {
		close(fd[1]);
		*stream = fdopen(fd[0], "r");
		if (*stream == NULL) {
			print_err("%s", strerror(errno));
			return -errno;
		}

		return 0;
	}

	close(fd[0]);
	ret = dup2(fd[1], STDOUT_FILENO);
	if (ret < 0)
		goto out_err;

	execvp(file, argv);

out_err:
	close(fd[1]);
	print_err("%s", strerror(errno));
	exit(EXIT_FAILURE);
}