Merge pull request #47 from loneil/feature/deleteOob

Delete OOB utility function
hyperledger · Mar 25, 2024 · c476335 · c476335
2 parents beb2288 + ebbe208
commit c476335
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/load-agent/agent.ts b/load-agent/agent.ts
@@ -271,6 +271,10 @@ const pingMediator = async (agent) => {
   }
 }
 
+let deleteOobRecordById = async (agent, id) => {
+  await agent.oob.deleteById(id);
+};
+
 let receiveInvitation = async (agent, invitationUrl) => {
   // wait for the connection
   let timeout = config.verified_timeout_seconds * 1000
@@ -578,6 +582,12 @@ rl.on('line', async (line) => {
       process.stdout.write(
         JSON.stringify({ error: 0, result: 'Ping Mediator' }) + '\n'
       )
+    } else if (command['cmd'] == 'deleteOobRecordById') {
+      await deleteOobRecordById(agent, command['id'])
+
+      process.stdout.write(
+        JSON.stringify({ error: 0, result: 'Delete OOB Record' }) + '\n'
+      )
     } else if (command['cmd'] == 'receiveInvitation') {
       let connection = await receiveInvitation(agent, command['invitationUrl'])
 

diff --git a/load-agent/locustClient.py b/load-agent/locustClient.py
@@ -266,6 +266,12 @@ def issuer_getinvite(self):
     def issuer_getliveness(self):
         return self.issuer.is_up()
 
+    @stopwatch
+    def delete_oob(self, id):
+        self.run_command({"cmd": "deleteOobRecordById", "id": id})
+
+        line = self.readjsonline()
+
     @stopwatch
     def accept_invite(self, invite, useConnectionDid=False):
         try: