MM-15188: Migrate the "WebHook.PermanentDeleteOutgoingByUser" to Sync by default (#10709)

Этот коммит содержится в:
Puneeth Reddy
2019-04-26 22:45:02 -07:00
коммит произвёл Hanzei
родитель 7e590c7efe
Коммит 214e9d2ae0
5 изменённых файлов: 16 добавлений и 16 удалений

Просмотреть файл

@@ -288,13 +288,13 @@ func (s SqlWebhookStore) DeleteOutgoing(webhookId string, time int64) *model.App
return nil
}
func (s SqlWebhookStore) PermanentDeleteOutgoingByUser(userId string) store.StoreChannel {
return store.Do(func(result *store.StoreResult) {
_, err := s.GetMaster().Exec("DELETE FROM OutgoingWebhooks WHERE CreatorId = :UserId", map[string]interface{}{"UserId": userId})
if err != nil {
result.Err = model.NewAppError("SqlWebhookStore.DeleteOutgoingByUser", "store.sql_webhooks.permanent_delete_outgoing_by_user.app_error", nil, "id="+userId+", err="+err.Error(), http.StatusInternalServerError)
}
})
func (s SqlWebhookStore) PermanentDeleteOutgoingByUser(userId string) *model.AppError {
_, err := s.GetMaster().Exec("DELETE FROM OutgoingWebhooks WHERE CreatorId = :UserId", map[string]interface{}{"UserId": userId})
if err != nil {
return model.NewAppError("SqlWebhookStore.DeleteOutgoingByUser", "store.sql_webhooks.permanent_delete_outgoing_by_user.app_error", nil, "id="+userId+", err="+err.Error(), http.StatusInternalServerError)
}
return nil
}
func (s SqlWebhookStore) PermanentDeleteOutgoingByChannel(channelId string) *model.AppError {