Fixes

packages/database/src/pg/impl/knex.ts

@@ -15,7 +15,7 @@ export const getKnex = () => {
       },
       pool: {
         min: Number(process.env.DB_POOL_MIN || 0),
-        max: Number(process.env.DB_POOL_MAX || 10),
+        max: Number(process.env.DB_POOL_MAX || 50),
       },
     });
   }
@@ -37,7 +37,7 @@ export const getKnexTran = () => {
       },
       pool: {
         min: Number(process.env.DB_POOL_MIN || 0),
-        max: Number(process.env.DB_POOL_MAX || 10),
+        max: Number(process.env.DB_POOL_MAX || 100),
       },
     });
   }

packages/functions/src/cron/media.cron.ts

@@ -18,8 +18,8 @@ import {
   putCar,
   tokenToIpfsMetadata,
 } from '../utils/car.utils';
-import { spaceToIpfsMetadata } from '../utils/space.utils';
 import { logger } from '../utils/logger';
+import { spaceToIpfsMetadata } from '../utils/space.utils';
 
 export const MEDIA_UPLOAD_BACH_SIZE = 30;
 

packages/functions/src/cron/stakeReward.cron.ts

@@ -17,8 +17,8 @@ import {
 import dayjs from 'dayjs';
 import { isEmpty } from 'lodash';
 import { getProject } from '../utils/common.utils';
-import { getRandomEthAddress } from '../utils/wallet.utils';
 import { logger } from '../utils/logger';
+import { getRandomEthAddress } from '../utils/wallet.utils';
 
 export const onStakeRewardExpired = async () => {
   const stakeRewards = await getDueStakeRewards();

packages/functions/src/runtime/https/https.ts

@@ -5,9 +5,9 @@ import { AnySchema, ValidationOptions } from 'joi';
 import { get } from 'lodash';
 import { Context } from '../../controls/common';
 import { WEN_FUNC_SCALE } from '../../scale.settings';
+import { logger } from '../../utils/logger';
 import { CloudFunctions, RuntimeOptions } from '../common';
 import { auth } from './middlewares';
-import { logger } from '../../utils/logger';
 
 type HandlerType = (req: express.Request, res: express.Response) => Promise<void>;
 

packages/functions/src/services/payment/nft/nft-deposit.service.ts

@@ -26,6 +26,7 @@ import { getNftByMintingId } from '../../../utils/collection-minting-utils/nft.u
 import { getProject } from '../../../utils/common.utils';
 import { getBucket } from '../../../utils/config.utils';
 import { dateToTimestamp, serverTime } from '../../../utils/dateTime.utils';
+import { logger } from '../../../utils/logger';
 import { migrateUriToSotrage, uriToUrl } from '../../../utils/media.utils';
 import {
   collectionIrc27Scheam,
@@ -40,7 +41,6 @@ import { NftWallet } from '../../wallet/NftWallet';
 import { WalletService } from '../../wallet/wallet.service';
 import { BaseService, HandlerParams } from '../base';
 import { Action, TransactionMatch } from '../transaction-service';
-import { logger } from '../../../utils/logger';
 
 export class NftDepositService extends BaseService {
   public handleRequest = async ({ order, match, tranEntry }: HandlerParams) => {

packages/functions/src/services/payment/nft/nft-stake.service.ts

@@ -22,13 +22,13 @@ import {
 import dayjs from 'dayjs';
 import { cloneDeep } from 'lodash';
 import { dateToTimestamp } from '../../../utils/dateTime.utils';
+import { logger } from '../../../utils/logger';
 import { getRandomEthAddress } from '../../../utils/wallet.utils';
 import { WalletService } from '../../wallet/wallet.service';
 import { BaseService, HandlerParams } from '../base';
 import { createNftWithdrawOrder } from '../tangle-service/nft/nft-purchase.service';
 import { Action } from '../transaction-service';
 import { NftDepositService } from './nft-deposit.service';
-import { logger } from '../../../utils/logger';
 
 export class NftStakeService extends BaseService {
   public handleRequest = async ({ project, order, match, tranEntry }: HandlerParams) => {

packages/functions/src/services/payment/tangle-service/TangleRequestService.ts

@@ -12,6 +12,7 @@ import {
 import { get, isEmpty } from 'lodash';
 import { getOutputMetadata } from '../../../utils/basic-output.utils';
 import { invalidArgument } from '../../../utils/error.utils';
+import { logger } from '../../../utils/logger';
 import { getRandomNonce } from '../../../utils/wallet.utils';
 import { BaseTangleService, HandlerParams } from '../base';
 import { TangleAddressValidationService } from './address/address-validation.service';
@@ -44,7 +45,6 @@ import { SwapSetFundedTangleService } from './swap/SwapSetFundedTangleService';
 import { TangleStakeService } from './token/stake.service';
 import { TangleTokenClaimService } from './token/token-claim.service';
 import { TangleTokenTradeService } from './token/token-trade.service';
-import { logger } from '../../../utils/logger';
 
 export class TangleRequestService extends BaseTangleService<TangleResponse> {
   public handleRequest = async (params: HandlerParams) => {

packages/functions/src/services/payment/transaction-service.ts

@@ -23,9 +23,9 @@ import { MilestoneTransactionAdapter } from '../../triggers/milestone-transactio
 import { getOutputMetadata } from '../../utils/basic-output.utils';
 import { getProject } from '../../utils/common.utils';
 import { dateToTimestamp, serverTime } from '../../utils/dateTime.utils';
+import { logger } from '../../utils/logger';
 import { getPathParts } from '../../utils/milestone';
 import { getRandomEthAddress } from '../../utils/wallet.utils';
-import { logger } from '../../utils/logger';
 
 export interface TransactionMatch {
   msgId: string;

packages/functions/src/services/wallet/NftWallet.ts

@@ -48,14 +48,14 @@ import {
   createNftOutput,
   nftToMetadata,
 } from '../../utils/collection-minting-utils/nft.utils';
+import { logger } from '../../utils/logger';
 import { EMPTY_ALIAS_ID } from '../../utils/token-minting-utils/alias.utils';
 import { awardBadgeToNttMetadata, awardToCollectionMetadata } from '../payment/award/award-service';
 import { stampToNftMetadata } from '../payment/tangle-service/stamp/StampTangleService';
 import { AliasWallet } from './AliasWallet';
 import { MnemonicService } from './mnemonic';
 import { Wallet, WalletParams } from './wallet';
 import { AddressDetails, setConsumedOutputIds } from './wallet.service';
-import { logger } from '../../utils/logger';
 
 interface MintNftInputParams {
   readonly aliasOutputId: string;

packages/functions/src/triggers/algolia/algolia.trigger.ts

@@ -2,8 +2,8 @@ import { BaseRecord } from '@build-5/database';
 import { COL, SOON_PROJECT_ID } from '@build-5/interfaces';
 import algoliasearch from 'algoliasearch';
 import { algoliaAppId, algoliaKey } from '../../utils/config.utils';
-import { PgDocEvent } from '../common';
 import { logger } from '../../utils/logger';
+import { PgDocEvent } from '../common';
 
 const client = algoliasearch(algoliaAppId(), algoliaKey());
 

packages/functions/src/triggers/collection.trigger.ts

@@ -14,9 +14,9 @@ import { last } from 'lodash';
 import { getAddress } from '../utils/address.utils';
 import { collectionToIpfsMetadata, downloadMediaAndPackCar } from '../utils/car.utils';
 import { getProject } from '../utils/common.utils';
+import { logger } from '../utils/logger';
 import { getRandomEthAddress } from '../utils/wallet.utils';
 import { PgDocEvent } from './common';
-import { logger } from '../utils/logger';
 
 export const onCollectionUpdated = async (event: PgDocEvent<PgCollection>) => {
   const { prev, curr } = event;

packages/functions/src/triggers/milestone-transactions-triggers/milestone-transaction.trigger.ts

@@ -2,12 +2,12 @@ import { PgMilestoneTransactions, build5Db } from '@build-5/database';
 import { COL, Network, SUB_COL } from '@build-5/interfaces';
 import dayjs from 'dayjs';
 import { ProcessingService } from '../../services/payment/payment-processing';
+import { logger } from '../../utils/logger';
 import { PgDocEvent } from '../common';
 import { MilestoneTransactionAdapter } from './MilestoneTransactionAdapter';
 import { confirmTransaction } from './common';
 import { processConsumedVoteOutputs } from './consumed.vote.outputs';
 import { updateTokenSupplyData } from './token.foundry';
-import { logger } from '../../utils/logger';
 
 export const handleMilestoneTransactionWrite =
   // eslint-disable-next-line require-await

packages/functions/src/triggers/storage/resize.img.trigger.ts

@@ -6,8 +6,8 @@ import fs from 'fs';
 import os from 'os';
 import path from 'path';
 import sharp from 'sharp';
-import { getRandomEthAddress } from '../../utils/wallet.utils';
 import { logger } from '../../utils/logger';
+import { getRandomEthAddress } from '../../utils/wallet.utils';
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const ffprobePath = require('@ffprobe-installer/ffprobe').path;

packages/functions/src/triggers/token.trigger.ts

@@ -22,6 +22,7 @@ import { WalletService } from '../services/wallet/wallet.service';
 import { getAddress } from '../utils/address.utils';
 import { downloadMediaAndPackCar, tokenToIpfsMetadata } from '../utils/car.utils';
 import { getProject, guardedRerun } from '../utils/common.utils';
+import { logger } from '../utils/logger';
 import { getRoyaltyFees } from '../utils/royalty.utils';
 import { cancelTradeOrderUtil } from '../utils/token-trade.utils';
 import {
@@ -33,7 +34,6 @@ import {
 } from '../utils/token.utils';
 import { getRandomEthAddress } from '../utils/wallet.utils';
 import { PgDocEvent } from './common';
-import { logger } from '../utils/logger';
 
 export const onTokenStatusUpdated = async (event: PgDocEvent<PgToken>) => {
   const { prev, curr } = event;

packages/functions/src/triggers/transaction-trigger/airdrop.claim.ts

@@ -24,9 +24,9 @@ import { WalletService } from '../../services/wallet/wallet.service';
 import { getAddress } from '../../utils/address.utils';
 import { getProject } from '../../utils/common.utils';
 import { dateToTimestamp, serverTime } from '../../utils/dateTime.utils';
+import { logger } from '../../utils/logger';
 import { dropToOutput } from '../../utils/token-minting-utils/member.utils';
 import { getRandomEthAddress } from '../../utils/wallet.utils';
-import { logger } from '../../utils/logger';
 
 const LOOP_SIZE = 10000;
 

packages/functions/src/triggers/transaction-trigger/collection-minting.ts

@@ -13,9 +13,9 @@ import { TransactionPayload, Utils } from '@iota/sdk';
 import dayjs from 'dayjs';
 import { getAddress } from '../../utils/address.utils';
 import { getProject } from '../../utils/common.utils';
+import { logger } from '../../utils/logger';
 import { getPathParts } from '../../utils/milestone';
 import { getRandomEthAddress } from '../../utils/wallet.utils';
-import { logger } from '../../utils/logger';
 
 export const onCollectionMintingUpdate = async (transaction: PgTransaction) => {
   switch (transaction.payload_type) {

packages/functions/src/triggers/transaction-trigger/transaction.trigger.ts

@@ -24,6 +24,7 @@ import { getAddress } from '../../utils/address.utils';
 import { getProject } from '../../utils/common.utils';
 import { isEmulatorEnv } from '../../utils/config.utils';
 import { serverTime } from '../../utils/dateTime.utils';
+import { logger } from '../../utils/logger';
 import { getRandomEthAddress } from '../../utils/wallet.utils';
 import { PgDocEvent } from '../common';
 import { unclockMnemonic } from '../milestone-transactions-triggers/common';
@@ -37,7 +38,6 @@ import { onStakingConfirmed } from './staking';
 import { onStampMintUpdate } from './stamp-minting';
 import { onTokenMintingUpdate } from './token-minting';
 import { getWalletParams } from './wallet-params';
-import { logger } from '../../utils/logger';
 
 export const DEFAULT_EXECUTABLE_TRANSACTIONS = [
   TransactionType.BILL_PAYMENT,

packages/functions/test-tangle/collection-minting/Helper.ts

@@ -185,7 +185,7 @@ export class CollectionMintHelper {
   });
 
   public createDummyNft = (collection: string, description = 'babba') => ({
-    name: 'NFT ' + description,
+    name: 'NFT ' + Math.random(),
     description,
     collection,
     availableFrom: dayjs().add(1, 'hour').toDate(),