[Search] serverless: add in_trial config value (elastic#232703)

## Summary

Adding an explicit boolean `in_trial` config value for serverless
projects to set. This will be used for the context of the feature flag
service in lieu of the `trial_end_date` used for cloud hosted.

### Checklist

- [ ] ~Any text added follows [EUI's writing
guidelines](https://elastic.github.io/eui/#/guidelines/writing), uses
sentence case text and includes [i18n
support](https://github.com/elastic/kibana/blob/main/src/platform/packages/shared/kbn-i18n/README.md)~
- [ ]
[Documentation](https://www.elastic.co/guide/en/kibana/master/development-documentation.html)
was added for features that require explanation or tutorials
- [x] [Unit or functional
tests](https://www.elastic.co/guide/en/kibana/master/development-tests.html)
were updated or added to match the most common scenarios
- [ ] If a plugin configuration key changed, check if it needs to be
allowlisted in the cloud and added to the [docker
list](https://github.com/elastic/kibana/blob/main/src/dev/build/tasks/os_packages/docker_generator/resources/base/bin/kibana-docker)
- [ ] This was checked for breaking HTTP API changes, and any breaking
changes have been approved by the breaking-change committee. The
`release_note:breaking` label should be applied in these situations.
- [ ] [Flaky Test
Runner](https://ci-stats.kibana.dev/trigger_flaky_test_runner/1) was
used on any tests changed
- [x] The PR description includes the appropriate Release Notes section,
and the correct `release_note:*` label is applied per the
[guidelines](https://www.elastic.co/guide/en/kibana/master/contributing.html#kibana-release-notes-process)
- [x] Review the [backport
guidelines](https://docs.google.com/document/d/1VyN5k91e5OVumlc0Gb9RPa3h1ewuPE705nRtioPiTvY/edit?usp=sharing)
and apply applicable `backport:*` labels.

---------

Co-authored-by: Elastic Machine <elasticmachine@users.noreply.github.com>

Author: TattdCodeMonkey

src/platform/test/plugin_functional/test_suites/core_plugins/rendering.ts

@@ -259,6 +259,7 @@ export default function ({ getService }: PluginFunctionalProviderContext) {
         'xpack.cloud.serverless.project_type (observability?|security?|search?|chat?)',
         'xpack.cloud.serverless.product_tier (never|complete?|essentials?|search_ai_lake?|logs_essentials?)',
         'xpack.cloud.serverless.orchestrator_target (string?)',
+        'xpack.cloud.serverless.in_trial (boolean?)',
         'xpack.cloud.onboarding.default_solution (string?)',
         'xpack.contentConnectors.ui.enabled (boolean?)',
         'xpack.discoverEnhanced.actions.exploreDataInChart.enabled (boolean?)',

x-pack/platform/plugins/private/cloud_integrations/cloud_experiments/common/metadata_service/initialize_metadata.ts

@@ -46,6 +46,7 @@ export function initializeMetadata({
     organizationKey: cloud.organizationId,
     trial_end_date: cloud.trialEndDate,
     is_elastic_staff: cloud.isElasticStaffOwned,
+    in_trial: cloud.serverless?.organizationInTrial,
   });
 
   // Update the client's contexts when we get any updates in the metadata.

x-pack/platform/plugins/private/cloud_integrations/cloud_experiments/common/metadata_service/metadata_service.test.ts

@@ -104,6 +104,20 @@ describe('MetadataService', () => {
         });
       })
     );
+
+    test('accepts inTrial from cloud serverless config', async () => {
+      metadataService.setup({
+        ...initialMetadata,
+        in_trial: true,
+      });
+      await expect(firstValueFrom(metadataService.userMetadata$)).resolves.toStrictEqual({
+        ...multiContextFormat,
+        organization: {
+          ...multiContextFormat.organization,
+          in_trial: true,
+        },
+      });
+    });
   });
 
   describe('start', () => {

x-pack/platform/plugins/shared/cloud/public/plugin.tsx

@@ -47,6 +47,7 @@ export interface CloudConfigType {
     project_type?: KibanaSolution;
     product_tier?: KibanaProductTier;
     orchestrator_target?: string;
+    in_trial?: boolean;
   };
 }
 
@@ -124,6 +125,7 @@ export class CloudPlugin implements Plugin<CloudSetup> {
         // It is exposed for informational purposes (telemetry and feature flags). Do not use it for feature-gating.
         // Use `core.pricing` when checking if a feature is available for the current product tier.
         productTier: this.config.serverless?.product_tier,
+        organizationInTrial: this.config.serverless?.in_trial,
       },
       registerCloudService: (contextProvider) => {
         this.contextProviders.push(contextProvider);
@@ -182,6 +184,7 @@ export class CloudPlugin implements Plugin<CloudSetup> {
         projectId: this.config.serverless?.project_id,
         projectName: this.config.serverless?.project_name,
         projectType: this.config.serverless?.project_type,
+        organizationInTrial: this.config.serverless?.in_trial,
       },
       performanceUrl,
       usersAndRolesUrl,

x-pack/platform/plugins/shared/cloud/public/types.ts

@@ -90,6 +90,10 @@ export interface CloudStart {
      * Will always be present if `isServerlessEnabled` is `true`
      */
     projectType?: KibanaSolution;
+    /**
+     * Whether the serverless project belongs to an organization currently in trial.
+     */
+    organizationInTrial?: boolean;
   };
 }
 
@@ -231,6 +235,10 @@ export interface CloudSetup {
      * Will always be present if `isServerlessEnabled` is `true`
      */
     orchestratorTarget?: string;
+    /**
+     * Whether the serverless project belongs to an organization currently in trial.
+     */
+    organizationInTrial?: boolean;
   };
 }
 

x-pack/platform/plugins/shared/cloud/server/__snapshots__/plugin.test.ts.snap

@@ -69,6 +69,26 @@ describe('createCloudUsageCollector', () => {
       });
     });
 
+    it('return inTrial true if inTrial is provided', async () => {
+      const collector = createCloudUsageCollector(usageCollection, {
+        isCloudEnabled: true,
+        organizationInTrial: true,
+      } as CloudUsageCollectorConfig);
+
+      expect(await collector.fetch(collectorFetchContext)).toStrictEqual({
+        isCloudEnabled: true,
+        isElasticStaffOwned: undefined,
+        organizationId: undefined,
+        trialEndDate: undefined,
+        inTrial: true,
+        deploymentId: undefined,
+        projectId: undefined,
+        projectType: undefined,
+        productTier: undefined,
+        orchestratorTarget: undefined,
+      });
+    });
+
     it('pass-through properties are copied as expected', async () => {
       const collector = createCloudUsageCollector(usageCollection, {
         isCloudEnabled: true,
@@ -80,6 +100,7 @@ describe('createCloudUsageCollector', () => {
         projectType: 'security',
         productTier: 'complete',
         orchestratorTarget: 'canary',
+        organizationInTrial: undefined,
       });
 
       expect(await collector.fetch(collectorFetchContext)).toStrictEqual({

x-pack/platform/plugins/shared/cloud/server/collectors/cloud_usage_collector.test.ts

@@ -18,6 +18,7 @@ export interface CloudUsageCollectorConfig {
   projectType: string | undefined;
   productTier: string | undefined;
   orchestratorTarget: string | undefined;
+  organizationInTrial: boolean | undefined;
 }
 
 interface CloudUsage {
@@ -47,6 +48,7 @@ export function createCloudUsageCollector(
     projectType,
     productTier,
     orchestratorTarget,
+    organizationInTrial,
   } = config;
   const trialEndDateMs = trialEndDate ? new Date(trialEndDate).getTime() : undefined;
   return usageCollection.makeUsageCollector<CloudUsage>({
@@ -99,7 +101,11 @@ export function createCloudUsageCollector(
         isElasticStaffOwned,
         organizationId,
         trialEndDate,
-        ...(trialEndDateMs ? { inTrial: Date.now() <= trialEndDateMs } : {}),
+        ...(organizationInTrial
+          ? { inTrial: true }
+          : trialEndDateMs
+          ? { inTrial: Date.now() <= trialEndDateMs }
+          : {}),
         deploymentId,
         projectId,
         projectType,

x-pack/platform/plugins/shared/cloud/server/collectors/cloud_usage_collector.ts

@@ -101,6 +101,7 @@ const configSchema = schema.object({
         ),
         product_tier: schema.maybe(createProductTiersSchema()),
         orchestrator_target: schema.maybe(schema.string()),
+        in_trial: schema.maybe(schema.boolean()),
       },
       // avoid future chicken-and-egg situation with the component populating the config
       { unknowns: 'ignore' }
@@ -133,6 +134,7 @@ export const config: PluginConfigDescriptor<CloudConfigType> = {
       project_type: true,
       product_tier: true,
       orchestrator_target: true,
+      in_trial: true,
     },
     onboarding: {
       default_solution: true,

x-pack/platform/plugins/shared/cloud/server/config.ts

@@ -161,6 +161,10 @@ export interface CloudSetup {
      * Will always be present if `isServerlessEnabled` is `true`
      */
     orchestratorTarget?: string;
+    /**
+     * Whether the serverless project belongs to an organization currently in trial.
+     */
+    organizationInTrial?: boolean;
   };
 }
 
@@ -216,6 +220,7 @@ export class CloudPlugin implements Plugin<CloudSetup, CloudStart> {
       projectType,
       productTier,
       orchestratorTarget,
+      organizationInTrial: this.config.serverless?.in_trial,
     });
     const basePath = core.http.basePath.serverBasePath;
     core.http.resources.register(
@@ -374,6 +379,7 @@ export class CloudPlugin implements Plugin<CloudSetup, CloudStart> {
         // It is exposed for informational purposes (telemetry and feature flags). Do not use it for feature-gating.
         // Use `core.pricing` when checking if a feature is available for the current product tier.
         productTier,
+        organizationInTrial: this.config.serverless?.in_trial,
       },
     };
   }