LangGraph-യ്ക്ക് പ്രത്യേക package ഒന്നുമില്ല, അതിനായി ഒന്നും ആവശ്യമില്ല. നിങ്ങളുടെ -ലെ ഒരു plain node real client വിളിക്കുന്നു, payment webhook എത്തുന്നതുവരെ ഒരു graph-നെ suspend ചെയ്യുന്നു, തുടർന്ന് handler LangGraph-ന്റെ സ്വന്തം + ഉപയോഗിച്ച് അത് resume ചെയ്യുന്നു. Payments 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 നിങ്ങളുടെ dashboard-ലുള്ള sk_test_ testnet അല്ലെങ്കിൽ sk_live_ mainnet കീ ആണ്; client അതിനെ environment-ൽ നിന്ന് വായിക്കുന്നു. BLOCKCHAIN0X_WEBHOOK_SECRET (ഒരു webhook create ചെയ്യുമ്പോഴോ rotate ചെയ്യുമ്പോഴോ ഒരിക്കൽ return ചെയ്യുന്നത്) webhooks കൈകാര്യം ചെയ്യുന്ന process-ിൽ ആവശ്യമാണ്. നിങ്ങളുടെ graph ഒരു process-ിലും handler മറ്റൊന്നിലും പ്രവർത്തിക്കുന്നുവെങ്കിൽ, handler suspended thread കണ്ടെത്താൻ രണ്ടിനും same checkpointer (ഉദാ. shared Postgres) ആവശ്യമാണ്.

വെബ്‌ഹുക്ക് സ്ഥിരീകരിക്കുക, തുടർന്ന് ത്രെഡ് വീണ്ടും ആരംഭിക്കുക.

ഹാൻഡ്ലർ Node SDK-യിൽ നിന്ന് webhooks.verify ഉപയോഗിച്ച് ഒപ്പുവെച്ചതിന്റെ സ്ഥിരീകരണം നടത്തുന്നു, നിങ്ങളുടെ സ്വന്തം മാപ്പിംഗിൽ നിന്ന് സസ്പെൻഡഡ് LangGraph ത്രെഡ് പരിശോധിക്കുന്നു, graph.updateState ഉപയോഗിച്ച് settled ക്രമീകരിക്കുന്നു, graph.invoke(null, config) വിളിക്കുന്നു, ഇടവേളയിൽ നിന്ന് തുടരാൻ. പ്രത്യേക സഹായികളില്ല - അവ LangGraph-ന്റെ സ്വന്തം APIs ആണ്.

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 HMAC-SHA256 കൃത്യമായ സമയത്ത് കച്ചവട ശരീരത്തിൽ നടത്തുന്നു, വ്യത്യസ്തമായ യൂണിയൻ തിരികെ നൽകുന്നു - result.ok ൽ ബ്രാഞ്ച് ചെയ്യുക, ശ്രമിക്കുക/പിടിക്കുക ഇല്ല. result.eventId ന്റെ ത്രെഡ് നിങ്ങൾ നിർത്തിയതിലേക്ക് മാപ്പ് ചെയ്യുക, പിന്നീട് graph.updateState + graph.invoke(null, config) നിലനിൽക്കുന്ന ചെക്ക് പോയിന്റിൽ നിന്ന് പുനരാരംഭിക്കുന്നു, ഗ്രാഫ് പ്രവർത്തിക്കുന്നു. അയച്ച സംഭവങ്ങൾ payment.received, payment.sent, wallet.deployed, webhook.test ആണ്.

എടുപ്പിക്കേണ്ട അഞ്ചു LangGraph-നിഷ്‌ഠമായ തട്ടിപ്പുകൾ.

LangGraphന്റെ ദൃഢ-നടപ്പാക്കൽ മാതൃക ശക്തമാണ്, എന്നാൽ ചെക്ക്‌പോയിന്റുകൾ, ഇടപെടലുകൾ, സംസ്ഥാന അപ്ഡേറ്റുകൾ എന്നിവയുടെ ചുറ്റുപാടുകളിൽ അതിന്റെ സ്വന്തം അപകടങ്ങൾ ഉണ്ട്.