Function createProspect

server/src/services/prospect.ts:67–230

(
  input: CreateProspectInput
)

 * Auto-enriches the organization if a domain is provided.
 */
export async function createProspect(
  input: CreateProspectInput
): Promise<CreateProspectResult> {
  const pool = getPool();

  if (!workos) {
    return {
      success: false,
      error: 'WorkOS not configured',
    };
  }

  const name = input.name.trim();

  // Validate prospect_status if provided
  if (input.prospect_status && !VALID_PROSPECT_STATUSES.includes(input.prospect_status as typeof VALID_PROSPECT_STATUSES[number])) {
    return {
      success: false,
      error: `Invalid prospect_status. Must be one of: ${VALID_PROSPECT_STATUSES.join(', ')}`,
    };
  }

  // Normalize domain to lowercase
  const normalizedDomain = input.domain?.trim().toLowerCase() || null;

  // Check if domain resolves to an existing organization (exact, alias, sub-brand, or redirect)
  if (normalizedDomain) {
    const resolved = await resolveOrgByDomain(normalizedDomain);
    if (resolved) {
      const isAlias = resolved.matchedDomain !== normalizedDomain;
      logger.info({ domain: normalizedDomain, matchedDomain: resolved.matchedDomain, method: resolved.method, orgId: resolved.orgId },
        isAlias ? 'Domain resolves to existing org via alias' : 'Domain already tracked');

      // Fetch actual org details so callers have useful info
      const orgRow = await pool.query<{ name: string; prospect_status: string | null }>(
        `SELECT name, prospect_status FROM organizations WHERE workos_organization_id = $1`,
        [resolved.orgId]
      );
      const orgName = orgRow.rows[0]?.name ?? resolved.matchedDomain;
      return {
        success: false,
        error: isAlias ? `Domain resolves to ${orgName} via ${resolved.method}` : `Domain already tracked (${orgName})`,
        alreadyExists: true,
        organization: {
          workos_organization_id: resolved.orgId,
          name: orgRow.rows[0]?.name ?? resolved.matchedDomain,
          prospect_status: orgRow.rows[0]?.prospect_status ?? '',
        },
      };
    }
  }

  // Check for existing organization with same name
  const existing = await pool.query(
    `SELECT workos_organization_id, name FROM organizations
     WHERE LOWER(name) = LOWER($1) AND is_personal = false`,
    [name]
  );