Connect All Your SaaS Tools Without Writing Code

// Pipedream workflow: New HubSpot Deal → Stripe + Notion + Slack
// Trigger: HubSpot — Deal Stage Changed to "Closed Won"

// Step 1: Transform HubSpot deal data
export default defineComponent({
  async run({ steps }) {
    const deal = steps.trigger.event;

    return {
      companyName: deal.properties.dealname,
      contactEmail: deal.properties.email,
      amount: parseFloat(deal.properties.amount),
      plan: deal.properties.plan_type || "pro",    // Custom HubSpot property
      annualBilling: deal.properties.billing_cycle === "annual",
      salesRep: deal.properties.hubspot_owner_id,
      closeDate: deal.properties.closedate,
    };
  },
});

// Step 2: Create Stripe customer and subscription
export default defineComponent({
  props: {
    stripe: { type: "app", app: "stripe" },
  },
  async run({ steps }) {
    const deal = steps.transform.$return_value;
    const stripe = require("stripe")(this.stripe.$auth.api_key);

    // Create customer
    const customer = await stripe.customers.create({
      email: deal.contactEmail,
      name: deal.companyName,
      metadata: { hubspot_deal: steps.trigger.event.id, sales_rep: deal.salesRep },
    });

    // Create subscription
    const priceId = deal.annualBilling
      ? process.env[`STRIPE_${deal.plan.toUpperCase()}_ANNUAL`]
      : process.env[`STRIPE_${deal.plan.toUpperCase()}_MONTHLY`];

    const subscription = await stripe.subscriptions.create({
      customer: customer.id,
      items: [{ price: priceId }],
      trial_period_days: 14,
    });

    return { customerId: customer.id, subscriptionId: subscription.id };
  },
});

// Step 3: Create Notion onboarding card
export default defineComponent({
  props: {
    notion: { type: "app", app: "notion" },
  },
  async run({ steps }) {
    const deal = steps.transform.$return_value;
    const { Client } = require("@notionhq/client");
    const notion = new Client({ auth: this.notion.$auth.oauth_access_token });

    await notion.pages.create({
      parent: { database_id: process.env.NOTION_ONBOARDING_DB },
      properties: {
        "Company": { title: [{ text: { content: deal.companyName } }] },
        "Contact": { email: deal.contactEmail },
        "Plan": { select: { name: deal.plan } },
        "ARR": { number: deal.annualBilling ? deal.amount : deal.amount * 12 },
        "Status": { select: { name: "Onboarding" } },
        "Sales Rep": { rich_text: [{ text: { content: deal.salesRep } }] },
      },
    });
  },
});

// Step 4: Celebrate in Slack
export default defineComponent({
  props: {
    slack: { type: "app", app: "slack" },
  },
  async run({ steps }) {
    const deal = steps.transform.$return_value;
    const stripe = steps.create_stripe.$return_value;

    await this.slack.chat.postMessage({
      channel: "#wins",
      text: `🎉 *New customer!* ${deal.companyName} signed up for ${deal.plan} plan!\n` +
            `💰 ${deal.annualBilling ? "Annual" : "Monthly"}: $${deal.amount.toLocaleString()}\n` +
            `📧 ${deal.contactEmail}\n` +
            `Stripe: https://dashboard.stripe.com/customers/${stripe.customerId}`,
    });
  },
});

## Make.com Scenario: Support Escalation → Linear + Slack

### Visual Flow:
[Intercom Webhook] → [Filter: priority = urgent] → [Router]
    ├→ [Linear: Create Issue] → [Intercom: Add Note with Linear link]
    └→ [Slack: Send Message to #eng-escalations]

### Configuration:
1. **Trigger**: Intercom webhook — "Conversation tag added: escalation"
2. **Filter**: Only proceed if conversation.priority == "urgent"
3. **Linear module**:
   - Team: Engineering
   - Title: "🚨 Escalation: {{intercom.conversation.subject}}"
   - Description: "Customer: {{intercom.conversation.user.email}}\n\n{{intercom.conversation.last_message}}"
   - Priority: Urgent
   - Label: customer-escalation
4. **Slack module**:
   - Channel: #eng-escalations
   - Message: "🚨 Urgent escalation from {{intercom.conversation.user.name}}\nLinear: {{linear.issue.url}}\nIntercom: {{intercom.conversation.url}}"
5. **Intercom module**:
   - Add internal note: "Linear issue created: {{linear.issue.url}}"

### Schedule: Real-time (instant webhook trigger)

# docker-compose.yml — Self-hosted Activepieces
version: "3.8"
services:
  activepieces:
    image: activepieces/activepieces:latest
    ports:
      - "8080:80"
    environment:
      AP_ENGINE_EXECUTABLE_PATH: "dist/packages/engine/main.js"
      AP_ENVIRONMENT: "prod"
      AP_FRONTEND_URL: "https://automations.internal.company.com"
      AP_ENCRYPTION_KEY: "${AP_ENCRYPTION_KEY}"
      AP_JWT_SECRET: "${AP_JWT_SECRET}"
      AP_POSTGRES_HOST: "postgres"
      AP_POSTGRES_DATABASE: "activepieces"
      AP_POSTGRES_USERNAME: "${POSTGRES_USER}"
      AP_POSTGRES_PASSWORD: "${POSTGRES_PASS}"
      AP_REDIS_HOST: "redis"
    depends_on:
      - postgres
      - redis

  postgres:
    image: postgres:16
    volumes:
      - pg_data:/var/lib/postgresql/data
    environment:
      POSTGRES_DB: activepieces
      POSTGRES_USER: ${POSTGRES_USER}
      POSTGRES_PASSWORD: ${POSTGRES_PASS}

  redis:
    image: redis:7
    volumes:
      - redis_data:/data

volumes:
  pg_data:
  redis_data: