updated

vortex14 · Feb 28, 2023 · 6a101ae · 6a101ae
1 parent bd523aa
commit 6a101ae
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/extensions/pipelines/http/emulator/rod/request.go b/extensions/pipelines/http/emulator/rod/request.go
@@ -4,6 +4,7 @@ import (
 	"bytes"
 	"context"
 	"fmt"
+	"github.com/vortex14/gotyphoon/log"
 	"os"
 	"time"
 
@@ -78,6 +79,11 @@ func CreateRodRequestPipeline(
 			detailOptions.Options.Timeout = task.GetFetcherTimeout()
 			detailOptions.Options.Proxy = task.GetProxyAddress()
 
+			if len(task.GetProxyAddress()) > 0 {
+				context = log.PatchCtx(context, map[string]interface{}{"proxy": task.GetProxyAddress()})
+				_, logger = log.Get(context)
+			}
+
 			browser := CreateBaseBrowser(detailOptions.Options)
 
 			var pErr error

diff --git a/extensions/pipelines/http/emulator/rod/test_test.go b/extensions/pipelines/http/emulator/rod/test_test.go
@@ -62,9 +62,9 @@ func TestCreateRodPipeline(t *testing.T) {
 
 	Convey("create a new pipeline", t, func() {
 		_task := fake.CreateDefaultTask()
-		_task.SetProxyAddress("http://localhost:8888")
+		//_task.SetProxyAddress("http://localhost:8888")
 		//_task.SetProxyAddress("http://ukehiuwv-982:[email protected]")
-		//_task.SetProxyServerUrl("http://proxy-manager.typhoon-s1.ru")
+		_task.SetProxyServerUrl("http://proxy-manager.typhoon-s1.ru")
 		p := CreateRodRequestPipeline(
 			forms.GetNotRetribleOptions(),
 			&DetailsOptions{