Blame

Date:
Message:
parse commit objects
Actions:
History | Blob | Raw File
  1 d71d75ad 2017-11-05 stsp /*

  2 d71d75ad 2017-11-05 stsp  * Copyright (c) 2017 Stefan Sperling <stsp@openbsd.org>

  3 d71d75ad 2017-11-05 stsp  *

  4 d71d75ad 2017-11-05 stsp  * Permission to use, copy, modify, and distribute this software for any

  5 d71d75ad 2017-11-05 stsp  * purpose with or without fee is hereby granted, provided that the above

  6 d71d75ad 2017-11-05 stsp  * copyright notice and this permission notice appear in all copies.

  7 d71d75ad 2017-11-05 stsp  *

  8 d71d75ad 2017-11-05 stsp  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES

  9 d71d75ad 2017-11-05 stsp  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF

 10 d71d75ad 2017-11-05 stsp  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR

 11 d71d75ad 2017-11-05 stsp  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES

 12 d71d75ad 2017-11-05 stsp  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN

 13 d71d75ad 2017-11-05 stsp  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF

 14 d71d75ad 2017-11-05 stsp  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.

 15 d71d75ad 2017-11-05 stsp  */

 16 d71d75ad 2017-11-05 stsp 

 17 d1cda826 2017-11-06 stsp #include <sys/queue.h>

 18 d1cda826 2017-11-06 stsp 

 19 d71d75ad 2017-11-05 stsp #include <stdio.h>

 20 ab9a70b2 2017-11-06 stsp #include <stdlib.h>

 21 ab9a70b2 2017-11-06 stsp #include <string.h>

 22 d71d75ad 2017-11-05 stsp #include <sha1.h>

 23 ab9a70b2 2017-11-06 stsp #include <zlib.h>

 24 ab9a70b2 2017-11-06 stsp #include <ctype.h>

 25 ab9a70b2 2017-11-06 stsp #include <limits.h>

 26 d71d75ad 2017-11-05 stsp 

 27 ab9a70b2 2017-11-06 stsp #include "got_error.h"

 28 d71d75ad 2017-11-05 stsp #include "got_object.h"

 29 ab9a70b2 2017-11-06 stsp #include "got_repository.h"

 30 d1cda826 2017-11-06 stsp #include "got_sha1.h"

 31 d71d75ad 2017-11-05 stsp 

 32 ab9a70b2 2017-11-06 stsp #ifndef MIN

 33 ab9a70b2 2017-11-06 stsp #define	MIN(_a,_b) ((_a) < (_b) ? (_a) : (_b))

 34 ab9a70b2 2017-11-06 stsp #endif

 35 ab9a70b2 2017-11-06 stsp 

 36 ab9a70b2 2017-11-06 stsp #ifndef nitems

 37 ab9a70b2 2017-11-06 stsp #define nitems(_a) (sizeof(_a) / sizeof((_a)[0]))

 38 ab9a70b2 2017-11-06 stsp #endif

 39 ab9a70b2 2017-11-06 stsp 

 40 ab9a70b2 2017-11-06 stsp #define GOT_OBJ_TAG_COMMIT	"commit"

 41 ab9a70b2 2017-11-06 stsp #define GOT_OBJ_TAG_TREE	"tree"

 42 ab9a70b2 2017-11-06 stsp #define GOT_OBJ_TAG_BLOB	"blob"

 43 ab9a70b2 2017-11-06 stsp 

 44 d1cda826 2017-11-06 stsp #define GOT_COMMIT_TAG_TREE		"tree "

 45 d1cda826 2017-11-06 stsp #define GOT_COMMIT_TAG_PARENT		"parent "

 46 d1cda826 2017-11-06 stsp #define GOT_COMMIT_TAG_AUTHOR		"author "

 47 d1cda826 2017-11-06 stsp #define GOT_COMMIT_TAG_COMMITTER	"committer "

 48 d1cda826 2017-11-06 stsp 

 49 d71d75ad 2017-11-05 stsp const char *

 50 d71d75ad 2017-11-05 stsp got_object_id_str(struct got_object_id *id, char *buf, size_t size)

 51 d71d75ad 2017-11-05 stsp {

 52 d71d75ad 2017-11-05 stsp 	char *p = buf;

 53 d71d75ad 2017-11-05 stsp 	char hex[3];

 54 d71d75ad 2017-11-05 stsp 	int i;

 55 d71d75ad 2017-11-05 stsp 

 56 d71d75ad 2017-11-05 stsp 	if (size < SHA1_DIGEST_STRING_LENGTH)

 57 d71d75ad 2017-11-05 stsp 		return NULL;

 58 d71d75ad 2017-11-05 stsp 

 59 d71d75ad 2017-11-05 stsp 	for (i = 0; i < SHA1_DIGEST_LENGTH; i++) {

 60 d71d75ad 2017-11-05 stsp 		snprintf(hex, sizeof(hex), "%.2x", id->sha1[i]);

 61 d71d75ad 2017-11-05 stsp 		p[0] = hex[0];

 62 d71d75ad 2017-11-05 stsp 		p[1] = hex[1];

 63 d71d75ad 2017-11-05 stsp 		p += 2;

 64 d71d75ad 2017-11-05 stsp 	}

 65 d71d75ad 2017-11-05 stsp 	p[0] = '\0';

 66 d71d75ad 2017-11-05 stsp 

 67 d71d75ad 2017-11-05 stsp 	return buf;

 68 d71d75ad 2017-11-05 stsp }

 69 ab9a70b2 2017-11-06 stsp 

 70 ab9a70b2 2017-11-06 stsp struct got_zstream_buf {

 71 ab9a70b2 2017-11-06 stsp 	z_stream z;

 72 ab9a70b2 2017-11-06 stsp 	char *inbuf;

 73 ab9a70b2 2017-11-06 stsp 	size_t inlen;

 74 ab9a70b2 2017-11-06 stsp 	char *outbuf;

 75 ab9a70b2 2017-11-06 stsp 	size_t outlen;

 76 ab9a70b2 2017-11-06 stsp 	int flags;

 77 ab9a70b2 2017-11-06 stsp #define GOT_ZSTREAM_F_HAVE_MORE 0x01

 78 ab9a70b2 2017-11-06 stsp };

 79 ab9a70b2 2017-11-06 stsp 

 80 ab9a70b2 2017-11-06 stsp static void

 81 ab9a70b2 2017-11-06 stsp inflate_end(struct got_zstream_buf *zb)

 82 ab9a70b2 2017-11-06 stsp {

 83 ab9a70b2 2017-11-06 stsp 	free(zb->inbuf);

 84 ab9a70b2 2017-11-06 stsp 	free(zb->outbuf);

 85 ab9a70b2 2017-11-06 stsp 	inflateEnd(&zb->z);

 86 ab9a70b2 2017-11-06 stsp }

 87 ab9a70b2 2017-11-06 stsp 

 88 ab9a70b2 2017-11-06 stsp static const struct got_error *

 89 ab9a70b2 2017-11-06 stsp inflate_init(struct got_zstream_buf *zb, size_t bufsize)

 90 ab9a70b2 2017-11-06 stsp {

 91 ab9a70b2 2017-11-06 stsp 	const struct got_error *err = NULL;

 92 ab9a70b2 2017-11-06 stsp 

 93 ab9a70b2 2017-11-06 stsp 	memset(zb, 0, sizeof(*zb));

 94 ab9a70b2 2017-11-06 stsp 

 95 ab9a70b2 2017-11-06 stsp 	zb->z.zalloc = Z_NULL;

 96 ab9a70b2 2017-11-06 stsp 	zb->z.zfree = Z_NULL;

 97 ab9a70b2 2017-11-06 stsp 	if (inflateInit(&zb->z) != Z_OK) {

 98 ab9a70b2 2017-11-06 stsp 		err = got_error(GOT_ERR_IO);

 99 ab9a70b2 2017-11-06 stsp 		goto done;

100 ab9a70b2 2017-11-06 stsp 	}

101 ab9a70b2 2017-11-06 stsp 

102 ab9a70b2 2017-11-06 stsp 	zb->inlen = zb->outlen = bufsize;

103 ab9a70b2 2017-11-06 stsp 

104 ab9a70b2 2017-11-06 stsp 	zb->inbuf = calloc(1, zb->inlen);

105 ab9a70b2 2017-11-06 stsp 	if (zb->inbuf == NULL) {

106 ab9a70b2 2017-11-06 stsp 		err = got_error(GOT_ERR_NO_MEM);

107 ab9a70b2 2017-11-06 stsp 		goto done;

108 ab9a70b2 2017-11-06 stsp 	}

109 ab9a70b2 2017-11-06 stsp 

110 ab9a70b2 2017-11-06 stsp 	zb->outbuf = calloc(1, zb->outlen);

111 ab9a70b2 2017-11-06 stsp 	if (zb->outbuf == NULL) {

112 ab9a70b2 2017-11-06 stsp 		err = got_error(GOT_ERR_NO_MEM);

113 ab9a70b2 2017-11-06 stsp 		goto done;

114 ab9a70b2 2017-11-06 stsp 	}

115 ab9a70b2 2017-11-06 stsp 

116 ab9a70b2 2017-11-06 stsp done:

117 ab9a70b2 2017-11-06 stsp 	if (err)

118 ab9a70b2 2017-11-06 stsp 		inflate_end(zb);

119 ab9a70b2 2017-11-06 stsp 	return err;

120 ab9a70b2 2017-11-06 stsp }

121 ab9a70b2 2017-11-06 stsp 

122 ab9a70b2 2017-11-06 stsp static const struct got_error *

123 ab9a70b2 2017-11-06 stsp inflate_read(struct got_zstream_buf *zb, FILE *f, size_t *outlenp)

124 ab9a70b2 2017-11-06 stsp {

125 ab9a70b2 2017-11-06 stsp 	size_t last_total_out = zb->z.total_out;

126 ab9a70b2 2017-11-06 stsp 	z_stream *z = &zb->z;

127 ab9a70b2 2017-11-06 stsp 	int n, ret;

128 ab9a70b2 2017-11-06 stsp 

129 ab9a70b2 2017-11-06 stsp 	z->next_out = zb->outbuf;

130 ab9a70b2 2017-11-06 stsp 	z->avail_out = zb->outlen;

131 ab9a70b2 2017-11-06 stsp 

132 ab9a70b2 2017-11-06 stsp 	if (z->avail_in == 0 && (zb->flags & GOT_ZSTREAM_F_HAVE_MORE) == 0) {

133 ab9a70b2 2017-11-06 stsp 		int i;

134 ab9a70b2 2017-11-06 stsp 		n = fread(zb->inbuf, 1, zb->inlen, f);

135 ab9a70b2 2017-11-06 stsp 		if (n == 0) {

136 ab9a70b2 2017-11-06 stsp 			if (ferror(f))

137 ab9a70b2 2017-11-06 stsp 				return got_error(GOT_ERR_IO);

138 ab9a70b2 2017-11-06 stsp 			*outlenp = 0;

139 ab9a70b2 2017-11-06 stsp 			return NULL;

140 ab9a70b2 2017-11-06 stsp 		}

141 ab9a70b2 2017-11-06 stsp 		z->next_in = zb->inbuf;

142 ab9a70b2 2017-11-06 stsp 		z->avail_in = n;

143 ab9a70b2 2017-11-06 stsp 	}

144 ab9a70b2 2017-11-06 stsp 

145 ab9a70b2 2017-11-06 stsp 	ret = inflate(z, Z_SYNC_FLUSH);

146 ab9a70b2 2017-11-06 stsp 	if (ret == Z_OK) {

147 ab9a70b2 2017-11-06 stsp 		if (z->avail_out == 0)

148 ab9a70b2 2017-11-06 stsp 			zb->flags |= GOT_ZSTREAM_F_HAVE_MORE;

149 ab9a70b2 2017-11-06 stsp 		else

150 ab9a70b2 2017-11-06 stsp 			zb->flags &= ~GOT_ZSTREAM_F_HAVE_MORE;

151 ab9a70b2 2017-11-06 stsp 	} else if (ret != Z_STREAM_END)

152 ab9a70b2 2017-11-06 stsp 		return got_error(GOT_ERR_DECOMPRESSION);

153 ab9a70b2 2017-11-06 stsp 

154 ab9a70b2 2017-11-06 stsp 	*outlenp = z->total_out - last_total_out;

155 ab9a70b2 2017-11-06 stsp 	return NULL;

156 ab9a70b2 2017-11-06 stsp }

157 ab9a70b2 2017-11-06 stsp 

158 ab9a70b2 2017-11-06 stsp static const struct got_error *

159 d1cda826 2017-11-06 stsp parse_object_header(struct got_object **obj, char *buf, size_t len)

160 ab9a70b2 2017-11-06 stsp {

161 ab9a70b2 2017-11-06 stsp 	const char *obj_tags[] = {

162 ab9a70b2 2017-11-06 stsp 		GOT_OBJ_TAG_COMMIT,

163 ab9a70b2 2017-11-06 stsp 		GOT_OBJ_TAG_TREE,

164 ab9a70b2 2017-11-06 stsp 		GOT_OBJ_TAG_BLOB

165 ab9a70b2 2017-11-06 stsp 	};

166 ab9a70b2 2017-11-06 stsp 	const int obj_types[] = {

167 ab9a70b2 2017-11-06 stsp 		GOT_OBJ_TYPE_COMMIT,

168 ab9a70b2 2017-11-06 stsp 		GOT_OBJ_TYPE_TREE,

169 ab9a70b2 2017-11-06 stsp 		GOT_OBJ_TYPE_BLOB,

170 ab9a70b2 2017-11-06 stsp 	};

171 ab9a70b2 2017-11-06 stsp 	int type = 0;

172 d1cda826 2017-11-06 stsp 	size_t size = 0, hdrlen = 0;

173 ab9a70b2 2017-11-06 stsp 	int i;

174 ab9a70b2 2017-11-06 stsp 	char *p = strchr(buf, '\0');

175 ab9a70b2 2017-11-06 stsp 

176 ab9a70b2 2017-11-06 stsp 	if (p == NULL)

177 ab9a70b2 2017-11-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_HDR);

178 ab9a70b2 2017-11-06 stsp 

179 d1cda826 2017-11-06 stsp 	hdrlen = strlen(buf) + 1 /* '\0' */;

180 d1cda826 2017-11-06 stsp 

181 ab9a70b2 2017-11-06 stsp 	for (i = 0; i < nitems(obj_tags); i++) {

182 ab9a70b2 2017-11-06 stsp 		const char *tag = obj_tags[i];

183 63323519 2017-11-06 stsp 		size_t tlen = strlen(tag);

184 ab9a70b2 2017-11-06 stsp 		const char *errstr;

185 ab9a70b2 2017-11-06 stsp 

186 63323519 2017-11-06 stsp 		if (strncmp(buf, tag, tlen) != 0)

187 ab9a70b2 2017-11-06 stsp 			continue;

188 ab9a70b2 2017-11-06 stsp 

189 ab9a70b2 2017-11-06 stsp 		type = obj_types[i];

190 63323519 2017-11-06 stsp 		if (len <= tlen)

191 ab9a70b2 2017-11-06 stsp 			return got_error(GOT_ERR_BAD_OBJ_HDR);

192 63323519 2017-11-06 stsp 		size = strtonum(buf + tlen, 0, LONG_MAX, &errstr);

193 ab9a70b2 2017-11-06 stsp 		if (errstr != NULL)

194 ab9a70b2 2017-11-06 stsp 			return got_error(GOT_ERR_BAD_OBJ_HDR);

195 ab9a70b2 2017-11-06 stsp 		break;

196 ab9a70b2 2017-11-06 stsp 	}

197 ab9a70b2 2017-11-06 stsp 

198 ab9a70b2 2017-11-06 stsp 	if (type == 0)

199 ab9a70b2 2017-11-06 stsp 		return got_error(GOT_ERR_BAD_OBJ_HDR);

200 ab9a70b2 2017-11-06 stsp 

201 ab9a70b2 2017-11-06 stsp 	*obj = calloc(1, sizeof(**obj));

202 ab9a70b2 2017-11-06 stsp 	(*obj)->type = type;

203 d1cda826 2017-11-06 stsp 	(*obj)->hdrlen = hdrlen;

204 ab9a70b2 2017-11-06 stsp 	(*obj)->size = size;

205 ab9a70b2 2017-11-06 stsp 	return NULL;

206 ab9a70b2 2017-11-06 stsp }

207 ab9a70b2 2017-11-06 stsp 

208 ab9a70b2 2017-11-06 stsp static const struct got_error *

209 ab9a70b2 2017-11-06 stsp read_object_header(struct got_object **obj, struct got_repository *repo,

210 ab9a70b2 2017-11-06 stsp     const char *path)

211 ab9a70b2 2017-11-06 stsp {

212 ab9a70b2 2017-11-06 stsp 	const struct got_error *err;

213 ab9a70b2 2017-11-06 stsp 	FILE *f;

214 ab9a70b2 2017-11-06 stsp 	struct got_zstream_buf zb;

215 ab9a70b2 2017-11-06 stsp 	size_t outlen;

216 ab9a70b2 2017-11-06 stsp 	int i, ret;

217 ab9a70b2 2017-11-06 stsp 

218 ab9a70b2 2017-11-06 stsp 	f = fopen(path, "rb");

219 ab9a70b2 2017-11-06 stsp 	if (f == NULL)

220 ab9a70b2 2017-11-06 stsp 		return got_error(GOT_ERR_BAD_PATH);

221 ab9a70b2 2017-11-06 stsp 

222 ab9a70b2 2017-11-06 stsp 	err = inflate_init(&zb, 64);

223 ab9a70b2 2017-11-06 stsp 	if (err) {

224 ab9a70b2 2017-11-06 stsp 		fclose(f);

225 ab9a70b2 2017-11-06 stsp 		return err;

226 ab9a70b2 2017-11-06 stsp 	}

227 ab9a70b2 2017-11-06 stsp 

228 ab9a70b2 2017-11-06 stsp 	err = inflate_read(&zb, f, &outlen);

229 ab9a70b2 2017-11-06 stsp 	if (err)

230 ab9a70b2 2017-11-06 stsp 		goto done;

231 ab9a70b2 2017-11-06 stsp 

232 d1cda826 2017-11-06 stsp 	err = parse_object_header(obj, zb.outbuf, outlen);

233 ab9a70b2 2017-11-06 stsp done:

234 ab9a70b2 2017-11-06 stsp 	inflate_end(&zb);

235 ab9a70b2 2017-11-06 stsp 	fclose(f);

236 ab9a70b2 2017-11-06 stsp 	return err;

237 ab9a70b2 2017-11-06 stsp }

238 ab9a70b2 2017-11-06 stsp 

239 d1cda826 2017-11-06 stsp static const struct got_error *

240 d1cda826 2017-11-06 stsp object_path(char **path, struct got_object_id *id,

241 d1cda826 2017-11-06 stsp     struct got_repository *repo)

242 ab9a70b2 2017-11-06 stsp {

243 ab9a70b2 2017-11-06 stsp 	const struct got_error *err = NULL;

244 ab9a70b2 2017-11-06 stsp 	char hex[SHA1_DIGEST_STRING_LENGTH];

245 d1cda826 2017-11-06 stsp 	char *path_objects = got_repo_get_path_objects(repo);

246 ab9a70b2 2017-11-06 stsp 

247 ab9a70b2 2017-11-06 stsp 	if (path_objects == NULL)

248 ab9a70b2 2017-11-06 stsp 		return got_error(GOT_ERR_NO_MEM);

249 ab9a70b2 2017-11-06 stsp 

250 ab9a70b2 2017-11-06 stsp 	got_object_id_str(id, hex, sizeof(hex));

251 ab9a70b2 2017-11-06 stsp 

252 d1cda826 2017-11-06 stsp 	if (asprintf(path, "%s/%.2x/%s", path_objects,

253 d1cda826 2017-11-06 stsp 	    id->sha1[0], hex + 2) == -1)

254 ab9a70b2 2017-11-06 stsp 		err = got_error(GOT_ERR_NO_MEM);

255 ab9a70b2 2017-11-06 stsp 

256 d1cda826 2017-11-06 stsp 	free(path_objects);

257 d1cda826 2017-11-06 stsp 	return err;

258 d1cda826 2017-11-06 stsp }

259 d1cda826 2017-11-06 stsp 

260 d1cda826 2017-11-06 stsp const struct got_error *

261 d1cda826 2017-11-06 stsp got_object_open(struct got_object **obj, struct got_repository *repo,

262 d1cda826 2017-11-06 stsp     struct got_object_id *id)

263 d1cda826 2017-11-06 stsp {

264 d1cda826 2017-11-06 stsp 	const struct got_error *err = NULL;

265 d1cda826 2017-11-06 stsp 	char *path = NULL;

266 d1cda826 2017-11-06 stsp 

267 d1cda826 2017-11-06 stsp 	err = object_path(&path, id, repo);

268 d1cda826 2017-11-06 stsp 	if (err)

269 d1cda826 2017-11-06 stsp 		return err;

270 d1cda826 2017-11-06 stsp 

271 ab9a70b2 2017-11-06 stsp 	err = read_object_header(obj, repo, path);

272 ab9a70b2 2017-11-06 stsp 	if (err == NULL)

273 ab9a70b2 2017-11-06 stsp 		memcpy((*obj)->id.sha1, id->sha1, SHA1_DIGEST_LENGTH);

274 ab9a70b2 2017-11-06 stsp done:

275 ab9a70b2 2017-11-06 stsp 	free(path);

276 ab9a70b2 2017-11-06 stsp 	return err;

277 ab9a70b2 2017-11-06 stsp }

278 ab9a70b2 2017-11-06 stsp 

279 ab9a70b2 2017-11-06 stsp void

280 ab9a70b2 2017-11-06 stsp got_object_close(struct got_object *obj)

281 ab9a70b2 2017-11-06 stsp {

282 ab9a70b2 2017-11-06 stsp 	free(obj);

283 d1cda826 2017-11-06 stsp }

284 d1cda826 2017-11-06 stsp 

285 d1cda826 2017-11-06 stsp static int

286 d1cda826 2017-11-06 stsp commit_object_valid(struct got_commit_object *commit)

287 d1cda826 2017-11-06 stsp {

288 d1cda826 2017-11-06 stsp 	int i;

289 d1cda826 2017-11-06 stsp 	int n;

290 d1cda826 2017-11-06 stsp 

291 d1cda826 2017-11-06 stsp 	if (commit == NULL)

292 d1cda826 2017-11-06 stsp 		return 0;

293 d1cda826 2017-11-06 stsp 

294 d1cda826 2017-11-06 stsp 	n = 0;

295 d1cda826 2017-11-06 stsp 	for (i = 0; i < SHA1_DIGEST_LENGTH; i++) {

296 d1cda826 2017-11-06 stsp 		if (commit->tree_id.sha1[i] == 0)

297 d1cda826 2017-11-06 stsp 			n++;

298 d1cda826 2017-11-06 stsp 	}

299 d1cda826 2017-11-06 stsp 	if (n == SHA1_DIGEST_LENGTH)

300 d1cda826 2017-11-06 stsp 		return 0;

301 d1cda826 2017-11-06 stsp 

302 d1cda826 2017-11-06 stsp 	return 1;

303 ab9a70b2 2017-11-06 stsp }

304 d1cda826 2017-11-06 stsp 

305 d1cda826 2017-11-06 stsp static const struct got_error *

306 d1cda826 2017-11-06 stsp parse_commit_object(struct got_commit_object **commit, char *buf, size_t len)

307 d1cda826 2017-11-06 stsp {

308 d1cda826 2017-11-06 stsp 	const struct got_error *err = NULL;

309 d1cda826 2017-11-06 stsp 	char *s = buf;

310 d1cda826 2017-11-06 stsp 	size_t tlen;

311 d1cda826 2017-11-06 stsp 	ssize_t remain = (ssize_t)len;

312 d1cda826 2017-11-06 stsp  

313 d1cda826 2017-11-06 stsp 	*commit = calloc(1, sizeof(**commit));

314 d1cda826 2017-11-06 stsp 	if (*commit == NULL)

315 d1cda826 2017-11-06 stsp 		return got_error(GOT_ERR_NO_MEM);

316 d1cda826 2017-11-06 stsp 

317 d1cda826 2017-11-06 stsp 	SIMPLEQ_INIT(&(*commit)->parent_ids);

318 d1cda826 2017-11-06 stsp 

319 d1cda826 2017-11-06 stsp 	tlen = strlen(GOT_COMMIT_TAG_TREE);

320 d1cda826 2017-11-06 stsp 	if (strncmp(s, GOT_COMMIT_TAG_TREE, tlen) == 0) {

321 d1cda826 2017-11-06 stsp 		remain -= tlen;

322 d1cda826 2017-11-06 stsp 		if (remain < SHA1_DIGEST_STRING_LENGTH) {

323 d1cda826 2017-11-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);

324 d1cda826 2017-11-06 stsp 			goto done;

325 d1cda826 2017-11-06 stsp 		}

326 d1cda826 2017-11-06 stsp 		s += tlen;

327 d1cda826 2017-11-06 stsp 		if (!got_parse_sha1_digest((*commit)->tree_id.sha1, s)) {

328 d1cda826 2017-11-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);

329 d1cda826 2017-11-06 stsp 			goto done;

330 d1cda826 2017-11-06 stsp 		}

331 d1cda826 2017-11-06 stsp 		remain -= SHA1_DIGEST_STRING_LENGTH;

332 d1cda826 2017-11-06 stsp 		s += SHA1_DIGEST_STRING_LENGTH;

333 d1cda826 2017-11-06 stsp 	} else {

334 d1cda826 2017-11-06 stsp 		err = got_error(GOT_ERR_BAD_OBJ_DATA);

335 d1cda826 2017-11-06 stsp 		goto done;

336 d1cda826 2017-11-06 stsp 	}

337 d1cda826 2017-11-06 stsp 

338 d1cda826 2017-11-06 stsp 	tlen = strlen(GOT_COMMIT_TAG_PARENT);

339 d1cda826 2017-11-06 stsp 	while (strncmp(s, GOT_COMMIT_TAG_PARENT, tlen) == 0) {

340 d1cda826 2017-11-06 stsp 		struct got_parent_id *pid;

341 d1cda826 2017-11-06 stsp 

342 d1cda826 2017-11-06 stsp 		remain -= tlen;

343 d1cda826 2017-11-06 stsp 		if (remain < SHA1_DIGEST_STRING_LENGTH) {

344 d1cda826 2017-11-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);

345 d1cda826 2017-11-06 stsp 			goto done;

346 d1cda826 2017-11-06 stsp 		}	

347 d1cda826 2017-11-06 stsp 

348 d1cda826 2017-11-06 stsp 		pid = calloc(1, sizeof(*pid));

349 d1cda826 2017-11-06 stsp 		if (pid == NULL) {

350 d1cda826 2017-11-06 stsp 			err = got_error(GOT_ERR_NO_MEM);

351 d1cda826 2017-11-06 stsp 			goto done;

352 d1cda826 2017-11-06 stsp 		}

353 d1cda826 2017-11-06 stsp 		s += tlen;

354 d1cda826 2017-11-06 stsp 		if (!got_parse_sha1_digest(pid->id.sha1, s)) {

355 d1cda826 2017-11-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);

356 d1cda826 2017-11-06 stsp 			goto done;

357 d1cda826 2017-11-06 stsp 		}

358 d1cda826 2017-11-06 stsp 		SIMPLEQ_INSERT_TAIL(&(*commit)->parent_ids, pid, entry);

359 d1cda826 2017-11-06 stsp 		(*commit)->nparents++;

360 d1cda826 2017-11-06 stsp 

361 d1cda826 2017-11-06 stsp 		s += SHA1_DIGEST_STRING_LENGTH;

362 d1cda826 2017-11-06 stsp 	}

363 d1cda826 2017-11-06 stsp 

364 d1cda826 2017-11-06 stsp 	tlen = strlen(GOT_COMMIT_TAG_AUTHOR);

365 d1cda826 2017-11-06 stsp 	if (strncmp(s, GOT_COMMIT_TAG_AUTHOR, tlen) == 0) {

366 d1cda826 2017-11-06 stsp 		char *p;

367 d1cda826 2017-11-06 stsp 

368 d1cda826 2017-11-06 stsp 		remain -= tlen;

369 d1cda826 2017-11-06 stsp 		if (remain <= 0) {

370 d1cda826 2017-11-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);

371 d1cda826 2017-11-06 stsp 			goto done;

372 d1cda826 2017-11-06 stsp 		}

373 d1cda826 2017-11-06 stsp 		s += tlen;

374 d1cda826 2017-11-06 stsp 		p = strchr(s, '\n');

375 d1cda826 2017-11-06 stsp 		if (p == NULL) {

376 d1cda826 2017-11-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);

377 d1cda826 2017-11-06 stsp 			goto done;

378 d1cda826 2017-11-06 stsp 		}

379 d1cda826 2017-11-06 stsp 		*p = '\0';

380 d1cda826 2017-11-06 stsp 		(*commit)->author = strdup(s);

381 d1cda826 2017-11-06 stsp 		if ((*commit)->author == NULL) {

382 d1cda826 2017-11-06 stsp 			err = got_error(GOT_ERR_NO_MEM);

383 d1cda826 2017-11-06 stsp 			goto done;

384 d1cda826 2017-11-06 stsp 		}

385 d1cda826 2017-11-06 stsp 		s += strlen((*commit)->author) + 1;

386 d1cda826 2017-11-06 stsp 	}

387 d1cda826 2017-11-06 stsp 

388 d1cda826 2017-11-06 stsp 	tlen = strlen(GOT_COMMIT_TAG_COMMITTER);

389 d1cda826 2017-11-06 stsp 	if (strncmp(s, GOT_COMMIT_TAG_COMMITTER, tlen) == 0) {

390 d1cda826 2017-11-06 stsp 		char *p;

391 d1cda826 2017-11-06 stsp 

392 d1cda826 2017-11-06 stsp 		remain -= tlen;

393 d1cda826 2017-11-06 stsp 		if (remain <= 0) {

394 d1cda826 2017-11-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);

395 d1cda826 2017-11-06 stsp 			goto done;

396 d1cda826 2017-11-06 stsp 		}

397 d1cda826 2017-11-06 stsp 		s += tlen;

398 d1cda826 2017-11-06 stsp 		p = strchr(s, '\n');

399 d1cda826 2017-11-06 stsp 		if (p == NULL) {

400 d1cda826 2017-11-06 stsp 			err = got_error(GOT_ERR_BAD_OBJ_DATA);

401 d1cda826 2017-11-06 stsp 			goto done;

402 d1cda826 2017-11-06 stsp 		}

403 d1cda826 2017-11-06 stsp 		*p = '\0';

404 d1cda826 2017-11-06 stsp 		(*commit)->committer = strdup(s);

405 d1cda826 2017-11-06 stsp 		if ((*commit)->committer == NULL) {

406 d1cda826 2017-11-06 stsp 			err = got_error(GOT_ERR_NO_MEM);

407 d1cda826 2017-11-06 stsp 			goto done;

408 d1cda826 2017-11-06 stsp 		}

409 d1cda826 2017-11-06 stsp 		s += strlen((*commit)->committer) + 1;

410 d1cda826 2017-11-06 stsp 	}

411 d1cda826 2017-11-06 stsp 

412 d1cda826 2017-11-06 stsp 	(*commit)->logmsg = strdup(s);

413 d1cda826 2017-11-06 stsp done:

414 d1cda826 2017-11-06 stsp 	if (err)

415 d1cda826 2017-11-06 stsp 		got_object_commit_close(*commit);

416 d1cda826 2017-11-06 stsp 	return err;

417 d1cda826 2017-11-06 stsp }

418 d1cda826 2017-11-06 stsp 

419 d1cda826 2017-11-06 stsp static const struct got_error *

420 d1cda826 2017-11-06 stsp read_commit_object(struct got_commit_object **commit,

421 d1cda826 2017-11-06 stsp     struct got_repository *repo, struct got_object *obj, const char *path)

422 d1cda826 2017-11-06 stsp {

423 d1cda826 2017-11-06 stsp 	const struct got_error *err = NULL;

424 d1cda826 2017-11-06 stsp 	FILE *f;

425 d1cda826 2017-11-06 stsp 	struct got_zstream_buf zb;

426 d1cda826 2017-11-06 stsp 	size_t len;

427 d1cda826 2017-11-06 stsp 	char *p;

428 d1cda826 2017-11-06 stsp 	int i, ret;

429 d1cda826 2017-11-06 stsp 

430 d1cda826 2017-11-06 stsp 	f = fopen(path, "rb");

431 d1cda826 2017-11-06 stsp 	if (f == NULL)

432 d1cda826 2017-11-06 stsp 		return got_error(GOT_ERR_BAD_PATH);

433 d1cda826 2017-11-06 stsp 

434 d1cda826 2017-11-06 stsp 	err = inflate_init(&zb, 8192);

435 d1cda826 2017-11-06 stsp 	if (err) {

436 d1cda826 2017-11-06 stsp 		fclose(f);

437 d1cda826 2017-11-06 stsp 		return err;

438 d1cda826 2017-11-06 stsp 	}

439 d1cda826 2017-11-06 stsp 

440 d1cda826 2017-11-06 stsp 	do {

441 d1cda826 2017-11-06 stsp 		err = inflate_read(&zb, f, &len);

442 d1cda826 2017-11-06 stsp 		if (err || len == 0)

443 d1cda826 2017-11-06 stsp 			break;

444 d1cda826 2017-11-06 stsp 	} while (len < obj->hdrlen + obj->size);

445 d1cda826 2017-11-06 stsp 

446 d1cda826 2017-11-06 stsp 	if (len < obj->hdrlen + obj->size) {

447 d1cda826 2017-11-06 stsp 		err = got_error(GOT_ERR_BAD_OBJ_DATA);

448 d1cda826 2017-11-06 stsp 		goto done;

449 d1cda826 2017-11-06 stsp 	}

450 d1cda826 2017-11-06 stsp 

451 d1cda826 2017-11-06 stsp 	/* Skip object header. */

452 d1cda826 2017-11-06 stsp 	len -= obj->hdrlen;

453 d1cda826 2017-11-06 stsp 	err = parse_commit_object(commit, zb.outbuf + obj->hdrlen, len);

454 d1cda826 2017-11-06 stsp done:

455 d1cda826 2017-11-06 stsp 	inflate_end(&zb);

456 d1cda826 2017-11-06 stsp 	fclose(f);

457 d1cda826 2017-11-06 stsp 	return err;

458 d1cda826 2017-11-06 stsp }

459 d1cda826 2017-11-06 stsp 

460 d1cda826 2017-11-06 stsp const struct got_error *

461 d1cda826 2017-11-06 stsp got_object_commit_open(struct got_commit_object **commit,

462 d1cda826 2017-11-06 stsp     struct got_repository *repo, struct got_object *obj)

463 d1cda826 2017-11-06 stsp {

464 d1cda826 2017-11-06 stsp 	const struct got_error *err = NULL;

465 d1cda826 2017-11-06 stsp 	char *path = NULL;

466 d1cda826 2017-11-06 stsp 

467 d1cda826 2017-11-06 stsp 	if (obj->type != GOT_OBJ_TYPE_COMMIT)

468 d1cda826 2017-11-06 stsp 		return got_error(GOT_ERR_OBJ_TYPE);

469 d1cda826 2017-11-06 stsp 

470 d1cda826 2017-11-06 stsp 	err = object_path(&path, &obj->id, repo);

471 d1cda826 2017-11-06 stsp 	if (err)

472 d1cda826 2017-11-06 stsp 		return err;

473 d1cda826 2017-11-06 stsp 

474 d1cda826 2017-11-06 stsp 	err = read_commit_object(commit, repo, obj, path);

475 d1cda826 2017-11-06 stsp 	free(path);

476 d1cda826 2017-11-06 stsp 	return err;

477 d1cda826 2017-11-06 stsp }

478 d1cda826 2017-11-06 stsp 

479 d1cda826 2017-11-06 stsp void

480 d1cda826 2017-11-06 stsp got_object_commit_close(struct got_commit_object *commit)

481 d1cda826 2017-11-06 stsp {

482 d1cda826 2017-11-06 stsp 	struct got_parent_id *pid;

483 d1cda826 2017-11-06 stsp 

484 d1cda826 2017-11-06 stsp 	while (!SIMPLEQ_EMPTY(&commit->parent_ids)) {

485 d1cda826 2017-11-06 stsp 		pid = SIMPLEQ_FIRST(&commit->parent_ids);

486 d1cda826 2017-11-06 stsp 		SIMPLEQ_REMOVE_HEAD(&commit->parent_ids, entry);

487 d1cda826 2017-11-06 stsp 		free(pid);

488 d1cda826 2017-11-06 stsp 	}

489 d1cda826 2017-11-06 stsp 

490 d1cda826 2017-11-06 stsp 	free(commit->author);

491 d1cda826 2017-11-06 stsp 	free(commit->committer);

492 d1cda826 2017-11-06 stsp 	free(commit->logmsg);

493 d1cda826 2017-11-06 stsp 	free(commit);

494 d1cda826 2017-11-06 stsp }