Skip to content

Commit cd599a1

Browse files
autofix-ci[bot]autofix-ci[bot]
authored
ci: apply automated fixes
1 parent 9ee3073 commit cd599a1

7 files changed

Lines changed: 79 additions & 64 deletions

File tree

‎packages/db-sqlite-persistence-core/src/persisted.ts‎

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -247,12 +247,13 @@ export interface PersistenceAdapter {
247247
options: LoadSubsetOptions,
248248
ctx?: { requiredIndexSignatures?: ReadonlyArray<string> },
249249
) => Promise<
250-
Array<{ key: string | number; value: Record<string, unknown>; metadata?: unknown }>
250+
Array<{
251+
key: string | number
252+
value: Record<string, unknown>
253+
metadata?: unknown
254+
}>
251255
>
252-
applyCommittedTx: (
253-
collectionId: string,
254-
tx: PersistedTx,
255-
) => Promise<void>
256+
applyCommittedTx: (collectionId: string, tx: PersistedTx) => Promise<void>
256257
loadCollectionMetadata?: (
257258
collectionId: string,
258259
) => Promise<Array<{ key: string; value: unknown }>>
@@ -407,7 +408,10 @@ const REQUIRED_COORDINATOR_METHODS: ReadonlyArray<
407408
]
408409

409410
const REQUIRED_ADAPTER_METHODS: ReadonlyArray<
410-
keyof Pick<PersistenceAdapter, `loadSubset` | `applyCommittedTx` | `ensureIndex`>
411+
keyof Pick<
412+
PersistenceAdapter,
413+
`loadSubset` | `applyCommittedTx` | `ensureIndex`
414+
>
411415
> = [`loadSubset`, `applyCommittedTx`, `ensureIndex`]
412416

413417
const TARGETED_INVALIDATION_KEY_LIMIT = 128

‎packages/db-sqlite-persistence-core/src/sqlite-core-adapter.ts‎

Lines changed: 17 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -608,16 +608,20 @@ function sanitizeExpressionSqlFragment(fragment: string): string {
608608
return fragment
609609
}
610610

611-
type InMemoryRow<TKey extends string | number = string | number, T extends object = Record<string, unknown>> = {
611+
type InMemoryRow<
612+
TKey extends string | number = string | number,
613+
T extends object = Record<string, unknown>,
614+
> = {
612615
key: TKey
613616
value: T
614617
metadata?: unknown
615618
rowVersion: number
616619
}
617620

618-
function decodeStoredSqliteRows<TKey extends string | number = string | number, T extends object = Record<string, unknown>>(
619-
storedRows: ReadonlyArray<StoredSqliteRow>,
620-
): Array<InMemoryRow<TKey, T>> {
621+
function decodeStoredSqliteRows<
622+
TKey extends string | number = string | number,
623+
T extends object = Record<string, unknown>,
624+
>(storedRows: ReadonlyArray<StoredSqliteRow>): Array<InMemoryRow<TKey, T>> {
621625
return storedRows.map((row) => {
622626
const key = decodePersistedStorageKey(row.key) as TKey
623627
const value = deserializePersistedRowValue<T>(row.value)
@@ -1083,7 +1087,11 @@ export class SQLiteCorePersistenceAdapter implements PersistenceAdapter {
10831087
options: LoadSubsetOptions,
10841088
ctx?: { requiredIndexSignatures?: ReadonlyArray<string> },
10851089
): Promise<
1086-
Array<{ key: string | number; value: Record<string, unknown>; metadata?: unknown }>
1090+
Array<{
1091+
key: string | number
1092+
value: Record<string, unknown>
1093+
metadata?: unknown
1094+
}>
10871095
> {
10881096
const tableMapping = await this.ensureCollectionReady(collectionId)
10891097
await this.touchRequiredIndexes(collectionId, ctx?.requiredIndexSignatures)
@@ -1136,10 +1144,7 @@ export class SQLiteCorePersistenceAdapter implements PersistenceAdapter {
11361144
}))
11371145
}
11381146

1139-
async applyCommittedTx(
1140-
collectionId: string,
1141-
tx: PersistedTx,
1142-
): Promise<void> {
1147+
async applyCommittedTx(collectionId: string, tx: PersistedTx): Promise<void> {
11431148
const tableMapping = await this.ensureCollectionReady(collectionId)
11441149
const collectionTableSql = quoteIdentifier(tableMapping.tableName)
11451150
const tombstoneTableSql = quoteIdentifier(tableMapping.tombstoneTableName)
@@ -1688,9 +1693,7 @@ export class SQLiteCorePersistenceAdapter implements PersistenceAdapter {
16881693

16891694
const evaluator = compileRowExpressionEvaluator(where)
16901695
return rows.filter((row) =>
1691-
toBooleanPredicate(
1692-
evaluator(row.value) as boolean | null,
1693-
),
1696+
toBooleanPredicate(evaluator(row.value) as boolean | null),
16941697
)
16951698
}
16961699

@@ -1710,12 +1713,8 @@ export class SQLiteCorePersistenceAdapter implements PersistenceAdapter {
17101713
const ordered = [...rows]
17111714
ordered.sort((left, right) => {
17121715
for (const clause of compiledClauses) {
1713-
const leftValue = clause.evaluator(
1714-
left.value,
1715-
)
1716-
const rightValue = clause.evaluator(
1717-
right.value,
1718-
)
1716+
const leftValue = clause.evaluator(left.value)
1717+
const rightValue = clause.evaluator(right.value)
17191718

17201719
const comparison = compareOrderByValues(
17211720
leftValue,

‎packages/db-sqlite-persistence-core/tests/persisted.test.ts‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,10 @@ function createRecordingAdapter(
142142
if (rowMetadataMutation.type === `delete`) {
143143
rowMetadata.delete(rowMetadataMutation.key as string)
144144
} else {
145-
rowMetadata.set(rowMetadataMutation.key as string, rowMetadataMutation.value)
145+
rowMetadata.set(
146+
rowMetadataMutation.key as string,
147+
rowMetadataMutation.value,
148+
)
146149
}
147150
}
148151
for (const metadataMutation of tx.collectionMetadataMutations ?? []) {

‎packages/db-sqlite-persistence-core/tests/sqlite-core-adapter.test.ts‎

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,6 @@ type Todo = {
2020
score: number
2121
}
2222

23-
24-
2523
const execFileAsync = promisify(execFile)
2624

2725
function toSqlLiteral(value: unknown): string {
@@ -1479,11 +1477,9 @@ export function runSQLiteCoreAdapterContractSuite(
14791477

14801478
it(`falls back to in-memory filtering when SQL json path pushdown is unsupported`, async () => {
14811479
const { driver } = registerContractHarness()
1482-
const adapter = new SQLiteCorePersistenceAdapter(
1483-
{
1484-
driver,
1485-
},
1486-
)
1480+
const adapter = new SQLiteCorePersistenceAdapter({
1481+
driver,
1482+
})
14871483
const collectionId = `fallback-where`
14881484

14891485
await adapter.applyCommittedTx(collectionId, {
@@ -1529,11 +1525,9 @@ export function runSQLiteCoreAdapterContractSuite(
15291525

15301526
it(`supports alias-qualified refs during in-memory fallback filtering`, async () => {
15311527
const { driver } = registerContractHarness()
1532-
const adapter = new SQLiteCorePersistenceAdapter(
1533-
{
1534-
driver,
1535-
},
1536-
)
1528+
const adapter = new SQLiteCorePersistenceAdapter({
1529+
driver,
1530+
})
15371531
const collectionId = `fallback-alias-qualified-ref`
15381532

15391533
await adapter.applyCommittedTx(collectionId, {

‎packages/electron-db-sqlite-persistence/src/renderer.ts‎

Lines changed: 42 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -149,24 +149,31 @@ function createRendererRequestExecutor(options: {
149149
}
150150
}
151151

152-
type ElectronRendererResolvedAdapter = PersistedCollectionPersistence[`adapter`] & {
153-
loadCollectionMetadata: (
154-
collectionId: string,
155-
) => Promise<Array<{ key: string; value: unknown }>>
156-
scanRows: (
157-
collectionId: string,
158-
options?: { metadataOnly?: boolean },
159-
) => Promise<Array<{ key: string | number; value: Record<string, unknown>; metadata?: unknown }>>
160-
pullSince: (
161-
collectionId: string,
162-
fromRowVersion: number,
163-
) => Promise<SQLitePullSinceResult<string | number>>
164-
getStreamPosition: (collectionId: string) => Promise<{
165-
latestTerm: number
166-
latestSeq: number
167-
latestRowVersion: number
168-
}>
169-
}
152+
type ElectronRendererResolvedAdapter =
153+
PersistedCollectionPersistence[`adapter`] & {
154+
loadCollectionMetadata: (
155+
collectionId: string,
156+
) => Promise<Array<{ key: string; value: unknown }>>
157+
scanRows: (
158+
collectionId: string,
159+
options?: { metadataOnly?: boolean },
160+
) => Promise<
161+
Array<{
162+
key: string | number
163+
value: Record<string, unknown>
164+
metadata?: unknown
165+
}>
166+
>
167+
pullSince: (
168+
collectionId: string,
169+
fromRowVersion: number,
170+
) => Promise<SQLitePullSinceResult<string | number>>
171+
getStreamPosition: (collectionId: string) => Promise<{
172+
latestTerm: number
173+
latestSeq: number
174+
latestRowVersion: number
175+
}>
176+
}
170177

171178
function createResolvedRendererAdapter(
172179
executeRequest: RendererRequestExecutor,
@@ -188,7 +195,10 @@ function createResolvedRendererAdapter(
188195
resolution,
189196
)
190197

191-
return result as Array<{ key: string | number; value: Record<string, unknown> }>
198+
return result as Array<{
199+
key: string | number
200+
value: Record<string, unknown>
201+
}>
192202
},
193203
applyCommittedTx: async (
194204
collectionId: string,
@@ -216,14 +226,24 @@ function createResolvedRendererAdapter(
216226
scanRows: async (
217227
collectionId: string,
218228
options?: { metadataOnly?: boolean },
219-
): Promise<Array<{ key: string | number; value: Record<string, unknown>; metadata?: unknown }>> => {
229+
): Promise<
230+
Array<{
231+
key: string | number
232+
value: Record<string, unknown>
233+
metadata?: unknown
234+
}>
235+
> => {
220236
const result = await executeRequest(
221237
`scanRows`,
222238
collectionId,
223239
{ options },
224240
resolution,
225241
)
226-
return result as Array<{ key: string | number; value: Record<string, unknown>; metadata?: unknown }>
242+
return result as Array<{
243+
key: string | number
244+
value: Record<string, unknown>
245+
metadata?: unknown
246+
}>
227247
},
228248
ensureIndex: async (
229249
collectionId: string,
@@ -320,10 +340,7 @@ export function createElectronSQLitePersistence(
320340
channel: options.channel,
321341
timeoutMs: options.timeoutMs,
322342
})
323-
const adapterCache = new Map<
324-
string,
325-
ElectronRendererResolvedAdapter
326-
>()
343+
const adapterCache = new Map<string, ElectronRendererResolvedAdapter>()
327344

328345
const getAdapterForCollection = (
329346
mode: PersistedCollectionMode,

‎packages/electron-db-sqlite-persistence/tests/electron-ipc.test.ts‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ import type {
2424
ElectronPersistenceResponseEnvelope,
2525
} from '../src/protocol'
2626

27-
2827
type InvokeHarness = {
2928
invoke: ElectronPersistenceInvoke
3029
close: () => void

‎packages/tauri-db-sqlite-persistence/e2e/app/src/register-tauri-e2e-suite.ts‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@ import { registerPersistedCollectionConformanceSuite } from '../../shared/regist
44
import type { PersistedCollectionPersistence } from '@tanstack/db-sqlite-persistence-core'
55
import type { TauriSQLiteDatabaseLike } from '../../../src'
66

7-
87
export function registerTauriNativeE2ESuite(options: {
98
suiteName: string
109
database: TauriSQLiteDatabaseLike

0 commit comments

Comments
 (0)