Merge pull request #83 from vragovR/add-message-utm

Add `Utm` field to the `Dialog` struct

.github/workflows/ci.yml

@@ -19,33 +19,33 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Check out code into the Go module directory
-        uses: actions/checkout@v2
-      - name: Set up latest Go 1.x version
-        uses: actions/setup-go@v2
+        uses: actions/checkout@v4
+      - name: Set up Go 1.24
+        uses: actions/setup-go@v5
         with:
-          go-version: '1.17'
+          go-version: '1.24'
       - name: Get dependencies
         run: |
           go mod tidy
           cp .env.dist .env
       - name: Lint code with golangci-lint
-        uses: golangci/golangci-lint-action@v3
+        uses: golangci/golangci-lint-action@v6
         with:
-          version: v1.50.1
+          version: v1.62.2
           only-new-issues: true
   tests:
     name: Tests
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        go-version: ['1.13', '1.14', '1.15', '1.16']
+        go-version: ['1.13', '1.14', '1.15', '1.16', '1.17', '1.18', '1.19', '1.20', '1.21', '1.22', '1.23', '1.24']
     steps:
       - name: Set up Go ${{ matrix.go-version }}
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v5
         with:
           go-version: ${{ matrix.go-version }}
       - name: Check out code into the Go module directory
-        uses: actions/checkout@v2
+        uses: actions/checkout@v4
       - name: Get dependencies
         run: |
           go mod tidy

.golangci.yml

@@ -1,31 +1,15 @@
 run:
-  skip-dirs-use-default: true
   allow-parallel-runners: true
+  modules-download-mode: readonly
 
 output:
-  format: colored-line-number
+  formats:
+    - format: colored-line-number
   sort-results: true
 
-# Linters below do not support go1.18 yet because of generics.
-# See https://github.com/golangci/golangci-lint/issues/2649
-#    - bodyclose
-#    - sqlclosecheck
-
 linters:
   disable-all: true
   enable:
-    - paralleltest
-    - tparallel
-    - asciicheck
-    - asasalint
-    - varnamelen
-    - reassign
-    - nilnil
-    - nilerr
-    - nakedret
-    - goprintffuncname
-    - typecheck
-    - errchkjson
     - errcheck
     - gosimple
     - govet
@@ -33,11 +17,12 @@ linters:
     - staticcheck
     - unused
     - unparam
+    - bodyclose
     - dogsled
     - dupl
     - errorlint
     - exhaustive
-    - exportloopref
+    - copyloopvar
     - funlen
     - gocognit
     - goconst
@@ -46,6 +31,7 @@ linters:
     - godot
     - goimports
     - revive
+    - mnd
     - gosec
     - lll
     - makezero
@@ -53,22 +39,21 @@ linters:
     - nestif
     - prealloc
     - predeclared
-    - exportloopref
+    - sqlclosecheck
     - unconvert
     - whitespace
+    - unused
+    - testifylint
 
 linters-settings:
   govet:
-    check-shadowing: false
     disable-all: true
     enable:
       - assign
       - atomic
-      - atomicalign
       - bools
       - buildtag
       - copylocks
-      - fieldalignment
       - httpresponse
       - loopclosure
       - lostcancel
@@ -128,8 +113,6 @@ linters-settings:
           - log.Printf
           - log.Println
           - runtime/trace.Logf
-  unused:
-    check-exported: false
   unparam:
     check-exported: false
   dogsled:
@@ -138,8 +121,8 @@ linters-settings:
     threshold: 200
   errorlint:
     errorf: true
-    asserts: false
-    comparison: false
+    asserts: true
+    comparison: true
   exhaustive:
     check-generated: false
     default-signifies-exhaustive: false
@@ -161,25 +144,23 @@ linters-settings:
   whitespace:
     multi-if: false
     multi-func: false
-  varnamelen:
-    max-distance: 10
-    ignore-map-index-ok: true
-    ignore-type-assert-ok: true
-    ignore-chan-recv-ok: true
-    ignore-decls:
-      - t *testing.T
-      - e error
-      - i int
+
 issues:
   exclude-rules:
     - path: _test\.go
       linters:
+        - dupl
+        - mnd
         - lll
+        - bodyclose
         - errcheck
+        - sqlclosecheck
         - misspell
         - ineffassign
         - whitespace
         - makezero
+        - maligned
+        - ifshort
         - errcheck
         - funlen
         - goconst
@@ -187,8 +168,6 @@ issues:
         - gocyclo
         - godot
         - unused
-        - errchkjson
-        - varnamelen
   exclude-use-default: true
   exclude-case-sensitive: false
   max-issues-per-linter: 0
@@ -197,7 +176,4 @@ issues:
 
 severity:
   default-severity: error
-  case-sensitive: false
-
-service:
-  golangci-lint-version: 1.50.x
+  case-sensitive: false

v1/client.go

@@ -16,21 +16,21 @@ import (
 
 type Option func(*MgClient)
 
-// OptionHTTPClient set custom http.Client for MgClient
+// OptionHTTPClient set custom http.Client for MgClient.
 func OptionHTTPClient(client *http.Client) func(*MgClient) {
 	return func(c *MgClient) {
 		c.httpClient = client
 	}
 }
 
-// OptionLogger sets the provided logger instance into the MgClient
+// OptionLogger sets the provided logger instance into the MgClient.
 func OptionLogger(logger BasicLogger) func(*MgClient) {
 	return func(c *MgClient) {
 		c.logger = logger
 	}
 }
 
-// OptionDebug enables debug mode for MgClient
+// OptionDebug enables debug mode for MgClient.
 func OptionDebug() func(*MgClient) {
 	return func(c *MgClient) {
 		c.Debug = true
@@ -53,7 +53,7 @@ func New(url string, token string, opts ...Option) *MgClient {
 }
 
 // WithLogger sets the provided logger instance into the Client.
-// Deprecated: Use functional option OptionLogger instead
+// Deprecated: Use functional option OptionLogger instead.
 func (c *MgClient) WithLogger(logger BasicLogger) *MgClient {
 	c.logger = logger
 	return c
@@ -912,8 +912,57 @@ func (c *MgClient) UploadFileByURL(request UploadFileByUrlRequest) (UploadFileRe
 	return resp, status, err
 }
 
+// UpdateFileMetadata update file metadata
+//
+// Example:
+//
+//	response, status, err := c.UpdateFileMetadata(UploadFileByUrlRequest{
+//		ID:  "e038aa39-2338-4285-be86-e2a0bb424daa"
+//		Transcription: "demo transcription",
+//	})
+//
+//	if err != nil {
+//		fmt.Printf("%v", err)
+//	}
+//
+//	fmt.Printf("%s\n%s", response.ID, status)
+func (c *MgClient) UpdateFileMetadata(request UpdateFileMetadataRequest) (UploadFileResponse, int, error) {
+	var resp UploadFileResponse
+	outgoing, err := json.Marshal(&request)
+	if err != nil {
+		return resp, 0, err
+	}
+
+	data, status, err := c.PutRequest(fmt.Sprintf("/files/%s/meta", request.ID), outgoing)
+	if err != nil {
+		return resp, status, err
+	}
+
+	if status != http.StatusOK {
+		return resp, status, c.Error(data)
+	}
+
+	if e := json.Unmarshal(data, &resp); e != nil {
+		return resp, status, e
+	}
+
+	return resp, status, err
+}
+
+type wsParams struct {
+	options []string
+}
+
+type WsParams interface {
+	apply(*wsParams)
+}
+
+func (c WsOption) apply(opts *wsParams) {
+	opts.options = append(opts.options, string(c))
+}
+
 // WsMeta let you receive url & headers to open web socket connection
-func (c *MgClient) WsMeta(events []string) (string, http.Header, error) {
+func (c *MgClient) WsMeta(events []string, urlParams ...WsParams) (string, http.Header, error) {
 	var url string
 
 	if len(events) < 1 {
@@ -923,6 +972,14 @@ func (c *MgClient) WsMeta(events []string) (string, http.Header, error) {
 
 	url = fmt.Sprintf("%s%s%s%s", strings.Replace(c.URL, "https", "wss", 1), prefix, "/ws?events=", strings.Join(events[:], ","))
 
+	var params wsParams
+	for _, param := range urlParams {
+		param.apply(&params)
+	}
+	if len(params.options) > 0 {
+		url = fmt.Sprintf("%s&options=%s", url, strings.Join(params.options, ","))
+	}
+
 	if url == "" {
 		err := errors.New("empty WS URL")
 		return url, nil, err

v1/client_test.go

@@ -2,8 +2,12 @@ package v1
 
 import (
 	"bytes"
+	"compress/gzip"
+	"encoding/base64"
 	"encoding/json"
 	"fmt"
+	"github.com/stretchr/testify/require"
+	"io"
 	"log"
 	"math/rand"
 	"net/http"
@@ -69,7 +73,7 @@ func TestMgClient_Bots(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.NotEmpty(t, data)
 
 	for _, bot := range data {
@@ -148,7 +152,7 @@ func TestMgClient_Channels(t *testing.T) {
 		]`)
 
 	channels, status, err := c.Channels(ChannelsRequest{Active: 1})
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.Equal(t, 200, status)
 	assert.Len(t, channels, 1)
 
@@ -221,7 +225,7 @@ func TestMgClient_Users(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.NotEmpty(t, data)
 
 	for _, user := range data {
@@ -231,9 +235,9 @@ func TestMgClient_Users(t *testing.T) {
 		assert.Equal(t, "Test", user.FirstName)
 		assert.Equal(t, "Test", user.LastName)
 		assert.Equal(t, "2018-01-01T00:00:00.000000Z", user.CreatedAt)
-		assert.Equal(t, true, user.IsActive)
-		assert.Equal(t, true, user.IsOnline)
-		assert.Equal(t, true, user.IsTechnicalAccount)
+		assert.True(t, user.IsActive)
+		assert.True(t, user.IsOnline)
+		assert.True(t, user.IsTechnicalAccount)
 	}
 }
 
@@ -288,7 +292,7 @@ func TestMgClient_Customers(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.NotEmpty(t, data)
 
 	for _, customer := range data {
@@ -324,7 +328,7 @@ func TestMgClient_Chats(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.NotEmpty(t, data)
 
 	for _, chat := range data {
@@ -349,7 +353,7 @@ func TestMgClient_Members(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 
 	for _, member := range data {
 		assert.NotEmpty(t, member.ChatID)
@@ -373,7 +377,7 @@ func TestMgClient_Dialogs(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.NotEmpty(t, data)
 
 	for _, dialog := range data {
@@ -415,7 +419,7 @@ func TestMgClient_DialogUnassign(t *testing.T) {
 
 		resp, status, err := c.DialogUnassign(777)
 
-		assert.NoError(t, err)
+		require.NoError(t, err)
 		assert.Equal(t, http.StatusOK, status)
 
 		assert.Equal(t, int64(111), resp.PreviousResponsible.ID)
@@ -500,7 +504,7 @@ func TestMgClient_DialogsTagsAdd(t *testing.T) {
 
 	status, err := c.DialogsTagsAdd(req)
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.Equal(t, http.StatusOK, status)
 }
 
@@ -526,7 +530,7 @@ func TestMgClient_DialogsTagsDelete(t *testing.T) {
 
 	status, err := c.DialogTagsDelete(req)
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.Equal(t, http.StatusOK, status)
 }
 
@@ -547,7 +551,7 @@ func TestMgClient_Messages(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.NotEmpty(t, data)
 
 	for _, message := range data {
@@ -555,6 +559,83 @@ func TestMgClient_Messages(t *testing.T) {
 	}
 }
 
+func TestMgClient_MessagesDialog(t *testing.T) {
+	t.Parallel()
+
+	c := client()
+
+	defer gock.Off()
+
+	gock.New(mgURL).
+		Get("/api/bot/v1/messages").
+		Reply(200).
+		BodyString(`[
+			{
+				"id": 1,
+				"time": "2024-11-14T20:48:21Z",
+				"type": "system",
+				"scope": "private",
+				"chat_id": 1,
+				"is_read": false,
+				"is_edit": false,
+				"status": "received",
+				"dialog": {
+					"id": 2054
+				},
+				"action": "dialog_closed",
+				"channel_id": 71,
+				"created_at": "2024-11-14T20:48:21.907566Z",
+				"updated_at": "2024-11-14T20:48:21.907566Z"
+			},
+			{
+				"id": 2,
+				"time": "2024-11-14T19:58:42Z",
+				"type": "text",
+				"scope": "public",
+				"chat_id": 1,
+				"is_read": false,
+				"is_edit": false,
+				"status": "failed",
+				"from": {
+					"id": 1,
+					"external_id": "1",
+					"type": "user",
+					"avatar": "http://avatars-test.jpeg",
+					"name": "John Smith",
+					"first_name": "John",
+					"last_name": "Smith",
+					"available": true
+				},
+				"dialog": {
+					"id": 2054
+				},
+				"error": {
+					"code": "malformed_response"
+				},
+				"content": "Message from user John Smith",
+				"quote": null,
+				"channel_id": 71,
+				"created_at": "2024-11-14T19:58:42.933025Z",
+				"updated_at": "2024-11-14T19:58:45.01619Z"
+			}
+		]`)
+
+	req := MessagesRequest{}
+
+	data, status, err := c.Messages(req)
+	if err != nil {
+		t.Errorf("%d %v", status, err)
+	}
+
+	require.NoError(t, err)
+	assert.Len(t, data, 2)
+
+	for _, m := range data {
+		assert.NotNil(t, m.Message.Dialog)
+		assert.Equal(t, uint64(2054), m.Message.Dialog.ID)
+	}
+}
+
 func TestMgClient_MessageSendText(t *testing.T) {
 	c := client()
 
@@ -579,7 +660,7 @@ func TestMgClient_MessageSendText(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.NotEmpty(t, data.MessageID)
 }
 
@@ -617,7 +698,7 @@ func TestMgClient_MessageSendTextWithSuggestions(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.NotEmpty(t, data.MessageID)
 }
 
@@ -658,7 +739,7 @@ func TestMgClient_MessageSendProduct(t *testing.T) {
 		t.Errorf("%v", err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	t.Logf("%v", msg)
 }
 
@@ -718,7 +799,7 @@ func TestMgClient_MessageSendOrder(t *testing.T) {
 		t.Errorf("%v", err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	t.Logf("%v", msg)
 }
 
@@ -787,7 +868,7 @@ func TestMgClient_Info(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 }
 
 func TestMgClient_Commands(t *testing.T) {
@@ -807,7 +888,7 @@ func TestMgClient_Commands(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.NotEmpty(t, data)
 
 	for _, command := range data {
@@ -835,7 +916,7 @@ func TestMgClient_CommandEditDelete(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.NotEmpty(t, n.ID)
 
 	gock.New(mgURL).
@@ -848,10 +929,28 @@ func TestMgClient_CommandEditDelete(t *testing.T) {
 		t.Errorf("%d %v", status, err)
 	}
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	t.Logf("%v", d)
 }
 
+func TestMgClient_WsMeta_With_Options(t *testing.T) {
+	c := client()
+	events := []string{"user_updated", "user_join_chat"}
+	params := []WsParams{WsOptionIncludeMassCommunication}
+
+	url, headers, err := c.WsMeta(events, params...)
+
+	if err != nil {
+		t.Errorf("%v", err)
+	}
+
+	resURL := "wss://api.example.com/api/bot/v1/ws?events=user_updated,user_join_chat&options=include_mass_communication"
+	resToken := c.Token
+
+	assert.Equal(t, resURL, url)
+	assert.Equal(t, resToken, headers["X-Bot-Token"][0])
+}
+
 func TestMgClient_WsMeta(t *testing.T) {
 	c := client()
 	events := []string{"user_updated", "user_join_chat"}
@@ -861,23 +960,56 @@ func TestMgClient_WsMeta(t *testing.T) {
 		t.Errorf("%v", err)
 	}
 
-	resUrl := fmt.Sprintf("%s%s%s%s", strings.Replace(c.URL, "https", "wss", 1), prefix, "/ws?events=", strings.Join(events[:], ","))
+	resURL := fmt.Sprintf("%s%s%s%s", strings.Replace(c.URL, "https", "wss", 1), prefix, "/ws?events=", strings.Join(events, ","))
 	resToken := c.Token
 
-	assert.Equal(t, resUrl, url)
+	assert.Equal(t, resURL, url)
 	assert.Equal(t, resToken, headers["X-Bot-Token"][0])
 }
 
 func TestMgClient_UploadFile(t *testing.T) {
 	c := client()
 
+	defer gock.Off()
+	gock.New("https://via.placeholder.com").
+		Get("/300").
+		Reply(http.StatusOK).
+		SetHeader("Content-Type", "image/jpeg").
+		Body(func() io.Reader {
+			res, err := base64.StdEncoding.DecodeString(`
+H4sIAAAAAAACA/t/4/8DBgEvN083BkZGBgZGIGT4f5vBmYGVmYWFhZkVSLCysrKx83CwAwE/Nzcn
+jyC/kJAgv6CgsJiMuLCIlKigoISihJSsrLy8vLC4koqSnIqMnLwcyBBGoFZ2NnY+Dg4+ORFBETmS
+wf8DDIIcDAoMCsyMSgxMgozMgoz/jzDIA93JyggGDFDAyMTMAnQlBycXN1DBVgEGJkZmZiag+4Ee
+AMrWAuUZWARZhRQNHdmEAxPZlQpFjBonLuRQdtp4UDTo4gcV46SiJk4uMXEJSSlVNXUNTS0TUzNz
+C0srZxdXN3cPT6/gkNCw8IjIqOSU1LT0jMys4pLSsvKKyqrmlta29o7OrkmTp0ydNn3GzFmLFi9Z
+umz5ipWrNm3esnXb9h07dx06fOToseMnTp66dPnK1WvXb9y89fDR4ydPnz1/8fLVx0+fv3z99v3H
+z18gfzEyMDPCAFZ/CQL9xQSMFhZ2kL8YmcpBCgRZWBUN2YQcA9kTC4WVjBo5RJwmLtx4kFPZOOiD
+aFLRRS4xFZOHqh9BXgP7jDiPNZHlM7jHEP66xcDDzAiMPGZBBnuGH/fuKWs3sItefBlWa7FqV+h8
+P+01l9b8KnQQ27Labk545NLIL49WZwLl1m322vzyKEPFu6npl7temwAlQ3O1zi8XvQaSXMBtBdcZ
+itDYYP//JgDowAia0AIAAA==`)
+			if err != nil {
+				t.Errorf("%v", err)
+				t.FailNow()
+				return nil
+			}
+
+			unpacker, err := gzip.NewReader(bytes.NewReader(res))
+			if err != nil {
+				t.Errorf("%v", err)
+				t.FailNow()
+				return nil
+			}
+
+			return unpacker
+		}())
+
 	resp, err := http.Get("https://via.placeholder.com/300")
 	if err != nil {
 		t.Errorf("%v", err)
+		t.FailNow()
 	}
 
 	defer resp.Body.Close()
-	defer gock.Off()
 
 	gock.New(mgURL).
 		Post("/api/bot/v1/files/upload").
@@ -915,7 +1047,7 @@ func TestMgClient_UploadFileByUrl(t *testing.T) {
 
 	t.Logf("File %+v is upload", uploadFileResponse.ID)
 
-	assert.NoError(t, err)
+	require.NoError(t, err)
 }
 
 func RandStringBytesMaskImprSrc(n int) string {
@@ -978,9 +1110,9 @@ func TestMgClient_SuccessChatsByCustomerId(t *testing.T) {
 	}
 
 	resp, statusCode, err := apiClient.Chats(chatsRequest)
-	assert.NoError(t, err)
+	require.NoError(t, err)
 	assert.Equal(t, http.StatusOK, statusCode)
-	assert.Equal(t, 1, len(resp))
+	assert.Len(t, resp, 1)
 	assert.Equal(t, uint64(9000), resp[0].ID)
 	assert.Equal(t, uint64(8000), resp[0].Channel.ID)
 	assert.Equal(t, customerID, resp[0].Customer.ID)

v1/types.go

@@ -43,6 +43,8 @@ const (
 	WsEventSettingsUpdated   string = "settings_updated"
 	WsEventChatsDeleted      string = "chats_deleted"
 
+	WsOptionIncludeMassCommunication WsOption = "include_mass_communication"
+
 	ChannelFeatureNone    string = "none"
 	ChannelFeatureReceive string = "receive"
 	ChannelFeatureSend    string = "send"
@@ -50,6 +52,7 @@ const (
 
 	BotRoleDistributor string = "distributor"
 	BotRoleResponsible string = "responsible"
+	BotRoleHidden      string = "hidden"
 
 	MsgTypeText    string = "text"
 	MsgTypeSystem  string = "system"
@@ -146,15 +149,16 @@ type (
 	}
 
 	ChatsRequest struct {
-		ID                 uint64 `url:"id,omitempty"`
-		ChannelID          uint64 `url:"channel_id,omitempty" json:"channel_id"`
-		ChannelType        string `url:"channel_type,omitempty" json:"channel_type"`
-		CustomerID         uint64 `url:"customer_id,omitempty" json:"customer_id"`
-		CustomerExternalID string `url:"customer_external_id,omitempty" json:"customer_external_id"`
-		Since              string `url:"since,omitempty"`
-		Until              string `url:"until,omitempty"`
-		Limit              int    `url:"limit,omitempty"`
-		SinceID            int    `url:"since_id,omitempty"`
+		ID                       uint64 `url:"id,omitempty"`
+		ChannelID                uint64 `url:"channel_id,omitempty" json:"channel_id"`
+		ChannelType              string `url:"channel_type,omitempty" json:"channel_type"`
+		CustomerID               uint64 `url:"customer_id,omitempty" json:"customer_id"`
+		CustomerExternalID       string `url:"customer_external_id,omitempty" json:"customer_external_id"`
+		Since                    string `url:"since,omitempty"`
+		Until                    string `url:"until,omitempty"`
+		Limit                    int    `url:"limit,omitempty"`
+		SinceID                  int    `url:"since_id,omitempty"`
+		IncludeMassCommunication uint8  `url:"include_mass_communication,omitempty"`
 	}
 
 	MembersRequest struct {
@@ -167,16 +171,17 @@ type (
 	}
 
 	DialogsRequest struct {
-		ID      uint64 `url:"id,omitempty"`
-		ChatID  string `url:"chat_id,omitempty" json:"chat_id"`
-		UserID  string `url:"user_id,omitempty" json:"user_id"`
-		BotID   string `url:"bot_id,omitempty" json:"bot_id"`
-		Assign  uint8  `url:"assign,omitempty"`
-		Active  uint8  `url:"active,omitempty"`
-		Since   string `url:"since,omitempty"`
-		SinceID int    `url:"since_id,omitempty"`
-		Until   string `url:"until,omitempty"`
-		Limit   int    `url:"limit,omitempty"`
+		ID                       uint64 `url:"id,omitempty"`
+		ChatID                   string `url:"chat_id,omitempty" json:"chat_id"`
+		UserID                   string `url:"user_id,omitempty" json:"user_id"`
+		BotID                    string `url:"bot_id,omitempty" json:"bot_id"`
+		Assign                   uint8  `url:"assign,omitempty"`
+		Active                   uint8  `url:"active,omitempty"`
+		Since                    string `url:"since,omitempty"`
+		SinceID                  int    `url:"since_id,omitempty"`
+		Until                    string `url:"until,omitempty"`
+		Limit                    int    `url:"limit,omitempty"`
+		IncludeMassCommunication uint8  `url:"include_mass_communication,omitempty"`
 	}
 
 	DialogAssignRequest struct {
@@ -205,19 +210,20 @@ type (
 	}
 
 	MessagesRequest struct {
-		ID          []int  `url:"id,omitempty"`
-		ChatID      uint64 `url:"chat_id,omitempty" json:"chat_id"`
-		DialogID    uint64 `url:"dialog_id,omitempty" json:"dialog_id"`
-		UserID      uint64 `url:"user_id,omitempty" json:"user_id"`
-		CustomerID  uint64 `url:"customer_id,omitempty" json:"customer_id"`
-		BotID       uint64 `url:"bot_id,omitempty" json:"bot_id"`
-		ChannelID   uint64 `url:"channel_id,omitempty" json:"channel_id"`
-		ChannelType string `url:"channel_type,omitempty" json:"channel_type"`
-		Scope       string `url:"scope,omitempty"`
-		Type        string `url:"type,omitempty"`
-		Since       string `url:"since,omitempty"`
-		Until       string `url:"until,omitempty"`
-		Limit       int    `url:"limit,omitempty"`
+		ID                       []int  `url:"id,omitempty"`
+		ChatID                   uint64 `url:"chat_id,omitempty" json:"chat_id"`
+		DialogID                 uint64 `url:"dialog_id,omitempty" json:"dialog_id"`
+		UserID                   uint64 `url:"user_id,omitempty" json:"user_id"`
+		CustomerID               uint64 `url:"customer_id,omitempty" json:"customer_id"`
+		BotID                    uint64 `url:"bot_id,omitempty" json:"bot_id"`
+		ChannelID                uint64 `url:"channel_id,omitempty" json:"channel_id"`
+		ChannelType              string `url:"channel_type,omitempty" json:"channel_type"`
+		Scope                    string `url:"scope,omitempty"`
+		Type                     string `url:"type,omitempty"`
+		Since                    string `url:"since,omitempty"`
+		Until                    string `url:"until,omitempty"`
+		Limit                    int    `url:"limit,omitempty"`
+		IncludeMassCommunication uint8  `url:"include_mass_communication,omitempty"`
 	}
 
 	MessageSendRequest struct {
@@ -268,6 +274,13 @@ type (
 	UploadFileByUrlRequest struct {
 		Url string `json:"url"`
 	}
+
+	UpdateFileMetadataRequest struct {
+		ID            string `json:"-"`
+		Transcription string `json:"transcription,omitempty"`
+		// Current status of transcription process. Available values: "in_progress", "ready", "error"
+		TranscriptionStatus string `json:"transcription_status,omitempty"`
+	}
 )
 
 // Response types
@@ -334,16 +347,18 @@ type (
 	}
 
 	ChatResponseItem struct {
-		ID           uint64  `json:"id"`
-		Avatar       string  `json:"avatar"`
-		Name         string  `json:"name"`
-		Channel      Channel `json:"channel,omitempty"`
-		Customer     UserRef `json:"customer"`
-		AuthorID     uint64  `json:"author_id"`
-		LastMessage  Message `json:"last_message"`
-		LastActivity string  `json:"last_activity"`
-		CreatedAt    string  `json:"created_at"`
-		UpdatedAt    string  `json:"updated_at"`
+		ID              uint64    `json:"id"`
+		Avatar          string    `json:"avatar"`
+		Name            string    `json:"name"`
+		Channel         Channel   `json:"channel,omitempty"`
+		Customer        UserRef   `json:"customer"`
+		AuthorID        uint64    `json:"author_id"`
+		LastMessage     Message   `json:"last_message"`
+		LastUserMessage MessageID `json:"last_user_message"`
+		LastActivity    string    `json:"last_activity"`
+		LastDialog      Dialog    `json:"last_dialog"`
+		CreatedAt       string    `json:"created_at"`
+		UpdatedAt       string    `json:"updated_at"`
 	}
 
 	MemberResponseItem struct {
@@ -435,6 +450,11 @@ type (
 	}
 )
 
+// WS options.
+type (
+	WsOption string
+)
+
 // Single entity types
 type (
 	Message struct {
@@ -450,11 +470,16 @@ type (
 		From    *UserRef        `json:"from"`
 		Product *MessageProduct `json:"product,omitempty"`
 		Order   *MessageOrder   `json:"order,omitempty"`
+		Dialog  *MessageDialog  `json:"dialog,omitempty"`
 		*TextMessage
 		*SystemMessage
 		*AttachmentList
 	}
 
+	MessageID struct {
+		ID uint64 `json:"id"`
+	}
+
 	TextMessage struct {
 		Content string        `json:"content"`
 		Quote   *QuoteMessage `json:"quote"`
@@ -462,16 +487,22 @@ type (
 	}
 
 	SystemMessage struct {
-		Action      string               `json:"action"`
+		Action string `json:"action"`
+		// Deprecated: Use Message.Dialog.ID instead.
 		Dialog      *SystemMessageDialog `json:"dialog,omitempty"`
 		User        *UserRef             `json:"user,omitempty"`
 		Responsible *UserRef             `json:"responsible,omitempty"`
 	}
 
+	// Deprecated: Use MessageDialog instead.
 	SystemMessageDialog struct {
 		ID uint64 `json:"id"`
 	}
 
+	MessageDialog struct {
+		ID uint64 `json:"id"`
+	}
+
 	QuoteMessage struct {
 		ID      uint64   `json:"id"`
 		Content string   `json:"content"`
@@ -485,13 +516,21 @@ type (
 	}
 
 	Attachment struct {
-		ID         string  `json:"id"`
-		Mime       string  `json:"type"`
-		Caption    string  `json:"caption"`
-		Size       uint64  `json:"size"`
-		PreviewURL *string `json:"preview_url,omitempty"`
-		Height     *uint64 `json:"height,omitempty"`
-		Width      *uint64 `json:"width,omitempty"`
+		File
+
+		Caption string `json:"caption"`
+	}
+
+	File struct {
+		PreviewURL    *string `json:"preview_url,omitempty"`
+		Height        *uint64 `json:"height,omitempty"`
+		Width         *uint64 `json:"width,omitempty"`
+		Transcription string  `json:"transcription,omitempty"`
+		ID            string  `json:"id"`
+		Mime          string  `json:"type"`
+		Type          string  `json:"kind"`
+		Duration      int     `json:"duration,omitempty"`
+		Size          uint64  `json:"size"`
 	}
 
 	MessageProduct struct {
@@ -569,6 +608,7 @@ type (
 		IsAdmin            bool   `json:"is_admin"`
 		Available          bool   `json:"available"`
 		IsTechnicalAccount bool   `json:"is_technical_account"`
+		IsSystem           bool   `json:"is_system"`
 	}
 
 	Channel struct {
@@ -600,15 +640,16 @@ type (
 	}
 
 	Chat struct {
-		ID           uint64   `json:"id"`
-		Avatar       string   `json:"avatar"`
-		Name         string   `json:"name"`
-		Channel      *Channel `json:"channel,omitempty"`
-		Members      []Member `json:"members"`
-		Customer     *UserRef `json:"customer"`
-		AuthorID     uint64   `json:"author_id"`
-		LastMessage  *Message `json:"last_message"`
-		LastActivity string   `json:"last_activity"`
+		ID              uint64     `json:"id"`
+		Avatar          string     `json:"avatar"`
+		Name            string     `json:"name"`
+		Channel         *Channel   `json:"channel,omitempty"`
+		Members         []Member   `json:"members"`
+		Customer        *UserRef   `json:"customer"`
+		AuthorID        uint64     `json:"author_id"`
+		LastMessage     *Message   `json:"last_message"`
+		LastUserMessage *MessageID `json:"last_user_message"`
+		LastActivity    string     `json:"last_activity"`
 	}
 
 	WaitingChat struct {
@@ -631,6 +672,7 @@ type (
 		Responsible     *Responsible `json:"responsible"`
 		CreatedAt       string       `json:"created_at"`
 		ClosedAt        *string      `json:"closed_at"`
+		Utm             *Utm         `json:"utm,omitempty"`
 	}
 
 	FileMeta struct {