[Fleet] Simplify skipArchive behaviour for input packages

x-pack/plugins/fleet/server/services/epm/packages/get.test.ts

@@ -188,6 +188,10 @@ describe('When using EPM `get` services', () => {
         name: 'my-package',
         version: '1.0.0',
       } as RegistryPackage);
+      MockRegistry.fetchInfo.mockResolvedValue({
+        name: 'my-package',
+        version: '1.0.0',
+      } as RegistryPackage);
       MockRegistry.getPackage.mockResolvedValue({
         paths: [],
         packageInfo: {

x-pack/plugins/fleet/server/services/epm/packages/get.ts

@@ -152,13 +152,12 @@ export async function getPackageInfo({
   // If same version is available in registry and skipArchive is true, use the info from the registry (faster),
   // otherwise build it from the archive
   let paths: string[];
-  let packageInfo: RegistryPackage | ArchivePackage | undefined = skipArchive
-    ? await Registry.fetchInfo(pkgName, resolvedPkgVersion).catch(() => undefined)
-    : undefined;
-
+  const registryInfo = await Registry.fetchInfo(pkgName, resolvedPkgVersion).catch(() => undefined);
+  let packageInfo;
   // We need to get input only packages from source to get all fields
   // see https://github.com/elastic/package-registry/issues/864
-  if (packageInfo && packageInfo.type !== 'input') {
+  if (registryInfo && skipArchive && registryInfo.type !== 'input') {
+    packageInfo = registryInfo;
     // Fix the paths
     paths =
       packageInfo.assets?.map((path) =>
@@ -293,7 +292,7 @@ export async function getPackageFromSource(options: {
     }
   } else {
     res = await Registry.getPackage(pkgName, pkgVersion, { ignoreUnverified });
-    logger.debug(`retrieved uninstalled package ${pkgName}-${pkgVersion}`);
+    logger.debug(`retrieved package ${pkgName}-${pkgVersion} from registry`);
   }
   if (!res) {
     throw new FleetError(`package info for ${pkgName}-${pkgVersion} does not exist`);

x-pack/plugins/fleet/server/services/epm/registry/index.ts

@@ -265,7 +265,9 @@ async function getPackageInfoFromArchiveOrCache(
       archiveBuffer,
       ensureContentType(archivePath)
     );
-    setPackageInfo({ packageInfo, name, version });
+    // set the download URL as it isn't contained in the manifest
+    // this allows us to re-download the archive during package install
+    setPackageInfo({ packageInfo: { ...packageInfo, download: archivePath }, name, version });
     return packageInfo;
   } else {
     return cachedInfo;

x-pack/test/fleet_api_integration/apis/epm/get.ts

@@ -144,6 +144,18 @@ export default function (providerContext: FtrProviderContext) {
       expect(packageInfo.name).to.equal('apache');
       await uninstallPackage(testPkgName, testPkgVersion);
     });
+    it('should return all fields for input only packages', async function () {
+      // input packages have to get their package info from the manifest directly
+      // not from the package registry. This is because they contain a field the registry
+      // does not support
+      const res = await supertest
+        .get(`/api/fleet/epm/packages/integration_to_input/0.9.1`)
+        .expect(200);
+
+      const packageInfo = res.body.item;
+      expect(packageInfo.policy_templates.length).to.equal(1);
+      expect(packageInfo.policy_templates[0].vars).not.to.be(undefined);
+    });
     describe('Pkg verification', () => {
       it('should return validation error for unverified input only pkg', async function () {
         const res = await supertest.get(`/api/fleet/epm/packages/input_only/0.1.0`).expect(400);

x-pack/test/fleet_api_integration/apis/package_policy/create.ts

@@ -446,6 +446,72 @@ export default function (providerContext: FtrProviderContext) {
       expect(policy.name).to.equal(nameWithWhitespace.trim());
     });
 
+    describe('input only packages', () => {
+      it('should return 400 if dataset not provided for input only pkg', async function () {
+        await supertest
+          .post(`/api/fleet/package_policies`)
+          .set('kbn-xsrf', 'xxxx')
+          .send({
+            policy_id: agentPolicyId,
+            package: {
+              name: 'integration_to_input',
+              version: '0.9.1',
+            },
+            name: 'integration_to_input-1',
+            description: '',
+            namespace: 'default',
+            inputs: {
+              'logs-logfile': {
+                enabled: true,
+                streams: {
+                  'integration_to_input.logs': {
+                    enabled: true,
+                    vars: {
+                      paths: ['/tmp/test.log'],
+                      tags: ['tag1'],
+                      ignore_older: '72h',
+                    },
+                  },
+                },
+              },
+            },
+          })
+          .expect(400);
+      });
+      it('should successfully create an input only package policy with all required vars', async function () {
+        await supertest
+          .post(`/api/fleet/package_policies`)
+          .set('kbn-xsrf', 'xxxx')
+          .send({
+            policy_id: agentPolicyId,
+            package: {
+              name: 'integration_to_input',
+              version: '0.9.1',
+            },
+            name: 'integration_to_input-2',
+            description: '',
+            namespace: 'default',
+            inputs: {
+              'logs-logfile': {
+                enabled: true,
+                streams: {
+                  'integration_to_input.logs': {
+                    enabled: true,
+                    vars: {
+                      paths: ['/tmp/test.log'],
+                      tags: ['tag1'],
+                      ignore_older: '72h',
+                      'data_stream.dataset': 'generic',
+                    },
+                  },
+                },
+              },
+            },
+          })
+          .expect(200);
+      });
+    });
+
     describe('Simplified package policy', () => {
       it('should work with valid values', async () => {
         await supertest