2 * Copyright (c) 2016, 2019, 2020-2022 Tracey Emery <tracey@traceyemery.net>
3 * Copyright (c) 2015 Mike Larkin <mlarkin@openbsd.org>
4 * Copyright (c) 2014 Reyk Floeter <reyk@openbsd.org>
5 * Copyright (c) 2013 David Gwynne <dlg@openbsd.org>
6 * Copyright (c) 2013 Florian Obser <florian@openbsd.org>
8 * Permission to use, copy, modify, and distribute this software for any
9 * purpose with or without fee is hereby granted, provided that the above
10 * copyright notice and this permission notice appear in all copies.
12 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
13 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
14 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
15 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
16 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
17 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
18 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
20 #include "got_compat.h"
23 #include <netinet/in.h>
24 #include <sys/queue.h>
26 #include <sys/types.h>
39 #include "got_error.h"
40 #include "got_object.h"
41 #include "got_reference.h"
42 #include "got_repository.h"
44 #include "got_cancel.h"
45 #include "got_worktree.h"
47 #include "got_commit_graph.h"
48 #include "got_blame.h"
49 #include "got_privsep.h"
55 static const struct querystring_keys querystring_keys
[] = {
60 { "headref", HEADREF
},
61 { "index_page", INDEX_PAGE
},
66 static const struct action_keys action_keys
[] = {
69 { "blobraw", BLOBRAW
},
71 { "commits", COMMITS
},
75 { "summary", SUMMARY
},
82 static const struct got_error
*gotweb_init_querystring(struct querystring
**);
83 static const struct got_error
*gotweb_parse_querystring(struct querystring
**,
85 static const struct got_error
*gotweb_assign_querystring(struct querystring
**,
87 static int gotweb_render_index(struct template *);
88 static const struct got_error
*gotweb_init_repo_dir(struct repo_dir
**,
90 static const struct got_error
*gotweb_load_got_path(struct request
*c
,
92 static const struct got_error
*gotweb_get_repo_description(char **,
93 struct server
*, const char *, int);
94 static const struct got_error
*gotweb_get_clone_url(char **, struct server
*,
97 static void gotweb_free_querystring(struct querystring
*);
98 static void gotweb_free_repo_dir(struct repo_dir
*);
100 struct server
*gotweb_get_server(uint8_t *, uint8_t *);
103 gotweb_reply(struct request
*c
, int status
, const char *ctype
,
104 struct gotweb_url
*location
)
108 if (status
!= 200 && fcgi_printf(c
, "Status: %d\r\n", status
) == -1)
112 if (fcgi_puts(c
->tp
, "Location: ") == -1 ||
113 gotweb_render_url(c
, location
) == -1 ||
114 fcgi_puts(c
->tp
, "\r\n") == -1)
118 csp
= "Content-Security-Policy: default-src 'self'; "
119 "script-src 'none'; object-src 'none';\r\n";
120 if (fcgi_puts(c
->tp
, csp
) == -1)
123 if (ctype
&& fcgi_printf(c
, "Content-Type: %s\r\n", ctype
) == -1)
126 return fcgi_puts(c
->tp
, "\r\n");
130 gotweb_reply_file(struct request
*c
, const char *ctype
, const char *file
,
135 r
= fcgi_printf(c
, "Content-Disposition: attachment; "
136 "filename=%s%s\r\n", file
, suffix
? suffix
: "");
139 return gotweb_reply(c
, 200, ctype
, NULL
);
143 gotweb_process_request(struct request
*c
)
145 const struct got_error
*error
= NULL
;
146 struct server
*srv
= NULL
;
147 struct querystring
*qs
= NULL
;
148 struct repo_dir
*repo_dir
= NULL
;
149 const char *rss_ctype
= "application/rss+xml;charset=utf-8";
154 /* init the transport */
155 error
= gotweb_init_transport(&c
->t
);
157 log_warnx("%s: %s", __func__
, error
->msg
);
160 /* don't process any further if client disconnected */
161 if (c
->sock
->client_status
== CLIENT_DISCONNECT
)
163 /* get the gotwebd server */
164 srv
= gotweb_get_server(c
->server_name
, c
->http_host
);
166 log_warnx("%s: error server is NULL", __func__
);
170 /* parse our querystring */
171 error
= gotweb_init_querystring(&qs
);
173 log_warnx("%s: %s", __func__
, error
->msg
);
177 error
= gotweb_parse_querystring(&qs
, c
->querystring
);
179 log_warnx("%s: %s", __func__
, error
->msg
);
184 * certain actions require a commit id in the querystring. this stops
185 * bad actors from exploiting this by manually manipulating the
189 if (qs
->action
== BLAME
|| qs
->action
== BLOB
||
190 qs
->action
== BLOBRAW
|| qs
->action
== DIFF
) {
191 if (qs
->commit
== NULL
) {
192 error
= got_error(GOT_ERR_QUERYSTRING
);
197 if (qs
->action
!= INDEX
) {
198 error
= gotweb_init_repo_dir(&repo_dir
, qs
->path
);
201 error
= gotweb_load_got_path(c
, repo_dir
);
202 c
->t
->repo_dir
= repo_dir
;
203 if (error
&& error
->code
!= GOT_ERR_LONELY_PACKIDX
)
207 if (qs
->action
== BLOBRAW
|| qs
->action
== BLOB
) {
208 error
= got_get_repo_commits(c
, 1);
212 error
= got_open_blob_for_output(&c
->t
->blob
, &c
->t
->fd
,
220 error
= got_get_repo_commits(c
, 1);
222 log_warnx("%s: %s", __func__
, error
->msg
);
225 if (gotweb_reply(c
, 200, "text/html", NULL
) == -1)
227 gotweb_render_page(c
->tp
, gotweb_render_blame
);
231 struct gotweb_url url
= {
236 .commit
= qs
->commit
,
237 .folder
= qs
->folder
,
241 gotweb_reply(c
, 302, NULL
, &url
);
245 if (gotweb_reply(c
, 200, "text/html", NULL
) == -1)
247 gotweb_render_page(c
->tp
, gotweb_render_blob
);
251 r
= gotweb_reply_file(c
, "application/octet-stream",
254 r
= gotweb_reply(c
, 200, "text/plain", NULL
);
259 error
= got_object_blob_read_block(&len
, c
->t
->blob
);
264 buf
= got_object_blob_get_read_buf(c
->t
->blob
);
265 if (fcgi_gen_binary_response(c
, buf
, len
) == -1)
270 if (gotweb_reply(c
, 200, "text/html", NULL
) == -1)
272 gotweb_render_page(c
->tp
, gotweb_render_briefs
);
275 error
= got_get_repo_commits(c
, srv
->max_commits_display
);
277 log_warnx("%s: %s", __func__
, error
->msg
);
280 if (gotweb_reply(c
, 200, "text/html", NULL
) == -1)
282 gotweb_render_page(c
->tp
, gotweb_render_commits
);
285 error
= got_get_repo_commits(c
, 1);
287 log_warnx("%s: %s", __func__
, error
->msg
);
290 error
= got_open_diff_for_output(&c
->t
->fp
, &c
->t
->fd
, c
);
292 log_warnx("%s: %s", __func__
, error
->msg
);
295 if (gotweb_reply(c
, 200, "text/html", NULL
) == -1)
297 gotweb_render_page(c
->tp
, gotweb_render_diff
);
300 c
->t
->nrepos
= scandir(srv
->repos_path
, &c
->t
->repos
, NULL
,
302 if (c
->t
->nrepos
== -1) {
304 error
= got_error_from_errno2("scandir",
308 if (gotweb_reply(c
, 200, "text/html", NULL
) == -1)
310 gotweb_render_page(c
->tp
, gotweb_render_index
);
313 error
= got_get_repo_tags(c
, D_MAXSLCOMMDISP
);
316 if (gotweb_reply_file(c
, rss_ctype
, repo_dir
->name
, ".rss")
319 gotweb_render_rss(c
->tp
);
322 error
= got_ref_list(&c
->t
->refs
, c
->t
->repo
, "refs/heads",
323 got_ref_cmp_by_name
, NULL
);
325 log_warnx("%s: got_ref_list: %s", __func__
,
330 error
= got_get_repo_tags(c
, D_MAXSLCOMMDISP
);
332 log_warnx("%s: got_get_repo_tags: %s", __func__
,
336 qs
->action
= SUMMARY
;
337 if (gotweb_reply(c
, 200, "text/html", NULL
) == -1)
339 gotweb_render_page(c
->tp
, gotweb_render_summary
);
342 error
= got_get_repo_tags(c
, 1);
344 log_warnx("%s: %s", __func__
, error
->msg
);
347 if (c
->t
->tag_count
== 0) {
348 error
= got_error_msg(GOT_ERR_BAD_OBJ_ID
,
352 if (gotweb_reply(c
, 200, "text/html", NULL
) == -1)
354 gotweb_render_page(c
->tp
, gotweb_render_tag
);
357 error
= got_get_repo_tags(c
, srv
->max_commits_display
);
359 log_warnx("%s: %s", __func__
, error
->msg
);
362 if (gotweb_reply(c
, 200, "text/html", NULL
) == -1)
364 gotweb_render_page(c
->tp
, gotweb_render_tags
);
367 error
= got_get_repo_commits(c
, 1);
369 log_warnx("%s: %s", __func__
, error
->msg
);
372 if (gotweb_reply(c
, 200, "text/html", NULL
) == -1)
374 gotweb_render_page(c
->tp
, gotweb_render_tree
);
378 error
= got_error(GOT_ERR_BAD_QUERYSTRING
);
383 if (gotweb_reply(c
, 400, "text/html", NULL
) == -1)
385 gotweb_render_page(c
->tp
, gotweb_render_error
);
389 gotweb_get_server(uint8_t *server_name
, uint8_t *subdomain
)
391 struct server
*srv
= NULL
;
393 /* check against the server name first */
394 if (strlen(server_name
) > 0)
395 TAILQ_FOREACH(srv
, &gotwebd_env
->servers
, entry
)
396 if (strcmp(srv
->name
, server_name
) == 0)
399 /* check against subdomain second */
400 if (strlen(subdomain
) > 0)
401 TAILQ_FOREACH(srv
, &gotwebd_env
->servers
, entry
)
402 if (strcmp(srv
->name
, subdomain
) == 0)
405 /* if those fail, send first server */
406 TAILQ_FOREACH(srv
, &gotwebd_env
->servers
, entry
)
413 const struct got_error
*
414 gotweb_init_transport(struct transport
**t
)
416 const struct got_error
*error
= NULL
;
418 *t
= calloc(1, sizeof(**t
));
420 return got_error_from_errno2("%s: calloc", __func__
);
422 TAILQ_INIT(&(*t
)->repo_commits
);
423 TAILQ_INIT(&(*t
)->repo_tags
);
424 TAILQ_INIT(&(*t
)->refs
);
427 (*t
)->repo_dir
= NULL
;
429 (*t
)->next_id
= NULL
;
430 (*t
)->prev_id
= NULL
;
439 static const struct got_error
*
440 gotweb_init_querystring(struct querystring
**qs
)
442 const struct got_error
*error
= NULL
;
444 *qs
= calloc(1, sizeof(**qs
));
446 return got_error_from_errno2("%s: calloc", __func__
);
448 (*qs
)->headref
= strdup("HEAD");
449 if ((*qs
)->headref
== NULL
) {
452 return got_error_from_errno2("%s: strdup", __func__
);
455 (*qs
)->action
= INDEX
;
456 (*qs
)->commit
= NULL
;
458 (*qs
)->folder
= NULL
;
459 (*qs
)->index_page
= 0;
465 static const struct got_error
*
466 gotweb_parse_querystring(struct querystring
**qs
, char *qst
)
468 const struct got_error
*error
= NULL
;
469 char *tok1
= NULL
, *tok1_pair
= NULL
, *tok1_end
= NULL
;
470 char *tok2
= NULL
, *tok2_pair
= NULL
, *tok2_end
= NULL
;
477 return got_error_from_errno2("%s: strdup", __func__
);
482 while (tok1_pair
!= NULL
) {
483 strsep(&tok1_end
, "&");
485 tok2
= strdup(tok1_pair
);
488 return got_error_from_errno2("%s: strdup", __func__
);
494 while (tok2_pair
!= NULL
) {
495 strsep(&tok2_end
, "=");
497 error
= gotweb_assign_querystring(qs
, tok2_pair
,
502 tok2_pair
= tok2_end
;
505 tok1_pair
= tok1_end
;
516 * Adapted from usr.sbin/httpd/httpd.c url_decode.
518 static const struct got_error
*
519 gotweb_urldecode(char *url
)
531 /* Encoding character is followed by two hex chars */
532 if (!isxdigit((unsigned char)p
[1]) ||
533 !isxdigit((unsigned char)p
[2]) ||
534 (p
[1] == '0' && p
[2] == '0'))
535 return got_error(GOT_ERR_BAD_QUERYSTRING
);
541 * We don't have to validate "hex" because it is
542 * guaranteed to include two hex chars followed by nul.
544 x
= strtoul(hex
, NULL
, 16);
560 static const struct got_error
*
561 gotweb_assign_querystring(struct querystring
**qs
, char *key
, char *value
)
563 const struct got_error
*error
= NULL
;
567 error
= gotweb_urldecode(value
);
571 for (el_cnt
= 0; el_cnt
< QSELEM__MAX
; el_cnt
++) {
572 if (strcmp(key
, querystring_keys
[el_cnt
].name
) != 0)
575 switch (querystring_keys
[el_cnt
].element
) {
577 for (a_cnt
= 0; a_cnt
< ACTIONS__MAX
; a_cnt
++) {
578 if (strcmp(value
, action_keys
[a_cnt
].name
) != 0)
580 else if (strcmp(value
,
581 action_keys
[a_cnt
].name
) == 0){
583 action_keys
[a_cnt
].action
;
591 (*qs
)->commit
= strdup(value
);
592 if ((*qs
)->commit
== NULL
) {
593 error
= got_error_from_errno2("%s: strdup",
599 (*qs
)->file
= strdup(value
);
600 if ((*qs
)->file
== NULL
) {
601 error
= got_error_from_errno2("%s: strdup",
607 (*qs
)->folder
= strdup(value
);
608 if ((*qs
)->folder
== NULL
) {
609 error
= got_error_from_errno2("%s: strdup",
615 free((*qs
)->headref
);
616 (*qs
)->headref
= strdup(value
);
617 if ((*qs
)->headref
== NULL
) {
618 error
= got_error_from_errno2("%s: strdup",
624 if (strlen(value
) == 0)
626 (*qs
)->index_page
= strtonum(value
, INT64_MIN
,
629 error
= got_error_from_errno3("%s: strtonum %s",
633 if ((*qs
)->index_page
< 0)
634 (*qs
)->index_page
= 0;
637 (*qs
)->path
= strdup(value
);
638 if ((*qs
)->path
== NULL
) {
639 error
= got_error_from_errno2("%s: strdup",
645 if (strlen(value
) == 0)
647 (*qs
)->page
= strtonum(value
, INT64_MIN
,
650 error
= got_error_from_errno3("%s: strtonum %s",
666 gotweb_free_repo_tag(struct repo_tag
*rt
)
671 free(rt
->tag_commit
);
672 free(rt
->commit_msg
);
679 gotweb_free_repo_commit(struct repo_commit
*rc
)
689 free(rc
->commit_msg
);
695 gotweb_free_querystring(struct querystring
*qs
)
708 gotweb_free_repo_dir(struct repo_dir
*repo_dir
)
710 if (repo_dir
!= NULL
) {
711 free(repo_dir
->name
);
712 free(repo_dir
->owner
);
713 free(repo_dir
->description
);
715 free(repo_dir
->path
);
721 gotweb_free_transport(struct transport
*t
)
723 const struct got_error
*err
;
724 struct repo_commit
*rc
= NULL
, *trc
= NULL
;
725 struct repo_tag
*rt
= NULL
, *trt
= NULL
;
728 got_ref_list_free(&t
->refs
);
729 TAILQ_FOREACH_SAFE(rc
, &t
->repo_commits
, entry
, trc
) {
730 TAILQ_REMOVE(&t
->repo_commits
, rc
, entry
);
731 gotweb_free_repo_commit(rc
);
733 TAILQ_FOREACH_SAFE(rt
, &t
->repo_tags
, entry
, trt
) {
734 TAILQ_REMOVE(&t
->repo_tags
, rt
, entry
);
735 gotweb_free_repo_tag(rt
);
737 gotweb_free_repo_dir(t
->repo_dir
);
738 gotweb_free_querystring(t
->qs
);
743 got_object_blob_close(t
->blob
);
745 err
= got_gotweb_flushfile(t
->fp
, t
->fd
);
747 log_warnx("%s: got_gotweb_flushfile failure: %s",
754 for (i
= 0; i
< t
->nrepos
; ++i
)
762 gotweb_get_navs(struct request
*c
, struct gotweb_url
*prev
, int *have_prev
,
763 struct gotweb_url
*next
, int *have_next
)
765 struct transport
*t
= c
->t
;
766 struct querystring
*qs
= t
->qs
;
767 struct server
*srv
= c
->srv
;
769 *have_prev
= *have_next
= 0;
773 if (qs
->index_page
> 0) {
775 *prev
= (struct gotweb_url
){
777 .index_page
= qs
->index_page
- 1,
781 if (t
->next_disp
== srv
->max_repos_display
&&
782 t
->repos_total
!= (qs
->index_page
+ 1) *
783 srv
->max_repos_display
) {
785 *next
= (struct gotweb_url
){
787 .index_page
= qs
->index_page
+ 1,
793 if (t
->prev_id
&& qs
->commit
!= NULL
&&
794 strcmp(qs
->commit
, t
->prev_id
) != 0) {
796 *prev
= (struct gotweb_url
){
799 .page
= qs
->page
- 1,
801 .commit
= t
->prev_id
,
802 .headref
= qs
->headref
,
807 *next
= (struct gotweb_url
){
810 .page
= qs
->page
+ 1,
812 .commit
= t
->next_id
,
813 .headref
= qs
->headref
,
821 gotweb_render_index(struct template *tp
)
823 const struct got_error
*error
= NULL
;
824 struct request
*c
= tp
->tp_arg
;
825 struct server
*srv
= c
->srv
;
826 struct transport
*t
= c
->t
;
827 struct querystring
*qs
= t
->qs
;
828 struct repo_dir
*repo_dir
= NULL
;
829 struct dirent
**sd_dent
= t
->repos
;
830 unsigned int d_i
, d_disp
= 0;
831 unsigned int d_skipped
= 0;
834 if (gotweb_render_repo_table_hdr(c
->tp
) == -1)
837 for (d_i
= 0; d_i
< t
->nrepos
; d_i
++) {
838 if (srv
->max_repos
> 0 && t
->prev_disp
== srv
->max_repos
)
841 if (strcmp(sd_dent
[d_i
]->d_name
, ".") == 0 ||
842 strcmp(sd_dent
[d_i
]->d_name
, "..") == 0) {
847 error
= got_path_dirent_type(&type
, srv
->repos_path
,
851 if (type
!= DT_DIR
) {
856 if (qs
->index_page
> 0 && (qs
->index_page
*
857 srv
->max_repos_display
) > t
->prev_disp
) {
862 error
= gotweb_init_repo_dir(&repo_dir
, sd_dent
[d_i
]->d_name
);
866 error
= gotweb_load_got_path(c
, repo_dir
);
867 if (error
&& error
->code
== GOT_ERR_LONELY_PACKIDX
) {
868 if (error
->code
!= GOT_ERR_NOT_GIT_REPO
)
869 log_warnx("%s: %s: %s", __func__
,
870 sd_dent
[d_i
]->d_name
, error
->msg
);
871 gotweb_free_repo_dir(repo_dir
);
880 r
= gotweb_render_repo_fragment(c
->tp
, repo_dir
);
881 gotweb_free_repo_dir(repo_dir
);
886 if (d_disp
== srv
->max_repos_display
)
889 t
->repos_total
= t
->nrepos
- d_skipped
;
891 if (srv
->max_repos_display
== 0)
893 if (srv
->max_repos
> 0 && srv
->max_repos
< srv
->max_repos_display
)
895 if (t
->repos_total
<= srv
->max_repos
||
896 t
->repos_total
<= srv
->max_repos_display
)
899 if (gotweb_render_navs(c
->tp
) == -1)
906 should_urlencode(int c
)
908 if (c
<= ' ' || c
>= 127)
932 /* needed because the URLs are embedded into the HTML */
941 gotweb_urlencode(const char *str
)
949 for (s
= str
; *s
; ++s
) {
951 if (should_urlencode(*s
))
955 escaped
= calloc(1, len
+ 1);
960 for (s
= str
; *s
; ++s
) {
961 if (should_urlencode(*s
)) {
962 a
= (*s
& 0xF0) >> 4;
966 escaped
[i
++] = a
<= 9 ? ('0' + a
) : ('7' + a
);
967 escaped
[i
++] = b
<= 9 ? ('0' + b
) : ('7' + b
);
976 gotweb_action_name(int action
)
1011 gotweb_render_url(struct request
*c
, struct gotweb_url
*url
)
1013 const char *sep
= "?", *action
;
1017 action
= gotweb_action_name(url
->action
);
1018 if (action
!= NULL
) {
1019 if (fcgi_printf(c
, "?action=%s", action
) == -1)
1025 if (fcgi_printf(c
, "%scommit=%s", sep
, url
->commit
) == -1)
1031 if (fcgi_printf(c
, "%sprevid=%s", sep
, url
->previd
) == -1)
1037 if (fcgi_printf(c
, "%sprevset=%s", sep
, url
->prevset
) == -1)
1043 tmp
= gotweb_urlencode(url
->file
);
1046 r
= fcgi_printf(c
, "%sfile=%s", sep
, tmp
);
1054 tmp
= gotweb_urlencode(url
->folder
);
1057 r
= fcgi_printf(c
, "%sfolder=%s", sep
, tmp
);
1065 tmp
= gotweb_urlencode(url
->headref
);
1068 r
= fcgi_printf(c
, "%sheadref=%s", sep
, url
->headref
);
1075 if (url
->index_page
!= -1) {
1076 if (fcgi_printf(c
, "%sindex_page=%d", sep
,
1077 url
->index_page
) == -1)
1083 tmp
= gotweb_urlencode(url
->path
);
1086 r
= fcgi_printf(c
, "%spath=%s", sep
, tmp
);
1093 if (url
->page
!= -1) {
1094 if (fcgi_printf(c
, "%spage=%d", sep
, url
->page
) == -1)
1103 gotweb_render_absolute_url(struct request
*c
, struct gotweb_url
*url
)
1105 struct template *tp
= c
->tp
;
1106 const char *proto
= c
->https
? "https" : "http";
1108 if (fcgi_puts(tp
, proto
) == -1 ||
1109 fcgi_puts(tp
, "://") == -1 ||
1110 tp_htmlescape(tp
, c
->server_name
) == -1 ||
1111 tp_htmlescape(tp
, c
->document_uri
) == -1)
1114 return gotweb_render_url(c
, url
);
1117 static struct got_repository
*
1118 find_cached_repo(struct server
*srv
, const char *path
)
1122 for (i
= 0; i
< srv
->ncached_repos
; i
++) {
1123 if (strcmp(srv
->cached_repos
[i
].path
, path
) == 0)
1124 return srv
->cached_repos
[i
].repo
;
1130 static const struct got_error
*
1131 cache_repo(struct got_repository
**new, struct server
*srv
,
1132 struct repo_dir
*repo_dir
, struct socket
*sock
)
1134 const struct got_error
*error
= NULL
;
1135 struct got_repository
*repo
;
1136 struct cached_repo
*cr
;
1139 if (srv
->ncached_repos
>= GOTWEBD_REPO_CACHESIZE
) {
1140 cr
= &srv
->cached_repos
[srv
->ncached_repos
- 1];
1141 error
= got_repo_close(cr
->repo
);
1142 memset(cr
, 0, sizeof(*cr
));
1143 srv
->ncached_repos
--;
1146 memmove(&srv
->cached_repos
[1], &srv
->cached_repos
[0],
1147 srv
->ncached_repos
* sizeof(srv
->cached_repos
[0]));
1148 cr
= &srv
->cached_repos
[0];
1151 cr
= &srv
->cached_repos
[srv
->ncached_repos
];
1154 error
= got_repo_open(&repo
, repo_dir
->path
, NULL
, sock
->pack_fds
);
1157 memmove(&srv
->cached_repos
[0], &srv
->cached_repos
[1],
1158 srv
->ncached_repos
* sizeof(srv
->cached_repos
[0]));
1163 if (strlcpy(cr
->path
, repo_dir
->path
, sizeof(cr
->path
))
1164 >= sizeof(cr
->path
)) {
1166 memmove(&srv
->cached_repos
[0], &srv
->cached_repos
[1],
1167 srv
->ncached_repos
* sizeof(srv
->cached_repos
[0]));
1169 return got_error(GOT_ERR_NO_SPACE
);
1173 srv
->ncached_repos
++;
1178 static const struct got_error
*
1179 gotweb_load_got_path(struct request
*c
, struct repo_dir
*repo_dir
)
1181 const struct got_error
*error
= NULL
;
1182 struct socket
*sock
= c
->sock
;
1183 struct server
*srv
= c
->srv
;
1184 struct transport
*t
= c
->t
;
1185 struct got_repository
*repo
= NULL
;
1189 if (asprintf(&dir_test
, "%s/%s/%s", srv
->repos_path
, repo_dir
->name
,
1190 GOTWEB_GIT_DIR
) == -1)
1191 return got_error_from_errno("asprintf");
1193 dt
= opendir(dir_test
);
1197 repo_dir
->path
= dir_test
;
1202 if (asprintf(&dir_test
, "%s/%s", srv
->repos_path
,
1203 repo_dir
->name
) == -1)
1204 return got_error_from_errno("asprintf");
1206 dt
= opendir(dir_test
);
1208 error
= got_error_path(repo_dir
->name
, GOT_ERR_NOT_GIT_REPO
);
1211 repo_dir
->path
= dir_test
;
1216 if (srv
->respect_exportok
&&
1217 faccessat(dirfd(dt
), "git-daemon-export-ok", F_OK
, 0) == -1) {
1218 error
= got_error_path(repo_dir
->name
, GOT_ERR_NOT_GIT_REPO
);
1222 repo
= find_cached_repo(srv
, repo_dir
->path
);
1224 error
= cache_repo(&repo
, srv
, repo_dir
, sock
);
1229 error
= gotweb_get_repo_description(&repo_dir
->description
, srv
,
1230 repo_dir
->path
, dirfd(dt
));
1233 error
= got_get_repo_owner(&repo_dir
->owner
, c
);
1236 error
= got_get_repo_age(&repo_dir
->age
, c
, NULL
);
1239 error
= gotweb_get_clone_url(&repo_dir
->url
, srv
, repo_dir
->path
,
1243 if (dt
!= NULL
&& closedir(dt
) == EOF
&& error
== NULL
)
1244 error
= got_error_from_errno("closedir");
1248 static const struct got_error
*
1249 gotweb_init_repo_dir(struct repo_dir
**repo_dir
, const char *dir
)
1251 const struct got_error
*error
;
1253 *repo_dir
= calloc(1, sizeof(**repo_dir
));
1254 if (*repo_dir
== NULL
)
1255 return got_error_from_errno("calloc");
1257 if (asprintf(&(*repo_dir
)->name
, "%s", dir
) == -1) {
1258 error
= got_error_from_errno("asprintf");
1263 (*repo_dir
)->owner
= NULL
;
1264 (*repo_dir
)->description
= NULL
;
1265 (*repo_dir
)->url
= NULL
;
1266 (*repo_dir
)->path
= NULL
;
1271 static const struct got_error
*
1272 gotweb_get_repo_description(char **description
, struct server
*srv
,
1273 const char *dirpath
, int dir
)
1275 const struct got_error
*error
= NULL
;
1280 *description
= NULL
;
1281 if (srv
->show_repo_description
== 0)
1284 fd
= openat(dir
, "description", O_RDONLY
);
1286 if (errno
!= ENOENT
&& errno
!= EACCES
) {
1287 error
= got_error_from_errno_fmt("openat %s/%s",
1288 dirpath
, "description");
1293 if (fstat(fd
, &sb
) == -1) {
1294 error
= got_error_from_errno_fmt("fstat %s/%s",
1295 dirpath
, "description");
1300 if (len
> GOTWEBD_MAXDESCRSZ
- 1)
1301 len
= GOTWEBD_MAXDESCRSZ
- 1;
1303 *description
= calloc(len
+ 1, sizeof(**description
));
1304 if (*description
== NULL
) {
1305 error
= got_error_from_errno("calloc");
1309 if (read(fd
, *description
, len
) == -1)
1310 error
= got_error_from_errno("read");
1312 if (fd
!= -1 && close(fd
) == -1 && error
== NULL
)
1313 error
= got_error_from_errno("close");
1317 static const struct got_error
*
1318 gotweb_get_clone_url(char **url
, struct server
*srv
, const char *dirpath
,
1321 const struct got_error
*error
= NULL
;
1327 if (srv
->show_repo_cloneurl
== 0)
1330 fd
= openat(dir
, "cloneurl", O_RDONLY
);
1332 if (errno
!= ENOENT
&& errno
!= EACCES
) {
1333 error
= got_error_from_errno_fmt("openat %s/%s",
1334 dirpath
, "cloneurl");
1339 if (fstat(fd
, &sb
) == -1) {
1340 error
= got_error_from_errno_fmt("fstat %s/%s",
1341 dirpath
, "cloneurl");
1346 if (len
> GOTWEBD_MAXCLONEURLSZ
- 1)
1347 len
= GOTWEBD_MAXCLONEURLSZ
- 1;
1349 *url
= calloc(len
+ 1, sizeof(**url
));
1351 error
= got_error_from_errno("calloc");
1355 if (read(fd
, *url
, len
) == -1)
1356 error
= got_error_from_errno("read");
1358 if (fd
!= -1 && close(fd
) == -1 && error
== NULL
)
1359 error
= got_error_from_errno("close");
1364 gotweb_render_age(struct template *tp
, time_t committer_time
, int ref_tm
)
1366 struct request
*c
= tp
->tp_arg
;
1368 long long diff_time
;
1369 const char *years
= "years ago", *months
= "months ago";
1370 const char *weeks
= "weeks ago", *days
= "days ago";
1371 const char *hours
= "hours ago", *minutes
= "minutes ago";
1372 const char *seconds
= "seconds ago", *now
= "right now";
1379 diff_time
= time(NULL
) - committer_time
;
1380 if (diff_time
> 60 * 60 * 24 * 365 * 2) {
1381 if (fcgi_printf(c
, "%lld %s",
1382 (diff_time
/ 60 / 60 / 24 / 365), years
) == -1)
1384 } else if (diff_time
> 60 * 60 * 24 * (365 / 12) * 2) {
1385 if (fcgi_printf(c
, "%lld %s",
1386 (diff_time
/ 60 / 60 / 24 / (365 / 12)),
1389 } else if (diff_time
> 60 * 60 * 24 * 7 * 2) {
1390 if (fcgi_printf(c
, "%lld %s",
1391 (diff_time
/ 60 / 60 / 24 / 7), weeks
) == -1)
1393 } else if (diff_time
> 60 * 60 * 24 * 2) {
1394 if (fcgi_printf(c
, "%lld %s",
1395 (diff_time
/ 60 / 60 / 24), days
) == -1)
1397 } else if (diff_time
> 60 * 60 * 2) {
1398 if (fcgi_printf(c
, "%lld %s",
1399 (diff_time
/ 60 / 60), hours
) == -1)
1401 } else if (diff_time
> 60 * 2) {
1402 if (fcgi_printf(c
, "%lld %s", (diff_time
/ 60),
1405 } else if (diff_time
> 2) {
1406 if (fcgi_printf(c
, "%lld %s", diff_time
,
1410 if (fcgi_puts(tp
, now
) == -1)
1415 if (gmtime_r(&committer_time
, &tm
) == NULL
)
1418 s
= asctime_r(&tm
, datebuf
);
1422 if (fcgi_puts(tp
, datebuf
) == -1 ||
1423 fcgi_puts(tp
, " UTC") == -1)
1427 if (gmtime_r(&committer_time
, &tm
) == NULL
)
1430 r
= strftime(datebuf
, sizeof(datebuf
),
1431 "%a, %d %b %Y %H:%M:%S GMT", &tm
);
1435 if (fcgi_puts(tp
, datebuf
) == -1)