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 <sys/types.h>
19 #include <sys/socket.h>
29 #include "got_error.h"
32 #include "got_compat.h"
34 #include "got_lib_dial.h"
37 #define nitems(_a) (sizeof((_a)) / sizeof((_a)[0]))
41 #define ssizeof(_x) ((ssize_t)(sizeof(_x)))
45 #define MIN(_a,_b) ((_a) < (_b) ? (_a) : (_b))
48 #ifndef GOT_DIAL_PATH_SSH
49 #define GOT_DIAL_PATH_SSH "/usr/bin/ssh"
53 #define GOT_DEFAULT_GIT_PORT 9418
54 #define GOT_DEFAULT_GIT_PORT_STR "9418"
56 const struct got_error
*
57 got_dial_apply_unveil(const char *proto
)
59 if (strcmp(proto
, "git+ssh") == 0 || strcmp(proto
, "ssh") == 0) {
60 if (unveil(GOT_DIAL_PATH_SSH
, "x") != 0) {
61 return got_error_from_errno2("unveil",
70 hassuffix(char *base
, char *suf
)
76 if (ns
<= nb
&& strcmp(base
+ (nb
- ns
), suf
) == 0)
81 const struct got_error
*
82 got_dial_parse_uri(char **proto
, char **host
, char **port
,
83 char **server_path
, char **repo_name
, const char *uri
)
85 const struct got_error
*err
= NULL
;
89 *proto
= *host
= *port
= *server_path
= *repo_name
= NULL
;
91 p
= strstr(uri
, "://");
93 /* Try parsing Git's "scp" style URL syntax. */
94 *proto
= strdup("ssh");
96 err
= got_error_from_errno("strdup");
102 err
= got_error(GOT_ERR_PARSE_URI
);
105 /* No slashes allowed before first colon. */
108 err
= got_error(GOT_ERR_PARSE_URI
);
111 *host
= strndup(s
, q
- s
);
113 err
= got_error_from_errno("strndup");
118 *proto
= strndup(uri
, p
- uri
);
120 err
= got_error_from_errno("strndup");
126 if (p
== NULL
|| strlen(p
) == 1) {
127 err
= got_error(GOT_ERR_PARSE_URI
);
131 q
= memchr(s
, ':', p
- s
);
133 *host
= strndup(s
, q
- s
);
135 err
= got_error_from_errno("strndup");
138 *port
= strndup(q
+ 1, p
- (q
+ 1));
140 err
= got_error_from_errno("strndup");
144 *host
= strndup(s
, p
- s
);
146 err
= got_error_from_errno("strndup");
152 while (p
[0] == '/' && p
[1] == '/')
154 *server_path
= strdup(p
);
155 if (*server_path
== NULL
) {
156 err
= got_error_from_errno("strdup");
159 got_path_strip_trailing_slashes(*server_path
);
162 if (!p
|| strlen(p
) <= 1) {
163 err
= got_error(GOT_ERR_PARSE_URI
);
169 err
= got_error(GOT_ERR_PARSE_URI
);
172 if (hassuffix(p
, ".git"))
174 *repo_name
= strndup(p
, (p
+ n
) - p
);
175 if (*repo_name
== NULL
) {
176 err
= got_error_from_errno("strndup");
195 const struct got_error
*
196 got_dial_ssh(pid_t
*newpid
, int *newfd
, const char *host
,
197 const char *port
, const char *path
, const char *direction
, int verbosity
)
199 const struct got_error
*error
= NULL
;
208 argv
[i
++] = GOT_DIAL_PATH_SSH
;
211 argv
[i
++] = (char *)port
;
213 if (verbosity
== -1) {
216 /* ssh(1) allows up to 3 "-v" options. */
217 for (j
= 0; j
< MIN(3, verbosity
); j
++)
221 argv
[i
++] = (char *)host
;
222 argv
[i
++] = (char *)cmd
;
223 argv
[i
++] = (char *)path
;
225 assert(i
<= nitems(argv
));
227 if (socketpair(AF_UNIX
, SOCK_STREAM
, PF_UNSPEC
, pfd
) == -1)
228 return got_error_from_errno("socketpair");
232 error
= got_error_from_errno("fork");
236 } else if (pid
== 0) {
238 if (close(pfd
[1]) == -1)
240 if (dup2(pfd
[0], 0) == -1)
242 if (dup2(pfd
[0], 1) == -1)
244 n
= snprintf(cmd
, sizeof(cmd
), "git-%s-pack", direction
);
245 if (n
< 0 || n
>= ssizeof(cmd
))
247 if (execv(GOT_DIAL_PATH_SSH
, argv
) == -1)
249 abort(); /* not reached */
251 if (close(pfd
[0]) == -1)
252 return got_error_from_errno("close");
259 const struct got_error
*
260 got_dial_git(int *newfd
, const char *host
, const char *port
,
261 const char *path
, const char *direction
)
263 const struct got_error
*err
= NULL
;
264 struct addrinfo hints
, *servinfo
, *p
;
266 int fd
= -1, len
, r
, eaicode
;
271 port
= GOT_DEFAULT_GIT_PORT_STR
;
273 memset(&hints
, 0, sizeof hints
);
274 hints
.ai_family
= AF_UNSPEC
;
275 hints
.ai_socktype
= SOCK_STREAM
;
276 eaicode
= getaddrinfo(host
, port
, &hints
, &servinfo
);
279 snprintf(msg
, sizeof(msg
), "%s: %s", host
,
280 gai_strerror(eaicode
));
281 return got_error_msg(GOT_ERR_ADDRINFO
, msg
);
284 for (p
= servinfo
; p
!= NULL
; p
= p
->ai_next
) {
285 if ((fd
= socket(p
->ai_family
, p
->ai_socktype
,
286 p
->ai_protocol
)) == -1)
288 if (connect(fd
, p
->ai_addr
, p
->ai_addrlen
) == 0) {
292 err
= got_error_from_errno("connect");
298 if (asprintf(&cmd
, "git-%s-pack %s", direction
, path
) == -1) {
299 err
= got_error_from_errno("asprintf");
302 len
= 4 + strlen(cmd
) + 1 + strlen("host=") + strlen(host
) + 1;
303 r
= dprintf(fd
, "%04x%s%chost=%s%c", len
, cmd
, '\0', host
, '\0');
305 err
= got_error_from_errno("dprintf");