Skip to content
This repository was archived by the owner on Mar 28, 2023. It is now read-only.

Commit f349910

Browse files
authored
Merge pull request #1901 from OpenBazaar/brian.masterTransports
Fix transports for message retriever and images
2 parents b1fb778 + b871985 commit f349910

File tree

2 files changed

+11
-5
lines changed

2 files changed

+11
-5
lines changed

core/images.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -165,11 +165,15 @@ func (n *OpenBazaarNode) FetchImage(peerID string, imageType string, size string
165165
// GetBase64Image - fetch the image and return it as base64 encoded string
166166
func (n *OpenBazaarNode) GetBase64Image(url string) (base64ImageData, filename string, err error) {
167167
dial := net.Dial
168+
var client *http.Client
168169
if n.TorDialer != nil {
169170
dial = n.TorDialer.Dial
171+
tbTransport := &http.Transport{Dial: dial}
172+
client = &http.Client{Transport: tbTransport, Timeout: time.Second * 30}
173+
} else {
174+
client = &http.Client{Timeout: time.Second * 30}
170175
}
171-
tbTransport := &http.Transport{Dial: dial}
172-
client := &http.Client{Transport: tbTransport, Timeout: time.Second * 30}
176+
173177
resp, err := client.Get(url)
174178
if err != nil {
175179
return "", "", err

net/retriever/retriever.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -69,12 +69,14 @@ type offlineMessage struct {
6969

7070
func NewMessageRetriever(cfg MRConfig) *MessageRetriever {
7171
dial := gonet.Dial
72+
var client *http.Client
7273
if cfg.Dialer != nil {
7374
dial = cfg.Dialer.Dial
75+
tbTransport := &http.Transport{Dial: dial}
76+
client = &http.Client{Transport: tbTransport, Timeout: time.Second * 30}
77+
} else {
78+
client = &http.Client{Timeout: time.Second * 30}
7479
}
75-
76-
tbTransport := &http.Transport{Dial: dial}
77-
client := &http.Client{Transport: tbTransport, Timeout: time.Second * 30}
7880
mr := MessageRetriever{
7981
db: cfg.Db,
8082
node: cfg.IPFSNode,

0 commit comments

Comments
 (0)