Initial SDK

proxy/client.go

@@ -0,0 +1,34 @@
+package proxy
+
+import (
+	"crypto/tls"
+	"fmt"
+	"net/http"
+	"net/url"
+)
+
+// Init for Proxy runtime model.
+func Init(
+	username string,
+	password string,
+) (*http.Client, error) {
+	// Prepare proxy url.
+	proxyUrl, err := url.Parse(
+		fmt.Sprintf(
+			"http://%s:%s@realtime.oxylabs.io:60000",
+			username,
+			password,
+		),
+	)
+	if err != nil {
+		return nil, fmt.Errorf("error parsing proxy url: %v", err)
+	}
+
+	// Prepare custom transport.
+	customTransport := &http.Transport{Proxy: http.ProxyURL(proxyUrl)}
+	customTransport.TLSClientConfig = &tls.Config{InsecureSkipVerify: true}
+
+	client := &http.Client{Transport: customTransport}
+
+	return client, nil
+}

proxy/proxy_helpers.go

@@ -0,0 +1,26 @@
+package proxy
+
+import (
+	"net/http"
+
+	"github.com/mslmio/oxylabs-sdk-go/oxylabs"
+)
+
+// Helper functions to add headers to request object.s
+
+func AddGeoLocationHeader(request *http.Request, geoLocation string) {
+	request.Header.Add("x-oxylabs-geo-location", geoLocation)
+}
+
+func AddUserAgentHeader(request *http.Request, userAgent oxylabs.UserAgent) {
+	request.Header.Add("x-oxylabs-user-agent-type", string(userAgent))
+}
+
+func AddRenderHeader(request *http.Request, render oxylabs.Render) {
+	request.Header.Add("x-oxylabs-render", string(render))
+}
+
+func AddParseHeader(request *http.Request, parser string) {
+	request.Header.Add("x-oxylabs-parse", "1")
+	request.Header.Add("x-oxylabs-parser", parser)
+}

serp/async_helpers.go

@@ -97,7 +97,8 @@ func (c *SerpClientAsync) GetResponse(
 }
 
 // PollJobStatus polls the job status and handles the response/error channels.
-func (c *SerpClientAsync) PollJobStatus(jobID string,
+func (c *SerpClientAsync) PollJobStatus(
+	jobID string,
 	parse bool,
 	responseChan chan *Response,
 	errChan chan error,

serp/client.go

@@ -1,10 +1,7 @@
 package serp
 
 import (
-	"crypto/tls"
-	"fmt"
 	"net/http"
-	"net/url"
 )
 
 type ApiCredentials struct {
@@ -53,46 +50,3 @@ func InitAsync(
 		BaseUrl:    "https://data.oxylabs.io/v1/queries",
 	}
 }
-
-type SerpClientProxy struct {
-	HttpClient     *http.Client
-	ApiCredentials *ApiCredentials
-}
-
-// Init for Proxy runtime model.
-func InitProxy(
-	username string,
-	password string,
-) *SerpClientProxy {
-	// Prepare API credentials.
-	apiCredentials := &ApiCredentials{
-		Username: username,
-		Password: password,
-	}
-
-	// Prepare proxy url.
-	proxyUrl, err := url.Parse(
-		fmt.Sprintf(
-			"http://%s:%s@realtime.oxylabs.io:60000",
-			apiCredentials.Username,
-			apiCredentials.Password,
-		),
-	)
-	if err != nil {
-		fmt.Printf("error parsing proxy url: %v", err)
-	}
-
-	// Prepare custom transport.
-	customTransport := &http.Transport{Proxy: http.ProxyURL(proxyUrl)}
-	customTransport.TLSClientConfig = &tls.Config{InsecureSkipVerify: true}
-
-	client := &http.Client{Transport: customTransport}
-
-	return &SerpClientProxy{
-		ApiCredentials: &ApiCredentials{
-			Username: username,
-			Password: password,
-		},
-		HttpClient: client,
-	}
-}