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: {
      auth: {
        type: 'standard-webhooks',
        headerFamily: 'standard',
        signingSecrets: ['INBOUND_RELAY_WEBHOOK_SECRET'],
        toleranceSeconds: 300,
      },
    },
  },
);

deepline secrets set INBOUND_RELAY_WEBHOOK_SECRET --scope play --play inbound-lead

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