Two problems with my first commit:
[mirror/userdir-ldap.git] / 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);