fix UploadFile dependency on external URL

This commit is contained in:
Pavel 2025-03-06 14:59:25 +03:00 committed by GitHub
commit e2205fb4d9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
5 changed files with 98 additions and 85 deletions

View File

@ -19,33 +19,33 @@ jobs:
runs-on: ubuntu-latest runs-on: ubuntu-latest
steps: steps:
- name: Check out code into the Go module directory - name: Check out code into the Go module directory
uses: actions/checkout@v2 uses: actions/checkout@v4
- name: Set up latest Go 1.x version - name: Set up Go 1.24
uses: actions/setup-go@v2 uses: actions/setup-go@v5
with: with:
go-version: '1.17' go-version: '1.24'
- name: Get dependencies - name: Get dependencies
run: | run: |
go mod tidy go mod tidy
cp .env.dist .env cp .env.dist .env
- name: Lint code with golangci-lint - name: Lint code with golangci-lint
uses: golangci/golangci-lint-action@v3 uses: golangci/golangci-lint-action@v6
with: with:
version: v1.50.1 version: v1.62.2
only-new-issues: true only-new-issues: true
tests: tests:
name: Tests name: Tests
runs-on: ubuntu-latest runs-on: ubuntu-latest
strategy: strategy:
matrix: 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: steps:
- name: Set up Go ${{ matrix.go-version }} - name: Set up Go ${{ matrix.go-version }}
uses: actions/setup-go@v2 uses: actions/setup-go@v5
with: with:
go-version: ${{ matrix.go-version }} go-version: ${{ matrix.go-version }}
- name: Check out code into the Go module directory - name: Check out code into the Go module directory
uses: actions/checkout@v2 uses: actions/checkout@v4
- name: Get dependencies - name: Get dependencies
run: | run: |
go mod tidy go mod tidy

View File

@ -1,31 +1,15 @@
run: run:
skip-dirs-use-default: true
allow-parallel-runners: true allow-parallel-runners: true
modules-download-mode: readonly
output: output:
format: colored-line-number formats:
- format: colored-line-number
sort-results: true 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: linters:
disable-all: true disable-all: true
enable: enable:
- paralleltest
- tparallel
- asciicheck
- asasalint
- varnamelen
- reassign
- nilnil
- nilerr
- nakedret
- goprintffuncname
- typecheck
- errchkjson
- errcheck - errcheck
- gosimple - gosimple
- govet - govet
@ -33,11 +17,12 @@ linters:
- staticcheck - staticcheck
- unused - unused
- unparam - unparam
- bodyclose
- dogsled - dogsled
- dupl - dupl
- errorlint - errorlint
- exhaustive - exhaustive
- exportloopref - copyloopvar
- funlen - funlen
- gocognit - gocognit
- goconst - goconst
@ -46,6 +31,7 @@ linters:
- godot - godot
- goimports - goimports
- revive - revive
- mnd
- gosec - gosec
- lll - lll
- makezero - makezero
@ -53,22 +39,21 @@ linters:
- nestif - nestif
- prealloc - prealloc
- predeclared - predeclared
- exportloopref - sqlclosecheck
- unconvert - unconvert
- whitespace - whitespace
- unused
- testifylint
linters-settings: linters-settings:
govet: govet:
check-shadowing: false
disable-all: true disable-all: true
enable: enable:
- assign - assign
- atomic - atomic
- atomicalign
- bools - bools
- buildtag - buildtag
- copylocks - copylocks
- fieldalignment
- httpresponse - httpresponse
- loopclosure - loopclosure
- lostcancel - lostcancel
@ -128,8 +113,6 @@ linters-settings:
- log.Printf - log.Printf
- log.Println - log.Println
- runtime/trace.Logf - runtime/trace.Logf
unused:
check-exported: false
unparam: unparam:
check-exported: false check-exported: false
dogsled: dogsled:
@ -138,8 +121,8 @@ linters-settings:
threshold: 200 threshold: 200
errorlint: errorlint:
errorf: true errorf: true
asserts: false asserts: true
comparison: false comparison: true
exhaustive: exhaustive:
check-generated: false check-generated: false
default-signifies-exhaustive: false default-signifies-exhaustive: false
@ -161,25 +144,23 @@ linters-settings:
whitespace: whitespace:
multi-if: false multi-if: false
multi-func: 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: issues:
exclude-rules: exclude-rules:
- path: _test\.go - path: _test\.go
linters: linters:
- dupl
- mnd
- lll - lll
- bodyclose
- errcheck - errcheck
- sqlclosecheck
- misspell - misspell
- ineffassign - ineffassign
- whitespace - whitespace
- makezero - makezero
- maligned
- ifshort
- errcheck - errcheck
- funlen - funlen
- goconst - goconst
@ -187,8 +168,6 @@ issues:
- gocyclo - gocyclo
- godot - godot
- unused - unused
- errchkjson
- varnamelen
exclude-use-default: true exclude-use-default: true
exclude-case-sensitive: false exclude-case-sensitive: false
max-issues-per-linter: 0 max-issues-per-linter: 0
@ -198,6 +177,3 @@ issues:
severity: severity:
default-severity: error default-severity: error
case-sensitive: false case-sensitive: false
service:
golangci-lint-version: 1.50.x

View File

@ -16,21 +16,21 @@ import (
type Option func(*MgClient) 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) { func OptionHTTPClient(client *http.Client) func(*MgClient) {
return func(c *MgClient) { return func(c *MgClient) {
c.httpClient = client 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) { func OptionLogger(logger BasicLogger) func(*MgClient) {
return func(c *MgClient) { return func(c *MgClient) {
c.logger = logger c.logger = logger
} }
} }
// OptionDebug enables debug mode for MgClient // OptionDebug enables debug mode for MgClient.
func OptionDebug() func(*MgClient) { func OptionDebug() func(*MgClient) {
return func(c *MgClient) { return func(c *MgClient) {
c.Debug = true 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. // 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 { func (c *MgClient) WithLogger(logger BasicLogger) *MgClient {
c.logger = logger c.logger = logger
return c return c

View File

@ -2,8 +2,12 @@ package v1
import ( import (
"bytes" "bytes"
"compress/gzip"
"encoding/base64"
"encoding/json" "encoding/json"
"fmt" "fmt"
"github.com/stretchr/testify/require"
"io"
"log" "log"
"math/rand" "math/rand"
"net/http" "net/http"
@ -69,7 +73,7 @@ func TestMgClient_Bots(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
assert.NotEmpty(t, data) assert.NotEmpty(t, data)
for _, bot := range data { for _, bot := range data {
@ -148,7 +152,7 @@ func TestMgClient_Channels(t *testing.T) {
]`) ]`)
channels, status, err := c.Channels(ChannelsRequest{Active: 1}) channels, status, err := c.Channels(ChannelsRequest{Active: 1})
assert.NoError(t, err) require.NoError(t, err)
assert.Equal(t, 200, status) assert.Equal(t, 200, status)
assert.Len(t, channels, 1) assert.Len(t, channels, 1)
@ -221,7 +225,7 @@ func TestMgClient_Users(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
assert.NotEmpty(t, data) assert.NotEmpty(t, data)
for _, user := range 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.FirstName)
assert.Equal(t, "Test", user.LastName) assert.Equal(t, "Test", user.LastName)
assert.Equal(t, "2018-01-01T00:00:00.000000Z", user.CreatedAt) assert.Equal(t, "2018-01-01T00:00:00.000000Z", user.CreatedAt)
assert.Equal(t, true, user.IsActive) assert.True(t, user.IsActive)
assert.Equal(t, true, user.IsOnline) assert.True(t, user.IsOnline)
assert.Equal(t, true, user.IsTechnicalAccount) assert.True(t, user.IsTechnicalAccount)
} }
} }
@ -288,7 +292,7 @@ func TestMgClient_Customers(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
assert.NotEmpty(t, data) assert.NotEmpty(t, data)
for _, customer := range data { for _, customer := range data {
@ -324,7 +328,7 @@ func TestMgClient_Chats(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
assert.NotEmpty(t, data) assert.NotEmpty(t, data)
for _, chat := range data { for _, chat := range data {
@ -349,7 +353,7 @@ func TestMgClient_Members(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
for _, member := range data { for _, member := range data {
assert.NotEmpty(t, member.ChatID) assert.NotEmpty(t, member.ChatID)
@ -373,7 +377,7 @@ func TestMgClient_Dialogs(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
assert.NotEmpty(t, data) assert.NotEmpty(t, data)
for _, dialog := range data { for _, dialog := range data {
@ -415,7 +419,7 @@ func TestMgClient_DialogUnassign(t *testing.T) {
resp, status, err := c.DialogUnassign(777) resp, status, err := c.DialogUnassign(777)
assert.NoError(t, err) require.NoError(t, err)
assert.Equal(t, http.StatusOK, status) assert.Equal(t, http.StatusOK, status)
assert.Equal(t, int64(111), resp.PreviousResponsible.ID) assert.Equal(t, int64(111), resp.PreviousResponsible.ID)
@ -500,7 +504,7 @@ func TestMgClient_DialogsTagsAdd(t *testing.T) {
status, err := c.DialogsTagsAdd(req) status, err := c.DialogsTagsAdd(req)
assert.NoError(t, err) require.NoError(t, err)
assert.Equal(t, http.StatusOK, status) assert.Equal(t, http.StatusOK, status)
} }
@ -526,7 +530,7 @@ func TestMgClient_DialogsTagsDelete(t *testing.T) {
status, err := c.DialogTagsDelete(req) status, err := c.DialogTagsDelete(req)
assert.NoError(t, err) require.NoError(t, err)
assert.Equal(t, http.StatusOK, status) assert.Equal(t, http.StatusOK, status)
} }
@ -547,7 +551,7 @@ func TestMgClient_Messages(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
assert.NotEmpty(t, data) assert.NotEmpty(t, data)
for _, message := range data { for _, message := range data {
@ -623,7 +627,7 @@ func TestMgClient_MessagesDialog(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
assert.Len(t, data, 2) assert.Len(t, data, 2)
for _, m := range data { for _, m := range data {
@ -656,7 +660,7 @@ func TestMgClient_MessageSendText(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
assert.NotEmpty(t, data.MessageID) assert.NotEmpty(t, data.MessageID)
} }
@ -694,7 +698,7 @@ func TestMgClient_MessageSendTextWithSuggestions(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
assert.NotEmpty(t, data.MessageID) assert.NotEmpty(t, data.MessageID)
} }
@ -735,7 +739,7 @@ func TestMgClient_MessageSendProduct(t *testing.T) {
t.Errorf("%v", err) t.Errorf("%v", err)
} }
assert.NoError(t, err) require.NoError(t, err)
t.Logf("%v", msg) t.Logf("%v", msg)
} }
@ -795,7 +799,7 @@ func TestMgClient_MessageSendOrder(t *testing.T) {
t.Errorf("%v", err) t.Errorf("%v", err)
} }
assert.NoError(t, err) require.NoError(t, err)
t.Logf("%v", msg) t.Logf("%v", msg)
} }
@ -864,7 +868,7 @@ func TestMgClient_Info(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
} }
func TestMgClient_Commands(t *testing.T) { func TestMgClient_Commands(t *testing.T) {
@ -884,7 +888,7 @@ func TestMgClient_Commands(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
assert.NotEmpty(t, data) assert.NotEmpty(t, data)
for _, command := range data { for _, command := range data {
@ -912,7 +916,7 @@ func TestMgClient_CommandEditDelete(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
assert.NotEmpty(t, n.ID) assert.NotEmpty(t, n.ID)
gock.New(mgURL). gock.New(mgURL).
@ -925,7 +929,7 @@ func TestMgClient_CommandEditDelete(t *testing.T) {
t.Errorf("%d %v", status, err) t.Errorf("%d %v", status, err)
} }
assert.NoError(t, err) require.NoError(t, err)
t.Logf("%v", d) t.Logf("%v", d)
} }
@ -956,7 +960,7 @@ func TestMgClient_WsMeta(t *testing.T) {
t.Errorf("%v", err) 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 resToken := c.Token
assert.Equal(t, resURL, url) assert.Equal(t, resURL, url)
@ -966,13 +970,46 @@ func TestMgClient_WsMeta(t *testing.T) {
func TestMgClient_UploadFile(t *testing.T) { func TestMgClient_UploadFile(t *testing.T) {
c := client() 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") resp, err := http.Get("https://via.placeholder.com/300")
if err != nil { if err != nil {
t.Errorf("%v", err) t.Errorf("%v", err)
t.FailNow()
} }
defer resp.Body.Close() defer resp.Body.Close()
defer gock.Off()
gock.New(mgURL). gock.New(mgURL).
Post("/api/bot/v1/files/upload"). Post("/api/bot/v1/files/upload").
@ -1010,7 +1047,7 @@ func TestMgClient_UploadFileByUrl(t *testing.T) {
t.Logf("File %+v is upload", uploadFileResponse.ID) t.Logf("File %+v is upload", uploadFileResponse.ID)
assert.NoError(t, err) require.NoError(t, err)
} }
func RandStringBytesMaskImprSrc(n int) string { func RandStringBytesMaskImprSrc(n int) string {
@ -1073,9 +1110,9 @@ func TestMgClient_SuccessChatsByCustomerId(t *testing.T) {
} }
resp, statusCode, err := apiClient.Chats(chatsRequest) resp, statusCode, err := apiClient.Chats(chatsRequest)
assert.NoError(t, err) require.NoError(t, err)
assert.Equal(t, http.StatusOK, statusCode) 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(9000), resp[0].ID)
assert.Equal(t, uint64(8000), resp[0].Channel.ID) assert.Equal(t, uint64(8000), resp[0].Channel.ID)
assert.Equal(t, customerID, resp[0].Customer.ID) assert.Equal(t, customerID, resp[0].Customer.ID)

View File

@ -450,7 +450,7 @@ type (
} }
) )
// WS options // WS options.
type ( type (
WsOption string WsOption string
) )