protobuf_endpoint_converters.microgen.go

// Code generated by microgen 0.9.1. DO NOT EDIT.

// Please, do not change functions names!
package transportgrpc

import (
	"context"
	"errors"

	transport "git.perx.ru/perxis/perxis-go/pkg/collections/transport"
	pb "git.perx.ru/perxis/perxis-go/proto/collections"
	empty "github.com/golang/protobuf/ptypes/empty"
)

func _Encode_Create_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil CreateRequest")
	}
	req := request.(*transport.CreateRequest)
	reqCollection, err := PtrCollectionToProto(req.Collection)
	if err != nil {
		return nil, err
	}
	return &pb.CreateRequest{Collection: reqCollection}, nil
}

func _Encode_Get_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil GetRequest")
	}
	req := request.(*transport.GetRequest)
	return &pb.GetRequest{
		CollectionId: req.CollectionId,
		EnvId:        req.EnvId,
		SpaceId:      req.SpaceId,
		Options:      GetOptionsToProto(req.Options),
	}, nil
}

func _Encode_List_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil ListRequest")
	}
	req := request.(*transport.ListRequest)
	reqFilter, err := PtrFilterToProto(req.Filter)
	if err != nil {
		return nil, err
	}
	return &pb.ListRequest{
		EnvId:   req.EnvId,
		Filter:  reqFilter,
		SpaceId: req.SpaceId,
	}, nil
}

func _Encode_Update_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil UpdateRequest")
	}
	req := request.(*transport.UpdateRequest)
	reqColl, err := PtrCollectionToProto(req.Coll)
	if err != nil {
		return nil, err
	}
	return &pb.UpdateRequest{Collection: reqColl}, nil
}

func _Encode_SetSchema_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil SetSchemaRequest")