zip apparently gives a warning (`-l used on binary file') when you
[u/mdw/putty] / psftp.c
CommitLineData
4c7f0d61 1/*
f4ff9455 2 * psftp.c: (platform-independent) front end for PSFTP.
4c7f0d61 3 */
4
5#include <stdio.h>
6#include <stdlib.h>
f9e162aa 7#include <stdarg.h>
4c7f0d61 8#include <assert.h>
d92624dc 9#include <limits.h>
4c7f0d61 10
4a8fc3c4 11#define PUTTY_DO_GLOBALS
12#include "putty.h"
d6cc41e6 13#include "psftp.h"
4a8fc3c4 14#include "storage.h"
15#include "ssh.h"
4c7f0d61 16#include "sftp.h"
17#include "int64.h"
18
5471d09a 19/*
20 * Since SFTP is a request-response oriented protocol, it requires
21 * no buffer management: when we send data, we stop and wait for an
22 * acknowledgement _anyway_, and so we can't possibly overfill our
23 * send buffer.
24 */
25
fa3db767 26static int psftp_connect(char *userhost, char *user, int portnumber);
07534184 27static int do_sftp_init(void);
679539d7 28void do_sftp_cleanup();
fa3db767 29
4c7f0d61 30/* ----------------------------------------------------------------------
4c7f0d61 31 * sftp client state.
32 */
33
34char *pwd, *homedir;
6b78788a 35static Backend *back;
36static void *backhandle;
3ea863a3 37static Config cfg;
4c7f0d61 38
39/* ----------------------------------------------------------------------
40 * Higher-level helper functions used in commands.
41 */
42
43/*
f9e162aa 44 * Attempt to canonify a pathname starting from the pwd. If
45 * canonification fails, at least fall back to returning a _valid_
46 * pathname (though it may be ugly, eg /home/simon/../foobar).
4c7f0d61 47 */
32874aea 48char *canonify(char *name)
49{
f9e162aa 50 char *fullname, *canonname;
1bc24185 51 struct sftp_packet *pktin;
52 struct sftp_request *req, *rreq;
4a8fc3c4 53
f9e162aa 54 if (name[0] == '/') {
55 fullname = dupstr(name);
56 } else {
4a8fc3c4 57 char *slash;
32874aea 58 if (pwd[strlen(pwd) - 1] == '/')
4a8fc3c4 59 slash = "";
60 else
61 slash = "/";
62 fullname = dupcat(pwd, slash, name, NULL);
f9e162aa 63 }
4a8fc3c4 64
1bc24185 65 sftp_register(req = fxp_realpath_send(fullname));
66 rreq = sftp_find_request(pktin = sftp_recv());
67 assert(rreq == req);
7b7de4f4 68 canonname = fxp_realpath_recv(pktin, rreq);
4a8fc3c4 69
f9e162aa 70 if (canonname) {
71 sfree(fullname);
72 return canonname;
50d7e054 73 } else {
32874aea 74 /*
75 * Attempt number 2. Some FXP_REALPATH implementations
76 * (glibc-based ones, in particular) require the _whole_
77 * path to point to something that exists, whereas others
78 * (BSD-based) only require all but the last component to
79 * exist. So if the first call failed, we should strip off
80 * everything from the last slash onwards and try again,
81 * then put the final component back on.
82 *
83 * Special cases:
84 *
85 * - if the last component is "/." or "/..", then we don't
86 * bother trying this because there's no way it can work.
87 *
88 * - if the thing actually ends with a "/", we remove it
89 * before we start. Except if the string is "/" itself
90 * (although I can't see why we'd have got here if so,
91 * because surely "/" would have worked the first
92 * time?), in which case we don't bother.
93 *
94 * - if there's no slash in the string at all, give up in
95 * confusion (we expect at least one because of the way
96 * we constructed the string).
97 */
98
99 int i;
100 char *returnname;
101
102 i = strlen(fullname);
103 if (i > 2 && fullname[i - 1] == '/')
104 fullname[--i] = '\0'; /* strip trailing / unless at pos 0 */
105 while (i > 0 && fullname[--i] != '/');
106
107 /*
108 * Give up on special cases.
109 */
110 if (fullname[i] != '/' || /* no slash at all */
111 !strcmp(fullname + i, "/.") || /* ends in /. */
112 !strcmp(fullname + i, "/..") || /* ends in /.. */
113 !strcmp(fullname, "/")) {
114 return fullname;
115 }
116
117 /*
118 * Now i points at the slash. Deal with the final special
119 * case i==0 (ie the whole path was "/nonexistentfile").
120 */
121 fullname[i] = '\0'; /* separate the string */
122 if (i == 0) {
1bc24185 123 sftp_register(req = fxp_realpath_send("/"));
32874aea 124 } else {
1bc24185 125 sftp_register(req = fxp_realpath_send(fullname));
32874aea 126 }
1bc24185 127 rreq = sftp_find_request(pktin = sftp_recv());
128 assert(rreq == req);
7b7de4f4 129 canonname = fxp_realpath_recv(pktin, rreq);
32874aea 130
131 if (!canonname)
132 return fullname; /* even that failed; give up */
133
134 /*
135 * We have a canonical name for all but the last path
136 * component. Concatenate the last component and return.
137 */
138 returnname = dupcat(canonname,
139 canonname[strlen(canonname) - 1] ==
140 '/' ? "" : "/", fullname + i + 1, NULL);
141 sfree(fullname);
142 sfree(canonname);
143 return returnname;
50d7e054 144 }
4c7f0d61 145}
146
dcf8495c 147/*
148 * Return a pointer to the portion of str that comes after the last
149 * slash (or backslash or colon, if `local' is TRUE).
150 */
151static char *stripslashes(char *str, int local)
152{
153 char *p;
154
155 if (local) {
156 p = strchr(str, ':');
157 if (p) str = p+1;
158 }
159
160 p = strrchr(str, '/');
161 if (p) str = p+1;
162
163 if (local) {
164 p = strrchr(str, '\\');
165 if (p) str = p+1;
166 }
167
168 return str;
169}
170
4c7f0d61 171/*
93e86a8b 172 * qsort comparison routine for fxp_name structures. Sorts by real
173 * file name.
4c7f0d61 174 */
93e86a8b 175static int sftp_name_compare(const void *av, const void *bv)
32874aea 176{
7d2c1789 177 const struct fxp_name *const *a = (const struct fxp_name *const *) av;
178 const struct fxp_name *const *b = (const struct fxp_name *const *) bv;
179 return strcmp((*a)->filename, (*b)->filename);
4c7f0d61 180}
4c7f0d61 181
182/*
93e86a8b 183 * Likewise, but for a bare char *.
4f2b387f 184 */
93e86a8b 185static int bare_name_compare(const void *av, const void *bv)
4f2b387f 186{
93e86a8b 187 const char **a = (const char **) av;
188 const char **b = (const char **) bv;
189 return strcmp(*a, *b);
4f2b387f 190}
191
93e86a8b 192/* ----------------------------------------------------------------------
193 * The meat of the `get' and `put' commands.
4c7f0d61 194 */
9c77ddf6 195int sftp_get_file(char *fname, char *outfname, int recurse, int restart,
196 char *wildcard)
32874aea 197{
4c7f0d61 198 struct fxp_handle *fh;
1bc24185 199 struct sftp_packet *pktin;
200 struct sftp_request *req, *rreq;
c606c42d 201 struct fxp_xfer *xfer;
4c7f0d61 202 uint64 offset;
203 FILE *fp;
479fe1ba 204 int ret, shown_err = FALSE;
4c7f0d61 205
93e86a8b 206 /*
207 * In recursive mode, see if we're dealing with a directory.
208 * (If we're not in recursive mode, we need not even check: the
209 * subsequent FXP_OPEN will return a usable error message.)
210 */
9c77ddf6 211 if (wildcard || recurse) {
93e86a8b 212 struct fxp_attrs attrs;
213 int result;
fa3db767 214
9c77ddf6 215 if (!wildcard) {
216 sftp_register(req = fxp_stat_send(fname));
217 rreq = sftp_find_request(pktin = sftp_recv());
218 assert(rreq == req);
219 result = fxp_stat_recv(pktin, rreq, &attrs);
220 } else
221 result = 0; /* placate optimisers */
222
223 if (wildcard ||
224 (result &&
225 (attrs.flags & SSH_FILEXFER_ATTR_PERMISSIONS) &&
226 (attrs.permissions & 0040000))) {
93e86a8b 227
228 struct fxp_handle *dirhandle;
229 int nnames, namesize;
230 struct fxp_name **ournames;
231 struct fxp_names *names;
232 int i;
233
234 /*
235 * First, attempt to create the destination directory,
9c77ddf6 236 * unless it already exists (or this is a wildcard
237 * run).
93e86a8b 238 */
9c77ddf6 239 if (!wildcard &&
240 file_type(outfname) != FILE_TYPE_DIRECTORY &&
93e86a8b 241 !create_directory(outfname)) {
242 printf("%s: Cannot create directory\n", outfname);
243 return 0;
244 }
4c7f0d61 245
93e86a8b 246 /*
247 * Now get the list of filenames in the remote
248 * directory.
249 */
250 sftp_register(req = fxp_opendir_send(fname));
251 rreq = sftp_find_request(pktin = sftp_recv());
252 assert(rreq == req);
253 dirhandle = fxp_opendir_recv(pktin, rreq);
254
255 if (!dirhandle) {
256 printf("%s: unable to open directory: %s\n",
257 fname, fxp_error());
258 return 0;
259 }
260 nnames = namesize = 0;
261 ournames = NULL;
262 while (1) {
263 int i;
264
265 sftp_register(req = fxp_readdir_send(dirhandle));
266 rreq = sftp_find_request(pktin = sftp_recv());
267 assert(rreq == req);
268 names = fxp_readdir_recv(pktin, rreq);
269
270 if (names == NULL) {
271 if (fxp_error_type() == SSH_FX_EOF)
272 break;
273 printf("%s: reading directory: %s\n", fname, fxp_error());
274 sfree(ournames);
275 return 0;
276 }
277 if (names->nnames == 0) {
278 fxp_free_names(names);
279 break;
280 }
281 if (nnames + names->nnames >= namesize) {
282 namesize += names->nnames + 128;
283 ournames = sresize(ournames, namesize, struct fxp_name *);
284 }
285 for (i = 0; i < names->nnames; i++)
e9d14678 286 if (strcmp(names->names[i].filename, ".") &&
287 strcmp(names->names[i].filename, "..") &&
9c77ddf6 288 (!wildcard || wc_match(wildcard,
e9d14678 289 names->names[i].filename))) {
290 if (!vet_filename(names->names[i].filename)) {
291 printf("ignoring potentially dangerous server-"
292 "supplied filename '%s'\n",
293 names->names[i].filename);
294 } else {
295 ournames[nnames++] =
296 fxp_dup_name(&names->names[i]);
297 }
298 }
93e86a8b 299 fxp_free_names(names);
300 }
301 sftp_register(req = fxp_close_send(dirhandle));
302 rreq = sftp_find_request(pktin = sftp_recv());
303 assert(rreq == req);
304 fxp_close_recv(pktin, rreq);
305
306 /*
9c77ddf6 307 * A polite warning if nothing at all matched the
308 * wildcard.
309 */
310 if (wildcard && !nnames) {
311 printf("%s: nothing matched\n", wildcard);
312 }
313
314 /*
93e86a8b 315 * Sort the names into a clear order. This ought to
316 * make things more predictable when we're doing a
317 * reget of the same directory, just in case two
318 * readdirs on the same remote directory return a
319 * different order.
320 */
321 qsort(ournames, nnames, sizeof(*ournames), sftp_name_compare);
322
323 /*
324 * If we're in restart mode, find the last filename on
325 * this list that already exists. We may have to do a
326 * reget on _that_ file, but shouldn't have to do
327 * anything on the previous files.
328 *
329 * If none of them exists, of course, we start at 0.
330 */
331 i = 0;
332 while (i < nnames) {
333 char *nextoutfname;
334 int ret;
9c77ddf6 335 if (outfname)
336 nextoutfname = dir_file_cat(outfname,
337 ournames[i]->filename);
338 else
339 nextoutfname = dupstr(ournames[i]->filename);
93e86a8b 340 ret = (file_type(nextoutfname) == FILE_TYPE_NONEXISTENT);
341 sfree(nextoutfname);
342 if (ret)
343 break;
344 i++;
345 }
346 if (i > 0)
347 i--;
348
349 /*
350 * Now we're ready to recurse. Starting at ournames[i]
351 * and continuing on to the end of the list, we
352 * construct a new source and target file name, and
353 * call sftp_get_file again.
354 */
355 for (; i < nnames; i++) {
356 char *nextfname, *nextoutfname;
357 int ret;
358
359 nextfname = dupcat(fname, "/", ournames[i]->filename, NULL);
9c77ddf6 360 if (outfname)
361 nextoutfname = dir_file_cat(outfname,
362 ournames[i]->filename);
363 else
364 nextoutfname = dupstr(ournames[i]->filename);
365 ret = sftp_get_file(nextfname, nextoutfname,
366 recurse, restart, NULL);
93e86a8b 367 restart = FALSE; /* after first partial file, do full */
368 sfree(nextoutfname);
369 sfree(nextfname);
370 if (!ret) {
371 for (i = 0; i < nnames; i++) {
372 fxp_free_name(ournames[i]);
373 }
374 sfree(ournames);
375 return 0;
376 }
377 }
378
379 /*
380 * Done this recursion level. Free everything.
381 */
382 for (i = 0; i < nnames; i++) {
383 fxp_free_name(ournames[i]);
384 }
385 sfree(ournames);
386
387 return 1;
388 }
4c7f0d61 389 }
4c7f0d61 390
1bc24185 391 sftp_register(req = fxp_open_send(fname, SSH_FXF_READ));
392 rreq = sftp_find_request(pktin = sftp_recv());
393 assert(rreq == req);
7b7de4f4 394 fh = fxp_open_recv(pktin, rreq);
1bc24185 395
4c7f0d61 396 if (!fh) {
397 printf("%s: %s\n", fname, fxp_error());
4c7f0d61 398 return 0;
399 }
d92624dc 400
401 if (restart) {
402 fp = fopen(outfname, "rb+");
403 } else {
404 fp = fopen(outfname, "wb");
405 }
406
4c7f0d61 407 if (!fp) {
408 printf("local: unable to open %s\n", outfname);
1bc24185 409
410 sftp_register(req = fxp_close_send(fh));
411 rreq = sftp_find_request(pktin = sftp_recv());
412 assert(rreq == req);
7b7de4f4 413 fxp_close_recv(pktin, rreq);
1bc24185 414
4c7f0d61 415 return 0;
416 }
417
d92624dc 418 if (restart) {
419 long posn;
420 fseek(fp, 0L, SEEK_END);
421 posn = ftell(fp);
422 printf("reget: restarting at file position %ld\n", posn);
423 offset = uint64_make(0, posn);
424 } else {
425 offset = uint64_make(0, 0);
426 }
4c7f0d61 427
d92624dc 428 printf("remote:%s => local:%s\n", fname, outfname);
4c7f0d61 429
430 /*
431 * FIXME: we can use FXP_FSTAT here to get the file size, and
432 * thus put up a progress bar.
433 */
df49ff19 434 ret = 1;
c606c42d 435 xfer = xfer_download_init(fh, offset);
df0870fc 436 while (!xfer_done(xfer)) {
c606c42d 437 void *vbuf;
438 int ret, len;
4c7f0d61 439 int wpos, wlen;
440
c606c42d 441 xfer_download_queue(xfer);
442 pktin = sftp_recv();
443 ret = xfer_download_gotpkt(xfer, pktin);
444
445 if (ret < 0) {
479fe1ba 446 if (!shown_err) {
447 printf("error while reading: %s\n", fxp_error());
448 shown_err = TRUE;
449 }
c606c42d 450 ret = 0;
4c7f0d61 451 }
32874aea 452
c606c42d 453 while (xfer_download_data(xfer, &vbuf, &len)) {
454 unsigned char *buf = (unsigned char *)vbuf;
455
456 wpos = 0;
457 while (wpos < len) {
458 wlen = fwrite(buf + wpos, 1, len - wpos, fp);
459 if (wlen <= 0) {
460 printf("error while writing local file\n");
461 ret = 0;
462 xfer_set_error(xfer);
463 }
464 wpos += wlen;
465 }
466 if (wpos < len) { /* we had an error */
df49ff19 467 ret = 0;
c606c42d 468 xfer_set_error(xfer);
4c7f0d61 469 }
9ff4e23d 470
471 sfree(vbuf);
df49ff19 472 }
4c7f0d61 473 }
474
c606c42d 475 xfer_cleanup(xfer);
476
4c7f0d61 477 fclose(fp);
1bc24185 478
479 sftp_register(req = fxp_close_send(fh));
480 rreq = sftp_find_request(pktin = sftp_recv());
481 assert(rreq == req);
7b7de4f4 482 fxp_close_recv(pktin, rreq);
1bc24185 483
df49ff19 484 return ret;
4c7f0d61 485}
486
9c77ddf6 487int sftp_put_file(char *fname, char *outfname, int recurse, int restart,
488 char *wildcard)
32874aea 489{
4c7f0d61 490 struct fxp_handle *fh;
df0870fc 491 struct fxp_xfer *xfer;
1bc24185 492 struct sftp_packet *pktin;
493 struct sftp_request *req, *rreq;
4c7f0d61 494 uint64 offset;
495 FILE *fp;
df0870fc 496 int ret, err, eof;
4c7f0d61 497
93e86a8b 498 /*
499 * In recursive mode, see if we're dealing with a directory.
500 * (If we're not in recursive mode, we need not even check: the
501 * subsequent fopen will return an error message.)
502 */
9c77ddf6 503 if (wildcard || (recurse && file_type(fname) == FILE_TYPE_DIRECTORY)) {
93e86a8b 504 struct fxp_attrs attrs;
505 int result;
506 int nnames, namesize;
507 char *name, **ournames;
508 DirHandle *dh;
509 int i;
4c7f0d61 510
9c77ddf6 511 if (!wildcard) {
512 /*
513 * First, attempt to create the destination directory,
514 * unless it already exists.
515 */
516 sftp_register(req = fxp_stat_send(outfname));
93e86a8b 517 rreq = sftp_find_request(pktin = sftp_recv());
518 assert(rreq == req);
9c77ddf6 519 result = fxp_stat_recv(pktin, rreq, &attrs);
520 if (!result ||
521 !(attrs.flags & SSH_FILEXFER_ATTR_PERMISSIONS) ||
522 !(attrs.permissions & 0040000)) {
523 sftp_register(req = fxp_mkdir_send(outfname));
524 rreq = sftp_find_request(pktin = sftp_recv());
525 assert(rreq == req);
526 result = fxp_mkdir_recv(pktin, rreq);
93e86a8b 527
9c77ddf6 528 if (!result) {
529 printf("%s: create directory: %s\n",
530 outfname, fxp_error());
531 return 0;
532 }
93e86a8b 533 }
534 }
535
536 /*
537 * Now get the list of filenames in the local directory.
538 */
93e86a8b 539 nnames = namesize = 0;
540 ournames = NULL;
9c77ddf6 541 if (wildcard) {
542 WildcardMatcher *wcm;
543
544 wcm = begin_wildcard_matching(wildcard);
545 if (wcm) {
546 while ((name = wildcard_get_filename(wcm)) != NULL) {
547 if (nnames >= namesize) {
548 namesize += 128;
549 ournames = sresize(ournames, namesize, char *);
550 }
551 ournames[nnames++] = name;
552 }
553 finish_wildcard_matching(wcm);
93e86a8b 554 }
9c77ddf6 555 } else {
556 dh = open_directory(fname);
557 if (!dh) {
558 printf("%s: unable to open directory\n", fname);
559 return 0;
560 }
561 while ((name = read_filename(dh)) != NULL) {
562 if (nnames >= namesize) {
563 namesize += 128;
564 ournames = sresize(ournames, namesize, char *);
565 }
566 ournames[nnames++] = name;
567 }
568 close_directory(dh);
569 }
570
571 /*
572 * A polite warning if nothing at all matched the
573 * wildcard.
574 */
575 if (wildcard && !nnames) {
576 printf("%s: nothing matched\n", wildcard);
93e86a8b 577 }
93e86a8b 578
579 /*
580 * Sort the names into a clear order. This ought to make
581 * things more predictable when we're doing a reput of the
582 * same directory, just in case two readdirs on the same
583 * local directory return a different order.
584 */
585 qsort(ournames, nnames, sizeof(*ournames), bare_name_compare);
586
587 /*
588 * If we're in restart mode, find the last filename on this
589 * list that already exists. We may have to do a reput on
590 * _that_ file, but shouldn't have to do anything on the
591 * previous files.
592 *
593 * If none of them exists, of course, we start at 0.
594 */
595 i = 0;
596 while (i < nnames) {
597 char *nextoutfname;
598 nextoutfname = dupcat(outfname, "/", ournames[i], NULL);
599 sftp_register(req = fxp_stat_send(nextoutfname));
600 rreq = sftp_find_request(pktin = sftp_recv());
601 assert(rreq == req);
602 result = fxp_stat_recv(pktin, rreq, &attrs);
603 sfree(nextoutfname);
604 if (!result)
605 break;
606 i++;
607 }
608 if (i > 0)
609 i--;
610
611 /*
612 * Now we're ready to recurse. Starting at ournames[i]
613 * and continuing on to the end of the list, we
614 * construct a new source and target file name, and
615 * call sftp_put_file again.
616 */
617 for (; i < nnames; i++) {
618 char *nextfname, *nextoutfname;
619 int ret;
620
9c77ddf6 621 if (fname)
622 nextfname = dir_file_cat(fname, ournames[i]);
623 else
624 nextfname = dupstr(ournames[i]);
93e86a8b 625 nextoutfname = dupcat(outfname, "/", ournames[i], NULL);
9c77ddf6 626 ret = sftp_put_file(nextfname, nextoutfname,
627 recurse, restart, NULL);
93e86a8b 628 restart = FALSE; /* after first partial file, do full */
629 sfree(nextoutfname);
630 sfree(nextfname);
631 if (!ret) {
632 for (i = 0; i < nnames; i++) {
633 sfree(ournames[i]);
634 }
635 sfree(ournames);
636 return 0;
637 }
638 }
639
640 /*
641 * Done this recursion level. Free everything.
642 */
643 for (i = 0; i < nnames; i++) {
644 sfree(ournames[i]);
645 }
646 sfree(ournames);
647
648 return 1;
4c7f0d61 649 }
650
651 fp = fopen(fname, "rb");
652 if (!fp) {
653 printf("local: unable to open %s\n", fname);
4c7f0d61 654 return 0;
655 }
d92624dc 656 if (restart) {
1bc24185 657 sftp_register(req = fxp_open_send(outfname, SSH_FXF_WRITE));
d92624dc 658 } else {
1bc24185 659 sftp_register(req = fxp_open_send(outfname, SSH_FXF_WRITE |
660 SSH_FXF_CREAT | SSH_FXF_TRUNC));
d92624dc 661 }
1bc24185 662 rreq = sftp_find_request(pktin = sftp_recv());
663 assert(rreq == req);
7b7de4f4 664 fh = fxp_open_recv(pktin, rreq);
1bc24185 665
4c7f0d61 666 if (!fh) {
667 printf("%s: %s\n", outfname, fxp_error());
4c7f0d61 668 return 0;
669 }
670
d92624dc 671 if (restart) {
672 char decbuf[30];
673 struct fxp_attrs attrs;
1bc24185 674 int ret;
675
676 sftp_register(req = fxp_fstat_send(fh));
677 rreq = sftp_find_request(pktin = sftp_recv());
678 assert(rreq == req);
7b7de4f4 679 ret = fxp_fstat_recv(pktin, rreq, &attrs);
1bc24185 680
681 if (!ret) {
d92624dc 682 printf("read size of %s: %s\n", outfname, fxp_error());
d92624dc 683 return 0;
684 }
685 if (!(attrs.flags & SSH_FILEXFER_ATTR_SIZE)) {
686 printf("read size of %s: size was not given\n", outfname);
d92624dc 687 return 0;
688 }
689 offset = attrs.size;
690 uint64_decimal(offset, decbuf);
691 printf("reput: restarting at file position %s\n", decbuf);
692 if (uint64_compare(offset, uint64_make(0, LONG_MAX)) > 0) {
693 printf("reput: remote file is larger than we can deal with\n");
d92624dc 694 return 0;
695 }
696 if (fseek(fp, offset.lo, SEEK_SET) != 0)
697 fseek(fp, 0, SEEK_END); /* *shrug* */
698 } else {
699 offset = uint64_make(0, 0);
700 }
4c7f0d61 701
d92624dc 702 printf("local:%s => remote:%s\n", fname, outfname);
4c7f0d61 703
704 /*
705 * FIXME: we can use FXP_FSTAT here to get the file size, and
706 * thus put up a progress bar.
707 */
df49ff19 708 ret = 1;
df0870fc 709 xfer = xfer_upload_init(fh, offset);
710 err = eof = 0;
711 while ((!err && !eof) || !xfer_done(xfer)) {
4c7f0d61 712 char buffer[4096];
1bc24185 713 int len, ret;
4c7f0d61 714
df0870fc 715 while (xfer_upload_ready(xfer) && !err && !eof) {
716 len = fread(buffer, 1, sizeof(buffer), fp);
717 if (len == -1) {
718 printf("error while reading local file\n");
719 err = 1;
720 } else if (len == 0) {
721 eof = 1;
722 } else {
723 xfer_upload_data(xfer, buffer, len);
724 }
4c7f0d61 725 }
1bc24185 726
2dbd915a 727 if (!xfer_done(xfer)) {
728 pktin = sftp_recv();
729 ret = xfer_upload_gotpkt(xfer, pktin);
730 if (!ret) {
731 printf("error while writing: %s\n", fxp_error());
732 err = 1;
733 }
4c7f0d61 734 }
4c7f0d61 735 }
736
df0870fc 737 xfer_cleanup(xfer);
738
1bc24185 739 sftp_register(req = fxp_close_send(fh));
740 rreq = sftp_find_request(pktin = sftp_recv());
741 assert(rreq == req);
7b7de4f4 742 fxp_close_recv(pktin, rreq);
1bc24185 743
4c7f0d61 744 fclose(fp);
93e86a8b 745
746 return ret;
747}
748
749/* ----------------------------------------------------------------------
750 * Actual sftp commands.
751 */
752struct sftp_command {
753 char **words;
754 int nwords, wordssize;
755 int (*obey) (struct sftp_command *); /* returns <0 to quit */
756};
757
758int sftp_cmd_null(struct sftp_command *cmd)
759{
760 return 1; /* success */
761}
762
763int sftp_cmd_unknown(struct sftp_command *cmd)
764{
765 printf("psftp: unknown command \"%s\"\n", cmd->words[0]);
766 return 0; /* failure */
767}
768
769int sftp_cmd_quit(struct sftp_command *cmd)
770{
771 return -1;
772}
773
b614ce89 774int sftp_cmd_close(struct sftp_command *cmd)
775{
776 if (back == NULL) {
777 printf("psftp: not connected to a host; use \"open host.name\"\n");
778 return 0;
779 }
780
781 if (back != NULL && back->socket(backhandle) != NULL) {
782 char ch;
783 back->special(backhandle, TS_EOF);
784 sftp_recvdata(&ch, 1);
785 }
786 do_sftp_cleanup();
787
788 return 0;
789}
790
93e86a8b 791/*
792 * List a directory. If no arguments are given, list pwd; otherwise
793 * list the directory given in words[1].
794 */
795int sftp_cmd_ls(struct sftp_command *cmd)
796{
797 struct fxp_handle *dirh;
798 struct fxp_names *names;
799 struct fxp_name **ournames;
800 int nnames, namesize;
3394416c 801 char *dir, *cdir, *unwcdir, *wildcard;
93e86a8b 802 struct sftp_packet *pktin;
803 struct sftp_request *req, *rreq;
804 int i;
805
806 if (back == NULL) {
807 printf("psftp: not connected to a host; use \"open host.name\"\n");
808 return 0;
809 }
810
811 if (cmd->nwords < 2)
812 dir = ".";
813 else
814 dir = cmd->words[1];
815
3394416c 816 unwcdir = snewn(1 + strlen(dir), char);
817 if (wc_unescape(unwcdir, dir)) {
818 dir = unwcdir;
819 wildcard = NULL;
820 } else {
821 char *tmpdir;
822 int len, check;
823
824 wildcard = stripslashes(dir, 0);
825 unwcdir = dupstr(dir);
826 len = wildcard - dir;
827 unwcdir[len] = '\0';
828 if (len > 0 && unwcdir[len-1] == '/')
829 unwcdir[len-1] = '\0';
830 tmpdir = snewn(1 + len, char);
831 check = wc_unescape(tmpdir, unwcdir);
832 sfree(tmpdir);
833 if (!check) {
834 printf("Multiple-level wildcards are not supported\n");
835 sfree(unwcdir);
836 return 0;
837 }
838 dir = unwcdir;
839 }
840
93e86a8b 841 cdir = canonify(dir);
842 if (!cdir) {
843 printf("%s: %s\n", dir, fxp_error());
3394416c 844 sfree(unwcdir);
93e86a8b 845 return 0;
846 }
847
848 printf("Listing directory %s\n", cdir);
849
850 sftp_register(req = fxp_opendir_send(cdir));
851 rreq = sftp_find_request(pktin = sftp_recv());
852 assert(rreq == req);
853 dirh = fxp_opendir_recv(pktin, rreq);
854
855 if (dirh == NULL) {
856 printf("Unable to open %s: %s\n", dir, fxp_error());
857 } else {
858 nnames = namesize = 0;
859 ournames = NULL;
860
861 while (1) {
862
863 sftp_register(req = fxp_readdir_send(dirh));
864 rreq = sftp_find_request(pktin = sftp_recv());
865 assert(rreq == req);
866 names = fxp_readdir_recv(pktin, rreq);
867
868 if (names == NULL) {
869 if (fxp_error_type() == SSH_FX_EOF)
870 break;
871 printf("Reading directory %s: %s\n", dir, fxp_error());
872 break;
873 }
874 if (names->nnames == 0) {
875 fxp_free_names(names);
876 break;
877 }
878
879 if (nnames + names->nnames >= namesize) {
880 namesize += names->nnames + 128;
881 ournames = sresize(ournames, namesize, struct fxp_name *);
882 }
883
884 for (i = 0; i < names->nnames; i++)
3394416c 885 if (!wildcard || wc_match(wildcard, names->names[i].filename))
886 ournames[nnames++] = fxp_dup_name(&names->names[i]);
93e86a8b 887
888 fxp_free_names(names);
889 }
890 sftp_register(req = fxp_close_send(dirh));
891 rreq = sftp_find_request(pktin = sftp_recv());
892 assert(rreq == req);
893 fxp_close_recv(pktin, rreq);
894
895 /*
896 * Now we have our filenames. Sort them by actual file
897 * name, and then output the longname parts.
898 */
899 qsort(ournames, nnames, sizeof(*ournames), sftp_name_compare);
900
901 /*
902 * And print them.
903 */
904 for (i = 0; i < nnames; i++) {
905 printf("%s\n", ournames[i]->longname);
906 fxp_free_name(ournames[i]);
907 }
908 sfree(ournames);
909 }
910
911 sfree(cdir);
3394416c 912 sfree(unwcdir);
93e86a8b 913
914 return 1;
915}
916
917/*
918 * Change directories. We do this by canonifying the new name, then
919 * trying to OPENDIR it. Only if that succeeds do we set the new pwd.
920 */
921int sftp_cmd_cd(struct sftp_command *cmd)
922{
923 struct fxp_handle *dirh;
924 struct sftp_packet *pktin;
925 struct sftp_request *req, *rreq;
926 char *dir;
927
928 if (back == NULL) {
929 printf("psftp: not connected to a host; use \"open host.name\"\n");
930 return 0;
931 }
932
933 if (cmd->nwords < 2)
934 dir = dupstr(homedir);
935 else
936 dir = canonify(cmd->words[1]);
937
938 if (!dir) {
939 printf("%s: %s\n", dir, fxp_error());
940 return 0;
941 }
942
943 sftp_register(req = fxp_opendir_send(dir));
944 rreq = sftp_find_request(pktin = sftp_recv());
945 assert(rreq == req);
946 dirh = fxp_opendir_recv(pktin, rreq);
947
948 if (!dirh) {
949 printf("Directory %s: %s\n", dir, fxp_error());
950 sfree(dir);
951 return 0;
952 }
953
954 sftp_register(req = fxp_close_send(dirh));
955 rreq = sftp_find_request(pktin = sftp_recv());
956 assert(rreq == req);
957 fxp_close_recv(pktin, rreq);
958
959 sfree(pwd);
960 pwd = dir;
961 printf("Remote directory is now %s\n", pwd);
962
963 return 1;
964}
965
966/*
967 * Print current directory. Easy as pie.
968 */
969int sftp_cmd_pwd(struct sftp_command *cmd)
970{
971 if (back == NULL) {
972 printf("psftp: not connected to a host; use \"open host.name\"\n");
973 return 0;
974 }
975
976 printf("Remote directory is %s\n", pwd);
977 return 1;
978}
979
980/*
9c77ddf6 981 * Get a file and save it at the local end. We have three very
982 * similar commands here. The basic one is `get'; `reget' differs
983 * in that it checks for the existence of the destination file and
984 * starts from where a previous aborted transfer left off; `mget'
985 * differs in that it interprets all its arguments as files to
986 * transfer (never as a different local name for a remote file) and
987 * can handle wildcards.
93e86a8b 988 */
9c77ddf6 989int sftp_general_get(struct sftp_command *cmd, int restart, int multiple)
93e86a8b 990{
9c77ddf6 991 char *fname, *unwcfname, *origfname, *outfname;
93e86a8b 992 int i, ret;
993 int recurse = FALSE;
994
995 if (back == NULL) {
996 printf("psftp: not connected to a host; use \"open host.name\"\n");
997 return 0;
998 }
999
1000 i = 1;
1001 while (i < cmd->nwords && cmd->words[i][0] == '-') {
1002 if (!strcmp(cmd->words[i], "--")) {
1003 /* finish processing options */
1004 i++;
1005 break;
1006 } else if (!strcmp(cmd->words[i], "-r")) {
1007 recurse = TRUE;
1008 } else {
9033711a 1009 printf("%s: unrecognised option '%s'\n", cmd->words[0], cmd->words[i]);
93e86a8b 1010 return 0;
1011 }
1012 i++;
1013 }
1014
1015 if (i >= cmd->nwords) {
9033711a 1016 printf("%s: expects a filename\n", cmd->words[0]);
93e86a8b 1017 return 0;
1018 }
1019
9c77ddf6 1020 do {
1021 unwcfname = NULL;
1022 origfname = cmd->words[i++];
93e86a8b 1023
9c77ddf6 1024 if (multiple &&
1025 !wc_unescape(unwcfname = snewn(strlen(origfname)+1, char),
1026 origfname)) {
1027 ret = sftp_get_file(pwd, NULL, recurse, restart, origfname);
1028 } else {
1029 fname = canonify(origfname);
1030 if (!fname) {
1031 printf("%s: %s\n", origfname, fxp_error());
1032 sfree(unwcfname);
1033 return 0;
1034 }
93e86a8b 1035
9c77ddf6 1036 if (!multiple && i < cmd->nwords)
1037 outfname = cmd->words[i++];
1038 else
3394416c 1039 outfname = stripslashes(origfname, 0);
93e86a8b 1040
9c77ddf6 1041 ret = sftp_get_file(fname, outfname, recurse, restart, NULL);
1042
1043 sfree(fname);
1044 }
1045 sfree(unwcfname);
1046 if (!ret)
1047 return ret;
1048
1049 } while (multiple && i < cmd->nwords);
93e86a8b 1050
1051 return ret;
1052}
1053int sftp_cmd_get(struct sftp_command *cmd)
1054{
9c77ddf6 1055 return sftp_general_get(cmd, 0, 0);
1056}
1057int sftp_cmd_mget(struct sftp_command *cmd)
1058{
1059 return sftp_general_get(cmd, 0, 1);
93e86a8b 1060}
1061int sftp_cmd_reget(struct sftp_command *cmd)
1062{
9c77ddf6 1063 return sftp_general_get(cmd, 1, 0);
93e86a8b 1064}
1065
1066/*
9c77ddf6 1067 * Send a file and store it at the remote end. We have three very
1068 * similar commands here. The basic one is `put'; `reput' differs
1069 * in that it checks for the existence of the destination file and
1070 * starts from where a previous aborted transfer left off; `mput'
1071 * differs in that it interprets all its arguments as files to
1072 * transfer (never as a different remote name for a local file) and
1073 * can handle wildcards.
93e86a8b 1074 */
9c77ddf6 1075int sftp_general_put(struct sftp_command *cmd, int restart, int multiple)
93e86a8b 1076{
1077 char *fname, *origoutfname, *outfname;
1078 int i, ret;
1079 int recurse = FALSE;
1080
1081 if (back == NULL) {
1082 printf("psftp: not connected to a host; use \"open host.name\"\n");
1083 return 0;
1084 }
1085
1086 i = 1;
1087 while (i < cmd->nwords && cmd->words[i][0] == '-') {
1088 if (!strcmp(cmd->words[i], "--")) {
1089 /* finish processing options */
1090 i++;
1091 break;
1092 } else if (!strcmp(cmd->words[i], "-r")) {
1093 recurse = TRUE;
1094 } else {
9033711a 1095 printf("%s: unrecognised option '%s'\n", cmd->words[0], cmd->words[i]);
93e86a8b 1096 return 0;
1097 }
1098 i++;
1099 }
1100
1101 if (i >= cmd->nwords) {
9033711a 1102 printf("%s: expects a filename\n", cmd->words[0]);
93e86a8b 1103 return 0;
1104 }
1105
9c77ddf6 1106 do {
1107 fname = cmd->words[i++];
93e86a8b 1108
9c77ddf6 1109 if (multiple && test_wildcard(fname, FALSE) == WCTYPE_WILDCARD) {
1110 ret = sftp_put_file(NULL, pwd, recurse, restart, fname);
1111 } else {
1112 if (!multiple && i < cmd->nwords)
1113 origoutfname = cmd->words[i++];
1114 else
1115 origoutfname = stripslashes(fname, 1);
1116
1117 outfname = canonify(origoutfname);
1118 if (!outfname) {
1119 printf("%s: %s\n", origoutfname, fxp_error());
1120 return 0;
1121 }
1122 ret = sftp_put_file(fname, outfname, recurse, restart, NULL);
1123 sfree(outfname);
1124 }
1125 if (!ret)
1126 return ret;
93e86a8b 1127
9c77ddf6 1128 } while (multiple && i < cmd->nwords);
4c7f0d61 1129
df49ff19 1130 return ret;
4c7f0d61 1131}
d92624dc 1132int sftp_cmd_put(struct sftp_command *cmd)
1133{
9c77ddf6 1134 return sftp_general_put(cmd, 0, 0);
1135}
1136int sftp_cmd_mput(struct sftp_command *cmd)
1137{
1138 return sftp_general_put(cmd, 0, 1);
d92624dc 1139}
1140int sftp_cmd_reput(struct sftp_command *cmd)
1141{
9c77ddf6 1142 return sftp_general_put(cmd, 1, 0);
d92624dc 1143}
4c7f0d61 1144
9954aaa3 1145int sftp_cmd_mkdir(struct sftp_command *cmd)
1146{
1147 char *dir;
1bc24185 1148 struct sftp_packet *pktin;
1149 struct sftp_request *req, *rreq;
9954aaa3 1150 int result;
1151
fa3db767 1152 if (back == NULL) {
1153 printf("psftp: not connected to a host; use \"open host.name\"\n");
1154 return 0;
1155 }
9954aaa3 1156
1157 if (cmd->nwords < 2) {
1158 printf("mkdir: expects a directory\n");
1159 return 0;
1160 }
1161
1162 dir = canonify(cmd->words[1]);
1163 if (!dir) {
1164 printf("%s: %s\n", dir, fxp_error());
1165 return 0;
1166 }
1167
1bc24185 1168 sftp_register(req = fxp_mkdir_send(dir));
1169 rreq = sftp_find_request(pktin = sftp_recv());
1170 assert(rreq == req);
7b7de4f4 1171 result = fxp_mkdir_recv(pktin, rreq);
1bc24185 1172
9954aaa3 1173 if (!result) {
1174 printf("mkdir %s: %s\n", dir, fxp_error());
1175 sfree(dir);
1176 return 0;
1177 }
1178
d92624dc 1179 sfree(dir);
df49ff19 1180 return 1;
9954aaa3 1181}
1182
1183int sftp_cmd_rmdir(struct sftp_command *cmd)
1184{
1185 char *dir;
1bc24185 1186 struct sftp_packet *pktin;
1187 struct sftp_request *req, *rreq;
9954aaa3 1188 int result;
1189
fa3db767 1190 if (back == NULL) {
1191 printf("psftp: not connected to a host; use \"open host.name\"\n");
1192 return 0;
1193 }
9954aaa3 1194
1195 if (cmd->nwords < 2) {
1196 printf("rmdir: expects a directory\n");
1197 return 0;
1198 }
1199
1200 dir = canonify(cmd->words[1]);
1201 if (!dir) {
1202 printf("%s: %s\n", dir, fxp_error());
1203 return 0;
1204 }
1205
1bc24185 1206 sftp_register(req = fxp_rmdir_send(dir));
1207 rreq = sftp_find_request(pktin = sftp_recv());
1208 assert(rreq == req);
7b7de4f4 1209 result = fxp_rmdir_recv(pktin, rreq);
1bc24185 1210
9954aaa3 1211 if (!result) {
1212 printf("rmdir %s: %s\n", dir, fxp_error());
1213 sfree(dir);
1214 return 0;
1215 }
1216
d92624dc 1217 sfree(dir);
df49ff19 1218 return 1;
9954aaa3 1219}
1220
1221int sftp_cmd_rm(struct sftp_command *cmd)
1222{
1223 char *fname;
1bc24185 1224 struct sftp_packet *pktin;
1225 struct sftp_request *req, *rreq;
9954aaa3 1226 int result;
1227
fa3db767 1228 if (back == NULL) {
1229 printf("psftp: not connected to a host; use \"open host.name\"\n");
1230 return 0;
1231 }
1232
9954aaa3 1233 if (cmd->nwords < 2) {
1234 printf("rm: expects a filename\n");
1235 return 0;
1236 }
1237
1238 fname = canonify(cmd->words[1]);
1239 if (!fname) {
1240 printf("%s: %s\n", fname, fxp_error());
1241 return 0;
1242 }
1243
1bc24185 1244 sftp_register(req = fxp_remove_send(fname));
1245 rreq = sftp_find_request(pktin = sftp_recv());
1246 assert(rreq == req);
7b7de4f4 1247 result = fxp_remove_recv(pktin, rreq);
1bc24185 1248
9954aaa3 1249 if (!result) {
1250 printf("rm %s: %s\n", fname, fxp_error());
1251 sfree(fname);
1252 return 0;
1253 }
1254
d92624dc 1255 sfree(fname);
df49ff19 1256 return 1;
d92624dc 1257}
1258
1259int sftp_cmd_mv(struct sftp_command *cmd)
1260{
1261 char *srcfname, *dstfname;
1bc24185 1262 struct sftp_packet *pktin;
1263 struct sftp_request *req, *rreq;
d92624dc 1264 int result;
1265
fa3db767 1266 if (back == NULL) {
1267 printf("psftp: not connected to a host; use \"open host.name\"\n");
1268 return 0;
1269 }
1270
d92624dc 1271 if (cmd->nwords < 3) {
1272 printf("mv: expects two filenames\n");
9954aaa3 1273 return 0;
d92624dc 1274 }
1275 srcfname = canonify(cmd->words[1]);
1276 if (!srcfname) {
1277 printf("%s: %s\n", srcfname, fxp_error());
1278 return 0;
1279 }
1280
1281 dstfname = canonify(cmd->words[2]);
1282 if (!dstfname) {
1283 printf("%s: %s\n", dstfname, fxp_error());
1284 return 0;
1285 }
9954aaa3 1286
1bc24185 1287 sftp_register(req = fxp_rename_send(srcfname, dstfname));
1288 rreq = sftp_find_request(pktin = sftp_recv());
1289 assert(rreq == req);
7b7de4f4 1290 result = fxp_rename_recv(pktin, rreq);
1bc24185 1291
d92624dc 1292 if (!result) {
1293 char const *error = fxp_error();
1294 struct fxp_attrs attrs;
1295
1296 /*
1297 * The move might have failed because dstfname pointed at a
1298 * directory. We check this possibility now: if dstfname
1299 * _is_ a directory, we re-attempt the move by appending
1300 * the basename of srcfname to dstfname.
1301 */
1bc24185 1302 sftp_register(req = fxp_stat_send(dstfname));
1303 rreq = sftp_find_request(pktin = sftp_recv());
1304 assert(rreq == req);
7b7de4f4 1305 result = fxp_stat_recv(pktin, rreq, &attrs);
1bc24185 1306
d92624dc 1307 if (result &&
1308 (attrs.flags & SSH_FILEXFER_ATTR_PERMISSIONS) &&
1309 (attrs.permissions & 0040000)) {
1310 char *p;
1311 char *newname, *newcanon;
1312 printf("(destination %s is a directory)\n", dstfname);
1313 p = srcfname + strlen(srcfname);
1314 while (p > srcfname && p[-1] != '/') p--;
1315 newname = dupcat(dstfname, "/", p, NULL);
1316 newcanon = canonify(newname);
1317 sfree(newname);
1318 if (newcanon) {
1319 sfree(dstfname);
1320 dstfname = newcanon;
1bc24185 1321
1322 sftp_register(req = fxp_rename_send(srcfname, dstfname));
1323 rreq = sftp_find_request(pktin = sftp_recv());
1324 assert(rreq == req);
7b7de4f4 1325 result = fxp_rename_recv(pktin, rreq);
1bc24185 1326
d92624dc 1327 error = result ? NULL : fxp_error();
1328 }
1329 }
1330 if (error) {
1331 printf("mv %s %s: %s\n", srcfname, dstfname, error);
1332 sfree(srcfname);
1333 sfree(dstfname);
1334 return 0;
1335 }
1336 }
1337 printf("%s -> %s\n", srcfname, dstfname);
1338
1339 sfree(srcfname);
1340 sfree(dstfname);
df49ff19 1341 return 1;
9954aaa3 1342}
1343
d92624dc 1344int sftp_cmd_chmod(struct sftp_command *cmd)
1345{
1346 char *fname, *mode;
1347 int result;
1348 struct fxp_attrs attrs;
1349 unsigned attrs_clr, attrs_xor, oldperms, newperms;
1bc24185 1350 struct sftp_packet *pktin;
1351 struct sftp_request *req, *rreq;
d92624dc 1352
fa3db767 1353 if (back == NULL) {
1354 printf("psftp: not connected to a host; use \"open host.name\"\n");
1355 return 0;
1356 }
1357
d92624dc 1358 if (cmd->nwords < 3) {
1359 printf("chmod: expects a mode specifier and a filename\n");
1360 return 0;
1361 }
1362
1363 /*
1364 * Attempt to parse the mode specifier in cmd->words[1]. We
1365 * don't support the full horror of Unix chmod; instead we
1366 * support a much simpler syntax in which the user can either
1367 * specify an octal number, or a comma-separated sequence of
1368 * [ugoa]*[-+=][rwxst]+. (The initial [ugoa] sequence may
1369 * _only_ be omitted if the only attribute mentioned is t,
1370 * since all others require a user/group/other specification.
1371 * Additionally, the s attribute may not be specified for any
1372 * [ugoa] specifications other than exactly u or exactly g.
1373 */
1374 attrs_clr = attrs_xor = 0;
1375 mode = cmd->words[1];
1376 if (mode[0] >= '0' && mode[0] <= '9') {
1377 if (mode[strspn(mode, "01234567")]) {
1378 printf("chmod: numeric file modes should"
1379 " contain digits 0-7 only\n");
1380 return 0;
1381 }
1382 attrs_clr = 07777;
1383 sscanf(mode, "%o", &attrs_xor);
1384 attrs_xor &= attrs_clr;
1385 } else {
1386 while (*mode) {
1387 char *modebegin = mode;
1388 unsigned subset, perms;
1389 int action;
1390
1391 subset = 0;
1392 while (*mode && *mode != ',' &&
1393 *mode != '+' && *mode != '-' && *mode != '=') {
1394 switch (*mode) {
1395 case 'u': subset |= 04700; break; /* setuid, user perms */
1396 case 'g': subset |= 02070; break; /* setgid, group perms */
1397 case 'o': subset |= 00007; break; /* just other perms */
1398 case 'a': subset |= 06777; break; /* all of the above */
1399 default:
1400 printf("chmod: file mode '%.*s' contains unrecognised"
1401 " user/group/other specifier '%c'\n",
b51259f6 1402 (int)strcspn(modebegin, ","), modebegin, *mode);
d92624dc 1403 return 0;
1404 }
1405 mode++;
1406 }
1407 if (!*mode || *mode == ',') {
1408 printf("chmod: file mode '%.*s' is incomplete\n",
b51259f6 1409 (int)strcspn(modebegin, ","), modebegin);
d92624dc 1410 return 0;
1411 }
1412 action = *mode++;
1413 if (!*mode || *mode == ',') {
1414 printf("chmod: file mode '%.*s' is incomplete\n",
b51259f6 1415 (int)strcspn(modebegin, ","), modebegin);
d92624dc 1416 return 0;
1417 }
1418 perms = 0;
1419 while (*mode && *mode != ',') {
1420 switch (*mode) {
1421 case 'r': perms |= 00444; break;
1422 case 'w': perms |= 00222; break;
1423 case 'x': perms |= 00111; break;
1424 case 't': perms |= 01000; subset |= 01000; break;
1425 case 's':
1426 if ((subset & 06777) != 04700 &&
1427 (subset & 06777) != 02070) {
1428 printf("chmod: file mode '%.*s': set[ug]id bit should"
1429 " be used with exactly one of u or g only\n",
b51259f6 1430 (int)strcspn(modebegin, ","), modebegin);
d92624dc 1431 return 0;
1432 }
1433 perms |= 06000;
1434 break;
1435 default:
1436 printf("chmod: file mode '%.*s' contains unrecognised"
1437 " permission specifier '%c'\n",
b51259f6 1438 (int)strcspn(modebegin, ","), modebegin, *mode);
d92624dc 1439 return 0;
1440 }
1441 mode++;
1442 }
1443 if (!(subset & 06777) && (perms &~ subset)) {
1444 printf("chmod: file mode '%.*s' contains no user/group/other"
1445 " specifier and permissions other than 't' \n",
b51259f6 1446 (int)strcspn(modebegin, ","), modebegin);
d92624dc 1447 return 0;
1448 }
1449 perms &= subset;
1450 switch (action) {
1451 case '+':
1452 attrs_clr |= perms;
1453 attrs_xor |= perms;
1454 break;
1455 case '-':
1456 attrs_clr |= perms;
1457 attrs_xor &= ~perms;
1458 break;
1459 case '=':
1460 attrs_clr |= subset;
1461 attrs_xor |= perms;
1462 break;
1463 }
1464 if (*mode) mode++; /* eat comma */
1465 }
1466 }
1467
1468 fname = canonify(cmd->words[2]);
1469 if (!fname) {
1470 printf("%s: %s\n", fname, fxp_error());
1471 return 0;
1472 }
1473
1bc24185 1474 sftp_register(req = fxp_stat_send(fname));
1475 rreq = sftp_find_request(pktin = sftp_recv());
1476 assert(rreq == req);
7b7de4f4 1477 result = fxp_stat_recv(pktin, rreq, &attrs);
1bc24185 1478
d92624dc 1479 if (!result || !(attrs.flags & SSH_FILEXFER_ATTR_PERMISSIONS)) {
1480 printf("get attrs for %s: %s\n", fname,
1481 result ? "file permissions not provided" : fxp_error());
1482 sfree(fname);
1483 return 0;
1484 }
1485
1486 attrs.flags = SSH_FILEXFER_ATTR_PERMISSIONS; /* perms _only_ */
1487 oldperms = attrs.permissions & 07777;
1488 attrs.permissions &= ~attrs_clr;
1489 attrs.permissions ^= attrs_xor;
1490 newperms = attrs.permissions & 07777;
1491
1bc24185 1492 sftp_register(req = fxp_setstat_send(fname, attrs));
1493 rreq = sftp_find_request(pktin = sftp_recv());
1494 assert(rreq == req);
7b7de4f4 1495 result = fxp_setstat_recv(pktin, rreq);
d92624dc 1496
1497 if (!result) {
1498 printf("set attrs for %s: %s\n", fname, fxp_error());
1499 sfree(fname);
1500 return 0;
1501 }
1502
1503 printf("%s: %04o -> %04o\n", fname, oldperms, newperms);
1504
1505 sfree(fname);
df49ff19 1506 return 1;
d92624dc 1507}
9954aaa3 1508
fa3db767 1509static int sftp_cmd_open(struct sftp_command *cmd)
1510{
f11233cb 1511 int portnumber;
1512
fa3db767 1513 if (back != NULL) {
1514 printf("psftp: already connected\n");
1515 return 0;
1516 }
1517
1518 if (cmd->nwords < 2) {
1519 printf("open: expects a host name\n");
1520 return 0;
1521 }
1522
f11233cb 1523 if (cmd->nwords > 2) {
1524 portnumber = atoi(cmd->words[2]);
1525 if (portnumber == 0) {
1526 printf("open: invalid port number\n");
1527 return 0;
1528 }
1529 } else
1530 portnumber = 0;
1531
1532 if (psftp_connect(cmd->words[1], NULL, portnumber)) {
fa3db767 1533 back = NULL; /* connection is already closed */
1534 return -1; /* this is fatal */
1535 }
1536 do_sftp_init();
df49ff19 1537 return 1;
fa3db767 1538}
1539
3af97463 1540static int sftp_cmd_lcd(struct sftp_command *cmd)
1541{
d6cc41e6 1542 char *currdir, *errmsg;
3af97463 1543
1544 if (cmd->nwords < 2) {
1545 printf("lcd: expects a local directory name\n");
1546 return 0;
1547 }
1548
d6cc41e6 1549 errmsg = psftp_lcd(cmd->words[1]);
1550 if (errmsg) {
1551 printf("lcd: unable to change directory: %s\n", errmsg);
1552 sfree(errmsg);
3af97463 1553 return 0;
1554 }
1555
d6cc41e6 1556 currdir = psftp_getcwd();
3af97463 1557 printf("New local directory is %s\n", currdir);
1558 sfree(currdir);
1559
1560 return 1;
1561}
1562
1563static int sftp_cmd_lpwd(struct sftp_command *cmd)
1564{
1565 char *currdir;
3af97463 1566
d6cc41e6 1567 currdir = psftp_getcwd();
3af97463 1568 printf("Current local directory is %s\n", currdir);
1569 sfree(currdir);
1570
1571 return 1;
1572}
1573
1574static int sftp_cmd_pling(struct sftp_command *cmd)
1575{
1576 int exitcode;
1577
1578 exitcode = system(cmd->words[1]);
1579 return (exitcode == 0);
1580}
1581
bf5240cd 1582static int sftp_cmd_help(struct sftp_command *cmd);
1583
4c7f0d61 1584static struct sftp_cmd_lookup {
1585 char *name;
bf5240cd 1586 /*
1587 * For help purposes, there are two kinds of command:
1588 *
1589 * - primary commands, in which `longhelp' is non-NULL. In
1590 * this case `shorthelp' is descriptive text, and `longhelp'
1591 * is longer descriptive text intended to be printed after
1592 * the command name.
1593 *
1594 * - alias commands, in which `longhelp' is NULL. In this case
1595 * `shorthelp' is the name of a primary command, which
1596 * contains the help that should double up for this command.
1597 */
3af97463 1598 int listed; /* do we list this in primary help? */
bf5240cd 1599 char *shorthelp;
1600 char *longhelp;
32874aea 1601 int (*obey) (struct sftp_command *);
4c7f0d61 1602} sftp_lookup[] = {
1603 /*
1604 * List of sftp commands. This is binary-searched so it MUST be
1605 * in ASCII order.
1606 */
32874aea 1607 {
d6cc41e6 1608 "!", TRUE, "run a local command",
3af97463 1609 "<command>\n"
d6cc41e6 1610 /* FIXME: this example is crap for non-Windows. */
1611 " Runs a local command. For example, \"!del myfile\".\n",
3af97463 1612 sftp_cmd_pling
1613 },
1614 {
1615 "bye", TRUE, "finish your SFTP session",
bf5240cd 1616 "\n"
1617 " Terminates your SFTP session and quits the PSFTP program.\n",
1618 sftp_cmd_quit
1619 },
1620 {
3af97463 1621 "cd", TRUE, "change your remote working directory",
bf5240cd 1622 " [ <New working directory> ]\n"
1623 " Change the remote working directory for your SFTP session.\n"
1624 " If a new working directory is not supplied, you will be\n"
1625 " returned to your home directory.\n",
1626 sftp_cmd_cd
1627 },
1628 {
3af97463 1629 "chmod", TRUE, "change file permissions and modes",
bf5240cd 1630 " ( <octal-digits> | <modifiers> ) <filename>\n"
1631 " Change the file permissions on a file or directory.\n"
1632 " <octal-digits> can be any octal Unix permission specifier.\n"
1633 " Alternatively, <modifiers> can include:\n"
1634 " u+r make file readable by owning user\n"
1635 " u+w make file writable by owning user\n"
1636 " u+x make file executable by owning user\n"
1637 " u-r make file not readable by owning user\n"
1638 " [also u-w, u-x]\n"
1639 " g+r make file readable by members of owning group\n"
1640 " [also g+w, g+x, g-r, g-w, g-x]\n"
1641 " o+r make file readable by all other users\n"
1642 " [also o+w, o+x, o-r, o-w, o-x]\n"
1643 " a+r make file readable by absolutely everybody\n"
1644 " [also a+w, a+x, a-r, a-w, a-x]\n"
1645 " u+s enable the Unix set-user-ID bit\n"
1646 " u-s disable the Unix set-user-ID bit\n"
1647 " g+s enable the Unix set-group-ID bit\n"
1648 " g-s disable the Unix set-group-ID bit\n"
1649 " +t enable the Unix \"sticky bit\"\n"
1650 " You can give more than one modifier for the same user (\"g-rwx\"), and\n"
1651 " more than one user for the same modifier (\"ug+w\"). You can\n"
1652 " use commas to separate different modifiers (\"u+rwx,g+s\").\n",
1653 sftp_cmd_chmod
1654 },
1655 {
b614ce89 1656 "close", TRUE, "finish your SFTP session but do not quit PSFTP",
1657 "\n"
1658 " Terminates your SFTP session, but does not quit the PSFTP\n"
1659 " program. You can then use \"open\" to start another SFTP\n"
1660 " session, to the same server or to a different one.\n",
1661 sftp_cmd_close
1662 },
1663 {
3af97463 1664 "del", TRUE, "delete a file",
bf5240cd 1665 " <filename>\n"
1666 " Delete a file.\n",
1667 sftp_cmd_rm
1668 },
1669 {
3af97463 1670 "delete", FALSE, "del", NULL, sftp_cmd_rm
bf5240cd 1671 },
1672 {
3af97463 1673 "dir", TRUE, "list contents of a remote directory",
9033711a 1674 " [ <directory-name> ]/[ <wildcard> ]\n"
bf5240cd 1675 " List the contents of a specified directory on the server.\n"
1676 " If <directory-name> is not given, the current working directory\n"
9033711a 1677 " is assumed.\n"
1678 " If <wildcard> is given, it is treated as a set of files to\n"
1679 " list; otherwise, all files are listed.\n",
bf5240cd 1680 sftp_cmd_ls
1681 },
1682 {
3af97463 1683 "exit", TRUE, "bye", NULL, sftp_cmd_quit
bf5240cd 1684 },
1685 {
3af97463 1686 "get", TRUE, "download a file from the server to your local machine",
9033711a 1687 " [ -r ] [ -- ] <filename> [ <local-filename> ]\n"
bf5240cd 1688 " Downloads a file on the server and stores it locally under\n"
1689 " the same name, or under a different one if you supply the\n"
9033711a 1690 " argument <local-filename>.\n"
1691 " If -r specified, recursively fetch a directory.\n",
bf5240cd 1692 sftp_cmd_get
1693 },
1694 {
3af97463 1695 "help", TRUE, "give help",
bf5240cd 1696 " [ <command> [ <command> ... ] ]\n"
1697 " Give general help if no commands are specified.\n"
1698 " If one or more commands are specified, give specific help on\n"
1699 " those particular commands.\n",
1700 sftp_cmd_help
1701 },
1702 {
3af97463 1703 "lcd", TRUE, "change local working directory",
1704 " <local-directory-name>\n"
1705 " Change the local working directory of the PSFTP program (the\n"
1706 " default location where the \"get\" command will save files).\n",
1707 sftp_cmd_lcd
1708 },
1709 {
1710 "lpwd", TRUE, "print local working directory",
1711 "\n"
1712 " Print the local working directory of the PSFTP program (the\n"
1713 " default location where the \"get\" command will save files).\n",
1714 sftp_cmd_lpwd
1715 },
1716 {
1717 "ls", TRUE, "dir", NULL,
bf5240cd 1718 sftp_cmd_ls
1719 },
1720 {
9c77ddf6 1721 "mget", TRUE, "download multiple files at once",
9033711a 1722 " [ -r ] [ -- ] <filename-or-wildcard> [ <filename-or-wildcard>... ]\n"
9c77ddf6 1723 " Downloads many files from the server, storing each one under\n"
1724 " the same name it has on the server side. You can use wildcards\n"
9033711a 1725 " such as \"*.c\" to specify lots of files at once.\n"
1726 " If -r specified, recursively fetch files and directories.\n",
9c77ddf6 1727 sftp_cmd_mget
1728 },
1729 {
3af97463 1730 "mkdir", TRUE, "create a directory on the remote server",
bf5240cd 1731 " <directory-name>\n"
1732 " Creates a directory with the given name on the server.\n",
1733 sftp_cmd_mkdir
1734 },
1735 {
9c77ddf6 1736 "mput", TRUE, "upload multiple files at once",
1737 " <filename-or-wildcard> [ <filename-or-wildcard>... ]\n"
1738 " Uploads many files to the server, storing each one under the\n"
1739 " same name it has on the client side. You can use wildcards\n"
9033711a 1740 " such as \"*.c\" to specify lots of files at once.\n"
1741 " If -r specified, recursively store files and directories.\n",
9c77ddf6 1742 sftp_cmd_mput
1743 },
1744 {
3af97463 1745 "mv", TRUE, "move or rename a file on the remote server",
bf5240cd 1746 " <source-filename> <destination-filename>\n"
1747 " Moves or renames the file <source-filename> on the server,\n"
1748 " so that it is accessible under the name <destination-filename>.\n",
1749 sftp_cmd_mv
1750 },
1751 {
3af97463 1752 "open", TRUE, "connect to a host",
f11233cb 1753 " [<user>@]<hostname> [<port>]\n"
fa3db767 1754 " Establishes an SFTP connection to a given host. Only usable\n"
1755 " when you did not already specify a host name on the command\n"
1756 " line.\n",
1757 sftp_cmd_open
1758 },
1759 {
56542985 1760 "put", TRUE, "upload a file from your local machine to the server",
9033711a 1761 " [ -r ] [ -- ] <filename> [ <remote-filename> ]\n"
56542985 1762 " Uploads a file to the server and stores it there under\n"
1763 " the same name, or under a different one if you supply the\n"
9033711a 1764 " argument <remote-filename>.\n"
1765 " If -r specified, recursively store a directory.\n",
56542985 1766 sftp_cmd_put
1767 },
1768 {
3af97463 1769 "pwd", TRUE, "print your remote working directory",
4f2b387f 1770 "\n"
1771 " Print the current remote working directory for your SFTP session.\n",
1772 sftp_cmd_pwd
1773 },
1774 {
3af97463 1775 "quit", TRUE, "bye", NULL,
bf5240cd 1776 sftp_cmd_quit
1777 },
1778 {
3af97463 1779 "reget", TRUE, "continue downloading a file",
9033711a 1780 " [ -r ] [ -- ] <filename> [ <local-filename> ]\n"
bf5240cd 1781 " Works exactly like the \"get\" command, but the local file\n"
1782 " must already exist. The download will begin at the end of the\n"
9033711a 1783 " file. This is for resuming a download that was interrupted.\n"
1784 " If -r specified, resume interrupted \"get -r\".\n",
bf5240cd 1785 sftp_cmd_reget
1786 },
1787 {
3af97463 1788 "ren", TRUE, "mv", NULL,
bf5240cd 1789 sftp_cmd_mv
1790 },
1791 {
3af97463 1792 "rename", FALSE, "mv", NULL,
bf5240cd 1793 sftp_cmd_mv
1794 },
1795 {
3af97463 1796 "reput", TRUE, "continue uploading a file",
9033711a 1797 " [ -r ] [ -- ] <filename> [ <remote-filename> ]\n"
bf5240cd 1798 " Works exactly like the \"put\" command, but the remote file\n"
1799 " must already exist. The upload will begin at the end of the\n"
9033711a 1800 " file. This is for resuming an upload that was interrupted.\n"
1801 " If -r specified, resume interrupted \"put -r\".\n",
bf5240cd 1802 sftp_cmd_reput
1803 },
1804 {
3af97463 1805 "rm", TRUE, "del", NULL,
bf5240cd 1806 sftp_cmd_rm
1807 },
1808 {
3af97463 1809 "rmdir", TRUE, "remove a directory on the remote server",
bf5240cd 1810 " <directory-name>\n"
1811 " Removes the directory with the given name on the server.\n"
1812 " The directory will not be removed unless it is empty.\n",
1813 sftp_cmd_rmdir
1814 }
1815};
1816
1817const struct sftp_cmd_lookup *lookup_command(char *name)
1818{
1819 int i, j, k, cmp;
1820
1821 i = -1;
1822 j = sizeof(sftp_lookup) / sizeof(*sftp_lookup);
1823 while (j - i > 1) {
1824 k = (j + i) / 2;
1825 cmp = strcmp(name, sftp_lookup[k].name);
1826 if (cmp < 0)
1827 j = k;
1828 else if (cmp > 0)
1829 i = k;
1830 else {
1831 return &sftp_lookup[k];
1832 }
1833 }
1834 return NULL;
1835}
1836
1837static int sftp_cmd_help(struct sftp_command *cmd)
1838{
1839 int i;
1840 if (cmd->nwords == 1) {
1841 /*
1842 * Give short help on each command.
1843 */
1844 int maxlen;
1845 maxlen = 0;
1846 for (i = 0; i < sizeof(sftp_lookup) / sizeof(*sftp_lookup); i++) {
3af97463 1847 int len;
1848 if (!sftp_lookup[i].listed)
1849 continue;
1850 len = strlen(sftp_lookup[i].name);
bf5240cd 1851 if (maxlen < len)
1852 maxlen = len;
1853 }
1854 for (i = 0; i < sizeof(sftp_lookup) / sizeof(*sftp_lookup); i++) {
1855 const struct sftp_cmd_lookup *lookup;
3af97463 1856 if (!sftp_lookup[i].listed)
1857 continue;
bf5240cd 1858 lookup = &sftp_lookup[i];
1859 printf("%-*s", maxlen+2, lookup->name);
1860 if (lookup->longhelp == NULL)
1861 lookup = lookup_command(lookup->shorthelp);
1862 printf("%s\n", lookup->shorthelp);
1863 }
1864 } else {
1865 /*
1866 * Give long help on specific commands.
1867 */
1868 for (i = 1; i < cmd->nwords; i++) {
1869 const struct sftp_cmd_lookup *lookup;
1870 lookup = lookup_command(cmd->words[i]);
1871 if (!lookup) {
1872 printf("help: %s: command not found\n", cmd->words[i]);
1873 } else {
1874 printf("%s", lookup->name);
1875 if (lookup->longhelp == NULL)
1876 lookup = lookup_command(lookup->shorthelp);
1877 printf("%s", lookup->longhelp);
1878 }
1879 }
1880 }
df49ff19 1881 return 1;
bf5240cd 1882}
4c7f0d61 1883
1884/* ----------------------------------------------------------------------
1885 * Command line reading and parsing.
1886 */
9954aaa3 1887struct sftp_command *sftp_getcmd(FILE *fp, int mode, int modeflags)
32874aea 1888{
4c7f0d61 1889 char *line;
4c7f0d61 1890 struct sftp_command *cmd;
1891 char *p, *q, *r;
1892 int quoting;
1893
3d88e64d 1894 cmd = snew(struct sftp_command);
4c7f0d61 1895 cmd->words = NULL;
1896 cmd->nwords = 0;
1897 cmd->wordssize = 0;
1898
1899 line = NULL;
39934deb 1900
1901 if (fp) {
1902 if (modeflags & 1)
1903 printf("psftp> ");
1904 line = fgetline(fp);
1905 } else {
65857773 1906 line = ssh_sftp_get_cmdline("psftp> ", back == NULL);
4c7f0d61 1907 }
39934deb 1908
1909 if (!line || !*line) {
1910 cmd->obey = sftp_cmd_quit;
1911 if ((mode == 0) || (modeflags & 1))
1912 printf("quit\n");
1913 return cmd; /* eof */
1914 }
1915
1916 line[strcspn(line, "\r\n")] = '\0';
1917
df49ff19 1918 if (modeflags & 1) {
1919 printf("%s\n", line);
1920 }
4c7f0d61 1921
4c7f0d61 1922 p = line;
3af97463 1923 while (*p && (*p == ' ' || *p == '\t'))
1924 p++;
1925
1926 if (*p == '!') {
1927 /*
1928 * Special case: the ! command. This is always parsed as
1929 * exactly two words: one containing the !, and the second
1930 * containing everything else on the line.
1931 */
1932 cmd->nwords = cmd->wordssize = 2;
3d88e64d 1933 cmd->words = sresize(cmd->words, cmd->wordssize, char *);
679539d7 1934 cmd->words[0] = dupstr("!");
1935 cmd->words[1] = dupstr(p+1);
3af97463 1936 } else {
1937
1938 /*
1939 * Parse the command line into words. The syntax is:
1940 * - double quotes are removed, but cause spaces within to be
1941 * treated as non-separating.
1942 * - a double-doublequote pair is a literal double quote, inside
1943 * _or_ outside quotes. Like this:
1944 *
1945 * firstword "second word" "this has ""quotes"" in" and""this""
1946 *
1947 * becomes
1948 *
1949 * >firstword<
1950 * >second word<
1951 * >this has "quotes" in<
1952 * >and"this"<
1953 */
4c7f0d61 1954 while (*p) {
3af97463 1955 /* skip whitespace */
1956 while (*p && (*p == ' ' || *p == '\t'))
1957 p++;
1958 /* mark start of word */
1959 q = r = p; /* q sits at start, r writes word */
1960 quoting = 0;
1961 while (*p) {
1962 if (!quoting && (*p == ' ' || *p == '\t'))
1963 break; /* reached end of word */
1964 else if (*p == '"' && p[1] == '"')
1965 p += 2, *r++ = '"'; /* a literal quote */
1966 else if (*p == '"')
1967 p++, quoting = !quoting;
1968 else
1969 *r++ = *p++;
1970 }
1971 if (*p)
1972 p++; /* skip over the whitespace */
1973 *r = '\0';
1974 if (cmd->nwords >= cmd->wordssize) {
1975 cmd->wordssize = cmd->nwords + 16;
3d88e64d 1976 cmd->words = sresize(cmd->words, cmd->wordssize, char *);
3af97463 1977 }
679539d7 1978 cmd->words[cmd->nwords++] = dupstr(q);
4c7f0d61 1979 }
4c7f0d61 1980 }
1981
39934deb 1982 sfree(line);
1983
4c7f0d61 1984 /*
1985 * Now parse the first word and assign a function.
1986 */
1987
1988 if (cmd->nwords == 0)
1989 cmd->obey = sftp_cmd_null;
1990 else {
bf5240cd 1991 const struct sftp_cmd_lookup *lookup;
1992 lookup = lookup_command(cmd->words[0]);
1993 if (!lookup)
1994 cmd->obey = sftp_cmd_unknown;
1995 else
1996 cmd->obey = lookup->obey;
4c7f0d61 1997 }
1998
1999 return cmd;
2000}
2001
774204f5 2002static int do_sftp_init(void)
32874aea 2003{
1bc24185 2004 struct sftp_packet *pktin;
2005 struct sftp_request *req, *rreq;
2006
4c7f0d61 2007 /*
2008 * Do protocol initialisation.
2009 */
2010 if (!fxp_init()) {
2011 fprintf(stderr,
32874aea 2012 "Fatal: unable to initialise SFTP: %s\n", fxp_error());
774204f5 2013 return 1; /* failure */
4c7f0d61 2014 }
2015
2016 /*
2017 * Find out where our home directory is.
2018 */
1bc24185 2019 sftp_register(req = fxp_realpath_send("."));
2020 rreq = sftp_find_request(pktin = sftp_recv());
2021 assert(rreq == req);
7b7de4f4 2022 homedir = fxp_realpath_recv(pktin, rreq);
1bc24185 2023
4c7f0d61 2024 if (!homedir) {
2025 fprintf(stderr,
2026 "Warning: failed to resolve home directory: %s\n",
2027 fxp_error());
2028 homedir = dupstr(".");
2029 } else {
2030 printf("Remote working directory is %s\n", homedir);
2031 }
2032 pwd = dupstr(homedir);
774204f5 2033 return 0;
fa3db767 2034}
2035
679539d7 2036void do_sftp_cleanup()
2037{
2038 char ch;
f11233cb 2039 if (back) {
2040 back->special(backhandle, TS_EOF);
2041 sftp_recvdata(&ch, 1);
2042 back->free(backhandle);
2043 sftp_cleanup_request();
65857773 2044 back = NULL;
2045 backhandle = NULL;
f11233cb 2046 }
679539d7 2047 if (pwd) {
2048 sfree(pwd);
2049 pwd = NULL;
2050 }
2051 if (homedir) {
2052 sfree(homedir);
2053 homedir = NULL;
2054 }
2055}
2056
fa3db767 2057void do_sftp(int mode, int modeflags, char *batchfile)
2058{
2059 FILE *fp;
df49ff19 2060 int ret;
4c7f0d61 2061
9954aaa3 2062 /*
2063 * Batch mode?
4c7f0d61 2064 */
9954aaa3 2065 if (mode == 0) {
2066
2067 /* ------------------------------------------------------------------
2068 * Now we're ready to do Real Stuff.
2069 */
2070 while (1) {
df49ff19 2071 struct sftp_command *cmd;
39934deb 2072 cmd = sftp_getcmd(NULL, 0, 0);
df49ff19 2073 if (!cmd)
2074 break;
679539d7 2075 ret = cmd->obey(cmd);
2076 if (cmd->words) {
2077 int i;
2078 for(i = 0; i < cmd->nwords; i++)
2079 sfree(cmd->words[i]);
2080 sfree(cmd->words);
2081 }
2082 sfree(cmd);
2083 if (ret < 0)
df49ff19 2084 break;
bf5240cd 2085 }
9954aaa3 2086 } else {
2087 fp = fopen(batchfile, "r");
2088 if (!fp) {
bf5240cd 2089 printf("Fatal: unable to open %s\n", batchfile);
2090 return;
9954aaa3 2091 }
2092 while (1) {
bf5240cd 2093 struct sftp_command *cmd;
2094 cmd = sftp_getcmd(fp, mode, modeflags);
2095 if (!cmd)
2096 break;
df49ff19 2097 ret = cmd->obey(cmd);
2098 if (ret < 0)
bf5240cd 2099 break;
df49ff19 2100 if (ret == 0) {
bf5240cd 2101 if (!(modeflags & 2))
9954aaa3 2102 break;
bf5240cd 2103 }
9954aaa3 2104 }
bf5240cd 2105 fclose(fp);
9954aaa3 2106
4c7f0d61 2107 }
4a8fc3c4 2108}
4c7f0d61 2109
4a8fc3c4 2110/* ----------------------------------------------------------------------
2111 * Dirty bits: integration with PuTTY.
2112 */
2113
2114static int verbose = 0;
2115
7bedb13c 2116/*
4a8fc3c4 2117 * Print an error message and perform a fatal exit.
2118 */
2119void fatalbox(char *fmt, ...)
2120{
57356d63 2121 char *str, *str2;
4a8fc3c4 2122 va_list ap;
2123 va_start(ap, fmt);
57356d63 2124 str = dupvprintf(fmt, ap);
2125 str2 = dupcat("Fatal: ", str, "\n", NULL);
2126 sfree(str);
4a8fc3c4 2127 va_end(ap);
57356d63 2128 fputs(str2, stderr);
2129 sfree(str2);
4a8fc3c4 2130
93b581bd 2131 cleanup_exit(1);
4a8fc3c4 2132}
1709795f 2133void modalfatalbox(char *fmt, ...)
2134{
57356d63 2135 char *str, *str2;
1709795f 2136 va_list ap;
2137 va_start(ap, fmt);
57356d63 2138 str = dupvprintf(fmt, ap);
2139 str2 = dupcat("Fatal: ", str, "\n", NULL);
2140 sfree(str);
1709795f 2141 va_end(ap);
57356d63 2142 fputs(str2, stderr);
2143 sfree(str2);
1709795f 2144
2145 cleanup_exit(1);
2146}
a8327734 2147void connection_fatal(void *frontend, char *fmt, ...)
4a8fc3c4 2148{
57356d63 2149 char *str, *str2;
4a8fc3c4 2150 va_list ap;
2151 va_start(ap, fmt);
57356d63 2152 str = dupvprintf(fmt, ap);
2153 str2 = dupcat("Fatal: ", str, "\n", NULL);
2154 sfree(str);
4a8fc3c4 2155 va_end(ap);
57356d63 2156 fputs(str2, stderr);
2157 sfree(str2);
4a8fc3c4 2158
93b581bd 2159 cleanup_exit(1);
4a8fc3c4 2160}
2161
6b78788a 2162void ldisc_send(void *handle, char *buf, int len, int interactive)
32874aea 2163{
4a8fc3c4 2164 /*
2165 * This is only here because of the calls to ldisc_send(NULL,
2166 * 0) in ssh.c. Nothing in PSFTP actually needs to use the
2167 * ldisc as an ldisc. So if we get called with any real data, I
2168 * want to know about it.
4c7f0d61 2169 */
4a8fc3c4 2170 assert(len == 0);
2171}
2172
2173/*
c44bf5bd 2174 * In psftp, all agent requests should be synchronous, so this is a
2175 * never-called stub.
2176 */
2177void agent_schedule_callback(void (*callback)(void *, void *, int),
2178 void *callback_ctx, void *data, int len)
2179{
2180 assert(!"We shouldn't be here");
2181}
2182
2183/*
4a8fc3c4 2184 * Receive a block of data from the SSH link. Block until all data
2185 * is available.
2186 *
2187 * To do this, we repeatedly call the SSH protocol module, with our
2188 * own trap in from_backend() to catch the data that comes back. We
2189 * do this until we have enough data.
2190 */
2191
32874aea 2192static unsigned char *outptr; /* where to put the data */
2193static unsigned outlen; /* how much data required */
4a8fc3c4 2194static unsigned char *pending = NULL; /* any spare data */
32874aea 2195static unsigned pendlen = 0, pendsize = 0; /* length and phys. size of buffer */
9fab77dc 2196int from_backend(void *frontend, int is_stderr, const char *data, int datalen)
32874aea 2197{
2198 unsigned char *p = (unsigned char *) data;
2199 unsigned len = (unsigned) datalen;
4a8fc3c4 2200
2201 /*
2202 * stderr data is just spouted to local stderr and otherwise
2203 * ignored.
2204 */
2205 if (is_stderr) {
bfa5400d 2206 if (len > 0)
2207 fwrite(data, 1, len, stderr);
5471d09a 2208 return 0;
4a8fc3c4 2209 }
2210
2211 /*
2212 * If this is before the real session begins, just return.
2213 */
2214 if (!outptr)
5471d09a 2215 return 0;
4a8fc3c4 2216
bfa5400d 2217 if ((outlen > 0) && (len > 0)) {
32874aea 2218 unsigned used = outlen;
2219 if (used > len)
2220 used = len;
2221 memcpy(outptr, p, used);
2222 outptr += used;
2223 outlen -= used;
2224 p += used;
2225 len -= used;
4a8fc3c4 2226 }
2227
2228 if (len > 0) {
32874aea 2229 if (pendsize < pendlen + len) {
2230 pendsize = pendlen + len + 4096;
3d88e64d 2231 pending = sresize(pending, pendsize, unsigned char);
32874aea 2232 }
2233 memcpy(pending + pendlen, p, len);
2234 pendlen += len;
4a8fc3c4 2235 }
5471d09a 2236
2237 return 0;
4a8fc3c4 2238}
32874aea 2239int sftp_recvdata(char *buf, int len)
2240{
2241 outptr = (unsigned char *) buf;
4a8fc3c4 2242 outlen = len;
2243
2244 /*
2245 * See if the pending-input block contains some of what we
2246 * need.
2247 */
2248 if (pendlen > 0) {
32874aea 2249 unsigned pendused = pendlen;
2250 if (pendused > outlen)
2251 pendused = outlen;
4a8fc3c4 2252 memcpy(outptr, pending, pendused);
32874aea 2253 memmove(pending, pending + pendused, pendlen - pendused);
4a8fc3c4 2254 outptr += pendused;
2255 outlen -= pendused;
32874aea 2256 pendlen -= pendused;
2257 if (pendlen == 0) {
2258 pendsize = 0;
2259 sfree(pending);
2260 pending = NULL;
2261 }
2262 if (outlen == 0)
2263 return 1;
4a8fc3c4 2264 }
2265
2266 while (outlen > 0) {
d6cc41e6 2267 if (ssh_sftp_loop_iteration() < 0)
32874aea 2268 return 0; /* doom */
4a8fc3c4 2269 }
2270
2271 return 1;
2272}
32874aea 2273int sftp_senddata(char *buf, int len)
2274{
776792d7 2275 back->send(backhandle, buf, len);
4a8fc3c4 2276 return 1;
2277}
2278
2279/*
4a8fc3c4 2280 * Short description of parameters.
2281 */
2282static void usage(void)
2283{
2284 printf("PuTTY Secure File Transfer (SFTP) client\n");
2285 printf("%s\n", ver);
90767715 2286 printf("Usage: psftp [options] [user@]host\n");
4a8fc3c4 2287 printf("Options:\n");
9954aaa3 2288 printf(" -b file use specified batchfile\n");
2289 printf(" -bc output batchfile commands\n");
2290 printf(" -be don't stop batchfile processing if errors\n");
4a8fc3c4 2291 printf(" -v show verbose messages\n");
e2a197cf 2292 printf(" -load sessname Load settings from saved session\n");
2293 printf(" -l user connect with specified username\n");
4a8fc3c4 2294 printf(" -P port connect to specified port\n");
2295 printf(" -pw passw login with specified password\n");
e2a197cf 2296 printf(" -1 -2 force use of particular SSH protocol version\n");
2297 printf(" -C enable compression\n");
2298 printf(" -i key private key file for authentication\n");
2299 printf(" -batch disable all interactive prompts\n");
dc108ebc 2300 printf(" -V print version information\n");
93b581bd 2301 cleanup_exit(1);
4a8fc3c4 2302}
2303
dc108ebc 2304static void version(void)
2305{
2306 printf("psftp: %s\n", ver);
2307 cleanup_exit(1);
2308}
2309
4a8fc3c4 2310/*
fa3db767 2311 * Connect to a host.
4a8fc3c4 2312 */
fa3db767 2313static int psftp_connect(char *userhost, char *user, int portnumber)
4a8fc3c4 2314{
fa3db767 2315 char *host, *realhost;
cbe2d68f 2316 const char *err;
b51259f6 2317 void *logctx;
4a8fc3c4 2318
2319 /* Separate host and username */
2320 host = userhost;
2321 host = strrchr(host, '@');
2322 if (host == NULL) {
2323 host = userhost;
2324 } else {
2325 *host++ = '\0';
2326 if (user) {
32874aea 2327 printf("psftp: multiple usernames specified; using \"%s\"\n",
2328 user);
4a8fc3c4 2329 } else
2330 user = userhost;
2331 }
2332
18e62ad8 2333 /*
2334 * If we haven't loaded session details already (e.g., from -load),
2335 * try looking for a session called "host".
2336 */
2337 if (!loaded_session) {
2338 /* Try to load settings for `host' into a temporary config */
2339 Config cfg2;
2340 cfg2.host[0] = '\0';
2341 do_defaults(host, &cfg2);
2342 if (cfg2.host[0] != '\0') {
2343 /* Settings present and include hostname */
2344 /* Re-load data into the real config. */
2345 do_defaults(host, &cfg);
2346 } else {
2347 /* Session doesn't exist or mention a hostname. */
2348 /* Use `host' as a bare hostname. */
2349 strncpy(cfg.host, host, sizeof(cfg.host) - 1);
2350 cfg.host[sizeof(cfg.host) - 1] = '\0';
2351 }
2352 } else {
2353 /* Patch in hostname `host' to session details. */
32874aea 2354 strncpy(cfg.host, host, sizeof(cfg.host) - 1);
2355 cfg.host[sizeof(cfg.host) - 1] = '\0';
f133db8e 2356 }
2357
2358 /*
2359 * Force use of SSH. (If they got the protocol wrong we assume the
2360 * port is useless too.)
2361 */
2362 if (cfg.protocol != PROT_SSH) {
2363 cfg.protocol = PROT_SSH;
2364 cfg.port = 22;
4a8fc3c4 2365 }
2366
449925a6 2367 /*
4123fa9a 2368 * If saved session / Default Settings says SSH-1 (`1 only' or `1'),
2369 * then change it to SSH-2, on the grounds that that's more likely to
2370 * work for SFTP. (Can be overridden with `-1' option.)
2371 * But if it says `2 only' or `2', respect which.
2372 */
2373 if (cfg.sshprot != 2 && cfg.sshprot != 3)
2374 cfg.sshprot = 2;
2375
2376 /*
c0a81592 2377 * Enact command-line overrides.
2378 */
5555d393 2379 cmdline_run_saved(&cfg);
c0a81592 2380
2381 /*
449925a6 2382 * Trim leading whitespace off the hostname if it's there.
2383 */
2384 {
2385 int space = strspn(cfg.host, " \t");
2386 memmove(cfg.host, cfg.host+space, 1+strlen(cfg.host)-space);
2387 }
2388
2389 /* See if host is of the form user@host */
2390 if (cfg.host[0] != '\0') {
5dd103a8 2391 char *atsign = strrchr(cfg.host, '@');
449925a6 2392 /* Make sure we're not overflowing the user field */
2393 if (atsign) {
2394 if (atsign - cfg.host < sizeof cfg.username) {
2395 strncpy(cfg.username, cfg.host, atsign - cfg.host);
2396 cfg.username[atsign - cfg.host] = '\0';
2397 }
2398 memmove(cfg.host, atsign + 1, 1 + strlen(atsign + 1));
2399 }
2400 }
2401
2402 /*
2403 * Trim a colon suffix off the hostname if it's there.
2404 */
2405 cfg.host[strcspn(cfg.host, ":")] = '\0';
2406
cae0c023 2407 /*
2408 * Remove any remaining whitespace from the hostname.
2409 */
2410 {
2411 int p1 = 0, p2 = 0;
2412 while (cfg.host[p2] != '\0') {
2413 if (cfg.host[p2] != ' ' && cfg.host[p2] != '\t') {
2414 cfg.host[p1] = cfg.host[p2];
2415 p1++;
2416 }
2417 p2++;
2418 }
2419 cfg.host[p1] = '\0';
2420 }
2421
4a8fc3c4 2422 /* Set username */
2423 if (user != NULL && user[0] != '\0') {
32874aea 2424 strncpy(cfg.username, user, sizeof(cfg.username) - 1);
2425 cfg.username[sizeof(cfg.username) - 1] = '\0';
4a8fc3c4 2426 }
2427 if (!cfg.username[0]) {
b5af97b3 2428 if (!console_get_line("login as: ",
2429 cfg.username, sizeof(cfg.username), FALSE)) {
2430 fprintf(stderr, "psftp: no username, aborting\n");
93b581bd 2431 cleanup_exit(1);
4a8fc3c4 2432 } else {
2433 int len = strlen(cfg.username);
32874aea 2434 if (cfg.username[len - 1] == '\n')
2435 cfg.username[len - 1] = '\0';
4a8fc3c4 2436 }
2437 }
2438
4a8fc3c4 2439 if (portnumber)
2440 cfg.port = portnumber;
2441
d27b4a18 2442 /*
2443 * Disable scary things which shouldn't be enabled for simple
2444 * things like SCP and SFTP: agent forwarding, port forwarding,
2445 * X forwarding.
2446 */
2447 cfg.x11_forward = 0;
2448 cfg.agentfwd = 0;
2449 cfg.portfwd[0] = cfg.portfwd[1] = '\0';
2450
bebf22d0 2451 /* Set up subsystem name. */
4a8fc3c4 2452 strcpy(cfg.remote_cmd, "sftp");
2453 cfg.ssh_subsys = TRUE;
2454 cfg.nopty = TRUE;
2455
bebf22d0 2456 /*
2457 * Set up fallback option, for SSH1 servers or servers with the
2458 * sftp subsystem not enabled but the server binary installed
2459 * in the usual place. We only support fallback on Unix
248c0c5a 2460 * systems, and we use a kludgy piece of shellery which should
2461 * try to find sftp-server in various places (the obvious
2462 * systemwide spots /usr/lib and /usr/local/lib, and then the
2463 * user's PATH) and finally give up.
bebf22d0 2464 *
248c0c5a 2465 * test -x /usr/lib/sftp-server && exec /usr/lib/sftp-server
2466 * test -x /usr/local/lib/sftp-server && exec /usr/local/lib/sftp-server
2467 * exec sftp-server
bebf22d0 2468 *
2469 * the idea being that this will attempt to use either of the
2470 * obvious pathnames and then give up, and when it does give up
2471 * it will print the preferred pathname in the error messages.
2472 */
2473 cfg.remote_cmd_ptr2 =
248c0c5a 2474 "test -x /usr/lib/sftp-server && exec /usr/lib/sftp-server\n"
2475 "test -x /usr/local/lib/sftp-server && exec /usr/local/lib/sftp-server\n"
2476 "exec sftp-server";
bebf22d0 2477 cfg.ssh_subsys2 = FALSE;
2478
4a8fc3c4 2479 back = &ssh_backend;
2480
79bf227b 2481 err = back->init(NULL, &backhandle, &cfg, cfg.host, cfg.port, &realhost,
2482 0, cfg.tcp_keepalives);
4a8fc3c4 2483 if (err != NULL) {
fa3db767 2484 fprintf(stderr, "ssh_init: %s\n", err);
4a8fc3c4 2485 return 1;
2486 }
c229ef97 2487 logctx = log_init(NULL, &cfg);
a8327734 2488 back->provide_logctx(backhandle, logctx);
d3fef4a5 2489 console_provide_logctx(logctx);
d6cc41e6 2490 while (!back->sendok(backhandle)) {
2491 if (ssh_sftp_loop_iteration() < 0) {
2492 fprintf(stderr, "ssh_init: error during SSH connection setup\n");
2493 return 1;
2494 }
2495 }
4a8fc3c4 2496 if (verbose && realhost != NULL)
2497 printf("Connected to %s\n", realhost);
679539d7 2498 if (realhost != NULL)
2499 sfree(realhost);
fa3db767 2500 return 0;
2501}
2502
c0a81592 2503void cmdline_error(char *p, ...)
2504{
2505 va_list ap;
86256dc6 2506 fprintf(stderr, "psftp: ");
c0a81592 2507 va_start(ap, p);
2508 vfprintf(stderr, p, ap);
2509 va_end(ap);
86256dc6 2510 fprintf(stderr, "\n try typing \"psftp -h\" for help\n");
c0a81592 2511 exit(1);
2512}
2513
fa3db767 2514/*
2515 * Main program. Parse arguments etc.
2516 */
d6cc41e6 2517int psftp_main(int argc, char *argv[])
fa3db767 2518{
2519 int i;
2520 int portnumber = 0;
2521 char *userhost, *user;
2522 int mode = 0;
2523 int modeflags = 0;
2524 char *batchfile = NULL;
86256dc6 2525 int errors = 0;
fa3db767 2526
b51259f6 2527 flags = FLAG_STDERR | FLAG_INTERACTIVE
2528#ifdef FLAG_SYNCAGENT
2529 | FLAG_SYNCAGENT
2530#endif
2531 ;
c0a81592 2532 cmdline_tooltype = TOOLTYPE_FILETRANSFER;
ff2ae367 2533 ssh_get_line = &console_get_line;
fa3db767 2534 sk_init();
2535
2536 userhost = user = NULL;
2537
18e62ad8 2538 /* Load Default Settings before doing anything else. */
2539 do_defaults(NULL, &cfg);
2540 loaded_session = FALSE;
2541
86256dc6 2542 errors = 0;
fa3db767 2543 for (i = 1; i < argc; i++) {
c0a81592 2544 int ret;
fa3db767 2545 if (argv[i][0] != '-') {
c0a81592 2546 if (userhost)
2547 usage();
2548 else
2549 userhost = dupstr(argv[i]);
2550 continue;
2551 }
5555d393 2552 ret = cmdline_process_param(argv[i], i+1<argc?argv[i+1]:NULL, 1, &cfg);
c0a81592 2553 if (ret == -2) {
2554 cmdline_error("option \"%s\" requires an argument", argv[i]);
2555 } else if (ret == 2) {
2556 i++; /* skip next argument */
2557 } else if (ret == 1) {
2558 /* We have our own verbosity in addition to `flags'. */
2559 if (flags & FLAG_VERBOSE)
2560 verbose = 1;
fa3db767 2561 } else if (strcmp(argv[i], "-h") == 0 ||
2562 strcmp(argv[i], "-?") == 0) {
2563 usage();
dc108ebc 2564 } else if (strcmp(argv[i], "-V") == 0) {
2565 version();
c0a81592 2566 } else if (strcmp(argv[i], "-batch") == 0) {
2567 console_batch_mode = 1;
fa3db767 2568 } else if (strcmp(argv[i], "-b") == 0 && i + 1 < argc) {
2569 mode = 1;
2570 batchfile = argv[++i];
d13c2ee9 2571 } else if (strcmp(argv[i], "-bc") == 0) {
fa3db767 2572 modeflags = modeflags | 1;
d13c2ee9 2573 } else if (strcmp(argv[i], "-be") == 0) {
fa3db767 2574 modeflags = modeflags | 2;
2575 } else if (strcmp(argv[i], "--") == 0) {
2576 i++;
2577 break;
2578 } else {
86256dc6 2579 cmdline_error("unknown option \"%s\"", argv[i]);
fa3db767 2580 }
2581 }
2582 argc -= i;
2583 argv += i;
2584 back = NULL;
2585
2586 /*
e1bb41d1 2587 * If the loaded session provides a hostname, and a hostname has not
2588 * otherwise been specified, pop it in `userhost' so that
2589 * `psftp -load sessname' is sufficient to start a session.
2590 */
2591 if (!userhost && cfg.host[0] != '\0') {
2592 userhost = dupstr(cfg.host);
2593 }
2594
2595 /*
fa3db767 2596 * If a user@host string has already been provided, connect to
2597 * it now.
2598 */
2599 if (userhost) {
679539d7 2600 int ret;
2601 ret = psftp_connect(userhost, user, portnumber);
2602 sfree(userhost);
2603 if (ret)
fa3db767 2604 return 1;
774204f5 2605 if (do_sftp_init())
2606 return 1;
fa3db767 2607 } else {
2608 printf("psftp: no hostname specified; use \"open host.name\""
679539d7 2609 " to connect\n");
fa3db767 2610 }
4c7f0d61 2611
9954aaa3 2612 do_sftp(mode, modeflags, batchfile);
4a8fc3c4 2613
51470298 2614 if (back != NULL && back->socket(backhandle) != NULL) {
4a8fc3c4 2615 char ch;
51470298 2616 back->special(backhandle, TS_EOF);
4a8fc3c4 2617 sftp_recvdata(&ch, 1);
2618 }
b614ce89 2619 do_sftp_cleanup();
4a8fc3c4 2620 random_save_seed();
679539d7 2621 cmdline_cleanup();
2622 console_provide_logctx(NULL);
679539d7 2623 sk_cleanup();
4a8fc3c4 2624
4c7f0d61 2625 return 0;
2626}