Webhooks and Schedules

{
  "email": "jane@example.com",
  "company_domain": "example.com",
  "source": "hubspot"
}

import { definePlay } from 'deepline';

type InboundLead = {
  email: string;
  company_domain?: string;
};

export default definePlay('inbound-lead', async (ctx, input: InboundLead) => {
  const domain = input.company_domain ?? input.email.split('@')[1] ?? '';
  const company = await ctx.tools.execute({
    id: 'company_context',
    tool: 'test_rate_limit',
    input: { key: domain },
    description: 'Add company context before routing the inbound lead.',
  });

  return { email: input.email, domain, company_status: company.status };
}, {
  webhook: {
    hmac: {
      secretEnv: 'HUBSPOT_WEBHOOK_SECRET',
      header: 'x-hubspot-signature-v3',
      algorithm: 'sha256',
    },
  },
});

import { definePlay } from 'deepline';

export default definePlay('inbound-lead', async (_ctx, input: { email: string }) => {
  return { email: input.email };
}, {
  webhook: {},
});

import { definePlay } from 'deepline';

type Account = {
  domain: string;
};

export default definePlay('nightly-account-refresh', async (ctx, input: { accounts: Account[] }) => {
  const rows = await ctx
    .dataset('accounts', input.accounts)
    .withColumn('company_signal', (account, rowCtx) =>
      rowCtx.tools.execute({
        id: 'company_signal',
        tool: 'test_rate_limit',
        input: { key: account.domain },
        description: 'Refresh one account signal.',
      }),
    )
    .run({ key: 'domain' });

  return { rows };
}, {
  cron: {
    schedule: '0 9 * * *',
    timezone: 'America/New_York',
  },
});

deepline plays check docs-examples/sdk-v2/nightly-account-refresh.play.ts
deepline plays publish docs-examples/sdk-v2/nightly-account-refresh.play.ts

deepline plays run docs-nightly-account-refresh --input '{"accounts":[]}' --watch