Method UpdatePermission

worker/dbms.go:326–368

UpdatePermission exports the update permission interface for test.

(dbID proto.DatabaseID, user proto.AccountAddress, permStat *types.PermStat)

// UpdatePermission exports the update permission interface for test.
func (dbms *DBMS) UpdatePermission(dbID proto.DatabaseID, user proto.AccountAddress, permStat *types.PermStat) (err error) {
	dbms.busService.lock.Lock()
	defer dbms.busService.lock.Unlock()
	profile, ok := dbms.busService.sqlChainProfiles[dbID]
	if !ok {
		dbms.busService.sqlChainProfiles[dbID] = &types.SQLChainProfile{
			ID: dbID,
			Users: []*types.SQLChainUser{
				&types.SQLChainUser{
					Address:    user,
					Permission: permStat.Permission,
					Status:     permStat.Status,
				},
			},
		}
	} else {
		exist := false
		for _, u := range profile.Users {
			if u.Address == user {
				u.Permission = permStat.Permission
				u.Status = permStat.Status
				exist = true
				break
			}
		}
		if !exist {
			profile.Users = append(profile.Users, &types.SQLChainUser{
				Address:    user,
				Permission: permStat.Permission,
				Status:     permStat.Status,
			})
			dbms.busService.sqlChainProfiles[dbID] = profile
		}
	}

	_, ok = dbms.busService.sqlChainState[dbID]
	if !ok {
		dbms.busService.sqlChainState[dbID] = make(map[proto.AccountAddress]*types.PermStat)
	}
	dbms.busService.sqlChainState[dbID][user] = permStat

	return
}

func (dbms *DBMS) initDatabases(
	meta *DBMSMeta, profiles map[proto.DatabaseID]*types.SQLChainProfile) (err error,