client.microgen.go

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

package transport

import (
	"context"
	"errors"

	invitations "git.perx.ru/perxis/perxis-go/pkg/invitations"
	"git.perx.ru/perxis/perxis-go/pkg/options"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

func (set EndpointsSet) Create(arg0 context.Context, arg1 *invitations.Invitation) (res0 *invitations.Invitation, res1 error) {
	request := CreateRequest{Invitation: arg1}
	response, res1 := set.CreateEndpoint(arg0, &request)
	if res1 != nil {
		if e, ok := status.FromError(res1); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res1 = errors.New(e.Message())
		}
		return
	}
	return response.(*CreateResponse).Created, res1
}

func (set EndpointsSet) Get(arg0 context.Context, arg1 string) (res0 *invitations.Invitation, res1 error) {
	request := GetRequest{InvitationId: arg1}
	response, res1 := set.GetEndpoint(arg0, &request)
	if res1 != nil {
		if e, ok := status.FromError(res1); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res1 = errors.New(e.Message())
		}
		return
	}
	return response.(*GetResponse).Invitation, res1
}

func (set EndpointsSet) Accept(arg0 context.Context, arg1 string, arg2 string) (res0 error) {
	request := AcceptRequest{
		InvitationId: arg1,
		UserId:       arg2,
	}
	_, res0 = set.AcceptEndpoint(arg0, &request)
	if res0 != nil {
		if e, ok := status.FromError(res0); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res0 = errors.New(e.Message())
		}
		return
	}
	return res0
}

func (set EndpointsSet) Find(arg0 context.Context, arg1 *invitations.Filter, arg2 *options.FindOptions) (res0 []*invitations.Invitation, res1 int, res2 error) {
	request := FindRequest{
		Filter: arg1,
		Opts:   arg2,
	}
	response, res2 := set.FindEndpoint(arg0, &request)
	if res2 != nil {
		if e, ok := status.FromError(res2); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res2 = errors.New(e.Message())
		}
		return
	}
	return response.(*FindResponse).Invitations, response.(*FindResponse).Total, res2
}

func (set EndpointsSet) Delete(arg0 context.Context, arg1 string) (res0 error) {
	request := DeleteRequest{InvitationId: arg1}
	_, res0 = set.DeleteEndpoint(arg0, &request)
	if res0 != nil {
		if e, ok := status.FromError(res0); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res0 = errors.New(e.Message())
		}
		return
	}
	return res0
}