Something went wrong. Try again.
Monorepo for Aesthetic.Computer aesthetic.computer
Something went wrong. Try again.
JavaScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226// keep-prepare.mjs — Job-based keep preparation endpoint.//// POST /api/keep-prepare// Body: { piece, walletAddress, network, regenerate?, force? }// Auth: Bearer token (required for new mints, optional for rebake if on-chain owner)// Returns: { jobId, status, stage, ... }//// Validates auth & ownership, creates a keep-job in MongoDB, then invokes// keep-prepare-background to run the heavy pipeline (oven, IPFS, metadata).// Client polls GET /api/keep-status?jobId=xxx for real-time progress.
import { authorize, handleFor, hasAdmin } from "../../backend/authorization.mjs";import { connect } from "../../backend/database.mjs";import { loadKidlispPiece } from "../../backend/kidlisp-read.mjs";import { getKeepsContractAddress, LEGACY_KEEPS_CONTRACT } from "../../backend/tezos-keeps-contract.mjs";import { upsertJob, formatJobForClient, getJob, markJobFailed,} from "../../backend/keep-job.mjs";
const dev = process.env.CONTEXT === "dev";if (dev) process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0";
const NETWORK = process.env.TEZOS_NETWORK || "mainnet";let CONTRACT_ADDRESS = LEGACY_KEEPS_CONTRACT;
function isTezosAddress(addr) { return typeof addr === "string" && /^tz[123][a-zA-Z0-9]{33}$/.test(addr);}
function getTzktApiBase() { return NETWORK === "mainnet" ? "https://api.tzkt.io" : `https://api.${NETWORK}.tzkt.io`;}
async function checkMintStatus(pieceName) { try { const res = await fetch(`${getTzktApiBase()}/v1/tokens?contract=${CONTRACT_ADDRESS}&metadata.symbol=${pieceName}&limit=1`); if (!res.ok) return { minted: false }; const tokens = await res.json(); if (tokens.length > 0) { const token = tokens[0]; return { minted: true, tokenId: token.tokenId, name: token.metadata?.name, objktUrl: `https://objkt.com/tokens/${CONTRACT_ADDRESS}/${token.tokenId}`, }; } } catch {} return { minted: false };}
const CORS_HEADERS = { "Access-Control-Allow-Origin": "*", "Access-Control-Allow-Headers": "Content-Type, Authorization", "Content-Type": "application/json",};
function jsonResponse(statusCode, body) { return { statusCode, headers: CORS_HEADERS, body: JSON.stringify(body) };}
// ═══════════════════════════════════════════════════════════════════════════════// Handler — validates, creates job, invokes background pipeline// ═══════════════════════════════════════════════════════════════════════════════export const handler = async (event) => { if (event.httpMethod === "OPTIONS") { return { statusCode: 200, headers: CORS_HEADERS, body: "" }; }
if (event.httpMethod !== "POST") { return jsonResponse(405, { error: "Method not allowed" }); }
let body; try { body = JSON.parse(event.body || "{}"); } catch { return jsonResponse(400, { error: "Invalid JSON body" }); }
const pieceName = body.piece?.replace(/^\$/, "").trim(); const walletAddress = body.walletAddress; const regenerate = body.regenerate === true;
if (!pieceName) return jsonResponse(400, { error: "Missing 'piece'" }); if (!walletAddress || !isTezosAddress(walletAddress)) { return jsonResponse(400, { error: "Valid Tezos wallet address required" }); }
// ── Resolve contract address ─────────────────────────────────────── CONTRACT_ADDRESS = await getKeepsContractAddress({ network: NETWORK, fallback: LEGACY_KEEPS_CONTRACT });
// ── Auth ──────────────────────────────────────────────────────────── const user = await authorize(event.headers);
// ── Load piece from DB (Datomic-aware; new pieces live only in Datomic) ─ const database = await connect(); const piece = await loadKidlispPiece(database, pieceName); if (!piece) return jsonResponse(404, { error: `Piece '$${pieceName}' not found` });
// ── Check mint status ────────────────────────────────────────────── const mintStatus = await checkMintStatus(pieceName); const isRebake = mintStatus.minted && regenerate;
// ── Verify on-chain ownership (for rebake without AC login) ──────── let isOnChainOwner = false; if (isRebake && walletAddress && mintStatus.tokenId != null) { try { const tokenRes = await fetch( `https://api.tzkt.io/v1/tokens/balances?token.contract=${CONTRACT_ADDRESS}&token.tokenId=${mintStatus.tokenId}&balance.gt=0` ); const balances = await tokenRes.json(); isOnChainOwner = !!balances.find(b => b.account?.address === walletAddress); } catch {} }
// ── Auth checks ──────────────────────────────────────────────────── if (!isRebake && !user) return jsonResponse(401, { error: "Please log in first" }); if (isRebake && !user && !isOnChainOwner) return jsonResponse(401, { error: "Login or connect token-owning wallet" });
let userHandle = null; let isAdmin = false; if (user) { userHandle = await handleFor(user.sub); if (!userHandle && !isRebake) return jsonResponse(400, { error: "You need an @handle first" }); isAdmin = await hasAdmin(user); }
if (!piece.user) return jsonResponse(400, { error: "Anonymous pieces cannot be kept" }); if (!isRebake && user && !isAdmin && piece.user !== user.sub) { return jsonResponse(403, { error: "This piece belongs to someone else" }); } if (isRebake && !isAdmin && !isOnChainOwner && (!user || piece.user !== user.sub)) { return jsonResponse(403, { error: "Only the piece owner or token holder can rebake" }); }
// Already minted (and not regenerating) if (mintStatus.minted && !regenerate) { return jsonResponse(200, { alreadyMinted: true, tokenId: mintStatus.tokenId, objktUrl: mintStatus.objktUrl, }); }
// ── Wallet validation (new mints) ────────────────────────────────── let creatorWalletAddress; if (!isRebake) { const usersCol = database.db.collection("users"); const userDoc = user ? await usersCol.findOne({ _id: user.sub }) : null; const linkedWallet = userDoc?.tezos?.address; if (!linkedWallet) { console.error(`🪙 KEEP: No linked wallet for user ${user.sub} (userDoc ${userDoc ? 'exists' : 'missing'})`); return jsonResponse(400, { error: "No wallet linked — connect your Tezos wallet and try again" }); } if (walletAddress !== linkedWallet) { console.error(`🪙 KEEP: Wallet mismatch — request=${walletAddress?.slice(0, 8)} linked=${linkedWallet.slice(0, 8)}`); return jsonResponse(400, { error: `Wallet mismatch — mint from ${linkedWallet.slice(0, 8)}...` }); } creatorWalletAddress = walletAddress; } else { const usersCol = database.db.collection("users"); const userDoc = user ? await usersCol.findOne({ _id: user.sub }) : null; creatorWalletAddress = userDoc?.tezos?.address || "tz1burnburnburnburnburnburnburjAYjjX"; }
// ── Check for existing active job ────────────────────────────────── const forceFreshJob = body.force === true || regenerate; const existingJob = await getJob(pieceName, walletAddress); if (existingJob && existingJob.status === "preparing" && !forceFreshJob) { const ageMs = Date.now() - new Date(existingJob.updatedAt).getTime(); if (ageMs < 5 * 60 * 1000) { // Job still in progress — return it return jsonResponse(200, { resuming: true, ...formatJobForClient(existingJob) }); } } if (existingJob && forceFreshJob) { // Regenerate/rebake requests must not reuse stale in-flight jobs. try { await database.db.collection("keep-jobs").deleteOne({ _id: existingJob._id }); } catch (deleteErr) { console.warn("🪙 KEEP: Could not clear previous job before forced regenerate:", deleteErr.message); } }
// ── Create job ───────────────────────────────────────────────────── const job = await upsertJob({ piece: pieceName, wallet: walletAddress, user: user?.sub, handle: userHandle, isRebake, regenerate, });
// ── Invoke background function ───────────────────────────────────── const siteUrl = process.env.URL || process.env.DEPLOY_URL || (dev ? "http://localhost:8888" : "https://aesthetic.computer"); const bgPayload = { jobId: job._id.toString(), pieceName, isRebake, regenerate, creatorWalletAddress, userHandle, walletAddress, };
// Invoke background function — must await so the request is fully sent // before this handler returns (Netlify freezes the process after return). let bgLaunchOk = false; try { const bgRes = await fetch(`${siteUrl}/.netlify/functions/keep-prepare-background`, { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify(bgPayload), }); // Netlify background functions return 202; anything else is a problem bgLaunchOk = bgRes.status === 202 || bgRes.ok; if (!bgLaunchOk) { console.error(`🪙 KEEP: Background function returned ${bgRes.status}`); await markJobFailed(job._id.toString(), `Background pipeline failed to launch (HTTP ${bgRes.status})`, "validate"); } } catch (err) { console.error(`🪙 KEEP: Failed to invoke background function:`, err.message); await markJobFailed(job._id.toString(), `Background pipeline unreachable: ${err.message}`, "validate"); }
// ── Return immediately ───────────────────────────────────────────── return jsonResponse(200, formatJobForClient(job));};