lib/ic/realms.go

// Copyright 2019 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package ic

import (
	"net/http"

	"google.golang.org/grpc/status" /* copybara-comment */
	"github.com/golang/protobuf/proto" /* copybara-comment */
	"github.com/GoogleCloudPlatform/healthcare-federated-access-services/lib/ga4gh" /* copybara-comment: ga4gh */
	"github.com/GoogleCloudPlatform/healthcare-federated-access-services/lib/handlerfactory" /* copybara-comment: handlerfactory */
	"github.com/GoogleCloudPlatform/healthcare-federated-access-services/lib/httputils" /* copybara-comment: httputils */
	"github.com/GoogleCloudPlatform/healthcare-federated-access-services/lib/storage" /* copybara-comment: storage */

	pb "github.com/GoogleCloudPlatform/healthcare-federated-access-services/proto/ic/v1" /* copybara-comment: go_proto */
)

func (s *Service) realmFactory() *handlerfactory.Options {
	return &handlerfactory.Options{
		TypeName:            "realm",
		NameField:           "realm",
		PathPrefix:          realmPath,
		HasNamedIdentifiers: true,
		Service: func() handlerfactory.Service {
			return &realm{
				s:     s,
				input: &pb.RealmRequest{},
			}
		},
	}
}

type realm struct {
	s     *Service
	input *pb.RealmRequest
	item  *pb.Realm
	cfg   *pb.IcConfig
	id    *ga4gh.Identity
}

func (c *realm) Setup(r *http.Request, tx storage.Tx) (int, error) {
	cfg, _, id, status, err := c.s.handlerSetup(tx, r, noScope, c.input)
	c.cfg = cfg
	c.id = id
	return status, err
}

func (c *realm) LookupItem(r *http.Request, name string, vars map[string]string) bool {
	// Accept any name that passes the name check.
	c.item = &pb.Realm{}
	return true
}

func (c *realm) NormalizeInput(r *http.Request, name string, vars map[string]string) error {
	if err := httputils.DecodeProtoReq(c.input, r); err != nil {
		return err
	}
	if c.input == nil {
		c.input = &pb.RealmRequest{}
	}
	if c.input.Item == nil {
		c.input.Item = &pb.Realm{}
	}
	return nil
}

func (c *realm) Get(r *http.Request, name string) (proto.Message, error) {
	if c.item != nil {
		return c.item, nil
	}
	return nil, nil
}

func (c *realm) Post(r *http.Request, name string) (proto.Message, error) {
	// Accept, but do nothing.
	return nil, nil
}

func (c *realm) Put(r *http.Request, name string) (proto.Message, error) {
	// Accept, but do nothing.
	return nil, nil
}

func (c *realm) Patch(r *http.Request, name string) (proto.Message, error) {
	// Accept, but do nothing.
	return nil, nil
}

func (c *realm) Remove(r *http.Request, name string) (proto.Message, error) {
	if _, err := c.s.store.Wipe(r.Context(), name, 0, 0); err != nil {
		return nil, err
	}
	if name == storage.DefaultRealm {
		return nil, ImportConfig(c.s.store, c.s.serviceName, nil, true, true, true)
	}
	return nil, nil
}

func (c *realm) CheckIntegrity(r *http.Request) *status.Status {
	return nil
}

func (c *realm) Save(r *http.Request, tx storage.Tx, name string, vars map[string]string, desc, typeName string) error {
	// Accept, but do nothing.
	return nil
}