customerservice

Documentation

Index

• type CRMLookupResponse
• type CustomerService
  • func New(repo repo.Repo, resolver session.PriorityResolver) *CustomerService
  • func (svc *CustomerService) CRMLookupHandler(w http.ResponseWriter, req *http.Request)
  • func (svc *CustomerService) SearchCustomer(ctx context.Context, msg *connect.Request[customerv1.SearchCustomerRequest]) (*connect.Response[customerv1.SearchCustomerResponse], error)
  • func (svc *CustomerService) SearchCustomerStream(ctx context.Context, ...) error
  • func (svc *CustomerService) UpdateCustomer(ctx context.Context, req *connect.Request[customerv1.UpdateCustomerRequest]) (*connect.Response[customerv1.UpdateCustomerResponse], error)

Types

type CRMLookupResponse

type CRMLookupResponse struct {
	FirstName string `json:"firstName"`
	LastName  string `json:"lastName"`
	ID        string `json:"id"`

	PhoneNumbers map[string]string `json:"phoneNumbers"`
}

type CustomerService

type CustomerService struct {
	customerv1connect.UnimplementedCustomerServiceHandler
	// contains filtered or unexported fields
}

func New

func New(repo repo.Repo, resolver session.PriorityResolver) *CustomerService

func (*CustomerService) CRMLookupHandler

func (svc *CustomerService) CRMLookupHandler(w http.ResponseWriter, req *http.Request)

GET /crm/lookup?phone=xyz

func (*CustomerService) SearchCustomer

func (svc *CustomerService) SearchCustomer(ctx context.Context, msg *connect.Request[customerv1.SearchCustomerRequest]) (*connect.Response[customerv1.SearchCustomerResponse], error)

func (*CustomerService) SearchCustomerStream

func (svc *CustomerService) SearchCustomerStream(ctx context.Context, stream *connect.BidiStream[customerv1.SearchCustomerRequest, customerv1.SearchCustomerResponse]) error

func (*CustomerService) UpdateCustomer

func (svc *CustomerService) UpdateCustomer(ctx context.Context, req *connect.Request[customerv1.UpdateCustomerRequest]) (*connect.Response[customerv1.UpdateCustomerResponse], error)