Method getQueryDataPolicy

backend/store/policy.go:252–275

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

}

func (s *Store) getQueryDataPolicy(ctx context.Context, workspaceID string, resource string) (*storepb.QueryDataPolicy, error) {
	resourceType, _, err := common.GetPolicyResourceTypeAndResource(resource)
	if err != nil {
		return nil, err
	}
	policy, err := s.GetPolicy(ctx, &FindPolicyMessage{
		Workspace:    workspaceID,
		ResourceType: &resourceType,
		Resource:     &resource,
		Type:         new(storepb.Policy_QUERY_DATA),
	})
	if err != nil {
		return nil, errors.Wrapf(err, "failed to get policy")
	}
	if policy == nil {
		return &storepb.QueryDataPolicy{}, nil
	}

	p := &storepb.QueryDataPolicy{}
	if err := common.ProtojsonUnmarshaler.Unmarshal([]byte(policy.Payload), p); err != nil {
		return nil, errors.Wrapf(err, "failed to unmarshal query data policy")
	}
	return p, nil
}

type reviewConfigResource struct {
	resourceType storepb.Policy_Resource