message_thread_service.go   A
last analyzed

Size/Duplication

Total Lines 43
Duplicated Lines 0 %

Importance

Changes 0
Metric Value
cc 5
eloc 25
dl 0
loc 43
rs 10
c 0
b 0
f 0

1 Method

Rating   Name   Duplication   Size   Complexity  
A httpsms.*MessageThreadService.Index 0 28 5
1
package httpsms
2
3
import (
4
	"context"
5
	"encoding/json"
6
	"net/http"
7
	"strconv"
8
)
9
10
// MessageThreadService is the API client for the `/message-threads` endpoint
11
type MessageThreadService service
12
13
// Index returns a list of contacts which a phone number has communicated with (threads). It will be sorted by timestamp in descending order.
14
//
15
// API Docs: https://api.httpsms.com/index.html#/Channel%20Threads/get_message_threads
16
func (service *MessageThreadService) Index(ctx context.Context, params *MessageThreadIndexParams) (*MessageThreadsResponse, *Response, error) {
17
	request, err := service.client.newRequest(ctx, http.MethodGet, "/v1/message-threads", nil)
18
	if err != nil {
19
		return nil, nil, err
20
	}
21
22
	q := request.URL.Query()
23
	q.Add("skip", strconv.Itoa(params.Skip))
24
	q.Add("owner", params.Owner)
25
	q.Add("limit", strconv.Itoa(params.Limit))
26
27
	if params.Query != nil {
28
		q.Add("query", *params.Query)
29
	}
30
31
	request.URL.RawQuery = q.Encode()
32
33
	response, err := service.client.do(request)
34
	if err != nil {
35
		return nil, response, err
36
	}
37
38
	messageThreads := new(MessageThreadsResponse)
39
	if err = json.Unmarshal(*response.Body, messageThreads); err != nil {
40
		return nil, response, err
41
	}
42
43
	return messageThreads, response, nil
44
}
45