codefmt

const url = inputData.apiUrl;
const apiKey = inputData.apiKey;

const response = await fetch(url, {
  method: "GET",
  headers: {
    Authorization: `Bearer ${apiKey}`,
    Accept: "application/json",
  },
});
  ...

const raw = inputData.dateString;
const date = new Date(raw);

if (isNaN(date.getTime())) {
  throw new Error(`Invalid date: "${raw}"`);
}

const iso = date.toISOString();
const yyyy = date.getFullYear();
const mm = String(date.getMonth() + 1).padStart(2, "0");
  ...

const items = JSON.parse(inputData.jsonArray);

const transformed = items
  .filter((item) => item.status === "active" && item.email)
  .map((item) => ({
    fullName: `${item.firstName} ${item.lastName}`.trim(),
    email: item.email.toLowerCase(),
    role: item.role || "member",
  }));

  ...

const email = (inputData.email || "").trim().toLowerCase();
const name = (inputData.name || "").trim();
const amount = parseFloat(inputData.amount);

if (!email || !email.includes("@")) {
  throw new Error(`Invalid email: "${inputData.email}"`);
}

if (!name || name.length < 2) {
  throw new Error("Name is required and must be at least 2 characters");
  ...

const raw = inputData.emails || "";
const tag = inputData.tag || "imported";

const emails = raw
  .split(",")
  .map((e) => e.trim().toLowerCase())
  .filter((e) => e.includes("@"));

if (emails.length === 0) {
  throw new Error("No valid emails found in input");
  ...

const items = $input.all();
const results = [];

for (const item of items) {
  const { name, email, score } = item.json;

  results.push({
    json: {
      name: (name || "").trim(),
      email: (email || "").toLowerCase(),
  ...

const url = $json.apiUrl || $env.API_URL;
const maxRetries = 3;
let lastError;

for (let attempt = 0; attempt < maxRetries; attempt++) {
  try {
    const response = await fetch(url, {
      headers: { Authorization: `Bearer ${$env.API_KEY}` },
    });

  ...

const startStr = $json.startDate;
const endStr = $json.endDate;

const start = new Date(startStr);
const end = new Date(endStr);

if (isNaN(start.getTime()) || isNaN(end.getTime())) {
  return [{ json: { error: "Invalid date input" } }];
}

  ...

const items = $input.all();
const results = [];

for (const item of items) {
  try {
    const payload = JSON.parse(item.json.rawData);

    if (!payload.id) {
      throw new Error("Missing required field: id");
    }
  ...

const webhookData = $("Webhook").first().json;
const dbRecords = $("Postgres").all();
const configValue = $("Set Config").first().json.apiEndpoint;

const enriched = dbRecords.map((record) => ({
  json: {
    ...record.json,
    source: webhookData.source || "unknown",
    triggeredBy: webhookData.userId,
    endpoint: configValue,
  ...

const body = event.body;

if (!body || !body.action) {
  $.flow.exit("Missing required field: action");
}

const allowedActions = ["create", "update", "delete"];
if (!allowedActions.includes(body.action)) {
  $.flow.exit(`Invalid action: ${body.action}`);
}
  ...

const { data } = await $.axios(this, {
  method: "POST",
  url: `https://api.example.com/v1/records`,
  headers: {
    Authorization: `Bearer ${steps.trigger.event.auth_token}`,
    "Content-Type": "application/json",
  },
  data: {
    name: steps.trigger.event.body.name,
    email: steps.trigger.event.body.email,
  ...

const db = $.service.db;
const key = `user:${event.body.userId}`;

const existing = db.get(key);

if (existing && existing.lastSeen) {
  const lastSeen = new Date(existing.lastSeen);
  const now = new Date();
  const hoursSince = (now - lastSeen) / (1000 * 60 * 60);

  ...

const requiredVars = ["API_KEY", "WEBHOOK_SECRET"];
const missing = requiredVars.filter((v) => !process.env[v]);

if (missing.length > 0) {
  throw new Error(`Missing env vars: ${missing.join(", ")}`);
}

const config = {
  apiKey: process.env.API_KEY,
  webhookSecret: process.env.WEBHOOK_SECRET,
  ...

const { firstName, lastName, email, phone, tags } = bundle.inputData;

const fullName = `${(firstName || "").trim()} ${(lastName || "").trim()}`.trim();

const tagList = (tags || "")
  .split(",")
  .map((t) => t.trim().toLowerCase())
  .filter(Boolean);

const contact = {
  ...

const rawPayload = bundle.inputData.jsonPayload;
const rawMeta = bundle.inputData.metadata;

let payload;
let metadata;

try {
  payload = typeof rawPayload === "string" ? JSON.parse(rawPayload) : rawPayload;
} catch (e) {
  throw new Error(`Failed to parse jsonPayload: ${e.message}`);
  ...

const url = bundle.inputData.url;
const apiKey = connection.apiKey;

try {
  const response = await fetch(url, {
    headers: {
      Authorization: `Bearer ${apiKey}`,
      Accept: "application/json",
    },
  });
  ...

const email = event.inputFields["email"];

try {
  const searchResponse = await hubspot.crm.contacts.searchApi.doSearch({
    filterGroups: [
      {
        filters: [
          { propertyName: "email", operator: "EQ", value: email },
        ],
      },
  ...

const objectId = event.object.objectId;
const email = event.inputFields["email"];
const apiKey = event.secrets.EXTERNAL_API_KEY;

try {
  const response = await axios.post("https://api.example.com/enrich", {
    email,
    source: "hubspot",
  }, {
    headers: { Authorization: `Bearer ${apiKey}` },
  ...

const eventType = event.inputFields["hs_event_type"];
const objectId = event.object.objectId;
const properties = event.inputFields;

let action;
let outputData = {};

switch (eventType) {
  case "contact.creation":
    action = "new_contact";
  ...

const contactId = event.object.objectId;
const requiredFields = ["email", "firstname"];

try {
  const missing = requiredFields.filter((f) => !event.inputFields[f]);
  if (missing.length > 0) {
    throw new Error(`Missing fields: ${missing.join(", ")}`);
  }

  const contact = await hubspot.crm.contacts.basicApi.getById(contactId, [
  ...

{% set items = module.items %}
{% if items %}
  <ul class="card-list">
    {% for item in items %}
      <li class="card{% if loop.first %} card--first{% endif %}">
        <h3>{{ item.title|escape }}</h3>
        {% if item.description %}
          <p>{{ item.description|truncatewords(30) }}</p>
        {% else %}
          <p class="text-muted">No description available</p>
  ...

{# Custom CTA Banner Module #}
{% set heading = module.heading || "Get Started Today" %}
{% set subtext = module.subtext || "" %}
{% set button_text = module.button_text || "Learn More" %}
{% set button_url = module.button_url || "#" %}
{% set style = module.style || "primary" %}

<section class="cta-banner cta-banner--{{ style }}">
  <div class="cta-banner__content">
    <h2 class="cta-banner__heading">{{ heading }}</h2>
  ...

{% set blog_posts = blog_recent_posts("default", 6) %}

<div class="blog-listing">
  <h2>{{ module.heading || "Latest Posts" }}</h2>
  <div class="blog-grid">
    {% for post in blog_posts %}
      <article class="blog-card">
        {% if post.featured_image %}
          <img src="{{ post.featured_image }}"
               alt="{{ post.featured_image_alt_text|default(post.name, true) }}"
  ...

{% set form_id = module.form.form_id %}
{% set show_title = module.show_title|default(true) %}
{% set bg_color = module.background_color.color|default("#ffffff") %}

{% if form_id %}
  <div class="form-section" style="background-color: {{ bg_color }};">
    <div class="form-section__inner">
      {% if show_title and module.title %}
        <h2 class="form-section__title">{{ module.title }}</h2>
      {% endif %}
  ...