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

Copied to Clipboard!

How to use New method of json Package

Best K6 code snippet using json.New

json_test.go

Source:json_test.go

...18	Convey("With a JSON array input reader", t, func() {19		var jsonFile, fileHandle *os.File20		Convey("an error should be thrown if a plain JSON document is supplied", func() {21			contents := `{"a": "ae"}`22			r := NewJSONInputReader(true, bytes.NewReader([]byte(contents)), 1)23			So(r.StreamDocument(true, make(chan bson.D, 1)), ShouldNotBeNil)24		})25		Convey("reading a JSON object that has no opening bracket should "+26			"error out", func() {27			contents := `{"a":3},{"b":4}]`28			r := NewJSONInputReader(true, bytes.NewReader([]byte(contents)), 1)29			So(r.StreamDocument(true, make(chan bson.D, 1)), ShouldNotBeNil)30		})31		Convey("JSON arrays that do not end with a closing bracket should "+32			"error out", func() {33			contents := `[{"a": "ae"}`34			r := NewJSONInputReader(true, bytes.NewReader([]byte(contents)), 1)35			docChan := make(chan bson.D, 1)36			So(r.StreamDocument(true, docChan), ShouldNotBeNil)37			// though first read should be fine38			So(<-docChan, ShouldResemble, bson.D{{"a", "ae"}})39		})40		Convey("an error should be thrown if a plain JSON file is supplied", func() {41			fileHandle, err := os.Open("testdata/test_plain.json")42			So(err, ShouldBeNil)43			r := NewJSONInputReader(true, fileHandle, 1)44			So(r.StreamDocument(true, make(chan bson.D, 50)), ShouldNotBeNil)45		})46		Convey("array JSON input file sources should be parsed correctly and "+47			"subsequent imports should parse correctly", func() {48			// TODO: currently parses JSON as floats and not ints49			expectedReadOne := bson.D{50				{"a", 1.2},51				{"b", "a"},52				{"c", 0.4},53			}54			expectedReadTwo := bson.D{55				{"a", 2.4},56				{"b", "string"},57				{"c", 52.9},58			}59			fileHandle, err := os.Open("testdata/test_array.json")60			So(err, ShouldBeNil)61			r := NewJSONInputReader(true, fileHandle, 1)62			docChan := make(chan bson.D, 50)63			So(r.StreamDocument(true, docChan), ShouldBeNil)64			So(<-docChan, ShouldResemble, expectedReadOne)65			So(<-docChan, ShouldResemble, expectedReadTwo)66		})67		Reset(func() {68			jsonFile.Close()69			fileHandle.Close()70		})71	})72}73func TestJSONPlainStreamDocument(t *testing.T) {74	testtype.SkipUnlessTestType(t, testtype.UnitTestType)75	Convey("With a plain JSON input reader", t, func() {76		var jsonFile, fileHandle *os.File77		Convey("string valued JSON documents should be imported properly", func() {78			contents := `{"a": "ae"}`79			expectedRead := bson.D{{"a", "ae"}}80			r := NewJSONInputReader(false, bytes.NewReader([]byte(contents)), 1)81			docChan := make(chan bson.D, 1)82			So(r.StreamDocument(true, docChan), ShouldBeNil)83			So(<-docChan, ShouldResemble, expectedRead)84		})85		Convey("several string valued JSON documents should be imported "+86			"properly", func() {87			contents := `{"a": "ae"}{"b": "dc"}`88			expectedReadOne := bson.D{{"a", "ae"}}89			expectedReadTwo := bson.D{{"b", "dc"}}90			r := NewJSONInputReader(false, bytes.NewReader([]byte(contents)), 1)91			docChan := make(chan bson.D, 2)92			So(r.StreamDocument(true, docChan), ShouldBeNil)93			So(<-docChan, ShouldResemble, expectedReadOne)94			So(<-docChan, ShouldResemble, expectedReadTwo)95		})96		Convey("number valued JSON documents should be imported properly", func() {97			contents := `{"a": "ae", "b": 2.0}`98			expectedRead := bson.D{{"a", "ae"}, {"b", 2.0}}99			r := NewJSONInputReader(false, bytes.NewReader([]byte(contents)), 1)100			docChan := make(chan bson.D, 1)101			So(r.StreamDocument(true, docChan), ShouldBeNil)102			So(<-docChan, ShouldResemble, expectedRead)103		})104		Convey("JSON arrays should return an error", func() {105			contents := `[{"a": "ae", "b": 2.0}]`106			r := NewJSONInputReader(false, bytes.NewReader([]byte(contents)), 1)107			So(r.StreamDocument(true, make(chan bson.D, 50)), ShouldNotBeNil)108		})109		Convey("plain JSON input file sources should be parsed correctly and "+110			"subsequent imports should parse correctly", func() {111			expectedReads := []bson.D{112				{113					{"a", 4},114					{"b", "string value"},115					{"c", 1},116				}, {117					{"a", 5},118					{"b", "string value"},119					{"c", 2},120				}, {121					{"a", 6},122					{"b", "string value"},123					{"c", 3},124				},125			}126			fileHandle, err := os.Open("testdata/test_plain.json")127			So(err, ShouldBeNil)128			r := NewJSONInputReader(false, fileHandle, 1)129			docChan := make(chan bson.D, len(expectedReads))130			So(r.StreamDocument(true, docChan), ShouldBeNil)131			for i := 0; i < len(expectedReads); i++ {132				for j, readDocument := range <-docChan {133					So(readDocument.Name, ShouldEqual, expectedReads[i][j].Name)134					So(readDocument.Value, ShouldEqual, expectedReads[i][j].Value)135				}136			}137		})138		Convey("reading JSON that starts with a UTF-8 BOM should not error",139			func() {140				expectedReads := []bson.D{141					{142						{"a", 1},143						{"b", 2},144						{"c", 3},145					}, {146						{"a", 4},147						{"b", 5},148						{"c", 6},149					},150				}151				fileHandle, err := os.Open("testdata/test_bom.json")152				So(err, ShouldBeNil)153				r := NewJSONInputReader(false, fileHandle, 1)154				docChan := make(chan bson.D, 2)155				So(r.StreamDocument(true, docChan), ShouldBeNil)156				for _, expectedRead := range expectedReads {157					for i, readDocument := range <-docChan {158						So(readDocument.Name, ShouldEqual, expectedRead[i].Name)159						So(readDocument.Value, ShouldEqual, expectedRead[i].Value)160					}161				}162			})163		Reset(func() {164			jsonFile.Close()165			fileHandle.Close()166		})167	})168}169func TestReadJSONArraySeparator(t *testing.T) {170	testtype.SkipUnlessTestType(t, testtype.UnitTestType)171	Convey("With an array JSON input reader", t, func() {172		Convey("reading a JSON array separator should consume [",173			func() {174				contents := `[{"a": "ae"}`175				jsonImporter := NewJSONInputReader(true, bytes.NewReader([]byte(contents)), 1)176				So(jsonImporter.readJSONArraySeparator(), ShouldBeNil)177				// at this point it should have consumed all bytes up to `{`178				So(jsonImporter.readJSONArraySeparator(), ShouldNotBeNil)179			})180		Convey("reading a closing JSON array separator without a "+181			"corresponding opening bracket should error out ",182			func() {183				contents := `]`184				jsonImporter := NewJSONInputReader(true, bytes.NewReader([]byte(contents)), 1)185				So(jsonImporter.readJSONArraySeparator(), ShouldNotBeNil)186			})187		Convey("reading an opening JSON array separator without a "+188			"corresponding closing bracket should error out ",189			func() {190				contents := `[`191				jsonImporter := NewJSONInputReader(true, bytes.NewReader([]byte(contents)), 1)192				So(jsonImporter.readJSONArraySeparator(), ShouldBeNil)193				So(jsonImporter.readJSONArraySeparator(), ShouldNotBeNil)194			})195		Convey("reading an opening JSON array separator with an ending "+196			"closing bracket should return EOF",197			func() {198				contents := `[]`199				jsonImporter := NewJSONInputReader(true, bytes.NewReader([]byte(contents)), 1)200				So(jsonImporter.readJSONArraySeparator(), ShouldBeNil)201				So(jsonImporter.readJSONArraySeparator(), ShouldEqual, io.EOF)202			})203		Convey("reading an opening JSON array separator, an ending closing "+204			"bracket but then additional characters after that, should error",205			func() {206				contents := `[]a`207				jsonImporter := NewJSONInputReader(true, bytes.NewReader([]byte(contents)), 1)208				So(jsonImporter.readJSONArraySeparator(), ShouldBeNil)209				So(jsonImporter.readJSONArraySeparator(), ShouldNotBeNil)210			})211		Convey("reading invalid JSON objects between valid objects should "+212			"error out",213			func() {214				contents := `[{"a":3}x{"b":4}]`215				r := NewJSONInputReader(true, bytes.NewReader([]byte(contents)), 1)216				docChan := make(chan bson.D, 1)217				So(r.StreamDocument(true, docChan), ShouldNotBeNil)218				// read first valid document219				<-docChan220				So(r.readJSONArraySeparator(), ShouldNotBeNil)221			})222		Convey("reading invalid JSON objects after valid objects but between "+223			"valid objects should error out",224			func() {225				contents := `[{"a":3},b{"b":4}]`226				r := NewJSONInputReader(true, bytes.NewReader([]byte(contents)), 1)227				So(r.StreamDocument(true, make(chan bson.D, 1)), ShouldNotBeNil)228				contents = `[{"a":3},,{"b":4}]`229				r = NewJSONInputReader(true, bytes.NewReader([]byte(contents)), 1)230				So(r.StreamDocument(true, make(chan bson.D, 1)), ShouldNotBeNil)231			})232	})233}234func TestJSONConvert(t *testing.T) {235	testtype.SkipUnlessTestType(t, testtype.UnitTestType)236	Convey("With a JSON input reader", t, func() {237		Convey("calling convert on a JSONConverter should return the expected BSON document", func() {238			jsonConverter := JSONConverter{239				data:  []byte(`{field1:"a",field2:"b",field3:"c"}`),240				index: uint64(0),241			}242			expectedDocument := bson.D{243				{"field1", "a"},...

user_test.go

Source:user_test.go

...28	payloadJSON, err := json.Marshal(payload)29	if err != nil {30		t.Error(err)31	}32	req, _ := http.NewRequest(http.MethodPost, "/sessions", bytes.NewBuffer(payloadJSON))33	writer := httptest.NewRecorder()34	service.App.Router.ServeHTTP(writer, req)35	session := new(entity.Session)36	err = json.Unmarshal(writer.Body.Bytes(), session)37	if err != nil {38		t.Error(err)39	}40	defer service.App.Delete(util.SessionBucket, []byte(session.Token))41	v, err := service.App.CacheGet(util.AdminKey)42	if err != nil {43		t.Error(err)44	}45	payload = map[string]interface{}{46		"email":     "test@einheit.co",47		"role":      util.Management,48		"invitedBy": string(v),49	}50	payloadJSON, err = json.Marshal(payload)51	if err != nil {52		t.Error(err)53	}54	// Create invite.55	req, _ = http.NewRequest(http.MethodPost, "/invites", bytes.NewBuffer(payloadJSON))56	req.Header.Set("Authorization", fmt.Sprintf("Token %s", session.Token))57	writer = httptest.NewRecorder()58	service.App.Router.ServeHTTP(writer, req)59	invite := new(entity.Invite)60	err = json.Unmarshal(writer.Body.Bytes(), invite)61	if err != nil {62		t.Error(err)63	}64	defer service.App.Delete(util.InviteBucket, []byte(invite.Uuid))65	payload = map[string]interface{}{66		"invite":    invite.Uuid,67		"firstName": "test",68		"lastName":  "user",69		"password":  "boltkit",70		"email":     "test@einheit.co",71		"role":      util.Management,72	}73	payloadJSON, err = json.Marshal(payload)74	if err != nil {75		t.Error(err)76	}77	// Create user.78	req, _ = http.NewRequest(http.MethodPost, "/users", bytes.NewBuffer(payloadJSON))79	writer = httptest.NewRecorder()80	service.App.Router.ServeHTTP(writer, req)81	user := new(entity.User)82	err = json.Unmarshal(writer.Body.Bytes(), user)83	if err != nil {84		t.Error(err)85	}86	defer service.App.Delete(util.UserBucket, []byte(user.Uuid))87	fmt.Println("create user response: ", writer.Body.String())88	if writer.Code != http.StatusCreated {89		t.Fatalf("expected %d got %d", http.StatusOK, writer.Code)90	}91	// Get user.92	getUser := fmt.Sprint("/users/", user.Uuid)93	req, _ = http.NewRequest(http.MethodGet, getUser, nil)94	req.Header.Set("Authorization", fmt.Sprintf("Token %s", session.Token))95	writer = httptest.NewRecorder()96	service.App.Router.ServeHTTP(writer, req)97	fmt.Println("get user response: ", writer.Body.String())98	if writer.Code != http.StatusOK {99		t.Fatalf("expected %d got %d", http.StatusOK, writer.Code)100	}101	// Update user.102	user.FirstName = "cog"103	userJSON, err := json.Marshal(user)104	if err != nil {105		t.Error(err)106	}107	updateUser := fmt.Sprint("/users/", user.Uuid)108	req, _ = http.NewRequest(http.MethodPut, updateUser, bytes.NewBuffer(userJSON))109	req.Header.Set("Authorization", fmt.Sprintf("Token %s", session.Token))110	writer = httptest.NewRecorder()111	service.App.Router.ServeHTTP(writer, req)112	fmt.Println("update user response: ", writer.Body.String())113	if writer.Code != http.StatusOK {114		t.Fatalf("expected %d got %d", http.StatusOK, writer.Code)115	}116	// Create password reset.117	payload = map[string]interface{}{118		"user":  user.Uuid,119		"email": user.Email,120	}121	payloadJSON, err = json.Marshal(payload)122	if err != nil {123		t.Error(err)124	}125	req, _ = http.NewRequest(http.MethodPost, "/resets", bytes.NewBuffer(payloadJSON))126	writer = httptest.NewRecorder()127	service.App.Router.ServeHTTP(writer, req)128	reset := new(entity.PassReset)129	err = json.Unmarshal(writer.Body.Bytes(), reset)130	if err != nil {131		t.Error(err)132	}133	defer service.App.Delete(util.PassResetBucket, []byte(reset.Uuid))134	// Reset user password.135	payload = map[string]interface{}{136		"password": "test",137		"resetId":  reset.Uuid,138	}139	payloadJSON, err = json.Marshal(payload)140	if err != nil {141		t.Error(err)142	}143	resetPassword := fmt.Sprint("/users/", user.Uuid, "/resetpassword")144	req, _ = http.NewRequest(http.MethodPut, resetPassword, bytes.NewBuffer(payloadJSON))145	req.Header.Set("Authorization", fmt.Sprintf("Token %s", session.Token))146	writer = httptest.NewRecorder()147	service.App.Router.ServeHTTP(writer, req)148	fmt.Println("reset user password response: ", writer.Body.String())149	if writer.Code != http.StatusOK {150		t.Fatalf("expected %d got %d", http.StatusOK, writer.Code)151	}152	// Update user role.153	payload = map[string]interface{}{154		"role": util.Management,155	}156	payloadJSON, err = json.Marshal(payload)157	if err != nil {158		t.Error(err)159	}160	updateRole := fmt.Sprint("/users/", user.Uuid, "/role")161	req, _ = http.NewRequest(http.MethodPut, updateRole, bytes.NewBuffer(payloadJSON))162	req.Header.Set("Authorization", fmt.Sprintf("Token %s", session.Token))163	writer = httptest.NewRecorder()164	service.App.Router.ServeHTTP(writer, req)165	fmt.Println("update user role response: ", writer.Body.String())166	if writer.Code != http.StatusOK {167		t.Fatalf("expected %d got %d", http.StatusOK, writer.Code)168	}169	// Delete user.170	user.Deleted = true171	userJSON, err = json.Marshal(user)172	if err != nil {173		t.Error(err)174	}175	deleteUser := fmt.Sprint("/users/", user.Uuid)176	req, _ = http.NewRequest(http.MethodDelete, deleteUser, bytes.NewBuffer(userJSON))177	req.Header.Set("Authorization", fmt.Sprintf("Token %s", session.Token))178	writer = httptest.NewRecorder()179	service.App.Router.ServeHTTP(writer, req)180	if writer.Code != http.StatusNoContent {181		t.Fatalf("expected %d got %d", http.StatusOK, writer.Code)182	}183	// List users.184	payload = map[string]interface{}{185		"offset": 0,186		"term":   util.Management,187	}188	payloadJSON, err = json.Marshal(payload)189	if err != nil {190		t.Error(err)191	}192	req, _ = http.NewRequest(http.MethodPost, "/users/list", bytes.NewBuffer(payloadJSON))193	req.Header.Set("Authorization", fmt.Sprintf("Token %s", session.Token))194	writer = httptest.NewRecorder()195	service.App.Router.ServeHTTP(writer, req)196	fmt.Println("list users response size: ", writer.Body.Len())197	if writer.Code != http.StatusOK {198		t.Fatalf("expected %d got %d", http.StatusOK, writer.Code)199	}200}...

new_test.go

Source:new_test.go

...9	"github.com/mongodb/mongo-tools/common/testtype"10	. "github.com/smartystreets/goconvey/convey"11	"testing"12)13func TestNewKeyword(t *testing.T) {14	testtype.SkipUnlessTestType(t, testtype.UnitTestType)15	Convey("When unmarshalling JSON using the new keyword", t, func() {16		Convey("can be used with BinData constructor", func() {17			var jsonMap map[string]interface{}18			key := "key"19			value := `new BinData(1, "xyz")`20			data := fmt.Sprintf(`{"%v":%v}`, key, value)21			err := Unmarshal([]byte(data), &jsonMap)22			So(err, ShouldBeNil)23			jsonValue, ok := jsonMap[key].(BinData)24			So(ok, ShouldBeTrue)25			So(jsonValue, ShouldResemble, BinData{1, "xyz"})26		})27		Convey("can be used with Boolean constructor", func() {...

New

Using AI Code Generation

1func main() {2    var jsonBlob = []byte(`[3        {"Name": "Platypus", "Order": "Monotremata"},4        {"Name": "Quoll",    "Order": "Dasyuromorphia"}5    type Animal struct {6    }7    err := json.Unmarshal(jsonBlob, &animals)8    if err != nil {9        fmt.Println("error:", err)10    }11    fmt.Printf("%+v12}13[{Name:Platypus Order:Monotremata} {Name:Quoll Order:Dasyuromorphia}]14func main() {15    var jsonBlob = []byte(`[16        {"Name": "Platypus", "Order": "Monotremata"},17        {"Name": "Quoll",    "Order": "Dasyuromorphia"}18    type Animal struct {19    }20    err := json.Unmarshal(jsonBlob, &animals)21    if err != nil {22        fmt.Println("error:", err)23    }24    fmt.Printf("%+v25}26[{Name:Platypus Order:Monotremata} {Name:Quoll Order:Dasyuromorphia}]27func main() {28    type Animal struct {29    }30    animals := []Animal{31        {"Platypus", "Monotremata"},32        {"Quoll", "Dasyuromorphia"},33    }34    jsonBlob, err := json.Marshal(animals)35    if err != nil {36        fmt.Println("error:", err)37    }38    fmt.Printf("%s39}40[{"Name":"Platypus","Order":"Monotremata"},{"Name":"Quoll","Order":"

New

Using AI Code Generation

1import (2type Person struct {3}4func main() {5	p1 := Person{"James", "Bond", 20}6	bs, _ := json.Marshal(p1)7	fmt.Println(bs)8	fmt.Printf("%T9	fmt.Println(string(bs))10}11{"First":"James","Last":"Bond","Age":20}12import (13type Person struct {14}15func main() {16	p1 := Person{"James", "Bond", 20}17	bs, err := json.Marshal(p1)18	if err != nil {19		fmt.Println(err)20	}21	fmt.Println(bs)22	fmt.Printf("%T23	fmt.Println(string(bs))24}25{"First":"James","Last":"Bond","Age":20}

New

Using AI Code Generation

1import (2type Person struct {3}4func main() {5	jsonData, _ := json.Marshal(p1)6	fmt.Println(string(jsonData))7}8{"firstname":"John","lastname":"Doe","age":25}

New

Using AI Code Generation

1import (2type Person struct {3}4func main() {5	p1 := Person{"Alice", 20}6	p2 := Person{"Bob", 30}7	people := []Person{p1, p2}8	encoder := json.NewEncoder(os.Stdout)9	encoder.Encode(people)10}11[{"Name":"Alice","Age":20},{"Name":"Bob","Age":30}]12import (13type Person struct {14}15func main() {16	p1 := Person{"Alice", 20}17	p2 := Person{"Bob", 30}18	people := []Person{p1, p2}19	peopleJson, _ := json.Marshal(people)20	fmt.Println(string(peopleJson))21}22[{"Name":"Alice","Age":20},{"Name":"Bob","Age":30}]23import (24type Person struct {25}26func main() {27	p1 := Person{"Alice", 20}28	p2 := Person{"Bob", 30}29	people := []Person{p1, p2}30	peopleJson, _ := json.MarshalIndent(people, "", " ")31	fmt.Println(string(peopleJson))32}33 {34 },35 {36 }37import (38type Person struct {39}40func main() {41	p1 := Person{"Alice", 20}42	p2 := Person{"Bob", 30}43	people := []Person{p1, p2}44	encoder := json.NewEncoder(os.Stdout)45	encoder.SetIndent("", " ")46	encoder.Encode(people)47}48 {49 },50 {

New

Using AI Code Generation

1import (2type Person struct {3}4func main() {5p := &Person{"John", 29}6b, err := json.Marshal(p)7if err != nil {8fmt.Println("error:", err)9}10fmt.Println(string(b))11}12Output: {"Name":"John","Age":29}13import (14type Person struct {15}16func main() {17p := &Person{"John", 29}18b, err := json.Marshal(p)19if err != nil {20fmt.Println("error:", err)21}22fmt.Println(string(b))23}24Output: {"Name":"John","Age":29}25import (26type Person struct {27}28func main() {29p := &Person{"John", 29}30b, err := json.Marshal(p)31if err != nil {32fmt.Println("error:", err)33}34fmt.Println(string(b))35}36Output: {"Name":"John","Age":29}37import (38type Person struct {39}40func main() {41p := &Person{"John", 29}42b, err := json.Marshal(p)43if err != nil {44fmt.Println("error:", err)45}46fmt.Println(string(b))47}48Output: {"Name":"John","Age":29}49import (50type Person struct {51}52func main() {53p := &Person{"John", 29}54b, err := json.Marshal(p)55if err != nil {56fmt.Println("error:", err)57}58fmt.Println(string(b))59}60Output: {"Name":"John","Age":29}61import (62type Person struct {63}64func main() {65p := &Person{"John", 29}66b, err := json.Marshal(p

New

Using AI Code Generation

1import (2type Person struct {3}4func main() {5	jsonString := []byte(`{"Name":"Ravi","Age":25}`)6	err := json.Unmarshal(jsonString, &p)7	if err != nil {8		fmt.Println(err)9	}10	fmt.Println(p.Name)11	fmt.Println(p.Age)12}13import (14func main() {15	jsonString := []byte(`{"Name":"Ravi","Age":25}`)16	var p map[string]interface{}17	err := json.Unmarshal(jsonString, &p)18	if err != nil {19		fmt.Println(err)20	}21	fmt.Println(p["Name"])22	fmt.Println(p["Age"])23}24import (25type Person struct {26}27func main() {28	p := Person{Name: "Ravi", Age: 25}29	jsonString, err := json.Marshal(p)30	if err != nil {31		fmt.Println(err)32	}33	fmt.Println(string(jsonString))34}35{"Name":"Ravi","Age":25}

New

Using AI Code Generation

1import (2func main() {3	json1 := json.New()4	json2 := json.New(`{"name":"dinesh","age":30}`)5	json3 := json.New([]byte(`{"name":"dinesh","age":30}`))6	json4 := json.New("/home/dinesh/go/src/pack1/json1.json")7	fmt.Println(json1)8	fmt.Println(json2)9	fmt.Println(json3)10	fmt.Println(json4)11}12{}13{"name":"dinesh","age":30}14{"name":"dinesh","age":30}15{"name

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.