How to use incomingEmail method of main Package

Best Syzkaller code snippet using main.incomingEmail

email_test.go

Source:email_test.go

...88`, sender0)89	c.expectOK(c.POST("/_ah/mail/", incoming1))90	// Emulate that somebody sends us our own email back without quoting.91	// We used to extract "#syz fix: exact-commit-title" from it.92	c.incomingEmail(sender0, body0)93	c.incomingEmail(sender0, "I don't want emails", EmailOptFrom(`"idont" <idont@WANT.emails>`))94	c.expectNoEmail()95	// This person sends an email and is listed as a maintainer, but opt-out of emails.96	// We should not send anything else to them for this bug. Also don't warn about no mailing list in CC.97	c.incomingEmail(sender0, "#syz uncc", EmailOptFrom(`"IDONT" <Idont@want.emails>`), EmailOptCC(nil))98	c.expectNoEmail()99	// Now report syz reproducer and check updated email.100	build2 := testBuild(10)101	build2.Arch = "386"102	build2.KernelRepo = testConfig.Namespaces["test2"].Repos[0].URL103	build2.KernelBranch = testConfig.Namespaces["test2"].Repos[0].Branch104	build2.KernelCommitTitle = "a really long title, longer than 80 chars, really long-long-long-long-long-long title"105	c.client2.UploadBuild(build2)106	crash.BuildID = build2.ID107	crash.ReproOpts = []byte("repro opts")108	crash.ReproSyz = []byte("getpid()")109	syzRepro := []byte(fmt.Sprintf("# https://testapp.appspot.com/bug?id=%v\n%s#%s\n%s",110		dbBug0.keyHash(), syzReproPrefix, crash.ReproOpts, crash.ReproSyz))111	c.client2.ReportCrash(crash)112	{113		msg := c.pollEmailBug()114		c.expectEQ(msg.Sender, sender0)115		sender, _, err := email.RemoveAddrContext(msg.Sender)116		c.expectOK(err)117		_, dbCrash, dbBuild := c.loadBug(extBugID0)118		reproSyzLink := externalLink(c.ctx, textReproSyz, dbCrash.ReproSyz)119		crashLogLink := externalLink(c.ctx, textCrashLog, dbCrash.Log)120		kernelConfigLink := externalLink(c.ctx, textKernelConfig, dbBuild.KernelConfig)121		c.expectEQ(sender, fromAddr(c.ctx))122		to := []string{123			"always@cc.me",124			"bugs2@syzkaller.com",125			"bugs@syzkaller.com", // This is from incomingEmail.126			"default@sender.com", // This is from incomingEmail.127			"foo@bar.com",128			config.Namespaces["test2"].Reporting[0].Config.(*EmailConfig).Email,129		}130		c.expectEQ(msg.To, to)131		c.expectEQ(msg.Subject, "Re: "+crash.Title)132		c.expectEQ(len(msg.Attachments), 0)133		c.expectEQ(msg.Headers["In-Reply-To"], []string{"<1234>"})134		c.expectEQ(msg.Body, fmt.Sprintf(`syzbot has found a reproducer for the following crash on:135HEAD commit:    10101010 a really long title, longer than 80 chars, really..136git tree:       repo10alias137console output: %[3]v138kernel config:  %[4]v139dashboard link: https://testapp.appspot.com/bug?extid=%[1]v140compiler:       compiler10141userspace arch: i386142syz repro:      %[2]v143CC:             [bar@foo.com foo@bar.com maintainers@repo10.org bugs@repo10.org]144IMPORTANT: if you fix the bug, please add the following tag to the commit:145Reported-by: syzbot+%[1]v@testapp.appspotmail.com146report1147`, extBugID0, reproSyzLink, crashLogLink, kernelConfigLink))148		c.checkURLContents(reproSyzLink, syzRepro)149		c.checkURLContents(crashLogLink, crash.Log)150		c.checkURLContents(kernelConfigLink, build2.KernelConfig)151	}152	// Now upstream the bug and check that it reaches the next reporting.153	c.incomingEmail(sender0, "#syz upstream")154	sender1, extBugID1 := "", ""155	{156		msg := c.pollEmailBug()157		sender1 = msg.Sender158		c.expectNE(sender1, sender0)159		sender, extBugID, err := email.RemoveAddrContext(msg.Sender)160		c.expectOK(err)161		extBugID1 = extBugID162		_, dbCrash, dbBuild := c.loadBug(extBugID1)163		reproSyzLink := externalLink(c.ctx, textReproSyz, dbCrash.ReproSyz)164		crashLogLink := externalLink(c.ctx, textCrashLog, dbCrash.Log)165		kernelConfigLink := externalLink(c.ctx, textKernelConfig, dbBuild.KernelConfig)166		c.expectEQ(sender, fromAddr(c.ctx))167		c.expectEQ(msg.To, []string{168			"always@cc.me",169			"bar@foo.com",170			"bugs@repo10.org",171			"bugs@syzkaller.com",172			"default@maintainers.com",173			"foo@bar.com",174			"maintainers@repo10.org",175		})176		c.expectEQ(msg.Subject, crash.Title)177		c.expectEQ(len(msg.Attachments), 0)178		c.expectEQ(msg.Body, fmt.Sprintf(`Hello,179syzbot found the following crash on:180HEAD commit:    10101010 a really long title, longer than 80 chars, really..181git tree:       repo10alias182console output: %[3]v183kernel config:  %[4]v184dashboard link: https://testapp.appspot.com/bug?extid=%[1]v185compiler:       compiler10186userspace arch: i386187syz repro:      %[2]v188CC:             [bar@foo.com foo@bar.com maintainers@repo10.org bugs@repo10.org]189IMPORTANT: if you fix the bug, please add the following tag to the commit:190Reported-by: syzbot+%[1]v@testapp.appspotmail.com191report1192---193This bug is generated by a bot. It may contain errors.194See https://goo.gl/tpsmEJ for more information about syzbot.195syzbot engineers can be reached at syzkaller@googlegroups.com.196syzbot will keep track of this bug report. See:197https://goo.gl/tpsmEJ#status for how to communicate with syzbot.198syzbot can test patches for this bug, for details see:199https://goo.gl/tpsmEJ#testing-patches`,200			extBugID1, reproSyzLink, crashLogLink, kernelConfigLink))201		c.checkURLContents(reproSyzLink, syzRepro)202		c.checkURLContents(crashLogLink, crash.Log)203		c.checkURLContents(kernelConfigLink, build2.KernelConfig)204	}205	// Model that somebody adds more emails to CC list.206	incoming3 := fmt.Sprintf(`Sender: syzkaller@googlegroups.com207Date: Tue, 15 Aug 2017 14:59:00 -0700208Message-ID: <1234>209Subject: crash1210From: foo@bar.com211To: %v212CC: new@new.com, "another" <another@another.com>, bar@foo.com, bugs@syzkaller.com, foo@bar.com213Content-Type: text/plain214+more people215`, sender1)216	c.expectOK(c.POST("/_ah/mail/", incoming3))217	// Now upload a C reproducer.218	crash.ReproC = []byte("int main() {}")219	crash.Maintainers = []string{"\"qux\" <qux@qux.com>"}220	c.client2.ReportCrash(crash)221	cRepro := []byte(fmt.Sprintf("// https://testapp.appspot.com/bug?id=%v\n%s",222		dbBug0.keyHash(), crash.ReproC))223	{224		msg := c.pollEmailBug()225		c.expectEQ(msg.Sender, sender1)226		sender, _, err := email.RemoveAddrContext(msg.Sender)227		c.expectOK(err)228		_, dbCrash, dbBuild := c.loadBug(extBugID1)229		reproCLink := externalLink(c.ctx, textReproC, dbCrash.ReproC)230		reproSyzLink := externalLink(c.ctx, textReproSyz, dbCrash.ReproSyz)231		crashLogLink := externalLink(c.ctx, textCrashLog, dbCrash.Log)232		kernelConfigLink := externalLink(c.ctx, textKernelConfig, dbBuild.KernelConfig)233		c.expectEQ(sender, fromAddr(c.ctx))234		c.expectEQ(msg.To, []string{235			"always@cc.me",236			"another@another.com", "bar@foo.com", "bugs@repo10.org",237			"bugs@syzkaller.com", "default@maintainers.com", "foo@bar.com",238			"maintainers@repo10.org", "new@new.com", "qux@qux.com"})239		c.expectEQ(msg.Subject, "Re: "+crash.Title)240		c.expectEQ(len(msg.Attachments), 0)241		c.expectEQ(msg.Body, fmt.Sprintf(`syzbot has found a reproducer for the following crash on:242HEAD commit:    10101010 a really long title, longer than 80 chars, really..243git tree:       repo10alias244console output: %[4]v245kernel config:  %[5]v246dashboard link: https://testapp.appspot.com/bug?extid=%[1]v247compiler:       compiler10248userspace arch: i386249syz repro:      %[3]v250C reproducer:   %[2]v251CC:             [qux@qux.com maintainers@repo10.org bugs@repo10.org]252IMPORTANT: if you fix the bug, please add the following tag to the commit:253Reported-by: syzbot+%[1]v@testapp.appspotmail.com254report1255`, extBugID1, reproCLink, reproSyzLink, crashLogLink, kernelConfigLink))256		c.checkURLContents(reproCLink, cRepro)257		c.checkURLContents(reproSyzLink, syzRepro)258		c.checkURLContents(crashLogLink, crash.Log)259		c.checkURLContents(kernelConfigLink, build2.KernelConfig)260	}261	// Send an invalid command.262	incoming4 := fmt.Sprintf(`Sender: syzkaller@googlegroups.com263Date: Tue, 15 Aug 2017 14:59:00 -0700264Message-ID: <abcdef>265Subject: title1266From: foo@bar.com267To: %v268Content-Type: text/plain269#syz bad-command270`, sender1)271	c.expectOK(c.POST("/_ah/mail/", incoming4))272	{273		msg := c.pollEmailBug()274		c.expectEQ(msg.To, []string{"<foo@bar.com>"})275		c.expectEQ(msg.Subject, "Re: title1")276		c.expectEQ(msg.Headers["In-Reply-To"], []string{"<abcdef>"})277		if !strings.Contains(msg.Body, `> #syz bad-command278unknown command "bad-command"279`) {280			t.Fatal("no unknown command reply for bad command")281		}282	}283	// Now mark the bug as fixed.284	c.incomingEmail(sender1, "#syz fix: some: commit title", EmailOptCC(nil))285	reply := c.pollEmailBug().Body286	// nolint: lll287	c.expectEQ(reply, `> #syz fix: some: commit title288Your 'fix:' command is accepted, but please keep bugs@syzkaller.com mailing list in CC next time. It serves as a history of what happened with each bug report. Thank you.289`)290	// Check that the commit is now passed to builders.291	builderPollResp, _ := c.client2.BuilderPoll(build.Manager)292	c.expectEQ(len(builderPollResp.PendingCommits), 1)293	c.expectEQ(builderPollResp.PendingCommits[0], "some: commit title")294	build3 := testBuild(3)295	build3.Manager = build.Manager296	build3.Commits = []string{"some: commit title"}297	c.client2.UploadBuild(build3)298	build4 := testBuild(4)299	build4.Manager = build2.Manager300	build4.Commits = []string{"some: commit title"}301	c.client2.UploadBuild(build4)302	// New crash must produce new bug in the first reporting.303	c.client2.ReportCrash(crash)304	{305		msg := c.pollEmailBug()306		c.expectEQ(msg.Subject, crash.Title+" (2)")307		c.expectNE(msg.Sender, sender0)308	}309}310// Bug must not be mailed to maintainers if maintainers list is empty.311func TestEmailNoMaintainers(t *testing.T) {312	c := NewCtx(t)313	defer c.Close()314	build := testBuild(1)315	c.client2.UploadBuild(build)316	crash := testCrash(build, 1)317	c.client2.ReportCrash(crash)318	sender := c.pollEmailBug().Sender319	incoming1 := fmt.Sprintf(`Sender: syzkaller@googlegroups.com320Date: Tue, 15 Aug 2017 14:59:00 -0700321Message-ID: <1234>322Subject: crash1323From: %v324To: foo@bar.com325Content-Type: text/plain326#syz upstream327`, sender)328	c.expectOK(c.POST("/_ah/mail/", incoming1))329}330// Basic dup scenario: mark one bug as dup of another.331func TestEmailDup(t *testing.T) {332	c := NewCtx(t)333	defer c.Close()334	build := testBuild(1)335	c.client2.UploadBuild(build)336	crash1 := testCrash(build, 1)337	crash1.Title = "BUG: slightly more elaborate title"338	c.client2.ReportCrash(crash1)339	crash2 := testCrash(build, 2)340	crash1.Title = "KASAN: another title"341	c.client2.ReportCrash(crash2)342	c.expectOK(c.GET("/email_poll"))343	msg1 := c.pollEmailBug()344	msg2 := c.pollEmailBug()345	// Dup crash2 to crash1.346	c.incomingEmail(msg2.Sender, "#syz dup: BUG: slightly more elaborate title")347	c.expectNoEmail()348	// Second crash happens again349	crash2.ReproC = []byte("int main() {}")350	c.client2.ReportCrash(crash2)351	c.expectNoEmail()352	// Now close the original bug, and check that new bugs for dup are now created.353	c.incomingEmail(msg1.Sender, "#syz invalid")354	// uncc command must not trugger error reply even for closed bug.355	c.incomingEmail(msg1.Sender, "#syz uncc", EmailOptCC(nil))356	c.expectNoEmail()357	// New crash must produce new bug in the first reporting.358	c.client2.ReportCrash(crash2)359	{360		msg := c.pollEmailBug()361		c.expectEQ(msg.Subject, crash2.Title+" (2)")362	}363}364func TestEmailUndup(t *testing.T) {365	c := NewCtx(t)366	defer c.Close()367	build := testBuild(1)368	c.client2.UploadBuild(build)369	crash1 := testCrash(build, 1)370	crash1.Title = "BUG: slightly more elaborate title"371	c.client2.ReportCrash(crash1)372	crash2 := testCrash(build, 2)373	crash1.Title = "KASAN: another title"374	c.client2.ReportCrash(crash2)375	c.expectOK(c.GET("/email_poll"))376	msg1 := c.pollEmailBug()377	msg2 := c.pollEmailBug()378	// Dup crash2 to crash1.379	c.incomingEmail(msg2.Sender, "#syz dup BUG: slightly more elaborate title")380	c.expectNoEmail()381	// Undup crash2.382	c.incomingEmail(msg2.Sender, "#syz undup")383	c.expectNoEmail()384	// Now close the original bug, and check that new crashes for the dup does not create bugs.385	c.incomingEmail(msg1.Sender, "#syz invalid")386	c.client2.ReportCrash(crash2)387	c.expectNoEmail()388}389func TestEmailCrossReportingDup(t *testing.T) {390	c := NewCtx(t)391	defer c.Close()392	build := testBuild(1)393	c.client2.UploadBuild(build)394	tests := []struct {395		bug    int396		dup    int397		result bool398	}{399		{0, 0, true},400		{0, 1, false},401		{0, 2, false},402		{1, 0, false},403		{1, 1, true},404		{1, 2, true},405		{2, 0, false},406		{2, 1, false},407		{2, 2, true},408	}409	for i, test := range tests {410		t.Logf("duping %v->%v, expect %v", test.bug, test.dup, test.result)411		c.advanceTime(24 * time.Hour) // to not hit email limit per day412		crash1 := testCrash(build, 1)413		crash1.Title = fmt.Sprintf("bug_%v", i)414		c.client2.ReportCrash(crash1)415		bugSender := c.pollEmailBug().Sender416		for j := 0; j < test.bug; j++ {417			c.incomingEmail(bugSender, "#syz upstream")418			bugSender = c.pollEmailBug().Sender419		}420		crash2 := testCrash(build, 2)421		crash2.Title = fmt.Sprintf("dup_%v", i)422		c.client2.ReportCrash(crash2)423		dupSender := c.pollEmailBug().Sender424		for j := 0; j < test.dup; j++ {425			c.incomingEmail(dupSender, "#syz upstream")426			dupSender = c.pollEmailBug().Sender427		}428		c.incomingEmail(bugSender, "#syz dup: "+crash2.Title)429		if test.result {430			c.expectNoEmail()431		} else {432			msg := c.pollEmailBug()433			if !strings.Contains(msg.Body, "> #syz dup:") ||434				!strings.Contains(msg.Body, "Can't dup bug to a bug in different reporting") {435				c.t.Fatalf("bad reply body:\n%v", msg.Body)436			}437		}438	}439}440func TestEmailErrors(t *testing.T) {441	c := NewCtx(t)442	defer c.Close()443	// No reply for email without bug hash and no commands.444	c.incomingEmail("syzbot@testapp.appspotmail.com", "Investment Proposal")445	c.expectNoEmail()446	// If email contains a command we need to reply.447	c.incomingEmail("syzbot@testapp.appspotmail.com", "#syz invalid")448	reply := c.pollEmailBug()449	c.expectEQ(reply.To, []string{"<default@sender.com>"})450	c.expectEQ(reply.Body, `> #syz invalid451I see the command but can't find the corresponding bug.452Please resend the email to syzbot+HASH@testapp.appspotmail.com address453that is the sender of the bug report (also present in the Reported-by tag).454`)455	c.incomingEmail("syzbot+123@testapp.appspotmail.com", "#syz invalid")456	reply = c.pollEmailBug()457	c.expectEQ(reply.Body, `> #syz invalid458I see the command but can't find the corresponding bug.459The email is sent to  syzbot+HASH@testapp.appspotmail.com address460but the HASH does not correspond to any known bug.461Please double check the address.462`)463}464func TestEmailFailedBuild(t *testing.T) {465	c := NewCtx(t)466	defer c.Close()467	build := testBuild(1)468	c.client2.UploadBuild(build)469	failedBuild := testBuild(10)...

notifications_test.go

Source:notifications_test.go

...59	crash := testCrash(build, 1)60	c.client2.ReportCrash(crash)61	report := c.pollEmailBug()62	c.expectEQ(report.To, []string{"test@syzkaller.com"})63	c.incomingEmail(report.Sender, "#syz fix some: commit title")64	c.expectNoEmail()65	// Notification about bad fixing commit should be send after 90 days.66	c.advanceTime(50 * 24 * time.Hour)67	c.expectNoEmail()68	c.advanceTime(35 * 24 * time.Hour)69	c.expectNoEmail()70	c.advanceTime(10 * 24 * time.Hour)71	notif := c.pollEmailBug()72	if !strings.Contains(notif.Body, "This bug is marked as fixed by commit:\nsome: commit title\n") {73		t.Fatalf("bad notification text: %q", notif.Body)74	}75	// No notifications for another 14 days, then another one.76	c.advanceTime(13 * 24 * time.Hour)77	c.expectNoEmail()78	c.advanceTime(2 * 24 * time.Hour)79	notif = c.pollEmailBug()80	if !strings.Contains(notif.Body, "This bug is marked as fixed by commit:\nsome: commit title\n") {81		t.Fatalf("bad notification text: %q", notif.Body)82	}83}84func TestBugObsoleting(t *testing.T) {85	// To simplify test we specify all dates in days from a fixed point in time.86	const day = 24 * time.Hour87	days := func(n int) time.Time {88		t := time.Date(2000, 0, 0, 0, 0, 0, 0, time.UTC)89		t.Add(time.Duration(n+1) * day)90		return t91	}92	tests := []struct {93		bug    *Bug94		period time.Duration95	}{96		// Final bug with just 1 crash: max final period.97		{98			bug: &Bug{99				FirstTime:  days(0),100				LastTime:   days(0),101				NumCrashes: 1,102				Reporting:  []BugReporting{{Reported: days(0)}},103			},104			period: 100 * day,105		},106		// Non-final bug with just 1 crash: max non-final period.107		{108			bug: &Bug{109				FirstTime:  days(0),110				LastTime:   days(0),111				NumCrashes: 1,112				Reporting:  []BugReporting{{Reported: days(0)}, {}},113			},114			period: 60 * day,115		},116		// Special manger: max period that that manager.117		{118			bug: &Bug{119				FirstTime:  days(0),120				LastTime:   days(0),121				NumCrashes: 1,122				HappenedOn: []string{"special-obsoleting"},123				Reporting:  []BugReporting{{Reported: days(0)}, {}},124			},125			period: 20 * day,126		},127		// Special manger and a non-special: normal rules.128		{129			bug: &Bug{130				FirstTime:  days(0),131				LastTime:   days(0),132				NumCrashes: 1,133				HappenedOn: []string{"special-obsoleting", "non-special-manager"},134				Reporting:  []BugReporting{{Reported: days(0)}},135			},136			period: 100 * day,137		},138		// Happened a lot: min period.139		{140			bug: &Bug{141				FirstTime:  days(0),142				LastTime:   days(1),143				NumCrashes: 1000,144				Reporting:  []BugReporting{{Reported: days(0)}},145			},146			period: 80 * day,147		},148	}149	for i, test := range tests {150		test.bug.Namespace = "test1"151		got := test.bug.obsoletePeriod()152		if got != test.period {153			t.Errorf("test #%v: got: %.2f, want %.2f",154				i, float64(got/time.Hour)/24, float64(test.period/time.Hour)/24)155		}156	}157}158func TestEmailNotifObsoleted(t *testing.T) {159	c := NewCtx(t)160	defer c.Close()161	build := testBuild(1)162	c.client2.UploadBuild(build)163	crash := testCrash(build, 1)164	crash.Maintainers = []string{"maintainer@syzkaller.com"}165	c.client2.ReportCrash(crash)166	report := c.pollEmailBug()167	// Need to upstream so that it's not auto-upstreamed before obsoleted.168	c.incomingEmail(report.Sender, "#syz upstream")169	report = c.pollEmailBug()170	// Add more people to bug CC.171	c.incomingEmail(report.Sender, "wow", EmailOptCC([]string{"somebody@else.com"}))172	// Bug is open, new crashes don't create new bug.173	c.client2.ReportCrash(crash)174	c.expectNoEmail()175	// Not yet.176	c.advanceTime(59 * 24 * time.Hour)177	c.expectNoEmail()178	// Now!179	c.advanceTime(2 * 24 * time.Hour)180	notif := c.pollEmailBug()181	if !strings.Contains(notif.Body, "Auto-closing this bug as obsolete") {182		t.Fatalf("bad notification text: %q", notif.Body)183	}184	c.expectEQ(notif.To, []string{"bugs@syzkaller.com", "default@sender.com", "somebody@else.com"})185	// New crash must create new bug.186	c.client2.ReportCrash(crash)187	report = c.pollEmailBug()188	c.expectEQ(report.Subject, "title1 (2)")189	// Now the same, but for the last reporting (must have smaller CC list).190	c.incomingEmail(report.Sender, "#syz upstream")191	report = c.pollEmailBug()192	c.incomingEmail(report.Sender, "#syz upstream")193	report = c.pollEmailBug()194	_ = report195	c.advanceTime(101 * 24 * time.Hour)196	notif = c.pollEmailBug()197	if !strings.Contains(notif.Body, "Auto-closing this bug as obsolete") {198		t.Fatalf("bad notification text: %q", notif.Body)199	}200	c.expectEQ(notif.To, []string{"bugs2@syzkaller.com"})201}202func TestEmailNotifNotObsoleted(t *testing.T) {203	c := NewCtx(t)204	defer c.Close()205	build := testBuild(1)206	c.client2.UploadBuild(build)207	// Crashes with repro are not auto-obsoleted.208	crash1 := testCrash(build, 1)209	crash1.ReproSyz = []byte("repro")210	c.client2.ReportCrash(crash1)211	report1 := c.pollEmailBug()212	c.incomingEmail(report1.Sender, "#syz upstream")213	report1 = c.pollEmailBug()214	_ = report1215	// This crash will get another crash later.216	crash2 := testCrash(build, 2)217	c.client2.ReportCrash(crash2)218	report2 := c.pollEmailBug()219	c.incomingEmail(report2.Sender, "#syz upstream")220	report2 = c.pollEmailBug()221	_ = report2222	// This crash will get some activity later.223	crash3 := testCrash(build, 3)224	c.client2.ReportCrash(crash3)225	report3 := c.pollEmailBug()226	c.incomingEmail(report3.Sender, "#syz upstream")227	report3 = c.pollEmailBug()228	// This will be obsoleted (just to check that we have timings right).229	c.advanceTime(24 * time.Hour)230	crash4 := testCrash(build, 4)231	c.client2.ReportCrash(crash4)232	report4 := c.pollEmailBug()233	c.incomingEmail(report4.Sender, "#syz upstream")234	report4 = c.pollEmailBug()235	c.advanceTime(59 * 24 * time.Hour)236	c.expectNoEmail()237	c.client2.ReportCrash(crash2)238	c.incomingEmail(report3.Sender, "I am looking at it")239	c.advanceTime(5 * 24 * time.Hour)240	// Only crash 4 is obsoleted.241	notif := c.pollEmailBug()242	c.expectEQ(notif.Sender, report4.Sender)243	c.expectNoEmail()244	// Crash 3 also obsoleted after some time.245	c.advanceTime(20 * 24 * time.Hour)246	notif = c.pollEmailBug()247	c.expectEQ(notif.Sender, report3.Sender)248}249func TestEmailNotifObsoletedManager(t *testing.T) {250	// Crashes with repro are auto-obsoleted if happen on a particular manager only.251	c := NewCtx(t)252	defer c.Close()253	build := testBuild(1)254	build.Manager = "no-fix-bisection-manager"255	c.client2.UploadBuild(build)256	crash := testCrashWithRepro(build, 1)257	c.client2.ReportCrash(crash)258	report := c.pollEmailBug()259	c.incomingEmail(report.Sender, "#syz upstream")260	report = c.pollEmailBug()261	_ = report262	c.advanceTime(200 * 24 * time.Hour)263	notif := c.pollEmailBug()264	c.expectTrue(strings.Contains(notif.Body, "Auto-closing this bug as obsolete"))265}266func TestExtNotifUpstreamEmbargo(t *testing.T) {267	c := NewCtx(t)268	defer c.Close()269	build1 := testBuild(1)270	c.client.UploadBuild(build1)271	crash1 := testCrash(build1, 1)272	c.client.ReportCrash(crash1)273	rep := c.client.pollBug()...

incomingEmail

Using AI Code Generation

1import (2func main() {3    email.incomingEmail()4}5import (6type Email struct {7}8func (email Email) incomingEmail() {9    fmt.Println("Username: " + email.username)10    fmt.Println("Password: " + email.password)11}

incomingEmail

Using AI Code Generation

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

incomingEmail

Using AI Code Generation

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

incomingEmail

Using AI Code Generation

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

incomingEmail

Using AI Code Generation

1import (2func main() {3 abc.IncomingEmail()4}5import (6func main() {7 abc.OutgoingEmail()8}

incomingEmail

Using AI Code Generation

1import "fmt"2func main() {3    obj.incomingEmail()4}5import "fmt"6func (obj main) incomingEmail() {7    fmt.Println("Incoming Email")8}

incomingEmail

Using AI Code Generation

1import (2func main() {3	fmt.Println("main started")4	email := make(chan string)5	go incomingEmail(email)6	fmt.Println("main ended")7}8func incomingEmail(email chan string) {9	fmt.Println("incomingEmail started")10	time.Sleep(2 * time.Second)11	fmt.Println("incomingEmail ended")12}13import (14func main() {15	fmt.Println("main started")16	wg.Add(1)17	email := make(chan string)18	go incomingEmail(email, &wg)19	wg.Wait()20	fmt.Println("main ended")21}22func incomingEmail(email chan string, wg *sync.WaitGroup) {23	fmt.Println("incomingEmail started")24	time.Sleep(2 * time.Second)25	fmt.Println("incomingEmail ended")26	wg.Done()27}28In the above example, we have created an instance of the WaitGroup type. Then, we have called the Add() method of the

incomingEmail

Using AI Code Generation

1import (2func main() {3	m := mainPackage.Main{}4	fmt.Println(m.IncomingEmail())5}6import "testing"7func TestIncomingEmail(t *testing.T) {8	m := Main{}9	if m.IncomingEmail() != "Incoming email" {10		t.Error("Expected Incoming email")11	}12}13total:					(statements)	100.0%

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.