Merge pull request #151 from powersync-ja/diagnostics-app

Diagnostics app

Author: benitav

.changeset/shy-suns-drop.md

@@ -0,0 +1,5 @@
+---
+"@powersync/common": patch
+---
+
+Fix type of Schema.tables

.changeset/stale-insects-teach.md

@@ -0,0 +1,5 @@
+---
+"@powersync/common": patch
+---
+
+Fix disconnectAndClear() not clearing ps_untyped

README.md

@@ -55,6 +55,10 @@ Demo applications are located in the [`demos/`](./demos/) directory. Also see ou
 - [demos/example-vite](./demos/example-vite/README.md): A minimal example demonstrating bundling with Vite.
 - [demos/example-nextjs](./demos/example-nextjs/README.md): An example demonstrating setup with Next.js.
 
+## Tools
+
+- [tools/diagnostics-app](./tools/diagnostics-app): A standalone web app that presents stats about a user's local database (incl. tables and sync buckets).
+
 # Development
 
 This monorepo uses pnpm.

packages/common/src/client/AbstractPowerSyncDatabase.ts

@@ -367,6 +367,7 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
       await tx.execute(`DELETE FROM ${PSInternalTable.OPLOG}`);
       await tx.execute(`DELETE FROM ${PSInternalTable.CRUD}`);
       await tx.execute(`DELETE FROM ${PSInternalTable.BUCKETS}`);
+      await tx.execute(`DELETE FROM ${PSInternalTable.UNTYPED}`);
 
       const tableGlob = clearLocal ? 'ps_data_*' : 'ps_data__*';
 

packages/common/src/client/sync/bucket/BucketStorageAdapter.ts

@@ -42,7 +42,8 @@ export enum PSInternalTable {
   DATA = 'ps_data',
   CRUD = 'ps_crud',
   BUCKETS = 'ps_buckets',
-  OPLOG = 'ps_oplog'
+  OPLOG = 'ps_oplog',
+  UNTYPED = 'ps_untyped'
 }
 
 export interface BucketStorageListener extends BaseListener {

packages/common/src/db/schema/Schema.ts

@@ -16,7 +16,9 @@ export class Schema<S extends SchemaType = SchemaType> {
   */
   readonly types: SchemaTableType<S>;
   readonly props: S;
-  constructor(public tables: ClassicTable[] | S) {
+  readonly tables: ClassicTable[];
+
+  constructor(tables: ClassicTable[] | S) {
     if (Array.isArray(tables)) {
       this.tables = tables;
     } else {