worker.go

package patchright

type workerImpl struct {
	channelOwner
	page    *pageImpl
	context *browserContextImpl
}

func (w *workerImpl) URL() string {
	return w.initializer["url"].(string)
}

func (w *workerImpl) Evaluate(expression string, options ...any) (any, error) {
	var arg any
	if len(options) == 1 {
		arg = options[0]
	}
	result, err := w.channel.Send("evaluateExpression", map[string]any{
		"expression":      expression,
		"arg":             serializeArgument(arg),
		"isolatedContext": true,
	})
	if err != nil {
		return nil, err
	}
	return parseResult(result), nil
}

func (w *workerImpl) EvaluateHandle(expression string, options ...any) (JSHandle, error) {
	var arg any
	if len(options) == 1 {
		arg = options[0]
	}
	result, err := w.channel.Send("evaluateExpressionHandle", map[string]any{
		"expression":      expression,
		"arg":             serializeArgument(arg),
		"isolatedContext": true,
	})
	if err != nil {
		return nil, err
	}
	return fromChannel(result).(JSHandle), nil
}

func (w *workerImpl) onClose() {
	if w.page != nil {
		w.page.Lock()
		workers := make([]Worker, 0)
		for i := 0; i < len(w.page.workers); i++ {
			if w.page.workers[i] != w {
				workers = append(workers, w.page.workers[i])
			}
		}
		w.page.workers = workers
		w.page.Unlock()
	}
	if w.context != nil {
		w.context.Lock()
		workers := make([]Worker, 0)
		for i := 0; i < len(w.context.serviceWorkers); i++ {
			if w.context.serviceWorkers[i] != w {
				workers = append(workers, w.context.serviceWorkers[i])
			}
		}
		w.context.serviceWorkers = workers
		w.context.Unlock()
	}
	w.Emit("close", w)
}

func (w *workerImpl) OnClose(fn func(Worker)) {
	w.On("close", fn)
}

func (w *workerImpl) OnConsole(fn func(ConsoleMessage)) {
	w.On("console", fn)
}

func newWorker(parent *channelOwner, objectType string, guid string, initializer map[string]any) *workerImpl {
	bt := &workerImpl{}
	bt.createChannelOwner(bt, parent, objectType, guid, initializer)
	bt.setEventSubscriptionMapping(map[string]string{
		"console": "console",
	})
	bt.channel.On("close", bt.onClose)
	bt.channel.On("console", func(ev map[string]any) {
		bt.Emit("console", newConsoleMessage(ev))
	})
	return bt
}