ud-userimport

   1 #!/usr/bin/env python
   2 # -*- mode: python -*-
   3
   4 #   Copyright (c) 1999       Jason Gunthorpe <jgg@debian.org>
   5 #   Copyright (c) 2003       James Troup <troup@debian.org>
   6 #   Copyright (c) 2004       Joey Schulze <joey@debian.org>
   7 #
   8 #   This program is free software; you can redistribute it and/or modify
   9 #   it under the terms of the GNU General Public License as published by
  10 #   the Free Software Foundation; either version 2 of the License, or
  11 #   (at your option) any later version.
  12 #
  13 #   This program is distributed in the hope that it will be useful,
  14 #   but WITHOUT ANY WARRANTY; without even the implied warranty of
  15 #   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16 #   GNU General Public License for more details.
  17 #
  18 #   You should have received a copy of the GNU General Public License
  19 #   along with this program; if not, write to the Free Software
  20 #   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  21
  22 # Imports passwd, shadow and group files into the directory.
  23 # You should cleanse the files of anything you do not want to add to the
  24 # directory.
  25 #
  26 # The first step is to call this script to import the passwd file and
  27 # create all the new entries. This should be done on an empty freshly
  28 # initialized directory with the rootdn/password set in the server.
  29 # The command to execute is
  30 #   ldapimport -a -p ~/passwd
  31 # The -a tells the script to add all the entries it finds, it should be
  32 # used only once.
  33 #
  34 # The next step is to import the shadow file and group, no clensing need be
  35 # done for
  36 # this as any entries that do not exist will be ignored (silently)
  37 #  ldapimport -s /etc/shadow -g /etc/group
  38 #
  39
  40 import re, time, ldap, getopt, sys;
  41 from userdir_ldap import *;
  42
  43 DoAdd = 0;
  44 WritePasses = 1;
  45 Passwd = "";
  46 Shadow = "";
  47 Group = "";
  48
  49 # This parses a gecos field and returns a tuple containing the new normalized
  50 # field and the first, middle and last name of the user. Gecos is formed
  51 # in the standard debian manner with 5 feilds seperated by commas
  52 def ParseGecos(Field):
  53    Gecos = re.split("[,:]",Field);
  54    cn = "";
  55    mn = "";
  56    sn = "";
  57    if (len(Gecos) >= 1):
  58       (cn,mn,sn) = NameSplit(Gecos[0]);
  59
  60       # Normalize the gecos field
  61       if (len(Gecos) > 5):
  62          Gecos = Gecos[0:4];
  63       else:
  64          while (len(Gecos) < 5):
  65             Gecos.append("");
  66    else:
  67       Gecos = ["","","","",""];
  68
  69    # Reconstruct the gecos after mauling it
  70    Field = Gecos[0] + "," + Gecos[1] + "," + Gecos[2] + "," + \
  71            Gecos[3] + "," + Gecos[4];
  72    return (Field,cn,mn,sn);
  73
  74 # Read the passwd file into the database
  75 def DoPasswd(l,Passwd):
  76    # Read the passwd file and import it
  77    Passwd = open(Passwd,"r");
  78    Outstanding = 0;
  79    while(1):
  80       Line = Passwd.readline();
  81       if Line == "":
  82          break;
  83
  84       Split = re.split("[:\n]",Line);
  85       (Split[4],cn,mn,sn) = ParseGecos(Split[4]);
  86       # This just tests whether these are integers and throws an
  87       # exception if not
  88       int(Split[2])
  89       int(Split[3])
  90       Rec = [("uid",Split[0]),
  91              ("uidNumber",Split[2]),
  92              ("gidNumber",Split[3]),
  93              ("gecos",Split[4]),
  94              ("homeDirectory",Split[5]),
  95              ("loginShell",Split[6]),
  96              ("cn",cn),
  97              ("sn",sn)];
  98
  99       # Avoid schema check complaints when mn is empty
 100       if (mn):
 101           Rec.append(("mn",mn))
 102
 103       Dn = "uid=" + Split[0] + "," + BaseDn;
 104       print "Importing", Dn
 105       sys.stdout.flush();
 106
 107       DoModify = True
 108
 109       if (DoAdd == 1):
 110          try:
 111             AddRec = Rec[:]
 112             AddRec.append(("objectClass", UserObjectClasses))
 113             l.add_s(Dn,AddRec)
 114             DoModify = False
 115
 116          except ldap.ALREADY_EXISTS:
 117             print "exists",;
 118
 119       if (DoModify):
 120           # Send the modify request
 121           ModRec = [(ldap.MOD_REPLACE, k[0], k[1]) for k in Rec]
 122           l.modify(Dn,ModRec);
 123           Outstanding = Outstanding + 1;
 124           Outstanding = FlushOutstanding(l,Outstanding,1);
 125           print "done";
 126
 127    FlushOutstanding(l,Outstanding);
 128
 129 # Read the shadow file into the database
 130 def DoShadow(l,Shadow):
 131    # Read the passwd file and import it
 132    Shadow = open(Shadow,"r");
 133    Outstanding = 0;
 134    while(1):
 135       Line = Shadow.readline();
 136       if Line == "":
 137          break;
 138
 139       Split = re.split("[:\n]",Line);
 140
 141       # Ignore system accounts with no password, they do not belong in the
 142       # directory.
 143       if (Split[1] == 'x' or Split[1] == '*'):
 144          print "Ignoring system account,",Split[0];
 145          continue;
 146
 147       for x in range(2,8):
 148          int(Split[x])
 149
 150       Rec = [(ldap.MOD_REPLACE,"shadowLastChange",Split[2]),
 151              (ldap.MOD_REPLACE,"shadowMin",Split[3]),
 152              (ldap.MOD_REPLACE,"shadowMax",Split[4]),
 153              (ldap.MOD_REPLACE,"shadowWarning",Split[5])]
 154
 155       # Avoid schema violations
 156       if (Split[6]):
 157          Rec.append((ldap.MOD_REPLACE,"shadowInactive",Split[6]))
 158
 159       if (Split[7]):
 160          Rec.append((ldap.MOD_REPLACE,"shadowExpire",Split[7]))
 161
 162       if (WritePasses == 1):
 163          Rec.append((ldap.MOD_REPLACE,"userPassword","{crypt}"+Split[1]));
 164
 165       Dn = "uid=" + Split[0] + "," + BaseDn;
 166       print "Importing",Dn,
 167       sys.stdout.flush();
 168
 169       # Send the modify request
 170       l.modify(Dn,Rec);
 171       Outstanding = Outstanding + 1;
 172       print "done";
 173       Outstanding = FlushOutstanding(l,Outstanding,1);
 174    FlushOutstanding(l,Outstanding);
 175
 176 # Read the group file into the database
 177 def DoGroup(l,Group):
 178    # Read the passwd file and import it
 179    Group = open(Group,"r");
 180    Outstanding = 0;
 181    while(1):
 182       Line = Group.readline();
 183       if Line == "":
 184          break;
 185
 186       # Split up the group information
 187       Split = re.split("[:\n]",Line);
 188       Members = re.split("[, ]*",Split[3]);
 189       int(Split[2])
 190
 191       # Iterate over the membership list and add the membership information
 192       # To the directory
 193       Rec = [(ldap.MOD_ADD,"supplementaryGid",Split[0])];
 194       Counter = 0;
 195       for x in Members:
 196          if x == "":
 197             continue;
 198
 199          Dn = "uid=" + x + "," + BaseDn;
 200          print "Adding",Dn,"to group",Split[0];
 201          Counter = Counter+1;
 202
 203          # Send the modify request
 204          l.modify(Dn,Rec);
 205          Outstanding = Outstanding + 1;
 206          Outstanding = FlushOutstanding(l,Outstanding,1);
 207
 208       if Counter == 0:
 209          continue;
 210
 211       Rec = [(ldap.MOD_REPLACE,"gid",Split[0]),
 212              (ldap.MOD_REPLACE,"gidNumber",Split[2])];
 213
 214       Dn = "gid=" + Split[0] + "," + BaseDn;
 215       print "Importing",Dn,
 216       sys.stdout.flush();
 217
 218       # Unfortunately add_s does not take the same args as modify :|
 219       if (DoAdd == 1):
 220          try:
 221             l.add_s(Dn,[("gid",Split[0]),
 222                         ("objectClass", GroupObjectClasses)])
 223          except ldap.ALREADY_EXISTS:
 224             print "exists",;
 225
 226       # Send the modify request
 227       l.modify(Dn,Rec);
 228       Outstanding = Outstanding + 1;
 229       print ".";
 230
 231    FlushOutstanding(l,Outstanding);
 232
 233 # Process options
 234 (options, arguments) = getopt.getopt(sys.argv[1:], "ap:s:g:xu:")
 235 for (switch, val) in options:
 236    if (switch == '-a'):
 237       DoAdd = 1;
 238    if (switch == '-x'):
 239       WritePasses = 0;
 240    elif (switch == '-p'):
 241       Passwd = val
 242    elif (switch == '-s'):
 243       Shadow = val
 244    elif (switch == '-g'):
 245       Group = val
 246    elif (switch == '-u'):
 247       AdminUser = val
 248
 249 # Main program starts here
 250
 251 # Connect to the ldap server
 252 l = passwdAccessLDAP(BaseDn, AdminUser)
 253
 254 if (Passwd != ""):
 255    DoPasswd(l,Passwd);
 256
 257 if (Shadow != ""):
 258    DoShadow(l,Shadow);
 259
 260 if (Group != ""):
 261    DoGroup(l,Group);