Fix debug representation

Author: simolus3

packages/sync-rules/src/SqlBucketDescriptor.ts

@@ -221,7 +221,7 @@ export class SqlBucketDescriptor implements BucketSource {
     let all_data_queries = [...this.dataQueries.values()].flat();
     return {
       name: this.name,
-      type: this.type.toString(),
+      type: BucketSourceType[this.type],
       bucket_parameters: this.bucketParameters,
       global_parameter_queries: this.globalParameterQueries.map((q) => {
         return {

packages/sync-rules/src/SqlSyncRules.ts

@@ -152,8 +152,8 @@ export class SqlSyncRules implements SyncRules {
       return true;
     };
 
-    if (bucketMap == null) {
-      rules.errors.push(new YamlError(new Error(`'bucket_definitions' is required`)));
+    if (bucketMap == null && streamMap == null) {
+      rules.errors.push(new YamlError(new Error(`'bucket_definitions' or 'streams' is required`)));
 
       if (throwOnError) {
         rules.throwOnError();

packages/sync-rules/src/json_schema.ts

@@ -56,8 +56,8 @@ export const syncRulesSchema: ajvModule.Schema = {
       patternProperties: {
         '.*': {
           type: 'object',
-          required: ['data'],
-          examples: [{ data: ['select * from mytable'] }],
+          required: ['query'],
+          examples: [{ query: ['select * from mytable'] }],
           properties: {
             accept_potentially_dangerous_queries: {
               description: 'If true, disables warnings on potentially dangerous queries',

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

@@ -129,7 +129,7 @@ export class SyncStream implements BucketSource {
   debugRepresentation() {
     return {
       name: this.name,
-      type: this.type.toString(),
+      type: BucketSourceType[this.type],
       variants: this.variants.map((v) => v.debugRepresentation()),
       data: {
         table: this.data.sourceTable,