Files
supabase/apps/studio/components/ui/AIAssistantPanel/AIAssistant.utils.ts
Joshen Lim 225d461381 Hook up RLS to new assistant if feature flag is enabled (#30357)
* Hook up RLS to new assistant if feature flag is enabled

* Reset conversation if opening a different entity

* Add prompt to use alter policy if policy definition is provided

* Remove console log
2024-11-08 18:03:30 +08:00

185 lines
5.3 KiB
TypeScript

import { CommonDatabaseEntity } from 'state/app-state'
import { SupportedAssistantEntities, SupportedAssistantQuickPromptTypes } from './AIAssistant.types'
const PLACEHOLDER_PREFIX = `-- Press tab to use this code
\n \n`
const PLACEHOLDER_LIMIT = `Just three examples will do.`
export const generateTitle = (
editor?: SupportedAssistantEntities | null,
entity?: CommonDatabaseEntity
) => {
switch (editor) {
case 'functions':
if (entity === undefined) return 'Create a new function'
else return `Edit function: ${entity.name}`
case 'rls-policies':
if (entity === undefined) return 'Create a new RLS policy'
else return `Edit RLS policy: ${entity.name}`
default:
return 'SQL Scratch Pad'
}
}
export const generateCTA = (editor?: SupportedAssistantEntities | null) => {
switch (editor) {
case 'functions':
return 'Save function'
case 'rls-policies':
return 'Save policy'
default:
return 'Run query'
}
}
export const generatePlaceholder = (
editor?: SupportedAssistantEntities | null,
entity?: CommonDatabaseEntity,
existingDefinition?: string
) => {
switch (editor) {
case 'functions':
if (entity === undefined) {
return `${PLACEHOLDER_PREFIX}
CREATE FUNCTION *schema*.*function_name*(*param1 type*, *param2 type*)\n
  RETURNS *return_type*\n
  LANGUAGE *plpgsql*\n
  SECURITY DEFINER\n
  SET *search_path = ''*\n
AS $$\n
DECLARE\n
  *-- Variable declarations*\n
BEGIN\n
  *-- Function logic*\n
END;\n
$$;
`
} else {
return `${PLACEHOLDER_PREFIX}
-- To rename the function\n
ALTER FUNCTION *${entity.name}* RENAME TO *new_name*;\n
 \n
-- To change the schema of the function\n
ALTER FUNCTION *${entity.name}* SET SCHEMA *new_schema*;\n
 \n
-- To update the function body or the arguments, use\n
-- the create or replace statement instead\n
${existingDefinition
?.replaceAll(
'\n ',
`\n\
  `
)
.replaceAll('\n', '\n\n')
.trim()}
`
}
case 'rls-policies':
if (entity === undefined) {
return `${PLACEHOLDER_PREFIX}
CREATE POLICY *name* ON *table_name*\n
AS PERMISSIVE -- PERMISSIVE | RESTRICTIVE\n
FOR ALL -- ALL | SELECT | INSERT | UPDATE | DELETE\n
TO *role_name* -- Default: public\n
USING ( *using_expression* )\n
WITH CHECK ( *check_expression* );
`
} else {
let expression = ''
if (entity.definition !== null && entity.definition !== undefined) {
expression += `USING ( *${entity.definition}* )${
entity.check === null || entity.check === undefined ? ';' : ''
}\n`
}
if (entity.check !== null && entity.check !== undefined) {
expression += `WITH CHECK ( *${entity.check}* );\n`
}
return `${PLACEHOLDER_PREFIX}
BEGIN;\n
 \n
-- To update your policy definition\n
ALTER POLICY "${entity.name}"\n
ON "${entity.schema}"."${entity.table}"\n
TO *${(entity.roles ?? []).join(', ')}*\n
${expression}
 \n
-- To rename the policy\n
ALTER POLICY "${entity.name}"\n
ON "${entity.schema}"."${entity.table}"\n
RENAME TO "*New Policy Name*";\n
 \n
COMMIT;
`
}
default:
return undefined
}
}
export const retrieveDocsUrl = (editor?: SupportedAssistantEntities | null) => {
switch (editor) {
case 'functions':
return 'https://supabase.com/docs/guides/database/functions'
case 'rls-policies':
return 'https://supabase.com/docs/guides/database/postgres/row-level-security'
default:
return undefined
}
}
// [Joshen] This is just very basic validation, but possible can extend perhaps
export const validateQuery = (editor: SupportedAssistantEntities | null, query: string) => {
const formattedQuery = query.toLowerCase().replaceAll('\n', ' ')
switch (editor) {
case 'functions':
return (
formattedQuery.includes('create function') ||
formattedQuery.includes('create or replace function')
)
case 'rls-policies':
return formattedQuery.includes('create policy') || formattedQuery.includes('alter policy')
default:
return true
}
}
export const generatePrompt = ({
type,
context,
schemas,
tables,
}: {
type: SupportedAssistantQuickPromptTypes
context: SupportedAssistantEntities
schemas: string[]
tables: readonly { schema: string; name: string }[]
}) => {
if (type === 'examples') {
return `What are some common examples of user-defined database ${context}? ${PLACEHOLDER_LIMIT}`
} else if (type === 'ask') {
return `Could you explain to me what are used-defined database ${context}?`
} else if (type === 'suggest') {
const output =
context === 'functions'
? 'user-defined database functions'
: context === 'rls-policies'
? 'RLS policies'
: ''
const suffix =
context === 'functions' ? 'Let me know for which tables each function will be useful' : ''
const basePrompt = `Suggest some ${output} that might be useful`
if (tables.length > 0 && schemas.length > 0) {
return `${basePrompt} for the following tables within this database: ${tables.map((x) => `${x.schema}.${x.name}`)}. ${PLACEHOLDER_LIMIT} ${suffix}`.trim()
} else if (schemas.length > 0) {
return `${basePrompt} for the tables in the following schemas within this database: ${schemas.join(', ')}. ${suffix}`.trim()
}
return basePrompt
}
}