diff --git a/fcm.go b/fcm.go index 409349b..daed817 100644 --- a/fcm.go +++ b/fcm.go @@ -108,7 +108,7 @@ func (c *Client) SendMessage(ctx context.Context, msg Message) (SendResponse, er Message: msg, } - return c.doSendRequest(sendRequest, true) + return c.doSendRequest(ctx, sendRequest, true) } func (c *Client) ValidateMessage(ctx context.Context, msg Message) (SendResponse, error) { @@ -117,7 +117,7 @@ func (c *Client) ValidateMessage(ctx context.Context, msg Message) (SendResponse Message: msg, } - return c.doSendRequest(sendRequest, true) + return c.doSendRequest(ctx, sendRequest, true) } func (c *Client) Send(ctx context.Context, message Message) (string, error) { @@ -125,7 +125,7 @@ func (c *Client) Send(ctx context.Context, message Message) (string, error) { ValidateOnly: false, Message: message, } - resp, err := c.doSendRequest(sendRequest, false) + resp, err := c.doSendRequest(ctx, sendRequest, false) return resp.MessageName, err } @@ -135,12 +135,12 @@ func (c *Client) Validate(ctx context.Context, message Message) (string, error) ValidateOnly: true, Message: message, } - resp, err := c.doSendRequest(sendRequest, false) + resp, err := c.doSendRequest(ctx, sendRequest, false) return resp.MessageName, err } -func (c *Client) doSendRequest(req SendRequest, loggerEnabled bool) (SendResponse, error) { +func (c *Client) doSendRequest(ctx context.Context, req SendRequest, loggerEnabled bool) (SendResponse, error) { accessToken, err := c.ts.Token() if err != nil { return SendResponse{}, err