Feature/sudt backend

packages/common/src/util.ts

@@ -1,5 +1,5 @@
 import type { TransactionWithStatus } from '@ckb-lumos/base'
-import type { RPC } from '@ckb-lumos/lumos'
+import { config, type RPC, type helpers } from '@ckb-lumos/lumos'
 import { scheduler } from 'node:timers/promises'
 import path from 'node:path'
 import fs from 'node:fs'
@@ -84,3 +84,20 @@ export async function getPackageJson(): Promise<PackageJson> {
   const root = getPackageRoot()
   return JSON.parse(fs.readFileSync(path.join(root, 'package.json'), 'utf-8'))
 }
+
+export const addBuiltInCellDeps = (txSkeleton: helpers.TransactionSkeletonType, dep: string) => {
+  const depConfig = config.getConfig().SCRIPTS[dep]
+  if (depConfig) {
+    txSkeleton = txSkeleton.update('cellDeps', (cellDeps) =>
+      cellDeps.push({
+        outPoint: {
+          txHash: depConfig.TX_HASH,
+          index: depConfig.INDEX,
+        },
+        depType: depConfig.DEP_TYPE,
+      }),
+    )
+  }
+
+  return txSkeleton
+}

packages/models/src/resource-binding/manager.ts

@@ -109,8 +109,12 @@ export class Manager extends Actor<object, MessagePayload<ResourceBindingManager
   constructor(
     private _listener: Listener<Header>,
     private _dataSource: ChainSource,
+    startBlockNumber?: string,
   ) {
     super()
+    if (startBlockNumber && BI.isBI(BI.from(startBlockNumber))) {
+      this.#tipBlockNumber = BI.from(startBlockNumber)
+    }
   }
 
   onListenBlock = (blockHeader: Header) => {
@@ -233,7 +237,7 @@ export class Manager extends Actor<object, MessagePayload<ResourceBindingManager
       )
     })
     /**
-     * remove inputs and outputs if they are matched in the block
+     * remove inputs and outputs if they are matched in the block cross transactions
      */
     ;[...newInputs.keys()].forEach((outPoint) => {
       if (newOutputs.has(outPoint)) {

packages/models/src/resource-binding/utils.ts

@@ -15,12 +15,13 @@ export function initiateResourceBindingManager(params: {
   dataSource?: ChainSource
   listener?: Listener<Header>
   rpc?: string
+  startBlockNumber?: string
 }) {
   assert(params.rpc || params.dataSource, 'dataSource or rpc is required')
 
   const dataSource = params.dataSource ?? new NervosChainSource(params.rpc!)
   const listener = params.listener ?? new TipHeaderListener(dataSource)
   Reflect.defineMetadata(ProviderKey.Actor, { ref: new ActorReference('resource', '/').json }, Manager)
-  const manager = new Manager(listener, dataSource)
+  const manager = new Manager(listener, dataSource, params.startBlockNumber)
   return { manager, ...manager.listen() }
 }

packages/samples/sudt/.env.example

@@ -0,0 +1,19 @@
+# app
+HOST=127.0.0.1
+PORT=3001
+
+# ckb
+CKB_RPC_URL=https://testnet.ckb.dev/rpc
+NETWORK=testnet
+
+# redis
+REDIS_PORT=6379
+REDIS_HOST=127.0.0.1
+
+EXPLORER_HOST=https://explorer.nervos.org
+EXPLORER_API_HOST=https://explorer.nervos.org/api
+DB_HOST=localhost
+DB_PORT=3306
+DB_USERNAME=root
+DB_PASSWORD=root
+DB_DATABASE=sudt