/mandos/trunk

« back to all changes in this revision

Viewing changes to plugins.d/mandos-client.c

• browse files at revision 260
• compare with another revision
• download diff
• download tarball
• view history from revision 260

• reverse the comparison (260 to 167)
• stop comparing with revision 167

Show diffs side-by-side

added

removed

plugins.d/mandos-client.c

9

9

 * "browse_callback", and parts of "main".

10

10

 * 

11

11

 * Everything else is

12

 

 * Copyright © 2007-2008 Teddy Hogeborn & Björn Påhlsson

 

12

 * Copyright © 2008,2009 Teddy Hogeborn

 

13

 * Copyright © 2008,2009 Björn Påhlsson

13

14

 * 

14

15

 * This program is free software: you can redistribute it and/or

15

16

 * modify it under the terms of the GNU General Public License as

101

102

 

102

103

#define BUFFER_SIZE 256

103

104

 

104

 

/*

105

 

  #define PATHDIR "/conf/conf.d/mandos"

106

 

*/

107

 

 

108

105

#define PATHDIR "/conf/conf.d/mandos"

109

106

#define SECKEY "seckey.txt"

110

 

#define PUBKEY "pupkey.txt"

 

107

#define PUBKEY "pubkey.txt"

111

108

 

112

109

bool debug = false;

113

110

static const char mandos_protocol_version[] = "1";

114

 

const char *argp_program_version = "password-request 1.0";

 

111

const char *argp_program_version = "mandos-client " VERSION;

115

112

const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";

116

113

 

117

114

/* Used for passing in values through the Avahi callback functions */

150

147

  int ret;

151

148

  gpgme_error_t rc;

152

149

  gpgme_engine_info_t engine_info;

153

 

 

 

150

  

154

151

  

155

152

  /*

156

153

   * Helper function to insert pub and seckey to the enigne keyring.

159

156

    int fd;

160

157

    gpgme_data_t pgp_data;

161

158

    

162

 

    fd = TEMP_FAILURE_RETRY(open(filename, O_RDONLY));

 

159

    fd = (int)TEMP_FAILURE_RETRY(open(filename, O_RDONLY));

163

160

    if(fd == -1){

164

161

      perror("open");

165

162

      return false;

171

168

              gpgme_strsource(rc), gpgme_strerror(rc));

172

169

      return false;

173

170

    }

174

 

 

 

171

    

175

172

    rc = gpgme_op_import(mc->ctx, pgp_data);

176

173

    if (rc != GPG_ERR_NO_ERROR){

177

174

      fprintf(stderr, "bad gpgme_op_import: %s: %s\n",

178

175

              gpgme_strsource(rc), gpgme_strerror(rc));

179

176

      return false;

180

177

    }

181

 

 

182

 

    ret = TEMP_FAILURE_RETRY(close(fd));

 

178

    

 

179

    ret = (int)TEMP_FAILURE_RETRY(close(fd));

183

180

    if(ret == -1){

184

181

      perror("close");

185

182

    }

190

187

  if (debug){

191

188

    fprintf(stderr, "Initialize gpgme\n");

192

189

  }

193

 

 

 

190

  

194

191

  /* Init GPGME */

195

192

  gpgme_check_version(NULL);

196

193

  rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);

199

196

            gpgme_strsource(rc), gpgme_strerror(rc));

200

197

    return false;

201

198

  }

202

 

 

 

199

  

203

200

    /* Set GPGME home directory for the OpenPGP engine only */

204

201

  rc = gpgme_get_engine_info (&engine_info);

205

202

  if (rc != GPG_ERR_NO_ERROR){

219

216

    fprintf(stderr, "Could not set GPGME home dir to %s\n", tempdir);

220

217

    return false;

221

218

  }

222

 

 

 

219

  

223

220

  /* Create new GPGME "context" */

224

221

  rc = gpgme_new(&(mc->ctx));

225

222

  if (rc != GPG_ERR_NO_ERROR){

315

312

  

316

313

  /* Seek back to the beginning of the GPGME plaintext data buffer */

317

314

  if (gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET) == -1){

318

 

    perror("pgpme_data_seek");

 

315

    perror("gpgme_data_seek");

319

316

    plaintext_length = -1;

320

317

    goto decrypt_end;

321

318

  }

451

448

  

452

449

  gnutls_certificate_free_credentials(mc->cred);

453

450

  gnutls_global_deinit();

 

451

  gnutls_dh_params_deinit(mc->dh_params);

454

452

  return -1;

455

453

}

456

454

 

503

501

                                      AvahiIfIndex if_index,

504

502

                                      mandos_context *mc){

505

503

  int ret, tcp_sd;

 

504

  ssize_t sret;

506

505

  union { struct sockaddr in; struct sockaddr_in6 in6; } to;

507

506

  char *buffer = NULL;

508

507

  char *decrypted_buffer;

579

578

  written = 0;

580

579

  while (true){

581

580

    size_t out_size = strlen(out);

582

 

    ret = TEMP_FAILURE_RETRY(write(tcp_sd, out + written,

 

581

    ret = (int)TEMP_FAILURE_RETRY(write(tcp_sd, out + written,

583

582

                                   out_size - written));

584

583

    if (ret == -1){

585

584

      perror("write");

634

633

      goto mandos_end;

635

634

    }

636

635

    

637

 

    ret = gnutls_record_recv(session, buffer+buffer_length,

638

 

                             BUFFER_SIZE);

639

 

    if (ret == 0){

 

636

    sret = gnutls_record_recv(session, buffer+buffer_length,

 

637

                              BUFFER_SIZE);

 

638

    if (sret == 0){

640

639

      break;

641

640

    }

642

 

    if (ret < 0){

643

 

      switch(ret){

 

641

    if (sret < 0){

 

642

      switch(sret){

644

643

      case GNUTLS_E_INTERRUPTED:

645

644

      case GNUTLS_E_AGAIN:

646

645

        break;

663

662

        goto mandos_end;

664

663

      }

665

664

    } else {

666

 

      buffer_length += (size_t) ret;

 

665

      buffer_length += (size_t) sret;

667

666

    }

668

667

  }

669

668

  

705

704

  

706

705

 mandos_end:

707

706

  free(buffer);

708

 

  ret = TEMP_FAILURE_RETRY(close(tcp_sd));

 

707

  ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));

709

708

  if(ret == -1){

710

709

    perror("close");

711

710

  }

830

829

                          .dh_bits = 1024, .priority = "SECURE256"

831

830

                          ":!CTYPE-X.509:+CTYPE-OPENPGP" };

832

831

    bool gnutls_initalized = false;

833

 

    bool pgpme_initalized = false;

 

832

    bool gpgme_initalized = false;

834

833

    

835

834

    {

836

835

      struct argp_option options[] = {

942

941

          goto end;

943

942

        }

944

943

      }

945

 

      ret = TEMP_FAILURE_RETRY(close(sd));

 

944

      ret = (int)TEMP_FAILURE_RETRY(close(sd));

946

945

      if(ret == -1){

947

946

        perror("close");

948

947

      }

977

976

    }

978

977

    

979

978

    if(not init_gpgme(&mc, pubkey, seckey, tempdir)){

980

 

      fprintf(stderr, "pgpme_initalized failed\n");

 

979

      fprintf(stderr, "gpgme_initalized failed\n");

981

980

      exitcode = EXIT_FAILURE;

982

981

      goto end;

983

982

    } else {

984

 

      pgpme_initalized = true;

 

983

      gpgme_initalized = true;

985

984

    }

986

985

    

987

986

    if_index = (AvahiIfIndex) if_nametoindex(interface);

1098

1097

    if (gnutls_initalized){

1099

1098

      gnutls_certificate_free_credentials(mc.cred);

1100

1099

      gnutls_global_deinit ();

 

1100

      gnutls_dh_params_deinit(mc.dh_params);

1101

1101

    }

1102

 

 

1103

 

    if(pgpme_initalized){

 

1102

    

 

1103

    if(gpgme_initalized){

1104

1104

      gpgme_release(mc.ctx);

1105

1105

    }

1106

 

 

 

1106

    

1107

1107

    /* Removes the temp directory used by GPGME */

1108

1108

    if(tempdir[0] != '\0'){

1109

1109

      DIR *d;

1133

1133

            free(fullname);

1134

1134

          }

1135

1135

        }

 

1136

        closedir(d);

1136

1137

      }

1137

1138

      ret = rmdir(tempdir);

1138

1139

      if(ret == -1){

• Older »

Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0