doc_new.go

/*
Copyright © 2020 FairOS Authors

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 api

import (
	"encoding/json"
	"net/http"
	"strings"

	"github.com/fairdatasociety/fairOS-dfs/pkg/auth"

	"github.com/fairdatasociety/fairOS-dfs/pkg/collection"

	"resenje.org/jsonhttp"
)

// DocRequest is used for creating a doc
type DocRequest struct {
	PodName     string `json:"podName,omitempty"`
	TableName   string `json:"tableName,omitempty"`
	SimpleIndex string `json:"si,omitempty"`
	Mutable     bool   `json:"mutable,omitempty"`
}

// SimpleDocRequest is used in doc delete request
type SimpleDocRequest struct {
	PodName   string `json:"podName,omitempty"`
	TableName string `json:"tableName,omitempty"`
}

// DocCreateHandler godoc
//
//	@Summary      Create in doc table
//	@Description  DocCreateHandler is the api handler to create a new document database
//	@ID		      doc-create
//	@Tags         doc
//	@Accept       json
//	@Produce      json
//	@Param	      doc_request body DocRequest true "doc table info. si or simple index is a comma separated list of keys and their types. eg: 'first_name=string,age=number'. valid index types can be 'string', 'number', 'map', 'list'. default index is 'id' and it should be of type string"
//	@Param	      Cookie header string true "cookie parameter"
//	@Success      201  {object}  response
//	@Failure      400  {object}  response
//	@Failure      500  {object}  response
//	@Router       /v1/doc/new [post]
func (h *Handler) DocCreateHandler(w http.ResponseWriter, r *http.Request) {
	contentType := r.Header.Get("Content-Type")
	if contentType != jsonContentType {
		h.logger.Errorf("doc create: invalid request body type")
		jsonhttp.BadRequest(w, &response{Message: "doc create: invalid request body type"})
		return
	}

	decoder := json.NewDecoder(r.Body)
	var docReq DocRequest
	err := decoder.Decode(&docReq)
	if err != nil {
		h.logger.Errorf("doc create: could not decode arguments")
		jsonhttp.BadRequest(w, &response{Message: "doc create: could not decode arguments"})
		return
	}

	podName := docReq.PodName
	if podName == "" {
		h.logger.Errorf("doc create: \"podName\" argument missing")
		jsonhttp.BadRequest(w, &response{Message: "doc create: \"podName\" argument missing"})
		return
	}

	name := docReq.TableName
	if name == "" {
		h.logger.Errorf("doc create: \"tableName\" argument missing")
		jsonhttp.BadRequest(w, &response{Message: "doc  create: \"tableName\" argument missing"})
		return
	}

	// by default, add the index type "id" as stringIndex
	indexes := make(map[string]collection.IndexType)
	si := docReq.SimpleIndex
	if si != "" {
		idxs := strings.Split(si, ",")
		for _, idx := range idxs {
			nt := strings.Split(idx, "=")
			if len(nt) != 2 {
				h.logger.Errorf("doc create: \"si\" invalid argument ")
				jsonhttp.BadRequest(w, &response{Message: "doc  create: \"si\" invalid argument"})
				return
			}
			switch nt[1] {
			case "string":
				indexes[nt[0]] = collection.StringIndex
			case "number":
				indexes[nt[0]] = collection.NumberIndex
			case "map":
				indexes[nt[0]] = collection.MapIndex
			case "list":
				indexes[nt[0]] = collection.ListIndex
			case "bytes":
			default:
				h.logger.Errorf("doc create: invalid \"indexType\" ")
				jsonhttp.BadRequest(w, &response{Message: "doc create: invalid \"indexType\""})
				return
			}
		}
	}

	mutable := docReq.Mutable

	// get sessionId from request
	sessionId, err := auth.GetSessionIdFromRequest(r)
	if err != nil {
		h.logger.Errorf("sessionId parse failed: ", err)
		jsonhttp.BadRequest(w, &response{Message: ErrUnauthorized.Error()})
		return
	}
	if sessionId == "" {
		h.logger.Error("sessionId not set: ", err)
		jsonhttp.BadRequest(w, &response{Message: ErrUnauthorized.Error()})
		return
	}

	err = h.dfsAPI.DocCreate(sessionId, podName, name, indexes, mutable)
	if err != nil {
		h.logger.Errorf("doc create: %v", err)
		jsonhttp.InternalServerError(w, &response{Message: "doc create: " + err.Error()})
		return
	}

	jsonhttp.Created(w, &response{Message: "document db created"})
}