|
diff --git a/shared.c b/shared.c index 06f70bb..9f7d6a5 100644 --- a/ shared.c+++ b/ shared.c |
|
@@ -307,128 +307,199 @@ void cgit_diff_tree(const unsigned char *old_sha1, |
307 | const unsigned char *new_sha1, |
307 | const unsigned char *new_sha1, |
308 | filepair_fn fn, const char *prefix) |
308 | filepair_fn fn, const char *prefix) |
309 | { |
309 | { |
310 | struct diff_options opt; |
310 | struct diff_options opt; |
311 | int ret; |
311 | int ret; |
312 | int prefixlen; |
312 | int prefixlen; |
313 | |
313 | |
314 | diff_setup(&opt); |
314 | diff_setup(&opt); |
315 | opt.output_format = DIFF_FORMAT_CALLBACK; |
315 | opt.output_format = DIFF_FORMAT_CALLBACK; |
316 | opt.detect_rename = 1; |
316 | opt.detect_rename = 1; |
317 | opt.rename_limit = ctx.cfg.renamelimit; |
317 | opt.rename_limit = ctx.cfg.renamelimit; |
318 | DIFF_OPT_SET(&opt, RECURSIVE); |
318 | DIFF_OPT_SET(&opt, RECURSIVE); |
319 | opt.format_callback = cgit_diff_tree_cb; |
319 | opt.format_callback = cgit_diff_tree_cb; |
320 | opt.format_callback_data = fn; |
320 | opt.format_callback_data = fn; |
321 | if (prefix) { |
321 | if (prefix) { |
322 | opt.nr_paths = 1; |
322 | opt.nr_paths = 1; |
323 | opt.paths = &prefix; |
323 | opt.paths = &prefix; |
324 | prefixlen = strlen(prefix); |
324 | prefixlen = strlen(prefix); |
325 | opt.pathlens = &prefixlen; |
325 | opt.pathlens = &prefixlen; |
326 | } |
326 | } |
327 | diff_setup_done(&opt); |
327 | diff_setup_done(&opt); |
328 | |
328 | |
329 | if (old_sha1 && !is_null_sha1(old_sha1)) |
329 | if (old_sha1 && !is_null_sha1(old_sha1)) |
330 | ret = diff_tree_sha1(old_sha1, new_sha1, "", &opt); |
330 | ret = diff_tree_sha1(old_sha1, new_sha1, "", &opt); |
331 | else |
331 | else |
332 | ret = diff_root_tree_sha1(new_sha1, "", &opt); |
332 | ret = diff_root_tree_sha1(new_sha1, "", &opt); |
333 | diffcore_std(&opt); |
333 | diffcore_std(&opt); |
334 | diff_flush(&opt); |
334 | diff_flush(&opt); |
335 | } |
335 | } |
336 | |
336 | |
337 | void cgit_diff_commit(struct commit *commit, filepair_fn fn) |
337 | void cgit_diff_commit(struct commit *commit, filepair_fn fn) |
338 | { |
338 | { |
339 | unsigned char *old_sha1 = NULL; |
339 | unsigned char *old_sha1 = NULL; |
340 | |
340 | |
341 | if (commit->parents) |
341 | if (commit->parents) |
342 | old_sha1 = commit->parents->item->object.sha1; |
342 | old_sha1 = commit->parents->item->object.sha1; |
343 | cgit_diff_tree(old_sha1, commit->object.sha1, fn, NULL); |
343 | cgit_diff_tree(old_sha1, commit->object.sha1, fn, NULL); |
344 | } |
344 | } |
345 | |
345 | |
346 | int cgit_parse_snapshots_mask(const char *str) |
346 | int cgit_parse_snapshots_mask(const char *str) |
347 | { |
347 | { |
348 | const struct cgit_snapshot_format *f; |
348 | const struct cgit_snapshot_format *f; |
349 | static const char *delim = " \t,:/|;"; |
349 | static const char *delim = " \t,:/|;"; |
350 | int tl, sl, rv = 0; |
350 | int tl, sl, rv = 0; |
351 | |
351 | |
352 | /* favor legacy setting */ |
352 | /* favor legacy setting */ |
353 | if(atoi(str)) |
353 | if(atoi(str)) |
354 | return 1; |
354 | return 1; |
355 | for(;;) { |
355 | for(;;) { |
356 | str += strspn(str,delim); |
356 | str += strspn(str,delim); |
357 | tl = strcspn(str,delim); |
357 | tl = strcspn(str,delim); |
358 | if (!tl) |
358 | if (!tl) |
359 | break; |
359 | break; |
360 | for (f = cgit_snapshot_formats; f->suffix; f++) { |
360 | for (f = cgit_snapshot_formats; f->suffix; f++) { |
361 | sl = strlen(f->suffix); |
361 | sl = strlen(f->suffix); |
362 | if((tl == sl && !strncmp(f->suffix, str, tl)) || |
362 | if((tl == sl && !strncmp(f->suffix, str, tl)) || |
363 | (tl == sl-1 && !strncmp(f->suffix+1, str, tl-1))) { |
363 | (tl == sl-1 && !strncmp(f->suffix+1, str, tl-1))) { |
364 | rv |= f->bit; |
364 | rv |= f->bit; |
365 | break; |
365 | break; |
366 | } |
366 | } |
367 | } |
367 | } |
368 | str += tl; |
368 | str += tl; |
369 | } |
369 | } |
370 | return rv; |
370 | return rv; |
371 | } |
371 | } |
372 | |
372 | |
373 | int cgit_open_filter(struct cgit_filter *filter) |
373 | int cgit_open_filter(struct cgit_filter *filter) |
374 | { |
374 | { |
375 | |
375 | |
376 | filter->old_stdout = chk_positive(dup(STDOUT_FILENO), |
376 | filter->old_stdout = chk_positive(dup(STDOUT_FILENO), |
377 | "Unable to duplicate STDOUT"); |
377 | "Unable to duplicate STDOUT"); |
378 | chk_zero(pipe(filter->pipe_fh), "Unable to create pipe to subprocess"); |
378 | chk_zero(pipe(filter->pipe_fh), "Unable to create pipe to subprocess"); |
379 | filter->pid = chk_non_negative(fork(), "Unable to create subprocess"); |
379 | filter->pid = chk_non_negative(fork(), "Unable to create subprocess"); |
380 | if (filter->pid == 0) { |
380 | if (filter->pid == 0) { |
381 | close(filter->pipe_fh[1]); |
381 | close(filter->pipe_fh[1]); |
382 | chk_non_negative(dup2(filter->pipe_fh[0], STDIN_FILENO), |
382 | chk_non_negative(dup2(filter->pipe_fh[0], STDIN_FILENO), |
383 | "Unable to use pipe as STDIN"); |
383 | "Unable to use pipe as STDIN"); |
384 | execvp(filter->cmd, filter->argv); |
384 | execvp(filter->cmd, filter->argv); |
385 | die("Unable to exec subprocess %s: %s (%d)", filter->cmd, |
385 | die("Unable to exec subprocess %s: %s (%d)", filter->cmd, |
386 | strerror(errno), errno); |
386 | strerror(errno), errno); |
387 | } |
387 | } |
388 | close(filter->pipe_fh[0]); |
388 | close(filter->pipe_fh[0]); |
389 | chk_non_negative(dup2(filter->pipe_fh[1], STDOUT_FILENO), |
389 | chk_non_negative(dup2(filter->pipe_fh[1], STDOUT_FILENO), |
390 | "Unable to use pipe as STDOUT"); |
390 | "Unable to use pipe as STDOUT"); |
391 | close(filter->pipe_fh[1]); |
391 | close(filter->pipe_fh[1]); |
392 | return 0; |
392 | return 0; |
393 | } |
393 | } |
394 | |
394 | |
395 | int cgit_close_filter(struct cgit_filter *filter) |
395 | int cgit_close_filter(struct cgit_filter *filter) |
396 | { |
396 | { |
397 | chk_non_negative(dup2(filter->old_stdout, STDOUT_FILENO), |
397 | chk_non_negative(dup2(filter->old_stdout, STDOUT_FILENO), |
398 | "Unable to restore STDOUT"); |
398 | "Unable to restore STDOUT"); |
399 | close(filter->old_stdout); |
399 | close(filter->old_stdout); |
400 | if (filter->pid < 0) |
400 | if (filter->pid < 0) |
401 | return 0; |
401 | return 0; |
402 | waitpid(filter->pid, &filter->exitstatus, 0); |
402 | waitpid(filter->pid, &filter->exitstatus, 0); |
403 | if (WIFEXITED(filter->exitstatus) && !WEXITSTATUS(filter->exitstatus)) |
403 | if (WIFEXITED(filter->exitstatus) && !WEXITSTATUS(filter->exitstatus)) |
404 | return 0; |
404 | return 0; |
405 | die("Subprocess %s exited abnormally", filter->cmd); |
405 | die("Subprocess %s exited abnormally", filter->cmd); |
406 | } |
406 | } |
407 | |
407 | |
408 | /* Read the content of the specified file into a newly allocated buffer, |
408 | /* Read the content of the specified file into a newly allocated buffer, |
409 | * zeroterminate the buffer and return 0 on success, errno otherwise. |
409 | * zeroterminate the buffer and return 0 on success, errno otherwise. |
410 | */ |
410 | */ |
411 | int readfile(const char *path, char **buf, size_t *size) |
411 | int readfile(const char *path, char **buf, size_t *size) |
412 | { |
412 | { |
413 | int fd, e; |
413 | int fd, e; |
414 | struct stat st; |
414 | struct stat st; |
415 | |
415 | |
416 | fd = open(path, O_RDONLY); |
416 | fd = open(path, O_RDONLY); |
417 | if (fd == -1) |
417 | if (fd == -1) |
418 | return errno; |
418 | return errno; |
419 | if (fstat(fd, &st)) { |
419 | if (fstat(fd, &st)) { |
420 | e = errno; |
420 | e = errno; |
421 | close(fd); |
421 | close(fd); |
422 | return e; |
422 | return e; |
423 | } |
423 | } |
424 | if (!S_ISREG(st.st_mode)) { |
424 | if (!S_ISREG(st.st_mode)) { |
425 | close(fd); |
425 | close(fd); |
426 | return EISDIR; |
426 | return EISDIR; |
427 | } |
427 | } |
428 | *buf = xmalloc(st.st_size + 1); |
428 | *buf = xmalloc(st.st_size + 1); |
429 | *size = read_in_full(fd, *buf, st.st_size); |
429 | *size = read_in_full(fd, *buf, st.st_size); |
430 | e = errno; |
430 | e = errno; |
431 | (*buf)[*size] = '\0'; |
431 | (*buf)[*size] = '\0'; |
432 | close(fd); |
432 | close(fd); |
433 | return (*size == st.st_size ? 0 : e); |
433 | return (*size == st.st_size ? 0 : e); |
434 | } |
434 | } |
| |
435 | |
| |
436 | int is_token_char(char c) |
| |
437 | { |
| |
438 | return isalnum(c) || c == '_'; |
| |
439 | } |
| |
440 | |
| |
441 | /* Replace name with getenv(name), return pointer to zero-terminating char |
| |
442 | */ |
| |
443 | char *expand_macro(char *name, int maxlength) |
| |
444 | { |
| |
445 | char *value; |
| |
446 | int len; |
| |
447 | |
| |
448 | len = 0; |
| |
449 | value = getenv(name); |
| |
450 | if (value) { |
| |
451 | len = strlen(value); |
| |
452 | if (len > maxlength) |
| |
453 | len = maxlength; |
| |
454 | strncpy(name, value, len); |
| |
455 | } |
| |
456 | return name + len; |
| |
457 | } |
| |
458 | |
| |
459 | #define EXPBUFSIZE (1024 * 8) |
| |
460 | |
| |
461 | /* Replace all tokens prefixed by '$' in the specified text with the |
| |
462 | * value of the named environment variable. |
| |
463 | * NB: the return value is a static buffer, i.e. it must be strdup'd |
| |
464 | * by the caller. |
| |
465 | */ |
| |
466 | char *expand_macros(const char *txt) |
| |
467 | { |
| |
468 | static char result[EXPBUFSIZE]; |
| |
469 | char *p, *start; |
| |
470 | int len; |
| |
471 | |
| |
472 | p = result; |
| |
473 | start = NULL; |
| |
474 | while (p < result + EXPBUFSIZE - 1 && txt && *txt) { |
| |
475 | *p = *txt; |
| |
476 | if (start) { |
| |
477 | if (!is_token_char(*txt)) { |
| |
478 | if (p - start > 0) { |
| |
479 | *p = '\0'; |
| |
480 | len = result + EXPBUFSIZE - start - 1; |
| |
481 | p = expand_macro(start, len) - 1; |
| |
482 | } |
| |
483 | start = NULL; |
| |
484 | txt--; |
| |
485 | } |
| |
486 | p++; |
| |
487 | txt++; |
| |
488 | continue; |
| |
489 | } |
| |
490 | if (*txt == '$') { |
| |
491 | start = p; |
| |
492 | txt++; |
| |
493 | continue; |
| |
494 | } |
| |
495 | p++; |
| |
496 | txt++; |
| |
497 | } |
| |
498 | *p = '\0'; |
| |
499 | if (start && p - start > 0) { |
| |
500 | len = result + EXPBUFSIZE - start - 1; |
| |
501 | p = expand_macro(start, len); |
| |
502 | *p = '\0'; |
| |
503 | } |
| |
504 | return result; |
| |
505 | } |
|