refactor: added logs for unsubscribing demand

golemfactory · May 6, 2024 · 693c2df · 693c2df
1 parent 0c8cbfd
commit 693c2df
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git a/examples/basic/hello-world.ts b/examples/basic/hello-world.ts
@@ -54,6 +54,7 @@ import { pinoPrettyLogger } from "@golem-sdk/pino-logger";
 
     // We managed to create the activity, no need to look for more agreement candidates
     proposalSubscription.unsubscribe();
+    await draftProposal.clear();
 
     // Access your work context to perform operations
     const ctx = await glm.activity.createWorkContext(activity);
@@ -69,6 +70,7 @@ import { pinoPrettyLogger } from "@golem-sdk/pino-logger";
 
     // This will keep the script waiting for payments etc
     await lease.finalize();
+    await glm.payment.releaseAllocation(allocation);
   } catch (err) {
     console.error("Failed to run example on Golem", err);
   } finally {

diff --git a/src/shared/yagna/adapters/market-api-adapter.ts b/src/shared/yagna/adapters/market-api-adapter.ts
@@ -24,6 +24,7 @@ export class MarketApiAdapter implements MarketApi {
     if (result?.message) {
       throw new Error(`Failed to unsubscribe from demand: ${result.message}`);
     }
+    this.logger.info("Demand unsubscribed", { demand: demand.id });
   }
 
   observeProposalEvents(demand: DemandNew): Observable<ProposalEvent> {

diff --git a/tests/e2e/activityPool.spec.ts b/tests/e2e/activityPool.spec.ts
@@ -51,7 +51,7 @@ describe("ActivityPool", () => {
   afterEach(async () => {
     await proposalSubscription.unsubscribe();
     await agreementPool.drainAndClear();
-    proposalPool.clear();
+    await proposalPool.clear();
   });
 
   it("should run a simple script on the activity from the pool", async () => {