1 a440fac0 2018-09-06 stsp /*
  2 a440fac0 2018-09-06 stsp  * Copyright (c) 2018 Stefan Sperling <stsp@openbsd.org>
  3 a440fac0 2018-09-06 stsp  *
  4 a440fac0 2018-09-06 stsp  * Permission to use, copy, modify, and distribute this software for any
  5 a440fac0 2018-09-06 stsp  * purpose with or without fee is hereby granted, provided that the above
  6 a440fac0 2018-09-06 stsp  * copyright notice and this permission notice appear in all copies.
  7 a440fac0 2018-09-06 stsp  *
  8 a440fac0 2018-09-06 stsp  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
  9 a440fac0 2018-09-06 stsp  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 10 a440fac0 2018-09-06 stsp  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 11 a440fac0 2018-09-06 stsp  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 12 a440fac0 2018-09-06 stsp  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 13 a440fac0 2018-09-06 stsp  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 14 a440fac0 2018-09-06 stsp  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 15 a440fac0 2018-09-06 stsp  */
 16 a440fac0 2018-09-06 stsp 
 17 a440fac0 2018-09-06 stsp #include <sys/types.h>
 18 a440fac0 2018-09-06 stsp #include <sys/stat.h>
 19 a440fac0 2018-09-06 stsp #include <sys/queue.h>
 20 a440fac0 2018-09-06 stsp #include <sys/uio.h>
 21 a440fac0 2018-09-06 stsp #include <sys/socket.h>
 22 a440fac0 2018-09-06 stsp #include <sys/wait.h>
 23 a440fac0 2018-09-06 stsp 
 24 a440fac0 2018-09-06 stsp #include <errno.h>
 25 a440fac0 2018-09-06 stsp #include <stdio.h>
 26 a440fac0 2018-09-06 stsp #include <stdlib.h>
 27 a440fac0 2018-09-06 stsp #include <string.h>
 28 a440fac0 2018-09-06 stsp #include <stdint.h>
 29 a440fac0 2018-09-06 stsp #include <sha1.h>
 30 a440fac0 2018-09-06 stsp #include <zlib.h>
 31 a440fac0 2018-09-06 stsp #include <ctype.h>
 32 a440fac0 2018-09-06 stsp #include <limits.h>
 33 a440fac0 2018-09-06 stsp #include <imsg.h>
 34 a440fac0 2018-09-06 stsp #include <time.h>
 35 a440fac0 2018-09-06 stsp 
 36 a440fac0 2018-09-06 stsp #include "got_error.h"
 37 a440fac0 2018-09-06 stsp #include "got_object.h"
 38 a440fac0 2018-09-06 stsp #include "got_repository.h"
 39 a440fac0 2018-09-06 stsp #include "got_opentemp.h"
 40 a440fac0 2018-09-06 stsp 
 41 a440fac0 2018-09-06 stsp #include "got_lib_sha1.h"
 42 a440fac0 2018-09-06 stsp #include "got_lib_delta.h"
 43 a440fac0 2018-09-06 stsp #include "got_lib_pack.h"
 44 a440fac0 2018-09-06 stsp #include "got_lib_inflate.h"
 45 a440fac0 2018-09-06 stsp #include "got_lib_object.h"
 46 a440fac0 2018-09-06 stsp #include "got_lib_privsep.h"
 47 a440fac0 2018-09-06 stsp 
 48 a440fac0 2018-09-06 stsp #ifndef nitems
 49 a440fac0 2018-09-06 stsp #define nitems(_a) (sizeof(_a) / sizeof((_a)[0]))
 50 a440fac0 2018-09-06 stsp #endif
 51 a440fac0 2018-09-06 stsp 
 52 a440fac0 2018-09-06 stsp #define GOT_OBJ_TAG_COMMIT	"commit"
 53 a440fac0 2018-09-06 stsp #define GOT_OBJ_TAG_TREE	"tree"
 54 a440fac0 2018-09-06 stsp #define GOT_OBJ_TAG_BLOB	"blob"
 55 a440fac0 2018-09-06 stsp 
 56 a440fac0 2018-09-06 stsp #define GOT_COMMIT_TAG_TREE		"tree "
 57 a440fac0 2018-09-06 stsp #define GOT_COMMIT_TAG_PARENT		"parent "
 58 a440fac0 2018-09-06 stsp #define GOT_COMMIT_TAG_AUTHOR		"author "
 59 a440fac0 2018-09-06 stsp #define GOT_COMMIT_TAG_COMMITTER	"committer "
 60 a440fac0 2018-09-06 stsp 
 61 a440fac0 2018-09-06 stsp static const struct got_error *
 62 a440fac0 2018-09-06 stsp parse_object_header(struct got_object **obj, char *buf, size_t len)
 63 a440fac0 2018-09-06 stsp {
 64 a440fac0 2018-09-06 stsp 	const char *obj_tags[] = {
 65 a440fac0 2018-09-06 stsp 		GOT_OBJ_TAG_COMMIT,
 66 a440fac0 2018-09-06 stsp 		GOT_OBJ_TAG_TREE,
 67 a440fac0 2018-09-06 stsp 		GOT_OBJ_TAG_BLOB
 68 a440fac0 2018-09-06 stsp 	};
 69 a440fac0 2018-09-06 stsp 	const int obj_types[] = {
 70 a440fac0 2018-09-06 stsp 		GOT_OBJ_TYPE_COMMIT,
 71 a440fac0 2018-09-06 stsp 		GOT_OBJ_TYPE_TREE,
 72 a440fac0 2018-09-06 stsp 		GOT_OBJ_TYPE_BLOB,
 73 a440fac0 2018-09-06 stsp 	};
 74 a440fac0 2018-09-06 stsp 	int type = 0;
 75 a440fac0 2018-09-06 stsp 	size_t size = 0, hdrlen = 0;
 76 a440fac0 2018-09-06 stsp 	int i;
 77 a440fac0 2018-09-06 stsp 	char *p = strchr(buf, '\0');
 78 a440fac0 2018-09-06 stsp 
 79 a440fac0 2018-09-06 stsp 	if (p == NULL)
 80 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_HDR);
 81 a440fac0 2018-09-06 stsp 
 82 a440fac0 2018-09-06 stsp 	hdrlen = strlen(buf) + 1 /* '\0' */;
 83 a440fac0 2018-09-06 stsp 
 84 a440fac0 2018-09-06 stsp 	for (i = 0; i < nitems(obj_tags); i++) {
 85 a440fac0 2018-09-06 stsp 		const char *tag = obj_tags[i];
 86 a440fac0 2018-09-06 stsp 		size_t tlen = strlen(tag);
 87 a440fac0 2018-09-06 stsp 		const char *errstr;
 88 a440fac0 2018-09-06 stsp 
 89 a440fac0 2018-09-06 stsp 		if (strncmp(buf, tag, tlen) != 0)
 90 a440fac0 2018-09-06 stsp 			continue;
 91 a440fac0 2018-09-06 stsp 
 92 a440fac0 2018-09-06 stsp 		type = obj_types[i];
 93 a440fac0 2018-09-06 stsp 		if (len <= tlen)
 94 a440fac0 2018-09-06 stsp 			return got_error(GOT_ERR_BAD_OBJ_HDR);
 95 a440fac0 2018-09-06 stsp 		size = strtonum(buf + tlen, 0, LONG_MAX, &errstr);
 96 a440fac0 2018-09-06 stsp 		if (errstr != NULL)
 97 a440fac0 2018-09-06 stsp 			return got_error(GOT_ERR_BAD_OBJ_HDR);
 98 a440fac0 2018-09-06 stsp 		break;
 99 a440fac0 2018-09-06 stsp 	}
100 a440fac0 2018-09-06 stsp 
101 a440fac0 2018-09-06 stsp 	if (type == 0)
102 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_HDR);
103 a440fac0 2018-09-06 stsp 
104 a440fac0 2018-09-06 stsp 	*obj = calloc(1, sizeof(**obj));
105 a440fac0 2018-09-06 stsp 	if (*obj == NULL)
106 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
107 a440fac0 2018-09-06 stsp 	(*obj)->type = type;
108 a440fac0 2018-09-06 stsp 	(*obj)->hdrlen = hdrlen;
109 a440fac0 2018-09-06 stsp 	(*obj)->size = size;
110 a440fac0 2018-09-06 stsp 	return NULL;
111 a440fac0 2018-09-06 stsp }
112 a440fac0 2018-09-06 stsp 
113 a440fac0 2018-09-06 stsp static const struct got_error *
114 a440fac0 2018-09-06 stsp read_object_header(struct got_object **obj, int fd)
115 a440fac0 2018-09-06 stsp {
116 a440fac0 2018-09-06 stsp 	const struct got_error *err;
117 a440fac0 2018-09-06 stsp 	struct got_zstream_buf zb;
118 a440fac0 2018-09-06 stsp 	char *buf;
119 a440fac0 2018-09-06 stsp 	const size_t zbsize = 64;
120 a440fac0 2018-09-06 stsp 	size_t outlen, totlen;
121 a440fac0 2018-09-06 stsp 	int nbuf = 1;
122 a440fac0 2018-09-06 stsp 
123 a440fac0 2018-09-06 stsp 	buf = malloc(zbsize);
124 a440fac0 2018-09-06 stsp 	if (buf == NULL)
125 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
126 a440fac0 2018-09-06 stsp 
127 a440fac0 2018-09-06 stsp 	err = got_inflate_init(&zb, buf, zbsize);
128 a440fac0 2018-09-06 stsp 	if (err)
129 a440fac0 2018-09-06 stsp 		return err;
130 a440fac0 2018-09-06 stsp 
131 a440fac0 2018-09-06 stsp 	totlen = 0;
132 a440fac0 2018-09-06 stsp 	do {
133 a440fac0 2018-09-06 stsp 		err = got_inflate_read_fd(&zb, fd, &outlen);
134 a440fac0 2018-09-06 stsp 		if (err)
135 a440fac0 2018-09-06 stsp 			goto done;
136 a440fac0 2018-09-06 stsp 		if (outlen == 0)
137 a440fac0 2018-09-06 stsp 			break;
138 a440fac0 2018-09-06 stsp 		totlen += outlen;
139 a440fac0 2018-09-06 stsp 		if (strchr(zb.outbuf, '\0') == NULL) {
140 a440fac0 2018-09-06 stsp 			char *newbuf;
141 a440fac0 2018-09-06 stsp 			nbuf++;
142 a440fac0 2018-09-06 stsp 			newbuf = recallocarray(buf, nbuf - 1, nbuf, zbsize);
143 a440fac0 2018-09-06 stsp 			if (newbuf == NULL) {
144 a440fac0 2018-09-06 stsp 				err = got_error_from_errno();
145 a440fac0 2018-09-06 stsp 				goto done;
146 a440fac0 2018-09-06 stsp 			}
147 a440fac0 2018-09-06 stsp 			buf = newbuf;
148 a440fac0 2018-09-06 stsp 			zb.outbuf = newbuf + totlen;
149 a440fac0 2018-09-06 stsp 			zb.outlen = (nbuf * zbsize) - totlen;
150 a440fac0 2018-09-06 stsp 		}
151 a440fac0 2018-09-06 stsp 	} while (strchr(zb.outbuf, '\0') == NULL);
152 a440fac0 2018-09-06 stsp 
153 a440fac0 2018-09-06 stsp 	err = parse_object_header(obj, buf, totlen);
154 a440fac0 2018-09-06 stsp done:
155 a440fac0 2018-09-06 stsp 	free(buf);
156 a440fac0 2018-09-06 stsp 	got_inflate_end(&zb);
157 a440fac0 2018-09-06 stsp 	return err;
158 a440fac0 2018-09-06 stsp }
159 a440fac0 2018-09-06 stsp 
160 a440fac0 2018-09-06 stsp static void
161 a440fac0 2018-09-06 stsp read_object_header_privsep_child(int obj_fd, int imsg_fds[2])
162 a440fac0 2018-09-06 stsp {
163 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL;
164 a440fac0 2018-09-06 stsp 	struct got_object *obj = NULL;
165 a440fac0 2018-09-06 stsp 	struct imsgbuf ibuf;
166 a440fac0 2018-09-06 stsp 	int status = 0;
167 a440fac0 2018-09-06 stsp 
168 a440fac0 2018-09-06 stsp 	setproctitle("read object header");
169 a440fac0 2018-09-06 stsp 	close(imsg_fds[0]);
170 a440fac0 2018-09-06 stsp 	imsg_init(&ibuf, imsg_fds[1]);
171 a440fac0 2018-09-06 stsp 
172 a440fac0 2018-09-06 stsp 	/* revoke access to most system calls */
173 a440fac0 2018-09-06 stsp 	if (pledge("stdio", NULL) == -1) {
174 a440fac0 2018-09-06 stsp 		err = got_error_from_errno();
175 a440fac0 2018-09-06 stsp 		goto done;
176 a440fac0 2018-09-06 stsp 	}
177 a440fac0 2018-09-06 stsp 
178 a440fac0 2018-09-06 stsp 	err = read_object_header(&obj, obj_fd);
179 a440fac0 2018-09-06 stsp 	if (err)
180 a440fac0 2018-09-06 stsp 		goto done;
181 a440fac0 2018-09-06 stsp 
182 a440fac0 2018-09-06 stsp 	err = got_privsep_send_obj(&ibuf, obj, 0);
183 a440fac0 2018-09-06 stsp done:
184 a440fac0 2018-09-06 stsp 	if (obj)
185 a440fac0 2018-09-06 stsp 		got_object_close(obj);
186 a440fac0 2018-09-06 stsp 	if (err) {
187 a440fac0 2018-09-06 stsp 		got_privsep_send_error(&ibuf, err);
188 a440fac0 2018-09-06 stsp 		status = 1;
189 a440fac0 2018-09-06 stsp 	}
190 a440fac0 2018-09-06 stsp 	close(obj_fd);
191 a440fac0 2018-09-06 stsp 	imsg_clear(&ibuf);
192 a440fac0 2018-09-06 stsp 	close(imsg_fds[1]);
193 a440fac0 2018-09-06 stsp 	_exit(status);
194 a440fac0 2018-09-06 stsp }
195 a440fac0 2018-09-06 stsp 
196 a440fac0 2018-09-06 stsp static const struct got_error *
197 a440fac0 2018-09-06 stsp wait_for_child(pid_t pid)
198 a440fac0 2018-09-06 stsp {
199 a440fac0 2018-09-06 stsp 	int child_status;
200 a440fac0 2018-09-06 stsp 
201 a440fac0 2018-09-06 stsp 	waitpid(pid, &child_status, 0);
202 a440fac0 2018-09-06 stsp 
203 a440fac0 2018-09-06 stsp 	if (!WIFEXITED(child_status))
204 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_PRIVSEP_DIED);
205 a440fac0 2018-09-06 stsp 
206 a440fac0 2018-09-06 stsp 	if (WEXITSTATUS(child_status) != 0)
207 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_PRIVSEP_EXIT);
208 a440fac0 2018-09-06 stsp 
209 a440fac0 2018-09-06 stsp 	return NULL;
210 a440fac0 2018-09-06 stsp }
211 a440fac0 2018-09-06 stsp 
212 a440fac0 2018-09-06 stsp const struct got_error *
213 a440fac0 2018-09-06 stsp got_object_read_header_privsep(struct got_object **obj, int fd)
214 a440fac0 2018-09-06 stsp {
215 a440fac0 2018-09-06 stsp 	struct imsgbuf parent_ibuf;
216 a440fac0 2018-09-06 stsp 	int imsg_fds[2];
217 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL, *err_child = NULL;
218 a440fac0 2018-09-06 stsp 	pid_t pid;
219 a440fac0 2018-09-06 stsp 
220 a440fac0 2018-09-06 stsp 	if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1)
221 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
222 a440fac0 2018-09-06 stsp 
223 a440fac0 2018-09-06 stsp 	pid = fork();
224 a440fac0 2018-09-06 stsp 	if (pid == -1)
225 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
226 a440fac0 2018-09-06 stsp 	else if (pid == 0) {
227 a440fac0 2018-09-06 stsp 		read_object_header_privsep_child(fd, imsg_fds);
228 a440fac0 2018-09-06 stsp 		/* not reached */
229 a440fac0 2018-09-06 stsp 	}
230 a440fac0 2018-09-06 stsp 
231 a440fac0 2018-09-06 stsp 	close(imsg_fds[1]);
232 a440fac0 2018-09-06 stsp 	imsg_init(&parent_ibuf, imsg_fds[0]);
233 a440fac0 2018-09-06 stsp 	err = got_privsep_recv_obj(obj, &parent_ibuf);
234 a440fac0 2018-09-06 stsp 	imsg_clear(&parent_ibuf);
235 a440fac0 2018-09-06 stsp 	err_child = wait_for_child(pid);
236 a440fac0 2018-09-06 stsp 	close(imsg_fds[0]);
237 a440fac0 2018-09-06 stsp 	return err ? err : err_child;
238 a440fac0 2018-09-06 stsp }
239 a440fac0 2018-09-06 stsp 
240 a440fac0 2018-09-06 stsp struct got_commit_object *
241 a440fac0 2018-09-06 stsp got_object_commit_alloc_partial(void)
242 a440fac0 2018-09-06 stsp {
243 a440fac0 2018-09-06 stsp 	struct got_commit_object *commit;
244 a440fac0 2018-09-06 stsp 
245 a440fac0 2018-09-06 stsp 	commit = calloc(1, sizeof(*commit));
246 a440fac0 2018-09-06 stsp 	if (commit == NULL)
247 a440fac0 2018-09-06 stsp 		return NULL;
248 a440fac0 2018-09-06 stsp 	commit->tree_id = calloc(1, sizeof(*commit->tree_id));
249 a440fac0 2018-09-06 stsp 	if (commit->tree_id == NULL) {
250 a440fac0 2018-09-06 stsp 		free(commit);
251 a440fac0 2018-09-06 stsp 		return NULL;
252 a440fac0 2018-09-06 stsp 	}
253 a440fac0 2018-09-06 stsp 
254 a440fac0 2018-09-06 stsp 	SIMPLEQ_INIT(&commit->parent_ids);
255 a440fac0 2018-09-06 stsp 
256 a440fac0 2018-09-06 stsp 	return commit;
257 a440fac0 2018-09-06 stsp }
258 a440fac0 2018-09-06 stsp 
259 a440fac0 2018-09-06 stsp const struct got_error *
260 a440fac0 2018-09-06 stsp got_object_commit_add_parent(struct got_commit_object *commit,
261 a440fac0 2018-09-06 stsp     const char *id_str)
262 a440fac0 2018-09-06 stsp {
263 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL;
264 a440fac0 2018-09-06 stsp 	struct got_object_qid *qid;
265 a440fac0 2018-09-06 stsp 
266 a440fac0 2018-09-06 stsp 	qid = malloc(sizeof(*qid));
267 a440fac0 2018-09-06 stsp 	if (qid == NULL)
268 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
269 a440fac0 2018-09-06 stsp 
270 a440fac0 2018-09-06 stsp 	qid->id = malloc(sizeof(*qid->id));
271 a440fac0 2018-09-06 stsp 	if (qid->id == NULL) {
272 a440fac0 2018-09-06 stsp 		err = got_error_from_errno();
273 a440fac0 2018-09-06 stsp 		got_object_qid_free(qid);
274 a440fac0 2018-09-06 stsp 		return err;
275 a440fac0 2018-09-06 stsp 	}
276 a440fac0 2018-09-06 stsp 
277 a440fac0 2018-09-06 stsp 	if (!got_parse_sha1_digest(qid->id->sha1, id_str)) {
278 a440fac0 2018-09-06 stsp 		err = got_error(GOT_ERR_BAD_OBJ_DATA);
279 a440fac0 2018-09-06 stsp 		free(qid->id);
280 a440fac0 2018-09-06 stsp 		free(qid);
281 a440fac0 2018-09-06 stsp 		return err;
282 a440fac0 2018-09-06 stsp 	}
283 a440fac0 2018-09-06 stsp 
284 a440fac0 2018-09-06 stsp 	SIMPLEQ_INSERT_TAIL(&commit->parent_ids, qid, entry);
285 a440fac0 2018-09-06 stsp 	commit->nparents++;
286 a440fac0 2018-09-06 stsp 
287 a440fac0 2018-09-06 stsp 	return NULL;
288 a440fac0 2018-09-06 stsp }
289 a440fac0 2018-09-06 stsp 
290 a440fac0 2018-09-06 stsp static const struct got_error *
291 a440fac0 2018-09-06 stsp parse_gmtoff(time_t *gmtoff, const char *tzstr)
292 a440fac0 2018-09-06 stsp {
293 a440fac0 2018-09-06 stsp 	int sign = 1;
294 a440fac0 2018-09-06 stsp 	const char *p = tzstr;
295 a440fac0 2018-09-06 stsp 	time_t h, m;
296 a440fac0 2018-09-06 stsp 
297 a440fac0 2018-09-06 stsp 	*gmtoff = 0;
298 a440fac0 2018-09-06 stsp 
299 a440fac0 2018-09-06 stsp 	if (*p == '-')
300 a440fac0 2018-09-06 stsp 		sign = -1;
301 a440fac0 2018-09-06 stsp 	else if (*p != '+')
302 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_DATA);
303 a440fac0 2018-09-06 stsp 	p++;
304 a440fac0 2018-09-06 stsp 	if (!isdigit(*p) && !isdigit(*(p + 1)))
305 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_DATA);
306 a440fac0 2018-09-06 stsp 	h = (((*p - '0') * 10) + (*(p + 1) - '0'));
307 a440fac0 2018-09-06 stsp 
308 a440fac0 2018-09-06 stsp 	p += 2;
309 a440fac0 2018-09-06 stsp 	if (!isdigit(*p) && !isdigit(*(p + 1)))
310 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_DATA);
311 a440fac0 2018-09-06 stsp 	m = ((*p - '0') * 10) + (*(p + 1) - '0');
312 a440fac0 2018-09-06 stsp 
313 a440fac0 2018-09-06 stsp 	*gmtoff = (h * 60 * 60 + m * 60) * sign;
314 a440fac0 2018-09-06 stsp 	return NULL;
315 a440fac0 2018-09-06 stsp }
316 a440fac0 2018-09-06 stsp 
317 a440fac0 2018-09-06 stsp static const struct got_error *
318 a440fac0 2018-09-06 stsp parse_commit_time(struct tm *tm, char *committer)
319 a440fac0 2018-09-06 stsp {
320 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL;
321 a440fac0 2018-09-06 stsp 	const char *errstr;
322 a440fac0 2018-09-06 stsp 	char *space, *tzstr;
323 a440fac0 2018-09-06 stsp 	time_t gmtoff;
324 a440fac0 2018-09-06 stsp 	time_t time;
325 a440fac0 2018-09-06 stsp 
326 a440fac0 2018-09-06 stsp 	/* Parse and strip off trailing timezone indicator string. */
327 a440fac0 2018-09-06 stsp 	space = strrchr(committer, ' ');
328 a440fac0 2018-09-06 stsp 	if (space == NULL)
329 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_DATA);
330 a440fac0 2018-09-06 stsp 	tzstr = strdup(space + 1);
331 a440fac0 2018-09-06 stsp 	if (tzstr == NULL)
332 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
333 a440fac0 2018-09-06 stsp 	err = parse_gmtoff(&gmtoff, tzstr);
334 a440fac0 2018-09-06 stsp 	free(tzstr);
335 a440fac0 2018-09-06 stsp 	if (err)
336 a440fac0 2018-09-06 stsp 		return err;
337 a440fac0 2018-09-06 stsp 	*space = '\0';
338 a440fac0 2018-09-06 stsp 
339 a440fac0 2018-09-06 stsp 	/* Timestamp is separated from committer name + email by space. */
340 a440fac0 2018-09-06 stsp 	space = strrchr(committer, ' ');
341 a440fac0 2018-09-06 stsp 	if (space == NULL)
342 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_DATA);
343 a440fac0 2018-09-06 stsp 
344 a440fac0 2018-09-06 stsp 	/* Timestamp parsed here is expressed in comitter's local time. */
345 a440fac0 2018-09-06 stsp 	time = strtonum(space + 1, 0, INT64_MAX, &errstr);
346 a440fac0 2018-09-06 stsp 	if (errstr)
347 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_DATA);
348 a440fac0 2018-09-06 stsp 
349 a440fac0 2018-09-06 stsp 	/* Express the time stamp in UTC. */
350 a440fac0 2018-09-06 stsp 	memset(tm, 0, sizeof(*tm));
351 a440fac0 2018-09-06 stsp 	time -= gmtoff;
352 a440fac0 2018-09-06 stsp 	if (localtime_r(&time, tm) == NULL)
353 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
354 a440fac0 2018-09-06 stsp 	tm->tm_gmtoff = gmtoff;
355 a440fac0 2018-09-06 stsp 
356 a440fac0 2018-09-06 stsp 	/* Strip off parsed time information, leaving just author and email. */
357 a440fac0 2018-09-06 stsp 	*space = '\0';
358 a440fac0 2018-09-06 stsp 
359 a440fac0 2018-09-06 stsp 	return NULL;
360 a440fac0 2018-09-06 stsp }
361 a440fac0 2018-09-06 stsp 
362 a440fac0 2018-09-06 stsp const struct got_error *
363 a440fac0 2018-09-06 stsp got_object_parse_commit(struct got_commit_object **commit, char *buf, size_t len)
364 a440fac0 2018-09-06 stsp {
365 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL;
366 a440fac0 2018-09-06 stsp 	char *s = buf;
367 a440fac0 2018-09-06 stsp 	size_t tlen;
368 a440fac0 2018-09-06 stsp 	ssize_t remain = (ssize_t)len;
369 a440fac0 2018-09-06 stsp  
370 a440fac0 2018-09-06 stsp 	*commit = got_object_commit_alloc_partial();
371 a440fac0 2018-09-06 stsp 	if (*commit == NULL)
372 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
373 a440fac0 2018-09-06 stsp 
374 a440fac0 2018-09-06 stsp 	tlen = strlen(GOT_COMMIT_TAG_TREE);
375 a440fac0 2018-09-06 stsp 	if (strncmp(s, GOT_COMMIT_TAG_TREE, tlen) == 0) {
376 a440fac0 2018-09-06 stsp 		remain -= tlen;
377 a440fac0 2018-09-06 stsp 		if (remain < SHA1_DIGEST_STRING_LENGTH) {
378 a440fac0 2018-09-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);
379 a440fac0 2018-09-06 stsp 			goto done;
380 a440fac0 2018-09-06 stsp 		}
381 a440fac0 2018-09-06 stsp 		s += tlen;
382 a440fac0 2018-09-06 stsp 		if (!got_parse_sha1_digest((*commit)->tree_id->sha1, s)) {
383 a440fac0 2018-09-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);
384 a440fac0 2018-09-06 stsp 			goto done;
385 a440fac0 2018-09-06 stsp 		}
386 a440fac0 2018-09-06 stsp 		remain -= SHA1_DIGEST_STRING_LENGTH;
387 a440fac0 2018-09-06 stsp 		s += SHA1_DIGEST_STRING_LENGTH;
388 a440fac0 2018-09-06 stsp 	} else {
389 a440fac0 2018-09-06 stsp 		err = got_error(GOT_ERR_BAD_OBJ_DATA);
390 a440fac0 2018-09-06 stsp 		goto done;
391 a440fac0 2018-09-06 stsp 	}
392 a440fac0 2018-09-06 stsp 
393 a440fac0 2018-09-06 stsp 	tlen = strlen(GOT_COMMIT_TAG_PARENT);
394 a440fac0 2018-09-06 stsp 	while (strncmp(s, GOT_COMMIT_TAG_PARENT, tlen) == 0) {
395 a440fac0 2018-09-06 stsp 		remain -= tlen;
396 a440fac0 2018-09-06 stsp 		if (remain < SHA1_DIGEST_STRING_LENGTH) {
397 a440fac0 2018-09-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);
398 a440fac0 2018-09-06 stsp 			goto done;
399 a440fac0 2018-09-06 stsp 		}
400 a440fac0 2018-09-06 stsp 		s += tlen;
401 a440fac0 2018-09-06 stsp 		err = got_object_commit_add_parent(*commit, s);
402 a440fac0 2018-09-06 stsp 		if (err)
403 a440fac0 2018-09-06 stsp 			goto done;
404 a440fac0 2018-09-06 stsp 
405 a440fac0 2018-09-06 stsp 		remain -= SHA1_DIGEST_STRING_LENGTH;
406 a440fac0 2018-09-06 stsp 		s += SHA1_DIGEST_STRING_LENGTH;
407 a440fac0 2018-09-06 stsp 	}
408 a440fac0 2018-09-06 stsp 
409 a440fac0 2018-09-06 stsp 	tlen = strlen(GOT_COMMIT_TAG_AUTHOR);
410 a440fac0 2018-09-06 stsp 	if (strncmp(s, GOT_COMMIT_TAG_AUTHOR, tlen) == 0) {
411 a440fac0 2018-09-06 stsp 		char *p;
412 a440fac0 2018-09-06 stsp 		size_t slen;
413 a440fac0 2018-09-06 stsp 
414 a440fac0 2018-09-06 stsp 		remain -= tlen;
415 a440fac0 2018-09-06 stsp 		if (remain <= 0) {
416 a440fac0 2018-09-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);
417 a440fac0 2018-09-06 stsp 			goto done;
418 a440fac0 2018-09-06 stsp 		}
419 a440fac0 2018-09-06 stsp 		s += tlen;
420 a440fac0 2018-09-06 stsp 		p = strchr(s, '\n');
421 a440fac0 2018-09-06 stsp 		if (p == NULL) {
422 a440fac0 2018-09-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);
423 a440fac0 2018-09-06 stsp 			goto done;
424 a440fac0 2018-09-06 stsp 		}
425 a440fac0 2018-09-06 stsp 		*p = '\0';
426 a440fac0 2018-09-06 stsp 		slen = strlen(s);
427 a440fac0 2018-09-06 stsp 		err = parse_commit_time(&(*commit)->tm_author, s);
428 a440fac0 2018-09-06 stsp 		if (err)
429 a440fac0 2018-09-06 stsp 			goto done;
430 a440fac0 2018-09-06 stsp 		(*commit)->author = strdup(s);
431 a440fac0 2018-09-06 stsp 		if ((*commit)->author == NULL) {
432 a440fac0 2018-09-06 stsp 			err = got_error_from_errno();
433 a440fac0 2018-09-06 stsp 			goto done;
434 a440fac0 2018-09-06 stsp 		}
435 a440fac0 2018-09-06 stsp 		s += slen + 1;
436 a440fac0 2018-09-06 stsp 		remain -= slen + 1;
437 a440fac0 2018-09-06 stsp 	}
438 a440fac0 2018-09-06 stsp 
439 a440fac0 2018-09-06 stsp 	tlen = strlen(GOT_COMMIT_TAG_COMMITTER);
440 a440fac0 2018-09-06 stsp 	if (strncmp(s, GOT_COMMIT_TAG_COMMITTER, tlen) == 0) {
441 a440fac0 2018-09-06 stsp 		char *p;
442 a440fac0 2018-09-06 stsp 		size_t slen;
443 a440fac0 2018-09-06 stsp 
444 a440fac0 2018-09-06 stsp 		remain -= tlen;
445 a440fac0 2018-09-06 stsp 		if (remain <= 0) {
446 a440fac0 2018-09-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);
447 a440fac0 2018-09-06 stsp 			goto done;
448 a440fac0 2018-09-06 stsp 		}
449 a440fac0 2018-09-06 stsp 		s += tlen;
450 a440fac0 2018-09-06 stsp 		p = strchr(s, '\n');
451 a440fac0 2018-09-06 stsp 		if (p == NULL) {
452 a440fac0 2018-09-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);
453 a440fac0 2018-09-06 stsp 			goto done;
454 a440fac0 2018-09-06 stsp 		}
455 a440fac0 2018-09-06 stsp 		*p = '\0';
456 a440fac0 2018-09-06 stsp 		slen = strlen(s);
457 a440fac0 2018-09-06 stsp 		err = parse_commit_time(&(*commit)->tm_committer, s);
458 a440fac0 2018-09-06 stsp 		if (err)
459 a440fac0 2018-09-06 stsp 			goto done;
460 a440fac0 2018-09-06 stsp 		(*commit)->committer = strdup(s);
461 a440fac0 2018-09-06 stsp 		if ((*commit)->committer == NULL) {
462 a440fac0 2018-09-06 stsp 			err = got_error_from_errno();
463 a440fac0 2018-09-06 stsp 			goto done;
464 a440fac0 2018-09-06 stsp 		}
465 a440fac0 2018-09-06 stsp 		s += slen + 1;
466 a440fac0 2018-09-06 stsp 		remain -= slen + 1;
467 a440fac0 2018-09-06 stsp 	}
468 a440fac0 2018-09-06 stsp 
469 a440fac0 2018-09-06 stsp 	(*commit)->logmsg = strndup(s, remain);
470 a440fac0 2018-09-06 stsp 	if ((*commit)->logmsg == NULL) {
471 a440fac0 2018-09-06 stsp 		err = got_error_from_errno();
472 a440fac0 2018-09-06 stsp 		goto done;
473 a440fac0 2018-09-06 stsp 	}
474 a440fac0 2018-09-06 stsp done:
475 a440fac0 2018-09-06 stsp 	if (err) {
476 a440fac0 2018-09-06 stsp 		got_object_commit_close(*commit);
477 a440fac0 2018-09-06 stsp 		*commit = NULL;
478 a440fac0 2018-09-06 stsp 	}
479 a440fac0 2018-09-06 stsp 	return err;
480 a440fac0 2018-09-06 stsp }
481 a440fac0 2018-09-06 stsp 
482 a440fac0 2018-09-06 stsp void
483 a440fac0 2018-09-06 stsp got_object_tree_entry_close(struct got_tree_entry *te)
484 a440fac0 2018-09-06 stsp {
485 a440fac0 2018-09-06 stsp 	free(te->id);
486 a440fac0 2018-09-06 stsp 	free(te->name);
487 a440fac0 2018-09-06 stsp 	free(te);
488 a440fac0 2018-09-06 stsp }
489 a440fac0 2018-09-06 stsp 
490 a440fac0 2018-09-06 stsp struct got_tree_entry *
491 a440fac0 2018-09-06 stsp got_alloc_tree_entry_partial(void)
492 a440fac0 2018-09-06 stsp {
493 a440fac0 2018-09-06 stsp 	struct got_tree_entry *te;
494 a440fac0 2018-09-06 stsp 
495 a440fac0 2018-09-06 stsp 	te = calloc(1, sizeof(*te));
496 a440fac0 2018-09-06 stsp 	if (te == NULL)
497 a440fac0 2018-09-06 stsp 		return NULL;
498 a440fac0 2018-09-06 stsp 
499 a440fac0 2018-09-06 stsp 	te->id = calloc(1, sizeof(*te->id));
500 a440fac0 2018-09-06 stsp 	if (te->id == NULL) {
501 a440fac0 2018-09-06 stsp 		free(te);
502 a440fac0 2018-09-06 stsp 		te = NULL;
503 a440fac0 2018-09-06 stsp 	}
504 a440fac0 2018-09-06 stsp 	return te;
505 a440fac0 2018-09-06 stsp }
506 a440fac0 2018-09-06 stsp 
507 a440fac0 2018-09-06 stsp static const struct got_error *
508 a440fac0 2018-09-06 stsp parse_tree_entry(struct got_tree_entry **te, size_t *elen, char *buf,
509 a440fac0 2018-09-06 stsp     size_t maxlen)
510 a440fac0 2018-09-06 stsp {
511 a440fac0 2018-09-06 stsp 	char *p = buf, *space;
512 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL;
513 a440fac0 2018-09-06 stsp 
514 a440fac0 2018-09-06 stsp 	*te = got_alloc_tree_entry_partial();
515 a440fac0 2018-09-06 stsp 	if (*te == NULL)
516 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
517 a440fac0 2018-09-06 stsp 
518 a440fac0 2018-09-06 stsp 	*elen = strlen(buf) + 1;
519 a440fac0 2018-09-06 stsp 	if (*elen > maxlen) {
520 a440fac0 2018-09-06 stsp 		free(*te);
521 a440fac0 2018-09-06 stsp 		*te = NULL;
522 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_DATA);
523 a440fac0 2018-09-06 stsp 	}
524 a440fac0 2018-09-06 stsp 
525 a440fac0 2018-09-06 stsp 	space = strchr(buf, ' ');
526 a440fac0 2018-09-06 stsp 	if (space == NULL) {
527 a440fac0 2018-09-06 stsp 		err = got_error(GOT_ERR_BAD_OBJ_DATA);
528 a440fac0 2018-09-06 stsp 		free(*te);
529 a440fac0 2018-09-06 stsp 		*te = NULL;
530 a440fac0 2018-09-06 stsp 		return err;
531 a440fac0 2018-09-06 stsp 	}
532 a440fac0 2018-09-06 stsp 	while (*p != ' ') {
533 a440fac0 2018-09-06 stsp 		if (*p < '0' && *p > '7') {
534 a440fac0 2018-09-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);
535 a440fac0 2018-09-06 stsp 			goto done;
536 a440fac0 2018-09-06 stsp 		}
537 a440fac0 2018-09-06 stsp 		(*te)->mode <<= 3;
538 a440fac0 2018-09-06 stsp 		(*te)->mode |= *p - '0';
539 a440fac0 2018-09-06 stsp 		p++;
540 a440fac0 2018-09-06 stsp 	}
541 a440fac0 2018-09-06 stsp 
542 a440fac0 2018-09-06 stsp 	(*te)->name = strdup(space + 1);
543 a440fac0 2018-09-06 stsp 	if (*elen > maxlen || maxlen - *elen < SHA1_DIGEST_LENGTH) {
544 a440fac0 2018-09-06 stsp 		err = got_error(GOT_ERR_BAD_OBJ_DATA);
545 a440fac0 2018-09-06 stsp 		goto done;
546 a440fac0 2018-09-06 stsp 	}
547 a440fac0 2018-09-06 stsp 	buf += strlen(buf) + 1;
548 a440fac0 2018-09-06 stsp 	memcpy((*te)->id->sha1, buf, SHA1_DIGEST_LENGTH);
549 a440fac0 2018-09-06 stsp 	*elen += SHA1_DIGEST_LENGTH;
550 a440fac0 2018-09-06 stsp done:
551 a440fac0 2018-09-06 stsp 	if (err) {
552 a440fac0 2018-09-06 stsp 		got_object_tree_entry_close(*te);
553 a440fac0 2018-09-06 stsp 		*te = NULL;
554 a440fac0 2018-09-06 stsp 	}
555 a440fac0 2018-09-06 stsp 	return err;
556 a440fac0 2018-09-06 stsp }
557 a440fac0 2018-09-06 stsp 
558 a440fac0 2018-09-06 stsp const struct got_error *
559 a440fac0 2018-09-06 stsp got_object_parse_tree(struct got_tree_object **tree, uint8_t *buf, size_t len)
560 a440fac0 2018-09-06 stsp {
561 a440fac0 2018-09-06 stsp 	const struct got_error *err;
562 a440fac0 2018-09-06 stsp 	size_t remain = len;
563 a440fac0 2018-09-06 stsp 
564 a440fac0 2018-09-06 stsp 	*tree = calloc(1, sizeof(**tree));
565 a440fac0 2018-09-06 stsp 	if (*tree == NULL)
566 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
567 a440fac0 2018-09-06 stsp 
568 a440fac0 2018-09-06 stsp 	SIMPLEQ_INIT(&(*tree)->entries.head);
569 a440fac0 2018-09-06 stsp 
570 a440fac0 2018-09-06 stsp 	while (remain > 0) {
571 a440fac0 2018-09-06 stsp 		struct got_tree_entry *te;
572 a440fac0 2018-09-06 stsp 		size_t elen;
573 a440fac0 2018-09-06 stsp 
574 a440fac0 2018-09-06 stsp 		err = parse_tree_entry(&te, &elen, buf, remain);
575 a440fac0 2018-09-06 stsp 		if (err)
576 a440fac0 2018-09-06 stsp 			return err;
577 a440fac0 2018-09-06 stsp 		(*tree)->entries.nentries++;
578 a440fac0 2018-09-06 stsp 		SIMPLEQ_INSERT_TAIL(&(*tree)->entries.head, te, entry);
579 a440fac0 2018-09-06 stsp 		buf += elen;
580 a440fac0 2018-09-06 stsp 		remain -= elen;
581 a440fac0 2018-09-06 stsp 	}
582 a440fac0 2018-09-06 stsp 
583 a440fac0 2018-09-06 stsp 	if (remain != 0) {
584 a440fac0 2018-09-06 stsp 		got_object_tree_close(*tree);
585 a440fac0 2018-09-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_DATA);
586 a440fac0 2018-09-06 stsp 	}
587 a440fac0 2018-09-06 stsp 
588 a440fac0 2018-09-06 stsp 	return NULL;
589 a440fac0 2018-09-06 stsp }
590 a440fac0 2018-09-06 stsp 
591 a440fac0 2018-09-06 stsp static const struct got_error *
592 a440fac0 2018-09-06 stsp read_to_mem(uint8_t **outbuf, size_t *outlen, FILE *f)
593 a440fac0 2018-09-06 stsp {
594 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL;
595 a440fac0 2018-09-06 stsp 	static const size_t blocksize = 512;
596 a440fac0 2018-09-06 stsp 	size_t n, total, remain;
597 a440fac0 2018-09-06 stsp 	uint8_t *buf;
598 a440fac0 2018-09-06 stsp 
599 a440fac0 2018-09-06 stsp 	*outbuf = NULL;
600 a440fac0 2018-09-06 stsp 	*outlen = 0;
601 a440fac0 2018-09-06 stsp 
602 a440fac0 2018-09-06 stsp 	buf = malloc(blocksize);
603 a440fac0 2018-09-06 stsp 	if (buf == NULL)
604 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
605 a440fac0 2018-09-06 stsp 
606 a440fac0 2018-09-06 stsp 	remain = blocksize;
607 a440fac0 2018-09-06 stsp 	total = 0;
608 a440fac0 2018-09-06 stsp 	while (1) {
609 a440fac0 2018-09-06 stsp 		if (remain == 0) {
610 a440fac0 2018-09-06 stsp 			uint8_t *newbuf;
611 a440fac0 2018-09-06 stsp 			newbuf = reallocarray(buf, 1, total + blocksize);
612 a440fac0 2018-09-06 stsp 			if (newbuf == NULL) {
613 a440fac0 2018-09-06 stsp 				err = got_error_from_errno();
614 a440fac0 2018-09-06 stsp 				goto done;
615 a440fac0 2018-09-06 stsp 			}
616 a440fac0 2018-09-06 stsp 			buf = newbuf;
617 a440fac0 2018-09-06 stsp 			remain += blocksize;
618 a440fac0 2018-09-06 stsp 		}
619 a440fac0 2018-09-06 stsp 		n = fread(buf + total, 1, remain, f);
620 a440fac0 2018-09-06 stsp 		if (n == 0) {
621 a440fac0 2018-09-06 stsp 			if (ferror(f)) {
622 a440fac0 2018-09-06 stsp 				err = got_ferror(f, GOT_ERR_IO);
623 a440fac0 2018-09-06 stsp 				goto done;
624 a440fac0 2018-09-06 stsp 			}
625 a440fac0 2018-09-06 stsp 			break; /* EOF */
626 a440fac0 2018-09-06 stsp 		}
627 a440fac0 2018-09-06 stsp 		remain -= n;
628 a440fac0 2018-09-06 stsp 		total += n;
629 a440fac0 2018-09-06 stsp 	};
630 a440fac0 2018-09-06 stsp 
631 a440fac0 2018-09-06 stsp done:
632 a440fac0 2018-09-06 stsp 	if (err == NULL) {
633 a440fac0 2018-09-06 stsp 		*outbuf = buf;
634 a440fac0 2018-09-06 stsp 		*outlen = total;
635 a440fac0 2018-09-06 stsp 	} else
636 a440fac0 2018-09-06 stsp 		free(buf);
637 a440fac0 2018-09-06 stsp 	return err;
638 a440fac0 2018-09-06 stsp }
639 a440fac0 2018-09-06 stsp 
640 a440fac0 2018-09-06 stsp static const struct got_error *
641 a440fac0 2018-09-06 stsp read_commit_object(struct got_commit_object **commit, struct got_object *obj,
642 a440fac0 2018-09-06 stsp     FILE *f)
643 a440fac0 2018-09-06 stsp {
644 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL;
645 a440fac0 2018-09-06 stsp 	size_t len;
646 a440fac0 2018-09-06 stsp 	uint8_t *p;
647 a440fac0 2018-09-06 stsp 
648 a440fac0 2018-09-06 stsp 	if (obj->flags & GOT_OBJ_FLAG_PACKED)
649 a440fac0 2018-09-06 stsp 		err = read_to_mem(&p, &len, f);
650 a440fac0 2018-09-06 stsp 	else
651 a440fac0 2018-09-06 stsp 		err = got_inflate_to_mem(&p, &len, f);
652 a440fac0 2018-09-06 stsp 	if (err)
653 a440fac0 2018-09-06 stsp 		return err;
654 a440fac0 2018-09-06 stsp 
655 a440fac0 2018-09-06 stsp 	if (len < obj->hdrlen + obj->size) {
656 a440fac0 2018-09-06 stsp 		err = got_error(GOT_ERR_BAD_OBJ_DATA);
657 a440fac0 2018-09-06 stsp 		goto done;
658 a440fac0 2018-09-06 stsp 	}
659 a440fac0 2018-09-06 stsp 
660 a440fac0 2018-09-06 stsp 	/* Skip object header. */
661 a440fac0 2018-09-06 stsp 	len -= obj->hdrlen;
662 a440fac0 2018-09-06 stsp 	err = got_object_parse_commit(commit, p + obj->hdrlen, len);
663 a440fac0 2018-09-06 stsp 	free(p);
664 a440fac0 2018-09-06 stsp done:
665 a440fac0 2018-09-06 stsp 	return err;
666 a440fac0 2018-09-06 stsp }
667 a440fac0 2018-09-06 stsp 
668 a440fac0 2018-09-06 stsp static void
669 a440fac0 2018-09-06 stsp read_commit_object_privsep_child(struct got_object *obj, int obj_fd,
670 a440fac0 2018-09-06 stsp     int imsg_fds[2])
671 a440fac0 2018-09-06 stsp {
672 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL;
673 a440fac0 2018-09-06 stsp 	struct got_commit_object *commit = NULL;
674 a440fac0 2018-09-06 stsp 	struct imsgbuf ibuf;
675 a440fac0 2018-09-06 stsp 	FILE *f = NULL;
676 a440fac0 2018-09-06 stsp 	int status = 0;
677 a440fac0 2018-09-06 stsp 
678 a440fac0 2018-09-06 stsp 	setproctitle("read commit object");
679 a440fac0 2018-09-06 stsp 	close(imsg_fds[0]);
680 a440fac0 2018-09-06 stsp 	imsg_init(&ibuf, imsg_fds[1]);
681 a440fac0 2018-09-06 stsp 
682 a440fac0 2018-09-06 stsp 	/* revoke access to most system calls */
683 a440fac0 2018-09-06 stsp 	if (pledge("stdio", NULL) == -1) {
684 a440fac0 2018-09-06 stsp 		err = got_error_from_errno();
685 a440fac0 2018-09-06 stsp 		goto done;
686 a440fac0 2018-09-06 stsp 	}
687 a440fac0 2018-09-06 stsp 
688 a440fac0 2018-09-06 stsp 	f = fdopen(obj_fd, "rb");
689 a440fac0 2018-09-06 stsp 	if (f == NULL) {
690 a440fac0 2018-09-06 stsp 		err = got_error_from_errno();
691 a440fac0 2018-09-06 stsp 		close(obj_fd);
692 a440fac0 2018-09-06 stsp 		goto done;
693 a440fac0 2018-09-06 stsp 	}
694 a440fac0 2018-09-06 stsp 
695 a440fac0 2018-09-06 stsp 	err = read_commit_object(&commit, obj, f);
696 a440fac0 2018-09-06 stsp 	if (err)
697 a440fac0 2018-09-06 stsp 		goto done;
698 a440fac0 2018-09-06 stsp 
699 a440fac0 2018-09-06 stsp 	err = got_privsep_send_commit(&ibuf, commit);
700 a440fac0 2018-09-06 stsp done:
701 a440fac0 2018-09-06 stsp 	if (commit)
702 a440fac0 2018-09-06 stsp 		got_object_commit_close(commit);
703 a440fac0 2018-09-06 stsp 	if (err) {
704 a440fac0 2018-09-06 stsp 		got_privsep_send_error(&ibuf, err);
705 a440fac0 2018-09-06 stsp 		status = 1;
706 a440fac0 2018-09-06 stsp 	}
707 a440fac0 2018-09-06 stsp 	if (f)
708 a440fac0 2018-09-06 stsp 		fclose(f);
709 a440fac0 2018-09-06 stsp 	imsg_clear(&ibuf);
710 a440fac0 2018-09-06 stsp 	close(imsg_fds[1]);
711 a440fac0 2018-09-06 stsp 	_exit(status);
712 a440fac0 2018-09-06 stsp }
713 a440fac0 2018-09-06 stsp 
714 a440fac0 2018-09-06 stsp const struct got_error *
715 a440fac0 2018-09-06 stsp got_object_read_commit_privsep(struct got_commit_object **commit,
716 a440fac0 2018-09-06 stsp     struct got_object *obj, int fd)
717 a440fac0 2018-09-06 stsp {
718 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL, *err_child = NULL;
719 a440fac0 2018-09-06 stsp 	struct imsgbuf parent_ibuf;
720 a440fac0 2018-09-06 stsp 	int imsg_fds[2];
721 a440fac0 2018-09-06 stsp 	pid_t pid;
722 a440fac0 2018-09-06 stsp 
723 a440fac0 2018-09-06 stsp 	if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1)
724 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
725 a440fac0 2018-09-06 stsp 
726 a440fac0 2018-09-06 stsp 	pid = fork();
727 a440fac0 2018-09-06 stsp 	if (pid == -1)
728 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
729 a440fac0 2018-09-06 stsp 	else if (pid == 0) {
730 a440fac0 2018-09-06 stsp 		read_commit_object_privsep_child(obj, fd, imsg_fds);
731 a440fac0 2018-09-06 stsp 		/* not reached */
732 a440fac0 2018-09-06 stsp 	}
733 a440fac0 2018-09-06 stsp 
734 a440fac0 2018-09-06 stsp 	close(imsg_fds[1]);
735 a440fac0 2018-09-06 stsp 	imsg_init(&parent_ibuf, imsg_fds[0]);
736 a440fac0 2018-09-06 stsp 	err = got_privsep_recv_commit(commit, &parent_ibuf);
737 a440fac0 2018-09-06 stsp 	imsg_clear(&parent_ibuf);
738 a440fac0 2018-09-06 stsp 	err_child = wait_for_child(pid);
739 a440fac0 2018-09-06 stsp 	close(imsg_fds[0]);
740 a440fac0 2018-09-06 stsp 	return err ? err : err_child;
741 a440fac0 2018-09-06 stsp }
742 a440fac0 2018-09-06 stsp 
743 a440fac0 2018-09-06 stsp static const struct got_error *
744 a440fac0 2018-09-06 stsp read_tree_object(struct got_tree_object **tree, struct got_object *obj, FILE *f)
745 a440fac0 2018-09-06 stsp {
746 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL;
747 a440fac0 2018-09-06 stsp 	size_t len;
748 a440fac0 2018-09-06 stsp 	uint8_t *p;
749 a440fac0 2018-09-06 stsp 
750 a440fac0 2018-09-06 stsp 	if (obj->flags & GOT_OBJ_FLAG_PACKED)
751 a440fac0 2018-09-06 stsp 		err = read_to_mem(&p, &len, f);
752 a440fac0 2018-09-06 stsp 	else
753 a440fac0 2018-09-06 stsp 		err = got_inflate_to_mem(&p, &len, f);
754 a440fac0 2018-09-06 stsp 	if (err)
755 a440fac0 2018-09-06 stsp 		return err;
756 a440fac0 2018-09-06 stsp 
757 a440fac0 2018-09-06 stsp 	if (len < obj->hdrlen + obj->size) {
758 a440fac0 2018-09-06 stsp 		err = got_error(GOT_ERR_BAD_OBJ_DATA);
759 a440fac0 2018-09-06 stsp 		goto done;
760 a440fac0 2018-09-06 stsp 	}
761 a440fac0 2018-09-06 stsp 
762 a440fac0 2018-09-06 stsp 	/* Skip object header. */
763 a440fac0 2018-09-06 stsp 	len -= obj->hdrlen;
764 a440fac0 2018-09-06 stsp 	err = got_object_parse_tree(tree, p + obj->hdrlen, len);
765 a440fac0 2018-09-06 stsp 	free(p);
766 a440fac0 2018-09-06 stsp done:
767 a440fac0 2018-09-06 stsp 	return err;
768 a440fac0 2018-09-06 stsp }
769 a440fac0 2018-09-06 stsp 
770 a440fac0 2018-09-06 stsp static void
771 a440fac0 2018-09-06 stsp read_tree_object_privsep_child(struct got_object *obj, int obj_fd,
772 a440fac0 2018-09-06 stsp     int imsg_fds[2])
773 a440fac0 2018-09-06 stsp {
774 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL;
775 a440fac0 2018-09-06 stsp 	struct got_tree_object *tree = NULL;
776 a440fac0 2018-09-06 stsp 	struct imsgbuf ibuf;
777 a440fac0 2018-09-06 stsp 	FILE *f = NULL;
778 a440fac0 2018-09-06 stsp 	int status = 0;
779 a440fac0 2018-09-06 stsp 
780 a440fac0 2018-09-06 stsp 	setproctitle("read tree object");
781 a440fac0 2018-09-06 stsp 	close(imsg_fds[0]);
782 a440fac0 2018-09-06 stsp 	imsg_init(&ibuf, imsg_fds[1]);
783 a440fac0 2018-09-06 stsp 
784 a440fac0 2018-09-06 stsp 	/* revoke access to most system calls */
785 a440fac0 2018-09-06 stsp 	if (pledge("stdio", NULL) == -1) {
786 a440fac0 2018-09-06 stsp 		err = got_error_from_errno();
787 a440fac0 2018-09-06 stsp 		goto done;
788 a440fac0 2018-09-06 stsp 	}
789 a440fac0 2018-09-06 stsp 
790 a440fac0 2018-09-06 stsp 	f = fdopen(obj_fd, "rb");
791 a440fac0 2018-09-06 stsp 	if (f == NULL) {
792 a440fac0 2018-09-06 stsp 		err = got_error_from_errno();
793 a440fac0 2018-09-06 stsp 		close(obj_fd);
794 a440fac0 2018-09-06 stsp 		goto done;
795 a440fac0 2018-09-06 stsp 	}
796 a440fac0 2018-09-06 stsp 
797 a440fac0 2018-09-06 stsp 	err = read_tree_object(&tree, obj, f);
798 a440fac0 2018-09-06 stsp 	if (err)
799 a440fac0 2018-09-06 stsp 		goto done;
800 a440fac0 2018-09-06 stsp 
801 a440fac0 2018-09-06 stsp 	err = got_privsep_send_tree(&ibuf, tree);
802 a440fac0 2018-09-06 stsp done:
803 a440fac0 2018-09-06 stsp 	if (tree)
804 a440fac0 2018-09-06 stsp 		got_object_tree_close(tree);
805 a440fac0 2018-09-06 stsp 	if (err) {
806 a440fac0 2018-09-06 stsp 		got_privsep_send_error(&ibuf, err);
807 a440fac0 2018-09-06 stsp 		status = 1;
808 a440fac0 2018-09-06 stsp 	}
809 a440fac0 2018-09-06 stsp 	if (f)
810 a440fac0 2018-09-06 stsp 		fclose(f);
811 a440fac0 2018-09-06 stsp 	imsg_clear(&ibuf);
812 a440fac0 2018-09-06 stsp 	close(imsg_fds[1]);
813 a440fac0 2018-09-06 stsp 	_exit(status);
814 a440fac0 2018-09-06 stsp }
815 a440fac0 2018-09-06 stsp 
816 a440fac0 2018-09-06 stsp const struct got_error *
817 a440fac0 2018-09-06 stsp got_object_read_tree_privsep(struct got_tree_object **tree,
818 a440fac0 2018-09-06 stsp     struct got_object *obj, int fd)
819 a440fac0 2018-09-06 stsp {
820 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL, *err_child = NULL;
821 a440fac0 2018-09-06 stsp 	struct imsgbuf parent_ibuf;
822 a440fac0 2018-09-06 stsp 	int imsg_fds[2];
823 a440fac0 2018-09-06 stsp 	pid_t pid;
824 a440fac0 2018-09-06 stsp 
825 a440fac0 2018-09-06 stsp 	if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1)
826 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
827 a440fac0 2018-09-06 stsp 
828 a440fac0 2018-09-06 stsp 	pid = fork();
829 a440fac0 2018-09-06 stsp 	if (pid == -1)
830 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
831 a440fac0 2018-09-06 stsp 	else if (pid == 0) {
832 a440fac0 2018-09-06 stsp 		read_tree_object_privsep_child(obj, fd, imsg_fds);
833 a440fac0 2018-09-06 stsp 		/* not reached */
834 a440fac0 2018-09-06 stsp 	}
835 a440fac0 2018-09-06 stsp 
836 a440fac0 2018-09-06 stsp 	close(imsg_fds[1]);
837 a440fac0 2018-09-06 stsp 	imsg_init(&parent_ibuf, imsg_fds[0]);
838 a440fac0 2018-09-06 stsp 	err = got_privsep_recv_tree(tree, &parent_ibuf);
839 a440fac0 2018-09-06 stsp 	imsg_clear(&parent_ibuf);
840 a440fac0 2018-09-06 stsp 	err_child = wait_for_child(pid);
841 a440fac0 2018-09-06 stsp 	close(imsg_fds[0]);
842 a440fac0 2018-09-06 stsp 	return err ? err : err_child;
843 a440fac0 2018-09-06 stsp }
844 a440fac0 2018-09-06 stsp 
845 a440fac0 2018-09-06 stsp static const struct got_error *
846 a440fac0 2018-09-06 stsp read_blob_object_privsep_child(int outfd, int infd, int imsg_fds[2])
847 a440fac0 2018-09-06 stsp {
848 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL;
849 a440fac0 2018-09-06 stsp 	struct imsgbuf ibuf;
850 a440fac0 2018-09-06 stsp 	int status = 0;
851 a440fac0 2018-09-06 stsp 	size_t size;
852 a440fac0 2018-09-06 stsp 	FILE *infile = NULL;
853 a440fac0 2018-09-06 stsp 
854 a440fac0 2018-09-06 stsp 	setproctitle("read blob object");
855 a440fac0 2018-09-06 stsp 	close(imsg_fds[0]);
856 a440fac0 2018-09-06 stsp 	imsg_init(&ibuf, imsg_fds[1]);
857 a440fac0 2018-09-06 stsp 
858 a440fac0 2018-09-06 stsp 	/* revoke access to most system calls */
859 a440fac0 2018-09-06 stsp 	if (pledge("stdio", NULL) == -1) {
860 a440fac0 2018-09-06 stsp 		err = got_error_from_errno();
861 a440fac0 2018-09-06 stsp 		goto done;
862 a440fac0 2018-09-06 stsp 	}
863 a440fac0 2018-09-06 stsp 
864 a440fac0 2018-09-06 stsp 	infile = fdopen(infd, "rb");
865 a440fac0 2018-09-06 stsp 	if (infile == NULL) {
866 a440fac0 2018-09-06 stsp 		err = got_error_from_errno();
867 a440fac0 2018-09-06 stsp 		close(infd);
868 a440fac0 2018-09-06 stsp 		goto done;
869 a440fac0 2018-09-06 stsp 	}
870 a440fac0 2018-09-06 stsp 	err = got_inflate_to_fd(&size, infile, outfd);
871 a440fac0 2018-09-06 stsp 	fclose(infile);
872 a440fac0 2018-09-06 stsp 	if (err)
873 a440fac0 2018-09-06 stsp 		goto done;
874 a440fac0 2018-09-06 stsp 
875 a440fac0 2018-09-06 stsp 	err = got_privsep_send_blob(&ibuf, size);
876 a440fac0 2018-09-06 stsp done:
877 a440fac0 2018-09-06 stsp 	if (err) {
878 a440fac0 2018-09-06 stsp 		got_privsep_send_error(&ibuf, err);
879 a440fac0 2018-09-06 stsp 		status = 1;
880 a440fac0 2018-09-06 stsp 	}
881 a440fac0 2018-09-06 stsp 	close(outfd);
882 a440fac0 2018-09-06 stsp 	imsg_clear(&ibuf);
883 a440fac0 2018-09-06 stsp 	close(imsg_fds[1]);
884 a440fac0 2018-09-06 stsp 	_exit(status);
885 a440fac0 2018-09-06 stsp }
886 a440fac0 2018-09-06 stsp 
887 a440fac0 2018-09-06 stsp const struct got_error *
888 a440fac0 2018-09-06 stsp got_object_read_blob_privsep(size_t *size, int outfd, int infd)
889 a440fac0 2018-09-06 stsp {
890 a440fac0 2018-09-06 stsp 	struct imsgbuf parent_ibuf;
891 a440fac0 2018-09-06 stsp 	int imsg_fds[2];
892 a440fac0 2018-09-06 stsp 	const struct got_error *err = NULL, *err_child = NULL;
893 a440fac0 2018-09-06 stsp 	pid_t pid;
894 a440fac0 2018-09-06 stsp 
895 a440fac0 2018-09-06 stsp 	if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1)
896 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
897 a440fac0 2018-09-06 stsp 
898 a440fac0 2018-09-06 stsp 	pid = fork();
899 a440fac0 2018-09-06 stsp 	if (pid == -1)
900 a440fac0 2018-09-06 stsp 		return got_error_from_errno();
901 a440fac0 2018-09-06 stsp 	else if (pid == 0) {
902 a440fac0 2018-09-06 stsp 		read_blob_object_privsep_child(outfd, infd, imsg_fds);
903 a440fac0 2018-09-06 stsp 		/* not reached */
904 a440fac0 2018-09-06 stsp 	}
905 a440fac0 2018-09-06 stsp 
906 a440fac0 2018-09-06 stsp 	close(imsg_fds[1]);
907 a440fac0 2018-09-06 stsp 	imsg_init(&parent_ibuf, imsg_fds[0]);
908 a440fac0 2018-09-06 stsp 	err = got_privsep_recv_blob(size, &parent_ibuf);
909 a440fac0 2018-09-06 stsp 	imsg_clear(&parent_ibuf);
910 a440fac0 2018-09-06 stsp 	err_child = wait_for_child(pid);
911 a440fac0 2018-09-06 stsp 	close(imsg_fds[0]);
912 a440fac0 2018-09-06 stsp 	if (lseek(outfd, SEEK_SET, 0) == -1)
913 a440fac0 2018-09-06 stsp 		err = got_error_from_errno();
914 a440fac0 2018-09-06 stsp 	return err ? err : err_child;
915 a440fac0 2018-09-06 stsp }