web plugin, refactoring #15
Conversation
plugins/web/plugin.go
Outdated
| errorText := fmt.Sprintf("Invalid input data: %s", string(input)) | ||
| return errors.New(errorText) | ||
| } | ||
| p.storage.Mutex.Lock() |
There was a problem hiding this comment.
торчащий наружу мьютекс – плохая идея
plugins/web/plugin.go
Outdated
| } | ||
| for pos, element := range p.storage.Data[unsubscribeData.EventName] { | ||
| if element == unsubscribeData.Url { | ||
| p.storage.Data[unsubscribeData.EventName][pos] = p.storage.Data[unsubscribeData.EventName][len(p.storage.Data[unsubscribeData.EventName])-1] |
There was a problem hiding this comment.
не понял, что тут происходит
There was a problem hiding this comment.
громоздко удаляю подписчика
plugins/web/plugin.go
Outdated
| log.Error(err) | ||
| continue | ||
| } | ||
| req.Header.Set("Content-Type", "application/json") |
There was a problem hiding this comment.
мы уверены, что нам будут только json посылать?
There was a problem hiding this comment.
как минимум сейчас я бы говорил только про json
plugins/web/plugin.go
Outdated
|
|
||
| func (p PluginWeb) ProcessEvent(eventData event.Event) { | ||
| httpClient := &http.Client{} |
There was a problem hiding this comment.
надо таймаут указать, по дефолту он не выставляется и возникают проблемы
https://medium.com/@nate510/don-t-use-go-s-default-http-client-4804cb19f779#.uba9lfk7b
plugins/web/plugin.go
Outdated
| func (p PluginWeb) ProcessEvent(eventData event.Event) { | ||
| httpClient := &http.Client{} | ||
| for _, subscribeUrl := range p.storage.Data[eventData.Name] { | ||
| req, err := http.NewRequest("POST", subscribeUrl, bytes.NewBuffer(eventData.Payload)) |
There was a problem hiding this comment.
реквест можно создать вне цикла, а внутри только урл менять. ну и все содержимое цикла в горутину кинуть
dispatcher/dispatcher_test.go
Outdated
| subscrService.ProcessSubscribe(subscribeData) | ||
| client := &FakePostClient{t, requestUrl, requestData} | ||
| dsp := NewDispatcher(rmq, storageUnit, client) | ||
| subscribeData := []byte("{\"test\": \"hello\"}") |
There was a problem hiding this comment.
FYI, такое можно в бэктиках писать
[]byte(`{"test": "hello"}`)
plugins/web/plugin.go
Outdated
| log.Error(err) | ||
| continue | ||
| } | ||
| resp, err := p.client.Do(req) |
There was a problem hiding this comment.
в горутину не стал уводить?
plugins/web/plugin.go
Outdated
| continue | ||
| } | ||
| // TODO: add ability to log statistics | ||
| go p.client.Do(req) |
There was a problem hiding this comment.
Я тут кстати не обломаюсь с тем, что реквест может поменяться до того, как отправится? Может стоит каждый раз все же новый реквест создавать?
There was a problem hiding this comment.
может. чтоб не обломаться, можно сделать так:
go func(req http.Request, url string) {
req.URL, err = url.Parse(subscribeUrl)
if err != nil {
log.Error(err)
continue
}
// TODO: add ability to log statistics
go p.client.Do(req)
} (&req, subscribeUrl)
There was a problem hiding this comment.
ну или вынести это в отдельный метод
No description provided.