fix: use new version of serverless functions api

packages/zip-it-and-ship-it/src/runtimes/node/index.ts

@@ -108,6 +108,7 @@ const zipFunction: ZipFunction = async function ({
 
   createPluginsModulesPathAliases(srcFiles, pluginsModulesPath, aliases, finalBasePath)
 
+  const generator = mergedConfig?.generator || getInternalValue(isInternal)
   const zipPath = await zipNodeJs({
     aliases,
     archiveFormat,
@@ -124,6 +125,7 @@ const zipFunction: ZipFunction = async function ({
     rewrites,
     runtimeAPIVersion,
     srcFiles,
+    generator,
   })
 
   await cleanupFunction?.()
@@ -153,7 +155,7 @@ const zipFunction: ZipFunction = async function ({
     config: mergedConfig,
     displayName: mergedConfig?.name,
     entryFilename: zipPath.entryFilename,
-    generator: mergedConfig?.generator || getInternalValue(isInternal),
+    generator,
     timeout: mergedConfig?.timeout,
     inputs,
     includedFiles,

packages/zip-it-and-ship-it/src/runtimes/node/utils/entry_file.test.ts

@@ -0,0 +1,41 @@
+import { test, expect } from 'vitest'
+
+import { getTelemetryFile, kebabCase } from './entry_file.js'
+
+test('kebab-case', () => {
+  expect(kebabCase('hello-world')).toBe('hello-world')
+  expect(kebabCase('hello World')).toBe('hello-world')
+  expect(kebabCase('--Hello--World--')).toBe('hello-world')
+  expect(kebabCase('Next.js Runtime')).toBe('next-js-runtime')
+  expect(kebabCase('@netlify/plugin-nextjs@14')).toBe('netlify-plugin-nextjs-14')
+  expect(kebabCase('CamelCaseShould_Be_transformed')).toBe('camel-case-should-be-transformed')
+  expect(kebabCase('multiple   spaces')).toBe('multiple-spaces')
+})
+
+test('getTelemetryFile should handle no defined generator', () => {
+  const telemetryFile = getTelemetryFile()
+  expect(telemetryFile.filename).toBe('___netlify-telemetry.mjs')
+  expect(telemetryFile.contents).toContain('var SERVICE_NAME = undefined;')
+  expect(telemetryFile.contents).toContain('var SERVICE_VERSION = undefined;')
+})
+
+test('getTelemetryFile should handle internalFunc generator', () => {
+  const telemetryFile = getTelemetryFile('internalFunc')
+  expect(telemetryFile.filename).toBe('___netlify-telemetry.mjs')
+  expect(telemetryFile.contents).toContain('var SERVICE_NAME = "internal-func";')
+  expect(telemetryFile.contents).toContain('var SERVICE_VERSION = undefined;')
+})
+
+test('getTelemetryFile should handle generator with version', () => {
+  const telemetryFile = getTelemetryFile('@netlify/plugin-nextjs@14.13.2')
+  expect(telemetryFile.filename).toBe('___netlify-telemetry.mjs')
+  expect(telemetryFile.contents).toContain('var SERVICE_NAME = "netlify-plugin-nextjs";')
+  expect(telemetryFile.contents).toContain('var SERVICE_VERSION = "14.13.2";')
+})
+
+test('getTelemetryFile should handle generator without version', () => {
+  const telemetryFile = getTelemetryFile('@netlify/plugin-nextjs')
+  expect(telemetryFile.filename).toBe('___netlify-telemetry.mjs')
+  expect(telemetryFile.contents).toContain('var SERVICE_NAME = "netlify-plugin-nextjs";')
+  expect(telemetryFile.contents).toContain('var SERVICE_VERSION = undefined;')
+})

packages/zip-it-and-ship-it/src/runtimes/node/utils/entry_file.ts

@@ -26,6 +26,20 @@ export interface EntryFile {
   filename: string
 }
 
+/**
+ * A minimal implementation of kebab-case.
+ * It is used to transform the generator name into a service name for the telemetry file.
+ * As DataDog has a special handling for the service name, we need to make sure it is kebab-case.
+ */
+export const kebabCase = (input: string): string =>
+  input
+    .replace(/([a-z])([A-Z])/g, '$1 $2')
+    .replace(/[@#//$\s_\\.-]+/g, ' ')
+    .trim()
+    .toLowerCase()
+    .split(' ')
+    .join('-')
+
 const getEntryFileContents = (
   mainPath: string,
   moduleFormat: string,
@@ -158,10 +172,33 @@ const getEntryFileName = ({
   return `${basename(filename, extname(filename))}${extension}`
 }
 
-export const getTelemetryFile = (): EntryFile => {
+export const getTelemetryFile = (generator?: string): EntryFile => {
   // TODO: switch with import.meta.resolve once we drop support for Node 16.x
   const filePath = require.resolve('@netlify/serverless-functions-api/instrumentation.js')
-  const contents = readFileSync(filePath, 'utf8')
+  let serviceName: string | undefined
+  let serviceVersion: string | undefined
+
+  if (generator) {
+    // the generator can be something like: `@netlify/plugin-nextjs@14.13.2`
+    // following the convention of name@version but it must not have a version.
+    // split the generator by the @ sign to separate name and version.
+    // pop the last part (the version) and join the rest with a @ again.
+    const versionSepPos = generator.lastIndexOf('@')
+    if (versionSepPos > 1) {
+      const name = generator.substring(0, versionSepPos)
+      const version = generator.substring(versionSepPos + 1)
+      serviceVersion = version
+      serviceName = kebabCase(name)
+    } else {
+      serviceName = kebabCase(generator)
+    }
+  }
+
+  const contents = `
+var SERVICE_NAME = ${JSON.stringify(serviceName)};
+var SERVICE_VERSION = ${JSON.stringify(serviceVersion)};
+${readFileSync(filePath, 'utf8')}
+`
 
   return {
     contents,

packages/zip-it-and-ship-it/src/runtimes/node/utils/zip.ts

@@ -54,6 +54,7 @@ interface ZipNodeParameters {
   rewrites?: Map<string, string>
   runtimeAPIVersion: number
   srcFiles: string[]
+  generator?: string
 }
 
 const addBootstrapFile = function (srcFiles: string[], aliases: Map<string, string>) {
@@ -188,6 +189,7 @@ const createZipArchive = async function ({
   rewrites,
   runtimeAPIVersion,
   srcFiles,
+  generator,
 }: ZipNodeParameters) {
   const destPath = join(destFolder, `${basename(filename, extension)}.zip`)
   const { archive, output } = startZip(destPath)
@@ -233,7 +235,7 @@ const createZipArchive = async function ({
 
     addEntryFileToZip(archive, entryFile)
   }
-  const telemetryFile = getTelemetryFile()
+  const telemetryFile = getTelemetryFile(generator)
 
   if (featureFlags.zisi_add_instrumentation_loader === true) {
     addEntryFileToZip(archive, telemetryFile)
@@ -268,7 +270,10 @@ const createZipArchive = async function ({
 export const zipNodeJs = function ({
   archiveFormat,
   ...options
-}: ZipNodeParameters & { archiveFormat: ArchiveFormat }): Promise<{ path: string; entryFilename: string }> {
+}: ZipNodeParameters & { archiveFormat: ArchiveFormat }): Promise<{
+  path: string
+  entryFilename: string
+}> {
   if (archiveFormat === ARCHIVE_FORMAT.ZIP) {
     return createZipArchive(options)
   }

packages/zip-it-and-ship-it/vitest.config.ts

@@ -5,7 +5,7 @@ import { defineConfig } from 'vitest/config'
 export default defineConfig({
   test: {
     setupFiles: ['./tests/helpers/vitest_setup.ts'],
-    include: ['tests/**/*.test.ts'],
+    include: ['tests/**/*.test.ts', 'src/**/*.test.ts'],
     testTimeout: 90_000,
     deps: {
       // Disable vitest handling of imports to these paths, especially the tmpdir is important as we extract functions to there