feat(bungee): support merging views according to a privacy policy

Signed-off-by: eduv09 <eduardovasques10@tecnico.ulisboa.pt>

packages/cactus-plugin-bungee/src/main/typescript/plugin-bungee.ts

@@ -28,6 +28,7 @@ import {
 } from "./generated/openapi/typescript-axios";
 import { Snapshot } from "./view-creation/snapshot";
 import { View } from "./view-creation/view";
+import { IntegratedView } from "./view-merging/integrated-view";
 import {
   NetworkDetails,
   ObtainLedgerStrategy,
@@ -232,4 +233,37 @@ export class PluginBUNGEE implements ICactusPlugin, IPluginWebService {
 
     return snapshot;
   }
+
+  public mergeViews(
+    views: View[],
+    privacyPolicy: string = "no privacy policy",
+  ): { view: IntegratedView; signature: string } {
+    const integratedView = new IntegratedView(privacyPolicy);
+
+    for (const view of views) {
+      integratedView.addParticipant(view.getSnapshot().getParticipant());
+      for (const state of view.getSnapshot().getStateBins()) {
+        if (integratedView.getExtendedState(state.getId()) == undefined) {
+          integratedView.createExtendedState(state.getId());
+        }
+        integratedView.addStateInExtendedState(
+          state.getId(),
+          view.getKey(),
+          state,
+        );
+        // eslint-disable-next-line prettier/prettier
+        if (parseInt(state.getInitialTime()) < parseInt(integratedView.getTI())) {
+          integratedView.setTI(state.getInitialTime());
+        }
+
+        if (parseInt(state.getFinalTime()) > parseInt(integratedView.getTF())) {
+          integratedView.setTF(state.getFinalTime());
+        }
+      }
+    }
+    return {
+      view: integratedView,
+      signature: this.sign(JSON.stringify(integratedView)),
+    };
+  }
 }

packages/cactus-plugin-bungee/src/main/typescript/view-creation/snapshot.ts

@@ -17,6 +17,10 @@ export class Snapshot {
     return this.id;
   }
 
+  public getParticipant(): string {
+    return this.participant;
+  }
+
   public getTI() {
     return this.tI;
   }

packages/cactus-plugin-bungee/src/main/typescript/view-creation/view.ts

@@ -19,6 +19,11 @@ export class View {
     this.snapshot = snapshot;
     snapshot.pruneStates(this.tI, this.tF);
   }
+
+  public getSnapshot(): Snapshot {
+    return this.snapshot;
+  }
+
   public getKey() {
     return this.key;
   }

packages/cactus-plugin-bungee/src/main/typescript/view-merging/extended-state.ts

@@ -0,0 +1,16 @@
+import { State } from "../view-creation/state";
+
+export class ExtendedState {
+  private states: Map<string, State>;
+  constructor() {
+    this.states = new Map<string, State>();
+  }
+  public getState(viewId: string): State | undefined {
+    return this.states.get(viewId);
+  }
+  public setState(viewId: string, state: State) {
+    if (this.getState(viewId) == undefined) {
+      this.states.set(viewId, state);
+    }
+  }
+}

packages/cactus-plugin-bungee/src/main/typescript/view-merging/integrated-view.ts

@@ -0,0 +1,55 @@
+import { State } from "../view-creation/state";
+import { ExtendedState } from "./extended-state";
+
+export class IntegratedView {
+  private stateList: Map<string, ExtendedState>;
+  private tI: string;
+  private tF: string;
+  private participants: string[];
+  private privacyPolicy: string;
+  constructor(privacyPolicy: string) {
+    this.stateList = new Map<string, ExtendedState>();
+    this.tI = "999999999999999";
+    this.tF = "0";
+    this.participants = [];
+    this.privacyPolicy = privacyPolicy;
+  }
+  public getTI(): string {
+    return this.tI;
+  }
+  public setTI(tI: string) {
+    this.tI = tI;
+  }
+  public getTF(): string {
+    return this.tF;
+  }
+  public setTF(TF: string) {
+    this.tF = TF;
+  }
+  public addParticipant(participant: string) {
+    this.participants.push(participant);
+  }
+  public getExtendedState(stateId: string): ExtendedState | undefined {
+    return this.stateList.get(stateId);
+  }
+
+  public createExtendedState(stateId: string) {
+    if (this.getExtendedState(stateId) == undefined) {
+      this.stateList.set(stateId, new ExtendedState());
+    }
+  }
+  public addStateInExtendedState(
+    stateId: string,
+    viewId: string,
+    state: State,
+  ) {
+    const extendedState = this.getExtendedState(stateId);
+    if (extendedState != undefined) {
+      extendedState.setState(viewId, state);
+    }
+  }
+
+  public getState(stateId: string, viewId: string): State | undefined {
+    return this.getExtendedState(stateId)?.getState(viewId);
+  }
+}

packages/cactus-plugin-bungee/tsconfig.json

@@ -33,9 +33,6 @@
     },
     {
       "path": "../cactus-core/tsconfig.json"
-    },
-    {
-      "path": "../../extensions/cactus-plugin-object-store-ipfs/tsconfig.json"
     }
   ]
 }