Method Client.doSendRequest(). Add param ctx.
This commit is contained in:
parent
5cae4c8fe5
commit
d32afb0d3a
10
fcm.go
10
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
|
||||
|
|
Loading…
Reference in New Issue