summaryrefslogtreecommitdiffabout
path: root/cgit.c
authorLars Hjemli <hjemli@gmail.com>2008-02-16 20:16:53 (UTC)
committer Lars Hjemli <hjemli@gmail.com>2008-02-16 20:48:19 (UTC)
commitb88fb016d0209f7041ac7d3b4d2c077318407a4d (patch) (unidiff)
tree777e9cd042c3da9caaefe1f63363a52b56601521 /cgit.c
parentd1f3bbe9d22029f45a77bb938c176ccc0c827d46 (diff)
downloadcgit-b88fb016d0209f7041ac7d3b4d2c077318407a4d.zip
cgit-b88fb016d0209f7041ac7d3b4d2c077318407a4d.tar.gz
cgit-b88fb016d0209f7041ac7d3b4d2c077318407a4d.tar.bz2
Improve initialization of git directory
Using the functions offered by libgit feels like the right thing to do. Also, make sure that config errors gets properly reported. Signed-off-by: Lars Hjemli <hjemli@gmail.com>
Diffstat (limited to 'cgit.c') (more/less context) (ignore whitespace changes)
-rw-r--r--cgit.c17
1 files changed, 8 insertions, 9 deletions
diff --git a/cgit.c b/cgit.c
index b270fdc..2c933dc 100644
--- a/cgit.c
+++ b/cgit.c
@@ -1,318 +1,317 @@
1/* cgit.c: cgi for the git scm 1/* cgit.c: cgi for the git scm
2 * 2 *
3 * Copyright (C) 2006 Lars Hjemli 3 * Copyright (C) 2006 Lars Hjemli
4 * 4 *
5 * Licensed under GNU General Public License v2 5 * Licensed under GNU General Public License v2
6 * (see COPYING for full license text) 6 * (see COPYING for full license text)
7 */ 7 */
8 8
9#include "cgit.h" 9#include "cgit.h"
10 10
11static int cgit_prepare_cache(struct cacheitem *item) 11static int cgit_prepare_cache(struct cacheitem *item)
12{ 12{
13 if (!ctx.repo && ctx.qry.repo) { 13 if (!ctx.repo && ctx.qry.repo) {
14 char *title = fmt("%s - %s", ctx.cfg.root_title, "Bad request"); 14 char *title = fmt("%s - %s", ctx.cfg.root_title, "Bad request");
15 cgit_print_docstart(title, item); 15 cgit_print_docstart(title, item);
16 cgit_print_pageheader(title, 0); 16 cgit_print_pageheader(title, 0);
17 cgit_print_error(fmt("Unknown repo: %s", ctx.qry.repo)); 17 cgit_print_error(fmt("Unknown repo: %s", ctx.qry.repo));
18 cgit_print_docend(); 18 cgit_print_docend();
19 return 0; 19 return 0;
20 } 20 }
21 21
22 if (!ctx.repo) { 22 if (!ctx.repo) {
23 item->name = xstrdup(fmt("%s/index.html", ctx.cfg.cache_root)); 23 item->name = xstrdup(fmt("%s/index.html", ctx.cfg.cache_root));
24 item->ttl = ctx.cfg.cache_root_ttl; 24 item->ttl = ctx.cfg.cache_root_ttl;
25 return 1; 25 return 1;
26 } 26 }
27 27
28 if (!cgit_cmd) { 28 if (!cgit_cmd) {
29 item->name = xstrdup(fmt("%s/%s/index.%s.html", ctx.cfg.cache_root, 29 item->name = xstrdup(fmt("%s/%s/index.%s.html", ctx.cfg.cache_root,
30 cache_safe_filename(ctx.repo->url), 30 cache_safe_filename(ctx.repo->url),
31 cache_safe_filename(ctx.qry.raw))); 31 cache_safe_filename(ctx.qry.raw)));
32 item->ttl = ctx.cfg.cache_repo_ttl; 32 item->ttl = ctx.cfg.cache_repo_ttl;
33 } else { 33 } else {
34 item->name = xstrdup(fmt("%s/%s/%s/%s.html", ctx.cfg.cache_root, 34 item->name = xstrdup(fmt("%s/%s/%s/%s.html", ctx.cfg.cache_root,
35 cache_safe_filename(ctx.repo->url), 35 cache_safe_filename(ctx.repo->url),
36 ctx.qry.page, 36 ctx.qry.page,
37 cache_safe_filename(ctx.qry.raw))); 37 cache_safe_filename(ctx.qry.raw)));
38 if (ctx.qry.has_symref) 38 if (ctx.qry.has_symref)
39 item->ttl = ctx.cfg.cache_dynamic_ttl; 39 item->ttl = ctx.cfg.cache_dynamic_ttl;
40 else if (ctx.qry.has_sha1) 40 else if (ctx.qry.has_sha1)
41 item->ttl = ctx.cfg.cache_static_ttl; 41 item->ttl = ctx.cfg.cache_static_ttl;
42 else 42 else
43 item->ttl = ctx.cfg.cache_repo_ttl; 43 item->ttl = ctx.cfg.cache_repo_ttl;
44 } 44 }
45 return 1; 45 return 1;
46} 46}
47 47
48struct refmatch { 48struct refmatch {
49 char *req_ref; 49 char *req_ref;
50 char *first_ref; 50 char *first_ref;
51 int match; 51 int match;
52}; 52};
53 53
54int find_current_ref(const char *refname, const unsigned char *sha1, 54int find_current_ref(const char *refname, const unsigned char *sha1,
55 int flags, void *cb_data) 55 int flags, void *cb_data)
56{ 56{
57 struct refmatch *info; 57 struct refmatch *info;
58 58
59 info = (struct refmatch *)cb_data; 59 info = (struct refmatch *)cb_data;
60 if (!strcmp(refname, info->req_ref)) 60 if (!strcmp(refname, info->req_ref))
61 info->match = 1; 61 info->match = 1;
62 if (!info->first_ref) 62 if (!info->first_ref)
63 info->first_ref = xstrdup(refname); 63 info->first_ref = xstrdup(refname);
64 return info->match; 64 return info->match;
65} 65}
66 66
67char *find_default_branch(struct cgit_repo *repo) 67char *find_default_branch(struct cgit_repo *repo)
68{ 68{
69 struct refmatch info; 69 struct refmatch info;
70 70
71 info.req_ref = repo->defbranch; 71 info.req_ref = repo->defbranch;
72 info.first_ref = NULL; 72 info.first_ref = NULL;
73 info.match = 0; 73 info.match = 0;
74 for_each_branch_ref(find_current_ref, &info); 74 for_each_branch_ref(find_current_ref, &info);
75 if (info.match) 75 if (info.match)
76 return info.req_ref; 76 return info.req_ref;
77 else 77 else
78 return info.first_ref; 78 return info.first_ref;
79} 79}
80 80
81static void cgit_print_repo_page(struct cacheitem *item) 81static void cgit_print_repo_page(struct cacheitem *item)
82{ 82{
83 char *title, *tmp; 83 char *title, *tmp;
84 int show_search; 84 int show_search;
85 unsigned char sha1[20]; 85 unsigned char sha1[20];
86 int nongit = 0;
86 87
87 if (chdir(ctx.repo->path)) { 88 setenv("GIT_DIR", ctx.repo->path, 1);
88 title = fmt("%s - %s", ctx.cfg.root_title, "Bad request"); 89 setup_git_directory_gently(&nongit);
90 if (nongit) {
91 title = fmt("%s - %s", ctx.cfg.root_title, "config error");
92 tmp = fmt("Not a git repository: '%s'", ctx.repo->path);
93 ctx.repo = NULL;
89 cgit_print_docstart(title, item); 94 cgit_print_docstart(title, item);
90 cgit_print_pageheader(title, 0); 95 cgit_print_pageheader(title, 0);
91 cgit_print_error(fmt("Unable to scan repository: %s", 96 cgit_print_error(tmp);
92 strerror(errno)));
93 cgit_print_docend(); 97 cgit_print_docend();
94 return; 98 return;
95 } 99 }
96 100
97 title = fmt("%s - %s", ctx.repo->name, ctx.repo->desc); 101 title = fmt("%s - %s", ctx.repo->name, ctx.repo->desc);
98 show_search = 0; 102 show_search = 0;
99 setenv("GIT_DIR", ctx.repo->path, 1);
100 103
101 if (!ctx.qry.head) { 104 if (!ctx.qry.head) {
102 ctx.qry.head = xstrdup(find_default_branch(ctx.repo)); 105 ctx.qry.head = xstrdup(find_default_branch(ctx.repo));
103 ctx.repo->defbranch = ctx.qry.head; 106 ctx.repo->defbranch = ctx.qry.head;
104 } 107 }
105 108
106 if (!ctx.qry.head) { 109 if (!ctx.qry.head) {
107 cgit_print_docstart(title, item); 110 cgit_print_docstart(title, item);
108 cgit_print_pageheader(title, 0); 111 cgit_print_pageheader(title, 0);
109 cgit_print_error("Repository seems to be empty"); 112 cgit_print_error("Repository seems to be empty");
110 cgit_print_docend(); 113 cgit_print_docend();
111 return; 114 return;
112 } 115 }
113 116
114 if (get_sha1(ctx.qry.head, sha1)) { 117 if (get_sha1(ctx.qry.head, sha1)) {
115 tmp = xstrdup(ctx.qry.head); 118 tmp = xstrdup(ctx.qry.head);
116 ctx.qry.head = ctx.repo->defbranch; 119 ctx.qry.head = ctx.repo->defbranch;
117 cgit_print_docstart(title, item); 120 cgit_print_docstart(title, item);
118 cgit_print_pageheader(title, 0); 121 cgit_print_pageheader(title, 0);
119 cgit_print_error(fmt("Invalid branch: %s", tmp)); 122 cgit_print_error(fmt("Invalid branch: %s", tmp));
120 cgit_print_docend(); 123 cgit_print_docend();
121 return; 124 return;
122 } 125 }
123 126
124 if ((cgit_cmd == CMD_SNAPSHOT) && ctx.repo->snapshots) { 127 if ((cgit_cmd == CMD_SNAPSHOT) && ctx.repo->snapshots) {
125 cgit_print_snapshot(item, ctx.qry.head, ctx.qry.sha1, 128 cgit_print_snapshot(item, ctx.qry.head, ctx.qry.sha1,
126 cgit_repobasename(ctx.repo->url), 129 cgit_repobasename(ctx.repo->url),
127 ctx.qry.path, 130 ctx.qry.path,
128 ctx.repo->snapshots ); 131 ctx.repo->snapshots );
129 return; 132 return;
130 } 133 }
131 134
132 if (cgit_cmd == CMD_PATCH) { 135 if (cgit_cmd == CMD_PATCH) {
133 cgit_print_patch(ctx.qry.sha1, item); 136 cgit_print_patch(ctx.qry.sha1, item);
134 return; 137 return;
135 } 138 }
136 139
137 if (cgit_cmd == CMD_BLOB) { 140 if (cgit_cmd == CMD_BLOB) {
138 cgit_print_blob(item, ctx.qry.sha1, ctx.qry.path); 141 cgit_print_blob(item, ctx.qry.sha1, ctx.qry.path);
139 return; 142 return;
140 } 143 }
141 144
142 show_search = (cgit_cmd == CMD_LOG); 145 show_search = (cgit_cmd == CMD_LOG);
143 cgit_print_docstart(title, item); 146 cgit_print_docstart(title, item);
144 if (!cgit_cmd) { 147 if (!cgit_cmd) {
145 cgit_print_pageheader("summary", show_search); 148 cgit_print_pageheader("summary", show_search);
146 cgit_print_summary(); 149 cgit_print_summary();
147 cgit_print_docend(); 150 cgit_print_docend();
148 return; 151 return;
149 } 152 }
150 153
151 cgit_print_pageheader(ctx.qry.page, show_search); 154 cgit_print_pageheader(ctx.qry.page, show_search);
152 155
153 switch(cgit_cmd) { 156 switch(cgit_cmd) {
154 case CMD_LOG: 157 case CMD_LOG:
155 cgit_print_log(ctx.qry.sha1, ctx.qry.ofs, 158 cgit_print_log(ctx.qry.sha1, ctx.qry.ofs,
156 ctx.cfg.max_commit_count, ctx.qry.grep, ctx.qry.search, 159 ctx.cfg.max_commit_count, ctx.qry.grep, ctx.qry.search,
157 ctx.qry.path, 1); 160 ctx.qry.path, 1);
158 break; 161 break;
159 case CMD_TREE: 162 case CMD_TREE:
160 cgit_print_tree(ctx.qry.sha1, ctx.qry.path); 163 cgit_print_tree(ctx.qry.sha1, ctx.qry.path);
161 break; 164 break;
162 case CMD_COMMIT: 165 case CMD_COMMIT:
163 cgit_print_commit(ctx.qry.sha1); 166 cgit_print_commit(ctx.qry.sha1);
164 break; 167 break;
165 case CMD_REFS: 168 case CMD_REFS:
166 cgit_print_refs(); 169 cgit_print_refs();
167 break; 170 break;
168 case CMD_TAG: 171 case CMD_TAG:
169 cgit_print_tag(ctx.qry.sha1); 172 cgit_print_tag(ctx.qry.sha1);
170 break; 173 break;
171 case CMD_DIFF: 174 case CMD_DIFF:
172 cgit_print_diff(ctx.qry.sha1, ctx.qry.sha2, ctx.qry.path); 175 cgit_print_diff(ctx.qry.sha1, ctx.qry.sha2, ctx.qry.path);
173 break; 176 break;
174 default: 177 default:
175 cgit_print_error("Invalid request"); 178 cgit_print_error("Invalid request");
176 } 179 }
177 cgit_print_docend(); 180 cgit_print_docend();
178} 181}
179 182
180static void cgit_fill_cache(struct cacheitem *item, int use_cache) 183static void cgit_fill_cache(struct cacheitem *item, int use_cache)
181{ 184{
182 static char buf[PATH_MAX];
183 int stdout2; 185 int stdout2;
184 186
185 getcwd(buf, sizeof(buf));
186 item->st.st_mtime = time(NULL); 187 item->st.st_mtime = time(NULL);
187 188
188 if (use_cache) { 189 if (use_cache) {
189 stdout2 = chk_positive(dup(STDOUT_FILENO), 190 stdout2 = chk_positive(dup(STDOUT_FILENO),
190 "Preserving STDOUT"); 191 "Preserving STDOUT");
191 chk_zero(close(STDOUT_FILENO), "Closing STDOUT"); 192 chk_zero(close(STDOUT_FILENO), "Closing STDOUT");
192 chk_positive(dup2(item->fd, STDOUT_FILENO), "Dup2(cachefile)"); 193 chk_positive(dup2(item->fd, STDOUT_FILENO), "Dup2(cachefile)");
193 } 194 }
194 195
195 if (ctx.repo) 196 if (ctx.repo)
196 cgit_print_repo_page(item); 197 cgit_print_repo_page(item);
197 else 198 else
198 cgit_print_repolist(item); 199 cgit_print_repolist(item);
199 200
200 if (use_cache) { 201 if (use_cache) {
201 chk_zero(close(STDOUT_FILENO), "Close redirected STDOUT"); 202 chk_zero(close(STDOUT_FILENO), "Close redirected STDOUT");
202 chk_positive(dup2(stdout2, STDOUT_FILENO), 203 chk_positive(dup2(stdout2, STDOUT_FILENO),
203 "Restoring original STDOUT"); 204 "Restoring original STDOUT");
204 chk_zero(close(stdout2), "Closing temporary STDOUT"); 205 chk_zero(close(stdout2), "Closing temporary STDOUT");
205 } 206 }
206
207 chdir(buf);
208} 207}
209 208
210static void cgit_check_cache(struct cacheitem *item) 209static void cgit_check_cache(struct cacheitem *item)
211{ 210{
212 int i = 0; 211 int i = 0;
213 212
214 top: 213 top:
215 if (++i > ctx.cfg.max_lock_attempts) { 214 if (++i > ctx.cfg.max_lock_attempts) {
216 die("cgit_refresh_cache: unable to lock %s: %s", 215 die("cgit_refresh_cache: unable to lock %s: %s",
217 item->name, strerror(errno)); 216 item->name, strerror(errno));
218 } 217 }
219 if (!cache_exist(item)) { 218 if (!cache_exist(item)) {
220 if (!cache_lock(item)) { 219 if (!cache_lock(item)) {
221 sleep(1); 220 sleep(1);
222 goto top; 221 goto top;
223 } 222 }
224 if (!cache_exist(item)) { 223 if (!cache_exist(item)) {
225 cgit_fill_cache(item, 1); 224 cgit_fill_cache(item, 1);
226 cache_unlock(item); 225 cache_unlock(item);
227 } else { 226 } else {
228 cache_cancel_lock(item); 227 cache_cancel_lock(item);
229 } 228 }
230 } else if (cache_expired(item) && cache_lock(item)) { 229 } else if (cache_expired(item) && cache_lock(item)) {
231 if (cache_expired(item)) { 230 if (cache_expired(item)) {
232 cgit_fill_cache(item, 1); 231 cgit_fill_cache(item, 1);
233 cache_unlock(item); 232 cache_unlock(item);
234 } else { 233 } else {
235 cache_cancel_lock(item); 234 cache_cancel_lock(item);
236 } 235 }
237 } 236 }
238} 237}
239 238
240static void cgit_print_cache(struct cacheitem *item) 239static void cgit_print_cache(struct cacheitem *item)
241{ 240{
242 static char buf[4096]; 241 static char buf[4096];
243 ssize_t i; 242 ssize_t i;
244 243
245 int fd = open(item->name, O_RDONLY); 244 int fd = open(item->name, O_RDONLY);
246 if (fd<0) 245 if (fd<0)
247 die("Unable to open cached file %s", item->name); 246 die("Unable to open cached file %s", item->name);
248 247
249 while((i=read(fd, buf, sizeof(buf))) > 0) 248 while((i=read(fd, buf, sizeof(buf))) > 0)
250 write(STDOUT_FILENO, buf, i); 249 write(STDOUT_FILENO, buf, i);
251 250
252 close(fd); 251 close(fd);
253} 252}
254 253
255static void cgit_parse_args(int argc, const char **argv) 254static void cgit_parse_args(int argc, const char **argv)
256{ 255{
257 int i; 256 int i;
258 257
259 for (i = 1; i < argc; i++) { 258 for (i = 1; i < argc; i++) {
260 if (!strncmp(argv[i], "--cache=", 8)) { 259 if (!strncmp(argv[i], "--cache=", 8)) {
261 ctx.cfg.cache_root = xstrdup(argv[i]+8); 260 ctx.cfg.cache_root = xstrdup(argv[i]+8);
262 } 261 }
263 if (!strcmp(argv[i], "--nocache")) { 262 if (!strcmp(argv[i], "--nocache")) {
264 ctx.cfg.nocache = 1; 263 ctx.cfg.nocache = 1;
265 } 264 }
266 if (!strncmp(argv[i], "--query=", 8)) { 265 if (!strncmp(argv[i], "--query=", 8)) {
267 ctx.qry.raw = xstrdup(argv[i]+8); 266 ctx.qry.raw = xstrdup(argv[i]+8);
268 } 267 }
269 if (!strncmp(argv[i], "--repo=", 7)) { 268 if (!strncmp(argv[i], "--repo=", 7)) {
270 ctx.qry.repo = xstrdup(argv[i]+7); 269 ctx.qry.repo = xstrdup(argv[i]+7);
271 } 270 }
272 if (!strncmp(argv[i], "--page=", 7)) { 271 if (!strncmp(argv[i], "--page=", 7)) {
273 ctx.qry.page = xstrdup(argv[i]+7); 272 ctx.qry.page = xstrdup(argv[i]+7);
274 } 273 }
275 if (!strncmp(argv[i], "--head=", 7)) { 274 if (!strncmp(argv[i], "--head=", 7)) {
276 ctx.qry.head = xstrdup(argv[i]+7); 275 ctx.qry.head = xstrdup(argv[i]+7);
277 ctx.qry.has_symref = 1; 276 ctx.qry.has_symref = 1;
278 } 277 }
279 if (!strncmp(argv[i], "--sha1=", 7)) { 278 if (!strncmp(argv[i], "--sha1=", 7)) {
280 ctx.qry.sha1 = xstrdup(argv[i]+7); 279 ctx.qry.sha1 = xstrdup(argv[i]+7);
281 ctx.qry.has_sha1 = 1; 280 ctx.qry.has_sha1 = 1;
282 } 281 }
283 if (!strncmp(argv[i], "--ofs=", 6)) { 282 if (!strncmp(argv[i], "--ofs=", 6)) {
284 ctx.qry.ofs = atoi(argv[i]+6); 283 ctx.qry.ofs = atoi(argv[i]+6);
285 } 284 }
286 } 285 }
287} 286}
288 287
289int main(int argc, const char **argv) 288int main(int argc, const char **argv)
290{ 289{
291 struct cacheitem item; 290 struct cacheitem item;
292 const char *cgit_config_env = getenv("CGIT_CONFIG"); 291 const char *cgit_config_env = getenv("CGIT_CONFIG");
293 292
294 cgit_prepare_context(&ctx); 293 cgit_prepare_context(&ctx);
295 htmlfd = STDOUT_FILENO; 294 htmlfd = STDOUT_FILENO;
296 item.st.st_mtime = time(NULL); 295 item.st.st_mtime = time(NULL);
297 cgit_repolist.length = 0; 296 cgit_repolist.length = 0;
298 cgit_repolist.count = 0; 297 cgit_repolist.count = 0;
299 cgit_repolist.repos = NULL; 298 cgit_repolist.repos = NULL;
300 299
301 cgit_read_config(cgit_config_env ? cgit_config_env : CGIT_CONFIG, 300 cgit_read_config(cgit_config_env ? cgit_config_env : CGIT_CONFIG,
302 cgit_global_config_cb); 301 cgit_global_config_cb);
303 if (getenv("SCRIPT_NAME")) 302 if (getenv("SCRIPT_NAME"))
304 ctx.cfg.script_name = xstrdup(getenv("SCRIPT_NAME")); 303 ctx.cfg.script_name = xstrdup(getenv("SCRIPT_NAME"));
305 if (getenv("QUERY_STRING")) 304 if (getenv("QUERY_STRING"))
306 ctx.qry.raw = xstrdup(getenv("QUERY_STRING")); 305 ctx.qry.raw = xstrdup(getenv("QUERY_STRING"));
307 cgit_parse_args(argc, argv); 306 cgit_parse_args(argc, argv);
308 cgit_parse_query(ctx.qry.raw, cgit_querystring_cb); 307 cgit_parse_query(ctx.qry.raw, cgit_querystring_cb);
309 if (!cgit_prepare_cache(&item)) 308 if (!cgit_prepare_cache(&item))
310 return 0; 309 return 0;
311 if (ctx.cfg.nocache) { 310 if (ctx.cfg.nocache) {
312 cgit_fill_cache(&item, 0); 311 cgit_fill_cache(&item, 0);
313 } else { 312 } else {
314 cgit_check_cache(&item); 313 cgit_check_cache(&item);
315 cgit_print_cache(&item); 314 cgit_print_cache(&item);
316 } 315 }
317 return 0; 316 return 0;
318} 317}