Update rules schema

Author: simolus3

packages/sync-rules/src/SqlSyncRules.ts

@@ -227,13 +227,13 @@ export class SqlSyncRules implements SyncRules {
         ...options,
         accept_potentially_dangerous_queries,
         priority: rules.parsePriority(value),
-        default: value.get('default', true)?.value == true
+        auto_subscribe: value.get('auto_subscribe', true)?.value == true
       };
 
       const data = value.get('query', true) as unknown;
       if (data instanceof Scalar) {
         rules.withScalar(data, (q) => {
-          const [parsed, errors] = syncStreamFromSql(key, q, options);
+          const [parsed, errors] = syncStreamFromSql(key, q, queryOptions);
           rules.bucketSources.push(parsed);
           return {
             parsed: true,

packages/sync-rules/src/json_schema.ts

@@ -49,6 +49,36 @@ export const syncRulesSchema: ajvModule.Schema = {
         }
       }
     },
+    streams: {
+      type: 'object',
+      description: 'List of stream definitions',
+      examples: [{ user_details: { query: 'select * from users where id = auth.user_id()' } }],
+      patternProperties: {
+        '.*': {
+          type: 'object',
+          required: ['data'],
+          examples: [{ data: ['select * from mytable'] }],
+          properties: {
+            accept_potentially_dangerous_queries: {
+              description: 'If true, disables warnings on potentially dangerous queries',
+              type: 'boolean'
+            },
+            auto_subscribe: {
+              description: 'Whether clients will subscribe to this stream by default.',
+              type: 'boolean'
+            },
+            priority: {
+              description: 'Priority for the bucket (lower values indicate higher priority).',
+              type: 'integer'
+            },
+            query: {
+              description: 'The SQL query defining content to sync in this stream.',
+              type: 'string'
+            }
+          }
+        }
+      }
+    },
     event_definitions: {
       type: 'object',
       description: 'Record of sync replication event definitions',
@@ -79,7 +109,7 @@ export const syncRulesSchema: ajvModule.Schema = {
       }
     }
   },
-  required: ['bucket_definitions'],
+  required: [],
   additionalProperties: false
 } as const;
 

packages/sync-rules/src/streams/from_sql.ts

@@ -93,7 +93,7 @@ class SyncStreamCompiler {
       this.descriptorName,
       new BaseSqlDataQuery(this.compileDataQuery(tools, query, alias, sourceTable))
     );
-    stream.subscribedToByDefault = this.options.default ?? false;
+    stream.subscribedToByDefault = this.options.auto_subscribe ?? false;
     if (filter.isValid(tools)) {
       stream.variants = filter.compileVariants(this.descriptorName);
     }

packages/sync-rules/src/types.ts

@@ -19,7 +19,7 @@ export interface QueryParseOptions extends SyncRulesOptions {
 }
 
 export interface StreamParseOptions extends QueryParseOptions {
-  default?: boolean;
+  auto_subscribe?: boolean;
 }
 
 export interface EvaluatedParameters {