Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use fprint method of har Package

Best K6 code snippet using har.fprint

converter.go

Source:converter.go

...30	"strings"31	"github.com/tidwall/pretty"32	"go.k6.io/k6/lib"33)34// fprint panics when where's an error writing to the supplied io.Writer35// since this will be used on in-memory expandable buffers, that should36// happen only when we run out of memory...37func fprint(w io.Writer, a ...interface{}) int {38	n, err := fmt.Fprint(w, a...)39	if err != nil {40		panic(err.Error())41	}42	return n43}44// fprintf panics when where's an error writing to the supplied io.Writer45// since this will be used on in-memory expandable buffers, that should46// happen only when we run out of memory...47func fprintf(w io.Writer, format string, a ...interface{}) int {48	n, err := fmt.Fprintf(w, format, a...)49	if err != nil {50		panic(err.Error())51	}52	return n53}54// TODO: refactor this to have fewer parameters... or just refactor in general...55func Convert(h HAR, options lib.Options, minSleep, maxSleep uint, enableChecks bool, returnOnFailedCheck bool, batchTime uint, nobatch bool, correlate bool, only, skip []string) (result string, convertErr error) {56	var b bytes.Buffer57	w := bufio.NewWriter(&b)58	if returnOnFailedCheck && !enableChecks {59		return "", fmt.Errorf("return on failed check requires --enable-status-code-checks")60	}61	if correlate && !nobatch {62		return "", fmt.Errorf("correlation requires --no-batch")63	}64	if h.Log == nil {65		return "", fmt.Errorf("invalid HAR file supplied, the 'log' property is missing")66	}67	if enableChecks {68		fprint(w, "import { group, check, sleep } from 'k6';\n")69	} else {70		fprint(w, "import { group, sleep } from 'k6';\n")71	}72	fprint(w, "import http from 'k6/http';\n\n")73	fprintf(w, "// Version: %v\n", h.Log.Version)74	fprintf(w, "// Creator: %v\n", h.Log.Creator.Name)75	if h.Log.Browser != nil {76		fprintf(w, "// Browser: %v\n", h.Log.Browser.Name)77	}78	if h.Log.Comment != "" {79		fprintf(w, "// %v\n", h.Log.Comment)80	}81	fprint(w, "\nexport let options = {\n")82	options.ForEachSpecified("json", func(key string, val interface{}) {83		if valJSON, err := json.MarshalIndent(val, "    ", "    "); err != nil {84			convertErr = err85		} else {86			fprintf(w, "    %s: %s,\n", key, valJSON)87		}88	})89	if convertErr != nil {90		return "", convertErr91	}92	fprint(w, "};\n\n")93	fprint(w, "export default function() {\n\n")94	pages := h.Log.Pages95	sort.Sort(PageByStarted(pages))96	// Hack to handle HAR files without a pages array97	// Temporary fix for https://github.com/k6io/k6/issues/79398	if len(pages) == 0 {99		pages = []Page{{100			ID:      "", // The Pageref property of all Entries will be an empty string101			Title:   "Global",102			Comment: "Placeholder page since there were no pages specified in the HAR file",103		}}104	}105	// Grouping by page and URL filtering106	pageEntries := make(map[string][]*Entry)107	for _, e := range h.Log.Entries {108		// URL filtering109		u, err := url.Parse(e.Request.URL)110		if err != nil {111			return "", err112		}113		if !IsAllowedURL(u.Host, only, skip) {114			continue115		}116		// Avoid multipart/form-data requests until k6 scripts can support binary data117		if e.Request.PostData != nil && strings.HasPrefix(e.Request.PostData.MimeType, "multipart/form-data") {118			continue119		}120		// Create new group o adding page to a existing one121		if _, ok := pageEntries[e.Pageref]; !ok {122			pageEntries[e.Pageref] = append([]*Entry{}, e)123		} else {124			pageEntries[e.Pageref] = append(pageEntries[e.Pageref], e)125		}126	}127	for i, page := range pages {128		entries := pageEntries[page.ID]129		scriptGroupName := page.ID + " - " + page.Title130		if page.ID == "" {131			// Temporary fix for https://github.com/k6io/k6/issues/793132			// I can't just remove the group() call since all of the subsequent code indentation is hardcoded...133			scriptGroupName = page.Title134		}135		fprintf(w, "\tgroup(%q, function() {\n", scriptGroupName)136		sort.Sort(EntryByStarted(entries))137		if nobatch {138			var recordedRedirectURL string139			previousResponse := map[string]interface{}{}140			fprint(w, "\t\tlet res, redirectUrl, json;\n")141			for entryIndex, e := range entries {142				var params []string143				var cookies []string144				var body string145				fprintf(w, "\t\t// Request #%d\n", entryIndex)146				if e.Request.PostData != nil {147					body = e.Request.PostData.Text148				}149				for _, c := range e.Request.Cookies {150					cookies = append(cookies, fmt.Sprintf(`%q: %q`, c.Name, c.Value))151				}152				if len(cookies) > 0 {153					params = append(params, fmt.Sprintf("\"cookies\": {\n\t\t\t\t%s\n\t\t\t}", strings.Join(cookies, ",\n\t\t\t\t\t")))154				}155				if headers := buildK6Headers(e.Request.Headers); len(headers) > 0 {156					params = append(params, fmt.Sprintf("\"headers\": {\n\t\t\t\t\t%s\n\t\t\t\t}", strings.Join(headers, ",\n\t\t\t\t\t")))157				}158				fprintf(w, "\t\tres = http.%s(", strings.ToLower(e.Request.Method))159				if correlate && recordedRedirectURL != "" {160					if recordedRedirectURL != e.Request.URL {161						return "", errors.New( //nolint:stylecheck162							"The har file contained a redirect but the next request did not match that redirect. " +163								"Possibly a misbehaving client or concurrent requests?",164						)165					}166					fprintf(w, "redirectUrl")167					recordedRedirectURL = ""168				} else {169					fprintf(w, "%q", e.Request.URL)170				}171				if e.Request.Method != "GET" {172					if correlate && e.Request.PostData != nil && strings.Contains(e.Request.PostData.MimeType, "json") {173						requestMap := map[string]interface{}{}174						escapedPostdata := strings.Replace(e.Request.PostData.Text, "$", "\\$", -1)175						if err := json.Unmarshal([]byte(escapedPostdata), &requestMap); err != nil {176							return "", err177						}178						if len(previousResponse) != 0 {179							traverseMaps(requestMap, previousResponse, nil)180						}181						requestText, err := json.Marshal(requestMap)182						if err == nil {183							prettyJSONString := string(pretty.PrettyOptions(requestText, &pretty.Options{Width: 999999, Prefix: "\t\t\t", Indent: "\t", SortKeys: true})[:])184							fprintf(w, ",\n\t\t\t`%s`", strings.TrimSpace(prettyJSONString))185						} else {186							return "", err187						}188					} else {189						fprintf(w, ",\n\t\t%q", body)190					}191				}192				if len(params) > 0 {193					fprintf(w, ",\n\t\t\t{\n\t\t\t\t%s\n\t\t\t}", strings.Join(params, ",\n\t\t\t"))194				}195				fprintf(w, "\n\t\t)\n")196				if e.Response != nil {197					// the response is nil if there is a failed request in the recording, or if responses were not recorded198					if enableChecks {199						if e.Response.Status > 0 {200							if returnOnFailedCheck {201								fprintf(w, "\t\tif (!check(res, {\"status is %v\": (r) => r.status === %v })) { return };\n", e.Response.Status, e.Response.Status)202							} else {203								fprintf(w, "\t\tcheck(res, {\"status is %v\": (r) => r.status === %v });\n", e.Response.Status, e.Response.Status)204							}205						}206					}207					if e.Response.Headers != nil {208						for _, header := range e.Response.Headers {209							if header.Name == "Location" {210								fprintf(w, "\t\tredirectUrl = res.headers.Location;\n")211								recordedRedirectURL = header.Value212								break213							}214						}215					}216					responseMimeType := e.Response.Content.MimeType217					if correlate &&218						strings.Index(responseMimeType, "application/") == 0 &&219						strings.Index(responseMimeType, "json") == len(responseMimeType)-4 {220						if err := json.Unmarshal([]byte(e.Response.Content.Text), &previousResponse); err != nil {221							return "", err222						}223						fprint(w, "\t\tjson = JSON.parse(res.body);\n")224					}225				}226			}227		} else {228			batches := SplitEntriesInBatches(entries, batchTime)229			fprint(w, "\t\tlet req, res;\n")230			for j, batchEntries := range batches {231				fprint(w, "\t\treq = [")232				for k, e := range batchEntries {233					r, err := buildK6RequestObject(e.Request)234					if err != nil {235						return "", err236					}237					fprintf(w, "%v", r)238					if k != len(batchEntries)-1 {239						fprint(w, ",")240					}241				}242				fprint(w, "];\n")243				fprint(w, "\t\tres = http.batch(req);\n")244				if enableChecks {245					for k, e := range batchEntries {246						if e.Response.Status > 0 {247							if returnOnFailedCheck {248								fprintf(w, "\t\tif (!check(res, {\"status is %v\": (r) => r.status === %v })) { return };\n", e.Response.Status, e.Response.Status)249							} else {250								fprintf(w, "\t\tcheck(res[%v], {\"status is %v\": (r) => r.status === %v });\n", k, e.Response.Status, e.Response.Status)251							}252						}253					}254				}255				if j != len(batches)-1 {256					lastBatchEntry := batchEntries[len(batchEntries)-1]257					firstBatchEntry := batches[j+1][0]258					t := firstBatchEntry.StartedDateTime.Sub(lastBatchEntry.StartedDateTime).Seconds()259					fprintf(w, "\t\tsleep(%.2f);\n", t)260				}261			}262			if i == len(pages)-1 {263				// Last page; add random sleep time at the group completion264				fprintf(w, "\t\t// Random sleep between %ds and %ds\n", minSleep, maxSleep)265				fprintf(w, "\t\tsleep(Math.floor(Math.random()*%d+%d));\n", maxSleep-minSleep, minSleep)266			} else {267				// Add sleep time at the end of the group268				nextPage := pages[i+1]269				sleepTime := 0.5270				if len(entries) > 0 {271					lastEntry := entries[len(entries)-1]272					t := nextPage.StartedDateTime.Sub(lastEntry.StartedDateTime).Seconds()273					if t >= 0.01 {274						sleepTime = t275					}276				}277				fprintf(w, "\t\tsleep(%.2f);\n", sleepTime)278			}279		}280		fprint(w, "\t});\n")281	}282	fprint(w, "\n}\n")283	if err := w.Flush(); err != nil {284		return "", err285	}286	return b.String(), nil287}288func buildK6RequestObject(req *Request) (string, error) {289	var b bytes.Buffer290	w := bufio.NewWriter(&b)291	fprint(w, "{\n")292	method := strings.ToLower(req.Method)293	if method == "delete" {294		method = "del"295	}296	fprintf(w, `"method": %q, "url": %q`, method, req.URL)297	if req.PostData != nil && method != "get" {298		postParams, plainText, err := buildK6Body(req)299		if err != nil {300			return "", err301		} else if len(postParams) > 0 {302			fprintf(w, `, "body": { %s }`, strings.Join(postParams, ", "))303		} else if plainText != "" {304			fprintf(w, `, "body": %q`, plainText)305		}306	}307	var params []string308	var cookies []string309	for _, c := range req.Cookies {310		cookies = append(cookies, fmt.Sprintf(`%q: %q`, c.Name, c.Value))311	}312	if len(cookies) > 0 {313		params = append(params, fmt.Sprintf(`"cookies": { %s }`, strings.Join(cookies, ", ")))314	}315	if headers := buildK6Headers(req.Headers); len(headers) > 0 {316		params = append(params, fmt.Sprintf(`"headers": { %s }`, strings.Join(headers, ", ")))317	}318	if len(params) > 0 {319		fprintf(w, `, "params": { %s }`, strings.Join(params, ", "))320	}321	fprint(w, "}")322	if err := w.Flush(); err != nil {323		return "", err324	}325	var buffer bytes.Buffer326	err := json.Indent(&buffer, b.Bytes(), "\t\t", "\t")327	if err != nil {328		return "", err329	}330	return buffer.String(), nil331}332func buildK6Headers(headers []Header) []string {333	var h []string334	if len(headers) > 0 {335		ignored := map[string]bool{"cookie": true, "content-length": true}...

fprint

Using AI Code Generation

1import (2func main() {3    http.HandleFunc("/", handler)4    log.Fatal(http.ListenAndServe("localhost:8000", nil))5}6func handler(w http.ResponseWriter, r *http.Request) {7    fmt.Fprintf(w, "URL.Path = %q8}9import (10func main() {11    http.HandleFunc("/", handler)12    log.Fatal(http.ListenAndServe("localhost:8000", nil))13}14func handler(w http.ResponseWriter, r *http.Request) {15    fmt.Fprintf(w, "URL.Path = %q16}17import (18func main() {19    http.HandleFunc("/", handler)20    log.Fatal(http.ListenAndServe("localhost:8000", nil))21}22func handler(w http.ResponseWriter, r *http.Request) {23    fmt.Fprintf(w, "URL.Path = %q24}25import (26func main() {27    http.HandleFunc("/", handler)28    log.Fatal(http.ListenAndServe("localhost:8000", nil))29}30func handler(w http.ResponseWriter, r *http.Request) {31    fmt.Fprintf(w, "URL.Path = %q32}33import (34func main() {35    http.HandleFunc("/", handler)36    log.Fatal(http.ListenAndServe("localhost:8000", nil))37}38func handler(w http.ResponseWriter, r *http.Request) {39    fmt.Fprintf(w, "URL.Path = %q40}41import (42func main() {43    http.HandleFunc("/", handler)44    log.Fatal(http.ListenAndServe("localhost:

fprint

Using AI Code Generation

1import "fmt"2func main() {3    fmt.Println("hello world")4}5import "fmt"6func main() {7    fmt.Println("hello world")8}9import "fmt"10func main() {11    fmt.Println("hello world")12}13import "fmt"14func main() {15    fmt.Println("hello world")16}17import "fmt"18func main() {19    fmt.Println("hello world")20}21import "fmt"22func main() {23    fmt.Println("hello world")24}25import "fmt"26func main() {27    fmt.Println("hello world")28}29import "fmt"30func main() {31    fmt.Println("hello world")32}33import "fmt"34func main() {35    fmt.Println("hello world")36}37import "fmt"38func main() {39    fmt.Println("hello world")40}41import "fmt"42func main() {43    fmt.Println("hello world")44}45import "fmt"46func main() {47    fmt.Println("hello world")48}49import "fmt"50func main() {51    fmt.Println("hello world")52}53import "fmt"54func main() {55    fmt.Println("hello world

fprint

Using AI Code Generation

1import (2func main() {3	f, err := os.Create("test.txt")4	if err != nil {5		fmt.Println(err)6	}7	defer f.Close()8	l, err := f.WriteString("Hello World")9	if err != nil {10		fmt.Println(err)11		f.Close()12	}13	fmt.Println(l, "bytes written successfully")14}15import (16func main() {17	f, err := os.OpenFile("test.txt", os.O_RDWR, 0644)18	if err != nil {19		fmt.Println(err)20	}21	defer f.Close()22	l, err := f.WriteString("Hello World")23	if err != nil {24		fmt.Println(err)25		f.Close()26	}27	fmt.Println(l, "bytes written successfully")28}29import (30func main() {31	f, err := os.OpenFile("test.txt", os.O_RDWR, 0644)32	if err != nil {33		fmt.Println(err)34	}35	defer f.Close()36	l, err := f.WriteString("Hello World")37	if err != nil {38		fmt.Println(err)39		f.Close()40	}41	fmt.Println(l, "bytes written successfully")42	err = f.Sync()43	if err != nil {44		fmt.Println(err)45		f.Close()46	}47}48import (49func main() {50	f, err := os.Create("test.txt")51	if err != nil {52		fmt.Println(err)53	}54	defer f.Close()55	l, err := f.WriteString("Hello

fprint

Using AI Code Generation

1import (2func main() {3	f, err := os.Create("test.txt")4	if err != nil {5		fmt.Println(err)6	}7	l, err := f.WriteString("Hello World")8	if err != nil {9		fmt.Println(err)10		f.Close()11	}12	fmt.Println(l, "bytes written successfully")13	err = f.Close()14	if err != nil {15		fmt.Println(err)16	}17}18import (19func main() {20	f, err := os.Open("test.txt")21	if err != nil {22		fmt.Println(err)23	}24	defer func() {25		if err = f.Close(); err != nil {26			fmt.Println(err)27		}28	}()29	b1 := make([]byte, 5)30	n1, err := f.Read(b1)31	if err != nil && err != io.EOF {32		fmt.Println(err)33	}34	fmt.Printf("%d bytes: %s35", n1, string(b1))36}37Read() method returns the number of bytes read and an error value. If an error occurs, the returned value

fprint

Using AI Code Generation

1import (2func main() {3	fmt.Fprint(os.Stdout, "hello world")4}5import (6func main() {7	fmt.Fprint(os.Stdout, "hello world", "hello world")8}9import (10func main() {11	fmt.Fprint(os.Stdout, "hello world", "hello world", "hello world")12}13import (14func main() {15	fmt.Fprint(os.Stdout, "hello world", "hello world", "hello world", "hello world")16}17import (18func main() {19	fmt.Fprint(os.Stdout, "hello world", "hello world", "hello world", "hello world", "hello world")20}21import (22func main() {23	fmt.Fprint(os.Stdout, "hello world", "hello world", "hello world", "hello world", "hello world", "hello world")24}25import (26func main() {27	fmt.Fprint(os.Stdout, "hello world", "hello world", "hello world", "hello world", "hello world", "hello world", "hello world")28}29import (30func main() {31	fmt.Fprint(os.Stdout, "hello world", "hello world", "hello world", "hello world", "hello world", "hello world", "hello world", "hello world")32}33import (34func main() {35	fmt.Fprint(os.Stdout, "hello world",

fprint

Using AI Code Generation

1import (2func main() {3	f, err := os.Create("test.txt")4	if err != nil {5		fmt.Println(err)6	}7	defer f.Close()8	l, err := f.WriteString("Hello World")9	if err != nil {10		fmt.Println(err)11		f.Close()12	}13	fmt.Println(l, "bytes written successfully")14}15WriteString() method16import (17func main() {18	f, err := os.Create("test.txt")19	if err != nil {20		fmt.Println(err)21	}22	defer f.Close()23	l, err := f.WriteString("Hello World")24	if err != nil {25		fmt.Println(err)26		f.Close()27	}28	fmt.Println(l, "bytes written successfully")29}30WriteByte() method31import (32func main() {33	f, err := os.Create("test.txt")34	if err != nil {35		fmt.Println(err)36	}37	defer f.Close()38	b := []byte{72, 101, 108, 108, 111, 32, 87, 111, 114, 108, 100}39	n, err := f.Write(b)40	if err != nil {41		fmt.Println(err)42		f.Close()43	}44	fmt.Println(n, "bytes written successfully")45}46WriteRune() method47import (48func main() {49	f, err := os.Create("test.txt")50	if err != nil {51		fmt.Println(err)52	}53	defer f.Close()54	n, err := f.WriteRune('H')55	if err != nil {

fprint

Using AI Code Generation

1import (2func main() {3	bytes, _ := ioutil.ReadAll(resp.Body)4	string_body := string(bytes)5	resp.Body.Close()6	fmt.Println(string_body)7}8import (9func main() {10	bytes, _ := ioutil.ReadAll(resp.Body)11	string_body := string(bytes)12	resp.Body.Close()13	fmt.Println(string_body)14}15import (16func main() {17	bytes, _ := ioutil.ReadAll(resp.Body)18	string_body := string(bytes)19	resp.Body.Close()20	fmt.Println(string_body)21}22import (23func main() {24	bytes, _ := ioutil.ReadAll(resp.Body)25	string_body := string(bytes)26	resp.Body.Close()27	fmt.Println(string_body)28}29import (30func main() {31	bytes, _ := ioutil.ReadAll(resp.Body)32	string_body := string(bytes)33	resp.Body.Close()34	fmt.Println(string_body)35}36import (37func main() {38	bytes, _ := ioutil.ReadAll(resp.Body)39	string_body := string(bytes)40	resp.Body.Close()41	fmt.Println(string_body)42}43import (44func main() {45	bytes, _ := ioutil.ReadAll(resp.Body)

fprint

Using AI Code Generation

1import (2func handler(w http.ResponseWriter, r *http.Request) {3	fmt.Fprintf(w, "Hi there, I love %s!", r.URL.Path[1:])4}5func main() {6	http.HandleFunc("/", handler)7	http.ListenAndServe(":8080", nil)8}9import (10func handler(w http.ResponseWriter, r *http.Request) {11	fmt.Print(w, "Hi there, I love %s!", r.URL.Path[1:])12}13func main() {14	http.HandleFunc("/", handler)15	http.ListenAndServe(":8080", nil)16}17import (18func handler(w http.ResponseWriter, r *http.Request) {19	io.WriteString(w, "Hi there, I love %s!", r.URL.Path[1:])20}21func main() {22	http.HandleFunc("/", handler)23	http.ListenAndServe(":8080", nil)24}25import (26func handler(w http.ResponseWriter, r *http.Request) {27	http.Error(w, "Hi there, I love %s!", r.URL.Path[1:])28}29func main() {30	http.HandleFunc("/", handler)31	http.ListenAndServe(":8080", nil)32}33import (

fprint

Using AI Code Generation

1import "fmt"2func main() {3    fmt.Printf("Hello World")4}5import "fmt"6func main() {7    fmt.Fprintf(os.Stdout, "Hello World")8}9import "fmt"10func main() {11    fmt.Fprintln(os.Stdout, "Hello World")12}13import "fmt"14func main() {15    fmt.Fprint(os.Stdout, "Hello World")16}17import "fmt"18func main() {19    fmt.Fprint(os.Stdout, "Hello World")20}21import "fmt"22func main() {23    fmt.Fprint(os.Stdout, "Hello World")24}25import "fmt"26func main() {27    fmt.Fprint(os.Stdout, "Hello World")28}29import "fmt"30func main() {31    fmt.Fprint(os.Stdout, "Hello World")32}33import "fmt"34func main() {35    fmt.Fprint(os.Stdout, "Hello World")36}37import "fmt"

fprint

Using AI Code Generation

1import (2func main() {3	fmt.Println("Hello, World!")4}5func Fprint(w io.Writer, a ...interface{}) (n int, err error)6import (7func main() {8	fmt.Fprint(os.Stdout, "Hello, World!9}10import (11func main() {12	fmt.Fprint(&b, "Hello, World!13	fmt.Println(b.String())14}

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.