Lint fixes 1

src/adaptors/yjs-ndn-adaptor.ts

@@ -123,40 +123,40 @@ export class NdnSvsAdaptor {
   }
 
   // Adam Chen Injection point 1
-  async publishUpdate(topic:any,content:any) {
+  private async publishUpdate(topic:string,content:Uint8Array) {
     await this.syncAgent.publishUpdate(topic, content)
     // await new Promise(r => setTimeout(r,500));
     // forced wait so that publishUpdate() is completed before we check SV.
     console.log('-- Injection point 1: Check StateVector / Create Snapshot --')
-    let stateVector = this.syncAgent.getUpdateSyncSV()
+    const stateVector = this.syncAgent.getUpdateSyncSV()
     console.log('debug: stateVector object: ',stateVector)
     let count = 0
-    for (const [id,seq] of stateVector){
+    for (const [_id,seq] of stateVector){
         count += seq
     }
     console.log('Total count of state vector', count)
     console.log('The above number should match the state vector in the debug page')
     if (count % 5 == 0){
         console.log('It\'s time to make a snapshot!')
         console.log('debug: group prefix: ', this.syncAgent.appPrefix.toString())
-        let encodedSV = Encoder.encode(stateVector)
-        let snapshotPrefix = this.syncAgent.appPrefix.append("32=snapshot")
+        const encodedSV = Encoder.encode(stateVector)
+        const snapshotPrefix = this.syncAgent.appPrefix.append("32=snapshot")
         // New SVS encodings
-        let snapshotName = snapshotPrefix.append(new Component(Version.type, encodedSV))
+        const snapshotName = snapshotPrefix.append(new Component(Version.type, encodedSV))
         console.log('debug: targeted snapshot Prefix (persistStore key): ', snapshotPrefix.toString())
         // /groupPrefix/32=snapshot/
         console.log('debug: targeted snapshot Name: ', snapshotName.toString())
         // /groupPrefix/32=snapshot/54=<stateVector>
-        let decodedSV = Decoder.decode(snapshotName.at(-1).value, StateVector)
+        const decodedSV = Decoder.decode(snapshotName.at(-1).value, StateVector)
         console.log('debug: decoding encoded SV from snapshotName: ', decodedSV)
         let count = 0
-        for (const [id,seq] of decodedSV){
+        for (const [_id,seq] of decodedSV){
             count += seq
         }
         console.log('debug: decoding encoded SV total packet count: ', count)
         console.log('This should match the state vector in the debug page and the previous count before encoding')
 
-        let content = Y.encodeStateAsUpdate(this.doc)
+        const content = Y.encodeStateAsUpdate(this.doc)
         // its already in UTF8, transporting currently without any additional encoding.
         console.log('yjs backend data: ',content)
 
@@ -165,11 +165,11 @@ export class NdnSvsAdaptor {
         await this.syncAgent.publishBlob('snapshot',content,snapshotName,true)
 
         //first segmented object is at /50=%00
-        let firstSegmentName = snapshotName.append('50=%00').toString()
+        const firstSegmentName = snapshotName.append('50=%00').toString()
         console.log('debugTargetName: ', firstSegmentName)
-        let firstSegmentPacketEncoded = await this.syncAgent.persistStorage.get(firstSegmentName)
+        const firstSegmentPacketEncoded = await this.syncAgent.persistStorage.get(firstSegmentName)
         if (firstSegmentPacketEncoded){
-          let firstSegmentPacket = Decoder.decode(firstSegmentPacketEncoded,Data)
+          const firstSegmentPacket = Decoder.decode(firstSegmentPacketEncoded,Data)
           console.log('persistentStore check: ', firstSegmentPacket)
           console.log('persistentStore check Data Name:', firstSegmentPacket.name.toString())
           await this.syncAgent.persistStorage.set(snapshotPrefix.toString(), Encoder.encode(firstSegmentPacket));
@@ -182,40 +182,40 @@ export class NdnSvsAdaptor {
 // -- Adam Chen Injection Point 3: HandleSnapshotUpdate --
 async handleSnapshotUpdate(snapshotName: Uint8Array){
     // Maybe it's wise to put this under a try() because it might fail due to network issues.
-    let decodedSnapshotName = Decoder.decode(snapshotName, Name)
+    const decodedSnapshotName = Decoder.decode(snapshotName, Name)
     console.log('-- Adam Chen Injection Point 3: Update Latest Snapshot (Received) --')
     console.log('Handling received snapshot packet with name: ', decodedSnapshotName.toString())
 
-    let snapshotPrefix = this.syncAgent.appPrefix.append("32=snapshot")
+    const snapshotPrefix = this.syncAgent.appPrefix.append("32=snapshot")
     console.log('snapshot prefix in persistStorage: ', snapshotPrefix.toString())
-    let oldSnapshotFirstSegmentEncoded = await this.syncAgent.persistStorage.get(snapshotPrefix.toString())
+    const oldSnapshotFirstSegmentEncoded = await this.syncAgent.persistStorage.get(snapshotPrefix.toString())
     let oldSVCount = 0
     if (oldSnapshotFirstSegmentEncoded){
-        let oldSnapshotFirstSegment = Decoder.decode(oldSnapshotFirstSegmentEncoded, Data)
-        let oldSnapshotVector = Decoder.decode(oldSnapshotFirstSegment.name.at(-2).value,StateVector)
-        for (const [id,seq] of oldSnapshotVector){
+        const oldSnapshotFirstSegment = Decoder.decode(oldSnapshotFirstSegmentEncoded, Data)
+        const oldSnapshotVector = Decoder.decode(oldSnapshotFirstSegment.name.at(-2).value,StateVector)
+        for (const [_id,seq] of oldSnapshotVector){
             oldSVCount += seq
         }
     }
 
-    let snapshotSV = Decoder.decode(decodedSnapshotName.at(-1).value,StateVector)
+    const snapshotSV = Decoder.decode(decodedSnapshotName.at(-1).value,StateVector)
     let snapshotSVcount = 0
-    for (const [id,seq] of snapshotSV){
+    for (const [_id,seq] of snapshotSV){
         snapshotSVcount += seq
     }
 
     console.log('current state vector total count: ', oldSVCount)
     console.log('snapshot state vector total count: ', snapshotSVcount)
 
     if (snapshotSVcount>oldSVCount){
-        let firstSegmentName = decodedSnapshotName.append('50=%00').toString()
+        const firstSegmentName = decodedSnapshotName.append('50=%00').toString()
         console.log('Retrieving the following from persist Storage: ', firstSegmentName)
         // await this.syncAgent.getBlob(decodedSnapshotName)
         await new Promise((r) => setTimeout(r, 1000))
-        let firstSegmentPacketEncoded = await this.syncAgent.persistStorage.get(firstSegmentName)
+        const firstSegmentPacketEncoded = await this.syncAgent.persistStorage.get(firstSegmentName)
         if (firstSegmentPacketEncoded){
             console.log('Debug: Retrieval results: ', firstSegmentPacketEncoded)
-            let firstSegmentPacket = Decoder.decode(firstSegmentPacketEncoded, Data)
+            const firstSegmentPacket = Decoder.decode(firstSegmentPacketEncoded, Data)
             console.log('Writing this packet: ', firstSegmentPacket.name.toString())
             console.log('To this location: ', snapshotPrefix.toString())
             // this is done to update the key of the prefix so program return latest when blind fetching.

src/sync-agent/sync-agent.ts

@@ -363,13 +363,13 @@ export class SyncAgent implements AsyncDisposable {
 
     if (intName.get(this.appPrefix.length)?.equals(getNamespace().snapshotKeyword)) {
       // console.log('snapshot interest detected, custom routine activated')
-      let wire = await this.persistStorage.get(intName.toString())
+      const wire = await this.persistStorage.get(intName.toString())
       if (wire === undefined || wire.length === 0) {
           // console.warn(`A remote peer is fetching a non-existing object: ${intName.toString()}`);
           console.log('MISS: SnapshotInterest: ', intName.toString())
           return undefined;
       }
-      let data = Decoder.decode(wire, Data)
+      const data = Decoder.decode(wire, Data)
       console.log('HIT: SnapshotInterest and Returned Data: ',intName.toString(),data.name.toString())
       return data
       }