add comments, fix indentatin

Author: harbu

packages/client/src/publish/GroupKeyQueue.ts

@@ -62,6 +62,7 @@ export class GroupKeyQueue {
     }
 
     private async generateNewKey(): Promise<GroupKey> {
+        // 1st try lit-protocol, if a key cannot be generated and stored, then generate group key locally
         const litProtocolGroupKey = await this.litProtocolKeyStore.store(this.streamId, crypto.randomBytes(32))
         return litProtocolGroupKey !== undefined ? litProtocolGroupKey : GroupKey.generate()
     }

packages/client/src/subscribe/Decrypt.ts

@@ -20,7 +20,7 @@ export class Decrypt {
         private keyExchange: SubscriberKeyExchange,
         private streamRegistryCached: StreamRegistryCached,
         private destroySignal: DestroySignal,
-        @inject(LitProtocolKeyStore) private readonly litProtocolKeyStore: LitProtocolKeyStore,
+        private readonly litProtocolKeyStore: LitProtocolKeyStore,
         @inject(LoggerFactory) loggerFactory: LoggerFactory,
         @inject(StreamrClientEventEmitter) private eventEmitter: StreamrClientEventEmitter,
         @inject(ConfigInjectionToken) private config: Pick<StrictStreamrClientConfig, 'decryption'>
@@ -49,26 +49,26 @@ export class Decrypt {
             const groupKeyId = streamMessage.groupKeyId!
 
             let groupKey = await this.groupKeyStore.get(groupKeyId, streamMessage.getStreamId())
-            if (groupKey === undefined) {
+            if (groupKey === undefined) { // 1st try lit protocol
                 groupKey = await this.litProtocolKeyStore.get(streamMessage.getStreamId(), groupKeyId)
                 if (groupKey !== undefined) {
                     await this.groupKeyStore.add(groupKey, streamMessage.getStreamId())
                 }
             }
-            if (groupKey === undefined) {
+            if (groupKey === undefined) { // 2nd try group-key exchange
                 await this.keyExchange.requestGroupKey(
                     streamMessage.groupKeyId,
                     streamMessage.getPublisherId(),
                     streamMessage.getStreamPartID()
                 )
                 try {
                     const groupKeys = await waitForEvent(
-                                        // TODO remove "as any" type casing in NET-889
-                                        this.eventEmitter as any,
-                                        'addGroupKey',
-                                        this.config.decryption.keyRequestTimeout,
-                                        (storedGroupKey: GroupKey) => storedGroupKey.id === groupKeyId,
-                                        this.destroySignal.abortSignal)
+                        // TODO remove "as any" type casing in NET-889
+                        this.eventEmitter as any,
+                        'addGroupKey',
+                        this.config.decryption.keyRequestTimeout,
+                        (storedGroupKey: GroupKey) => storedGroupKey.id === groupKeyId,
+                        this.destroySignal.abortSignal)
                     groupKey = groupKeys[0] as GroupKey
                 } catch (e: any) {
                     if (this.destroySignal.isDestroyed()) {