0c3a63ee0e0e33a83a1de31e318303605d612711
[gpgme.git] / src / engine-gpg.c
1 /* engine-gpg.c - Gpg Engine.
2    Copyright (C) 2000 Werner Koch (dd9jn)
3    Copyright (C) 2001, 2002, 2003, 2004, 2005, 2006, 2007,
4                  2009, 2010, 2012, 2013 g10 Code GmbH
5
6    This file is part of GPGME.
7
8    GPGME is free software; you can redistribute it and/or modify it
9    under the terms of the GNU Lesser General Public License as
10    published by the Free Software Foundation; either version 2.1 of
11    the License, or (at your option) any later version.
12
13    GPGME is distributed in the hope that it will be useful, but
14    WITHOUT ANY WARRANTY; without even the implied warranty of
15    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
16    Lesser General Public License for more details.
17
18    You should have received a copy of the GNU Lesser General Public
19    License along with this program; if not, see <https://www.gnu.org/licenses/>.
20 */
21
22 #if HAVE_CONFIG_H
23 #include <config.h>
24 #endif
25 #include <stdio.h>
26 #include <stdlib.h>
27 #include <string.h>
28 #include <assert.h>
29 #include <errno.h>
30 #ifdef HAVE_UNISTD_H
31 # include <unistd.h>
32 #endif
33 #ifdef HAVE_LOCALE_H
34 #include <locale.h>
35 #endif
36
37 #include "gpgme.h"
38 #include "util.h"
39 #include "ops.h"
40 #include "wait.h"
41 #include "context.h"  /*temp hack until we have GpmeData methods to do I/O */
42 #include "priv-io.h"
43 #include "sema.h"
44 #include "debug.h"
45 #include "data.h"
46
47 #include "engine-backend.h"
48
49
50 /* This type is used to build a list of gpg arguments and data
51    sources/sinks.  */
52 struct arg_and_data_s
53 {
54   struct arg_and_data_s *next;
55   gpgme_data_t data;  /* If this is not NULL, use arg below.  */
56   int inbound;     /* True if this is used for reading from gpg.  */
57   int dup_to;
58   int print_fd;    /* Print the fd number and not the special form of it.  */
59   int *arg_locp;   /* Write back the argv idx of this argument when
60                       building command line to this location.  */
61   char arg[1];     /* Used if data above is not used.  */
62 };
63
64
65 struct fd_data_map_s
66 {
67   gpgme_data_t data;
68   int inbound;  /* true if this is used for reading from gpg */
69   int dup_to;
70   int fd;       /* the fd to use */
71   int peer_fd;  /* the other side of the pipe */
72   int arg_loc;  /* The index into the argv for translation purposes.  */
73   void *tag;
74 };
75
76
77 /* NB.: R_LINE is allocated an gpgrt function and thus gpgrt_free
78  * shall be used to release it.  This takes care of custom memory
79  * allocators and avoids problems on Windows with different runtimes
80  * used for libgpg-error/gpgrt and gpgme.  */
81 typedef gpgme_error_t (*colon_preprocessor_t) (char *line, char **rline);
82
83 struct engine_gpg
84 {
85   char *file_name;
86   char *version;
87
88   char *lc_messages;
89   char *lc_ctype;
90
91   struct arg_and_data_s *arglist;
92   struct arg_and_data_s **argtail;
93
94   struct
95   {
96     int fd[2];
97     int arg_loc;
98     size_t bufsize;
99     char *buffer;
100     size_t readpos;
101     int eof;
102     engine_status_handler_t fnc;
103     void *fnc_value;
104     gpgme_status_cb_t mon_cb;
105     void *mon_cb_value;
106     void *tag;
107   } status;
108
109   /* This is a kludge - see the comment at colon_line_handler.  */
110   struct
111   {
112     int fd[2];
113     int arg_loc;
114     size_t bufsize;
115     char *buffer;
116     size_t readpos;
117     int eof;
118     engine_colon_line_handler_t fnc;  /* this indicate use of this structrue */
119     void *fnc_value;
120     void *tag;
121     colon_preprocessor_t preprocess_fnc;
122   } colon;
123
124   char **argv;
125   struct fd_data_map_s *fd_data_map;
126
127   /* stuff needed for interactive (command) mode */
128   struct
129   {
130     int used;
131     int fd;
132     void *cb_data;
133     int idx;            /* Index in fd_data_map */
134     gpgme_status_code_t code;  /* last code */
135     char *keyword;       /* what has been requested (malloced) */
136     engine_command_handler_t fnc;
137     void *fnc_value;
138     /* The kludges never end.  This is used to couple command handlers
139        with output data in edit key mode.  */
140     gpgme_data_t linked_data;
141     int linked_idx;
142   } cmd;
143
144   struct gpgme_io_cbs io_cbs;
145   gpgme_pinentry_mode_t pinentry_mode;
146
147   /* NULL or the data object fed to --override_session_key-fd.  */
148   gpgme_data_t override_session_key;
149 };
150
151 typedef struct engine_gpg *engine_gpg_t;
152
153 \f
154 static void
155 gpg_io_event (void *engine, gpgme_event_io_t type, void *type_data)
156 {
157   engine_gpg_t gpg = engine;
158
159   TRACE3 (DEBUG_ENGINE, "gpgme:gpg_io_event", gpg,
160           "event %p, type %d, type_data %p",
161           gpg->io_cbs.event, type, type_data);
162   if (gpg->io_cbs.event)
163     (*gpg->io_cbs.event) (gpg->io_cbs.event_priv, type, type_data);
164 }
165
166
167 static void
168 close_notify_handler (int fd, void *opaque)
169 {
170   engine_gpg_t gpg = opaque;
171   assert (fd != -1);
172
173   if (gpg->status.fd[0] == fd)
174     {
175       if (gpg->status.tag)
176         (*gpg->io_cbs.remove) (gpg->status.tag);
177       gpg->status.fd[0] = -1;
178     }
179   else if (gpg->status.fd[1] == fd)
180     gpg->status.fd[1] = -1;
181   else if (gpg->colon.fd[0] == fd)
182     {
183       if (gpg->colon.tag)
184         (*gpg->io_cbs.remove) (gpg->colon.tag);
185       gpg->colon.fd[0] = -1;
186     }
187   else if (gpg->colon.fd[1] == fd)
188     gpg->colon.fd[1] = -1;
189   else if (gpg->cmd.fd == fd)
190     gpg->cmd.fd = -1;
191   else if (gpg->fd_data_map)
192     {
193       int i;
194
195       for (i = 0; gpg->fd_data_map[i].data; i++)
196         {
197           if (gpg->fd_data_map[i].fd == fd)
198             {
199               if (gpg->fd_data_map[i].tag)
200                 (*gpg->io_cbs.remove) (gpg->fd_data_map[i].tag);
201               gpg->fd_data_map[i].fd = -1;
202               break;
203             }
204           if (gpg->fd_data_map[i].peer_fd == fd)
205             {
206               gpg->fd_data_map[i].peer_fd = -1;
207               break;
208             }
209         }
210     }
211 }
212
213 /* If FRONT is true, push at the front of the list.  Use this for
214    options added late in the process.  */
215 static gpgme_error_t
216 _add_arg (engine_gpg_t gpg, const char *prefix, const char *arg, size_t arglen,
217           int front, int *arg_locp)
218 {
219   struct arg_and_data_s *a;
220   size_t prefixlen = prefix? strlen (prefix) : 0;
221
222   assert (gpg);
223   assert (arg);
224
225   a = malloc (sizeof *a + prefixlen + arglen);
226   if (!a)
227     return gpg_error_from_syserror ();
228
229   a->data = NULL;
230   a->dup_to = -1;
231   a->arg_locp = arg_locp;
232
233   if (prefixlen)
234     memcpy (a->arg, prefix, prefixlen);
235   memcpy (a->arg + prefixlen, arg, arglen);
236   a->arg[prefixlen + arglen] = 0;
237   if (front)
238     {
239       a->next = gpg->arglist;
240       if (!gpg->arglist)
241         {
242           /* If this is the first argument, we need to update the tail
243              pointer.  */
244           gpg->argtail = &a->next;
245         }
246       gpg->arglist = a;
247     }
248   else
249     {
250       a->next = NULL;
251       *gpg->argtail = a;
252       gpg->argtail = &a->next;
253     }
254
255   return 0;
256 }
257
258
259 static gpgme_error_t
260 add_arg_ext (engine_gpg_t gpg, const char *arg, int front)
261 {
262   return _add_arg (gpg, NULL, arg, strlen (arg), front, NULL);
263 }
264
265 static gpgme_error_t
266 add_arg_with_locp (engine_gpg_t gpg, const char *arg, int *locp)
267 {
268   return _add_arg (gpg, NULL, arg, strlen (arg), 0, locp);
269 }
270
271 static gpgme_error_t
272 add_arg (engine_gpg_t gpg, const char *arg)
273 {
274   return _add_arg (gpg, NULL, arg, strlen (arg), 0, NULL);
275 }
276
277 static gpgme_error_t
278 add_arg_pfx (engine_gpg_t gpg, const char *prefix, const char *arg)
279 {
280   return _add_arg (gpg, prefix, arg, strlen (arg), 0, NULL);
281 }
282
283 static gpgme_error_t
284 add_arg_len (engine_gpg_t gpg, const char *prefix,
285              const char *arg, size_t arglen)
286 {
287   return _add_arg (gpg, prefix, arg, arglen, 0, NULL);
288 }
289
290
291 static gpgme_error_t
292 add_data (engine_gpg_t gpg, gpgme_data_t data, int dup_to, int inbound)
293 {
294   struct arg_and_data_s *a;
295
296   assert (gpg);
297   assert (data);
298
299   a = malloc (sizeof *a - 1);
300   if (!a)
301     return gpg_error_from_syserror ();
302   a->next = NULL;
303   a->data = data;
304   a->inbound = inbound;
305   a->arg_locp = NULL;
306
307   if (dup_to == -2)
308     {
309       a->print_fd = 1;
310       a->dup_to = -1;
311     }
312   else
313     {
314       a->print_fd = 0;
315       a->dup_to = dup_to;
316     }
317   *gpg->argtail = a;
318   gpg->argtail = &a->next;
319   return 0;
320 }
321
322
323 /* Return true if the engine's version is at least VERSION.  */
324 static int
325 have_gpg_version (engine_gpg_t gpg, const char *version)
326 {
327   return _gpgme_compare_versions (gpg->version, version);
328 }
329
330
331 \f
332 static char *
333 gpg_get_version (const char *file_name)
334 {
335   return _gpgme_get_program_version (file_name ? file_name
336                                      : _gpgme_get_default_gpg_name ());
337 }
338
339
340 static const char *
341 gpg_get_req_version (void)
342 {
343   return "1.4.0";
344 }
345
346
347 static void
348 free_argv (char **argv)
349 {
350   int i;
351
352   for (i = 0; argv[i]; i++)
353     free (argv[i]);
354   free (argv);
355 }
356
357
358 static void
359 free_fd_data_map (struct fd_data_map_s *fd_data_map)
360 {
361   int i;
362
363   if (!fd_data_map)
364     return;
365
366   for (i = 0; fd_data_map[i].data; i++)
367     {
368       if (fd_data_map[i].fd != -1)
369         _gpgme_io_close (fd_data_map[i].fd);
370       if (fd_data_map[i].peer_fd != -1)
371         _gpgme_io_close (fd_data_map[i].peer_fd);
372       /* Don't release data because this is only a reference.  */
373     }
374   free (fd_data_map);
375 }
376
377
378 static gpgme_error_t
379 gpg_cancel (void *engine)
380 {
381   engine_gpg_t gpg = engine;
382
383   if (!gpg)
384     return gpg_error (GPG_ERR_INV_VALUE);
385
386   /* If gpg may be waiting for a cmd, close the cmd fd first.  On
387      Windows, close operations block on the reader/writer thread.  */
388   if (gpg->cmd.used)
389     {
390       if (gpg->cmd.fd != -1)
391         _gpgme_io_close (gpg->cmd.fd);
392       else if (gpg->fd_data_map
393                && gpg->fd_data_map[gpg->cmd.idx].fd != -1)
394         _gpgme_io_close (gpg->fd_data_map[gpg->cmd.idx].fd);
395     }
396
397   if (gpg->status.fd[0] != -1)
398     _gpgme_io_close (gpg->status.fd[0]);
399   if (gpg->status.fd[1] != -1)
400     _gpgme_io_close (gpg->status.fd[1]);
401   if (gpg->colon.fd[0] != -1)
402     _gpgme_io_close (gpg->colon.fd[0]);
403   if (gpg->colon.fd[1] != -1)
404     _gpgme_io_close (gpg->colon.fd[1]);
405   if (gpg->fd_data_map)
406     {
407       free_fd_data_map (gpg->fd_data_map);
408       gpg->fd_data_map = NULL;
409     }
410
411   return 0;
412 }
413
414 static void
415 gpg_release (void *engine)
416 {
417   engine_gpg_t gpg = engine;
418
419   if (!gpg)
420     return;
421
422   gpg_cancel (engine);
423
424   if (gpg->file_name)
425     free (gpg->file_name);
426   if (gpg->version)
427     free (gpg->version);
428
429   if (gpg->lc_messages)
430     free (gpg->lc_messages);
431   if (gpg->lc_ctype)
432     free (gpg->lc_ctype);
433
434   while (gpg->arglist)
435     {
436       struct arg_and_data_s *next = gpg->arglist->next;
437
438       free (gpg->arglist);
439       gpg->arglist = next;
440     }
441
442   if (gpg->status.buffer)
443     free (gpg->status.buffer);
444   if (gpg->colon.buffer)
445     free (gpg->colon.buffer);
446   if (gpg->argv)
447     free_argv (gpg->argv);
448   if (gpg->cmd.keyword)
449     free (gpg->cmd.keyword);
450
451   gpgme_data_release (gpg->override_session_key);
452
453   free (gpg);
454 }
455
456
457 static gpgme_error_t
458 gpg_new (void **engine, const char *file_name, const char *home_dir,
459          const char *version)
460 {
461   engine_gpg_t gpg;
462   gpgme_error_t rc = 0;
463   char *dft_display = NULL;
464   char dft_ttyname[64];
465   char *dft_ttytype = NULL;
466   char *env_tty = NULL;
467
468   gpg = calloc (1, sizeof *gpg);
469   if (!gpg)
470     return gpg_error_from_syserror ();
471
472   if (file_name)
473     {
474       gpg->file_name = strdup (file_name);
475       if (!gpg->file_name)
476         {
477           rc = gpg_error_from_syserror ();
478           goto leave;
479         }
480     }
481
482   if (version)
483     {
484       gpg->version = strdup (version);
485       if (!gpg->version)
486         {
487           rc = gpg_error_from_syserror ();
488           goto leave;
489         }
490     }
491
492   gpg->argtail = &gpg->arglist;
493   gpg->status.fd[0] = -1;
494   gpg->status.fd[1] = -1;
495   gpg->colon.fd[0] = -1;
496   gpg->colon.fd[1] = -1;
497   gpg->cmd.fd = -1;
498   gpg->cmd.idx = -1;
499   gpg->cmd.linked_data = NULL;
500   gpg->cmd.linked_idx = -1;
501
502   /* Allocate the read buffer for the status pipe.  */
503   gpg->status.bufsize = 1024;
504   gpg->status.readpos = 0;
505   gpg->status.buffer = malloc (gpg->status.bufsize);
506   if (!gpg->status.buffer)
507     {
508       rc = gpg_error_from_syserror ();
509       goto leave;
510     }
511   /* In any case we need a status pipe - create it right here and
512      don't handle it with our generic gpgme_data_t mechanism.  */
513   if (_gpgme_io_pipe (gpg->status.fd, 1) == -1)
514     {
515       rc = gpg_error_from_syserror ();
516       goto leave;
517     }
518   if (_gpgme_io_set_close_notify (gpg->status.fd[0],
519                                   close_notify_handler, gpg)
520       || _gpgme_io_set_close_notify (gpg->status.fd[1],
521                                      close_notify_handler, gpg))
522     {
523       rc = gpg_error (GPG_ERR_GENERAL);
524       goto leave;
525     }
526   gpg->status.eof = 0;
527
528   if (home_dir)
529     {
530       rc = add_arg (gpg, "--homedir");
531       if (!rc)
532         rc = add_arg (gpg, home_dir);
533       if (rc)
534         goto leave;
535     }
536
537   rc = add_arg (gpg, "--status-fd");
538   if (rc)
539     goto leave;
540
541   {
542     char buf[25];
543     _gpgme_io_fd2str (buf, sizeof (buf), gpg->status.fd[1]);
544     rc = add_arg_with_locp (gpg, buf, &gpg->status.arg_loc);
545     if (rc)
546       goto leave;
547   }
548
549   rc = add_arg (gpg, "--no-tty");
550   if (!rc)
551     rc = add_arg (gpg, "--charset");
552   if (!rc)
553     rc = add_arg (gpg, "utf8");
554   if (!rc)
555     rc = add_arg (gpg, "--enable-progress-filter");
556   if (!rc && have_gpg_version (gpg, "2.1.11"))
557     rc = add_arg (gpg, "--exit-on-status-write-error");
558   if (rc)
559     goto leave;
560
561   rc = _gpgme_getenv ("DISPLAY", &dft_display);
562   if (rc)
563     goto leave;
564   if (dft_display)
565     {
566       rc = add_arg (gpg, "--display");
567       if (!rc)
568         rc = add_arg (gpg, dft_display);
569
570       free (dft_display);
571       if (rc)
572         goto leave;
573     }
574
575   rc = _gpgme_getenv ("GPG_TTY", &env_tty);
576   if (isatty (1) || env_tty || rc)
577     {
578       int err = 0;
579
580       if (rc)
581         goto leave;
582       else if (env_tty)
583         {
584           snprintf (dft_ttyname, sizeof (dft_ttyname), "%s", env_tty);
585           free (env_tty);
586         }
587       else
588         err = ttyname_r (1, dft_ttyname, sizeof (dft_ttyname));
589
590       /* Even though isatty() returns 1, ttyname_r() may fail in many
591          ways, e.g., when /dev/pts is not accessible under chroot.  */
592       if (!err)
593         {
594           if (*dft_ttyname)
595             {
596               rc = add_arg (gpg, "--ttyname");
597               if (!rc)
598                 rc = add_arg (gpg, dft_ttyname);
599             }
600           else
601             rc = 0;
602           if (!rc)
603             {
604               rc = _gpgme_getenv ("TERM", &dft_ttytype);
605               if (rc)
606                 goto leave;
607
608               if (dft_ttytype)
609                 {
610                   rc = add_arg (gpg, "--ttytype");
611                   if (!rc)
612                     rc = add_arg (gpg, dft_ttytype);
613                 }
614
615               free (dft_ttytype);
616             }
617           if (rc)
618             goto leave;
619         }
620     }
621
622  leave:
623   if (rc)
624     gpg_release (gpg);
625   else
626     *engine = gpg;
627   return rc;
628 }
629
630
631 static gpgme_error_t
632 gpg_set_locale (void *engine, int category, const char *value)
633 {
634   engine_gpg_t gpg = engine;
635
636   if (0)
637     ;
638 #ifdef LC_CTYPE
639   else if (category == LC_CTYPE)
640     {
641       if (gpg->lc_ctype)
642         {
643           free (gpg->lc_ctype);
644           gpg->lc_ctype = NULL;
645         }
646       if (value)
647         {
648           gpg->lc_ctype = strdup (value);
649           if (!gpg->lc_ctype)
650             return gpg_error_from_syserror ();
651         }
652     }
653 #endif
654 #ifdef LC_MESSAGES
655   else if (category == LC_MESSAGES)
656     {
657       if (gpg->lc_messages)
658         {
659           free (gpg->lc_messages);
660           gpg->lc_messages = NULL;
661         }
662       if (value)
663         {
664           gpg->lc_messages = strdup (value);
665           if (!gpg->lc_messages)
666             return gpg_error_from_syserror ();
667         }
668     }
669 #endif /* LC_MESSAGES */
670   else
671     return gpg_error (GPG_ERR_INV_VALUE);
672
673   return 0;
674 }
675
676 /* This sets a status callback for monitoring status lines before they
677  * are passed to a caller set handler.  */
678 static void
679 gpg_set_status_cb (void *engine, gpgme_status_cb_t cb, void *cb_value)
680 {
681   engine_gpg_t gpg = engine;
682
683   gpg->status.mon_cb = cb;
684   gpg->status.mon_cb_value = cb_value;
685 }
686
687
688 /* Note, that the status_handler is allowed to modifiy the args
689    value.  */
690 static void
691 gpg_set_status_handler (void *engine, engine_status_handler_t fnc,
692                         void *fnc_value)
693 {
694   engine_gpg_t gpg = engine;
695
696   gpg->status.fnc = fnc;
697   gpg->status.fnc_value = fnc_value;
698 }
699
700 /* Kludge to process --with-colon output.  */
701 static gpgme_error_t
702 gpg_set_colon_line_handler (void *engine, engine_colon_line_handler_t fnc,
703                             void *fnc_value)
704 {
705   engine_gpg_t gpg = engine;
706
707   gpg->colon.bufsize = 1024;
708   gpg->colon.readpos = 0;
709   gpg->colon.buffer = malloc (gpg->colon.bufsize);
710   if (!gpg->colon.buffer)
711     return gpg_error_from_syserror ();
712
713   if (_gpgme_io_pipe (gpg->colon.fd, 1) == -1)
714     {
715       int saved_err = gpg_error_from_syserror ();
716       free (gpg->colon.buffer);
717       gpg->colon.buffer = NULL;
718       return saved_err;
719     }
720   if (_gpgme_io_set_close_notify (gpg->colon.fd[0], close_notify_handler, gpg)
721       || _gpgme_io_set_close_notify (gpg->colon.fd[1],
722                                      close_notify_handler, gpg))
723     return gpg_error (GPG_ERR_GENERAL);
724   gpg->colon.eof = 0;
725   gpg->colon.fnc = fnc;
726   gpg->colon.fnc_value = fnc_value;
727   return 0;
728 }
729
730
731 static gpgme_error_t
732 command_handler (void *opaque, int fd)
733 {
734   struct io_cb_data *data = (struct io_cb_data *) opaque;
735   engine_gpg_t gpg = (engine_gpg_t) data->handler_value;
736   gpgme_error_t err;
737   int processed = 0;
738   assert (gpg->cmd.used);
739   assert (gpg->cmd.code);
740   assert (gpg->cmd.fnc);
741
742   err = gpg->cmd.fnc (gpg->cmd.fnc_value, gpg->cmd.code, gpg->cmd.keyword, fd,
743                       &processed);
744
745   gpg->cmd.code = 0;
746   /* And sleep again until read_status will wake us up again.  */
747   /* XXX We must check if there are any more fds active after removing
748      this one.  */
749   (*gpg->io_cbs.remove) (gpg->fd_data_map[gpg->cmd.idx].tag);
750   gpg->cmd.fd = gpg->fd_data_map[gpg->cmd.idx].fd;
751   gpg->fd_data_map[gpg->cmd.idx].fd = -1;
752
753   if (err)
754     return err;
755
756   /* We always need to send at least a newline character.  */
757   if (!processed)
758     _gpgme_io_write (fd, "\n", 1);
759
760   return 0;
761 }
762
763
764
765 /* The Fnc will be called to get a value for one of the commands with
766    a key KEY.  If the Code passed to FNC is 0, the function may release
767    resources associated with the returned value from another call.  To
768    match such a second call to a first call, the returned value from
769    the first call is passed as keyword.  */
770 static gpgme_error_t
771 gpg_set_command_handler (void *engine, engine_command_handler_t fnc,
772                          void *fnc_value, gpgme_data_t linked_data)
773 {
774   engine_gpg_t gpg = engine;
775   gpgme_error_t rc;
776
777   rc = add_arg (gpg, "--command-fd");
778   if (rc)
779     return rc;
780
781   /* This is a hack.  We don't have a real data object.  The only
782      thing that matters is that we use something unique, so we use the
783      address of the cmd structure in the gpg object.  */
784   rc = add_data (gpg, (void *) &gpg->cmd, -2, 0);
785   if (rc)
786     return rc;
787
788   gpg->cmd.fnc = fnc;
789   gpg->cmd.cb_data = (void *) &gpg->cmd;
790   gpg->cmd.fnc_value = fnc_value;
791   gpg->cmd.linked_data = linked_data;
792   gpg->cmd.used = 1;
793   return 0;
794 }
795
796
797 static gpgme_error_t
798 build_argv (engine_gpg_t gpg, const char *pgmname)
799 {
800   gpgme_error_t err;
801   struct arg_and_data_s *a;
802   struct fd_data_map_s *fd_data_map;
803   size_t datac=0, argc=0;
804   char **argv;
805   int need_special = 0;
806   int use_agent = 0;
807   char *p;
808
809   if (_gpgme_in_gpg_one_mode ())
810     {
811       /* In GnuPG-1 mode we don't want to use the agent with a
812          malformed environment variable.  This is only a very basic
813          test but sufficient to make our life in the regression tests
814          easier.  With GnuPG-2 the agent is anyway required and on
815          modern installations GPG_AGENT_INFO is optional.  */
816       err = _gpgme_getenv ("GPG_AGENT_INFO", &p);
817       if (err)
818         return err;
819       use_agent = (p && strchr (p, ':'));
820       if (p)
821         free (p);
822     }
823
824   if (gpg->argv)
825     {
826       free_argv (gpg->argv);
827       gpg->argv = NULL;
828     }
829   if (gpg->fd_data_map)
830     {
831       free_fd_data_map (gpg->fd_data_map);
832       gpg->fd_data_map = NULL;
833     }
834
835   argc++;       /* For argv[0].  */
836   for (a = gpg->arglist; a; a = a->next)
837     {
838       argc++;
839       if (a->data)
840         {
841           /*fprintf (stderr, "build_argv: data\n" );*/
842           datac++;
843           if (a->dup_to == -1 && !a->print_fd)
844             need_special = 1;
845         }
846       else
847         {
848           /*   fprintf (stderr, "build_argv: arg=`%s'\n", a->arg );*/
849         }
850     }
851   if (need_special)
852     argc++;
853   if (use_agent)
854     argc++;
855   if (gpg->pinentry_mode)
856     argc++;
857   if (!gpg->cmd.used)
858     argc++;     /* --batch */
859   argc += 1;    /* --no-sk-comments */
860
861   argv = calloc (argc + 1, sizeof *argv);
862   if (!argv)
863     return gpg_error_from_syserror ();
864   fd_data_map = calloc (datac + 1, sizeof *fd_data_map);
865   if (!fd_data_map)
866     {
867       int saved_err = gpg_error_from_syserror ();
868       free_argv (argv);
869       return saved_err;
870     }
871
872   argc = datac = 0;
873   argv[argc] = strdup (_gpgme_get_basename (pgmname)); /* argv[0] */
874   if (!argv[argc])
875     {
876       int saved_err = gpg_error_from_syserror ();
877       free (fd_data_map);
878       free_argv (argv);
879       return saved_err;
880     }
881   argc++;
882   if (need_special)
883     {
884       argv[argc] = strdup ("--enable-special-filenames");
885       if (!argv[argc])
886         {
887           int saved_err = gpg_error_from_syserror ();
888           free (fd_data_map);
889           free_argv (argv);
890           return saved_err;
891         }
892       argc++;
893     }
894   if (use_agent)
895     {
896       argv[argc] = strdup ("--use-agent");
897       if (!argv[argc])
898         {
899           int saved_err = gpg_error_from_syserror ();
900           free (fd_data_map);
901           free_argv (argv);
902           return saved_err;
903         }
904       argc++;
905     }
906
907   if (gpg->pinentry_mode && have_gpg_version (gpg, "2.1.0"))
908     {
909       const char *s = NULL;
910       switch (gpg->pinentry_mode)
911         {
912         case GPGME_PINENTRY_MODE_DEFAULT: break;
913         case GPGME_PINENTRY_MODE_ASK:     s = "--pinentry-mode=ask"; break;
914         case GPGME_PINENTRY_MODE_CANCEL:  s = "--pinentry-mode=cancel"; break;
915         case GPGME_PINENTRY_MODE_ERROR:   s = "--pinentry-mode=error"; break;
916         case GPGME_PINENTRY_MODE_LOOPBACK:s = "--pinentry-mode=loopback"; break;
917         }
918       if (s)
919         {
920           argv[argc] = strdup (s);
921           if (!argv[argc])
922             {
923               int saved_err = gpg_error_from_syserror ();
924               free (fd_data_map);
925               free_argv (argv);
926               return saved_err;
927             }
928           argc++;
929         }
930     }
931
932   if (!gpg->cmd.used)
933     {
934       argv[argc] = strdup ("--batch");
935       if (!argv[argc])
936         {
937           int saved_err = gpg_error_from_syserror ();
938           free (fd_data_map);
939           free_argv (argv);
940           return saved_err;
941         }
942       argc++;
943     }
944   argv[argc] = strdup ("--no-sk-comments");
945   if (!argv[argc])
946     {
947       int saved_err = gpg_error_from_syserror ();
948       free (fd_data_map);
949       free_argv (argv);
950       return saved_err;
951     }
952   argc++;
953   for (a = gpg->arglist; a; a = a->next)
954     {
955       if (a->arg_locp)
956         *(a->arg_locp) = argc;
957
958       if (a->data)
959         {
960           /* Create a pipe to pass it down to gpg.  */
961           fd_data_map[datac].inbound = a->inbound;
962
963           /* Create a pipe.  */
964           {
965             int fds[2];
966
967             if (_gpgme_io_pipe (fds, fd_data_map[datac].inbound ? 1 : 0)
968                 == -1)
969               {
970                 int saved_errno = errno;
971                 free (fd_data_map);
972                 free_argv (argv);
973                 return gpg_error (saved_errno);
974               }
975             if (_gpgme_io_set_close_notify (fds[0],
976                                             close_notify_handler, gpg)
977                 || _gpgme_io_set_close_notify (fds[1],
978                                                close_notify_handler,
979                                                gpg))
980               {
981                 /* We leak fd_data_map and the fds.  This is not easy
982                    to avoid and given that we reach this here only
983                    after a malloc failure for a small object, it is
984                    probably better not to do anything.  */
985                 return gpg_error (GPG_ERR_GENERAL);
986               }
987             /* If the data_type is FD, we have to do a dup2 here.  */
988             if (fd_data_map[datac].inbound)
989               {
990                 fd_data_map[datac].fd       = fds[0];
991                 fd_data_map[datac].peer_fd  = fds[1];
992               }
993             else
994               {
995                 fd_data_map[datac].fd       = fds[1];
996                 fd_data_map[datac].peer_fd  = fds[0];
997               }
998           }
999
1000           /* Hack to get hands on the fd later.  */
1001           if (gpg->cmd.used)
1002             {
1003               if (gpg->cmd.cb_data == a->data)
1004                 {
1005                   assert (gpg->cmd.idx == -1);
1006                   gpg->cmd.idx = datac;
1007                 }
1008               else if (gpg->cmd.linked_data == a->data)
1009                 {
1010                   assert (gpg->cmd.linked_idx == -1);
1011                   gpg->cmd.linked_idx = datac;
1012                 }
1013             }
1014
1015           fd_data_map[datac].data = a->data;
1016           fd_data_map[datac].dup_to = a->dup_to;
1017
1018           if (a->dup_to == -1)
1019             {
1020               char *ptr;
1021               int buflen = 25;
1022
1023               argv[argc] = malloc (buflen);
1024               if (!argv[argc])
1025                 {
1026                   int saved_err = gpg_error_from_syserror ();
1027                   free (fd_data_map);
1028                   free_argv (argv);
1029                   return saved_err;
1030                 }
1031
1032               ptr = argv[argc];
1033               if (!a->print_fd)
1034                 {
1035                   *(ptr++) = '-';
1036                   *(ptr++) = '&';
1037                   buflen -= 2;
1038                 }
1039
1040               _gpgme_io_fd2str (ptr, buflen, fd_data_map[datac].peer_fd);
1041               fd_data_map[datac].arg_loc = argc;
1042               argc++;
1043             }
1044           datac++;
1045         }
1046       else
1047         {
1048           argv[argc] = strdup (a->arg);
1049           if (!argv[argc])
1050             {
1051               int saved_err = gpg_error_from_syserror ();
1052               free (fd_data_map);
1053               free_argv (argv);
1054               return saved_err;
1055             }
1056             argc++;
1057         }
1058     }
1059
1060   gpg->argv = argv;
1061   gpg->fd_data_map = fd_data_map;
1062   return 0;
1063 }
1064
1065
1066 static gpgme_error_t
1067 add_io_cb (engine_gpg_t gpg, int fd, int dir, gpgme_io_cb_t handler, void *data,
1068            void **tag)
1069 {
1070   gpgme_error_t err;
1071
1072   err = (*gpg->io_cbs.add) (gpg->io_cbs.add_priv, fd, dir, handler, data, tag);
1073   if (err)
1074     return err;
1075   if (!dir)
1076     /* FIXME Kludge around poll() problem.  */
1077     err = _gpgme_io_set_nonblocking (fd);
1078   return err;
1079 }
1080
1081
1082 /* Handle the status output of GnuPG.  This function does read entire
1083    lines and passes them as C strings to the callback function (we can
1084    use C Strings because the status output is always UTF-8 encoded).
1085    Of course we have to buffer the lines to cope with long lines
1086    e.g. with a large user ID.  Note: We can optimize this to only cope
1087    with status line code we know about and skip all other stuff
1088    without buffering (i.e. without extending the buffer).  */
1089 static gpgme_error_t
1090 read_status (engine_gpg_t gpg)
1091 {
1092   char *p;
1093   int nread;
1094   size_t bufsize = gpg->status.bufsize;
1095   char *buffer = gpg->status.buffer;
1096   size_t readpos = gpg->status.readpos;
1097   gpgme_error_t err;
1098
1099   assert (buffer);
1100   if (bufsize - readpos < 256)
1101     {
1102       /* Need more room for the read.  */
1103       bufsize += 1024;
1104       buffer = realloc (buffer, bufsize);
1105       if (!buffer)
1106         return gpg_error_from_syserror ();
1107     }
1108
1109   nread = _gpgme_io_read (gpg->status.fd[0],
1110                           buffer + readpos, bufsize-readpos);
1111   if (nread == -1)
1112     return gpg_error_from_syserror ();
1113
1114   if (!nread)
1115     {
1116       err = 0;
1117       gpg->status.eof = 1;
1118       if (gpg->status.mon_cb)
1119         err = gpg->status.mon_cb (gpg->status.mon_cb_value, "", "");
1120       if (gpg->status.fnc)
1121         {
1122           char emptystring[1] = {0};
1123           err = gpg->status.fnc (gpg->status.fnc_value,
1124                                  GPGME_STATUS_EOF, emptystring);
1125           if (gpg_err_code (err) == GPG_ERR_FALSE)
1126             err = 0; /* Drop special error code.  */
1127         }
1128
1129       return err;
1130     }
1131
1132   while (nread > 0)
1133     {
1134       for (p = buffer + readpos; nread; nread--, p++)
1135         {
1136           if (*p == '\n')
1137             {
1138               /* (we require that the last line is terminated by a LF) */
1139               if (p > buffer && p[-1] == '\r')
1140                 p[-1] = 0;
1141               *p = 0;
1142               if (!strncmp (buffer, "[GNUPG:] ", 9)
1143                   && buffer[9] >= 'A' && buffer[9] <= 'Z')
1144                 {
1145                   char *rest;
1146                   gpgme_status_code_t r;
1147
1148                   rest = strchr (buffer + 9, ' ');
1149                   if (!rest)
1150                     rest = p; /* Set to an empty string.  */
1151                   else
1152                     *rest++ = 0;
1153
1154                   r = _gpgme_parse_status (buffer + 9);
1155                   if (gpg->status.mon_cb && r != GPGME_STATUS_PROGRESS)
1156                     {
1157                       /* Note that we call the monitor even if we do
1158                        * not know the status code (r < 0).  */
1159                       err = gpg->status.mon_cb (gpg->status.mon_cb_value,
1160                                                 buffer + 9, rest);
1161                       if (err)
1162                         return err;
1163                     }
1164                   if (r >= 0)
1165                     {
1166                       if (gpg->cmd.used
1167                           && (r == GPGME_STATUS_GET_BOOL
1168                               || r == GPGME_STATUS_GET_LINE
1169                               || r == GPGME_STATUS_GET_HIDDEN))
1170                         {
1171                           gpg->cmd.code = r;
1172                           if (gpg->cmd.keyword)
1173                             free (gpg->cmd.keyword);
1174                           gpg->cmd.keyword = strdup (rest);
1175                           if (!gpg->cmd.keyword)
1176                             return gpg_error_from_syserror ();
1177                           /* This should be the last thing we have
1178                              received and the next thing will be that
1179                              the command handler does its action.  */
1180                           if (nread > 1)
1181                             TRACE0 (DEBUG_CTX, "gpgme:read_status", 0,
1182                                     "error: unexpected data");
1183
1184                           add_io_cb (gpg, gpg->cmd.fd, 0,
1185                                      command_handler, gpg,
1186                                      &gpg->fd_data_map[gpg->cmd.idx].tag);
1187                           gpg->fd_data_map[gpg->cmd.idx].fd = gpg->cmd.fd;
1188                           gpg->cmd.fd = -1;
1189                         }
1190                       else if (gpg->status.fnc)
1191                         {
1192                           err = gpg->status.fnc (gpg->status.fnc_value,
1193                                                  r, rest);
1194                           if (gpg_err_code (err) == GPG_ERR_FALSE)
1195                             err = 0; /* Drop special error code.  */
1196                           if (err)
1197                             return err;
1198                         }
1199
1200                       if (r == GPGME_STATUS_END_STREAM)
1201                         {
1202                           if (gpg->cmd.used)
1203                             {
1204                               /* Before we can actually add the
1205                                  command fd, we might have to flush
1206                                  the linked output data pipe.  */
1207                               if (gpg->cmd.linked_idx != -1
1208                                   && gpg->fd_data_map[gpg->cmd.linked_idx].fd
1209                                   != -1)
1210                                 {
1211                                   struct io_select_fd_s fds;
1212                                   fds.fd =
1213                                     gpg->fd_data_map[gpg->cmd.linked_idx].fd;
1214                                   fds.for_read = 1;
1215                                   fds.for_write = 0;
1216                                   fds.opaque = NULL;
1217                                   do
1218                                     {
1219                                       fds.signaled = 0;
1220                                       _gpgme_io_select (&fds, 1, 1);
1221                                       if (fds.signaled)
1222                                         _gpgme_data_inbound_handler
1223                                           (gpg->cmd.linked_data, fds.fd);
1224                                     }
1225                                   while (fds.signaled);
1226                                 }
1227
1228                               /* XXX We must check if there are any
1229                                  more fds active after removing this
1230                                  one.  */
1231                               (*gpg->io_cbs.remove)
1232                                 (gpg->fd_data_map[gpg->cmd.idx].tag);
1233                               gpg->cmd.fd = gpg->fd_data_map[gpg->cmd.idx].fd;
1234                               gpg->fd_data_map[gpg->cmd.idx].fd = -1;
1235                             }
1236                         }
1237                     }
1238                 }
1239               /* To reuse the buffer for the next line we have to
1240                  shift the remaining data to the buffer start and
1241                  restart the loop Hmmm: We can optimize this function
1242                  by looking forward in the buffer to see whether a
1243                  second complete line is available and in this case
1244                  avoid the memmove for this line.  */
1245               nread--; p++;
1246               if (nread)
1247                 memmove (buffer, p, nread);
1248               readpos = 0;
1249               break; /* the for loop */
1250             }
1251           else
1252             readpos++;
1253         }
1254     }
1255
1256   /* Update the gpg object.  */
1257   gpg->status.bufsize = bufsize;
1258   gpg->status.buffer = buffer;
1259   gpg->status.readpos = readpos;
1260   return 0;
1261 }
1262
1263
1264 static gpgme_error_t
1265 status_handler (void *opaque, int fd)
1266 {
1267   struct io_cb_data *data = (struct io_cb_data *) opaque;
1268   engine_gpg_t gpg = (engine_gpg_t) data->handler_value;
1269   int err;
1270
1271   assert (fd == gpg->status.fd[0]);
1272   err = read_status (gpg);
1273   if (err)
1274     return err;
1275   if (gpg->status.eof)
1276     _gpgme_io_close (fd);
1277   return 0;
1278 }
1279
1280
1281 static gpgme_error_t
1282 read_colon_line (engine_gpg_t gpg)
1283 {
1284   char *p;
1285   int nread;
1286   size_t bufsize = gpg->colon.bufsize;
1287   char *buffer = gpg->colon.buffer;
1288   size_t readpos = gpg->colon.readpos;
1289
1290   assert (buffer);
1291   if (bufsize - readpos < 256)
1292     {
1293       /* Need more room for the read.  */
1294       bufsize += 1024;
1295       buffer = realloc (buffer, bufsize);
1296       if (!buffer)
1297         return gpg_error_from_syserror ();
1298     }
1299
1300   nread = _gpgme_io_read (gpg->colon.fd[0], buffer+readpos, bufsize-readpos);
1301   if (nread == -1)
1302     return gpg_error_from_syserror ();
1303
1304   if (!nread)
1305     {
1306       gpg->colon.eof = 1;
1307       assert (gpg->colon.fnc);
1308       gpg->colon.fnc (gpg->colon.fnc_value, NULL);
1309       return 0;
1310     }
1311
1312   while (nread > 0)
1313     {
1314       for (p = buffer + readpos; nread; nread--, p++)
1315         {
1316           if ( *p == '\n' )
1317             {
1318               /* (we require that the last line is terminated by a LF)
1319                  and we skip empty lines.  Note: we use UTF8 encoding
1320                  and escaping of special characters.  We require at
1321                  least one colon to cope with some other printed
1322                  information.  */
1323               *p = 0;
1324               if (*buffer && strchr (buffer, ':'))
1325                 {
1326                   char *line = NULL;
1327
1328                   if (gpg->colon.preprocess_fnc)
1329                     {
1330                       gpgme_error_t err;
1331
1332                       err = gpg->colon.preprocess_fnc (buffer, &line);
1333                       if (err)
1334                         return err;
1335                     }
1336
1337                   assert (gpg->colon.fnc);
1338                   if (line)
1339                     {
1340                       char *linep = line;
1341                       char *endp;
1342
1343                       do
1344                         {
1345                           endp = strchr (linep, '\n');
1346                           if (endp)
1347                             *endp++ = 0;
1348                           gpg->colon.fnc (gpg->colon.fnc_value, linep);
1349                           linep = endp;
1350                         }
1351                       while (linep && *linep);
1352
1353                       gpgrt_free (line);
1354                     }
1355                   else
1356                     gpg->colon.fnc (gpg->colon.fnc_value, buffer);
1357                 }
1358
1359               /* To reuse the buffer for the next line we have to
1360                  shift the remaining data to the buffer start and
1361                  restart the loop Hmmm: We can optimize this function
1362                  by looking forward in the buffer to see whether a
1363                  second complete line is available and in this case
1364                  avoid the memmove for this line.  */
1365               nread--; p++;
1366               if (nread)
1367                 memmove (buffer, p, nread);
1368               readpos = 0;
1369               break; /* The for loop.  */
1370             }
1371           else
1372             readpos++;
1373         }
1374     }
1375
1376   /* Update the gpg object.  */
1377   gpg->colon.bufsize = bufsize;
1378   gpg->colon.buffer  = buffer;
1379   gpg->colon.readpos = readpos;
1380   return 0;
1381 }
1382
1383
1384 /* This colonline handler thing is not the clean way to do it.  It
1385    might be better to enhance the gpgme_data_t object to act as a wrapper
1386    for a callback.  Same goes for the status thing.  For now we use
1387    this thing here because it is easier to implement.  */
1388 static gpgme_error_t
1389 colon_line_handler (void *opaque, int fd)
1390 {
1391   struct io_cb_data *data = (struct io_cb_data *) opaque;
1392   engine_gpg_t gpg = (engine_gpg_t) data->handler_value;
1393   gpgme_error_t rc = 0;
1394
1395   assert (fd == gpg->colon.fd[0]);
1396   rc = read_colon_line (gpg);
1397   if (rc)
1398     return rc;
1399   if (gpg->colon.eof)
1400     _gpgme_io_close (fd);
1401   return 0;
1402 }
1403
1404
1405 static gpgme_error_t
1406 start (engine_gpg_t gpg)
1407 {
1408   gpgme_error_t rc;
1409   int i, n;
1410   int status;
1411   struct spawn_fd_item_s *fd_list;
1412   pid_t pid;
1413   const char *pgmname;
1414
1415   if (!gpg)
1416     return gpg_error (GPG_ERR_INV_VALUE);
1417
1418   if (!gpg->file_name && !_gpgme_get_default_gpg_name ())
1419     return trace_gpg_error (GPG_ERR_INV_ENGINE);
1420
1421   if (gpg->lc_ctype)
1422     {
1423       rc = add_arg_ext (gpg, gpg->lc_ctype, 1);
1424       if (!rc)
1425         rc = add_arg_ext (gpg, "--lc-ctype", 1);
1426       if (rc)
1427         return rc;
1428     }
1429
1430   if (gpg->lc_messages)
1431     {
1432       rc = add_arg_ext (gpg, gpg->lc_messages, 1);
1433       if (!rc)
1434         rc = add_arg_ext (gpg, "--lc-messages", 1);
1435       if (rc)
1436         return rc;
1437     }
1438
1439   pgmname = gpg->file_name ? gpg->file_name : _gpgme_get_default_gpg_name ();
1440   rc = build_argv (gpg, pgmname);
1441   if (rc)
1442     return rc;
1443
1444   /* status_fd, colon_fd and end of list.  */
1445   n = 3;
1446   for (i = 0; gpg->fd_data_map[i].data; i++)
1447     n++;
1448   fd_list = calloc (n, sizeof *fd_list);
1449   if (! fd_list)
1450     return gpg_error_from_syserror ();
1451
1452   /* Build the fd list for the child.  */
1453   n = 0;
1454   fd_list[n].fd = gpg->status.fd[1];
1455   fd_list[n].dup_to = -1;
1456   fd_list[n].arg_loc = gpg->status.arg_loc;
1457   n++;
1458   if (gpg->colon.fnc)
1459     {
1460       fd_list[n].fd = gpg->colon.fd[1];
1461       fd_list[n].dup_to = 1;
1462       n++;
1463     }
1464   for (i = 0; gpg->fd_data_map[i].data; i++)
1465     {
1466       fd_list[n].fd = gpg->fd_data_map[i].peer_fd;
1467       fd_list[n].dup_to = gpg->fd_data_map[i].dup_to;
1468       fd_list[n].arg_loc = gpg->fd_data_map[i].arg_loc;
1469       n++;
1470     }
1471   fd_list[n].fd = -1;
1472   fd_list[n].dup_to = -1;
1473
1474   status = _gpgme_io_spawn (pgmname, gpg->argv,
1475                             (IOSPAWN_FLAG_DETACHED |IOSPAWN_FLAG_ALLOW_SET_FG),
1476                             fd_list, NULL, NULL, &pid);
1477   {
1478     int saved_err = gpg_error_from_syserror ();
1479     free (fd_list);
1480     if (status == -1)
1481       return saved_err;
1482   }
1483
1484   /*_gpgme_register_term_handler ( closure, closure_value, pid );*/
1485
1486   rc = add_io_cb (gpg, gpg->status.fd[0], 1, status_handler, gpg,
1487                   &gpg->status.tag);
1488   if (rc)
1489     /* FIXME: kill the child */
1490     return rc;
1491
1492   if (gpg->colon.fnc)
1493     {
1494       assert (gpg->colon.fd[0] != -1);
1495       rc = add_io_cb (gpg, gpg->colon.fd[0], 1, colon_line_handler, gpg,
1496                       &gpg->colon.tag);
1497       if (rc)
1498         /* FIXME: kill the child */
1499         return rc;
1500     }
1501
1502   for (i = 0; gpg->fd_data_map[i].data; i++)
1503     {
1504       if (gpg->cmd.used && i == gpg->cmd.idx)
1505         {
1506           /* Park the cmd fd.  */
1507           gpg->cmd.fd = gpg->fd_data_map[i].fd;
1508           gpg->fd_data_map[i].fd = -1;
1509         }
1510       else
1511         {
1512           rc = add_io_cb (gpg, gpg->fd_data_map[i].fd,
1513                           gpg->fd_data_map[i].inbound,
1514                           gpg->fd_data_map[i].inbound
1515                           ? _gpgme_data_inbound_handler
1516                           : _gpgme_data_outbound_handler,
1517                           gpg->fd_data_map[i].data, &gpg->fd_data_map[i].tag);
1518
1519           if (rc)
1520             /* FIXME: kill the child */
1521             return rc;
1522         }
1523     }
1524
1525   gpg_io_event (gpg, GPGME_EVENT_START, NULL);
1526
1527   /* fixme: check what data we can release here */
1528   return 0;
1529 }
1530
1531
1532 /* Add the --input-size-hint option if requested.  */
1533 static gpgme_error_t
1534 add_input_size_hint (engine_gpg_t gpg, gpgme_data_t data)
1535 {
1536   gpgme_error_t err;
1537   gpgme_off_t value = _gpgme_data_get_size_hint (data);
1538   char numbuf[50];  /* Large enough for even 2^128 in base-10.  */
1539   char *p;
1540
1541   if (!value || !have_gpg_version (gpg, "2.1.15"))
1542     return 0;
1543
1544   err = add_arg (gpg, "--input-size-hint");
1545   if (!err)
1546     {
1547       p = numbuf + sizeof numbuf;
1548       *--p = 0;
1549       do
1550         {
1551           *--p = '0' + (value % 10);
1552           value /= 10;
1553         }
1554       while (value);
1555       err = add_arg (gpg, p);
1556     }
1557   return err;
1558 }
1559
1560
1561 static gpgme_error_t
1562 gpg_decrypt (void *engine,
1563              gpgme_decrypt_flags_t flags,
1564              gpgme_data_t ciph, gpgme_data_t plain,
1565              int export_session_key, const char *override_session_key)
1566 {
1567   engine_gpg_t gpg = engine;
1568   gpgme_error_t err;
1569
1570   err = add_arg (gpg, "--decrypt");
1571
1572   if (!err && (flags & GPGME_DECRYPT_UNWRAP))
1573     {
1574       if (!have_gpg_version (gpg, "2.1.12"))
1575         err = gpg_error (GPG_ERR_NOT_SUPPORTED);
1576       else
1577         err = add_arg (gpg, "--unwrap");
1578     }
1579
1580   if (!err && export_session_key)
1581     err = add_arg (gpg, "--show-session-key");
1582
1583   if (!err && override_session_key && *override_session_key)
1584     {
1585       if (have_gpg_version (gpg, "2.1.16"))
1586         {
1587           gpgme_data_release (gpg->override_session_key);
1588           TRACE2 (DEBUG_ENGINE, "override", gpg, "seskey='%s' len=%zu\n",
1589                   override_session_key,
1590                   strlen (override_session_key));
1591
1592           err = gpgme_data_new_from_mem (&gpg->override_session_key,
1593                                          override_session_key,
1594                                          strlen (override_session_key), 1);
1595           if (!err)
1596             {
1597               err = add_arg (gpg, "--override-session-key-fd");
1598               if (!err)
1599                 err = add_data (gpg, gpg->override_session_key, -2, 0);
1600             }
1601         }
1602       else
1603         {
1604           /* Using that option may leak the session key via ps(1).  */
1605           err = add_arg (gpg, "--override-session-key");
1606           if (!err)
1607             err = add_arg (gpg, override_session_key);
1608         }
1609     }
1610
1611   /* Tell the gpg object about the data.  */
1612   if (!err)
1613     err = add_arg (gpg, "--output");
1614   if (!err)
1615     err = add_arg (gpg, "-");
1616   if (!err)
1617     err = add_data (gpg, plain, 1, 1);
1618   if (!err)
1619     err = add_input_size_hint (gpg, ciph);
1620   if (!err)
1621     err = add_arg (gpg, "--");
1622   if (!err)
1623     err = add_data (gpg, ciph, -1, 0);
1624
1625   if (!err)
1626     err = start (gpg);
1627   return err;
1628 }
1629
1630 static gpgme_error_t
1631 gpg_delete (void *engine, gpgme_key_t key, int allow_secret)
1632 {
1633   engine_gpg_t gpg = engine;
1634   gpgme_error_t err;
1635
1636   err = add_arg (gpg, allow_secret ? "--delete-secret-and-public-key"
1637                  : "--delete-key");
1638   if (!err)
1639     err = add_arg (gpg, "--");
1640   if (!err)
1641     {
1642       if (!key->subkeys || !key->subkeys->fpr)
1643         return gpg_error (GPG_ERR_INV_VALUE);
1644       else
1645         err = add_arg (gpg, key->subkeys->fpr);
1646     }
1647
1648   if (!err)
1649     err = start (gpg);
1650   return err;
1651 }
1652
1653
1654 static gpgme_error_t
1655 gpg_passwd (void *engine, gpgme_key_t key, unsigned int flags)
1656 {
1657   engine_gpg_t gpg = engine;
1658   gpgme_error_t err;
1659
1660   (void)flags;
1661
1662   if (!key || !key->subkeys || !key->subkeys->fpr)
1663     return gpg_error (GPG_ERR_INV_CERT_OBJ);
1664
1665   err = add_arg (gpg, "--passwd");
1666   if (!err)
1667     err = add_arg (gpg, key->subkeys->fpr);
1668   if (!err)
1669     err = start (gpg);
1670   return err;
1671 }
1672
1673
1674 static gpgme_error_t
1675 append_args_from_signers (engine_gpg_t gpg, gpgme_ctx_t ctx /* FIXME */)
1676 {
1677   gpgme_error_t err = 0;
1678   int i;
1679   gpgme_key_t key;
1680
1681   for (i = 0; (key = gpgme_signers_enum (ctx, i)); i++)
1682     {
1683       const char *s = key->subkeys ? key->subkeys->keyid : NULL;
1684       if (s)
1685         {
1686           if (!err)
1687             err = add_arg (gpg, "-u");
1688           if (!err)
1689             err = add_arg (gpg, s);
1690         }
1691       gpgme_key_unref (key);
1692       if (err)
1693         break;
1694     }
1695   return err;
1696 }
1697
1698
1699 static gpgme_error_t
1700 append_args_from_sender (engine_gpg_t gpg, gpgme_ctx_t ctx)
1701 {
1702   gpgme_error_t err;
1703
1704   if (ctx->sender && have_gpg_version (gpg, "2.1.15"))
1705     {
1706       err = add_arg (gpg, "--sender");
1707       if (!err)
1708         err = add_arg (gpg, ctx->sender);
1709     }
1710   else
1711     err = 0;
1712   return err;
1713 }
1714
1715
1716 static gpgme_error_t
1717 append_args_from_sig_notations (engine_gpg_t gpg, gpgme_ctx_t ctx /* FIXME */)
1718 {
1719   gpgme_error_t err = 0;
1720   gpgme_sig_notation_t notation;
1721
1722   notation = gpgme_sig_notation_get (ctx);
1723
1724   while (!err && notation)
1725     {
1726       if (notation->name
1727           && !(notation->flags & GPGME_SIG_NOTATION_HUMAN_READABLE))
1728         err = gpg_error (GPG_ERR_INV_VALUE);
1729       else if (notation->name)
1730         {
1731           char *arg;
1732
1733           /* Maximum space needed is one byte for the "critical" flag,
1734              the name, one byte for '=', the value, and a terminating
1735              '\0'.  */
1736
1737           arg = malloc (1 + notation->name_len + 1 + notation->value_len + 1);
1738           if (!arg)
1739             err = gpg_error_from_syserror ();
1740
1741           if (!err)
1742             {
1743               char *argp = arg;
1744
1745               if (notation->critical)
1746                 *(argp++) = '!';
1747
1748               memcpy (argp, notation->name, notation->name_len);
1749               argp += notation->name_len;
1750
1751               *(argp++) = '=';
1752
1753               /* We know that notation->name is '\0' terminated.  */
1754               strcpy (argp, notation->value);
1755             }
1756
1757           if (!err)
1758             err = add_arg (gpg, "--sig-notation");
1759           if (!err)
1760             err = add_arg (gpg, arg);
1761
1762           if (arg)
1763             free (arg);
1764         }
1765       else
1766         {
1767           /* This is a policy URL.  */
1768
1769           char *value;
1770
1771           if (notation->critical)
1772             {
1773               value = malloc (1 + notation->value_len + 1);
1774               if (!value)
1775                 err = gpg_error_from_syserror ();
1776               else
1777                 {
1778                   value[0] = '!';
1779                   /* We know that notation->value is '\0' terminated.  */
1780                   strcpy (&value[1], notation->value);
1781                 }
1782             }
1783           else
1784             value = notation->value;
1785
1786           if (!err)
1787             err = add_arg (gpg, "--sig-policy-url");
1788           if (!err)
1789             err = add_arg (gpg, value);
1790
1791           if (value != notation->value)
1792             free (value);
1793         }
1794
1795       notation = notation->next;
1796     }
1797   return err;
1798 }
1799
1800
1801 static gpgme_error_t
1802 gpg_edit (void *engine, int type, gpgme_key_t key, gpgme_data_t out,
1803           gpgme_ctx_t ctx /* FIXME */)
1804 {
1805   engine_gpg_t gpg = engine;
1806   gpgme_error_t err;
1807
1808   err = add_arg (gpg, "--with-colons");
1809   if (!err)
1810     err = append_args_from_signers (gpg, ctx);
1811   if (!err)
1812   err = add_arg (gpg, type == 0 ? "--edit-key" : "--card-edit");
1813   if (!err)
1814     err = add_data (gpg, out, 1, 1);
1815   if (!err)
1816     err = add_arg (gpg, "--");
1817   if (!err && type == 0)
1818     {
1819       const char *s = key->subkeys ? key->subkeys->fpr : NULL;
1820       if (!s)
1821         err = gpg_error (GPG_ERR_INV_VALUE);
1822       else
1823         err = add_arg (gpg, s);
1824     }
1825   if (!err)
1826     err = start (gpg);
1827
1828   return err;
1829 }
1830
1831
1832 static gpgme_error_t
1833 append_args_from_recipients (engine_gpg_t gpg, gpgme_key_t recp[])
1834 {
1835   gpgme_error_t err = 0;
1836   int i = 0;
1837
1838   while (recp[i])
1839     {
1840       if (!recp[i]->subkeys || !recp[i]->subkeys->fpr)
1841         err = gpg_error (GPG_ERR_INV_VALUE);
1842       if (!err)
1843         err = add_arg (gpg, "-r");
1844       if (!err)
1845         err = add_arg (gpg, recp[i]->subkeys->fpr);
1846       if (err)
1847         break;
1848       i++;
1849     }
1850   return err;
1851 }
1852
1853
1854 static gpgme_error_t
1855 gpg_encrypt (void *engine, gpgme_key_t recp[], gpgme_encrypt_flags_t flags,
1856              gpgme_data_t plain, gpgme_data_t ciph, int use_armor)
1857 {
1858   engine_gpg_t gpg = engine;
1859   gpgme_error_t err = 0;
1860
1861   if (recp)
1862     err = add_arg (gpg, "--encrypt");
1863
1864   if (!err && ((flags & GPGME_ENCRYPT_SYMMETRIC) || !recp))
1865     err = add_arg (gpg, "--symmetric");
1866
1867   if (!err && use_armor)
1868     err = add_arg (gpg, "--armor");
1869
1870   if (!err && (flags & GPGME_ENCRYPT_WRAP))
1871     {
1872       /* gpg is current not abale to detect already compressed
1873        * packets.  Thus when using
1874        *   gpg --unwrap -d | gpg --no-literal -e
1875        * the encryption would add an additional compression layer.
1876        * We better suppress that.  */
1877       flags |= GPGME_ENCRYPT_NO_COMPRESS;
1878       err = add_arg (gpg, "--no-literal");
1879     }
1880
1881   if (!err && (flags & GPGME_ENCRYPT_NO_COMPRESS))
1882     err = add_arg (gpg, "--compress-algo=none");
1883
1884   if (!err && (flags & GPGME_ENCRYPT_THROW_KEYIDS))
1885     err = add_arg (gpg, "--throw-keyids");
1886
1887   if (gpgme_data_get_encoding (plain) == GPGME_DATA_ENCODING_MIME
1888       && have_gpg_version (gpg, "2.1.14"))
1889     err = add_arg (gpg, "--mimemode");
1890
1891   if (recp)
1892     {
1893       /* If we know that all recipients are valid (full or ultimate trust)
1894          we can suppress further checks.  */
1895       if (!err && (flags & GPGME_ENCRYPT_ALWAYS_TRUST))
1896         err = add_arg (gpg, "--always-trust");
1897
1898       if (!err && (flags & GPGME_ENCRYPT_NO_ENCRYPT_TO))
1899         err = add_arg (gpg, "--no-encrypt-to");
1900
1901       if (!err)
1902         err = append_args_from_recipients (gpg, recp);
1903     }
1904
1905   /* Tell the gpg object about the data.  */
1906   if (!err)
1907     err = add_arg (gpg, "--output");
1908   if (!err)
1909     err = add_arg (gpg, "-");
1910   if (!err)
1911     err = add_data (gpg, ciph, 1, 1);
1912   if (gpgme_data_get_file_name (plain))
1913     {
1914       if (!err)
1915         err = add_arg (gpg, "--set-filename");
1916       if (!err)
1917         err = add_arg (gpg, gpgme_data_get_file_name (plain));
1918     }
1919   if (!err)
1920     err = add_input_size_hint (gpg, plain);
1921   if (!err)
1922     err = add_arg (gpg, "--");
1923   if (!err)
1924     err = add_data (gpg, plain, -1, 0);
1925
1926   if (!err)
1927     err = start (gpg);
1928
1929   return err;
1930 }
1931
1932
1933 static gpgme_error_t
1934 gpg_encrypt_sign (void *engine, gpgme_key_t recp[],
1935                   gpgme_encrypt_flags_t flags, gpgme_data_t plain,
1936                   gpgme_data_t ciph, int use_armor,
1937                   gpgme_ctx_t ctx /* FIXME */)
1938 {
1939   engine_gpg_t gpg = engine;
1940   gpgme_error_t err = 0;
1941
1942   if (recp)
1943     err = add_arg (gpg, "--encrypt");
1944
1945   if (!err && ((flags & GPGME_ENCRYPT_SYMMETRIC) || !recp))
1946     err = add_arg (gpg, "--symmetric");
1947
1948   if (!err)
1949     err = add_arg (gpg, "--sign");
1950   if (!err && use_armor)
1951     err = add_arg (gpg, "--armor");
1952
1953   if (!err && (flags & GPGME_ENCRYPT_NO_COMPRESS))
1954     err = add_arg (gpg, "--compress-algo=none");
1955
1956   if (!err && (flags & GPGME_ENCRYPT_THROW_KEYIDS))
1957     err = add_arg (gpg, "--throw-keyids");
1958
1959   if (gpgme_data_get_encoding (plain) == GPGME_DATA_ENCODING_MIME
1960       && have_gpg_version (gpg, "2.1.14"))
1961     err = add_arg (gpg, "--mimemode");
1962
1963   if (recp)
1964     {
1965       /* If we know that all recipients are valid (full or ultimate trust)
1966          we can suppress further checks.  */
1967       if (!err && (flags & GPGME_ENCRYPT_ALWAYS_TRUST))
1968         err = add_arg (gpg, "--always-trust");
1969
1970       if (!err && (flags & GPGME_ENCRYPT_NO_ENCRYPT_TO))
1971         err = add_arg (gpg, "--no-encrypt-to");
1972
1973       if (!err)
1974         err = append_args_from_recipients (gpg, recp);
1975     }
1976
1977   if (!err)
1978     err = append_args_from_signers (gpg, ctx);
1979
1980   if (!err)
1981     err = append_args_from_sender (gpg, ctx);
1982
1983   if (!err)
1984     err = append_args_from_sig_notations (gpg, ctx);
1985
1986   /* Tell the gpg object about the data.  */
1987   if (!err)
1988     err = add_arg (gpg, "--output");
1989   if (!err)
1990     err = add_arg (gpg, "-");
1991   if (!err)
1992     err = add_data (gpg, ciph, 1, 1);
1993   if (gpgme_data_get_file_name (plain))
1994     {
1995       if (!err)
1996         err = add_arg (gpg, "--set-filename");
1997       if (!err)
1998         err = add_arg (gpg, gpgme_data_get_file_name (plain));
1999     }
2000   if (!err)
2001     err = add_input_size_hint (gpg, plain);
2002   if (!err)
2003     err = add_arg (gpg, "--");
2004   if (!err)
2005     err = add_data (gpg, plain, -1, 0);
2006
2007   if (!err)
2008     err = start (gpg);
2009
2010   return err;
2011 }
2012
2013
2014 static gpgme_error_t
2015 export_common (engine_gpg_t gpg, gpgme_export_mode_t mode,
2016                gpgme_data_t keydata, int use_armor)
2017 {
2018   gpgme_error_t err = 0;
2019
2020   if ((mode & ~(GPGME_EXPORT_MODE_EXTERN
2021                 |GPGME_EXPORT_MODE_MINIMAL
2022                 |GPGME_EXPORT_MODE_SECRET)))
2023     return gpg_error (GPG_ERR_NOT_SUPPORTED);
2024
2025   if ((mode & GPGME_EXPORT_MODE_MINIMAL))
2026     err = add_arg (gpg, "--export-options=export-minimal");
2027
2028   if (err)
2029     ;
2030   else if ((mode & GPGME_EXPORT_MODE_EXTERN))
2031     {
2032       err = add_arg (gpg, "--send-keys");
2033     }
2034   else
2035     {
2036       if ((mode & GPGME_EXPORT_MODE_SECRET))
2037         err = add_arg (gpg, "--export-secret-keys");
2038       else
2039         err = add_arg (gpg, "--export");
2040       if (!err && use_armor)
2041         err = add_arg (gpg, "--armor");
2042       if (!err)
2043         err = add_data (gpg, keydata, 1, 1);
2044     }
2045   if (!err)
2046     err = add_arg (gpg, "--");
2047
2048   return err;
2049 }
2050
2051
2052 static gpgme_error_t
2053 gpg_export (void *engine, const char *pattern, gpgme_export_mode_t mode,
2054             gpgme_data_t keydata, int use_armor)
2055 {
2056   engine_gpg_t gpg = engine;
2057   gpgme_error_t err;
2058
2059   err = export_common (gpg, mode, keydata, use_armor);
2060
2061   if (!err && pattern && *pattern)
2062     err = add_arg (gpg, pattern);
2063
2064   if (!err)
2065     err = start (gpg);
2066
2067   return err;
2068 }
2069
2070
2071 static gpgme_error_t
2072 gpg_export_ext (void *engine, const char *pattern[], gpgme_export_mode_t mode,
2073                 gpgme_data_t keydata, int use_armor)
2074 {
2075   engine_gpg_t gpg = engine;
2076   gpgme_error_t err;
2077
2078   err = export_common (gpg, mode, keydata, use_armor);
2079
2080   if (pattern)
2081     {
2082       while (!err && *pattern && **pattern)
2083         err = add_arg (gpg, *(pattern++));
2084     }
2085
2086   if (!err)
2087     err = start (gpg);
2088
2089   return err;
2090 }
2091
2092
2093 \f
2094 /* Helper to add algo, usage, and expire to the list of args.  */
2095 static gpgme_error_t
2096 gpg_add_algo_usage_expire (engine_gpg_t gpg,
2097                            const char *algo,
2098                            unsigned long expires,
2099                            unsigned int flags)
2100 {
2101   gpg_error_t err;
2102
2103   /* This condition is only required to allow the use of gpg < 2.1.16 */
2104   if (algo
2105       || (flags & (GPGME_CREATE_SIGN | GPGME_CREATE_ENCR
2106                    | GPGME_CREATE_CERT | GPGME_CREATE_AUTH
2107                    | GPGME_CREATE_NOEXPIRE))
2108       || expires)
2109     {
2110       err = add_arg (gpg, algo? algo : "default");
2111       if (!err)
2112         {
2113           char tmpbuf[5*4+1];
2114           snprintf (tmpbuf, sizeof tmpbuf, "%s%s%s%s",
2115                     (flags & GPGME_CREATE_SIGN)? " sign":"",
2116                     (flags & GPGME_CREATE_ENCR)? " encr":"",
2117                     (flags & GPGME_CREATE_CERT)? " cert":"",
2118                     (flags & GPGME_CREATE_AUTH)? " auth":"");
2119           err = add_arg (gpg, *tmpbuf? tmpbuf : "default");
2120         }
2121       if (!err)
2122         {
2123           if ((flags & GPGME_CREATE_NOEXPIRE))
2124             err = add_arg (gpg, "never");
2125           else if (expires == 0)
2126             err = add_arg (gpg, "-");
2127           else
2128             {
2129               char tmpbuf[8+20];
2130               snprintf (tmpbuf, sizeof tmpbuf, "seconds=%lu", expires);
2131               err = add_arg (gpg, tmpbuf);
2132             }
2133         }
2134     }
2135   else
2136     err = 0;
2137
2138   return err;
2139 }
2140
2141
2142 static gpgme_error_t
2143 gpg_createkey_from_param (engine_gpg_t gpg,
2144                           gpgme_data_t help_data, unsigned int extraflags)
2145 {
2146   gpgme_error_t err;
2147
2148   err = add_arg (gpg, "--gen-key");
2149   if (!err && (extraflags & GENKEY_EXTRAFLAG_ARMOR))
2150     err = add_arg (gpg, "--armor");
2151   if (!err)
2152     err = add_arg (gpg, "--");
2153   if (!err)
2154     err = add_data (gpg, help_data, -1, 0);
2155   if (!err)
2156     err = start (gpg);
2157   return err;
2158 }
2159
2160
2161 static gpgme_error_t
2162 gpg_createkey (engine_gpg_t gpg,
2163                const char *userid, const char *algo,
2164                unsigned long expires,
2165                unsigned int flags,
2166                unsigned int extraflags)
2167 {
2168   gpgme_error_t err;
2169
2170   err = add_arg (gpg, "--quick-gen-key");
2171   if (!err && (extraflags & GENKEY_EXTRAFLAG_ARMOR))
2172     err = add_arg (gpg, "--armor");
2173   if (!err && (flags & GPGME_CREATE_NOPASSWD))
2174     {
2175       err = add_arg (gpg, "--passphrase");
2176       if (!err)
2177         err = add_arg (gpg, "");
2178       if (!err)
2179         err = add_arg (gpg, "--batch");
2180     }
2181   if (!err && (flags & GPGME_CREATE_FORCE))
2182     err = add_arg (gpg, "--yes");
2183   if (!err)
2184     err = add_arg (gpg, "--");
2185   if (!err)
2186     err = add_arg (gpg, userid);
2187
2188   if (!err)
2189     err = gpg_add_algo_usage_expire (gpg, algo, expires, flags);
2190
2191   if (!err)
2192     err = start (gpg);
2193   return err;
2194 }
2195
2196
2197 static gpgme_error_t
2198 gpg_addkey (engine_gpg_t gpg,
2199             const char *algo,
2200             unsigned long expires,
2201             gpgme_key_t key,
2202             unsigned int flags,
2203             unsigned int extraflags)
2204 {
2205   gpgme_error_t err;
2206
2207   if (!key || !key->fpr)
2208     return gpg_error (GPG_ERR_INV_ARG);
2209
2210   err = add_arg (gpg, "--quick-addkey");
2211   if (!err && (extraflags & GENKEY_EXTRAFLAG_ARMOR))
2212     err = add_arg (gpg, "--armor");
2213   if (!err && (flags & GPGME_CREATE_NOPASSWD))
2214     {
2215       err = add_arg (gpg, "--passphrase");
2216       if (!err)
2217         err = add_arg (gpg, "");
2218       if (!err)
2219         err = add_arg (gpg, "--batch");
2220     }
2221   if (!err)
2222     err = add_arg (gpg, "--");
2223   if (!err)
2224     err = add_arg (gpg, key->fpr);
2225
2226   if (!err)
2227     err = gpg_add_algo_usage_expire (gpg, algo, expires, flags);
2228
2229   if (!err)
2230     err = start (gpg);
2231   return err;
2232 }
2233
2234
2235 static gpgme_error_t
2236 gpg_adduid (engine_gpg_t gpg,
2237             gpgme_key_t key,
2238             const char *userid,
2239             unsigned int extraflags)
2240 {
2241   gpgme_error_t err;
2242
2243   if (!key || !key->fpr || !userid)
2244     return gpg_error (GPG_ERR_INV_ARG);
2245
2246   if ((extraflags & GENKEY_EXTRAFLAG_SETPRIMARY))
2247     {
2248       if (!have_gpg_version (gpg, "2.1.20"))
2249         err = gpg_error (GPG_ERR_NOT_SUPPORTED);
2250       else
2251         err = add_arg (gpg, "--quick-set-primary-uid");
2252     }
2253   else if ((extraflags & GENKEY_EXTRAFLAG_REVOKE))
2254     err = add_arg (gpg, "--quick-revuid");
2255   else
2256     err = add_arg (gpg, "--quick-adduid");
2257
2258   if (!err)
2259     err = add_arg (gpg, "--");
2260   if (!err)
2261     err = add_arg (gpg, key->fpr);
2262   if (!err)
2263     err = add_arg (gpg, userid);
2264
2265   if (!err)
2266     err = start (gpg);
2267   return err;
2268 }
2269
2270
2271 static gpgme_error_t
2272 gpg_genkey (void *engine,
2273             const char *userid, const char *algo,
2274             unsigned long reserved, unsigned long expires,
2275             gpgme_key_t key, unsigned int flags,
2276             gpgme_data_t help_data, unsigned int extraflags,
2277             gpgme_data_t pubkey, gpgme_data_t seckey)
2278 {
2279   engine_gpg_t gpg = engine;
2280   gpgme_error_t err;
2281
2282   (void)reserved;
2283
2284   if (!gpg)
2285     return gpg_error (GPG_ERR_INV_VALUE);
2286
2287   /* If HELP_DATA is given the use of the old interface
2288    * (gpgme_op_genkey) has been requested.  The other modes are:
2289    *
2290    *  USERID && !KEY          - Create a new keyblock.
2291    * !USERID &&  KEY          - Add a new subkey to KEY (gpg >= 2.1.14)
2292    *  USERID &&  KEY && !ALGO - Add a new user id to KEY (gpg >= 2.1.14).
2293    *                            or set a flag on a user id.
2294    */
2295   if (help_data)
2296     {
2297       /* We need a special mechanism to get the fd of a pipe here, so
2298          that we can use this for the %pubring and %secring
2299          parameters.  We don't have this yet, so we implement only the
2300          adding to the standard keyrings.  */
2301       if (pubkey || seckey)
2302         err = gpg_error (GPG_ERR_NOT_IMPLEMENTED);
2303       else
2304         err = gpg_createkey_from_param (gpg, help_data, extraflags);
2305     }
2306   else if (!have_gpg_version (gpg, "2.1.13"))
2307     err = gpg_error (GPG_ERR_NOT_SUPPORTED);
2308   else if (userid && !key)
2309     err = gpg_createkey (gpg, userid, algo, expires, flags, extraflags);
2310   else if (!userid && key)
2311     err = gpg_addkey (gpg, algo, expires, key, flags, extraflags);
2312   else if (userid && key && !algo)
2313     err = gpg_adduid (gpg, key, userid, extraflags);
2314   else
2315     err = gpg_error (GPG_ERR_INV_VALUE);
2316
2317   return err;
2318 }
2319
2320 /* Return the next DELIM delimited string from DATA as a C-string.
2321    The caller needs to provide the address of a pointer variable which
2322    he has to set to NULL before the first call.  After the last call
2323    to this function, this function needs to be called once more with
2324    DATA set to NULL so that the function can release its internal
2325    state.  After that the pointer variable is free for use again.
2326    Note that we use a delimiter and thus a trailing delimiter is not
2327    required.  DELIM may not be changed after the first call. */
2328 static const char *
2329 string_from_data (gpgme_data_t data, int delim,
2330                   void **helpptr, gpgme_error_t *r_err)
2331 {
2332 #define MYBUFLEN 2000 /* Fixme: We don't support URLs longer than that.  */
2333   struct {
2334     int  eof_seen;
2335     int  nbytes;      /* Length of the last returned string including
2336                          the delimiter. */
2337     int  buflen;      /* Valid length of BUF.  */
2338     char buf[MYBUFLEN+1];  /* Buffer with one byte extra space.  */
2339   } *self;
2340   char *p;
2341   int nread;
2342
2343   *r_err = 0;
2344   if (!data)
2345     {
2346       if (*helpptr)
2347         {
2348           free (*helpptr);
2349           *helpptr = NULL;
2350         }
2351       return NULL;
2352     }
2353
2354   if (*helpptr)
2355     self = *helpptr;
2356   else
2357     {
2358       self = malloc (sizeof *self);
2359       if (!self)
2360         {
2361           *r_err = gpg_error_from_syserror ();
2362           return NULL;
2363         }
2364       *helpptr = self;
2365       self->eof_seen = 0;
2366       self->nbytes = 0;
2367       self->buflen = 0;
2368     }
2369
2370   if (self->eof_seen)
2371     return NULL;
2372
2373   assert (self->nbytes <= self->buflen);
2374   memmove (self->buf, self->buf + self->nbytes, self->buflen - self->nbytes);
2375   self->buflen -= self->nbytes;
2376   self->nbytes = 0;
2377
2378   do
2379     {
2380       /* Fixme: This is fairly infective scanning because we may scan
2381          the buffer several times.  */
2382       p = memchr (self->buf, delim, self->buflen);
2383       if (p)
2384         {
2385           *p = 0;
2386           self->nbytes = p - self->buf + 1;
2387           return self->buf;
2388         }
2389
2390       if ( !(MYBUFLEN - self->buflen) )
2391         {
2392           /* Not enough space - URL too long.  */
2393           *r_err = gpg_error (GPG_ERR_TOO_LARGE);
2394           return NULL;
2395         }
2396
2397       nread = gpgme_data_read (data, self->buf + self->buflen,
2398                                MYBUFLEN - self->buflen);
2399       if (nread < 0)
2400         {
2401           *r_err = gpg_error_from_syserror ();
2402           return NULL;
2403         }
2404       self->buflen += nread;
2405     }
2406   while (nread);
2407
2408   /* EOF reached.  If we have anything in the buffer, append a Nul and
2409      return it. */
2410   self->eof_seen = 1;
2411   if (self->buflen)
2412     {
2413       self->buf[self->buflen] = 0;  /* (we allocated one extra byte)  */
2414       return self->buf;
2415     }
2416   return NULL;
2417 #undef MYBUFLEN
2418 }
2419
2420
2421
2422 static gpgme_error_t
2423 gpg_import (void *engine, gpgme_data_t keydata, gpgme_key_t *keyarray)
2424 {
2425   engine_gpg_t gpg = engine;
2426   gpgme_error_t err;
2427   int idx;
2428   gpgme_data_encoding_t dataenc;
2429
2430   if (keydata && keyarray)
2431     return gpg_error (GPG_ERR_INV_VALUE); /* Only one is allowed.  */
2432
2433   dataenc = gpgme_data_get_encoding (keydata);
2434
2435   if (keyarray)
2436     {
2437       err = add_arg (gpg, "--recv-keys");
2438       if (!err)
2439         err = add_arg (gpg, "--");
2440       for (idx=0; !err && keyarray[idx]; idx++)
2441         {
2442           if (keyarray[idx]->protocol != GPGME_PROTOCOL_OpenPGP)
2443             ;
2444           else if (!keyarray[idx]->subkeys)
2445             ;
2446           else if (keyarray[idx]->subkeys->fpr && *keyarray[idx]->subkeys->fpr)
2447             err = add_arg (gpg, keyarray[idx]->subkeys->fpr);
2448           else if (*keyarray[idx]->subkeys->keyid)
2449             err = add_arg (gpg, keyarray[idx]->subkeys->keyid);
2450         }
2451     }
2452   else if (dataenc == GPGME_DATA_ENCODING_URL
2453            || dataenc == GPGME_DATA_ENCODING_URL0)
2454     {
2455       void *helpptr;
2456       const char *string;
2457       gpgme_error_t xerr;
2458       int delim = (dataenc == GPGME_DATA_ENCODING_URL)? '\n': 0;
2459
2460       /* FIXME: --fetch-keys is probably not correct because it can't
2461          grok all kinds of URLs.  On Unix it should just work but on
2462          Windows we will build the command line and that may fail for
2463          some embedded control characters.  It is anyway limited to
2464          the maximum size of the command line.  We need another
2465          command which can take its input from a file.  Maybe we
2466          should use an option to gpg to modify such commands (ala
2467          --multifile).  */
2468       err = add_arg (gpg, "--fetch-keys");
2469       if (!err)
2470         err = add_arg (gpg, "--");
2471       helpptr = NULL;
2472       while (!err
2473              && (string = string_from_data (keydata, delim, &helpptr, &xerr)))
2474         err = add_arg (gpg, string);
2475       if (!err)
2476         err = xerr;
2477       string_from_data (NULL, delim, &helpptr, &xerr);
2478     }
2479   else if (dataenc == GPGME_DATA_ENCODING_URLESC)
2480     {
2481       /* Already escaped URLs are not yet supported.  */
2482       err = gpg_error (GPG_ERR_NOT_IMPLEMENTED);
2483     }
2484   else
2485     {
2486       err = add_arg (gpg, "--import");
2487       if (!err)
2488         err = add_arg (gpg, "--");
2489       if (!err)
2490         err = add_data (gpg, keydata, -1, 0);
2491     }
2492
2493   if (!err)
2494     err = start (gpg);
2495
2496   return err;
2497 }
2498
2499
2500 /* The output for external keylistings in GnuPG is different from all
2501    the other key listings.  We catch this here with a special
2502    preprocessor that reformats the colon handler lines.  */
2503 static gpgme_error_t
2504 gpg_keylist_preprocess (char *line, char **r_line)
2505 {
2506   enum
2507     {
2508       RT_NONE, RT_INFO, RT_PUB, RT_UID
2509     }
2510   rectype = RT_NONE;
2511 #define NR_FIELDS 16
2512   char *field[NR_FIELDS];
2513   int fields = 0;
2514   size_t n;
2515
2516   *r_line = NULL;
2517
2518   while (line && fields < NR_FIELDS)
2519     {
2520       field[fields++] = line;
2521       line = strchr (line, ':');
2522       if (line)
2523         *(line++) = '\0';
2524     }
2525
2526   if (!strcmp (field[0], "info"))
2527     rectype = RT_INFO;
2528   else if (!strcmp (field[0], "pub"))
2529     rectype = RT_PUB;
2530   else if (!strcmp (field[0], "uid"))
2531     rectype = RT_UID;
2532   else
2533     rectype = RT_NONE;
2534
2535   switch (rectype)
2536     {
2537     case RT_INFO:
2538       /* FIXME: Eventually, check the version number at least.  */
2539       return 0;
2540
2541     case RT_PUB:
2542       if (fields < 7)
2543         return 0;
2544
2545       /* The format is:
2546
2547          pub:<keyid>:<algo>:<keylen>:<creationdate>:<expirationdate>:<flags>
2548
2549          as defined in 5.2. Machine Readable Indexes of the OpenPGP
2550          HTTP Keyserver Protocol (draft).  Modern versions of the SKS
2551          keyserver return the fingerprint instead of the keyid.  We
2552          detect this here and use the v4 fingerprint format to convert
2553          it to a key id.
2554
2555          We want:
2556          pub:o<flags>:<keylen>:<algo>:<keyid>:<creatdate>:<expdate>::::::::
2557       */
2558
2559       n = strlen (field[1]);
2560       if (n > 16)
2561         {
2562           if (gpgrt_asprintf (r_line,
2563                         "pub:o%s:%s:%s:%s:%s:%s::::::::\n"
2564                         "fpr:::::::::%s:",
2565                         field[6], field[3], field[2], field[1] + n - 16,
2566                         field[4], field[5], field[1]) < 0)
2567             return gpg_error_from_syserror ();
2568         }
2569       else
2570         {
2571           if (gpgrt_asprintf (r_line,
2572                         "pub:o%s:%s:%s:%s:%s:%s::::::::",
2573                         field[6], field[3], field[2], field[1],
2574                         field[4], field[5]) < 0)
2575             return gpg_error_from_syserror ();
2576         }
2577
2578       return 0;
2579
2580     case RT_UID:
2581       /* The format is:
2582
2583          uid:<escaped uid string>:<creationdate>:<expirationdate>:<flags>
2584
2585          as defined in 5.2. Machine Readable Indexes of the OpenPGP
2586          HTTP Keyserver Protocol (draft).
2587
2588          We want:
2589          uid:o<flags>::::<creatdate>:<expdate>:::<c-coded uid>:
2590       */
2591
2592       {
2593         /* The user ID is percent escaped, but we want c-coded.
2594            Because we have to replace each '%HL' by '\xHL', we need at
2595            most 4/3 th the number of bytes.  But because we also need
2596            to escape the backslashes we allocate twice as much.  */
2597         char *uid = malloc (2 * strlen (field[1]) + 1);
2598         char *src;
2599         char *dst;
2600
2601         if (! uid)
2602           return gpg_error_from_syserror ();
2603         src = field[1];
2604         dst = uid;
2605         while (*src)
2606           {
2607             if (*src == '%')
2608               {
2609                 *(dst++) = '\\';
2610                 *(dst++) = 'x';
2611                 src++;
2612                 /* Copy the next two bytes unconditionally.  */
2613                 if (*src)
2614                   *(dst++) = *(src++);
2615                 if (*src)
2616                   *(dst++) = *(src++);
2617               }
2618             else if (*src == '\\')
2619               {
2620                 *dst++ = '\\';
2621                 *dst++ = '\\';
2622                 src++;
2623               }
2624             else
2625               *(dst++) = *(src++);
2626           }
2627         *dst = '\0';
2628
2629         if (gpgrt_asprintf (r_line, "uid:o%s::::%s:%s:::%s:",
2630                       field[4], field[2], field[3], uid) < 0)
2631           return gpg_error_from_syserror ();
2632       }
2633       return 0;
2634
2635     case RT_NONE:
2636       /* Unknown record.  */
2637       break;
2638     }
2639   return 0;
2640
2641 }
2642
2643
2644 static gpg_error_t
2645 gpg_keylist_build_options (engine_gpg_t gpg, int secret_only,
2646                            gpgme_keylist_mode_t mode)
2647 {
2648   gpg_error_t err;
2649
2650   err = add_arg (gpg, "--with-colons");
2651
2652   /* Since gpg 2.1.15 fingerprints are always printed, thus there is
2653    * no more need to explicitly request them.  */
2654   if (!have_gpg_version (gpg, "2.1.15"))
2655     {
2656       if (!err)
2657         err = add_arg (gpg, "--fixed-list-mode");
2658       if (!err)
2659         err = add_arg (gpg, "--with-fingerprint");
2660       if (!err)
2661         err = add_arg (gpg, "--with-fingerprint");
2662     }
2663
2664   if (!err && (mode & GPGME_KEYLIST_MODE_WITH_TOFU)
2665       && have_gpg_version (gpg, "2.1.16"))
2666     err = add_arg (gpg, "--with-tofu-info");
2667
2668   if (!err && (mode & GPGME_KEYLIST_MODE_WITH_SECRET))
2669     err = add_arg (gpg, "--with-secret");
2670
2671   if (!err
2672       && (mode & GPGME_KEYLIST_MODE_SIGS)
2673       && (mode & GPGME_KEYLIST_MODE_SIG_NOTATIONS))
2674     {
2675       err = add_arg (gpg, "--list-options");
2676       if (!err)
2677         err = add_arg (gpg, "show-sig-subpackets=\"20,26\"");
2678     }
2679
2680   if (!err)
2681     {
2682       if ( (mode & GPGME_KEYLIST_MODE_EXTERN) )
2683         {
2684           if (secret_only)
2685             err = gpg_error (GPG_ERR_NOT_SUPPORTED);
2686           else if ( (mode & GPGME_KEYLIST_MODE_LOCAL))
2687             {
2688               /* The local+extern mode is special.  It works only with
2689                  gpg >= 2.0.10.  FIXME: We should check that we have
2690                  such a version to that we can return a proper error
2691                  code.  The problem is that we don't know the context
2692                  here and thus can't access the cached version number
2693                  for the engine info structure.  */
2694               err = add_arg (gpg, "--locate-keys");
2695               if ((mode & GPGME_KEYLIST_MODE_SIGS))
2696                 err = add_arg (gpg, "--with-sig-check");
2697             }
2698           else
2699             {
2700               err = add_arg (gpg, "--search-keys");
2701               gpg->colon.preprocess_fnc = gpg_keylist_preprocess;
2702             }
2703         }
2704       else
2705         {
2706           err = add_arg (gpg, secret_only ? "--list-secret-keys"
2707                          : ((mode & GPGME_KEYLIST_MODE_SIGS)
2708                             ? "--check-sigs" : "--list-keys"));
2709         }
2710     }
2711
2712   if (!err)
2713     err = add_arg (gpg, "--");
2714
2715   return err;
2716 }
2717
2718
2719 static gpgme_error_t
2720 gpg_keylist (void *engine, const char *pattern, int secret_only,
2721              gpgme_keylist_mode_t mode, int engine_flags)
2722 {
2723   engine_gpg_t gpg = engine;
2724   gpgme_error_t err;
2725
2726   (void)engine_flags;
2727
2728   err = gpg_keylist_build_options (gpg, secret_only, mode);
2729
2730   if (!err && pattern && *pattern)
2731     err = add_arg (gpg, pattern);
2732
2733   if (!err)
2734     err = start (gpg);
2735
2736   return err;
2737 }
2738
2739
2740 static gpgme_error_t
2741 gpg_keylist_ext (void *engine, const char *pattern[], int secret_only,
2742                  int reserved, gpgme_keylist_mode_t mode, int engine_flags)
2743 {
2744   engine_gpg_t gpg = engine;
2745   gpgme_error_t err;
2746
2747   (void)engine_flags;
2748
2749   if (reserved)
2750     return gpg_error (GPG_ERR_INV_VALUE);
2751
2752   err = gpg_keylist_build_options (gpg, secret_only, mode);
2753
2754   if (pattern)
2755     {
2756       while (!err && *pattern && **pattern)
2757         err = add_arg (gpg, *(pattern++));
2758     }
2759
2760   if (!err)
2761     err = start (gpg);
2762
2763   return err;
2764 }
2765
2766
2767 static gpgme_error_t
2768 gpg_keylist_data (void *engine, gpgme_data_t data)
2769 {
2770   engine_gpg_t gpg = engine;
2771   gpgme_error_t err;
2772
2773   if (!have_gpg_version (gpg, "2.1.14"))
2774     return gpg_error (GPG_ERR_NOT_SUPPORTED);
2775
2776   err = add_arg (gpg, "--with-colons");
2777   if (!err)
2778     err = add_arg (gpg, "--with-fingerprint");
2779   if (!err)
2780     err = add_arg (gpg, "--import-options");
2781   if (!err)
2782     err = add_arg (gpg, "import-show");
2783   if (!err)
2784     err = add_arg (gpg, "--dry-run");
2785   if (!err)
2786     err = add_arg (gpg, "--import");
2787   if (!err)
2788     err = add_arg (gpg, "--");
2789   if (!err)
2790     err = add_data (gpg, data, -1, 0);
2791
2792   if (!err)
2793     err = start (gpg);
2794
2795   return err;
2796 }
2797
2798
2799 static gpgme_error_t
2800 gpg_keysign (void *engine, gpgme_key_t key, const char *userid,
2801              unsigned long expire, unsigned int flags,
2802              gpgme_ctx_t ctx)
2803 {
2804   engine_gpg_t gpg = engine;
2805   gpgme_error_t err;
2806   const char *s;
2807
2808   if (!key || !key->fpr)
2809     return gpg_error (GPG_ERR_INV_ARG);
2810
2811   if (!have_gpg_version (gpg, "2.1.12"))
2812     return gpg_error (GPG_ERR_NOT_SUPPORTED);
2813
2814   if ((flags & GPGME_KEYSIGN_LOCAL))
2815     err = add_arg (gpg, "--quick-lsign-key");
2816   else
2817     err = add_arg (gpg, "--quick-sign-key");
2818
2819   if (!err)
2820     err = append_args_from_signers (gpg, ctx);
2821
2822   /* If an expiration time has been given use that.  If none has been
2823    * given the default from gpg.conf is used.  To make sure not to set
2824    * an expiration time at all the flag GPGME_KEYSIGN_NOEXPIRE can be
2825    * used.  */
2826   if (!err && (expire || (flags & GPGME_KEYSIGN_NOEXPIRE)))
2827     {
2828       char tmpbuf[8+20];
2829
2830       if ((flags & GPGME_KEYSIGN_NOEXPIRE))
2831         expire = 0;
2832       snprintf (tmpbuf, sizeof tmpbuf, "seconds=%lu", expire);
2833       err = add_arg (gpg, "--default-cert-expire");
2834       if (!err)
2835         err = add_arg (gpg, tmpbuf);
2836     }
2837
2838   if (!err)
2839     err = add_arg (gpg, "--");
2840
2841   if (!err)
2842     err = add_arg (gpg, key->fpr);
2843   if (!err && userid)
2844     {
2845       if ((flags & GPGME_KEYSIGN_LFSEP))
2846         {
2847           for (; !err && (s = strchr (userid, '\n')); userid = s + 1)
2848             if ((s - userid))
2849               err = add_arg_len (gpg, "=", userid, s - userid);
2850           if (!err && *userid)
2851             err = add_arg_pfx (gpg, "=", userid);
2852         }
2853       else
2854         err = add_arg_pfx (gpg, "=", userid);
2855     }
2856
2857   if (!err)
2858     err = start (gpg);
2859
2860   return err;
2861 }
2862
2863
2864 static gpgme_error_t
2865 gpg_tofu_policy (void *engine, gpgme_key_t key, gpgme_tofu_policy_t policy)
2866 {
2867   engine_gpg_t gpg = engine;
2868   gpgme_error_t err;
2869   const char *policystr = NULL;
2870
2871   if (!key || !key->fpr)
2872     return gpg_error (GPG_ERR_INV_ARG);
2873
2874   switch (policy)
2875     {
2876     case GPGME_TOFU_POLICY_NONE:                           break;
2877     case GPGME_TOFU_POLICY_AUTO:    policystr = "auto";    break;
2878     case GPGME_TOFU_POLICY_GOOD:    policystr = "good";    break;
2879     case GPGME_TOFU_POLICY_BAD:     policystr = "bad";     break;
2880     case GPGME_TOFU_POLICY_ASK:     policystr = "ask";     break;
2881     case GPGME_TOFU_POLICY_UNKNOWN: policystr = "unknown"; break;
2882     }
2883   if (!policystr)
2884     return gpg_error (GPG_ERR_INV_VALUE);
2885
2886   if (!have_gpg_version (gpg, "2.1.10"))
2887     return gpg_error (GPG_ERR_NOT_SUPPORTED);
2888
2889   err = add_arg (gpg, "--tofu-policy");
2890   if (!err)
2891     err = add_arg (gpg, "--");
2892   if (!err)
2893     err = add_arg (gpg, policystr);
2894   if (!err)
2895     err = add_arg (gpg, key->fpr);
2896
2897   if (!err)
2898     err = start (gpg);
2899
2900   return err;
2901 }
2902
2903
2904 static gpgme_error_t
2905 gpg_sign (void *engine, gpgme_data_t in, gpgme_data_t out,
2906           gpgme_sig_mode_t mode, int use_armor, int use_textmode,
2907           int include_certs, gpgme_ctx_t ctx /* FIXME */)
2908 {
2909   engine_gpg_t gpg = engine;
2910   gpgme_error_t err;
2911
2912   (void)include_certs;
2913
2914   if (mode == GPGME_SIG_MODE_CLEAR)
2915     err = add_arg (gpg, "--clearsign");
2916   else
2917     {
2918       err = add_arg (gpg, "--sign");
2919       if (!err && mode == GPGME_SIG_MODE_DETACH)
2920         err = add_arg (gpg, "--detach");
2921       if (!err && use_armor)
2922         err = add_arg (gpg, "--armor");
2923       if (!err)
2924         {
2925           if (gpgme_data_get_encoding (in) == GPGME_DATA_ENCODING_MIME
2926               && have_gpg_version (gpg, "2.1.14"))
2927             err = add_arg (gpg, "--mimemode");
2928           else if (use_textmode)
2929             err = add_arg (gpg, "--textmode");
2930         }
2931     }
2932
2933   if (!err)
2934     err = append_args_from_signers (gpg, ctx);
2935   if (!err)
2936     err = append_args_from_sender (gpg, ctx);
2937   if (!err)
2938     err = append_args_from_sig_notations (gpg, ctx);
2939
2940   if (gpgme_data_get_file_name (in))
2941     {
2942       if (!err)
2943         err = add_arg (gpg, "--set-filename");
2944       if (!err)
2945         err = add_arg (gpg, gpgme_data_get_file_name (in));
2946     }
2947
2948   /* Tell the gpg object about the data.  */
2949   if (!err)
2950     err = add_input_size_hint (gpg, in);
2951   if (!err)
2952     err = add_arg (gpg, "--");
2953   if (!err)
2954     err = add_data (gpg, in, -1, 0);
2955   if (!err)
2956     err = add_data (gpg, out, 1, 1);
2957
2958   if (!err)
2959     err = start (gpg);
2960
2961   return err;
2962 }
2963
2964 static gpgme_error_t
2965 gpg_trustlist (void *engine, const char *pattern)
2966 {
2967   engine_gpg_t gpg = engine;
2968   gpgme_error_t err;
2969
2970   err = add_arg (gpg, "--with-colons");
2971   if (!err)
2972     err = add_arg (gpg, "--list-trust-path");
2973
2974   /* Tell the gpg object about the data.  */
2975   if (!err)
2976     err = add_arg (gpg, "--");
2977   if (!err)
2978     err = add_arg (gpg, pattern);
2979
2980   if (!err)
2981     err = start (gpg);
2982
2983   return err;
2984 }
2985
2986
2987 static gpgme_error_t
2988 gpg_verify (void *engine, gpgme_data_t sig, gpgme_data_t signed_text,
2989             gpgme_data_t plaintext, gpgme_ctx_t ctx)
2990 {
2991   engine_gpg_t gpg = engine;
2992   gpgme_error_t err;
2993
2994   err = append_args_from_sender (gpg, ctx);
2995   if (err)
2996     ;
2997   else if (plaintext)
2998     {
2999       /* Normal or cleartext signature.  */
3000       err = add_arg (gpg, "--output");
3001       if (!err)
3002         err = add_arg (gpg, "-");
3003       if (!err)
3004         err = add_input_size_hint (gpg, sig);
3005       if (!err)
3006         err = add_arg (gpg, "--");
3007       if (!err)
3008         err = add_data (gpg, sig, -1, 0);
3009       if (!err)
3010         err = add_data (gpg, plaintext, 1, 1);
3011     }
3012   else
3013     {
3014       err = add_arg (gpg, "--verify");
3015       if (!err)
3016         err = add_input_size_hint (gpg, signed_text);
3017       if (!err)
3018         err = add_arg (gpg, "--");
3019       if (!err)
3020         err = add_data (gpg, sig, -1, 0);
3021       if (!err && signed_text)
3022         err = add_data (gpg, signed_text, -1, 0);
3023     }
3024
3025   if (!err)
3026     err = start (gpg);
3027
3028   return err;
3029 }
3030
3031
3032 static void
3033 gpg_set_io_cbs (void *engine, gpgme_io_cbs_t io_cbs)
3034 {
3035   engine_gpg_t gpg = engine;
3036
3037   gpg->io_cbs = *io_cbs;
3038 }
3039
3040
3041 static gpgme_error_t
3042 gpg_set_pinentry_mode (void *engine, gpgme_pinentry_mode_t mode)
3043 {
3044   engine_gpg_t gpg = engine;
3045
3046   gpg->pinentry_mode = mode;
3047   return 0;
3048 }
3049
3050
3051 \f
3052 struct engine_ops _gpgme_engine_ops_gpg =
3053   {
3054     /* Static functions.  */
3055     _gpgme_get_default_gpg_name,
3056     NULL,
3057     gpg_get_version,
3058     gpg_get_req_version,
3059     gpg_new,
3060
3061     /* Member functions.  */
3062     gpg_release,
3063     NULL,                               /* reset */
3064     gpg_set_status_cb,
3065     gpg_set_status_handler,
3066     gpg_set_command_handler,
3067     gpg_set_colon_line_handler,
3068     gpg_set_locale,
3069     NULL,                               /* set_protocol */
3070     gpg_decrypt,
3071     gpg_delete,
3072     gpg_edit,
3073     gpg_encrypt,
3074     gpg_encrypt_sign,
3075     gpg_export,
3076     gpg_export_ext,
3077     gpg_genkey,
3078     gpg_import,
3079     gpg_keylist,
3080     gpg_keylist_ext,
3081     gpg_keylist_data,
3082     gpg_keysign,
3083     gpg_tofu_policy,    /* tofu_policy */
3084     gpg_sign,
3085     gpg_trustlist,
3086     gpg_verify,
3087     NULL,               /* getauditlog */
3088     NULL,               /* opassuan_transact */
3089     NULL,               /* conf_load */
3090     NULL,               /* conf_save */
3091     NULL,               /* query_swdb */
3092     gpg_set_io_cbs,
3093     gpg_io_event,
3094     gpg_cancel,
3095     NULL,               /* cancel_op */
3096     gpg_passwd,
3097     gpg_set_pinentry_mode,
3098     NULL                /* opspawn */
3099   };