Move debugRepresentation() back to BucketSource.

Author: rkistner

packages/sync-rules/src/BucketSource.ts

@@ -51,6 +51,8 @@ export interface BucketSource {
    * The same source could in theory be present in multiple stream definitions.
    */
   readonly parameterLookupSources: BucketParameterLookupSourceDefinition[];
+
+  debugRepresentation(): any;
 }
 
 export interface HydratedBucketSource {
@@ -80,8 +82,6 @@ export interface BucketDataSourceDefinition {
   resolveResultSets(schema: SourceSchema, tables: Record<string, Record<string, ColumnDefinition>>): void;
 
   debugWriteOutputTables(result: Record<string, { query: string }[]>): void;
-
-  debugRepresentation(): any;
 }
 
 /**

packages/sync-rules/src/SqlSyncRules.ts

@@ -473,7 +473,7 @@ export class SqlSyncRules {
   }
 
   debugRepresentation() {
-    return this.bucketDataSources.map((rules) => rules.debugRepresentation());
+    return this.bucketSources.map((rules) => rules.debugRepresentation());
   }
 
   private parsePriority(value: YAMLMap) {

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

@@ -53,6 +53,18 @@ export class SyncStream implements BucketSource {
   public get type(): BucketSourceType {
     return BucketSourceType.SYNC_STREAM;
   }
+
+  debugRepresentation() {
+    return {
+      name: this.name,
+      type: BucketSourceType[BucketSourceType.SYNC_STREAM],
+      variants: this.variants.map((v) => v.debugRepresentation()),
+      data: {
+        table: this.data.sourceTable,
+        columns: this.data.columnOutputNames()
+      }
+    };
+  }
 }
 
 export class SyncStreamDataSource implements BucketDataSourceDefinition {
@@ -90,18 +102,6 @@ export class SyncStreamDataSource implements BucketDataSourceDefinition {
     result[this.data.table!.sqlName].push(r);
   }
 
-  debugRepresentation() {
-    return {
-      name: this.stream.name,
-      type: BucketSourceType[BucketSourceType.SYNC_STREAM],
-      variants: this.stream.variants.map((v) => v.debugRepresentation()),
-      data: {
-        table: this.data.sourceTable,
-        columns: this.data.columnOutputNames()
-      }
-    };
-  }
-
   createDataSource(params: CreateSourceParams): BucketDataSource {
     return {
       evaluateRow: (options: EvaluateRowOptions): EvaluationResult[] => {