Ошибка при POST запросе?

Question

[arseniylebedev]

Через Talend Api делал запрос такой же отвечает 200 кодом.

Ошибка:

panic: Post "*URL*": read tcp 192.168.100.9:2270->131.44.251.57:443: wsarecv: A connection attempt failed because the connected party did not properly respond after a period of time, or es
tablished connection failed because connected host has failed to respond.

Код

package search

import (
	"bytes"
	"context"
	"encoding/json"
	"fmt"
	"gorm.io/gorm"
	"io"
	"loads_srv/loads_srv"
	"loads_srv/loads_srv/models"
	"loads_srv/loads_srv/postgres"
	"net/http"
)

const AtiLoadsSearchUrl = "*URL*"

type searchFilterJson struct {
	ExcludeGeoDicts bool `json:"exclude_geo_dicts"`
	Page            int  `json:"page"`
	ItemsPerPage    int  `json:"items_per_page"`
	Filter          struct {
		From struct {
			Id        string `json:"id"`
			Type      int    `json:"type"`
			ExactOnly bool   `json:"exact_only"`
		} `json:"from"`
		Dates struct {
			DateOption string `json:"date_option"`
		} `json:"dates"`
		WithDimensions bool `json:"with_dimensions"`
		ChangeDate     int  `json:"change_date"`
		SortingType    int  `json:"sorting_type"`
		WithAuction    bool `json:"with_auction"`
		Firm           struct {
			FirmRating int `json:"firm_rating"`
		} `json:"firm"`
	} `json:"filter"`
}

func createSearchFilterJson() searchFilterJson {
	var searchFilter = searchFilterJson{
		ExcludeGeoDicts: true,
		Page:            1,
		ItemsPerPage:    10,
	}
	searchFilter.Filter.WithAuction = false
	searchFilter.Filter.WithDimensions = false
	searchFilter.Filter.SortingType = 2
	searchFilter.Filter.ChangeDate = 1
	searchFilter.Filter.Dates.DateOption = "today-plus"
	searchFilter.Filter.Firm.FirmRating = 0
	searchFilter.Filter.From.ExactOnly = true
	searchFilter.Filter.From.Type = 1

	return searchFilter
}

func searchLoads(db *gorm.DB, regionId string) {
	var region models.LoadsSearchRegion
	err := db.Where(&models.LoadsSearchRegion{RegionId: regionId}).First(&region)
	if err.Error != nil {
		panic(err.Error)
	}
	var searchFilter = createSearchFilterJson()
	searchFilter.Filter.From.Id = regionId
	var searchFilterJsonBytes, _ = json.Marshal(searchFilter)

	req, _ := http.NewRequest("POST", AtiLoadsSearchUrl, bytes.NewBuffer(searchFilterJsonBytes))

	//req.Header.Add("Cookie", "uicult2=ru; _gcl_au=1.1.333980688.1702924027")
	//req.Header.Set("Content-Type", "application/json; charset=UTF-8")

	client := &http.Client{}
	resp, reqErr := client.Do(req) // <- Ошибка тут
	if reqErr != nil { // <- Ошибка тут
		panic(reqErr)
	}
	defer resp.Body.Close()

	fmt.Println("response Status:", resp.Status)
	fmt.Println("response Headers:", resp.Header)

	var body, _ = io.ReadAll(resp.Body)

	fmt.Print(string(body))

	//var headers = make(map[string][]string)
	//headers["Cookie"] = append(headers["Cookie"], "uicult2=ru; _gcl_au=1.1.333980688.1702924027")
	//headers["Content-Type"] = append(headers["Content-Type"], "application/json")

	//var pagesCounter = 1
	//var requestsCounter = 0

	//var reqCtx, cancel = context.WithTimeout(context.Background(), time.Second*5)
	//defer cancel()

}

func SearchingRoutine(workNowChan chan int, regionIdChan chan string, ctx context.Context, id int) {
	var app = loads_srv.GetApplication()
	db, err := postgres.Connect(app.Config)
	if err != nil {
		panic(err)
	}

Loop:
	for {
		select {
		case nowId := <-workNowChan:
			if id == nowId {
				var regionId = <-regionIdChan
				searchLoads(db, regionId)
			}
		case <-ctx.Done():
			break Loop
		}

	}

}

Comments

[Александр Павлюк]

Выглядит как то, что хост вообще не принимает запрос. Курлом запрос проходит успешно?

[arseniylebedev]

Александр Павлюк,

C:\Users\Downloads\curl-8.5.0_3-win64-mingw\bin>curl.exe -X POST -H Content-type=application/json *URL*
curl: (56) Recv failure: Connection was reset

[Александр Павлюк]

arseniylebedev, ну вот, курлом тоже не получается, значит проблема не в коде. Надо выяснить, какие запросы принимает сервер и принимает ли их вообще.

[d'Ivan]

Сервер перегружен?

[d'Ivan]

Александр Павлюк,

значит проблема не в коде.

по-моему, как раз таки, проблема и в коде, поскольку этот сценарий не обработан и поэтому паника.

[arseniylebedev]

Александр Павлюк, Из-за User-Agent и Accept-Encoding сервер обрывал соединение. Убираешь их и перестает работать

C:\Users\Downloads\curl-8.5.0_3-win64-mingw\bin>curl.exe -d '{"exclude_geo_dicts":true,"page":1,"items_per_page":10,"filter":{"from":{"id":"3","type":1,"exact_only":true},"dates":{"date_option":"today-plus"},"with_dimensions":false,"change_date":0,"sorting_type":2,"with_auction":false,"firm":{"firm_rating":0}}}' -H "Content-Type: application/json" -H "User-Agent: python/requests/2.31.0" -H "Accept-Encoding: gzip, deflate, br" -H "Connection: keep-alive" -X POST *URL*
<html>
<head><title>401 Authorization Required</title></head>
<body>
<center><h1>401 Authorization Required</h1></center>
<hr><center>nginx/1.22.1</center>
</body>
</html>

[Александр Павлюк]

arseniylebedev, осталось понять, какую авторизацию сервер принимает и все это можно будет перенести в код