previous transaction index (v0.2)

Author: fsteff

dist/lib/BlockStorage.js

@@ -257,6 +257,10 @@ function defineTransactionMarker () {
       var len = encodings.varint.encodingLength(obj.timestamp)
       length += 1 + len
     }
+    if (defined(obj.previous)) {
+      var len = encodings.varint.encodingLength(obj.previous)
+      length += 1 + len
+    }
     return length
   }
 
@@ -277,6 +281,11 @@ function defineTransactionMarker () {
       encodings.varint.encode(obj.timestamp, buf, offset)
       offset += encodings.varint.encode.bytes
     }
+    if (defined(obj.previous)) {
+      buf[offset++] = 32
+      encodings.varint.encode(obj.previous, buf, offset)
+      offset += encodings.varint.encode.bytes
+    }
     encode.bytes = offset - oldOffset
     return buf
   }
@@ -289,7 +298,8 @@ function defineTransactionMarker () {
     var obj = {
       sequenceNr: 0,
       objectCtr: 0,
-      timestamp: 0
+      timestamp: 0,
+      previous: 0
     }
     var found0 = false
     var found1 = false
@@ -317,6 +327,10 @@ function defineTransactionMarker () {
         obj.timestamp = encodings.varint.decode(buf, offset)
         offset += encodings.varint.decode.bytes
         break
+        case 4:
+        obj.previous = encodings.varint.decode(buf, offset)
+        offset += encodings.varint.decode.bytes
+        break
         default:
         offset = skip(prefix & 7, buf, offset)
       }

dist/lib/BlockStorage.js.map

@@ -24,7 +24,7 @@ export default class BlockStorage {
                 const indexNode = self.createIndexNode(0)
                 await feed.criticalSection(async lockKey => {
                     const buf = self.encodeIndexNode(indexNode)
-                    const marker = self.createTransactionMarker(1, 0)
+                    const marker = self.createTransactionMarker(1, 0, 0)
                     await feed.append([buf, marker], { lockKey })
                 })
             }
@@ -45,7 +45,6 @@ export default class BlockStorage {
     }
 
     async getIndexNodeForObjectId(id: number, head?: number): Promise<IndexNode> {
-        const self = this
         const prefix = id >> BUCKET_WIDTH
         return this.getIndexNode(prefix, head)
     }
@@ -195,15 +194,16 @@ export default class BlockStorage {
                 parent.children[slot] = node.index
             }
         }
-        bulk.push(this.createTransactionMarker(lastTransaction.sequenceNr + 1, objectCtr + 1))
+        bulk.push(this.createTransactionMarker(lastTransaction.sequenceNr + 1, objectCtr + 1, head + 1))
         await this.feed.append(bulk, { lockKey })
     }
 
-    createTransactionMarker(sequenceNr: number, objectCtr: number) {
+    createTransactionMarker(sequenceNr: number, objectCtr: number, previous: number) {
         const marker = {
             sequenceNr,
             objectCtr,
-            timestamp: Date.now()
+            timestamp: Date.now(),
+            previous
         }
         return this.encodeTransactionBlock(marker)
     }