[Ingest Management] main branch uses epr-snapshot. Others production

x-pack/plugins/ingest_manager/common/constants/epm.ts

@@ -6,5 +6,4 @@
 
 export const PACKAGES_SAVED_OBJECT_TYPE = 'epm-packages';
 export const INDEX_PATTERN_SAVED_OBJECT_TYPE = 'index-pattern';
-export const DEFAULT_REGISTRY_URL = 'https://epr-snapshot.ea-web.elastic.dev';
 export const INDEX_PATTERN_PLACEHOLDER_SUFFIX = '-index_pattern_placeholder';

x-pack/plugins/ingest_manager/server/constants/index.ts

@@ -43,5 +43,4 @@ export {
   // Defaults
   DEFAULT_AGENT_CONFIG,
   DEFAULT_OUTPUT,
-  DEFAULT_REGISTRY_URL,
 } from '../../common';

x-pack/plugins/ingest_manager/server/index.ts

@@ -6,7 +6,7 @@
 import { schema, TypeOf } from '@kbn/config-schema';
 import { PluginInitializerContext } from 'src/core/server';
 import { IngestManagerPlugin } from './plugin';
-export { AgentService, ESIndexPatternService } from './services';
+export { AgentService, ESIndexPatternService, getRegistryUrl } from './services';
 export {
   IngestManagerSetupContract,
   IngestManagerSetupDeps,

x-pack/plugins/ingest_manager/server/plugin.ts

@@ -15,7 +15,6 @@ import {
   HttpServiceSetup,
 } from 'kibana/server';
 import { UsageCollectionSetup } from 'src/plugins/usage_collection/server';
-import packageJSON from '../../../../package.json';
 import { LicensingPluginSetup, ILicense } from '../../licensing/server';
 import {
   EncryptedSavedObjectsPluginStart,
@@ -84,9 +83,9 @@ export interface IngestManagerAppContext {
   security?: SecurityPluginSetup;
   config$?: Observable<IngestManagerConfigType>;
   savedObjects: SavedObjectsServiceStart;
-  isProductionMode: boolean;
-  kibanaVersion: string;
-  kibanaBranch: string;
+  isProductionMode: PluginInitializerContext['env']['mode']['prod'];
+  kibanaVersion: PluginInitializerContext['env']['packageInfo']['version'];
+  kibanaBranch: PluginInitializerContext['env']['packageInfo']['branch'];
   cloud?: CloudSetup;
   logger?: Logger;
   httpSetup?: HttpServiceSetup;
@@ -145,17 +144,17 @@ export class IngestManagerPlugin
   private cloud: CloudSetup | undefined;
   private logger: Logger | undefined;
 
-  private isProductionMode: boolean;
-  private kibanaVersion: string;
-  private kibanaBranch: string;
+  private isProductionMode: IngestManagerAppContext['isProductionMode'];
+  private kibanaVersion: IngestManagerAppContext['kibanaVersion'];
+  private kibanaBranch: IngestManagerAppContext['kibanaBranch'];
   private httpSetup: HttpServiceSetup | undefined;
   private encryptedSavedObjectsSetup: EncryptedSavedObjectsPluginSetup | undefined;
 
   constructor(private readonly initializerContext: PluginInitializerContext) {
     this.config$ = this.initializerContext.config.create<IngestManagerConfigType>();
     this.isProductionMode = this.initializerContext.env.mode.prod;
     this.kibanaVersion = this.initializerContext.env.packageInfo.version;
-    this.kibanaBranch = packageJSON.branch;
+    this.kibanaBranch = this.initializerContext.env.packageInfo.branch;
     this.logger = this.initializerContext.logger.get();
   }
 

x-pack/plugins/ingest_manager/server/services/app_context.ts

@@ -22,9 +22,9 @@ class AppContextService {
   private config$?: Observable<IngestManagerConfigType>;
   private configSubject$?: BehaviorSubject<IngestManagerConfigType>;
   private savedObjects: SavedObjectsServiceStart | undefined;
-  private isProductionMode: boolean = false;
-  private kibanaVersion: string | undefined;
-  private kibanaBranch: string | undefined;
+  private isProductionMode: IngestManagerAppContext['isProductionMode'] = false;
+  private kibanaVersion: IngestManagerAppContext['kibanaVersion'] | undefined;
+  private kibanaBranch: IngestManagerAppContext['kibanaBranch'] | undefined;
   private cloud?: CloudSetup;
   private logger: Logger | undefined;
   private httpSetup?: HttpServiceSetup;

x-pack/plugins/ingest_manager/server/services/epm/registry/registry_url.ts

@@ -3,26 +3,43 @@
  * or more contributor license agreements. Licensed under the Elastic License;
  * you may not use this file except in compliance with the Elastic License.
  */
-import { DEFAULT_REGISTRY_URL } from '../../../constants';
 import { appContextService, licenseService } from '../../';
 
+// from https://github.com/elastic/package-registry#docker (maybe from OpenAPI one day)
+// the unused variables cause a TS warning about unused values
+// chose to comment them out vs @ts-ignore or @ts-expect-error on each line
+
+const PRODUCTION_REGISTRY_URL_CDN = 'https://epr.elastic.co';
+// const STAGING_REGISTRY_URL_CDN = 'https://epr-staging.elastic.co';
+// const EXPERIMENTAL_REGISTRY_URL_CDN = 'https://epr-experimental.elastic.co/';
+const SNAPSHOT_REGISTRY_URL_CDN = 'https://epr-snapshot.elastic.co';
+
+// const PRODUCTION_REGISTRY_URL_NO_CDN = 'https://epr.ea-web.elastic.dev';
+// const STAGING_REGISTRY_URL_NO_CDN = 'https://epr-staging.ea-web.elastic.dev';
+// const EXPERIMENTAL_REGISTRY_URL_NO_CDN = 'https://epr-experimental.ea-web.elastic.dev/';
+// const SNAPSHOT_REGISTRY_URL_NO_CDN = 'https://epr-snapshot.ea-web.elastic.dev';
+
+const getDefaultRegistryUrl = (): string => {
+  const branch = appContextService.getKibanaBranch();
+  if (branch === 'master') {
+    return SNAPSHOT_REGISTRY_URL_CDN;
+  } else {
+    return PRODUCTION_REGISTRY_URL_CDN;
+  }
+};
+
 export const getRegistryUrl = (): string => {
   const license = licenseService.getLicenseInformation();
   const customUrl = appContextService.getConfig()?.registryUrl;
+  const isGoldPlus = license?.isAvailable && license?.isActive && license?.hasAtLeast('gold');
 
-  if (
-    customUrl &&
-    license &&
-    license.isAvailable &&
-    license.hasAtLeast('gold') &&
-    license.isActive
-  ) {
+  if (customUrl && isGoldPlus) {
     return customUrl;
   }
 
   if (customUrl) {
     appContextService.getLogger().warn('Gold license is required to use a custom registry url.');
   }
 
-  return DEFAULT_REGISTRY_URL;
+  return getDefaultRegistryUrl();
 };

x-pack/plugins/ingest_manager/server/services/index.ts

@@ -9,6 +9,8 @@ import { AgentStatus, Agent } from '../types';
 import * as settingsService from './settings';
 export { ESIndexPatternSavedObjectService } from './es_index_pattern';
 
+export { getRegistryUrl } from './epm/registry/registry_url';
+
 /**
  * Service to return the index pattern of EPM packages
  */

x-pack/test/security_solution_endpoint/apps/endpoint/index.ts

@@ -3,7 +3,7 @@
  * or more contributor license agreements. Licensed under the Elastic License;
  * you may not use this file except in compliance with the Elastic License.
  */
-import { DEFAULT_REGISTRY_URL } from '../../../../plugins/ingest_manager/common';
+import { getRegistryUrl as getRegistryUrlFromIngest } from '../../../../plugins/ingest_manager/server';
 import { FtrProviderContext } from '../../ftr_provider_context';
 import {
   isRegistryEnabled,
@@ -22,7 +22,7 @@ export default function (providerContext: FtrProviderContext) {
       log.warning('These tests are being run with an external package registry');
     }
 
-    const registryUrl = getRegistryUrl() ?? DEFAULT_REGISTRY_URL;
+    const registryUrl = getRegistryUrl() ?? getRegistryUrlFromIngest();
     log.info(`Package registry URL for tests: ${registryUrl}`);
 
     before(async () => {

x-pack/test/security_solution_endpoint_api_int/apis/index.ts

@@ -5,7 +5,7 @@
  */
 import { FtrProviderContext } from '../ftr_provider_context';
 import { isRegistryEnabled, getRegistryUrl } from '../registry';
-import { DEFAULT_REGISTRY_URL } from '../../../plugins/ingest_manager/common';
+import { getRegistryUrl as getRegistryUrlFromIngest } from '../../../plugins/ingest_manager/server';
 
 export default function endpointAPIIntegrationTests(providerContext: FtrProviderContext) {
   const { loadTestFile, getService } = providerContext;
@@ -20,7 +20,7 @@ export default function endpointAPIIntegrationTests(providerContext: FtrProvider
       log.warning('These tests are being run with an external package registry');
     }
 
-    const registryUrl = getRegistryUrl() ?? DEFAULT_REGISTRY_URL;
+    const registryUrl = getRegistryUrl() ?? getRegistryUrlFromIngest();
     log.info(`Package registry URL for tests: ${registryUrl}`);
 
     before(async () => {