Wrap KibanaRequest execution context in a getter.

src/plugins/data/server/index_patterns/expressions/load_index_pattern.test.ts

@@ -38,9 +38,18 @@ describe('indexPattern expression function', () => {
   test('returns serialized index pattern', async () => {
     const indexPatternDefinition = getFunctionDefinition({ getStartDependencies });
     const result = await indexPatternDefinition().fn(null, { id: '1' }, {
-      kibanaRequest: {},
+      getKibanaRequest: () => ({}),
     } as any);
     expect(result.type).toEqual('index_pattern');
     expect(result.value.title).toEqual('value');
   });
+
+  test('throws if getKibanaRequest is not available', async () => {
+    const indexPatternDefinition = getFunctionDefinition({ getStartDependencies });
+    expect(async () => {
+      await indexPatternDefinition().fn(null, { id: '1' }, {} as any);
+    }).rejects.toThrowErrorMatchingInlineSnapshot(
+      `"A KibanaRequest is required to execute this search on the server. Please provide a request object to the expression execution params."`
+    );
+  });
 });

src/plugins/data/server/index_patterns/expressions/load_index_pattern.ts

@@ -46,7 +46,8 @@ export function getFunctionDefinition({
 }) {
   return (): IndexPatternLoadExpressionFunctionDefinition => ({
     ...getIndexPatternLoadMeta(),
-    async fn(input, args, { kibanaRequest }) {
+    async fn(input, args, { getKibanaRequest }) {
+      const kibanaRequest = getKibanaRequest ? getKibanaRequest() : null;
       if (!kibanaRequest) {
         throw new Error(
           i18n.translate('data.indexPatterns.indexPatternLoad.error.kibanaRequest', {

src/plugins/data/server/search/expressions/esaggs.ts

@@ -48,7 +48,12 @@ export function getFunctionDefinition({
 }): () => EsaggsExpressionFunctionDefinition {
   return () => ({
     ...getEsaggsMeta(),
-    async fn(input, args, { inspectorAdapters, abortSignal, getSearchSessionId, kibanaRequest }) {
+    async fn(
+      input,
+      args,
+      { inspectorAdapters, abortSignal, getSearchSessionId, getKibanaRequest }
+    ) {
+      const kibanaRequest = getKibanaRequest ? getKibanaRequest() : null;
       if (!kibanaRequest) {
         throw new Error(
           i18n.translate('data.search.esaggs.error.kibanaRequest', {

src/plugins/expressions/common/execution/execution.ts

@@ -152,6 +152,7 @@ export class Execution<
     this.context = {
       getSearchContext: () => this.execution.params.searchContext || {},
       getSearchSessionId: () => execution.params.searchSessionId,
+      getKibanaRequest: () => execution.params.kibanaRequest,
       variables: execution.params.variables || {},
       types: executor.getTypes(),
       abortSignal: this.abortController.signal,

src/plugins/expressions/common/execution/types.ts

@@ -63,11 +63,11 @@ export interface ExecutionContext<
   getSearchSessionId: () => string | undefined;
 
   /**
-   * Makes a `KibanaRequest` object available to expression functions. Useful for
-   * functions which are running on the server and need to perform operations that
-   * are scoped to a specific user.
+   * Getter to retrieve the `KibanaRequest` object inside an expression function.
+   * Useful for functions which are running on the server and need to perform
+   * operations that are scoped to a specific user.
    */
-  kibanaRequest?: KibanaRequest;
+  getKibanaRequest?: () => KibanaRequest;
 
   /**
    * Allows to fetch saved objects from ElasticSearch. In browser `getSavedObject`