source: trunk/third/moira/clients/lib/utils.c @ 24319

/* $Id: utils.c 3956 2010-01-05 20:56:56Z zacheiss $
 *
 * Random client utilities.
 *
 * Copyright (C) 1999 by the Massachusetts Institute of Technology
 * For copying and distribution information, please see the file
 * <mit-copyright.h>.
 */

#include <mit-copyright.h>
#include <moira.h>
#include <mrclient.h>

#include <com_err.h>
#include <krb5.h>

#include <sys/types.h>

#ifdef HAVE_UNAME
#include <sys/utsname.h>
#endif

#ifndef _WIN32
#include <sys/socket.h>
#include <netdb.h>
#include <netinet/in.h>
#endif /* _WIN32 */

#include <ctype.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

RCSID("$HeadURL: svn+ssh://svn.mit.edu/moira/trunk/moira/clients/lib/utils.c $ $Id: utils.c 3956 2010-01-05 20:56:56Z zacheiss $");

extern char *whoami;
extern krb5_context context;

int mrcl_connect(char *server, char *client, int version, int auth)
{
  int status;
  char *motd;

  status = mr_connect(server);
  if (status)
    {
      com_err(whoami, status, "while connecting to Moira");
      return MRCL_FAIL;
    }

  status = mr_motd(&motd);
  if (status)
    {
      mr_disconnect();
      com_err(whoami, status, "while checking server status");
      return MRCL_FAIL;
    }
  if (motd)
    {
      fprintf(stderr, "The Moira server is currently unavailable:\n%s\n",
              motd);
      mr_disconnect();
      return MRCL_FAIL;
    }

  status = mr_version(version);
  if (status)
    {
      if (status == MR_UNKNOWN_PROC)
        {
          if (version > 2)
            status = MR_VERSION_HIGH;
          else
            status = MR_SUCCESS;
        }

      if (status == MR_VERSION_HIGH)
        {
          com_err(whoami, 0, "Warning: This client is running newer code than the server.");
          com_err(whoami, 0, "Some operations may not work.");
        }
      else if (status && status != MR_VERSION_LOW)
        {
          com_err(whoami, status, "while setting query version number.");
          mr_disconnect();
          return MRCL_FAIL;
        }
    }

  if (auth)
    {
      status = mr_krb5_auth(client);

      /* New client talking to old server, try krb4. */
      if (status == MR_UNKNOWN_PROC)
        status = mr_auth(client);

      if (status)
        {
          com_err(whoami, status, "while authenticating to Moira.");
          mr_disconnect();
          return MRCL_AUTH_ERROR;
        }
    }

  return MRCL_SUCCESS;
}

char *mrcl_krb_user(void)
{
  int flags = 0;
  krb5_ccache cache = NULL;
  krb5_principal princ = NULL;
  krb5_error_code status;
  char *username = NULL;

  if (!context)
    krb5_init_context(&context);

  status = krb5_cc_default(context, &cache);
  if (status)
    {
      com_err(whoami, status, "while reading Kerberos ticket file.");
      goto out;
    }

  status = krb5_cc_get_principal(context, cache, &princ);
  if (status)
    {
      com_err(whoami, status, "while retrieving principal name.");
      goto out;
    }

  username = malloc(krb5_princ_component(context, princ, 0)->length + 1);
  if (!username)
    goto out;

  strncpy(username, krb5_princ_component(context, princ, 0)->data,
          krb5_princ_component(context, princ, 0)->length);
  username[krb5_princ_component(context, princ, 0)->length] = '\0';

 out:
  if (cache)
    krb5_cc_close(context, cache);
  if (princ)
    krb5_free_principal(context, princ);

  return username;
}

char *partial_canonicalize_hostname(char *s)
{
  char buf[256], *cp;
  static char *def_domain = NULL;

  if (!def_domain)
    {
      if (mr_host(buf, sizeof(buf)) == MR_SUCCESS)
        {
          cp = strchr(buf, '.');
          if (cp)
            def_domain = strdup(++cp);
        }
      else
        {
          struct hostent *hp;
#ifdef HAVE_UNAME
          struct utsname name;
          uname(&name);
          hp = gethostbyname(name.nodename);
#else
          char  name[256];
          gethostname(name, sizeof(name));
          name[sizeof(name)-1] = 0;
          hp = gethostbyname(name);
#endif /* HAVE_UNAME */
          cp = strchr(hp->h_name, '.');
          if (cp)
            def_domain = strdup(++cp);
        }
      if (!def_domain)
        def_domain = "";
    }

  if (strchr(s, '.') || strchr(s, '*'))
    return s;
  sprintf(buf, "%s.%s", s, def_domain);
  free(s);
  return strdup(buf);
}