From abe96654467a3d9a211d0134389116ca6a56cae8 Mon Sep 17 00:00:00 2001 From: Denis Arh Date: Tue, 9 Oct 2018 07:45:26 +0200 Subject: [PATCH] Added missing service call context --- sam/rest/channel.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/sam/rest/channel.go b/sam/rest/channel.go index 2fc96b1fc..26c8fd255 100644 --- a/sam/rest/channel.go +++ b/sam/rest/channel.go @@ -67,15 +67,15 @@ func (ctrl *Channel) Members(ctx context.Context, r *request.ChannelMembers) (in } func (ctrl *Channel) Invite(ctx context.Context, r *request.ChannelInvite) (interface{}, error) { - return ctrl.wrapMemberSet(ctrl.svc.ch.InviteUser(r.ChannelID, r.UserID...)) + return ctrl.wrapMemberSet(ctrl.svc.ch.With(ctx).InviteUser(r.ChannelID, r.UserID...)) } func (ctrl *Channel) Join(ctx context.Context, r *request.ChannelJoin) (interface{}, error) { - return ctrl.wrapMemberSet(ctrl.svc.ch.AddMember(r.ChannelID, r.UserID)) + return ctrl.wrapMemberSet(ctrl.svc.ch.With(ctx).AddMember(r.ChannelID, r.UserID)) } func (ctrl *Channel) Part(ctx context.Context, r *request.ChannelPart) (interface{}, error) { - return nil, ctrl.svc.ch.DeleteMember(r.ChannelID, r.UserID) + return nil, ctrl.svc.ch.With(ctx).DeleteMember(r.ChannelID, r.UserID) } func (ctrl *Channel) Attach(ctx context.Context, r *request.ChannelAttach) (interface{}, error) {