diff --git a/frontend/proof-of-existence/src/assets/images/copy-icon.svg b/frontend/proof-of-existence/src/assets/images/copy-icon.svg
new file mode 100644
index 000000000..764d716e2
--- /dev/null
+++ b/frontend/proof-of-existence/src/assets/images/copy-icon.svg
@@ -0,0 +1,3 @@
+<svg width="24" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg">
+<path d="M11.9991 23.9992H3.99741C2.37868 23.9992 1.40336 23.9992 0.698684 23.2946C-0.0059967 22.5899 -0.0059967 21.6146 -0.0059967 19.9958V11.9941C-0.0059967 10.3754 -0.0059967 9.4001 0.698684 8.69542C1.40336 7.99074 2.37868 7.99073 3.99741 7.99073H11.9991C13.6178 7.99073 14.5931 7.99074 15.2978 8.69542C16.0025 9.4001 16.0025 10.3754 16.0025 11.9941V19.9958C16.0025 21.6146 16.0025 22.5899 15.2978 23.2946C14.5931 23.9992 13.6178 23.9992 11.9991 23.9992ZM3.99741 9.59924C2.83315 9.59924 2.06719 9.59925 1.8323 9.83414C1.59741 10.069 1.59741 10.835 1.59741 11.9992V20.0009C1.59741 21.1652 1.59741 21.9312 1.8323 22.166C2.06719 22.4009 2.83315 22.4009 3.99741 22.4009H11.9991C13.1634 22.4009 13.9293 22.4009 14.1642 22.166C14.3991 21.9312 14.3991 21.1652 14.3991 20.0009V11.9992C14.3991 10.835 14.3991 10.069 14.1642 9.83414C13.9293 9.59925 13.1634 9.59924 11.9991 9.59924H3.99741ZM19.9957 15.9975H18.3974C17.9531 15.9975 17.5957 15.6401 17.5957 15.1958C17.5957 14.7516 17.9531 14.3941 18.3974 14.3941H19.9957C21.16 14.3941 21.9259 14.3941 22.1608 14.1592C22.3957 13.9243 22.3957 13.1584 22.3957 11.9941V3.99754C22.3957 2.83329 22.3957 2.06733 22.1608 1.83244C21.9259 1.59754 21.16 1.59754 19.9957 1.59754H11.994C10.8297 1.59754 10.0638 1.59754 9.82889 1.83244C9.594 2.06733 9.594 2.83329 9.594 3.99754V5.59584C9.594 6.0401 9.23655 6.39754 8.7923 6.39754C8.34804 6.39754 7.9906 6.0401 7.9906 5.59584V3.99754C7.9906 2.37882 7.9906 1.4035 8.69528 0.698821C9.39996 -0.00585938 10.3753 -0.00585938 11.994 -0.00585938H19.9957C21.6144 -0.00585938 22.5897 -0.00585938 23.2944 0.698821C23.9991 1.4035 23.9991 2.37882 23.9991 3.99754V11.9992C23.9991 13.618 23.9991 14.5933 23.2944 15.298C22.5897 16.0026 21.6144 16.0026 19.9957 16.0026V15.9975Z" fill="white"/>
+</svg>
diff --git a/frontend/proof-of-existence/src/utils/wallet-utils.ts b/frontend/proof-of-existence/src/utils/wallet-utils.ts
new file mode 100644
index 000000000..14bbd2c20
--- /dev/null
+++ b/frontend/proof-of-existence/src/utils/wallet-utils.ts
@@ -0,0 +1,15 @@
+import { Wallet } from "@/types/enums";
+import type { Keplr } from "@keplr-wallet/types";
+
+export function getWalletFromType(wallet: string): Keplr {
+  switch (wallet) {
+    case Wallet.Keplr:
+      return window.keplr;
+    case Wallet.Cosmostation:
+      return window.cosmostation.providers.keplr;
+    case Wallet.Leap:
+      return window.leap;
+    default:
+      throw new Error("Wallet not supported");
+  }
+}
diff --git a/frontend/proof-of-existence/src/views/certify/CreateProofView.vue b/frontend/proof-of-existence/src/views/certify/CreateProofView.vue
index 1dc8a9e0f..f2189c851 100644
--- a/frontend/proof-of-existence/src/views/certify/CreateProofView.vue
+++ b/frontend/proof-of-existence/src/views/certify/CreateProofView.vue
@@ -12,6 +12,7 @@ import { CHAIN_ID, RPC_URL } from "@/config/config";
 import type { OfflineSigner } from "@cosmjs/proto-signing";
 import type { DeliverTxResponse } from "@cosmjs/stargate/build/stargateclient";
 import { toast } from "vue3-toastify";
+import { getWalletFromType } from "@/utils/wallet-utils";
 
 const fee = {
   amount: [{ amount: "100000", denom: "umpwr" }],
@@ -28,6 +29,8 @@ const showModal = ref(false);
 const selectedWallet = ref("");
 const errorMessage = ref<string | undefined>();
 const loading = ref(false);
+const address = ref();
+const addressVisible = ref();
 
 //Methods
 const back = () => {
@@ -46,9 +49,21 @@ const closeModal = () => {
 
 const handleSelectedWallet = (wallet: Wallet) => {
   selectedWallet.value = wallet;
+  showWalletAddress(wallet);
   closeModal();
 };
 
+const showWalletAddress = async (selectedWallet: Wallet) => {
+  const wallet = getWalletFromType(selectedWallet);
+  const account = await wallet.getKey(CHAIN_ID);
+  const walletAddress = account.bech32Address;
+  address.value = walletAddress;
+  addressVisible.value =
+    walletAddress?.substring(0, 10) +
+    "..." +
+    walletAddress?.substring(walletAddress?.length - 4);
+};
+
 const handleTransaction = async () => {
   loading.value = true;
   switch (selectedWallet.value) {
@@ -125,6 +140,11 @@ const pushToSuccessPage = () => {
     },
   });
 };
+
+const copyAddress = async () => {
+  await navigator.clipboard.writeText(address.value);
+  toast.success("Address copied to clipboard");
+};
 </script>
 <template>
   <SelectWalletModel
@@ -209,6 +229,14 @@ const pushToSuccessPage = () => {
           class="h-20 cursor-pointer mb-3"
           v-if="selectedWallet === Wallet.Leap"
         />
+        <div
+          v-if="addressVisible"
+          class="flex flex-row bg-lightGray rounded-lg p-2 cursor-pointer w-fit mt-5 flex-wrap"
+          @click="copyAddress"
+        >
+          <p class="text-white text-title12">{{ addressVisible }}</p>
+          <img class="w-4 ml-4" src="../../assets/images/copy-icon.svg" />
+        </div>
         <button
           @click="openModal"
           class="bg-lightGreen mt-7 content-center p-1 px-7 rounded text-white"
diff --git a/indexer/scripts/build-with-env.sh b/indexer/scripts/build-with-env.sh
index e6536ba8b..5b02a21bb 100755
--- a/indexer/scripts/build-with-env.sh
+++ b/indexer/scripts/build-with-env.sh
@@ -1,14 +1,20 @@
 #!/bin/bash
 set -e
 
-# Get Google Maps API key from .env file (trim double quotes)
+# Get Google Maps API key, Rollbar access token and environment from .env file (trim double quotes)
 GOOGLE_MAPS_API_KEY=$(grep GOOGLE_MAPS_API_KEY .env | cut -d '=' -f2 | sed 's/"//g')
+ROLLBAR_ACCESS_TOKEN=$(grep ROLLBAR_ACCESS_TOKEN .env | cut -d '=' -f2 | sed 's/"//g')
+ENVIRONMENT=$(grep ENVIRONMENT .env | cut -d '=' -f2 | sed 's/"//g')
 
-# Replace $KEY in src/mappings/mappingHandlers.ts with Google Maps API key
+# Replace $GOOGLE_MAPS_API_KEY, $ROLLBAR_ACCESS_TOKEN and $ENVIRONMENT in src/mappings/mappingHandlers.ts
 if [[ "$OSTYPE" == "linux-gnu"* ]]; then
-    sed -i "s/\$KEY/$GOOGLE_MAPS_API_KEY/g" ./src/mappings/mappingHandlers.ts
+    sed -i "s/\$GOOGLE_MAPS_API_KEY/$GOOGLE_MAPS_API_KEY/g" ./src/mappings/mappingHandlers.ts
+    sed -i "s/\$ROLLBAR_ACCESS_TOKEN/$ROLLBAR_ACCESS_TOKEN/g" ./src/mappings/mappingHandlers.ts
+    sed -i "s/\$ENVIRONMENT/$ENVIRONMENT/g" ./src/mappings/mappingHandlers.ts
 elif [[ "$OSTYPE" == "darwin"* ]]; then
-    sed -i '' "s/\$KEY/$GOOGLE_MAPS_API_KEY/g" ./src/mappings/mappingHandlers.ts
+    sed -i '' "s/\$GOOGLE_MAPS_API_KEY/$GOOGLE_MAPS_API_KEY/g" ./src/mappings/mappingHandlers.ts
+    sed -i '' "s/\$ROLLBAR_ACCESS_TOKEN/$ROLLBAR_ACCESS_TOKEN/g" ./src/mappings/mappingHandlers.ts
+    sed -i '' "s/\$ENVIRONMENT/$ENVIRONMENT/g" ./src/mappings/mappingHandlers.ts
 fi
 
 # Build project
@@ -16,7 +22,11 @@ subql build
 
 # Restore original mappingHandlers.ts
 if [[ "$OSTYPE" == "linux-gnu"* ]]; then
-    sed -i "s/$GOOGLE_MAPS_API_KEY/\$KEY/g" ./src/mappings/mappingHandlers.ts
+    sed -i "s/$GOOGLE_MAPS_API_KEY/\$GOOGLE_MAPS_API_KEY/g" ./src/mappings/mappingHandlers.ts
+    sed -i "s/$ROLLBAR_ACCESS_TOKEN/\$ROLLBAR_ACCESS_TOKEN/g" ./src/mappings/mappingHandlers.ts
+    sed -i "s/$ENVIRONMENT/\$ENVIRONMENT/g" ./src/mappings/mappingHandlers.ts
 elif [[ "$OSTYPE" == "darwin"* ]]; then
-    sed -i '' "s/$GOOGLE_MAPS_API_KEY/\$KEY/g" ./src/mappings/mappingHandlers.ts
+    sed -i '' "s/$GOOGLE_MAPS_API_KEY/\$GOOGLE_MAPS_API_KEY/g" ./src/mappings/mappingHandlers.ts
+    sed -i '' "s/$ROLLBAR_ACCESS_TOKEN/\$ROLLBAR_ACCESS_TOKEN/g" ./src/mappings/mappingHandlers.ts
+    sed -i '' "s/$ENVIRONMENT/\$ENVIRONMENT/g" ./src/mappings/mappingHandlers.ts
 fi
\ No newline at end of file
diff --git a/indexer/src/mappings/mappingHandlers.ts b/indexer/src/mappings/mappingHandlers.ts
index 309bac7c1..bf627940f 100644
--- a/indexer/src/mappings/mappingHandlers.ts
+++ b/indexer/src/mappings/mappingHandlers.ts
@@ -1,12 +1,38 @@
-import { ExecuteEvent, Message, Transaction, Block, CreditCollection, EventData, MaterialData, MetadataUri, MediaFile, BinaryFile, ApplicantData, WebReference, CreditData, CreateListingWasmEvent, MarketplaceListing, BuyCreditsWasmEvent, UpdateListingWasmEvent, CancelListingWasmEvent, Country, Organization, Wallet, CreditBalance, TransferedCreditsEvent, RetiredCreditsEvent, Certificate, CreditOffsetCertificate } from "../types";
+import { CreditCollection, EventData, MaterialData, MetadataUri, MediaFile, BinaryFile, ApplicantData, WebReference, CreditData, CreateListingWasmEvent, MarketplaceListing, BuyCreditsWasmEvent, UpdateListingWasmEvent, CancelListingWasmEvent, Country, Organization, Wallet, CreditBalance, TransferedCreditsEvent, RetiredCreditsEvent, Certificate, CreditOffsetCertificate } from "../types";
 import {
   CosmosEvent,
-  CosmosBlock,
-  CosmosMessage,
-  CosmosTransaction,
 } from "@subql/types-cosmos";
 import fetch from "node-fetch";
 
+async function logRollbarError(error: Error, txHash: string): Promise<void> {
+  const request = await fetch("https://api.rollbar.com/api/1/item/", {
+    method: "POST",
+    headers: {
+      "Content-Type": "application/json",
+      "X-Rollbar-Access-Token": "$ROLLBAR_ACCESS_TOKEN",
+    },
+    body: JSON.stringify({
+      data: {
+        environment: "$ENVIRONMENT",
+        level: "error",
+        timestamp: Date.now() / 1000,
+        platform: "javascript",
+        framework: "node",
+        language: "javascript",
+        body: {
+          message: {
+            body: error?.message,
+          },
+        },
+        custom: {
+          txHash: txHash,
+        },
+      }
+    }),
+  });
+  await request.json();
+}
+
 async function createNewWallet(address: string, applicantId?: number): Promise<Wallet> {
   const wallet = Wallet.create({
     id: address,
@@ -18,7 +44,7 @@ async function createNewWallet(address: string, applicantId?: number): Promise<W
 }
 
 export async function handleCreateListing(event: CosmosEvent): Promise<void> {
-
+try {
   const listingOwner = fetchPropertyFromEvent(event, "listing_owner");
   const denom = fetchPropertyFromEvent(event, "denom");
   const numberOfCredits = BigInt(fetchPropertyFromEvent(event, "number_of_credits"));
@@ -48,10 +74,14 @@ export async function handleCreateListing(event: CosmosEvent): Promise<void> {
     creditCollectionId: denom,
   });
   await marketplaceListing.save();
+} catch (e) {
+  await logRollbarError(e, event.tx.hash);
+  throw new Error("Error in handleCreateListing: " + e.message);
+}
 }
 
 export async function handleUpdateListing(event: CosmosEvent): Promise<void> {
-
+try {
   const listingOwner = fetchPropertyFromEvent(event, "listing_owner");
   const denom = fetchPropertyFromEvent(event, "denom");
   const numberOfCredits = BigInt(fetchPropertyFromEvent(event, "number_of_credits"));
@@ -75,9 +105,16 @@ export async function handleUpdateListing(event: CosmosEvent): Promise<void> {
   marketplaceListing.pricePerCreditAmount = pricePerCreditAmount;
   marketplaceListing.pricePerCreditDenom = pricePerCreditDenom;
   await marketplaceListing.save();
+} catch (e) {
+  await logRollbarError(e, event.tx.hash);
+  throw new Error("Error in handleUpdateListing: " + e.message);
+}
 }
 
 export async function handleCancelListing(event: CosmosEvent): Promise<void> {
+  try {
+    const listingOwner = fetchPropertyFromEvent(event, "listing_owner");
+    const denom = fetchPropertyFromEvent(event, "denom");
 
   const listingOwner = fetchPropertyFromEvent(event, "listing_owner");
   const denom = fetchPropertyFromEvent(event, "denom");
@@ -90,148 +127,171 @@ export async function handleCancelListing(event: CosmosEvent): Promise<void> {
   });
   await cancelListingWasmEvent.save();
 
-  await MarketplaceListing.remove(`${listingOwner}-${denom}`);
+    await MarketplaceListing.remove(`${listingOwner}-${denom}`);
+  } catch (e) {
+    await logRollbarError(e, event.tx.hash);
+    throw new Error("Error in handleCancelListing: " + e.message);
+  }
 }
 
 export async function handleBuyCredits(event: CosmosEvent): Promise<void> {
+  try {
+    const listingOwner = fetchPropertyFromEvent(event, "listing_owner");
+    const denom = fetchPropertyFromEvent(event, "denom");
+    const buyer = fetchPropertyFromEvent(event, "buyer");
+    const numberOfCreditsBought = BigInt(fetchPropertyFromEvent(event, "number_of_credits_bought"));
+    const totalPriceAmount = BigInt(fetchPropertyFromEvent(event, "total_price_amount"));
+    const totalPriceDenom = fetchPropertyFromEvent(event, "total_price_denom");
+
+    // this is because there is a bug in SubQuery, which causes event to be processed multiple times
+    // for every transaction in the same block, therefore we're skipping processing
+    // of events that are already present in the database
+    const eventAlreadyProcessed = await BuyCreditsWasmEvent.get(`${event.tx.hash}-${event.msg.idx}-${event.idx}`);
+    if (eventAlreadyProcessed) {
+      return;
+    }
 
-  const listingOwner = fetchPropertyFromEvent(event, "listing_owner");
-  const denom = fetchPropertyFromEvent(event, "denom");
-  const buyer = fetchPropertyFromEvent(event, "buyer");
-  const numberOfCreditsBought = BigInt(fetchPropertyFromEvent(event, "number_of_credits_bought"));
-  const totalPriceAmount = BigInt(fetchPropertyFromEvent(event, "total_price_amount"));
-  const totalPriceDenom = fetchPropertyFromEvent(event, "total_price_denom");
-
-  // this is because there is a bug in SubQuery, which causes event to be processed multiple times
-  // for every transaction in the same block, therefore we're skipping processing
-  // of events that are already present in the database
-  const eventAlreadyProcessed = await BuyCreditsWasmEvent.get(`${event.tx.hash}-${event.msg.idx}-${event.idx}`);
-  if (eventAlreadyProcessed) {
-    return;
-  }
-
-  const buyCreditsWasmEvent = BuyCreditsWasmEvent.create({
-    id: `${event.tx.hash}-${event.msg.idx}-${event.idx}`,
-    listingOwner: listingOwner,
-    denom: denom,
-    buyer: buyer,
-    numberOfCreditsBought: numberOfCreditsBought,
-    totalPriceAmount: totalPriceAmount,
-    totalPriceDenom: totalPriceDenom,
-    saleDate: new Date(event.block.header.time.toISOString())
-  });
-  await buyCreditsWasmEvent.save();
-
-  const marketplaceListing = await MarketplaceListing.get(`${listingOwner}-${denom}`);
-  marketplaceListing.amount = marketplaceListing.amount - numberOfCreditsBought;
-  if (marketplaceListing.amount === BigInt(0)) {
-    await MarketplaceListing.remove(`${listingOwner}-${denom}`);
-  } else {
-    await marketplaceListing.save();
+    const buyCreditsWasmEvent = BuyCreditsWasmEvent.create({
+      id: `${event.tx.hash}-${event.msg.idx}-${event.idx}`,
+      listingOwner: listingOwner,
+      denom: denom,
+      buyer: buyer,
+      numberOfCreditsBought: numberOfCreditsBought,
+      totalPriceAmount: totalPriceAmount,
+      totalPriceDenom: totalPriceDenom,
+      saleDate: new Date(event.block.header.time.toISOString())
+    });
+    await buyCreditsWasmEvent.save();
+
+    const marketplaceListing = await MarketplaceListing.get(`${listingOwner}-${denom}`);
+    marketplaceListing.amount = marketplaceListing.amount - numberOfCreditsBought;
+    if (marketplaceListing.amount === BigInt(0)) {
+      await MarketplaceListing.remove(`${listingOwner}-${denom}`);
+    } else {
+      await marketplaceListing.save();
+    }
+  } catch (e) {
+    await logRollbarError(e, event.tx.hash);
+    throw new Error("Error in handleBuyCredits: " + e.message);
   }
 }
 
 export async function handleWasmEvents(event: CosmosEvent): Promise<void> {
-  const action = fetchPropertyFromEvent(event, "action");
-  switch (action) {
-    case "create_listing":
-      await handleCreateListing(event);
-      break;
-    case "update_listing":
-      await handleUpdateListing(event);
-      break;
-    case "cancel_listing":
-      await handleCancelListing(event);
-      break;
-    case "buy_credits":
-      await handleBuyCredits(event);
-      break;
-    default:
-      break;
+  try {
+    const action = fetchPropertyFromEvent(event, "action");
+    switch (action) {
+      case "create_listing":
+        await handleCreateListing(event);
+        break;
+      case "update_listing":
+        await handleUpdateListing(event);
+        break;
+      case "cancel_listing":
+        await handleCancelListing(event);
+        break;
+      case "buy_credits":
+        await handleBuyCredits(event);
+        break;
+      default:
+        break;
+    }
+  } catch (e) {
+    await logRollbarError(e, event.tx.hash);
+    throw new Error("Error in handleWasmEvents: " + e.message);
   }
 }
 
 export async function handleTransferCredits(event: CosmosEvent): Promise<void> {
-  const sender = fetchPropertyFromEvent(event, "sender");
-  const recipient = fetchPropertyFromEvent(event, "recipient");
-  const denom = fetchPropertyFromEvent(event, "denom");
-  const amount = BigInt(fetchPropertyFromEvent(event, "amount"));
-
-  // this is because there is a bug in SubQuery, which causes event to be processed multiple times
-  // for every transaction in the same block, therefore we're skipping processing
-  // of events that are already present in the database
-  const eventAlreadyProcessed = await TransferedCreditsEvent.get(`${event.tx.hash}-${event.msg.idx}-${event.idx}`);
-  if (eventAlreadyProcessed) {
-    return;
-  }
-
-  const transferedCreditsEvent = TransferedCreditsEvent.create({
-    id: `${event.tx.hash}-${event.msg.idx}-${event.idx}`,
-    sender: sender,
-    recipient: recipient,
-    amount: amount,
-    creditCollectionId: denom,
-  });
-  await transferedCreditsEvent.save();
-
-  let senderBalance = await CreditBalance.get(`${sender}-${denom}`);
-  senderBalance.amountActive = senderBalance.amountActive - amount;
-  await senderBalance.save();
+  try {
+    const sender = fetchPropertyFromEvent(event, "sender");
+    const recipient = fetchPropertyFromEvent(event, "recipient");
+    const denom = fetchPropertyFromEvent(event, "denom");
+    const amount = BigInt(fetchPropertyFromEvent(event, "amount"));
+
+    // this is because there is a bug in SubQuery, which causes event to be processed multiple times
+    // for every transaction in the same block, therefore we're skipping processing
+    // of events that are already present in the database
+    const eventAlreadyProcessed = await TransferedCreditsEvent.get(`${event.tx.hash}-${event.msg.idx}-${event.idx}`);
+    if (eventAlreadyProcessed) {
+      return;
+    }
 
-  let recipientWallet = await Wallet.get(recipient);
-  if (!recipientWallet) {
-    recipientWallet = Wallet.create({
-      id: recipient,
-      address: recipient,
-    });
-    await recipientWallet.save();
-  }
-  let recipientBalance = await CreditBalance.get(`${recipient}-${denom}`);
-  if (!recipientBalance) {
-    recipientBalance = CreditBalance.create({
-      id: `${recipient}-${denom}`,
-      walletId: recipientWallet.id,
+    const transferedCreditsEvent = TransferedCreditsEvent.create({
+      id: `${event.tx.hash}-${event.msg.idx}-${event.idx}`,
+      sender: sender,
+      recipient: recipient,
+      amount: amount,
       creditCollectionId: denom,
-      amountActive: amount,
-      amountRetired: BigInt(0),
     });
-    await recipientBalance.save();
-  } else {
-    recipientBalance.amountActive = recipientBalance.amountActive + amount;
-    await recipientBalance.save();
+    await transferedCreditsEvent.save();
+
+    let senderBalance = await CreditBalance.get(`${sender}-${denom}`);
+    senderBalance.amountActive = senderBalance.amountActive - amount;
+    await senderBalance.save();
+
+    let recipientWallet = await Wallet.get(recipient);
+    if (!recipientWallet) {
+      recipientWallet = Wallet.create({
+        id: recipient,
+        address: recipient,
+      });
+      await recipientWallet.save();
+    }
+    let recipientBalance = await CreditBalance.get(`${recipient}-${denom}`);
+    if (!recipientBalance) {
+      recipientBalance = CreditBalance.create({
+        id: `${recipient}-${denom}`,
+        walletId: recipientWallet.id,
+        creditCollectionId: denom,
+        amountActive: amount,
+        amountRetired: BigInt(0),
+      });
+      await recipientBalance.save();
+    } else {
+      recipientBalance.amountActive = recipientBalance.amountActive + amount;
+      await recipientBalance.save();
+    }
+  } catch (e) {
+    await logRollbarError(e, event.tx.hash);
+    throw new Error("Error in handleTransferCredits: " + e.message);
   }
 }
 
 export async function handleRetiredCredits(event: CosmosEvent): Promise<void> {
-  const owner = fetchPropertyFromEvent(event, "owner");
-  const denom = fetchPropertyFromEvent(event, "denom");
-  const amount = BigInt(fetchPropertyFromEvent(event, "amount"));
-
-  // this is because there is a bug in SubQuery, which causes event to be processed multiple times
-  // for every transaction in the same block, therefore we're skipping processing
-  // of events that are already present in the database
-  const eventAlreadyProcessed = await RetiredCreditsEvent.get(`${event.tx.hash}-${event.msg.idx}-${event.idx}`);
-  if (eventAlreadyProcessed) {
-    return;
-  }
-
-  const retiredCreditsEvent = RetiredCreditsEvent.create({
-    id: `${event.tx.hash}-${event.msg.idx}-${event.idx}`,
-    owner: owner,
-    amount: amount,
-    creditCollectionId: denom,
-  });
-  await retiredCreditsEvent.save();
-
-  let ownerBalance = await CreditBalance.get(`${owner}-${denom}`);
-  ownerBalance.amountActive = ownerBalance.amountActive - amount;
-  ownerBalance.amountRetired = ownerBalance.amountRetired + amount;
-  await ownerBalance.save();
+  try {
+    const owner = fetchPropertyFromEvent(event, "owner");
+    const denom = fetchPropertyFromEvent(event, "denom");
+    const amount = BigInt(fetchPropertyFromEvent(event, "amount"));
+
+    // this is because there is a bug in SubQuery, which causes event to be processed multiple times
+    // for every transaction in the same block, therefore we're skipping processing
+    // of events that are already present in the database
+    const eventAlreadyProcessed = await RetiredCreditsEvent.get(`${event.tx.hash}-${event.msg.idx}-${event.idx}`);
+    if (eventAlreadyProcessed) {
+      return;
+    }
 
-  let creditCollection = await CreditCollection.get(denom);
-  creditCollection.activeAmount = creditCollection.activeAmount - amount;
-  creditCollection.retiredAmount = creditCollection.retiredAmount + amount;
-  await creditCollection.save();
+    const retiredCreditsEvent = RetiredCreditsEvent.create({
+      id: `${event.tx.hash}-${event.msg.idx}-${event.idx}`,
+      owner: owner,
+      amount: amount,
+      creditCollectionId: denom,
+    });
+    await retiredCreditsEvent.save();
+
+    let ownerBalance = await CreditBalance.get(`${owner}-${denom}`);
+    ownerBalance.amountActive = ownerBalance.amountActive - amount;
+    ownerBalance.amountRetired = ownerBalance.amountRetired + amount;
+    await ownerBalance.save();
+
+    let creditCollection = await CreditCollection.get(denom);
+    creditCollection.activeAmount = creditCollection.activeAmount - amount;
+    creditCollection.retiredAmount = creditCollection.retiredAmount + amount;
+    await creditCollection.save();
+  } catch (e) {
+    await logRollbarError(e, event.tx.hash);
+    throw new Error("Error in handleRetiredCredits: " + e.message);
+  }
 }
 
 function findCertificateDataValueByKey(certificate: any[], key: string): string {
@@ -260,75 +320,84 @@ async function handleOffsetCertificate(certificateId: string, owner: string, cer
 }
 
 export async function handleCreateCertificate(event: CosmosEvent): Promise<void> {
-  const certificateId = fetchPropertyFromEvent(event, "certificate_id");
-  const issuer = fetchPropertyFromEvent(event, "issuer");
-  const owner = fetchPropertyFromEvent(event, "owner");
-  const certificateType = fetchPropertyFromEvent(event, "certificate_type");
-  const additionalData = fetchPropertyFromEvent(event, "additional_data");
-
-  const certificate = Certificate.create({
-    id: certificateId,
-    type: certificateType,
-    issuer: issuer,
-    owner: owner,
-    data: additionalData,
-    walletId: owner,
-  });
-  await certificate.save();
+  try {
+    const certificateId = fetchPropertyFromEvent(event, "certificate_id");
+    const issuer = fetchPropertyFromEvent(event, "issuer");
+    const owner = fetchPropertyFromEvent(event, "owner");
+    const certificateType = fetchPropertyFromEvent(event, "certificate_type");
+    const additionalData = fetchPropertyFromEvent(event, "additional_data");
+
+    const certificate = Certificate.create({
+      id: certificateId,
+      type: certificateType,
+      issuer: issuer,
+      owner: owner,
+      data: additionalData,
+      walletId: owner,
+    });
+    await certificate.save();
 
-  if (certificateType === "CREDIT_RETIREMENT") {
-    await handleOffsetCertificate(certificateId, owner, additionalData);
+    if (certificateType === "CREDIT_RETIREMENT") {
+      await handleOffsetCertificate(certificateId, owner, additionalData);
+    }
+  } catch (e) {
+    await logRollbarError(e, event.tx.hash);
+    throw new Error("Error in handleCreateCertificate: " + e.message);
   }
 }
 
 export async function handleIssueCredits(event: CosmosEvent): Promise<void> {
-  let denom = fetchPropertyFromEvent(event, "denom");
-  let amount = fetchPropertyFromEvent(event, "amount");
-  let projectId = fetchPropertyFromEvent(event, "project_id");
-  let applicantId = fetchPropertyFromEvent(event, "applicant_id");
-  let recipient = fetchPropertyFromEvent(event, "recipient");
-  let creditTypeAbbreviation = fetchPropertyFromEvent(event, "credit_type_abbreviation");
-
-  const metadataUrls = fetchPropertyFromEvent(event, "metadata_uris");
-  const metadataUrlsArray = decodeUriArrayFromEvent(metadataUrls);
-
-  const creditCollection = CreditCollection.create({
-    id: denom,
-    denom: denom,
-    projectId: parseInt(projectId),
-    applicantId: parseInt(applicantId),
-    issuanceDate: new Date(event.block.header.time.toISOString()),
-    activeAmount: BigInt(amount),
-    retiredAmount: BigInt(0),
-    creditType: creditTypeAbbreviation,
-  });
-  await creditCollection.save();
-
-  let wallet = await Wallet.get(recipient);
-  if (!wallet) {
-    wallet = await createNewWallet(recipient, parseInt(applicantId));
-  } else {
-    if (!wallet.applicantId) {
-      wallet.applicantId = parseInt(applicantId);
-      await wallet.save();
+  try {
+    let denom = fetchPropertyFromEvent(event, "denom");
+    let amount = fetchPropertyFromEvent(event, "amount");
+    let projectId = fetchPropertyFromEvent(event, "project_id");
+    let applicantId = fetchPropertyFromEvent(event, "applicant_id");
+    let recipient = fetchPropertyFromEvent(event, "recipient");
+    let creditTypeAbbreviation = fetchPropertyFromEvent(event, "credit_type_abbreviation");
+
+    const metadataUrls = fetchPropertyFromEvent(event, "metadata_uris");
+    const metadataUrlsArray = decodeUriArrayFromEvent(metadataUrls);
+
+    const creditCollection = CreditCollection.create({
+      id: denom,
+      denom: denom,
+      projectId: parseInt(projectId),
+      applicantId: parseInt(applicantId),
+      issuanceDate: new Date(event.block.header.time.toISOString()),
+      activeAmount: BigInt(amount),
+      retiredAmount: BigInt(0),
+      creditType: creditTypeAbbreviation,
+    });
+    await creditCollection.save();
+
+    let wallet = await Wallet.get(recipient);
+    if (!wallet) {
+      wallet = await createNewWallet(recipient, parseInt(applicantId));
+    } else {
+      if (!wallet.applicantId) {
+        wallet.applicantId = parseInt(applicantId);
+        await wallet.save();
+      }
     }
-  }
-  const creditBalance = CreditBalance.create({
-    id: `${recipient}-${denom}`,
-    creditCollectionId: denom,
-    amountActive: BigInt(amount),
-    amountRetired: BigInt(0),
-    walletId: wallet.id,
-  });
-  await creditBalance.save();
+    const creditBalance = CreditBalance.create({
+      id: `${recipient}-${denom}`,
+      creditCollectionId: denom,
+      amountActive: BigInt(amount),
+      amountRetired: BigInt(0),
+      walletId: wallet.id,
+    });
+    await creditBalance.save();
 
-  await handleMetadataUris(metadataUrlsArray, creditCollection.id);
+    await handleMetadataUris(metadataUrlsArray, creditCollection.id);
 
-  for (let [i, metadataUri] of metadataUrlsArray.entries()) {
-    const metadata = await fetchMetadataFromIpfs(metadataUri);
-    await handleCreditData(metadata, creditCollection.id, i.toString());
+    for (let [i, metadataUri] of metadataUrlsArray.entries()) {
+      const metadata = await fetchMetadataFromIpfs(metadataUri);
+      await handleCreditData(metadata, creditCollection.id, i.toString());
+    }
+  } catch (e) {
+    await logRollbarError(e, event.tx.hash);
+    throw new Error("Error in handleIssueCredits: " + e.message);
   }
-
 }
 
 function findPropById(id: string, creditProps: any[]): any {
@@ -393,7 +462,7 @@ async function handleEventData(eventDataJson: any, creditDataId: string, eventIn
   let country = "";
 
   try {
-    const reqUri = "https://maps.googleapis.com/maps/api/geocode/json?latlng=" + latitude + "," + longitude + "&key=$KEY";
+    const reqUri = "https://maps.googleapis.com/maps/api/geocode/json?latlng=" + latitude + "," + longitude + "&key=$GOOGLE_MAPS_API_KEY";
     const response = await fetch(reqUri);
     const result = await response.json();