2 * Copyright (c) 2018, 2019 Ori Bernstein <ori@openbsd.org>
3 * Copyright (c) 2021 Stefan Sperling <stsp@openbsd.org>
5 * Permission to use, copy, modify, and distribute this software for any
6 * purpose with or without fee is hereby granted, provided that the above
7 * copyright notice and this permission notice appear in all copies.
9 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
10 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
11 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
12 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
13 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
14 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
15 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
18 #include "got_compat.h"
20 #include <sys/queue.h>
21 #include <sys/types.h>
22 #include <sys/socket.h>
32 #include "got_error.h"
35 #include "got_compat.h"
37 #include "got_lib_dial.h"
41 #define nitems(_a) (sizeof((_a)) / sizeof((_a)[0]))
45 #define ssizeof(_x) ((ssize_t)(sizeof(_x)))
49 #define MIN(_a,_b) ((_a) < (_b) ? (_a) : (_b))
52 #ifndef GOT_DIAL_PATH_SSH
53 #define GOT_DIAL_PATH_SSH "/usr/bin/ssh"
57 #define GOT_DEFAULT_GIT_PORT 9418
58 #define GOT_DEFAULT_GIT_PORT_STR "9418"
60 const struct got_error *
61 got_dial_apply_unveil(const char *proto)
63 if (strcmp(proto, "git+ssh") == 0 || strcmp(proto, "ssh") == 0) {
64 if (unveil(GOT_DIAL_PATH_SSH, "x") != 0) {
65 return got_error_from_errno2("unveil",
74 hassuffix(const char *base, const char *suf)
80 if (ns <= nb && strcmp(base + (nb - ns), suf) == 0)
85 const struct got_error *
86 got_dial_parse_uri(char **proto, char **host, char **port,
87 char **server_path, char **repo_name, const char *uri)
89 const struct got_error *err = NULL;
92 *proto = *host = *port = *server_path = *repo_name = NULL;
94 p = strstr(uri, "://");
96 /* Try parsing Git's "scp" style URL syntax. */
97 *proto = strdup("ssh");
99 err = got_error_from_errno("strdup");
105 err = got_error(GOT_ERR_PARSE_URI);
108 /* No slashes allowed before first colon. */
111 err = got_error(GOT_ERR_PARSE_URI);
114 *host = strndup(s, q - s);
116 err = got_error_from_errno("strndup");
119 if ((*host)[0] == '\0') {
120 err = got_error(GOT_ERR_PARSE_URI);
125 *proto = strndup(uri, p - uri);
126 if (*proto == NULL) {
127 err = got_error_from_errno("strndup");
133 if (p == NULL || strlen(p) == 1) {
134 err = got_error(GOT_ERR_PARSE_URI);
138 q = memchr(s, ':', p - s);
140 *host = strndup(s, q - s);
142 err = got_error_from_errno("strndup");
145 if ((*host)[0] == '\0') {
146 err = got_error(GOT_ERR_PARSE_URI);
149 *port = strndup(q + 1, p - (q + 1));
151 err = got_error_from_errno("strndup");
154 if ((*port)[0] == '\0') {
155 err = got_error(GOT_ERR_PARSE_URI);
159 *host = strndup(s, p - s);
161 err = got_error_from_errno("strndup");
164 if ((*host)[0] == '\0') {
165 err = got_error(GOT_ERR_PARSE_URI);
171 while (p[0] == '/' && p[1] == '/')
173 *server_path = strdup(p);
174 if (*server_path == NULL) {
175 err = got_error_from_errno("strdup");
178 got_path_strip_trailing_slashes(*server_path);
179 if ((*server_path)[0] == '\0') {
180 err = got_error(GOT_ERR_PARSE_URI);
184 err = got_path_basename(repo_name, *server_path);
187 if (hassuffix(*repo_name, ".git"))
188 (*repo_name)[strlen(*repo_name) - 4] = '\0';
189 if ((*repo_name)[0] == '\0')
190 err = got_error(GOT_ERR_PARSE_URI);
207 const struct got_error *
208 got_dial_ssh(pid_t *newpid, int *newfd, const char *host,
209 const char *port, const char *path, const char *direction, int verbosity)
211 const struct got_error *error = NULL;
214 const char *argv[11];
220 argv[i++] = GOT_DIAL_PATH_SSH;
223 argv[i++] = (char *)port;
225 if (verbosity == -1) {
228 /* ssh(1) allows up to 3 "-v" options. */
229 for (j = 0; j < MIN(3, verbosity); j++)
233 argv[i++] = (char *)host;
234 argv[i++] = (char *)cmd;
235 argv[i++] = (char *)path;
237 assert(i <= nitems(argv));
239 if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, pfd) == -1)
240 return got_error_from_errno("socketpair");
244 error = got_error_from_errno("fork");
248 } else if (pid == 0) {
250 if (close(pfd[1]) == -1)
252 if (dup2(pfd[0], 0) == -1)
254 if (dup2(pfd[0], 1) == -1)
256 n = snprintf(cmd, sizeof(cmd), "git-%s-pack", direction);
257 if (n < 0 || n >= ssizeof(cmd))
259 if (execv(GOT_DIAL_PATH_SSH, (char *const *)argv) == -1)
261 abort(); /* not reached */
263 if (close(pfd[0]) == -1)
264 return got_error_from_errno("close");
271 const struct got_error *
272 got_dial_git(int *newfd, const char *host, const char *port,
273 const char *path, const char *direction)
275 const struct got_error *err = NULL;
276 struct addrinfo hints, *servinfo, *p;
278 int fd = -1, len, r, eaicode;
283 port = GOT_DEFAULT_GIT_PORT_STR;
285 memset(&hints, 0, sizeof hints);
286 hints.ai_family = AF_UNSPEC;
287 hints.ai_socktype = SOCK_STREAM;
288 eaicode = getaddrinfo(host, port, &hints, &servinfo);
291 snprintf(msg, sizeof(msg), "%s: %s", host,
292 gai_strerror(eaicode));
293 return got_error_msg(GOT_ERR_ADDRINFO, msg);
296 for (p = servinfo; p != NULL; p = p->ai_next) {
297 if ((fd = socket(p->ai_family, p->ai_socktype,
298 p->ai_protocol)) == -1)
300 if (connect(fd, p->ai_addr, p->ai_addrlen) == 0) {
304 err = got_error_from_errno("connect");
307 freeaddrinfo(servinfo);
311 if (asprintf(&cmd, "git-%s-pack %s", direction, path) == -1) {
312 err = got_error_from_errno("asprintf");
315 len = 4 + strlen(cmd) + 1 + strlen("host=") + strlen(host) + 1;
316 r = dprintf(fd, "%04x%s%chost=%s%c", len, cmd, '\0', host, '\0');
318 err = got_error_from_errno("dprintf");