Function newFunctionJSServer

db/functions/js_runner.go:45–57

Creates a JSServer instance wrapping a userJSRunner, for user JS functions.

(ctx context.Context, name string, what string, sourceCode string)

// Creates a JSServer instance wrapping a userJSRunner, for user JS functions.
func newFunctionJSServer(ctx context.Context, name string, what string, sourceCode string) (*sgbucket.JSServer, error) {
	js := fmt.Sprintf(kJavaScriptWrapper, sourceCode)
	jsServer := sgbucket.NewJSServer(ctx, js, 0, kUserFunctionCacheSize,
		func(ctx context.Context, fnSource string, timeout time.Duration) (sgbucket.JSServerTask, error) {
			return newJSRunner(ctx, name, what, fnSource)
		})
	// Call WithTask to force a task to be instantiated, which will detect syntax errors in the script. Otherwise the error only gets detected the first time a client calls the function.
	var err error
	_, err = jsServer.WithTask(ctx, func(sgbucket.JSServerTask) (any, error) {
		return nil, nil
	})
	return jsServer, err
}

// An object that runs a user JavaScript function.
// Not thread-safe! Owned by an sgbucket.JSServer, which arbitrates access to it.