Method GetEffectiveQueryDataPolicy

backend/store/policy.go:218–250

(ctx context.Context, workspaceID string, projectFullName string)

}

func (s *Store) GetEffectiveQueryDataPolicy(ctx context.Context, workspaceID string, projectFullName string) (*EffectiveQueryDataPolicy, error) {
	workspaceResource := common.FormatWorkspace(workspaceID)
	workspacePolicy, err := s.getQueryDataPolicy(ctx, workspaceID, workspaceResource)
	if err != nil {
		return nil, err
	}
	projectPolicy, err := s.getQueryDataPolicy(ctx, workspaceID, projectFullName)
	if err != nil {
		return nil, err
	}

	formatWorkspacePolicy := formatEffectiveQueryDataPolicy(workspacePolicy)
	formatProjectPolicy := formatEffectiveQueryDataPolicy(projectPolicy)

	maximumResultSize, err := s.GetSQLResultSize(ctx, workspaceID)
	if err != nil {
		return nil, err
	}

	queryTimeout, err := s.GetQueryTimeoutInSeconds(ctx, workspaceID)
	if err != nil {
		return nil, err
	}

	return &EffectiveQueryDataPolicy{
		DisableCopyData:          formatWorkspacePolicy.DisableCopyData,
		DisableExport:            formatWorkspacePolicy.DisableExport,
		MaximumResultRows:        min(formatWorkspacePolicy.MaximumResultRows, formatProjectPolicy.MaximumResultRows),
		MaximumResultSize:        maximumResultSize,
		MaxQueryTimeoutInSeconds: queryTimeout,
		AllowAdminDataSource:     formatWorkspacePolicy.AllowAdminDataSource,
	}, nil
}

func (s *Store) getQueryDataPolicy(ctx context.Context, workspaceID string, resource string) (*storepb.QueryDataPolicy, error) {
	resourceType, _, err := common.GetPolicyResourceTypeAndResource(resource)