Skip to content

Commit 9da8631

Browse files
committed
[push] clean code
1 parent d573318 commit 9da8631

File tree

1 file changed

+11
-10
lines changed
  • internal/sms-gateway/modules/push/upstream

1 file changed

+11
-10
lines changed

internal/sms-gateway/modules/push/upstream/client.go

Lines changed: 11 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -43,17 +43,18 @@ func (c *Client) Open(ctx context.Context) error {
4343
}
4444

4545
func (c *Client) Send(ctx context.Context, messages []types.Message) ([]error, error) {
46-
payload := make(smsgateway.UpstreamPushRequest, 0, len(messages))
47-
48-
for _, message := range messages {
49-
payload = append(payload, smsgateway.PushNotification{
50-
Token: message.Token,
51-
Event: message.Event.Type,
52-
Data: message.Event.Data,
53-
})
54-
}
46+
payload := lo.Map(
47+
messages,
48+
func(item types.Message, _ int) smsgateway.PushNotification {
49+
return smsgateway.PushNotification{
50+
Token: item.Token,
51+
Event: item.Event.Type,
52+
Data: item.Event.Data,
53+
}
54+
},
55+
)
5556

56-
payloadBytes, err := json.Marshal(payload)
57+
payloadBytes, err := json.Marshal(smsgateway.UpstreamPushRequest(payload))
5758

5859
if err != nil {
5960
return nil, fmt.Errorf("can't marshal payload: %w", err)

0 commit comments

Comments
 (0)