checkpoint

package.json

@@ -1,7 +1,6 @@
 {
   "name": "ordinals",
   "version": "1.0.0",
-  "main": "index.js",
   "license": "MIT",
   "private": true,
   "workspaces": [

packages/backend/package.json

@@ -2,16 +2,18 @@
   "name": "@0xflick/ordinals-backend",
   "version": "1.0.0",
   "type": "module",
-  "main": "index.js",
+  "main": "src/index.ts",
   "license": "MIT",
   "dependencies": {
     "@0xflick/mempool.js": "^2.3.0",
     "@aws-sdk/client-dynamodb": "^3.359.0",
     "@aws-sdk/client-s3": "^3.363.0",
     "@aws-sdk/lib-dynamodb": "^3.359.0",
-    "bunyan": "^1.8.15"
+    "bunyan": "^1.8.15",
+    "cookie": "^0.5.0"
   },
   "devDependencies": {
-    "@types/bunyan": "^1.8.8"
+    "@types/bunyan": "^1.8.8",
+    "@types/cookie": "^0.5.1"
   }
 }

packages/backend/src/bitcoin/fees.ts

@@ -5,8 +5,8 @@ export type IFeesRecommended = Awaited<
 >;
 
 export async function estimateFees(
-  mempool: MempoolClient
+  mempool: MempoolClient["bitcoin"]
 ): Promise<IFeesRecommended> {
-  const fees = await mempool.bitcoin.fees.getFeesRecommended();
+  const fees = await mempool.fees.getFeesRecommended();
   return fees;
 }

packages/backend/src/bitcoin/inscription.ts

@@ -1,10 +1,15 @@
 import {
   BitcoinNetworkNames,
   InscriptionContent,
+  InscriptionFile,
   generateFundingAddress,
   generatePrivKey,
 } from "@0xflick/inscriptions";
-import { IInscriptionDocFundingWait } from "../../../models/src/doc";
+import {
+  hashInscriptions,
+  toAddressInscriptionId,
+  IInscriptionDocFundingWait,
+} from "@0xflick/ordinals-models";
 
 export async function createInscriptionTransaction({
   address,
@@ -18,7 +23,7 @@ export async function createInscriptionTransaction({
   feeRate: number;
   tip: number;
   inscriptions: InscriptionContent[];
-}): Promise<IInscriptionDocFundingWait> {
+}): Promise<IInscriptionDocFundingWait & { files: InscriptionFile[] }> {
   const privKey = generatePrivKey();
   const {
     amount,
@@ -31,6 +36,7 @@ export async function createInscriptionTransaction({
     overhead,
     padding,
     totalFee,
+    files,
   } = await generateFundingAddress({
     address,
     inscriptions,
@@ -41,6 +47,13 @@ export async function createInscriptionTransaction({
   });
 
   return {
+    id: toAddressInscriptionId(
+      hashInscriptions(
+        fundingAddress,
+        inscriptionsToWrite.map((i) => i.tapkey)
+      )
+    ),
+    files,
     fundingAddress,
     fundingAmountBtc: amount,
     initCBlock,

packages/backend/src/bitcoin/mempool.ts

@@ -28,17 +28,16 @@ function urlForNetworkName(network: BitcoinNetworkNames) {
 export type MempoolClient = ReturnType<typeof createMempoolClient>;
 export function createMempoolClient({
   network,
+  hostname,
+  protocol,
 }: {
+  hostname: string;
+  protocol: "http" | "https";
   network: BitcoinNetworkNames;
 }) {
-  const url = new URL(urlForNetworkName(network));
-  const protocol = url.protocol.slice(0, -1);
-  if (["http", "https"].includes(protocol)) {
-    throw new Error(`Unsupported protocol: ${protocol}`);
-  }
   return mempoolJS({
     network,
-    hostname: url.hostname,
-    protocol: protocol as "http" | "https",
+    hostname,
+    protocol,
   });
 }

packages/backend/src/dao/funding.ts

@@ -2,18 +2,46 @@ import {
   IAddressInscriptionModel,
   TInscriptionDoc,
   InscriptionFile,
+  InscriptionId,
+  TCollectionModel,
+  ID_Collection,
 } from "@0xflick/ordinals-models";
 
-export interface IFundingDao {
-  createFunding(item: IAddressInscriptionModel): Promise<void>;
-  getFunding(id: string): Promise<IAddressInscriptionModel>;
+export interface IFundingDao<
+  ItemInputType extends Record<string, any> = {},
+  ItemMeta extends Record<string, any> = {},
+  ItemReturnType = any,
+  CollectionInputType extends Record<string, any> = {},
+  CollectionMeta extends Record<string, any> = {},
+  CollectionReturnType = any
+> {
+  createFunding(
+    item: IAddressInscriptionModel<ItemInputType>
+  ): Promise<ItemReturnType>;
+  getFunding(id: string): Promise<IAddressInscriptionModel<ItemMeta>>;
   deleteFunding(id: string): Promise<void>;
+  createCollection(
+    item: TCollectionModel<CollectionInputType>
+  ): Promise<CollectionReturnType>;
+  getCollection(id: ID_Collection): Promise<TCollectionModel<CollectionMeta>>;
+  deleteCollection(id: ID_Collection): Promise<void>;
+  incrementCollectionTotalCount(id: ID_Collection): Promise<number>;
+  updateMaxSupply(id: ID_Collection, maxSupply: number): Promise<void>;
+  updateCollectionMeta(
+    id: ID_Collection,
+    meta: CollectionMeta,
+    incrementTotalCount?: boolean
+  ): Promise<Partial<TCollectionModel<CollectionMeta>>>;
 }
 
 export interface IFundingDocDao {
-  transactionKey(opts: { address: string; id: string; tapKey: string }): string;
+  transactionKey(opts: { fundingAddress: string; id: string }): string;
+  transactionContentKey(id: InscriptionId): string;
   updateOrSaveInscriptionTransaction(item: TInscriptionDoc): Promise<void>;
   saveInscriptionContent(item: InscriptionFile): Promise<void>;
-  getInscriptionContent(tapKey: string): Promise<InscriptionFile>;
-  getInscriptionTransaction(id: string): Promise<TInscriptionDoc>;
+  getInscriptionContent(id: InscriptionId): Promise<InscriptionFile>;
+  getInscriptionTransaction(opts: {
+    fundingAddress: string;
+    id: string;
+  }): Promise<TInscriptionDoc>;
 }

packages/backend/src/dao/index.ts

@@ -1 +1,2 @@
-export * from "./funding.js"
+export * from "./funding.js";
+export * from "./ordinals/index.js";

packages/backend/src/dao/ordinals/incrementingReveal.ts

@@ -0,0 +1,11 @@
+import { IOrdinalIncrementingRevealModel } from "@0xflick/ordinals-models";
+
+export interface IIncrementingRevealMeta
+  extends IOrdinalIncrementingRevealModel {}
+interface IIncrementingRevealReturn {
+  tokenId: number;
+}
+
+export interface IIncrementingRevealDao {
+  nextTokenId(): Promise<IIncrementingRevealReturn>;
+}

packages/backend/src/dao/ordinals/index.ts

@@ -0,0 +1 @@
+export * from "./incrementingReveal.js";

packages/backend/src/dynamodb/create.ts

@@ -3,6 +3,7 @@ import { DynamoDBDocumentClient } from "@aws-sdk/lib-dynamodb";
 import {
   awsEndpoint,
   awsRegion,
+  dynamoDbUrl,
   dynamoDbRegion,
   dynamoDbSslEnabled,
 } from "../utils/config.js";
@@ -11,9 +12,14 @@ let instance: DynamoDBDocumentClient;
 
 export function createDb(opts?: DynamoDBClientConfig) {
   const config = {
-    endpoint: awsEndpoint.get(),
+    endpoint: dynamoDbUrl.get() ?? awsEndpoint.get(),
     region: dynamoDbRegion.get() ?? awsRegion.get(),
     sslEnabled: dynamoDbSslEnabled.get(),
+    ...(process.env.MOCK_DYNAMODB_ENDPOINT && {
+      endpoint: process.env.MOCK_DYNAMODB_ENDPOINT,
+      sslEnabled: false,
+      region: "local",
+    }),
     ...opts,
   };
   const ddb = new DynamoDBClient(config);

packages/backend/src/dynamodb/factory.ts

@@ -1,10 +1,48 @@
 import type { IFundingDao } from "../dao/funding.js";
 import { tableNames } from "../utils/config.js";
 import { createDb } from "./create.js";
-import { FundingDao } from "./funding.js";
+import {
+  FundingDao,
+  TFundingCollectionReturner,
+  TFundingItemReturner,
+} from "./funding.js";
 
-export function createDynamoDbFundingDao(): IFundingDao {
+export function createDynamoDbFundingDao<
+  ItemInputType extends Record<string, any> = {},
+  ItemMeta extends Record<string, any> = {},
+  ItemReturnType = any,
+  CollectionInputType extends Record<string, any> = {},
+  CollectionMeta extends Record<string, any> = {},
+  CollectionReturnType = any
+>({
+  itemFundingUpdater,
+  collectionFundingUpdater,
+}: {
+  itemFundingUpdater: TFundingItemReturner<ItemInputType, ItemReturnType>;
+  collectionFundingUpdater: TFundingCollectionReturner<
+    CollectionInputType,
+    CollectionReturnType
+  >;
+}): IFundingDao<
+  ItemInputType,
+  ItemMeta,
+  ItemReturnType,
+  CollectionInputType,
+  CollectionMeta,
+  CollectionReturnType
+> {
   const allTableNames = tableNames.get();
   FundingDao.TABLE_NAME = allTableNames.funding ?? FundingDao.TABLE_NAME;
-  return new FundingDao(createDb());
+  return new FundingDao<
+    ItemInputType,
+    ItemMeta,
+    ItemReturnType,
+    CollectionInputType,
+    CollectionMeta,
+    CollectionReturnType
+  >({
+    client: createDb(),
+    itemFundingUpdater,
+    collectionFundingUpdater,
+  });
 }