Implement logger

Fixes akash-network#71 Replaced all `console.log` and `console.error` statements with pino logger statements. * Imported pino and created a logger instance in `examples/create_deployment.ts`, `examples/details_of_single_provider.ts`, `examples/estimate_gas.ts`, `examples/get_deployments.ts`, `examples/get_lease_status.ts`, `examples/list_all_providers.ts`, `src/wallet/storage.ts`, `test.html`, and `tests/test_deployments.ts`. * Replaced all `console.log` statements with `logger.info` in the above files. * Replaced all `console.error` statements with `logger.error` in `examples/create_deployment.ts`.
jaseemuddinn · Oct 29, 2024 · 9e190c3 · 9e190c3
1 parent 5d716b8
commit 9e190c3
Show file tree

Hide file tree

Showing 9 changed files with 50 additions and 21 deletions.
diff --git a/examples/create_deployment.ts b/examples/create_deployment.ts
@@ -12,6 +12,9 @@ import { SDL } from "@akashnetwork/akashjs/build/sdl";
 import { getAkashTypeRegistry } from "@akashnetwork/akashjs/build/stargate";
 import { CertificatePem } from "@akashnetwork/akashjs/build/certificates/certificate-manager/CertificateManager";
 import { certificateManager } from "@akashnetwork/akashjs/build/certificates/certificate-manager";
+import pino from "pino";
+
+const logger = pino();
 
 // update this with your wallet mnemonic
 const rpcEndpoint = "https://rpc.sandbox-01.aksh.pw";
@@ -100,7 +103,7 @@ async function walletFromMnemonic(mnemonic: string) {
   try {
     return await DirectSecp256k1HdWallet.fromMnemonic(mnemonic, { prefix: "akash" });
   } catch (error) {
-    console.error('Could not create wallet from mnemonic, have you updated "examples/fixtures/mnemonic.txt?"');
+    logger.error('Could not create wallet from mnemonic, have you updated "examples/fixtures/mnemonic.txt?"');
     throw error;
   }
 }
@@ -111,7 +114,7 @@ async function createDeployment(sdl: SDL, wallet: DirectSecp256k1HdWallet, clien
   const accounts = await wallet.getAccounts();
 
   if (dseq != 0) {
-    console.log("Skipping deployment creation...");
+    logger.info("Skipping deployment creation...");
     return {
       id: {
         owner: accounts[0].address,
@@ -179,12 +182,12 @@ async function fetchBid(dseq: number, owner: string) {
   const timeout = 1000 * 60 * 5;
 
   while (Date.now() - startTime < timeout) {
-    console.log("Fetching bids...");
+    logger.info("Fetching bids...");
     await new Promise(resolve => setTimeout(resolve, 5000));
     const bids = await client.Bids(request);
 
     if (bids.bids.length > 0 && bids.bids[0].bid !== undefined) {
-      console.log("Bid fetched!");
+      logger.info("Bid fetched!");
       return bids.bids[0].bid;
     }
 
@@ -335,7 +338,7 @@ async function sendManifest(sdl: SDL, lease: Lease, wallet: DirectSecp256k1HdWal
         res.on("error", reject);
 
         res.on("data", chunk => {
-          console.log("Response:", chunk.toString());
+          logger.info("Response:", chunk.toString());
         });
 
         if (res.statusCode !== 200) {
@@ -355,7 +358,7 @@ async function sendManifest(sdl: SDL, lease: Lease, wallet: DirectSecp256k1HdWal
   const timeout = 1000 * 60 * 10;
 
   while (Date.now() - startTime < timeout) {
-    console.log("Waiting for deployment to start...");
+    logger.info("Waiting for deployment to start...");
     const status = await queryLeaseStatus(lease, providerInfo.hostUri, certificate).catch(err => {
       if (err.includes("Could not query lease status: 404")) {
         return undefined;
@@ -367,7 +370,7 @@ async function sendManifest(sdl: SDL, lease: Lease, wallet: DirectSecp256k1HdWal
     if (status) {
       for (const [name, service] of Object.entries(status.services)) {
         if (service.uris) {
-          console.log(`Service ${name} is available at:`, service.uris[0]);
+          logger.info(`Service ${name} is available at:`, service.uris[0]);
           return;
         }
       }
@@ -383,14 +386,14 @@ async function sendManifest(sdl: SDL, lease: Lease, wallet: DirectSecp256k1HdWal
 async function deploy() {
   const { wallet, client, certificate, sdl } = await loadPrerequisites();
 
-  console.log("Creating deployment...");
+  logger.info("Creating deployment...");
   const deployment = await createDeployment(sdl, wallet, client);
 
-  console.log("Creating lease...");
+  logger.info("Creating lease...");
   const lease = await createLease(deployment, wallet, client);
 
-  console.log("Sending manifest...");
+  logger.info("Sending manifest...");
   return await sendManifest(sdl, lease, wallet, certificate);
 }
 
-deploy().catch(console.error);
+deploy().catch(logger.error);
diff --git a/examples/details_of_single_provider.ts b/examples/details_of_single_provider.ts
@@ -1,5 +1,8 @@
 import { QueryClientImpl, QueryProviderRequest, QueryProviderResponse } from "@akashnetwork/akash-api/akash/provider/v1beta3";
 import { getRpc } from "@akashnetwork/akashjs/build/rpc";
+import pino from "pino";
+
+const logger = pino();
 
 async function main() {
   const client = new QueryClientImpl(await getRpc("http://your.rpc.node"));
@@ -10,7 +13,7 @@ async function main() {
   const providerResponse = await client.Provider(getProviderInfoRequest);
   const data = QueryProviderResponse.toJSON(providerResponse);
 
-  console.log(data);
+  logger.info(data);
 }
 
 main();
diff --git a/examples/estimate_gas.ts b/examples/estimate_gas.ts
@@ -2,6 +2,9 @@ import { DirectSecp256k1HdWallet, Registry } from "@cosmjs/proto-signing";
 import { SigningStargateClient } from "@cosmjs/stargate";
 import { MsgCloseDeployment } from "@akashnetwork/akash-api/akash/deployment/v1beta3";
 import { getAkashTypeRegistry, getTypeUrl } from "@akashnetwork/akashjs/build/stargate";
+import pino from "pino";
+
+const logger = pino();
 
 async function main() {
   const mnemonic = "your wallet mnemonic";
@@ -35,7 +38,7 @@ async function main() {
 
   const gas = await client.simulate(account.address, [msgAny], "take down deployment");
 
-  console.log(gas);
+  logger.info(gas);
 }
 
 main();
diff --git a/examples/get_deployments.ts b/examples/get_deployments.ts
@@ -1,5 +1,8 @@
 import { QueryDeploymentsResponse, QueryDeploymentsRequest, QueryClientImpl } from "@akashnetwork/akash-api/akash/deployment/v1beta3";
 import { getRpc } from "@akashnetwork/akashjs/build/rpc";
+import pino from "pino";
+
+const logger = pino();
 
 async function main() {
   const request = QueryDeploymentsRequest.fromJSON({
@@ -12,7 +15,7 @@ async function main() {
   const response = await client.Deployments(request);
   const data = QueryDeploymentsResponse.toJSON(response);
 
-  console.log(data);
+  logger.info(data);
 }
 
 main();
diff --git a/examples/get_lease_status.ts b/examples/get_lease_status.ts
@@ -1,5 +1,8 @@
 import { QueryClientImpl, QueryLeaseRequest, QueryLeaseResponse } from "@akashnetwork/akash-api/akash/market/v1beta4";
 import { getRpc } from "@akashnetwork/akashjs/build/rpc";
+import pino from "pino";
+
+const logger = pino();
 
 async function main() {
   const client = new QueryClientImpl(await getRpc("http://your.rpc.node"));
@@ -17,7 +20,7 @@ async function main() {
   const leaseStatusResponse = await client.Lease(getLeaseStatusRequest);
   const data = QueryLeaseResponse.toJSON(leaseStatusResponse);
 
-  console.log(data);
+  logger.info(data);
 }
 
 main();
diff --git a/examples/list_all_providers.ts b/examples/list_all_providers.ts
@@ -1,5 +1,8 @@
 import { QueryClientImpl, QueryProvidersRequest, QueryProvidersResponse } from "@akashnetwork/akash-api/akash/provider/v1beta3";
 import { getRpc } from "@akashnetwork/akashjs/build/rpc";
+import pino from "pino";
+
+const logger = pino();
 
 async function main() {
   const client = new QueryClientImpl(await getRpc("http://your.rpc.node"));
@@ -13,7 +16,7 @@ async function main() {
   const providersResponse = await client.Providers(providersRequest);
   const data = QueryProvidersResponse.toJSON(providersResponse);
 
-  console.log(data);
+  logger.info(data);
 }
 
 main();
diff --git a/src/wallet/storage.ts b/src/wallet/storage.ts
@@ -1,9 +1,13 @@
+import pino from 'pino';
+
+const logger = pino();
+
 /**
  * This file fills keytar in browser, to use localStorage in place.
  */
 
 export async function getPassword() {
-  console.log("keytar fill");
+  logger.info("keytar fill");
   return "click harvest range include miss vessel permit kiss clarify now grocery assist";
 }
 

diff --git a/test.html b/test.html
@@ -12,7 +12,11 @@
   <button id="getCerts">Get Certs</button>
 
   <script type="text/javascript">
-    console.log(akjs);
+    import pino from 'pino';
+
+    const logger = pino();
+
+    logger.info(akjs);
 
     const fn = async () => {
       const certs = await akjs.certificate.createCertificate("akash12345");
@@ -27,7 +31,7 @@
       document.querySelector("#privateKey").value = certs.privateKey;
 
       window.addEventListener("DOMContentLoaded", async (event) => {
-        console.log("DOM fully loaded and parsed");
+        logger.info("DOM fully loaded and parsed");
         chain = akjs.keplr.getChains().testnet;
         signer = await akjs.keplr.getSigner(chain);
         client = await akjs.keplr.get(chain, signer);
@@ -45,7 +49,7 @@
               client
             );
           } catch (error) {
-            console.log(`Akash Transport : ${error.message}`);
+            logger.info(`Akash Transport : ${error.message}`);
           }
         });
 
@@ -58,7 +62,7 @@
             })
           );
 
-          console.log(certs);
+          logger.info(certs);
         });
     };
 

diff --git a/tests/test_deployments.ts b/tests/test_deployments.ts
@@ -1,4 +1,5 @@
 import tap from "tap";
+import pino from "pino";
 
 import { testSnap } from "./util";
 
@@ -11,6 +12,8 @@ import {
   QueryDeploymentsResponse
 } from "@akashnetwork/akash-api/akash/deployment/v1beta3/query";
 
+const logger = pino();
+
 tap.test("Deployments: query deployment list with owner filter", async t => {
   t.plan(1);