SQuiz/amocrm
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

update logic tokens updating

Browse Source
This commit is contained in:
Pavel 2024-05-06 14:22:05 +03:00
parent e2fa6e7743
commit 6f16251af7
4 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
go.mod
View File

@ -12,7 +12,7 @@ require (
github.com/twmb/franz-go v1.16.1
go.uber.org/zap v1.27.0
google.golang.org/protobuf v1.33.0
penahub.gitlab.yandexcloud.net/backend/quiz/common.git v0.0.0-20240506103401-eb032d19f851
penahub.gitlab.yandexcloud.net/backend/quiz/common.git v0.0.0-20240506110833-3afa7086d8e7
penahub.gitlab.yandexcloud.net/backend/quiz/core.git v0.0.0-20240219174804-d78fd38511af
)

4
go.sum
View File

@ -151,7 +151,7 @@ gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
penahub.gitlab.yandexcloud.net/backend/penahub_common v0.0.0-20240223054633-6cb3d5ce45b6 h1:oV+/HNX+JPoQ3/GUx08hio7d45WpY0AMGrFs7j70QlA=
penahub.gitlab.yandexcloud.net/backend/penahub_common v0.0.0-20240223054633-6cb3d5ce45b6/go.mod h1:lTmpjry+8evVkXWbEC+WMOELcFkRD1lFMc7J09mOndM=
penahub.gitlab.yandexcloud.net/backend/quiz/common.git v0.0.0-20240506103401-eb032d19f851 h1:BaYvqxcwJuwVD0GQpyCtmArewJ3s1yggCic/FDnYOog=
penahub.gitlab.yandexcloud.net/backend/quiz/common.git v0.0.0-20240506103401-eb032d19f851/go.mod h1:oRyhT55ctjqp/7ZxIzkR7OsQ7T/NLibsfrbb7Ytns64=
penahub.gitlab.yandexcloud.net/backend/quiz/common.git v0.0.0-20240506110833-3afa7086d8e7 h1:SzwUo27l1O6mMuvCGzq/6LPyv7lZQWUAHyKliYClMh4=
penahub.gitlab.yandexcloud.net/backend/quiz/common.git v0.0.0-20240506110833-3afa7086d8e7/go.mod h1:oRyhT55ctjqp/7ZxIzkR7OsQ7T/NLibsfrbb7Ytns64=
penahub.gitlab.yandexcloud.net/backend/quiz/core.git v0.0.0-20240219174804-d78fd38511af h1:jQ7HaXSutDX5iepU7VRImxhikK7lV/lBKkiloOZ4Emo=
penahub.gitlab.yandexcloud.net/backend/quiz/core.git v0.0.0-20240219174804-d78fd38511af/go.mod h1:5S5YwjSXWmnEKjBjG6MtyGtFmljjukDRS8CwHk/CF/I=

2
internal/workers/post_fields_worker/post_worker.go
View File

@ -35,7 +35,7 @@ func NewPostFieldsWC(deps Deps) *PostFields {
}
func (wc *PostFields) Start(ctx context.Context) {
ticker := time.NewTicker(30 * time.Second)
ticker := time.NewTicker(1 * time.Minute)
defer ticker.Stop()
for {

14
internal/workers_methods/methods.go
View File

@ -39,8 +39,6 @@ func (m *Methods) UpdateTokens(ctx context.Context) ([]model.Token, error) {
return nil, err
}
var newTokens []model.Token
for _, oldToken := range allTokens {
req := models.UpdateWebHookReq{
GrantType: "refresh_token",
@ -61,12 +59,16 @@ func (m *Methods) UpdateTokens(ctx context.Context) ([]model.Token, error) {
CreatedAt: time.Now().Unix(),
}
newTokens = append(newTokens, newToken)
err = m.repo.AmoRepo.WebhookUpdate(ctx, newToken)
if err != nil {
m.logger.Error("error update token in db", zap.Error(err))
return nil, err
}
}
err = m.repo.AmoRepo.WebhookUpdate(ctx, newTokens)
newTokens, err := m.repo.AmoRepo.GetAllTokens(ctx)
if err != nil {
m.logger.Error("error update newTokens in UpdateTokens", zap.Error(err))
m.logger.Error("error getting all new updated tokens from db in UpdateTokens", zap.Error(err))
return nil, err
}
@ -380,7 +382,7 @@ func (m *Methods) CheckUTMs(ctx context.Context, token, accountID string, ids []
}
if len(utms) < 0 {
return fields, err
return fields, nil
}
toCreated, toUpdate := tools.ToCreatedUpdate(utms, fields)