Skip to content

Commit 0eccb76

Browse files
committed
Tweak logs.
1 parent 204fb7f commit 0eccb76

1 file changed

Lines changed: 2 additions & 13 deletions

File tree

modules/module-mongodb-storage/src/storage/implementation/IncrementalReprocessingSyncConfigLog.ts

Lines changed: 2 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,4 @@
1-
import {
2-
BucketDataSource,
3-
ParameterIndexLookupCreator,
4-
SyncConfigWithErrors,
5-
TablePattern
6-
} from '@powersync/service-sync-rules';
1+
import { BucketDataSource, ParameterIndexLookupCreator, SyncConfigWithErrors } from '@powersync/service-sync-rules';
72
import {
83
IncrementalMappingChanges,
94
IncrementalMappingDefinitionChange,
@@ -72,9 +67,7 @@ function sourceTablesForDefinition(
7267
}
7368

7469
function sourceTablesForSources(sources: Array<BucketDataSource | ParameterIndexLookupCreator>) {
75-
return uniqueSorted(
76-
sources.flatMap((source) => [...source.getSourceTables()].map((table) => formatTablePattern(table)))
77-
);
70+
return uniqueSorted(sources.flatMap((source) => [...source.getSourceTables()].map((table) => table.tablePattern)));
7871
}
7972

8073
function definitionKey(definition: IncrementalMappingDefinitionChange) {
@@ -93,10 +86,6 @@ function uniqueDefinitions(definitions: IncrementalMappingDefinitionChange[]) {
9386
return [...byKey.values()];
9487
}
9588

96-
function formatTablePattern(pattern: TablePattern) {
97-
return `${pattern.connectionTag}.${pattern.schema}.${pattern.tablePattern}`;
98-
}
99-
10089
function formatDefinitionSection(
10190
title: string,
10291
definitions: IncrementalDefinitionLogEntry[],

0 commit comments

Comments
 (0)