* Copyright (C) 1987 by the Massachusetts Institute of Technology
*
* $Log$
- * Revision 1.9 1987-08-22 17:41:34 wesommer
- * More of Mike's changes.
+ * Revision 1.18 1988-01-14 12:00:38 mar
+ * separate access check from setup routine.
+ * make get_query_need be more paranoid
*
+Revision 1.17 88/01/04 12:09:00 mar
+fixup pobox access checking & make id assignment more paranoid (wesommer)
+
+Revision 1.16 87/11/12 18:16:56 wesommer
+Add support for delete_user_by_uid.
+Fix access_pop.
+Check a few return codes.
+
+Revision 1.15 87/09/11 15:31:58 wesommer
+add_user_group modified to side-effect the time for tbs for groups as
+well as the other things.
+
+Revision 1.15 87/09/10 22:44:49 wesommer
+One more table needs to be modified when adding the user-group.
+
+Revision 1.14 87/09/04 17:50:03 mike
+Renamed delete_list_members to followup_delete_list. New routine removes
+list from maillists and groups tables in addition to the members table.
+
+Added routines validate_label and validate_label_2 used in validating
+filesys labels for get_filesys and delete_filesys respectively.
+
+Revision 1.13 87/09/01 16:24:01 wesommer
+A list should be considered modified if its acl changes.
+
+Revision 1.12 87/08/29 00:05:54 mike
+Fixed bug in check_nfs.
+Added code to upcasify machine names in validate_id.
+
+Revision 1.11 87/08/28 14:55:45 mike
+Modified delete_locker to require only one argument, the login name.
+Modified get_groups_of_all_users and get_all_poboxes to disable INGRES
+table locking.
+
+Revision 1.10 87/08/25 15:56:54 mike
+- Fixed bugs in get_groups_of_all_users
+- Added tblstats updates to add_user_group
+- Added routines: add_hostaccess (ashi), delete_hostaccess (dshi),
+ followup_ushp, and followup_usha
+
+Revision 1.9 87/08/22 17:41:34 wesommer
+More of Mike's changes.
+
Revision 1.8 87/08/18 15:05:20 wesommer
Fixed definition of add_locker.
## int exists;
if (!bcmp(q->name, "add_pobox", 10) && !bcmp(argv[1], "POP", 4)) {
+ box = argv[3];
+ if (strcmp(cl->kname.name, box) != 0) return SMS_PERM;
+
users_id = *(int *)argv[0];
mach_id = *(int *)argv[2];
- box = argv[3];
+
## range of p is pobox
## repeat retrieve (exists = any(p.#box where p.#users_id = @users_id
-## and p.type = "POP"
-## and p.#mach_id = @mach_id
-## and p.#box = @box))
+## and p.type = "POP"))
if (exists) return(SMS_EXISTS);
}
**
**/
-setup_add_group(q, argv, cl, access_check)
+setup_add_group(q, argv, cl)
struct query *q;
char *argv[];
client *cl;
- int access_check;
##{
## int ngid;
## int exists;
- int status;
-
- status = access_list(q, argv, cl);
-
- if (status != SMS_SUCCESS || access_check) return(status);
+## int rowcount;
+ int status;
## range of g is groups
## range of v is values
}
## repeat replace v (value = @ngid) where v.name = "gid"
- return(SMS_SUCCESS);
+## inquire_equel (rowcount = "rowcount")
+ if (rowcount != 1) return SMS_INGRES_ERR;
+ else return(SMS_SUCCESS);
##}
\f
/**
**
**/
-setup_add_user(q, argv, cl, access_check)
+setup_add_user(q, argv, cl)
struct query *q;
register char *argv[];
client *cl;
- int access_check;
##{
## int nuid;
## int exists;
- if (access_check) return(SMS_SUCCESS);
-
if (!bcmp(argv[1], "#", 2)) {
## range of u is users
## range of v is values
## int rowcount;
## char dir[32];
char caccess;
+ register int status;
register char *cp1;
register char *cp2;
caccess = (isupper(*access)) ? tolower(*access) : *access;
if (caccess != 'r' && caccess != 'w') return(SMS_FILESYS_ACCESS);
+ status = SMS_NFS;
## range of np is nfsphys
## retrieve (dir = np.#dir) where np.#mach_id = mach_id
## {
if (*cp1++ != *cp2) break;
cp2++;
}
- if (*cp2 == 0) return(SMS_SUCCESS);
+ if (*cp2 == 0) {
+ status = SMS_SUCCESS;
+## endretrieve
+ }
## }
- return(SMS_NFS);
+ return(status);
##}
\f
/* Followup Routines */
list_id = *(int *)argv[0];
## repeat replace list (modtime = "now") where list.#list_id = @list_id
+## repeat replace list (modtime = "now") where list.#acl_id = @list_id
return(SMS_SUCCESS);
##}
list_id = *(int *)argv[0];
## repeat replace list (modtime = "now") where list.#list_id = @list_id
+## repeat replace list (modtime = "now") where list.#acl_id = @list_id
/* if query is not amtl or if member_type is not LIST then return */
if (bcmp(q->shortname, "amtl", 4) || bcmp(argv[1], "LIST", 4))
return(SMS_SUCCESS);
##}
-delete_current_quota(q, argv, cl, access_check)
+delete_current_quota(q, argv, cl)
struct query *q;
register char *argv[];
client *cl;
- int access_check;
##{
## int mach_id;
## int users_id;
## char *device;
## int quota;
- if (access_check) return(SMS_SUCCESS);
-
mach_id = *(int *)argv[0];
device = argv[1];
users_id = *(int *)argv[2];
##}
\f
/**
- ** delete_list_members - called after the delete_list query to clean up
- ** members table.
+ ** add_hostaccess - create entry in hostaccess table upon adding a new
+ ** machine to the serverhosts table where service =
+ ** "hostaccess".
+ **
+ ** Inputs:
+ ** argv[0] - service
+ ** argv[1] - mach_id
+ **
+ **/
+
+add_hostaccess(q, argv)
+ struct query *q;
+ char *argv[];
+##{
+## int mach_id;
+
+ /* only work with service = "hostaccess" */
+ if (bcmp(argv[0], "hostaccess", 10)) return(SMS_SUCCESS);
+
+ mach_id = *(int *)argv[1];
+## repeat append hostaccess (#mach_id = @mach_id, status = 0)
+## repeat replace tblstats (modtime = "now", appends = tblstats.appends + 1)
+## where tblstats.table = "hostaccess"
+ return(SMS_SUCCESS);
+##}
+
+/* followup to delete_server_host_info */
+
+delete_hostaccess(q, argv)
+ struct query *q;
+ char *argv[];
+##{
+## int mach_id;
+
+ /* only work with service = "hostaccess" */
+ if (bcmp(argv[0], "hostaccess", 10)) return(SMS_SUCCESS);
+
+ mach_id = *(int *)argv[1];
+## repeat delete hostaccess where hostaccess.#mach_id = @mach_id
+## repeat replace tblstats (modtime = "now", deletes = tblstats.deletes + 1)
+## where tblstats.table = "hostaccess"
+ return(SMS_SUCCESS);
+##}
+
+followup_ushp(q, argv)
+ struct query *q;
+ char *argv[];
+##{
+## int mach_id;
+## int status;
+
+ mach_id = *(int *)argv[0];
+## range of ha is hostaccess
+## repeat retrieve (status = ha.#status) where ha.#mach_id = @mach_id
+ status |= 1;
+## repeat replace ha (#status = @status) where ha.#mach_id = @mach_id
+ return(SMS_SUCCESS);
+##}
+
+followup_usha(q, argv)
+ struct query *q;
+ char *argv[];
+##{
+## int mach_id;
+## int status;
+
+ mach_id = *(int *)argv[0];
+## range of ha is hostaccess
+## repeat retrieve (status = ha.#status) where ha.#mach_id = @mach_id
+ status |= 2;
+## repeat replace ha (#status = @status) where ha.#mach_id = @mach_id
+ return(SMS_SUCCESS);
+##}
+\f
+/**
+ ** followup_delete_list - called after the delete_list query to clean up
+ ** members table; also deletes list from maillist
+ ** and groups tables.
**
** Inputs: argv[0] - list_id
**
**
**/
-delete_list_members(q, argv)
+followup_delete_list(q, argv)
struct query *q;
register char *argv[];
##{
sq_destroy(sq);
## repeat delete m where m.#list_id = @list_id
+## repeat delete maillists where maillists.#list_id = @list_id
+## repeat delete groups where groups.#list_id = @list_id
return(SMS_SUCCESS);
##}
\f
/**
- ** grvd_support - Support routine for get_rvd_servers query
+ ** followup_grvd - Support routine for get_rvd_servers query
**
** Inputs:
** q - grvd query structure
**
**/
-grvd_support(q, sq, v, action, actarg)
+followup_grvd(q, sq, v, action, actarg)
struct query *q;
struct save_queue *sq;
struct validate *v;
return(SMS_SUCCESS);
##}
-gars_support(q, sq, v, action, actarg)
+followup_gars(q, sq, v, action, actarg)
struct query *q;
struct save_queue *sq;
struct validate *v;
char *object;
##{
## char *name;
+## int rowcount;
- name = object;
+ name = object;
## range of v is values
## repeat replace v (value = v.value + 1) where v.#name = @name
- return(SMS_SUCCESS);
+## inquire_equel (rowcount = "rowcount")
+ if (rowcount != 1)
+ return SMS_INGRES_ERR;
+ else return(SMS_SUCCESS);
##}
/**
last_get_time = argv[1];
table = q1->rtable;
- if (q1->type != RETRIEVE) return(SMS_NO_MATCH);
+ if (q1 == NULL || q1->type != RETRIEVE || table == NULL)
+ return(SMS_NO_MATCH);
## range of tbs is tblstats
## repeat retrieve (need = any(tbs.modtime where tbs.#table = @table and
**
** Inputs:
** argv[0] - users_id
- ** argv[1] - machine_id
- ** argv[2] - device
- ** argv[3] - quota
**
** Description:
+ ** - get login name from users_id
+ ** - get filesys entry from login
+ ** - use filesys.mach_id and filesys.name to determine machine/device
+ ** pair for nfsphys and nfsquota
** - delete filesys entry (label=<login>)
** - decrement allocated in nfsphys by quota
** - delete nfsquota entry
##{
## int users_id;
## int mach_id;
-## char *device;
## int quota;
## int rowcount;
## char login[9];
+## char lname[64];
+## char ndev[32];
+ register char *c;
/* copy arguments */
users_id = *(int *)argv[0];
- mach_id = *(int *)argv[1];
- device = argv[2];
- sscanf(argv[3], "%d", "a);
## range of u is users
## range of f is filesys
/* get login name */
## repeat retrieve (login = u.#login) where u.#users_id = @users_id
- /* delete the filesys entry */
-## repeat delete f where f.label = @login
+ /* get mach_id and locker name from filesys entry; then delete it */
+## repeat retrieve (mach_id = f.#mach_id, lname = f.#name)
+## where f.#label = @login
## inquire_equel (rowcount = "rowcount")
if (rowcount == 0) return(SMS_FILESYS);
+## repeat delete f where f.#label = @login
+
+ /* get prefix directory */
+ c = (char *)rindex(lname, '/');
+ *c = 0;
+
+ /* get nfs device */
+## repeat retrieve (ndev = np.device)
+## where np.#mach_id = @mach_id and np.dir = @lname
+
+ /* get quota from nfsquota entry; then delete entry */
+## repeat retrieve (quota = nq.#quota)
+## where nq.#mach_id = @mach_id and nq.#device = @ndev and
+## nq.#users_id = @users_id
+## repeat delete nq where nq.#mach_id = @mach_id and nq.#device = @ndev and
+## nq.#users_id = @users_id
+
+ /* decrement nfsphys.allocated */
+## repeat replace np (allocated = np.allocated - @quota)
+## where np.#mach_id = @mach_id and np.#device = @ndev
+
+ /* adjust table statistics */
## repeat replace tbs (deletes = tbs.deletes + 1, modtime = "now")
## where tbs.table = "filesys"
-
- /* decrement usage count in nfsphys table */
-## replace np (#allocated = np.#allocated - quota)
-## where np.#mach_id = mach_id and np.#device = device
## repeat replace tbs (updates = tbs.updates + 1, modtime = "now")
## where tbs.table = "nfsphys"
-
- /* delete nfsquota entry */
-## delete nq where nq.#users_id = users_id and nq.#mach_id = mach_id and
-## nq.#device = device
## repeat replace tbs (deletes = tbs.deletes + 1, modtime = "now")
## where tbs.table = "nfsquota"
## repeat replace values (value = @list_id) where values.name = "list_id"
/* create the list */
+## range of tbs is tblstats
## repeat append list (name = @login, #list_id = @list_id, flags = 1,
## desc = "User Group", acl_id = @list_id,
## expdate = "today" + "5 years", modtime = "now")
+## repeat replace tbs (modtime = "now", appends = tbs.appends + 1)
+## where tbs.table = "list"
/* add user to list */
## repeat append members (#list_id = @list_id, member_type = "USER",
## member_id = @users_id)
+## repeat replace tbs (modtime = "now", appends = tbs.appends + 1)
+## where tbs.table = "members"
/* get new gid */
## range of g is groups
## repeat retrieve (exists = any(g.#gid where g.#gid = @gid))
}
## repeat replace v (value = @gid) where v.name = "gid"
-
/* add list to group table */
## repeat append groups (#list_id = @list_id, ltid = list.tid, #gid = @gid)
## where list.#list_id = @list_id
+## repeat replace tbs (modtime = "now", appends = tbs.appends + 1)
+## where tbs.table = "groups"
+
+## repeat replace tbs (modtime = "now", appends = tbs.appends + 1)
+## where tbs.table = "members"
+
/* and we're done */
return(SMS_SUCCESS);
##}
## char login[9];
## char group[33];
## char gid[11];
+ char *targv[3];
## int errorno;
+ targv[0] = login;
+ targv[1] = group;
+ targv[2] = gid;
+
## range of u is users
## range of l is list
## range of m is members
## range of g is groups
-## repeat retrieve (login = u.#login, group = l.name, gid = g.#gid)
+## set lockmode session where readlock = nolock
+
+## repeat retrieve (login = u.#login, group = l.name, gid = text(g.#gid))
## where m.member_type = "USER" and m.member_id = u.users_id and
## u.status != 0 and m.list_id = g.list_id and
## g.ltid = l.tid
## sort by #login, #group
+## {
+ (*action)(3, targv, actarg);
+## }
## inquire_equel (errorno = "errorno")
+## set lockmode session where readlock = system
return((errorno) ? SMS_INGRES_ERR : SMS_SUCCESS);
##}
targv[3] = box;
targv[1] = "LOCAL";
+
+## set lockmode session where readlock = nolock
## range of p is pobox
## repeat retrieve (login=users.#login, machine = #machine.name, box=p.#box)
## where p.type = "LOCAL" and p.users_id = users.users_id
## {
(*action)(4, targv, actarg);
## }
+## set lockmode session where readlock = system
return(SMS_SUCCESS);
##}
## char *idfield;
## int id;
## int rowcount;
+ register char *c;
name = argv[vo->index];
table = vo->table;
+ /* minor kludge to upcasify machine names */
+ if (!bcmp(table, "machine", 7))
+ for (c = name; *c; c++) if (islower(*c)) *c = toupper(*c);
namefield = vo->namefield;
idfield = vo->idfield;
-## retrieve (id = table.idfield) where table.namefield = name
-## inquire_equel (rowcount = "rowcount")
+ if (!bcmp(namefield, "uid", 4)) {
+## retrieve (id = table.idfield) where table.namefield = int4(name)
+## inquire_equel (rowcount = "rowcount")
+ } else {
+## retrieve (id = table.idfield) where table.namefield = name
+## inquire_equel (rowcount = "rowcount")
+ }
if (rowcount != 1) return(vo->error);
*(int *)argv[vo->index] = id;
return(SMS_EXISTS);
return ((rowcount == 1) ? SMS_EXISTS : vo->error);
##}
+/* Special validation routine for get_filesys */
+validate_label(q, argv)
+ struct query *q;
+ char *argv[];
+{
+ register char *label;
+ register char *c;
+
+ label = argv[0];
+ c = (char *)index(label, '*');
+ if (c == label) return(SMS_NOT_UNIQUE);
+ return(SMS_SUCCESS);
+}
+
+/* Special validation routine for delete_filesys */
+validate_label_2(q, argv)
+ struct query *q;
+ char *argv[];
+{
+ if (index(argv[0], '*') != 0) return(SMS_NOT_UNIQUE);
+ return(SMS_SUCCESS);
+}
+
validate_date(argv, vo)
char *argv[];
struct valobj *vo;