Fairminter v2

.github/workflows/ruff_scanner.yml

@@ -16,7 +16,7 @@ jobs:
       - uses: chartboost/ruff-action@v1
         with:
           args: "format --check"
-          version: 0.9.9
+          version: 0.9.10
       - uses: chartboost/ruff-action@v1
         with:
-          version: 0.9.9
+          version: 0.9.10

.pre-commit-config.yaml

@@ -1,6 +1,6 @@
 repos:
 -   repo: https://github.com/astral-sh/ruff-pre-commit
-    rev: v0.3.5
+    rev:  v0.9.9
     hooks:
     -   id: ruff
         args: [ --fix ]

counterparty-core/counterpartycore/lib/ledger/issuances.py

@@ -512,6 +512,20 @@ def get_fairmint_quantities(db, fairminter_tx_hash):
     return (sums["quantity"] or 0) + (sums["commission"] or 0), (sums["paid_quantity"] or 0)
 
 
+def get_fairmint_by_address(db, fairminter_tx_hash, source):
+    cursor = db.cursor()
+    query = """
+        SELECT
+            SUM(earn_quantity) AS quantity
+        FROM fairmints
+        WHERE fairminter_tx_hash = ? AND status = ? AND source = ?
+    """
+    bindings = (fairminter_tx_hash, "valid", source)
+    cursor.execute(query, bindings)
+    sums = cursor.fetchone()
+    return sums["quantity"] or 0
+
+
 def get_fairminters_by_soft_cap_deadline(db, block_index):
     cursor = db.cursor()
     query = """

counterparty-core/counterpartycore/lib/ledger/migrations/0005.add_max_mint_by_address.sql

@@ -0,0 +1 @@
+ALTER TABLE fairminters ADD COLUMN max_mint_per_address INTEGER;

counterparty-core/counterpartycore/lib/ledger/other.py

@@ -115,6 +115,21 @@
     return msg_index
 
 
+def get_issuance_msg_index(db, tx_hash):
+    cursor = db.cursor()
+    last_msg_index = cursor.execute(
+        """
+        SELECT MAX(msg_index) as msg_index FROM issuances WHERE tx_hash = ?
+    """,
+        (tx_hash,),
+    ).fetchone()
+    if last_msg_index and last_msg_index["msg_index"] is not None:
+        msg_index = last_msg_index["msg_index"] + 1
+    else:
+        msg_index = 0
+    return msg_index
+
+
 #####################
 #       BETS        #
 #####################

counterparty-core/counterpartycore/lib/messages/fairmint.py

@@ -6,6 +6,7 @@
 from counterpartycore.lib import config, exceptions, ledger
 from counterpartycore.lib.messages import fairminter as fairminter_mod
 from counterpartycore.lib.parser import protocol
+from counterpartycore.lib.utils import helpers
 
 logger = logging.getLogger(config.LOGGER_NAME)
 
@@ -37,6 +38,15 @@
 
     asset_supply = ledger.supplies.asset_supply(db, fairminter["asset"])
 
+    if fairminter["max_mint_per_address"] is not None and fairminter["max_mint_per_address"] > 0:
+        alread_minted = ledger.issuances.get_fairmint_by_address(db, fairminter["tx_hash"], source)
+        if fairminter["price"] > 0:
+            if alread_minted + quantity > fairminter["max_mint_per_address"]:
+                problems.append("quantity exceeds maximum allowed by address")
+        else:
+            if alread_minted + fairminter["max_mint_per_tx"] > fairminter["max_mint_per_address"]:
+                problems.append("quantity exceeds maximum allowed by address")
+
     if fairminter["price"] > 0:
         # if the fairminter is not free the quantity is mandatory
         if quantity <= 0:
@@ -82,25 +92,35 @@
 
     # create message
     data = struct.pack(config.SHORT_TXTYPE_FORMAT, ID)
-    # to optimize the data size (avoiding fixed sizes per parameter) we use a simple
-    # string of characters separated by `|`.
-    data_content = "|".join(
-        [
-            str(value)
-            for value in [
-                asset,
-                quantity,
+
+    if protocol.enabled("fairminter_v2"):
+        asset_id = ledger.issuances.generate_asset_id(asset)
+        data += helpers.encode_data(asset_id, quantity or "")
+    else:
+        data_content = "|".join(
+            [
+                str(value)
+                for value in [
+                    asset,
+                    quantity,
+                ]
             ]
-        ]
-    ).encode("utf-8")
-    data += struct.pack(f">{len(data_content)}s", data_content)
+        ).encode("utf-8")
+        data += struct.pack(f">{len(data_content)}s", data_content)
+
     return (source, [], data)
 
 
 def unpack(message, return_dict=False):
     try:
-        data_content = struct.unpack(f">{len(message)}s", message)[0].decode("utf-8").split("|")
-        (asset, quantity) = data_content
+        if protocol.enabled("fairminter_v2"):
+            asset_id, quantity = helpers.decode_data(message)  # pylint: disable=unbalanced-tuple-unpacking
+            asset = ledger.issuances.generate_asset_name(helpers.bytes_to_int(asset_id))
+            quantity = helpers.bytes_to_int(quantity or b"\x00")
+        else:
+            data_content = struct.unpack(f">{len(message)}s", message)[0].decode("utf-8").split("|")
+            (asset, quantity) = data_content
+
         if return_dict:
             return {"asset": asset, "quantity": int(quantity)}