code snippets for automation platforms

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");
  ...

import requests

email = input_data.get("email", "").strip().lower()
api_key = input_data.get("api_key", "")

if not email or "@" not in email:
    raise Exception(f'Invalid email: "{input_data.get("email", "")}"')

response = requests.get(
    "https://api.example.com/v1/users",
  ...

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,
  ...

results = []

for item in _items:
    data = item["json"]
    name = (data.get("name") or "").strip()
    email = (data.get("email") or "").lower()
    score = float(data.get("score") or 0)

    results.append({
        "json": {
  ...

const body = steps.trigger.event.body;

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

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

const axios = require("axios");

const { data } = await axios.post(
  "https://api.example.com/v1/records",
  {
    name: steps.trigger.event.body.name,
    email: steps.trigger.event.body.email,
  },
  {
    headers: {
  ...

// In the Pipedream UI, attach a Data Store to this step. The configured
// store is exposed as this.db inside run().
export default defineComponent({
  props: {
    db: { type: "data_store" },
  },
  async run({ steps, $ }) {
    const userId = steps.trigger.event.body.userId;
    const key = `user:${userId}`;

  ...

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,
  ...

import requests

body = pd.steps["trigger"]["event"]["body"]

if not body or not body.get("action"):
    pd.flow.exit("Missing required field: action")

allowed = {"create", "update", "delete"}
if body["action"] not in allowed:
    pd.flow.exit(f'Invalid action: {body["action"]}')
  ...

const { firstName, lastName, email, phone, tags } = input;

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

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

const contact = {
  ...

const rawPayload = input.jsonPayload;
const rawMeta = input.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 = input.url;
const apiKey = input.apiKey;

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

items = input.get("items", [])

results = []
for item in items:
    name = (item.get("name") or "").strip()
    email = (item.get("email") or "").lower()

    if not name or "@" not in email:
        continue

  ...

const hubspot = require("@hubspot/api-client");
const hubspotClient = new hubspot.Client({
  accessToken: process.env.HUBSPOT_PRIVATE_APP_TOKEN,
});

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

try {
  const searchResponse = await hubspotClient.crm.contacts.searchApi.doSearch({
    filterGroups: [
  ...

const axios = require("axios");
const hubspot = require("@hubspot/api-client");
const hubspotClient = new hubspot.Client({
  accessToken: process.env.HUBSPOT_PRIVATE_APP_TOKEN,
});

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

try {
  ...

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 hubspot = require("@hubspot/api-client");
const hubspotClient = new hubspot.Client({
  accessToken: process.env.HUBSPOT_PRIVATE_APP_TOKEN,
});

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

try {
  const missing = requiredFields.filter((f) => !event.inputFields[f]);
  ...

import os
import requests

object_id = event.get("object", {}).get("objectId")
token = os.getenv("HUBSPOT_PRIVATE_APP_TOKEN")

if not object_id or not token:
    return {"outputFields": {"found": False, "error": "Missing objectId or token"}}

response = requests.get(
  ...

{% 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 or "Get Started Today" %}
{% set subtext = module.subtext or "" %}
{% set button_text = module.button_text or "Learn More" %}
{% set button_url = module.button_url or "#" %}
{% set style = module.style or "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 or "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 %}
  ...