refactor(cubesql): Use correct naming for checkSqlAuth

Author: ovr

packages/cubejs-api-gateway/src/sql-server.ts

@@ -107,10 +107,9 @@ export class SQLServer {
     this.sqlInterfaceInstance = await registerInterface({
       gatewayPort: this.gatewayPort,
       pgPort: options.pgSqlPort,
-      checkAuth: async ({ request, user, password }) => {
+      checkSqlAuth: async ({ request, user, password }) => {
         const { password: returnedPassword, superuser, securityContext, skipPasswordCheck } = await checkSqlAuth(request, user, password);
 
-        // Strip securityContext to improve speed deserialization
         return {
           password: returnedPassword,
           superuser: superuser || false,

packages/cubejs-backend-native/js/index.ts

@@ -88,7 +88,7 @@ export interface CanSwitchUserPayload {
 
 export type SQLInterfaceOptions = {
   pgPort?: number,
-  checkAuth: (payload: CheckAuthPayload) => CheckAuthResponse | Promise<CheckAuthResponse>,
+  checkSqlAuth: (payload: CheckAuthPayload) => CheckAuthResponse | Promise<CheckAuthResponse>,
   load: (payload: LoadPayload) => unknown | Promise<unknown>,
   sql: (payload: SqlPayload) => unknown | Promise<unknown>,
   meta: (payload: MetaPayload) => unknown | Promise<unknown>,
@@ -347,8 +347,8 @@ export const registerInterface = async (options: SQLInterfaceOptions): Promise<S
     throw new Error('Argument options must be an object');
   }
 
-  if (typeof options.checkAuth !== 'function') {
-    throw new Error('options.checkAuth must be a function');
+  if (typeof options.checkSqlAuth !== 'function') {
+    throw new Error('options.checkSqlAuth must be a function');
   }
 
   if (typeof options.load !== 'function') {
@@ -378,7 +378,7 @@ export const registerInterface = async (options: SQLInterfaceOptions): Promise<S
   const native = loadNative();
   return native.registerInterface({
     ...options,
-    checkAuth: wrapNativeFunctionWithChannelCallback(options.checkAuth),
+    checkSqlAuth: wrapNativeFunctionWithChannelCallback(options.checkSqlAuth),
     load: wrapNativeFunctionWithChannelCallback(options.load),
     sql: wrapNativeFunctionWithChannelCallback(options.sql),
     meta: wrapNativeFunctionWithChannelCallback(options.meta),

packages/cubejs-backend-native/test/sql.test.ts

@@ -103,8 +103,8 @@ function interfaceMethods() {
         dataSourceToSqlGenerator: {},
       };
     }),
-    checkAuth: jest.fn(async ({ request, user }) => {
-      console.log('[js] checkAuth', {
+    checkSqlAuth: jest.fn(async ({ request, user }) => {
+      console.log('[js] checkSqlAuth', {
         request,
         user,
       });
@@ -146,7 +146,7 @@ describe('SQLInterface', () => {
 
   it('SHOW FULL TABLES FROM `db`', async () => {
     const methods = interfaceMethods();
-    const { checkAuth, meta } = methods;
+    const { checkSqlAuth, meta } = methods;
 
     const instance = await native.registerInterface({
       pgPort: 5555,
@@ -178,9 +178,9 @@ describe('SQLInterface', () => {
           );
         }
 
-        console.log(checkAuth.mock.calls);
-        expect(checkAuth.mock.calls.length).toEqual(1);
-        expect(checkAuth.mock.calls[0][0]).toEqual({
+        console.log(checkSqlAuth.mock.calls);
+        expect(checkSqlAuth.mock.calls.length).toEqual(1);
+        expect(checkSqlAuth.mock.calls[0][0]).toEqual({
           request: {
             id: expect.any(String),
             meta: null,
@@ -195,19 +195,19 @@ describe('SQLInterface', () => {
         user: 'random user',
         password: undefined,
       });
-      checkAuth.mockClear();
+      checkSqlAuth.mockClear();
 
       await testConnectionFailed({
         user: 'allowed_user',
         password: undefined,
       });
-      checkAuth.mockClear();
+      checkSqlAuth.mockClear();
 
       await testConnectionFailed({
         user: 'allowed_user',
         password: 'wrong_password',
       });
-      checkAuth.mockClear();
+      checkSqlAuth.mockClear();
 
       const connection = new Client({
         host: '127.0.0.1',
@@ -236,8 +236,8 @@ describe('SQLInterface', () => {
         ]);
       }
 
-      expect(checkAuth.mock.calls.length).toEqual(1);
-      expect(checkAuth.mock.calls[0][0]).toEqual({
+      expect(checkSqlAuth.mock.calls.length).toEqual(1);
+      expect(checkSqlAuth.mock.calls[0][0]).toEqual({
         request: {
           id: expect.any(String),
           meta: null,