@memberjunction/integration-connectors

Concrete integration connectors for the MemberJunction Integration Engine. This package provides connectors for CRM, accounting, membership, newsletter, and file-based systems — all implementing BaseIntegrationConnector from @memberjunction/integration-engine.

Connectors

Production REST API Connectors

These connectors call live external APIs and extend BaseRESTIntegrationConnector.

SalesforceConnector

Production connector for Salesforce CRM using the REST API v61.0 with full bidirectional sync.

Registration: @RegisterClass(BaseIntegrationConnector, 'SalesforceConnector')

Authentication — Two Supported Flows:

The connector auto-detects the auth flow based on the credentials provided.

1. Client Credentials Flow (recommended for new setups):

{
  "authFlow": "client_credentials",
  "loginUrl": "https://myorg.my.salesforce.com",
  "clientId": "3MVG9...your-consumer-key",
  "clientSecret": "D4A28...your-client-secret",
  "apiVersion": "61.0"
}

2. JWT Bearer Token Flow (RS256, certificate-based):

{
  "authFlow": "jwt_bearer",
  "loginUrl": "https://login.salesforce.com",
  "tokenUrl": "https://myorg.my.salesforce.com",
  "clientId": "3MVG9...your-consumer-key",
  "username": "integration-user@myorg.com",
  "privateKey": "-----BEGIN RSA PRIVATE KEY-----\n...\n-----END RSA PRIVATE KEY-----",
  "apiVersion": "61.0"
}

Field	Required	Description
loginUrl	Yes	Org URL. For Client Credentials: My Domain URL. For JWT: login.salesforce.com (prod) or test.salesforce.com (sandbox) as the JWT audience.
clientId	Yes	Connected App Consumer Key
clientSecret	CC only	Client Secret from Connected App
username	JWT only	Integration user’s Salesforce email
privateKey	JWT only	PEM-encoded RSA private key (matching X.509 cert uploaded to Connected App)
tokenUrl	No	Token endpoint URL if different from loginUrl (e.g., My Domain URL for JWT flow)
apiVersion	No	Salesforce REST API version (default: 61.0)
authFlow	No	Explicit flow selection. Auto-detected: clientSecret present → client_credentials; privateKey + username present → jwt_bearer

Capabilities:

• Full CRUD (Create, Read, Update, Delete)
• SOQL-based search
• Live schema discovery via Describe API (standard + custom objects)
• Incremental sync with SystemModstamp watermarks and queryAll for deleted records
• Governor limit tracking (throttles at 80%, pauses at 95%)
• Automatic token caching and refresh

Standard Objects (9): Account, Contact, Lead, Opportunity, Task, Event, Case, Campaign, User (read-only)

Default field mappings:

Source Object	Target Entity	Key Mappings
Contact	Contacts	Email (key), FirstName, LastName, Phone, MobilePhone, Title, Department, mailing address fields (12 total)
Account	Companies	Name (key), Industry, Phone, Website, billing address fields, Type, AnnualRevenue, NumberOfEmployees (10 total)
Lead	Contacts	Email (key), FirstName, LastName, Company, Phone, Title (6 total)

See also: Connector usage guide · Connected App setup guide

HubSpotConnector

Production connector for HubSpot CRM using the V3 API with full bidirectional sync, including association objects.

Registration: @RegisterClass(BaseIntegrationConnector, 'HubSpotConnector')

Authentication: OAuth2 Bearer token via HubSpot Private App credentials.

Capabilities: Full CRUD, search, list, association fetching (v4 per-object associations endpoint)

Objects: Contacts, Companies, Deals, Owners, Tickets, Line Items, plus association objects (Contact↔Company, Deal↔Company, etc.)

Default field mappings:

Source Object	Target Entity	Key Mappings
Contacts	Contacts	email (key), firstname, lastname, phone, company, lifecyclestage
Companies	Companies	name (key), domain, industry, city, state

RasaConnector

Production connector for Rasa.io newsletter platform. Read-only — pulls newsletter and subscriber data.

Registration: @RegisterClass(BaseIntegrationConnector, 'RasaConnector')

Authentication: Basic auth (username/password) to obtain a JWT, scoped to a community ID.

Objects: Newsletters, Newsletter Sections, Newsletter Section Items, Subscribers

WicketConnector

Production connector for Wicket membership management platform with full bidirectional sync.

Registration: @RegisterClass(BaseIntegrationConnector, 'WicketConnector')

Authentication: HMAC-SHA256 signed requests.

Capabilities: Full CRUD, search

Accounting Connectors

These connectors integrate with accounting and ERP systems.

SageIntacctConnector

Production connector for Sage Intacct accounting/ERP using the XML Web Services API with full bidirectional sync.

Registration: @RegisterClass(BaseIntegrationConnector, 'SageIntacctConnector')

Authentication: Session-based — Sender ID/Password (app credentials) + User ID/Password authenticate via getAPISession, returning a session ID for subsequent requests.

Credentials JSON:

{
  "CompanyId": "your-company-id",
  "SenderId": "your-sender-id",
  "SenderPassword": "your-sender-password",
  "UserId": "your-user-id",
  "UserPassword": "your-user-password",
  "EntityId": "optional-entity-id"
}

Field	Required	Description
CompanyId	Yes	Sage Intacct Company ID
SenderId	Yes	Web Services Sender ID (from Marketplace subscription)
SenderPassword	Yes	Web Services Sender Password
UserId	Yes	User ID for API authentication
UserPassword	Yes	User password
EntityId	No	Entity ID for multi-entity shared companies

Capabilities:

• Full CRUD (Create, Read, Update, Delete)
• Query-based search via readByQuery
• Paginated listing via readMore
• Live schema discovery via inspect API
• Incremental sync with WHENMODIFIED watermarks
• Session caching and automatic refresh
• Retry with exponential backoff

Objects (9): Customer, Vendor, GL Account, AP Bill, AR Invoice, Project, Employee, Department, Class

Default field mappings:

Source Object	Target Entity	Key Mappings
CUSTOMER	Contacts	CUSTOMERID (key), NAME, EMAIL, PHONE, STATUS
VENDOR	Companies	VENDORID (key), NAME, EMAIL, PHONE, STATUS

QuickBooksConnector

Production connector for QuickBooks Online using the REST API v3 with OAuth 2.0 authentication.

Registration: @RegisterClass(BaseIntegrationConnector, 'QuickBooksConnector')

Authentication: OAuth 2.0 with automatic token refresh. Requires a QuickBooks app with client ID/secret and an initial refresh token obtained through the OAuth consent flow.

Credentials JSON:

{
  "ClientId": "your-client-id",
  "ClientSecret": "your-client-secret",
  "RefreshToken": "your-refresh-token",
  "RealmId": "your-company-realm-id",
  "Environment": "production"
}

Field	Required	Description
ClientId	Yes	OAuth 2.0 Client ID from QuickBooks developer portal
ClientSecret	Yes	OAuth 2.0 Client Secret
RefreshToken	Yes	OAuth 2.0 refresh token (auto-refreshed on each use)
RealmId	Yes	QuickBooks Company ID (Realm ID)
Environment	No	production (default) or sandbox

Capabilities:

• Full CRUD (Create, Read, Update, Delete)
• SQL-like query via QuickBooks Query Language
• Paginated listing
• Live schema discovery
• Incremental sync with MetaData.LastUpdatedTime watermarks
• Automatic OAuth token refresh
• Minor version pinning for API stability

Objects (10): Customer, Vendor, Account, Invoice, Bill, Item, Payment, Employee, Department, Class

Default field mappings:

Source Object	Target Entity	Key Mappings
Customer	Contacts	Id (key), DisplayName, PrimaryEmailAddr, PrimaryPhone, Active
Vendor	Companies	Id (key), DisplayName, PrimaryEmailAddr, PrimaryPhone, Active

SQL-Based Connectors

These connectors read from SQL Server databases and extend RelationalDBConnector.

RelationalDBConnector (Base Class)

Abstract base class for connectors backed by SQL Server via the mssql package.

Configuration JSON:

{
  "server": "your-sql-server",
  "database": "YourDatabase",
  "user": "username",
  "password": "password"
}

Shared capabilities:

• TestConnection — runs SELECT @@VERSION
• DiscoverObjects — queries INFORMATION_SCHEMA.TABLES
• DiscoverFields — queries INFORMATION_SCHEMA.COLUMNS
• FetchChangesFromTable — incremental fetch with watermark filtering and batch limiting
• Connection pool caching per server+database pair

YourMembershipConnector

Reads from YourMembership database tables: ym_Members, ym_Events, ym_EventRegistrations, ym_Chapters, ym_MembershipLevels.

Registration: @RegisterClass(BaseIntegrationConnector, 'YourMembershipConnector')

Default field mappings:

Source Object	Target Entity	Key Mappings
ym_Members	Contacts	email (key), first_name, last_name, phone, status

File-Based Connectors

FileFeedConnector

Reads data from local CSV files. Always performs a full load (no incremental sync).

Registration: @RegisterClass(BaseIntegrationConnector, 'FileFeedConnector')

Configuration JSON:

{
  "storagePath": "/absolute/path/to/file.csv",
  "fileType": "csv"
}

Capabilities:

• TestConnection — checks that the file exists on disk
• DiscoverObjects — returns the file name as the single available object
• DiscoverFields — parses the CSV header row
• FetchChanges — parses all rows into ExternalRecord[] (watermark ignored)

Action Generation

Integration connectors can auto-generate MJ Action metadata for use by AI agents and workflow engines. Each connector declares its objects and fields via GetIntegrationObjects(), and the CLI generator produces mj-sync compatible JSON files.

# Generate actions for all connectors
npx tsx src/generate-integration-actions.ts

# Generate for a specific connector
npx tsx src/generate-integration-actions.ts salesforce
npx tsx src/generate-integration-actions.ts hubspot
npx tsx src/generate-integration-actions.ts sage-intacct
npx tsx src/generate-integration-actions.ts quickbooks

See INTEGRATION_ACTIONS.md for full documentation.

Building

cd packages/Integration/connectors
npm run build

Testing

cd packages/Integration/connectors
npm run test          # single run
npm run test:watch    # watch mode

Architecture

src/
  index.ts                        # Package exports
  RelationalDBConnector.ts        # Base class for SQL-based connectors
  HubSpotConnector.ts             # HubSpot REST API connector (full CRUD)
  SalesforceConnector.ts          # Salesforce REST API connector (full CRUD)
  SageIntacctConnector.ts         # Sage Intacct XML API connector (full CRUD)
  QuickBooksConnector.ts          # QuickBooks Online REST API connector (full CRUD)
  RasaConnector.ts                # Rasa.io REST API connector (read-only)
  WicketConnector.ts              # Wicket REST API connector (full CRUD)
  YourMembershipConnector.ts      # YourMembership SQL connector
  FileFeedConnector.ts            # CSV file connector
  generate-integration-actions.ts # CLI: auto-generate action metadata from connectors
  __tests__/                      # Unit and integration tests
test-fixtures/
  sample-contacts.csv             # 100-row sample for FileFeed testing