feat: support grpc plugins with ts and bun

cli/src/commands/router/commands/plugin/commands/build.ts

@@ -6,12 +6,12 @@ import Spinner from 'ora';
 import { BaseCommandOptions } from '../../../../../core/types/types.js';
 import { renderResultTree } from '../helper.js';
 import {
-  buildBinaries,
+  buildGoBinaries,
   checkAndInstallTools,
   generateGRPCCode,
-  generateProtoAndMapping,
-  HOST_PLATFORM,
-  installGoDependencies,
+  generateProtoAndMapping, getLanguage,
+  getHostPlatform,
+  installGoDependencies, installTsDependencies, buildTsBinaries,
   normalizePlatforms,
 } from '../toolchain.js';
 
@@ -21,9 +21,7 @@ export default (opts: BaseCommandOptions) => {
   command.argument('[directory]', 'Directory of the plugin', '.');
   command.option('--generate-only', 'Generate only the proto and mapping files, do not compile the plugin');
   command.option('--debug', 'Build the binary with debug information', false);
-  command.option('--platform [platforms...]', 'Platform-architecture combinations (e.g., darwin-arm64 linux-amd64)', [
-    HOST_PLATFORM,
-  ]);
+  command.option('--platform [platforms...]', 'Platform-architecture combinations (e.g., darwin-arm64 linux-amd64)', []);
   command.option('--all-platforms', 'Build for all supported platforms', false);
   command.option('--skip-tools-installation', 'Skip tool installation', false);
   command.option(
@@ -46,29 +44,44 @@ export default (opts: BaseCommandOptions) => {
     let platforms: string[] = [];
 
     try {
+      const language = getLanguage(pluginDir)
+
       // Check and install tools if needed
       if (!options.skipToolsInstallation) {
         await checkAndInstallTools(options.forceToolsInstallation);
       }
 
-      // Normalize platform list
-      platforms = normalizePlatforms(options.platform, options.allPlatforms);
-
       // Start the main build process
       spinner.start('Building plugin...');
 
+      switch (language) {
+        case 'ts': {
+          await installTsDependencies(pluginDir, spinner);
+          break;
+        }
+      }
+
+      // Normalize platform list
+      platforms = normalizePlatforms(options.platform, options.allPlatforms, language);
+
       // Generate proto and mapping files
       await generateProtoAndMapping(pluginDir, goModulePath, spinner);
 
       // Generate gRPC code
-      await generateGRPCCode(pluginDir, spinner);
+      await generateGRPCCode(pluginDir, spinner, language);
 
       if (!options.generateOnly) {
-        // Install Go dependencies
-        await installGoDependencies(pluginDir, spinner);
-
-        // Build binaries for all platforms
-        await buildBinaries(pluginDir, platforms, options.debug, spinner);
+        switch (language) {
+          case 'go': {
+            await installGoDependencies(pluginDir, spinner);
+            await buildGoBinaries(pluginDir, platforms, options.debug, spinner);
+            break;
+          }
+          case 'ts': {
+            await buildTsBinaries(pluginDir, platforms, options.debug, spinner);
+            break;
+          }
+        }
       }
 
       // Calculate and format elapsed time

cli/src/commands/router/commands/plugin/commands/generate.ts

@@ -8,8 +8,8 @@ import { renderResultTree } from '../helper.js';
 import {
   checkAndInstallTools,
   generateGRPCCode,
-  generateProtoAndMapping,
-  installGoDependencies,
+  generateProtoAndMapping, getLanguage,
+  installGoDependencies, installTsDependencies,
 } from '../toolchain.js';
 
 export default (opts: BaseCommandOptions) => {
@@ -36,22 +36,35 @@ export default (opts: BaseCommandOptions) => {
     const goModulePath = options.goModulePath;
 
     try {
+      const language = getLanguage(pluginDir)
+
       // Check and install tools if needed
       if (!options.skipToolsInstallation) {
         await checkAndInstallTools(options.forceToolsInstallation);
       }
 
+      switch (language) {
+        case 'ts': {
+          await installTsDependencies(pluginDir, spinner);
+          break;
+        }
+      }
+
       // Start the generation process
       spinner.start('Generating plugin code...');
 
       // Generate proto and mapping files
       await generateProtoAndMapping(pluginDir, goModulePath, spinner);
 
       // Generate gRPC code
-      await generateGRPCCode(pluginDir, spinner);
+      await generateGRPCCode(pluginDir, spinner, language);
 
-      // Install Go dependencies
-      await installGoDependencies(pluginDir, spinner);
+      switch (language) {
+        case 'go': {
+          await installGoDependencies(pluginDir, spinner);
+          break;
+        }
+      }
 
       // Calculate and format elapsed time
       const endTime = performance.now();

cli/src/commands/router/commands/plugin/commands/init.ts

@@ -12,6 +12,8 @@ import { camelCase, upperFirst } from 'lodash-es';
 import { BaseCommandOptions } from '../../../../../core/types/types.js';
 import PluginTemplates from '../templates/plugin.js';
 import ProjectTemplates from '../templates/project.js';
+import GoTemplates from '../templates/goplugin.js';
+import TsTemplates from '../templates/tsplugin.js';
 import { renderResultTree } from '../helper.js';
 
 export default (opts: BaseCommandOptions) => {
@@ -59,36 +61,44 @@ export default (opts: BaseCommandOptions) => {
 
       spinner.text = 'Checkout templates...';
 
-      if (options.language.toLowerCase() !== 'go') {
+      options.language = options.language.toLowerCase();
+      if (options.language !== 'go' || options.language !== 'ts') {
         spinner.fail(pc.yellow(`Language '${options.language}' is not supported yet. Using 'go' instead.`));
-        options.language = 'go';
       }
 
       const goModulePath = 'github.com/wundergraph/cosmo/plugin';
 
       spinner.text = 'Generating mapping and proto files...';
 
+      await writeFile(resolve(srcDir, 'schema.graphql'), pupa(PluginTemplates.schema, { name }));
+      const mapping = compileGraphQLToMapping(PluginTemplates.schema, serviceName);
+      await writeFile(resolve(generatedDir, 'mapping.json'), JSON.stringify(mapping, null, 2));
+      await writeFile(resolve(tempDir, 'Makefile'), pupa(PluginTemplates.makefile, { originalPluginName }));
+
+      await writeFile(resolve(tempDir, '.gitignore'), PluginTemplates.gitignore);
+      await writeFile(resolve(tempDir, '.cursorignore'), PluginTemplates.cursorIgnore);
+
+      const proto = compileGraphQLToProto(PluginTemplates.schema, { serviceName, packageName: 'service', goPackage: goModulePath });
+      await writeFile(resolve(generatedDir, 'service.proto'), proto.proto);
+      await writeFile(resolve(generatedDir, 'service.proto.lock.json'), JSON.stringify(proto.lockData, null, 2));
+
+      switch (options.language) {
+        case 'go': {
+          await writeFile(resolve(srcDir, 'main.go'), pupa(GoTemplates.mainGo, { serviceName }));
+          await writeFile(resolve(srcDir, 'main_test.go'), pupa(GoTemplates.mainGoTest, { serviceName }));
+          await writeFile(resolve(tempDir, 'go.mod'), pupa(PluginTemplates.goMod, { modulePath: goModulePath }));
+          break;
+        }
+        case 'ts': {
+          await writeFile(resolve(srcDir, 'plugin.ts'), pupa(TsTemplates.pluginTs, { serviceName }));
+          await writeFile(resolve(srcDir, 'client.ts'), pupa(TsTemplates.clientTs, { serviceName }));
+          await writeFile(resolve(tempDir, 'package.json'), pupa(TsTemplates.packageJson, { serviceName }));
+        }
+      }
+      // Language Specific
+
       if (options.project) {
         await writeFile(resolve(tempDir, 'README.md'), pupa(ProjectTemplates.readme, { name, originalPluginName }));
-        await writeFile(resolve(srcDir, 'schema.graphql'), pupa(PluginTemplates.schema, { name }));
-
-        const mapping = compileGraphQLToMapping(PluginTemplates.schema, serviceName);
-        await writeFile(resolve(generatedDir, 'mapping.json'), JSON.stringify(mapping, null, 2));
-
-        const proto = compileGraphQLToProto(PluginTemplates.schema, {
-          serviceName,
-          packageName: 'service',
-          goPackage: goModulePath,
-        });
-
-        await writeFile(resolve(generatedDir, 'service.proto'), proto.proto);
-        await writeFile(resolve(generatedDir, 'service.proto.lock.json'), JSON.stringify(proto.lockData, null, 2));
-        await writeFile(resolve(srcDir, 'main.go'), pupa(PluginTemplates.mainGo, { serviceName }));
-        await writeFile(resolve(srcDir, 'main_test.go'), pupa(PluginTemplates.mainGoTest, { serviceName }));
-        await writeFile(resolve(tempDir, 'go.mod'), pupa(PluginTemplates.goMod, { modulePath: goModulePath }));
-        await writeFile(resolve(tempDir, 'Makefile'), pupa(PluginTemplates.makefile, { originalPluginName }));
-        await writeFile(resolve(tempDir, '.gitignore'), PluginTemplates.gitignore);
-        await writeFile(resolve(tempDir, '.cursorignore'), PluginTemplates.cursorIgnore);
 
         // Create cursor rules in .cursor/rules
         await mkdir(resolve(tempDir, '.cursor', 'rules'), { recursive: true });
@@ -115,11 +125,6 @@ export default (opts: BaseCommandOptions) => {
         await rename(tempDir, pluginDir);
       } else {
         await writeFile(resolve(tempDir, 'README.md'), pupa(PluginTemplates.readme, { name, originalPluginName }));
-        await writeFile(resolve(tempDir, 'Makefile'), pupa(PluginTemplates.makefile, { originalPluginName }));
-        await writeFile(resolve(srcDir, 'schema.graphql'), pupa(PluginTemplates.schema, { name }));
-
-        const mapping = compileGraphQLToMapping(PluginTemplates.schema, serviceName);
-        await writeFile(resolve(generatedDir, 'mapping.json'), JSON.stringify(mapping, null, 2));
 
         // Create cursor rules in .cursor/rules
         await mkdir(resolve(tempDir, '.cursor', 'rules'), { recursive: true });
@@ -128,22 +133,7 @@ export default (opts: BaseCommandOptions) => {
           pupa(PluginTemplates.cursorRules, { name, originalPluginName, pluginDir }),
         );
 
-        const proto = compileGraphQLToProto(PluginTemplates.schema, {
-          serviceName,
-          packageName: 'service',
-          goPackage: goModulePath,
-        });
-
-        await writeFile(resolve(generatedDir, 'service.proto'), proto.proto);
-        await writeFile(resolve(generatedDir, 'service.proto.lock.json'), JSON.stringify(proto.lockData, null, 2));
-        await writeFile(resolve(srcDir, 'main.go'), pupa(PluginTemplates.mainGo, { serviceName }));
-        await writeFile(resolve(srcDir, 'main_test.go'), pupa(PluginTemplates.mainGoTest, { serviceName }));
-        await writeFile(resolve(tempDir, 'go.mod'), pupa(PluginTemplates.goMod, { modulePath: goModulePath }));
-        await writeFile(resolve(tempDir, '.gitignore'), PluginTemplates.gitignore);
-        await writeFile(resolve(tempDir, '.cursorignore'), PluginTemplates.cursorIgnore);
-
         await mkdir(projectDir, { recursive: true });
-
         await rename(tempDir, pluginDir);
       }