@peerbit/document - npm Package Compare versions

Comparing version 9.3.0 to 9.3.1

dist/src/program.d.ts

@@ -97,2 +97,3 @@ import { type AbstractType } from "@dao-xyz/borsh";
         operation: PutOperation;
+        unique?: boolean;
     }): Promise<void>;
@@ -99,0 +100,0 @@ count(properties: {

dist/src/program.js

@@ -415,2 +415,17 @@ var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
                     }
+                    // if no casual ordering is used, use timestamps to order docs
+                    let existing = reference?.unique
+                        ? null
+                        : (await this._index.index.get(key)) || null;
+                    if (!this.strictHistory && existing) {
+                        // if immutable use oldest, else use newest
+                        let shouldIgnoreChange = this.immutable
+                            ? existing.value.__context.modified <
+                                item.meta.clock.timestamp.wallTime
+                            : existing.value.__context.modified >
+                                item.meta.clock.timestamp.wallTime;
+                        if (shouldIgnoreChange) {
+                            continue;
+                        }
+                    }
                     // Program specific
@@ -421,3 +436,3 @@ if (value instanceof Program) {
                     }
-                    const context = await this._index.put(value, key, item);
+                    const context = await this._index.put(value, key, item, existing);
                     documentsChanged.added.push(coerceWithContext(value, context));
@@ -424,0 +439,0 @@ modified.add(key.primitive);

dist/src/search.d.ts

@@ -105,3 +105,3 @@ import { type AbstractType } from "@dao-xyz/borsh";
     getFromGid(gid: string): Promise<indexerTypes.IndexedResult<WithContext<I>>>;
-    put(value: T, id: indexerTypes.IdKey, entry: Entry<Operation>): Promise<types.Context>;
+    put(value: T, id: indexerTypes.IdKey, entry: Entry<Operation>, existing: indexerTypes.IndexedResult<WithContext<I>> | null | undefined): Promise<types.Context>;
     putWithContext(value: T, id: indexerTypes.IdKey, context: types.Context): Promise<types.Context>;
@@ -108,0 +108,0 @@ del(key: indexerTypes.IdKey): indexerTypes.IdKey[] | Promise<indexerTypes.IdKey[]>;

dist/src/search.js

@@ -296,6 +296,6 @@ var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
     }
-    async put(value, id, entry) {
-        const existing = await this.index.get(id);
+    async put(value, id, entry, existing) {
+        const existingDefined = existing === undefined ? await this.index.get(id) : existing;
         const context = new types.Context({
-            created: existing?.value.__context.created ||
+            created: existingDefined?.value.__context.created ||
                 entry.meta.clock.timestamp.wallTime,
@@ -302,0 +302,0 @@ modified: entry.meta.clock.timestamp.wallTime,

package.json

 {
 	"name": "@peerbit/document",
-	"version": "9.3.0",
+	"version": "9.3.1",
 	"description": "Document store implementation",
@@ -62,12 +62,12 @@ "type": "module",
 		"@dao-xyz/borsh": "^5.2.3",
-		"@peerbit/program": "5.1.7",
-		"@peerbit/rpc": "5.0.40",
-		"@peerbit/shared-log": "10.4.3",
+		"@peerbit/program": "5.1.8",
+		"@peerbit/rpc": "5.0.41",
+		"@peerbit/shared-log": "10.4.4",
 		"@peerbit/indexer-interface": "^2.0.7",
 		"@peerbit/indexer-simple": "^1.1.11",
 		"@peerbit/indexer-sqlite3": "^1.2.14",
-		"@peerbit/document-interface": "^2.0.16"
+		"@peerbit/document-interface": "^2.0.17"
 	},
 	"devDependencies": {
-		"@peerbit/test-utils": "2.1.30",
+		"@peerbit/test-utils": "2.1.31",
 		"@peerbit/time": "2.0.8",
@@ -74,0 +74,0 @@ "@types/pidusage": "^2.0.5",

src/program.ts

@@ -556,3 +556,3 @@ import {
 		change: Change<Operation>,
-		reference?: { document: T; operation: PutOperation },
+		reference?: { document: T; operation: PutOperation; unique?: boolean },
 	): Promise<void> {
@@ -615,2 +615,18 @@ const isAppendOperation =
 
+					// if no casual ordering is used, use timestamps to order docs
+					let existing = reference?.unique
+						? null
+						: (await this._index.index.get(key)) || null;
+					if (!this.strictHistory && existing) {
+						// if immutable use oldest, else use newest
+						let shouldIgnoreChange = this.immutable
+							? existing.value.__context.modified <
+								item.meta.clock.timestamp.wallTime
+							: existing.value.__context.modified >
+								item.meta.clock.timestamp.wallTime;
+						if (shouldIgnoreChange) {
+							continue;
+						}
+					}
+
 					// Program specific
@@ -621,3 +637,3 @@ if (value instanceof Program) {
 					}
-					const context = await this._index.put(value, key, item);
+					const context = await this._index.put(value, key, item, existing);
 					documentsChanged.added.push(coerceWithContext(value, context));
@@ -624,0 +640,0 @@

src/search.ts

@@ -587,7 +587,13 @@ import { type AbstractType, field, serialize, variant } from "@dao-xyz/borsh";
 	}
-	public async put(value: T, id: indexerTypes.IdKey, entry: Entry<Operation>) {
-		const existing = await this.index.get(id);
+	public async put(
+		value: T,
+		id: indexerTypes.IdKey,
+		entry: Entry<Operation>,
+		existing: indexerTypes.IndexedResult<WithContext<I>> | null | undefined,
+	) {
+		const existingDefined =
+			existing === undefined ? await this.index.get(id) : existing;
 		const context = new types.Context({
 			created:
-				existing?.value.__context.created ||
+				existingDefined?.value.__context.created ||
 				entry.meta.clock.timestamp.wallTime,
@@ -594,0 +600,0 @@ modified: entry.meta.clock.timestamp.wallTime,

No alert changes

Improved metrics

Total package byte prevSize

309122

0.8%

Lines of code

5578

0.67%

Dependency changes

• + Added

  @peerbit/log@4.0.43
  (transitive)

• + Added

  @peerbit/program@5.1.8
  (transitive)

• + Added

  @peerbit/rpc@5.0.41
  (transitive)

• + Added

  @peerbit/shared-log@10.4.4
  (transitive)

• - Removed

  @peerbit/log@4.0.42
  (transitive)

• - Removed

  @peerbit/program@5.1.7
  (transitive)

• - Removed

  @peerbit/rpc@5.0.40
  (transitive)

• - Removed

  @peerbit/shared-log@10.4.3
  (transitive)

• Updated

  @peerbit/document-interface@^2.0.17

• Updated

  @peerbit/program@5.1.8

• Updated

  @peerbit/rpc@5.0.41

• Updated

  @peerbit/shared-log@10.4.4