George Lambert
b4150c8250
Compose-ready workspace: packages/zappier (rate card, portal, Stripe), packages/verae-zapier-middleware (timestamp + NATS), packages/verae-zapier (CLI app), vendor/zapier-platform, and research/zapier vendor corpus. Gate 0 structure checks pass. Product code and research are not yet wired.
76 lines
2.1 KiB
JavaScript
76 lines
2.1 KiB
JavaScript
/**
|
|
* Verae Zapier Platform app definition.
|
|
* @module index
|
|
*/
|
|
|
|
const authentication = require('./authentication');
|
|
const timestampAndWait = require('./creates/timestamp_and_wait');
|
|
const createTimestamp = require('./creates/create_timestamp');
|
|
const verifyTimestamp = require('./creates/verify_timestamp');
|
|
const batchTimestamp = require('./creates/batch_timestamp');
|
|
const jobStatus = require('./searches/job_status');
|
|
const timestampCompleted = require('./triggers/timestamp_completed');
|
|
|
|
/**
|
|
* Attach middleware API key to every outbound request.
|
|
* @param {object} request
|
|
* @param {object} _z
|
|
* @param {object} bundle
|
|
*/
|
|
const addApiKey = (request, _z, bundle) => {
|
|
request.headers = request.headers || {};
|
|
request.headers.Authorization = `Bearer ${bundle.authData.api_key}`;
|
|
return request;
|
|
};
|
|
|
|
/**
|
|
* Map middleware billing errors to Zapier errors.
|
|
* @param {object} response
|
|
* @param {object} z
|
|
*/
|
|
const mapMiddlewareErrors = (response, z) => {
|
|
if (response.status === 402) {
|
|
throw new z.errors.Error(
|
|
`${response.data?.error ?? 'Quota exceeded'}. Upgrade at ${response.data?.details?.upgradeUrl ?? response.data?.upgradeUrl ?? 'your billing portal'}.`,
|
|
'QuotaExceeded',
|
|
402,
|
|
);
|
|
}
|
|
|
|
if (response.status === 403 && response.data?.code === 'PLAN_UPGRADE_REQUIRED') {
|
|
throw new z.errors.Error(
|
|
response.data?.error ?? 'This action requires a paid plan.',
|
|
'PlanUpgradeRequired',
|
|
403,
|
|
);
|
|
}
|
|
|
|
return response;
|
|
};
|
|
|
|
let platformVersion = '15.19.0';
|
|
try {
|
|
platformVersion = require('zapier-platform-core').version;
|
|
} catch {
|
|
// optional for unit tests without full install
|
|
}
|
|
|
|
module.exports = {
|
|
version: require('./package.json').version,
|
|
platformVersion,
|
|
authentication,
|
|
beforeRequest: [addApiKey],
|
|
afterResponse: [mapMiddlewareErrors],
|
|
triggers: {
|
|
[timestampCompleted.key]: timestampCompleted,
|
|
},
|
|
creates: {
|
|
[timestampAndWait.key]: timestampAndWait,
|
|
[createTimestamp.key]: createTimestamp,
|
|
[verifyTimestamp.key]: verifyTimestamp,
|
|
[batchTimestamp.key]: batchTimestamp,
|
|
},
|
|
searches: {
|
|
[jobStatus.key]: jobStatus,
|
|
},
|
|
};
|