update fleet and handle breaking changes

package.json

@@ -38,8 +38,8 @@
     "typescript": "^4.7.4"
   },
   "dependencies": {
+    "@fleet-sdk/core": "^0.1.0-alpha.1",
     "@mando75/typeorm-graphql-loader": "^1.7.5",
-    "@nautilus-js/fleet": "^0.0.5",
     "apollo-server": "^3.9.0",
     "apollo-server-cache-redis": "^3.3.1",
     "apollo-server-plugin-response-cache": "^3.6.1",

src/context/box-repository.ts

@@ -1,4 +1,4 @@
-import { Address } from "@nautilus-js/fleet";
+import { ErgoAddress } from "@fleet-sdk/core";
 import { isEmpty, unionBy } from "lodash";
 import { AssetEntity, BoxEntity, HeaderEntity, InputEntity, TokenEntity } from "../entities";
 import { removeUndefined } from "../utils";
@@ -44,13 +44,13 @@ export class BoxRepository extends BaseRepository<BoxEntity> {
     }
 
     if (options.where?.address) {
-      ergoTrees.push(Address.fromBase58(options.where.address).ergoTree);
+      ergoTrees.push(ErgoAddress.fromBase58(options.where.address).ergoTree);
       delete options.where.address;
     }
 
     if (addresses) {
       for (const address of addresses) {
-        ergoTrees.push(Address.fromBase58(address).ergoTree);
+        ergoTrees.push(ErgoAddress.fromBase58(address).ergoTree);
       }
     }
 
@@ -147,7 +147,9 @@ export class BoxRepository extends BaseRepository<BoxEntity> {
       .groupBy("box.address")
       .setParameters(
         removeUndefined({
-          ergoTrees: options.where.addresses.map((address) => Address.fromBase58(address).ergoTree)
+          ergoTrees: options.where.addresses.map(
+            (address) => ErgoAddress.fromBase58(address).ergoTree
+          )
         })
       );
 
@@ -215,7 +217,9 @@ export class BoxRepository extends BaseRepository<BoxEntity> {
     return baseQuery
       .setParameters(
         removeUndefined({
-          ergoTrees: options.where.addresses.map((address) => Address.fromBase58(address).ergoTree)
+          ergoTrees: options.where.addresses.map(
+            (address) => ErgoAddress.fromBase58(address).ergoTree
+          )
         })
       )
       .getRawMany();

src/context/transactions-repository.ts

@@ -1,4 +1,4 @@
-import { Address } from "@nautilus-js/fleet";
+import { ErgoAddress } from "@fleet-sdk/core";
 import { MINER_FEE_ERGO_TREE } from "../consts";
 import { BoxEntity, InputEntity, TransactionEntity } from "../entities";
 import { getArgumentValue } from "../graphql/resolvers/utils";
@@ -25,14 +25,14 @@ export class TransactionRepository extends BaseRepository<TransactionEntity> {
   public override async find(options: TransactionFindOptions): Promise<TransactionEntity[]> {
     const { minHeight, maxHeight, address, addresses, transactionIds } = options;
     const ergoTrees = addresses
-      ? addresses.map((address) => Address.fromBase58(address).ergoTree)
+      ? addresses.map((address) => ErgoAddress.fromBase58(address).ergoTree)
       : [];
 
     return this.findBase(
       options,
       (filterQuery) => {
         if (address) {
-          ergoTrees.push(Address.fromBase58(address).ergoTree);
+          ergoTrees.push(ErgoAddress.fromBase58(address).ergoTree);
         }
         if (ergoTrees.length > 0) {
           const inputQuery = this.createInputQuery(maxHeight);
@@ -120,7 +120,7 @@ export class TransactionRepository extends BaseRepository<TransactionEntity> {
       .where(`${this.alias}.mainChain = true`)
       .setParameters(
         removeUndefined({
-          ergoTree: Address.fromBase58(options.where.address).ergoTree,
+          ergoTree: ErgoAddress.fromBase58(options.where.address).ergoTree,
           height: options.where.maxHeight
         })
       )

src/context/unconfirmed-box-repository.ts

@@ -1,4 +1,4 @@
-import { Address } from "@nautilus-js/fleet";
+import { ErgoAddress } from "@fleet-sdk/core";
 import { unionBy } from "lodash";
 import {
   TokenEntity,
@@ -21,7 +21,7 @@ export class UnconfirmedBoxRepository extends BaseRepository<UnconfirmedBoxEntit
   public override find(options: UnconfirmedBoxFindOptions): Promise<UnconfirmedBoxEntity[]> {
     const { tokenId } = options;
     if (options.where?.address) {
-      options.where.ergoTree = Address.fromBase58(options.where.address).ergoTree;
+      options.where.ergoTree = ErgoAddress.fromBase58(options.where.address).ergoTree;
       delete options.where.address;
     }
 
@@ -48,7 +48,9 @@ export class UnconfirmedBoxRepository extends BaseRepository<UnconfirmedBoxEntit
       .andWhere("input.boxId IS NULL")
       .groupBy("box.address")
       .setParameters({
-        ergoTrees: options.where.addresses.map((address) => Address.fromBase58(address).ergoTree)
+        ergoTrees: options.where.addresses.map(
+          (address) => ErgoAddress.fromBase58(address).ergoTree
+        )
       });
 
     const nanoErgs = options.include.nanoErgs

src/context/unconfirmed-transactions-repository.ts

@@ -1,4 +1,4 @@
-import { Address } from "@nautilus-js/fleet";
+import { ErgoAddress } from "@fleet-sdk/core";
 import {
   UnconfirmedBoxEntity,
   UnconfirmedInputEntity,
@@ -23,11 +23,11 @@ export class UnconfirmedTransactionRepository extends BaseRepository<Unconfirmed
   ): Promise<UnconfirmedTransactionEntity[]> {
     const { address, addresses, transactionIds } = options;
     const ergoTrees = addresses
-      ? addresses.map((address) => Address.fromBase58(address).ergoTree)
+      ? addresses.map((address) => ErgoAddress.fromBase58(address).ergoTree)
       : [];
     return this.findBase(options, (filterQuery) => {
       if (address) {
-        ergoTrees.push(Address.fromBase58(address).ergoTree);
+        ergoTrees.push(ErgoAddress.fromBase58(address).ergoTree);
       }
 
       if (ergoTrees.length > 0) {