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/invitations/transport"
	"git.perx.ru/perxis/perxis-go/pkg/options"
	pb "git.perx.ru/perxis/perxis-go/proto/invitations"
	empty "google.golang.org/protobuf/types/known/emptypb"
)

func _Encode_Create_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil CreateRequest")
	}
	req := request.(*transport.CreateRequest)
	pbInvitation, err := PtrInvitationToProto(req.Invitation)
	if err != nil {
		return nil, err
	}
	return &pb.CreateRequest{Invitation: pbInvitation}, 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{InvitationId: req.InvitationId}, nil
}

func _Encode_Accept_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil AcceptRequest")
	}
	req := request.(*transport.AcceptRequest)
	return &pb.AcceptRequest{
		InvitationId: req.InvitationId,
		UserId:       req.UserId,
	}, nil
}

func _Encode_Find_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil FindRequest")
	}
	req := request.(*transport.FindRequest)
	reqFilter, err := PtrFilterToProto(req.Filter)
	if err != nil {
		return nil, err
	}
	return &pb.FindRequest{
		Filter:  reqFilter,
		Options: options.FindOptionsToPB(req.Opts),
	}, nil
}

func _Encode_Delete_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil DeleteRequest")
	}
	req := request.(*transport.DeleteRequest)
	return &pb.DeleteRequest{InvitationId: req.InvitationId}, nil
}

func _Encode_Create_Response(ctx context.Context, response interface{}) (interface{}, error) {
	if response == nil {
		return nil, errors.New("nil CreateResponse")
	}
	resp := response.(*transport.CreateResponse)
	respInvitation, err := PtrInvitationToProto(resp.Created)
	if err != nil {
		return nil, err
	}
	return &pb.CreateResponse{Invitation: respInvitation}, nil
}

func _Encode_Get_Response(ctx context.Context, response interface{}) (interface{}, error) {
	if response == nil {
		return nil, errors.New("nil GetResponse")
	}
	resp := response.(*transport.GetResponse)
	respInvitation, err := PtrInvitationToProto(resp.Invitation)
	if err != nil {
		return nil, err
	}
	return &pb.GetResponse{Invitation: respInvitation}, nil
}

func _Encode_Accept_Response(ctx context.Context, response interface{}) (interface{}, error) {
	return &empty.Empty{}, nil
}

func _Encode_Find_Response(ctx context.Context, response interface{}) (interface{}, error) {
	if response == nil {
		return nil, errors.New("nil FindResponse")
	}
	resp := response.(*transport.FindResponse)
	respInvitations, err := ListPtrInvitationToProto(resp.Invitations)
	if err != nil {
		return nil, err
	}
	return &pb.FindResponse{
		Invitations: respInvitations,
		Total:       int64(resp.Total),
	}, nil
}

func _Encode_Delete_Response(ctx context.Context, response interface{}) (interface{}, error) {
	return &empty.Empty{}, nil
}

func _Decode_Create_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil CreateRequest")
	}
	req := request.(*pb.CreateRequest)
	invitation, err := ProtoToPtrInvitation(req.Invitation)
	if err != nil {
		return nil, err
	}
	return &transport.CreateRequest{Invitation: invitation}, nil
}

func _Decode_Get_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil GetRequest")
	}
	req := request.(*pb.GetRequest)
	return &transport.GetRequest{InvitationId: string(req.InvitationId)}, nil
}

func _Decode_Accept_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil AcceptRequest")
	}
	req := request.(*pb.AcceptRequest)
	return &transport.AcceptRequest{
		InvitationId: string(req.InvitationId),
		UserId:       string(req.UserId),
	}, nil
}

func _Decode_Find_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil FindRequest")
	}
	req := request.(*pb.FindRequest)
	reqFilter, err := ProtoToPtrFilter(req.Filter)
	if err != nil {
		return nil, err
	}
	return &transport.FindRequest{
		Filter: reqFilter,
		Opts:   options.FindOptionsFromPB(req.Options),
	}, nil
}

func _Decode_Delete_Request(ctx context.Context, request interface{}) (interface{}, error) {
	if request == nil {
		return nil, errors.New("nil DeleteRequest")
	}
	req := request.(*pb.DeleteRequest)
	return &transport.DeleteRequest{InvitationId: string(req.InvitationId)}, nil
}

func _Decode_Create_Response(ctx context.Context, response interface{}) (interface{}, error) {
	if response == nil {
		return nil, errors.New("nil CreateResponse")
	}
	resp := response.(*pb.CreateResponse)
	respInvitation, err := ProtoToPtrInvitation(resp.Invitation)
	if err != nil {
		return nil, err
	}
	return &transport.CreateResponse{Created: respInvitation}, nil
}

func _Decode_Get_Response(ctx context.Context, response interface{}) (interface{}, error) {
	if response == nil {
		return nil, errors.New("nil GetResponse")
	}
	resp := response.(*pb.GetResponse)
	respInvitation, err := ProtoToPtrInvitation(resp.Invitation)
	if err != nil {
		return nil, err
	}
	return &transport.GetResponse{Invitation: respInvitation}, nil
}

func _Decode_Accept_Response(ctx context.Context, response interface{}) (interface{}, error) {
	return &empty.Empty{}, nil
}

func _Decode_Find_Response(ctx context.Context, response interface{}) (interface{}, error) {
	if response == nil {
		return nil, errors.New("nil FindResponse")
	}
	resp := response.(*pb.FindResponse)
	respInvitations, err := ProtoToListPtrInvitation(resp.Invitations)
	if err != nil {
		return nil, err
	}
	return &transport.FindResponse{
		Invitations: respInvitations,
		Total:       int(resp.Total),
	}, nil
}

func _Decode_Delete_Response(ctx context.Context, response interface{}) (interface{}, error) {
	return &empty.Empty{}, nil
}