Method CollectionChannelGrantedPeriods

auth/user.go:411–506

Calculate periods where user had access to the given channel either directly or via a role

(scope, collection, chanName string)

// Calculate periods where user had access to the given channel either directly or via a role
func (user *userImpl) CollectionChannelGrantedPeriods(scope, collection, chanName string) ([]GrantHistorySequencePair, error) {
	var resultPairs []GrantHistorySequencePair

	// Grab user history and use this to begin the resultPairs
	userChannelHistory, ok := user.CollectionChannelHistory(scope, collection)[chanName]
	if ok {
		resultPairs = userChannelHistory.Entries
	}

	// Iterate over current user channels and add to resultPairs
	for channelName, chanInfo := range user.CollectionChannels(scope, collection) {
		if channelName != chanName {
			continue
		}
		resultPairs = append(resultPairs, GrantHistorySequencePair{
			StartSeq: chanInfo.Sequence,
			EndSeq:   math.MaxUint64,
		})
	}

	// Small function which takes the two start seqs and two end seqs and calculates the intersection
	compareAndAddPair := func(startSeq1, startSeq2, endSeq1, endSeq2 uint64) {
		start := base.Max(startSeq1, startSeq2)
		end := base.Min(endSeq1, endSeq2)
		if start < end {
			resultPairs = append(resultPairs, GrantHistorySequencePair{
				StartSeq: start,
				EndSeq:   end,
			})
		}
	}

	roles, err := user.GetRoles()
	if err != nil {
		return nil, err
	}
	// Iterate over current roles
	for _, currentRole := range roles {

		// Grab pairs from channel history on current roles
		roleChannelHistory, ok := currentRole.CollectionChannelHistory(scope, collection)[chanName]
		if ok {
			for _, roleChannelHistoryEntry := range roleChannelHistory.Entries {
				roleGrantedAt := user.RolesSince_[currentRole.Name()].Sequence
				compareAndAddPair(roleChannelHistoryEntry.StartSeq, roleGrantedAt, roleChannelHistoryEntry.EndSeq, math.MaxUint64)
			}
		}

		// Grab pairs from current channels on current roles
		if currentRole.CollectionChannels(scope, collection).Contains(chanName) {
			for _, channelInfo := range currentRole.CollectionChannels(scope, collection) {
				resultPairs = append(resultPairs, GrantHistorySequencePair{
					StartSeq: channelInfo.Sequence,
					EndSeq:   math.MaxUint64,
				})
			}
		}
	}