diff --git a/examples/create_deployment.ts b/examples/create_deployment.ts index c666500..164a119 100644 --- 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 index 4b10c6a..d8799f6 100644 --- 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 index db822af..4025f7f 100644 --- 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 index 50f1a2c..13a3335 100644 --- 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 index 119b231..7b70406 100644 --- 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 index 9ea1d1f..d7e52dd 100644 --- 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 index c269ea2..b41d9d8 100644 --- 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 index 8c796e5..9469141 100644 --- a/test.html +++ b/test.html @@ -12,7 +12,11 @@