merge: sync upstream bytebase/dbhub main (0.21.1)

Upstream changes:
- Make @aws-sdk/rds-signer and @azure/identity optional (bytebase#298)
- Fix PostgreSQL view comments in getTableComment() (bytebase#297)
- Version bump 0.21.0 → 0.21.1

Conflicts resolved: README.md, package.json, server.json, tsup.config.ts
(kept dbhub-analytics branding, merged upstream code changes)

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: amansingh63

frontend/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@dbhub-analytics/frontend",
   "private": true,
-  "version": "0.21.0",
+  "version": "0.21.1",
   "type": "module",
   "scripts": {
     "dev": "vite",

package.json

@@ -40,8 +40,6 @@
   "author": "amansingh63",
   "license": "MIT",
   "dependencies": {
-    "@aws-sdk/rds-signer": "^3.1001.0",
-    "@azure/identity": "^4.8.0",
     "@iarna/toml": "^2.2.5",
     "@modelcontextprotocol/sdk": "^1.25.1",
     "dotenv": "^16.4.7",
@@ -51,6 +49,8 @@
     "zod": "^3.24.2"
   },
   "optionalDependencies": {
+    "@aws-sdk/rds-signer": "^3.1001.0",
+    "@azure/identity": "^4.8.0",
     "@databricks/sql": "^1.13.0",
     "@google-cloud/bigquery": "^8.1.1",
     "better-sqlite3": "^11.9.0",

src/connectors/__tests__/postgres.integration.test.ts

@@ -167,6 +167,12 @@ class PostgreSQLIntegrationTest extends IntegrationTestBase<PostgreSQLTestContai
       ON CONFLICT DO NOTHING
     `, {});
 
+    // Create a view with a comment (for view comment test)
+    await connector.executeSQL(`
+      CREATE OR REPLACE VIEW active_users AS SELECT id, name, email FROM users WHERE age >= 25
+    `, {});
+    await connector.executeSQL(`COMMENT ON VIEW active_users IS 'Users aged 25 or older'`, {});
+
     // Create test stored procedures using SQL language to avoid dollar quoting
     await connector.executeSQL(`
       CREATE OR REPLACE FUNCTION get_user_count()
@@ -245,6 +251,11 @@ describe('PostgreSQL Connector Integration Tests', () => {
       expect(result.rows[0].array_val).toBeDefined();
     });
 
+    it('should return comment for views via getTableComment', async () => {
+      const comment = await postgresTest.connector.getTableComment!('active_users');
+      expect(comment).toBe('Users aged 25 or older');
+    });
+
     it('should handle PostgreSQL returning clause', async () => {
       const result = await postgresTest.connector.executeSQL(
         "INSERT INTO users (name, email, age) VALUES ('Returning Test', 'returning@example.com', 40) RETURNING id, name",

src/connectors/postgres/index.ts

@@ -382,7 +382,7 @@ export class PostgresConnector implements Connector {
         JOIN pg_catalog.pg_namespace n ON n.oid = c.relnamespace
         WHERE c.relname = $1
         AND n.nspname = $2
-        AND c.relkind IN ('r','p','m','f')
+        AND c.relkind IN ('r','p','m','f','v')
       `,
         [tableName, schemaToUse]
       );

src/connectors/sqlserver/index.ts

@@ -11,7 +11,7 @@ import {
   ExecuteOptions,
   ConnectorConfig,
 } from "../interface.js";
-import { DefaultAzureCredential } from "@azure/identity";
+import { isDriverNotInstalled } from "../../utils/module-loader.js";
 import { SafeURL } from "../../utils/safe-url.js";
 import { obfuscateDSNPassword } from "../../utils/dsn-obfuscate.js";
 import { SQLRowLimiter } from "../../utils/sql-row-limiter.js";
@@ -94,6 +94,17 @@ export class SQLServerDSNParser implements DSNParser {
       // Handle authentication types
       switch (options.authentication) {
         case "azure-active-directory-access-token": {
+          let DefaultAzureCredential: typeof import("@azure/identity")["DefaultAzureCredential"];
+          try {
+            ({ DefaultAzureCredential } = await import("@azure/identity"));
+          } catch (importError) {
+            if (isDriverNotInstalled(importError, "@azure/identity")) {
+              throw new Error(
+                'Azure AD authentication requires the "@azure/identity" package. Install it with: pnpm add @azure/identity'
+              );
+            }
+            throw importError;
+          }
           try {
             const credential = new DefaultAzureCredential();
             const token = await credential.getToken("https://database.windows.net/");

src/utils/__tests__/aws-rds-signer-missing.test.ts

@@ -0,0 +1,22 @@
+import { describe, it, expect } from 'vitest';
+import { isDriverNotInstalled } from '../module-loader.js';
+
+describe('isDriverNotInstalled with scoped packages', () => {
+  it('should match ERR_MODULE_NOT_FOUND for @aws-sdk/rds-signer', () => {
+    const err = new Error(
+      "Cannot find package '@aws-sdk/rds-signer' imported from /fake/path"
+    );
+    (err as NodeJS.ErrnoException).code = 'ERR_MODULE_NOT_FOUND';
+
+    expect(isDriverNotInstalled(err, '@aws-sdk/rds-signer')).toBe(true);
+  });
+
+  it('should not match unrelated ERR_MODULE_NOT_FOUND errors', () => {
+    const err = new Error(
+      "Cannot find package 'some-other-pkg' imported from /fake/path"
+    );
+    (err as NodeJS.ErrnoException).code = 'ERR_MODULE_NOT_FOUND';
+
+    expect(isDriverNotInstalled(err, '@aws-sdk/rds-signer')).toBe(false);
+  });
+});

src/utils/aws-rds-signer.ts

@@ -1,4 +1,4 @@
-import { Signer } from "@aws-sdk/rds-signer";
+import { isDriverNotInstalled } from "./module-loader.js";
 
 export interface RdsAuthTokenParams {
   hostname: string;
@@ -13,6 +13,18 @@ export interface RdsAuthTokenParams {
  * (AWS CLI profile, env vars, instance role, etc.).
  */
 export async function generateRdsAuthToken(params: RdsAuthTokenParams): Promise<string> {
+  let Signer: typeof import("@aws-sdk/rds-signer")["Signer"];
+  try {
+    ({ Signer } = await import("@aws-sdk/rds-signer"));
+  } catch (error) {
+    if (isDriverNotInstalled(error, "@aws-sdk/rds-signer")) {
+      throw new Error(
+        'AWS IAM authentication requires the "@aws-sdk/rds-signer" package. Install it with: pnpm add @aws-sdk/rds-signer'
+      );
+    }
+    throw error;
+  }
+
   const signer = new Signer({
     hostname: params.hostname,
     port: params.port,

tsup.config.ts

@@ -8,10 +8,13 @@ export default defineConfig({
   dts: true,
   clean: true,
   outDir: 'dist',
-  // Database drivers are optionalDependencies loaded at runtime via dynamic
-  // import(). They must be external so tsup does not bundle their CJS code
-  // into ESM chunks (which causes "Dynamic require of X is not supported").
-  external: ['pg', 'mysql2', 'mariadb', 'mssql', 'better-sqlite3', '@databricks/sql', '@google-cloud/bigquery'],
+  // Optional runtime-loaded dependencies (database drivers and cloud auth
+  // packages) are declared as optionalDependencies and loaded via dynamic
+  // import(). Database drivers must be external so tsup does not bundle their
+  // CJS code into ESM chunks (which causes "Dynamic require of X is not
+  // supported"). Cloud auth packages are externalized to keep their large
+  // dependency trees out of the bundle.
+  external: ['pg', 'mysql2', 'mariadb', 'mssql', 'better-sqlite3', '@databricks/sql', '@google-cloud/bigquery', '@aws-sdk/rds-signer', '@azure/identity'],
   // Copy the employee-sqlite demo data to dist
   async onSuccess() {
     // Create target directory