sqlite-replication - npm Package Compare versions

Comparing version 0.0.17-b to 0.0.18-b

dist/replicationHelpers.js

		@@ -32,6 +32,4 @@ const EXPECTED_COLUMNS = ['id', '_forkParent', 'updatedAt', 'deletedAt'];
		const conflictUpdate = keys.map((key) => `"${key}"=excluded."${key}"`).join();
		return db.execute(`INSERT INTO "${collectionName}" (${keys
		.map((key) => `"${key}"`)
		.join()}) values ${values.join()}
		ON CONFLICT DO UPDATE SET ${conflictUpdate}`);
		return db.execute(`INSERT INTO "${collectionName}" (${keys.map((key) => `"${key}"`).join()}) values ${values.join()}
		ON CONFLICT DO UPDATE SET ${conflictUpdate}`, false);
		},
		@@ -43,3 +41,3 @@ deleteAll: (documents) => {
		.map((document) => ReplicationHelpers.safeValue(document.id))
		.join()});`);
		.join()});`, false);
		},
		@@ -46,0 +44,0 @@ };

dist/replicationSQLiteStorage.js

		@@ -50,7 +50,7 @@ export class ReplicationSQLiteStorage {
		updateReplicationPushState(collectionName, offset, cursor) {
		return this.db.execute(`UPDATE _replicationStates set "pushOffset"=${offset},"pushCursor"=${cursor} where id="${collectionName}"`);
		return this.db.execute(`UPDATE _replicationStates set "pushOffset"=${offset},"pushCursor"=${cursor} where id="${collectionName}"`, false);
		}
		updateReplicationPullState(collectionName, offset, cursor) {
		return this.db.execute(`UPDATE _replicationStates set "pullOffset"=${offset},"pullCursor"=${cursor} where id="${collectionName}"`);
		return this.db.execute(`UPDATE _replicationStates set "pullOffset"=${offset},"pullCursor"=${cursor} where id="${collectionName}"`, false);
		}
		}

package.json

		{
		"name": "sqlite-replication",
		"version": "0.0.17b",
		"version": "0.0.18b",
		"description": "A Typescript module to replicate SQLite DB with server.",
		@@ -5,0 +5,0 @@ "scripts": {

src/replicationHelpers.ts

		@@ -41,6 +41,7 @@ import { SQLiteDBConnection } from '@capacitor-community/sqlite';
		const conflictUpdate = keys.map((key) => `"${key}"=excluded."${key}"`).join();
		return db.execute(`INSERT INTO "${collectionName}" (${keys
		.map((key) => `"${key}"`)
		.join()}) values ${values.join()}
		ON CONFLICT DO UPDATE SET ${conflictUpdate}`);
		return db.execute(
		`INSERT INTO "${collectionName}" (${keys.map((key) => `"${key}"`).join()}) values ${values.join()}
		ON CONFLICT DO UPDATE SET ${conflictUpdate}`,
		false,
		);
		},
		@@ -53,2 +54,3 @@ deleteAll: (documents: any[]) => {
		.join()});`,
		false,
		);
		@@ -55,0 +57,0 @@ },

src/replicationSQLiteStorage.ts

		@@ -55,2 +55,3 @@ import { SQLiteDBConnection } from '@capacitor-community/sqlite';
		`UPDATE _replicationStates set "pushOffset"=${offset},"pushCursor"=${cursor} where id="${collectionName}"`,
		false,
		);
		@@ -61,4 +62,5 @@ }
		`UPDATE _replicationStates set "pullOffset"=${offset},"pullCursor"=${cursor} where id="${collectionName}"`,
		false,
		);
		}
		}

New alerts