@ingeno/pipedream-services

Service utilities for Clarity data integrations.

Purpose

This package provides reusable service utilities for data integrations in the Clarity Pipedream project. It contains production-ready code that can be imported and used across different packages and deployed workflows.

Features

• AWS Services: Partner Central client, cost explorer, organizations, and STS utilities
• Zoho CRM: Complete CRM client with authentication, field metadata, and record management
• PostgreSQL: Database connection, table management, and bulk operations
• Collections: Data transformation and schema generation utilities
• Date/Time: Date manipulation and formatting helpers
• Streams: Reactive data streaming utilities

Usage

Zoho CRM Integration

1import { ZohoCRMClient, ZohoAuth } from '@ingeno/pipedream-services'
2
3const auth = new ZohoAuth(credentials)
4const client = new ZohoCRMClient({
5  accessToken: await auth.getAccessToken(),
6  apiDomain: credentials.api_domain
7})
8
9const deals = await client.getDeals()

PostgreSQL Operations

1import { fillTables, collectionsToTables } from '@ingeno/pipedream-services'
2
3const tablesRows = collectionsToTables(collections)
4await fillTables({
5  auth: postgresCredentials,
6  tablesRows,
7  tablesPrefix: 'zoho_crm_'
8})

AWS Partner Central

1import { PartnerCentralClient } from '@ingeno/pipedream-services'
2
3const client = new PartnerCentralClient({ credentials })
4const opportunities = await client.listAllOpportunities()

Installation

This package is published to npm and can be installed via:

1npm install @ingeno/pipedream-services
2# or
3pnpm add @ingeno/pipedream-services

Development

1# Build the package
2pnpm build
3
4# Run tests
5pnpm test
6
7# Lint code
8pnpm lint
9
10# Publish to npm
11pnpm pub

Architecture

This package contains only production code and is designed to be:

1. Lightweight: No test utilities or development dependencies
2. Reusable: Can be used across different packages and environments
3. Well-typed: Full TypeScript support with proper type definitions
4. Modular: Organized by service domain (AWS, Zoho, PostgreSQL, etc.)

Exports

The package provides both named and namespace exports:

• @ingeno/pipedream-services - Main entry point
• @ingeno/pipedream-services/aws - AWS-specific utilities
• @ingeno/pipedream-services/zoho - Zoho CRM utilities
• @ingeno/pipedream-services/date - Date utilities

License

MIT