/* $Header: /afs/sipb.mit.edu/project/sipb-athena/repository/src/moira/regtape/students.dc,v 1.20 1996/06/02 07:44:11 ghudson Exp $ */ #include #include #include #include #include #include EXEC SQL INCLUDE sqlca; #define WHO 11859 /* root */ #define PROG "stu-tape" #define MAX_ID_VALUE 31999 #define MIN_ID_VALUE 101 /* File format is: 0-29 name 30-38 id number 50-54 school code 55-79 year 80-109 address 110-124 room 125-144 city 145-158 state 159-168 dorm phone 169-212 home address 213-232 home city 243-251 mit phone (?) */ #define LOC_NAME 0 #define LOC_ID 30 #define LOC_COURSE 50 #define LOC_YEAR 55 #define LOC_ADDRESS 80 #define LOC_DORM_ROOM 110 #define LOC_CITY 125 #define LOC_STATE 145 #define LOC_DPHONE 155 #define LOC_MPHONE 243 #define LEN_NAME 30 #define LEN_ID 9 #define LEN_COURSE 5 #define LEN_YEAR 25 #define LEN_ADDRESS 30 #define LEN_DORM_ROOM 15 #define LEN_CITY 20 #define LEN_STATE 10 #define LEN_DPHONE 12 #define LEN_MPHONE 12 struct entry { char *name; char *last; char *first; char *middle; char *title; char *id; char *eid; char *course; char *year; char *address; char *dorm; char *city; char *state; char *dphone; char *mphone; char *class; }; char *whoami; int newfinger = 0; #define SQL_DUPLICATE -40100 #define SQL_DEADLOCK -49900 #define sqlfail() (sqlca.sqlcode && sqlca.sqlcode != 100) main(argc, argv) int argc; char **argv; { FILE *in; struct entry *e, *get_next_entry(); int i, wait = 0; char buf[BUFSIZ], *file = NULL; whoami = rindex(argv[0], '/'); if (whoami) whoami++; else whoami = argv[0]; for (i = 1; i < argc; i++) { if (!strcmp(argv[i], "-w")) wait++; else if (!strcmp(argv[i], "-D")) setenv("ING_SET", "set printqry"); else if (!strcmp(argv[i], "-n")) newfinger++; else if (file != NULL) fprintf(stderr, "Usage: %s [-w] [-D] [-n] inputfile\n", whoami); else file = argv[i]; } in = fopen(file, "r"); if (in == NULL) { fprintf(stderr, "Unable to open %s for input\n", file); exit(1); } setlinebuf(stdout); setlinebuf(stderr); initialize_sms_error_table(); EXEC SQL CONNECT moira; if (sqlca.sqlcode != 0) { com_err(whoami, 0, "ingres error %d", sqlca.sqlcode); exit(1); } while (e = get_next_entry(in)) { again: process_entry(e); EXEC SQL COMMIT WORK; if (sqlca.sqlcode != 0) { if (sqlca.sqlcode == SQL_DEADLOCK) { com_err(whoami, MR_DEADLOCK, "commiting work"); goto again; } else { com_err(whoami, 0, "ingres error %d", sqlca.sqlcode); exit(1); } } if (wait) { printf("Next"); fflush(stdout); gets(buf); } } exit(0); } struct entry *get_next_entry(in) FILE *in; { static struct entry e; static char buf[BUFSIZ], eid[16], classbuf[10], titlebuf[12]; static char name[LEN_NAME+1], id[LEN_ID+1], course[LEN_COURSE+1]; static char year[LEN_YEAR+1], address[LEN_ADDRESS+1]; static char dorm_room[LEN_DORM_ROOM+1], city[LEN_CITY+1]; static char state[LEN_STATE+1], dphone[LEN_DPHONE+1], mphone[LEN_MPHONE+1]; static char sname[LEN_NAME+1], title[128]; static int nyear = 0; int ends_jr, ends_iii, ends_iv, ends_sr, ends_ii, ends_v; char *p; if (nyear == 0) { struct tm *tm; struct timeval tv; gettimeofday(&tv, NULL); tm = localtime(&tv.tv_sec); nyear = tm->tm_year; if (tm->tm_mon > 5) nyear++; } if (fgets(buf, sizeof(buf), in) == NULL) return((struct entry *)NULL); strncpy(name, &buf[LOC_NAME], LEN_NAME); name[LEN_NAME] = 0; strncpy(id, &buf[LOC_ID], LEN_ID); id[LEN_ID] = 0; strncpy(course, &buf[LOC_COURSE], LEN_COURSE); course[LEN_COURSE] = 0; strncpy(year, &buf[LOC_YEAR], LEN_YEAR); year[LEN_YEAR] = 0; strncpy(address, &buf[LOC_ADDRESS], LEN_ADDRESS); address[LEN_ADDRESS] = 0; strncpy(dorm_room, &buf[LOC_DORM_ROOM], LEN_DORM_ROOM); dorm_room[LEN_DORM_ROOM] = 0; strncpy(city, &buf[LOC_CITY], LEN_CITY); city[LEN_CITY] = 0; strncpy(state, &buf[LOC_STATE], LEN_STATE); state[LEN_STATE] = 0; strncpy(dphone, &buf[LOC_DPHONE], LEN_DPHONE); dphone[LEN_DPHONE] = 0; strncpy(mphone, &buf[LOC_MPHONE], LEN_MPHONE); mphone[LEN_MPHONE] = 0; strcpy(sname, name); e.name = strtrim(sname); p = index(name, ','); if (p) *p = 0; e.last = strtrim(name); if (p) { p++; while (isspace(*p)) p++; e.first = p; if (p = index(e.first, ' ')) { *p = 0; e.first = strtrim(e.first); e.middle = strtrim(p + 1); } else { e.first = strtrim(e.first); e.middle = ""; } } else { e.first = ""; e.middle = ""; } ends_jr = ends_iii = ends_iv = ends_sr = ends_ii = ends_v = 0; LookForSt(e.last); LookForO(e.last); LookForJrAndIII(e.last, &ends_sr, &ends_jr, &ends_iii, &ends_iv, &ends_ii, &ends_v); LookForJrAndIII(e.first, &ends_sr, &ends_jr, &ends_iii, &ends_iv, &ends_ii, &ends_v); FixCase(e.last); FixCase(e.first); FixCase(e.middle); e.id = id; e.id[LEN_ID] = 0; e.eid = eid; EncryptID(e.eid, e.id, e.first, e.last); e.year = strtrim(year); e.title = title; if (e.year[0] == 'G') { e.class = "G"; sprintf(title, "Grad Student"); } else { e.class = classbuf; sprintf(classbuf, "%d", nyear + 4 - atoi(e.year) + 1900); sprintf(title, "Undergrad (class of %s)", classbuf); } e.course = strtrim(course); e.address = strtrim(address); e.dorm = strtrim(dorm_room); e.city = strtrim(city); e.state = strtrim(state); e.dphone = strtrim(dphone); e.mphone = strtrim(mphone); return(&e); } process_entry(e) struct entry *e; { int changed, nochange, encrypted; char buf[BUFSIZ], *from, *to; EXEC SQL BEGIN DECLARE SECTION; char *first, *last, *middle, *eid, *title, *sid, *name, *rname, *rdept, *rtitle; char *rophone, *rhphone, *prog; char class[9], haddr[128], hphone[33], ophone[33], dept[33], raddr[128]; char dfirst[17], dlast[17], dmiddle[17]; int id, status, who; EXEC SQL END DECLARE SECTION; who = WHO; prog = PROG; first = e->first; if (strlen(first) > 16) first[16] = 0; last = e->last; if (strlen(last) > 16) last[16] = 0; middle = e->middle; eid = e->eid; sid = e->id; id = 0; encrypted = 0; /* Get user info */ EXEC SQL REPEATED SELECT users_id, first, last, middle, type, home_addr, home_phone, office_phone, status, department INTO :id, :dfirst, :dlast, :dmiddle, :class, :haddr, :hphone, :ophone, :status, :dept FROM users WHERE clearid = :sid; if (sqlfail()) { if (sqlca.sqlcode == SQL_DUPLICATE) { com_err(whoami, 0, "duplicate ID number %s on user %s %s", sid, first, last); return; } else if (sqlca.sqlcode == SQL_DEADLOCK) { com_err(whoami, MR_DEADLOCK, "looking up user %s", sid); EXEC SQL ROLLBACK; return process_entry(e); } else sqlexit(); } if (id == 0) { EXEC SQL REPEATED SELECT users_id, first, last, middle, type, home_addr, home_phone, office_phone, status, department INTO :id, :dfirst, :dlast, :dmiddle, :class, :haddr, :hphone, :ophone, :status, :dept FROM users WHERE last = :last and first = :first and clearid = :eid; if (sqlfail()) { if (sqlca.sqlcode == SQL_DEADLOCK) { com_err(whoami, MR_DEADLOCK, "looking up user %s", sid); EXEC SQL ROLLBACK; return process_entry(e); } else if (sqlca.sqlcode != SQL_DUPLICATE) sqlexit(); } encrypted++; if (id == 0) { newuser(e); return; } } /* See if class changed: if it's different, and the value in the database * is not STAFF or SIPB, then update the database. Since they were on the * students tape, make the account usable. */ if (strcmp(e->class, strtrim(class)) && strcmp(class, "STAFF") && strcmp(class, "SIPB")) { com_err(whoami, 0, "updating class for user %s %s from %s to %s", first, last, class, e->class); if (status == US_NOT_ALLOWED) status = US_NO_LOGIN_YET; if (status == US_ENROLL_NOT_ALLOWED) status = US_ENROLLED; strcpy(class, e->class); EXEC SQL REPEATED UPDATE users SET type = :class, status = :status, modtime = 'now', modby = :who, modwith = :prog WHERE users_id = :id; if (sqlca.sqlcode != 0) { com_err(whoami, 0, "ingres error %d", sqlca.sqlcode); exit(1); } } /* Update name if necessary */ if (strcmp(first, strtrim(dfirst)) || strcmp(last, strtrim(dlast)) || strcmp(middle, strtrim(dmiddle))) { com_err(whoami, 0, "updating real name for %s %s", first, last); EXEC SQL UPDATE users SET first = :first, last = :last, middle = :middle, modby = :who, modwith = :prog, modtime = 'now' WHERE users_id = :id; if (sqlca.sqlcode != 0) { com_err(whoami, 0, "ingres error %d", sqlca.sqlcode); exit(1); } } /* Deal with updating the finger info if necessary */ changed = nochange = 0; if (encrypted) changed++; strcpy(buf, e->address); if (*e->dorm) { strcat(buf, " "); strcat(buf, e->dorm); } if (*e->city) { strcat(buf, " "); strcat(buf, e->city); } FixCase(buf); if (*e->state) { strcat(buf, " "); strcat(buf, e->state); } while (to = index(buf, ',')) *to = ';'; while (to = index(buf, ':')) *to = ';'; if (newfinger) { if (haddr[0] == ' ') { strncpy(haddr, buf, 80); haddr[80] = 0; changed++; } else if (strncmp(strtrim(haddr), buf, 80)) nochange++; } else { if (strncmp(strtrim(haddr), buf, 80)) changed++; strncpy(haddr, buf, 80); haddr[80] = 0; } from = e->dphone; to = buf; while (*from) { if (isdigit(*from)) *to++ = *from; from++; } *to = 0; if (newfinger) { if (hphone[0] == ' ') { strncpy(hphone, buf, 16); hphone[16] = 0; } else if (strncmp(strtrim(hphone), buf, 16)) nochange++; } else { if (strncmp(strtrim(hphone), buf, 16)) changed++; strncpy(hphone, buf, 16); hphone[16] = 0; } from = e->mphone; to = buf; while (*from) { if (isdigit(*from)) *to++ = *from; from++; } *to = 0; if (newfinger) { if (ophone[0] == ' ') { strncpy(ophone, buf, 12); ophone[12] = 0; } else if (strncmp(strtrim(ophone), buf, 12)) nochange++; } else { if (strncmp(strtrim(ophone), buf, 12)) changed++; strncpy(ophone, buf, 12); ophone[12] = 0; } e->course = e->course; if (newfinger) { if (dept[0] == ' ') { strncpy(dept, e->course, 12); dept[12] = 0; } else if (strncmp(strtrim(dept), e->course, 11)) nochange++; } else { if (strncmp(strtrim(dept), e->course, 11)) changed++; strncpy(dept, e->course, 12); dept[12] = 0; } sid = e->id; name = e->name; rdept = e->course; rtitle = e->title; rophone = e->mphone; rhphone = e->dphone; strcpy(raddr, e->address); if (*e->dorm) { strcat(raddr, " "); strcat(raddr, e->dorm); } strcat(raddr, "|"); if (*e->city) { strcat(raddr, e->city); FixCase(raddr); if (*e->state) { strcat(raddr, " "); if (isupper(e->state[0]) && isupper(e->state[1]) && isdigit(e->state[2]) && isdigit(e->state[3]) && isdigit(e->state[4]) && isdigit(e->state[5]) && isdigit(e->state[6])) { sprintf(buf, "%c%c %s", e->state[0],e->state[1], &(e->state[2])); strcat(raddr, buf); } else strcat(raddr, e->state); } } else { FixCase(raddr); strcat(raddr, "MIT INTERDEPARTMENTAL MAIL"); } if (changed) { com_err(whoami, 0, "updating finger for %s %s", first, last); EXEC SQL REPEATED UPDATE users SET home_addr = :haddr, home_phone = :hphone, office_phone = :ophone, department = :dept, fmodtime = 'now', fmodby = :who, fmodwith = :prog, xname = :name, xdept = :rdept, xtitle = :rtitle, xaddress = :raddr, xphone1 = :rhphone, xphone2 = :rophone, xmodtime = date('now'), clearid = :sid WHERE users_id = :id; if (sqlca.sqlcode != 0) { if (sqlca.sqlcode == SQL_DEADLOCK) { com_err(whoami, MR_DEADLOCK, "updating user %s", sid); EXEC SQL ROLLBACK; return process_entry(e); } else { com_err(whoami, 0, "ingres error %d", sqlca.sqlcode); exit(1); } } } else { EXEC SQL REPEATED UPDATE users SET xname = :name, xdept = :rdept, xtitle = :rtitle, xaddress = :raddr, xphone1 = :rhphone, xphone2 = :rophone, xmodtime = date('now'), clearid = :sid WHERE users_id = :id; if (sqlca.sqlcode != 0) { if (sqlca.sqlcode == SQL_DEADLOCK) { com_err(whoami, MR_DEADLOCK, "updating user %s", sid); EXEC SQL ROLLBACK; return process_entry(e); } else { com_err(whoami, 0, "ingres error %d", sqlca.sqlcode); exit(1); } } } } newuser(e) struct entry *e; { char buf[512], *from, *to; EXEC SQL BEGIN DECLARE SECTION; int id, uid, who; char *last, *first, *class, *middle, login[9], *sid, fullname[65], *prog; char haddr[81], hphone[17], ophone[13], dept[24], *title, raddr[81], *name; EXEC SQL END DECLARE SECTION; who = WHO; prog = PROG; strcpy(buf, e->address); if (*e->dorm) { strcat(buf, " "); strcat(buf, e->dorm); } if (*e->city) { strcat(buf, " "); strcat(buf, e->city); } if (*e->state) { strcat(buf, " "); strcat(buf, e->state); } strncpy(haddr, buf, 80); from = e->dphone; to = buf; while (*from) { if (isdigit(*from)) *to++ = *from; from++; } *to = 0; strncpy(hphone, buf, 16); from = e->mphone; to = buf; while (*from) { if (isdigit(*from)) *to++ = *from; from++; } *to = 0; strncpy(ophone, buf, 12); strncpy(dept, e->course, 12); id = set_next_users_id(0); uid = set_next_uid(1); sprintf(login, "#%d", uid); last = e->last; first = e->first; middle = e->middle; sid = e->id; class = e->class; title = e->title; if (*middle) sprintf(fullname, "%s %s %s", first, middle, last); else sprintf(fullname, "%s %s", first, last); name = e->name; strcpy(raddr, e->address); if (*e->dorm) { strcat(raddr, " "); strcat(raddr, e->dorm); } strcat(raddr, "|"); if (*e->city) { strcat(raddr, e->city); FixCase(raddr); if (*e->state) { strcat(raddr, " "); if (isupper(e->state[0]) && isupper(e->state[1]) && isdigit(e->state[2]) && isdigit(e->state[3]) && isdigit(e->state[4]) && isdigit(e->state[5]) && isdigit(e->state[6])) { sprintf(buf, "%c%c %s", e->state[0],e->state[1], &(e->state[2])); strcat(raddr, buf); } else strcat(raddr, e->state); } } else { FixCase(raddr); strcat(raddr, "MIT INTERDEPARTMENTAL MAIL"); } EXEC SQL REPEATED INSERT INTO users (login, users_id, uid, shell, last, first, middle, status, clearid, type, modtime, modby, modwith, fullname, home_addr, home_phone, office_phone, department, fmodtime, fmodby, fmodwith, potype, xname, xdept, xtitle, xaddress, xphone1, xphone2, xmodtime) VALUES (:login, :id, :uid, '/bin/csh', :last, :first, :middle, 0, :sid, :class, 'now', :who, :prog, :fullname, :haddr, :hphone, :ophone, :dept, 'now', :who, :prog, 'NONE', :name, :dept, :title, :raddr, :hphone, :ophone, date('now')); if (sqlca.sqlcode != 0) { if (sqlca.sqlcode == SQL_DEADLOCK) { com_err(whoami, MR_DEADLOCK, "adding user %s", sid); EXEC SQL ROLLBACK; return newuser(e); } else { com_err(whoami, 0, "ingres error %d", sqlca.sqlcode); exit(1); } } else com_err(whoami, 0, "adding user %s %s", e->first, e->last); } set_next_users_id(limit) int limit; { EXEC SQL BEGIN DECLARE SECTION; int rowcount, flag, value, retval; EXEC SQL END DECLARE SECTION; EXEC SQL REPEATED SELECT value INTO :value FROM numvalues WHERE name = 'users_id'; if (sqlfail()) sqlexit(); if (sqlca.sqlerrd[2] != 1) { EXEC SQL ROLLBACK; com_err(whoami, MR_INTERNAL, "values table inconsistancy"); exit(1); } flag = 0; EXEC SQL REPEATED SELECT users_id INTO :flag FROM users WHERE users_id = :value; if (sqlfail()) sqlexit(); if (sqlca.sqlerrd[2] == 0) flag = 0; while (flag) { value++; if (limit && value > MAX_ID_VALUE) value = MIN_ID_VALUE; flag = 0; EXEC SQL REPEATED SELECT users_id INTO :flag FROM users WHERE users_id = :value; if (sqlfail()) sqlexit(); if (sqlca.sqlerrd[2] == 0) flag = 0; } retval = value++; if (limit && value > MAX_ID_VALUE) value = MIN_ID_VALUE; EXEC SQL REPEATED UPDATE numvalues SET value = :value WHERE name = 'users_id'; if (sqlca.sqlcode != 0) { com_err(whoami, 0, "ingres error %d", sqlca.sqlcode); exit(1); } return(retval); } set_next_uid(limit) int limit; { EXEC SQL BEGIN DECLARE SECTION; int rowcount, flag, value, retval; EXEC SQL END DECLARE SECTION; EXEC SQL REPEATED SELECT value INTO :value FROM numvalues WHERE name = 'uid'; if (sqlfail()) sqlexit(); if (sqlca.sqlerrd[2] != 1) { EXEC SQL ROLLBACK; com_err(whoami, MR_INTERNAL, "values table inconsistancy"); exit(1); } flag = 0; EXEC SQL REPEATED SELECT uid INTO :flag FROM users WHERE uid = :value; if (sqlfail()) sqlexit(); if (sqlca.sqlerrd[2] == 0) flag = 0; while (flag) { value++; if (limit && value > MAX_ID_VALUE) value = MIN_ID_VALUE; flag = 0; EXEC SQL REPEATED SELECT uid INTO :flag FROM users WHERE uid = :value; if (sqlfail()) sqlexit(); if (sqlca.sqlerrd[2] == 0) flag = 0; } retval = value++; if (limit && value > MAX_ID_VALUE) value = MIN_ID_VALUE; EXEC SQL REPEATED UPDATE numvalues SET value = :value WHERE name = 'uid'; if (sqlca.sqlcode != 0) { com_err(whoami, 0, "ingres error %d", sqlca.sqlcode); exit(1); } return(retval); } sqlexit() { if (sqlca.sqlcode == SQL_DEADLOCK) com_err(whoami, MR_DEADLOCK, "unrecoverable ingres error %d", sqlca.sqlcode); else com_err(whoami, 0, "ingres error %d", sqlca.sqlcode); EXEC SQL ROLLBACK WORK; exit(1); }