Test your AI Agents with the all-new Agent to Agent Testing Platform.Learn More

How to use Leakless method of launcher Package

Best Rod code snippet using launcher.Leakless

launcher.go

Source:launcher.go

...32	serviceURL string33}34// New returns the default arguments to start browser.35// Headless will be enabled by default.36// Leakless will be enabled by default.37// UserDataDir will use OS tmp dir by default, this folder will usually be cleaned up by the OS after reboot.38func New() *Launcher {39	dir := defaults.Dir40	if dir == "" {41		dir = filepath.Join(DefaultUserDataDirPrefix, utils.RandString(8))42	}43	defaultFlags := map[flags.Flag][]string{44		flags.Bin:      {defaults.Bin},45		flags.Leakless: nil,46		flags.UserDataDir: {dir},47		// use random port by default48		flags.RemoteDebuggingPort: {defaults.Port},49		// enable headless by default50		flags.Headless: nil,51		// to disable the init blank window52		"no-first-run":      nil,53		"no-startup-window": nil,54		// TODO: about the "site-per-process" see https://github.com/puppeteer/puppeteer/issues/254855		"disable-features": {"site-per-process", "TranslateUI"},56		"disable-background-networking":                      nil,57		"disable-background-timer-throttling":                nil,58		"disable-backgrounding-occluded-windows":             nil,59		"disable-breakpad":                                   nil,60		"disable-client-side-phishing-detection":             nil,61		"disable-component-extensions-with-background-pages": nil,62		"disable-default-apps":                               nil,63		"disable-dev-shm-usage":                              nil,64		"disable-hang-monitor":                               nil,65		"disable-ipc-flooding-protection":                    nil,66		"disable-popup-blocking":                             nil,67		"disable-prompt-on-repost":                           nil,68		"disable-renderer-backgrounding":                     nil,69		"disable-sync":                                       nil,70		"enable-automation":                                  nil,71		"enable-features":                                    {"NetworkService", "NetworkServiceInProcess"},72		"force-color-profile":                                {"srgb"},73		"metrics-recording-only":                             nil,74		"use-mock-keychain":                                  nil,75	}76	if defaults.Show {77		delete(defaultFlags, flags.Headless)78	}79	if defaults.Devtools {80		defaultFlags["auto-open-devtools-for-tabs"] = nil81	}82	if inContainer {83		defaultFlags[flags.NoSandbox] = nil84	}85	if defaults.Proxy != "" {86		defaultFlags[flags.ProxyServer] = []string{defaults.Proxy}87	}88	ctx, cancel := context.WithCancel(context.Background())89	return &Launcher{90		ctx:       ctx,91		ctxCancel: cancel,92		Flags:     defaultFlags,93		exit:      make(chan struct{}),94		browser:   NewBrowser(),95		parser:    NewURLParser(),96		logger:    ioutil.Discard,97	}98}99// NewUserMode is a preset to enable reusing current user data. Useful for automation of personal browser.100// If you see any error, it may because you can't launch debug port for existing browser, the solution is to101// completely close the running browser. Unfortunately, there's no API for rod to tell it automatically yet.102func NewUserMode() *Launcher {103	ctx, cancel := context.WithCancel(context.Background())104	bin, _ := LookPath()105	return &Launcher{106		ctx:       ctx,107		ctxCancel: cancel,108		Flags: map[flags.Flag][]string{109			flags.RemoteDebuggingPort: {"37712"},110			"no-startup-window":       nil,111			flags.Bin:                 {bin},112		},113		browser: NewBrowser(),114		exit:    make(chan struct{}),115		parser:  NewURLParser(),116		logger:  ioutil.Discard,117	}118}119// NewAppMode is a preset to run the browser like a native application.120func NewAppMode(u string) *Launcher {121	l := New()122	l.Set(flags.App, u).123		Set(flags.Env, "GOOGLE_API_KEY=no").124		Headless(false).125		Delete("no-startup-window").126		Delete("enable-automation")127	return l128}129// Context sets the context130func (l *Launcher) Context(ctx context.Context) *Launcher {131	ctx, cancel := context.WithCancel(ctx)132	l.ctx = ctx133	l.parser.Context(ctx)134	l.ctxCancel = cancel135	return l136}137// Set a command line argument to launch the browser.138func (l *Launcher) Set(name flags.Flag, values ...string) *Launcher {139	if strings.Contains(string(name), "=") {140		panic("flag name should not contain '='")141	}142	l.Flags[l.normalizeFlag(name)] = values143	return l144}145// Get flag's first value146func (l *Launcher) Get(name flags.Flag) string {147	if list, has := l.GetFlags(name); has {148		return list[0]149	}150	return ""151}152// Has flag or not153func (l *Launcher) Has(name flags.Flag) bool {154	_, has := l.GetFlags(name)155	return has156}157// GetFlags from settings158func (l *Launcher) GetFlags(name flags.Flag) ([]string, bool) {159	flag, has := l.Flags[l.normalizeFlag(name)]160	return flag, has161}162// Append values to the flag163func (l *Launcher) Append(name flags.Flag, values ...string) *Launcher {164	flags, has := l.GetFlags(name)165	if !has {166		flags = []string{}167	}168	return l.Set(name, append(flags, values...)...)169}170// Delete a flag171func (l *Launcher) Delete(name flags.Flag) *Launcher {172	delete(l.Flags, l.normalizeFlag(name))173	return l174}175// Bin of the browser binary path to launch, if the path is not empty the auto download will be disabled176func (l *Launcher) Bin(path string) *Launcher {177	return l.Set(flags.Bin, path)178}179// Revision of the browser to auto download180func (l *Launcher) Revision(rev int) *Launcher {181	l.browser.Revision = rev182	return l183}184// Headless switch. Whether to run browser in headless mode. A mode without visible UI.185func (l *Launcher) Headless(enable bool) *Launcher {186	if enable {187		return l.Set(flags.Headless)188	}189	return l.Delete(flags.Headless)190}191// NoSandbox switch. Whether to run browser in no-sandbox mode.192// Linux users may face "running as root without --no-sandbox is not supported" in some Linux/Chrome combinations. This function helps switch mode easily.193// Be aware disabling sandbox is not trivial. Use at your own risk.194// Related doc: https://bugs.chromium.org/p/chromium/issues/detail?id=638180195func (l *Launcher) NoSandbox(enable bool) *Launcher {196	if enable {197		return l.Set(flags.NoSandbox)198	}199	return l.Delete(flags.NoSandbox)200}201// XVFB enables to run browser in by XVFB. Useful when you want to run headful mode on linux.202func (l *Launcher) XVFB(args ...string) *Launcher {203	return l.Set(flags.XVFB, args...)204}205// Leakless switch. If enabled, the browser will be force killed after the Go process exits.206// The doc of leakless: https://github.com/ysmood/leakless.207func (l *Launcher) Leakless(enable bool) *Launcher {208	if enable {209		return l.Set(flags.Leakless)210	}211	return l.Delete(flags.Leakless)212}213// Devtools switch to auto open devtools for each tab214func (l *Launcher) Devtools(autoOpenForTabs bool) *Launcher {215	if autoOpenForTabs {216		return l.Set("auto-open-devtools-for-tabs")217	}218	return l.Delete("auto-open-devtools-for-tabs")219}220// UserDataDir is where the browser will look for all of its state, such as cookie and cache.221// When set to empty, browser will use current OS home dir.222// Related doc: https://chromium.googlesource.com/chromium/src/+/master/docs/user_data_dir.md223func (l *Launcher) UserDataDir(dir string) *Launcher {224	if dir == "" {225		l.Delete(flags.UserDataDir)226	} else {227		l.Set(flags.UserDataDir, dir)228	}229	return l230}231// ProfileDir is the browser profile the browser will use.232// When set to empty, the profile 'Default' is used.233// Related article: https://superuser.com/a/377195234func (l *Launcher) ProfileDir(dir string) *Launcher {235	if dir == "" {236		l.Delete("profile-directory")237	} else {238		l.Set("profile-directory", dir)239	}240	return l241}242// RemoteDebuggingPort to launch the browser. Zero for a random port. Zero is the default value.243// If it's not zero and the Launcher.Leakless is disabled, the launcher will try to reconnect to it first,244// if the reconnection fails it will launch a new browser.245func (l *Launcher) RemoteDebuggingPort(port int) *Launcher {246	return l.Set(flags.RemoteDebuggingPort, fmt.Sprintf("%d", port))247}248// Proxy switch. When disabled leakless will be disabled.249func (l *Launcher) Proxy(host string) *Launcher {250	return l.Set(flags.ProxyServer, host)251}252// WorkingDir to launch the browser process.253func (l *Launcher) WorkingDir(path string) *Launcher {254	return l.Set(flags.WorkingDir, path)255}256// Env to launch the browser process. The default value is os.Environ().257// Usually you use it to set the timezone env. Such as:258//     Env(append(os.Environ(), "TZ=Asia/Tokyo")...)259func (l *Launcher) Env(env ...string) *Launcher {260	return l.Set(flags.Env, env...)261}262// StartURL to launch263func (l *Launcher) StartURL(u string) *Launcher {264	return l.Set("", u)265}266// FormatArgs returns the formated arg list for cli267func (l *Launcher) FormatArgs() []string {268	execArgs := []string{}269	for k, v := range l.Flags {270		if k == flags.Arguments {271			continue272		}273		if strings.HasPrefix(string(k), "rod-") {274			continue275		}276		// fix a bug of chrome, if path is not absolute chrome will hang277		if k == flags.UserDataDir {278			abs, err := filepath.Abs(v[0])279			utils.E(err)280			v[0] = abs281		}282		str := "--" + string(k)283		if v != nil {284			str += "=" + strings.Join(v, ",")285		}286		execArgs = append(execArgs, str)287	}288	execArgs = append(execArgs, l.Flags[flags.Arguments]...)289	sort.Strings(execArgs)290	return execArgs291}292// Logger to handle stdout and stderr from browser.293// For example, pipe all browser output to stdout: launcher.New().Logger(os.Stdout)294func (l *Launcher) Logger(w io.Writer) *Launcher {295	l.logger = w296	return l297}298// MustLaunch is similar to Launch299func (l *Launcher) MustLaunch() string {300	u, err := l.Launch()301	utils.E(err)302	return u303}304// Launch a standalone temp browser instance and returns the debug url.305// bin and profileDir are optional, set them to empty to use the default values.306// If you want to reuse sessions, such as cookies, set the UserDataDir to the same location.307func (l *Launcher) Launch() (string, error) {308	defer l.ctxCancel()309	bin, err := l.getBin()310	if err != nil {311		return "", err312	}313	var ll *leakless.Launcher314	var cmd *exec.Cmd315	if l.Has(flags.Leakless) && leakless.Support() {316		ll = leakless.New()317		cmd = ll.Command(bin, l.FormatArgs()...)318	} else {319		port := l.Get(flags.RemoteDebuggingPort)320		u, err := ResolveURL(port)321		if err == nil {322			return u, nil323		}324		cmd = exec.Command(bin, l.FormatArgs()...)325	}326	l.setupCmd(cmd)327	err = cmd.Start()328	if err != nil {329		return "", err...

leakless.go

Source:leakless.go

...36func (l *Launcher) Command(name string, arg ...string) *exec.Cmd {37	bin := ""38	func() {39		defer LockPort(l.Lock)()40		bin = GetLeaklessBin()41	}()42	uid := fmt.Sprintf("%x", utils.RandBytes(16))43	addr := l.serve(uid)44	arg = append([]string{uid, addr, name}, arg...)45	return exec.Command(bin, arg...)46}47// Pid signals the pid of the guarded sub-process. The channel may never receive the pid.48func (l *Launcher) Pid() chan int {49	return l.pid50}51// Err message from the guard process52func (l *Launcher) Err() string {53	return l.err54}55func (l *Launcher) serve(uid string) string {56	srv, err := net.Listen("tcp", "127.0.0.1:0")57	if err != nil {58		panic("[leakless] serve error: " + err.Error())59	}60	go func() {61		defer func() { _ = srv.Close() }()62		conn, err := srv.Accept()63		if err != nil {64			l.err = err.Error()65			l.pid <- 066			return67		}68		enc := json.NewEncoder(conn)69		err = enc.Encode(shared.Message{UID: uid})70		if err != nil {71			l.err = err.Error()72			l.pid <- 073			return74		}75		dec := json.NewDecoder(conn)76		var msg shared.Message77		err = dec.Decode(&msg)78		if err == nil {79			l.err = msg.Error80			l.pid <- msg.PID81		}82		_ = dec.Decode(&msg)83	}()84	return srv.Addr().String()85}86var leaklessDir = filepath.Join(os.TempDir(), "leakless-"+shared.Version)87// GetLeaklessBin returns the executable path of the guard, if it doesn't exists create one.88func GetLeaklessBin() string {89	bin := filepath.Join(leaklessDir, "leakless")90	if runtime.GOOS == "windows" {91		bin += ".exe"92	}93	if !utils.FileExists(bin) {94		name := utils.GetTarget().BinName()95		raw, err := base64.StdEncoding.DecodeString(leaklessBinaries[name])96		utils.E(err)97		gr, err := gzip.NewReader(bytes.NewBuffer(raw))98		utils.E(err)99		data, err := ioutil.ReadAll(gr)100		utils.E(err)101		utils.E(gr.Close())102		err = utils.OutputFile(bin, data, nil)...

Leakless

Using AI Code Generation

1import (2func main() {3	cmd := exec.Command("java", "Launcher")4	cmd.SysProcAttr = &syscall.SysProcAttr{5	}6	err := cmd.Run()7	if err != nil {8		fmt.Println(err)9	}10}11public class Launcher {12    public static void main(String[] args) {13        try {14            Process p = Runtime.getRuntime().exec("java -jar test.jar");15            p.waitFor();16        } catch (Exception e) {17            e.printStackTrace();18        }19    }20}21public class test {22    public static void main(String[] args) {23        try {24            Thread.sleep(10000);25        } catch (Exception e) {26            e.printStackTrace();27        }28    }29}30cmd := exec.Command("java", "-jar", "test.jar")31cmd.SysProcAttr = &syscall.SysProcAttr{32}33err := cmd.Run()34if err != nil {35    fmt.Println(err)36}37cmd := exec.Command("java", "-jar", "test.jar")38cmd.SysProcAttr = &syscall.SysProcAttr{39}40err := cmd.Run()41if err != nil {42    fmt.Println(err)43}44cmd := exec.Command("java", "-jar", "test.jar")45cmd.SysProcAttr = &syscall.SysProcAttr{46}47err := cmd.Run()48if err != nil {49    fmt.Println(err)50}

Leakless

Using AI Code Generation

1import (2func main() {3	runtime.GOMAXPROCS(1)4	runtime.SetFinalizer(&runtime.Launcher{}, func(l *runtime.Launcher) {5		fmt.Println("Launcher finalizer")6	})7	fmt.Println("Starting launcher")8	launcher := runtime.NewLauncher()9	fmt.Println("Launcher started")10	launcher.Launch(func() {11		fmt.Println("Running")12	})13	fmt.Println("Launched")14	time.Sleep(time.Second)15	fmt.Println("Done")16}17import (18func main() {19	runtime.GOMAXPROCS(1)20	runtime.SetFinalizer(&runtime.Launcher{}, func(l *runtime.Launcher) {21		fmt.Println("Launcher finalizer")22	})23	fmt.Println("Starting launcher")24	launcher := runtime.NewLauncher()25	fmt.Println("Launcher started")26	launcher.Launch(func() {27		fmt.Println("Running")28	})29	fmt.Println("Launched")30	launcher.Launch(func() {31		fmt.Println("Running")32	})33	fmt.Println("Launched")34	time.Sleep(time.Second)35	fmt.Println("Done")36}37import (38func main() {39	runtime.GOMAXPROCS(1)40	runtime.SetFinalizer(&runtime.Launcher{}, func(l *runtime.Launcher) {41		fmt.Println("Launcher finalizer")42	})43	fmt.Println("Starting launcher")44	launcher := runtime.NewLauncher()45	fmt.Println("Launcher started")46	launcher.Launch(func() {47		fmt.Println("Running")48	})49	fmt.Println("Launched")50	launcher.Launch(func() {51		fmt.Println("Running")52	})53	fmt.Println("Launched")54	launcher.Launch(func() {55		fmt.Println("Running")56	})57	fmt.Println("Launched")58	time.Sleep(time.Second)59	fmt.Println("Done")60}61import (62func main() {63	runtime.GOMAXPROCS(1)64	runtime.SetFinalizer(&runtime.Launcher{}, func(l *runtime.Launcher

Leakless

Using AI Code Generation

1public class Launcher {2    public static void main(String[] args) {3        new Thread(() -> {4            try {5                Thread.sleep(1000);6            } catch (InterruptedException e) {7                e.printStackTrace();8            }9            System.out.println("Hello from thread");10        }).start();11    }12}13public class Launcher {14    public static void main(String[] args) throws InterruptedException {15        Thread thread = new Thread(() -> {16            try {17                Thread.sleep(1000);18            } catch (InterruptedException e) {19                e.printStackTrace();20            }21            System.out.println("Hello from thread");22        });23        thread.start();24        thread.join();25    }26}

Leakless

Using AI Code Generation

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

Leakless

Using AI Code Generation

1import (2func main() {3	l := launcher.NewLauncher()4	l.Start()5	l = launcher.NewLauncher("Test Launcher")6	l.Start()7	l = launcher.NewLauncher("Test Launcher", "icon.png")8	l.Start()9	l = launcher.NewLauncher("Test Launcher", "icon.png", "1.0")10	l.Start()11	l = launcher.NewLauncher("Test Launcher", "icon.png", "1.0", 600, 400)12	l.Start()13	l = launcher.NewLauncher("Test Launcher", "icon.png", "1.0", 600, 400, "#00FF00")14	l.Start()15	l = launcher.NewLauncher("Test Launcher", "icon.png", "1.0", 600, 400, "#00FF00", "#0000FF")16	l.Start()17	l = launcher.NewLauncher("Test Launcher", "icon.png", "1.0", 600, 400, "#00FF00", "#0000FF", "Arial")18	l.Start()19	l = launcher.NewLauncher("Test Launcher", "icon.png", "1.0", 600, 400, "#00FF00", "#0000FF", "Arial", 20)20	l.Start()

Leakless

Using AI Code Generation

1import (2var (3func main() {4	context = gls.NewContext()5	context.Set("key", "value")6	go func() {7		v := context.Get("key")8		fmt.Println(v)9	}()10	context.Wait()11}12import (13var (14func main() {15	context = gls.NewContext()16	context.Set("key", "value")17	go func() {18		v := context.Get("key")19		fmt.Println(v)20	}()21	context.Wait()22}23import (24var (25func main() {26	context = gls.NewContext()27	context.Set("key", "value")28	go func() {29		v := context.Get("key")30		fmt.Println(v)31	}()32	context.Wait()33}34import (35var (36func main() {37	context = gls.NewContext()38	context.Set("key", "value")39	go func() {40		v := context.Get("key")41		fmt.Println(v)42	}()43	context.Wait()44}

Leakless

Using AI Code Generation

1import (2func main() {3	l := goczmq.NewLauncher()4	l.Start()5	w := goczmq.NewWorker()6	w.SetExecutable("./1.exe")7	w.Start()8	c := goczmq.NewClient()9	c.SetTimeout(1000)10	c.Send("Hello")11	msg, _ := c.Recv()12	fmt.Println("Received:", msg)13	w.Stop()14	l.Stop()15}16import (17func main() {18	s := goczmq.NewServer()19	s.Start()20	msg, _ := s.Recv()21	fmt.Println("Received:", msg)22	s.Send("World")23	s.Stop()24}25import (26func main() {27	s := goczmq.NewServer()28	s.Start()

Leakless

Using AI Code Generation

1import (2type launcher struct {3	call func()4}5func hello() {6	fmt.Println("Hello World")7}8type object struct {9}10func main() {11	o := new(object)12	l := launcher{13		object: unsafe.Pointer(o),14	}15	l.call()16}17import (18type launcher struct {19	call   func()20}21func hello() {22	fmt.Println("Hello World")23}24type object struct {25}26func main() {27	o := new(object)28	l := launcher{29		object: unsafe.Pointer(o),30	}31	l.call()32}33import (34type launcher struct {35	call   func()36}37func hello() {38	fmt.Println("Hello World")39}40type object struct {41}42func main() {43	o := new(object)44	l := launcher{45		object: unsafe.Pointer(o),46	}47	l.call()48}49import (50type launcher struct {51	call   func()52}53func hello() {54	fmt.Println("Hello World")55}56type object struct {57}58func main()

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.