LangGraph-এর জন্য আলাদা কোনো package নেই, এবং আপনারও তা দরকার নেই। আপনার -এর একটি plain node real client call করে, একটি payment webhook পৌঁছানো পর্যন্ত graph suspend করে, এবং handler LangGraph-এর নিজস্ব + দিয়ে তা resume করে। Payment Base-এ settle হয়।

LangGraph এবং মূল SDK ইনস্টল করুন। কোন অতিরিক্ত প্যাকেজ নেই।

Node 18+ এবং @langchain/langgraph 0.2+ এবং বাস্তব @blockchain0x/node ক্লায়েন্ট। কোন ভাষাতেই LangGraph অ্যাডাপ্টার যোগ করার জন্য নেই - Python LangGraph ব্যবহারকারীরা langgraph এবং blockchain0x Python ক্লায়েন্ট ইনস্টল করেন এবং একই রেসিপি লেখেন, Python পাশে interrupt() এবং Command(resume=...) সহ।

npm install @langchain/langgraph @blockchain0x/node

export BLOCKCHAIN0X_API_KEY=sk_test_...        # sk_test_ = Base Sepolia, sk_live_ = Base mainnet
export BLOCKCHAIN0X_WEBHOOK_SECRET=...          # for the webhook handler

BLOCKCHAIN0X_API_KEY আপনার ড্যাশবোর্ড থেকে একটি sk_test_ testnet বা sk_live_ mainnet কী; ক্লায়েন্ট এটি পরিবেশ থেকে পড়ে। BLOCKCHAIN0X_WEBHOOK_SECRET (যা আপনি একটি ওয়েবহুক তৈরি বা রোটেট করার সময় একবার ফেরত দেয়) ওয়েবহুক পরিচালনার প্রক্রিয়ায় প্রয়োজন। যদি আপনার গ্রাফ একটি প্রক্রিয়ায় চলে এবং হ্যান্ডলার অন্য একটি প্রক্রিয়ায় চলে, তবে উভয়কেই একই চেকপয়েন্টার (যেমন শেয়ার করা Postgres) প্রয়োজন যাতে হ্যান্ডলার সাসপেন্ডেড থ্রেডটি খুঁজে পায়।

ওয়েবহুকটি যাচাই করুন, তারপর থ্রেডটি পুনরায় শুরু করুন।

হ্যান্ডলারটি Node SDK থেকে webhooks.verify দিয়ে স্বাক্ষরটি যাচাই করে, আপনার নিজস্ব ম্যাপিং থেকে স্থগিত LangGraph থ্রেডটি খুঁজে বের করে, graph.updateState দিয়ে সেটেল করে, এবং interrupt থেকে অব্যাহত রাখতে graph.invoke(null, config) কল করে। কোনো বিশেষ সহায়ক নেই - সেগুলি LangGraph-এর নিজস্ব API।

import express from "express";
import { webhooks } from "@blockchain0x/node";
import { graph } from "./graph";

const app = express();
// Capture the RAW body. The HMAC is over the exact bytes on the wire.
app.use(express.raw({ type: "application/json" }));

app.post("/webhooks/payment", async (req, res) => {
  const result = webhooks.verify({
    headers: req.headers,
    rawBody: req.body, // Buffer, raw bytes
    secret: process.env.BLOCKCHAIN0X_WEBHOOK_SECRET!,
  });
  if (!result.ok) return res.status(400).json({ code: result.code });

  if (result.eventType === "payment.sent") {
    // You map the event to the suspended graph thread (your own store).
    const config = { configurable: { thread_id: threadFor(result.eventId) } };
    await graph.updateState(config, { settled: true });
    await graph.invoke(null, config); // resume from the interrupt
  }
  res.status(200).send("ok");
});

webhooks.verify RAW বডির উপর ধ্রুবক সময়ে HMAC-SHA256 করে এবং একটি বৈষম্যযুক্ত ইউনিয়ন ফেরত দেয় - result.ok এ শাখা করুন, কোন চেষ্টা/ধরা নেই। result.eventId কে সেই থ্রেডে ম্যাপ করুন যা আপনি স্থগিত করেছেন, তারপর graph.updateState + graph.invoke(null, config) সংরক্ষিত চেকপয়েন্ট থেকে পুনরায় শুরু করে এবং গ্রাফ রানগুলি বিতরণ করে। পাঠানো ইভেন্টগুলি হল payment.received, payment.sent, wallet.deployed, এবং webhook.test।

পাঁচটি LangGraph-নির্দিষ্ট ফাঁদ এড়ানো উচিত।

LangGraph-এর টেকসই-নিষ্পত্তি মডেল শক্তিশালী কিন্তু চেকপয়েন্ট, ইন্টারাপ্ট এবং রাষ্ট্র আপডেটের চারপাশে এর নিজস্ব বিপদ রয়েছে।