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