Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions generated-sources/api/.openapi-generator/FILES
Original file line number Diff line number Diff line change
Expand Up @@ -187,6 +187,7 @@ src/models/Problem.ts
src/models/Project.ts
src/models/ProjectEntitlements.ts
src/models/ProjectEntitlementsBrandingRemoval.ts
src/models/ProjectEntitlementsLogRetentionDays.ts
src/models/ProviderApp.ts
src/models/ProviderAppMetadata.ts
src/models/ProviderAppMetadata1.ts
Expand Down
12 changes: 12 additions & 0 deletions generated-sources/api/src/apis/InstallationApi.ts
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@ export interface CreateInstallationOperationRequest {
projectIdOrName: string;
integrationId: string;
installation: CreateInstallationRequest;
skipSampling?: boolean;
}

export interface DeleteInstallationRequest {
Expand Down Expand Up @@ -78,6 +79,7 @@ export interface UpdateInstallationOperationRequest {
integrationId: string;
installationId: string;
installationUpdate: UpdateInstallationRequest;
skipSampling?: boolean;
}

/**
Expand All @@ -93,6 +95,7 @@ export interface InstallationApiInterface {
* @param {string} projectIdOrName The Ampersand project ID or project name.
* @param {string} integrationId The integration ID.
* @param {CreateInstallationRequest} installation
* @param {boolean} [skipSampling] When `true`, skips the sample read that validates the installation\'s read configuration against the provider before saving. Defaults to `false`.
* @param {*} [options] Override http request option.
* @throws {RequiredError}
* @memberof InstallationApiInterface
Expand Down Expand Up @@ -202,6 +205,7 @@ export interface InstallationApiInterface {
* @param {string} integrationId The ID of the integration that this installation belongs to.
* @param {string} installationId The Ampersand installation ID.
* @param {UpdateInstallationRequest} installationUpdate
* @param {boolean} [skipSampling] When `true`, skips the sample read that validates the installation\'s read configuration against the provider before saving. Defaults to `false`.
* @param {*} [options] Override http request option.
* @throws {RequiredError}
* @memberof InstallationApiInterface
Expand Down Expand Up @@ -240,6 +244,10 @@ export class InstallationApi extends runtime.BaseAPI implements InstallationApiI

const queryParameters: any = {};

if (requestParameters.skipSampling !== undefined) {
queryParameters['skipSampling'] = requestParameters.skipSampling;
}

const headerParameters: runtime.HTTPHeaders = {};

headerParameters['Content-Type'] = 'application/json';
Expand Down Expand Up @@ -561,6 +569,10 @@ export class InstallationApi extends runtime.BaseAPI implements InstallationApiI

const queryParameters: any = {};

if (requestParameters.skipSampling !== undefined) {
queryParameters['skipSampling'] = requestParameters.skipSampling;
}

const headerParameters: runtime.HTTPHeaders = {};

headerParameters['Content-Type'] = 'application/json';
Expand Down
10 changes: 5 additions & 5 deletions generated-sources/api/src/apis/IntegrationApi.ts
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ export interface CreateIntegrationOperationRequest {

export interface DeleteIntegrationRequest {
projectIdOrName: string;
integrationId: string;
integrationIdOrName: string;
}

export interface GetIntegrationRequest {
Expand Down Expand Up @@ -104,7 +104,7 @@ export interface IntegrationApiInterface {
* Delete an integration and all its installations.
* @summary Delete an integration
* @param {string} projectIdOrName The Ampersand project ID or project name.
* @param {string} integrationId The integration ID.
* @param {string} integrationIdOrName The integration ID or name.
* @param {*} [options] Override http request option.
* @throws {RequiredError}
* @memberof IntegrationApiInterface
Expand Down Expand Up @@ -267,8 +267,8 @@ export class IntegrationApi extends runtime.BaseAPI implements IntegrationApiInt
throw new runtime.RequiredError('projectIdOrName','Required parameter requestParameters.projectIdOrName was null or undefined when calling deleteIntegration.');
}

if (requestParameters.integrationId === null || requestParameters.integrationId === undefined) {
throw new runtime.RequiredError('integrationId','Required parameter requestParameters.integrationId was null or undefined when calling deleteIntegration.');
if (requestParameters.integrationIdOrName === null || requestParameters.integrationIdOrName === undefined) {
throw new runtime.RequiredError('integrationIdOrName','Required parameter requestParameters.integrationIdOrName was null or undefined when calling deleteIntegration.');
}

const queryParameters: any = {};
Expand All @@ -288,7 +288,7 @@ export class IntegrationApi extends runtime.BaseAPI implements IntegrationApiInt
}
}
const response = await this.request({
path: `/projects/{projectIdOrName}/integrations/{integrationId}`.replace(`{${"projectIdOrName"}}`, encodeURIComponent(String(requestParameters.projectIdOrName))).replace(`{${"integrationId"}}`, encodeURIComponent(String(requestParameters.integrationId))),
path: `/projects/{projectIdOrName}/integrations/{integrationIdOrName}`.replace(`{${"projectIdOrName"}}`, encodeURIComponent(String(requestParameters.projectIdOrName))).replace(`{${"integrationIdOrName"}}`, encodeURIComponent(String(requestParameters.integrationIdOrName))),
method: 'DELETE',
headers: headerParameters,
query: queryParameters,
Expand Down
8 changes: 4 additions & 4 deletions generated-sources/api/src/apis/OperationApi.ts
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ export interface OperationApiInterface {
getBackfillProgress(requestParameters: GetBackfillProgressRequest, initOverrides?: RequestInit | runtime.InitOverrideFunction): Promise<BackfillProgress>;

/**
* Retrieve a single operation by ID. An operation represents an async read, write, or subscribe action for an installation. Use this endpoint to poll for status, inspect the result summary, or fetch metadata such as backfill progress or write outcome details.
* Retrieve a single operation by ID. An operation represents an async read, write, or subscribe action for an installation. Use this endpoint to poll for status, inspect the result summary, or fetch metadata such as read progress or write outcome details.
* @summary Get an operation
* @param {string} projectIdOrName The Ampersand project ID or project name.
* @param {string} operationId Unique identifier for the operation. Obtain from the list operations API endpoint, the Ampersand dashboard, or webhook payloads.
Expand All @@ -100,7 +100,7 @@ export interface OperationApiInterface {
getOperationRaw(requestParameters: GetOperationRequest, initOverrides?: RequestInit | runtime.InitOverrideFunction): Promise<runtime.ApiResponse<Operation>>;

/**
* Retrieve a single operation by ID. An operation represents an async read, write, or subscribe action for an installation. Use this endpoint to poll for status, inspect the result summary, or fetch metadata such as backfill progress or write outcome details.
* Retrieve a single operation by ID. An operation represents an async read, write, or subscribe action for an installation. Use this endpoint to poll for status, inspect the result summary, or fetch metadata such as read progress or write outcome details.
* Get an operation
*/
getOperation(requestParameters: GetOperationRequest, initOverrides?: RequestInit | runtime.InitOverrideFunction): Promise<Operation>;
Expand Down Expand Up @@ -204,7 +204,7 @@ export class OperationApi extends runtime.BaseAPI implements OperationApiInterfa
}

/**
* Retrieve a single operation by ID. An operation represents an async read, write, or subscribe action for an installation. Use this endpoint to poll for status, inspect the result summary, or fetch metadata such as backfill progress or write outcome details.
* Retrieve a single operation by ID. An operation represents an async read, write, or subscribe action for an installation. Use this endpoint to poll for status, inspect the result summary, or fetch metadata such as read progress or write outcome details.
* Get an operation
*/
async getOperationRaw(requestParameters: GetOperationRequest, initOverrides?: RequestInit | runtime.InitOverrideFunction): Promise<runtime.ApiResponse<Operation>> {
Expand Down Expand Up @@ -243,7 +243,7 @@ export class OperationApi extends runtime.BaseAPI implements OperationApiInterfa
}

/**
* Retrieve a single operation by ID. An operation represents an async read, write, or subscribe action for an installation. Use this endpoint to poll for status, inspect the result summary, or fetch metadata such as backfill progress or write outcome details.
* Retrieve a single operation by ID. An operation represents an async read, write, or subscribe action for an installation. Use this endpoint to poll for status, inspect the result summary, or fetch metadata such as read progress or write outcome details.
* Get an operation
*/
async getOperation(requestParameters: GetOperationRequest, initOverrides?: RequestInit | runtime.InitOverrideFunction): Promise<Operation> {
Expand Down
3 changes: 2 additions & 1 deletion generated-sources/api/src/models/CreateDestinationRequest.ts
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,8 @@ export interface CreateDestinationRequest {
*/
export const CreateDestinationRequestTypeEnum = {
Webhook: 'webhook',
Kinesis: 'kinesis'
Kinesis: 'kinesis',
S3: 's3'
} as const;
export type CreateDestinationRequestTypeEnum = typeof CreateDestinationRequestTypeEnum[keyof typeof CreateDestinationRequestTypeEnum];

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ export interface CreateDestinationRequestMetadata {
*/
headers?: { [key: string]: string; } | null;
/**
* The AWS region where the kinesis destination is hosted.
* The AWS region where the Kinesis or S3 destination is hosted.
* @type {string}
* @memberof CreateDestinationRequestMetadata
*/
Expand All @@ -55,6 +55,24 @@ export interface CreateDestinationRequestMetadata {
* @memberof CreateDestinationRequestMetadata
*/
partitionKeyTemplate?: string;
/**
* The name of the S3 bucket to write objects to.
* @type {string}
* @memberof CreateDestinationRequestMetadata
*/
bucket?: string;
/**
* The template for the S3 object key to use when writing objects (a JMESPath template). If omitted, the key defaults to the message timestamp followed by the message ID.
* @type {string}
* @memberof CreateDestinationRequestMetadata
*/
keyTemplate?: string;
/**
* The S3 storage class for written objects. Defaults to STANDARD. Common values include STANDARD, STANDARD_IA, ONEZONE_IA, INTELLIGENT_TIERING, GLACIER, GLACIER_IR, and DEEP_ARCHIVE.
* @type {string}
* @memberof CreateDestinationRequestMetadata
*/
storageClass?: string;
}

/**
Expand Down Expand Up @@ -82,6 +100,9 @@ export function CreateDestinationRequestMetadataFromJSONTyped(json: any, ignoreD
'streamName': !exists(json, 'streamName') ? undefined : json['streamName'],
'endpointUrl': !exists(json, 'endpointUrl') ? undefined : json['endpointUrl'],
'partitionKeyTemplate': !exists(json, 'partitionKeyTemplate') ? undefined : json['partitionKeyTemplate'],
'bucket': !exists(json, 'bucket') ? undefined : json['bucket'],
'keyTemplate': !exists(json, 'keyTemplate') ? undefined : json['keyTemplate'],
'storageClass': !exists(json, 'storageClass') ? undefined : json['storageClass'],
};
}

Expand All @@ -100,6 +121,9 @@ export function CreateDestinationRequestMetadataToJSON(value?: CreateDestination
'streamName': value.streamName,
'endpointUrl': value.endpointUrl,
'partitionKeyTemplate': value.partitionKeyTemplate,
'bucket': value.bucket,
'keyTemplate': value.keyTemplate,
'storageClass': value.storageClass,
};
}

Original file line number Diff line number Diff line change
Expand Up @@ -20,19 +20,19 @@ import { exists, mapValues } from '../runtime';
*/
export interface CreateDestinationRequestSecrets {
/**
* The AWS access key ID for the Kinesis destination.
* The AWS access key ID for the Kinesis or S3 destination.
* @type {string}
* @memberof CreateDestinationRequestSecrets
*/
awsKeyId?: string;
/**
* The AWS secret access key for the Kinesis destination.
* The AWS secret access key for the Kinesis or S3 destination.
* @type {string}
* @memberof CreateDestinationRequestSecrets
*/
awsSecretKey?: string;
/**
* The AWS session token for the Kinesis destination.
* The AWS session token for the Kinesis or S3 destination.
* @type {string}
* @memberof CreateDestinationRequestSecrets
*/
Expand Down
37 changes: 12 additions & 25 deletions generated-sources/api/src/models/CreateEventTopicRouteRequest.ts
Original file line number Diff line number Diff line change
Expand Up @@ -13,18 +13,25 @@
*/

import { exists, mapValues } from '../runtime';
import type { NotificationEventType } from './NotificationEventType';
import {
NotificationEventTypeFromJSON,
NotificationEventTypeFromJSONTyped,
NotificationEventTypeToJSON,
} from './NotificationEventType';

/**
*
* @export
* @interface CreateEventTopicRouteRequest
*/
export interface CreateEventTopicRouteRequest {
/**
* The type of notification event.
* @type {string}
*
* @type {NotificationEventType}
* @memberof CreateEventTopicRouteRequest
*/
eventType: CreateEventTopicRouteRequestEventTypeEnum;
eventType: NotificationEventType;
/**
* The ID of the topic to route events to.
* @type {string}
Expand All @@ -33,26 +40,6 @@ export interface CreateEventTopicRouteRequest {
topicId: string;
}


/**
* @export
*/
export const CreateEventTopicRouteRequestEventTypeEnum = {
ReadBackfillDone: 'read.backfill.done',
ConnectionCreated: 'connection.created',
ConnectionError: 'connection.error',
ConnectionRefreshed: 'connection.refreshed',
ConnectionDeleted: 'connection.deleted',
InstallationCreated: 'installation.created',
InstallationUpdated: 'installation.updated',
InstallationDeleted: 'installation.deleted',
ReadSchedulePaused: 'read.schedule.paused',
WriteAsyncDone: 'write.async.done',
DestinationWebhookDisabled: 'destination.webhook.disabled'
} as const;
export type CreateEventTopicRouteRequestEventTypeEnum = typeof CreateEventTopicRouteRequestEventTypeEnum[keyof typeof CreateEventTopicRouteRequestEventTypeEnum];


/**
* Check if a given object implements the CreateEventTopicRouteRequest interface.
*/
Expand All @@ -74,7 +61,7 @@ export function CreateEventTopicRouteRequestFromJSONTyped(json: any, ignoreDiscr
}
return {

'eventType': json['eventType'],
'eventType': NotificationEventTypeFromJSON(json['eventType']),
'topicId': json['topicId'],
};
}
Expand All @@ -88,7 +75,7 @@ export function CreateEventTopicRouteRequestToJSON(value?: CreateEventTopicRoute
}
return {

'eventType': value.eventType,
'eventType': NotificationEventTypeToJSON(value.eventType),
'topicId': value.topicId,
};
}
Expand Down
24 changes: 24 additions & 0 deletions generated-sources/api/src/models/DestinationMetadata.ts
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,24 @@ export interface DestinationMetadata {
* @memberof DestinationMetadata
*/
partitionKeyTemplate?: string;
/**
* The name of the S3 bucket
* @type {string}
* @memberof DestinationMetadata
*/
bucket?: string;
/**
* JMESPath template for generating S3 object keys
* @type {string}
* @memberof DestinationMetadata
*/
keyTemplate?: string;
/**
* The S3 storage class for written objects (defaults to STANDARD)
* @type {string}
* @memberof DestinationMetadata
*/
storageClass?: string;
}

/**
Expand All @@ -75,6 +93,9 @@ export function DestinationMetadataFromJSONTyped(json: any, ignoreDiscriminator:
'streamName': !exists(json, 'streamName') ? undefined : json['streamName'],
'region': !exists(json, 'region') ? undefined : json['region'],
'partitionKeyTemplate': !exists(json, 'partitionKeyTemplate') ? undefined : json['partitionKeyTemplate'],
'bucket': !exists(json, 'bucket') ? undefined : json['bucket'],
'keyTemplate': !exists(json, 'keyTemplate') ? undefined : json['keyTemplate'],
'storageClass': !exists(json, 'storageClass') ? undefined : json['storageClass'],
};
}

Expand All @@ -92,6 +113,9 @@ export function DestinationMetadataToJSON(value?: DestinationMetadata | null): a
'streamName': value.streamName,
'region': value.region,
'partitionKeyTemplate': value.partitionKeyTemplate,
'bucket': value.bucket,
'keyTemplate': value.keyTemplate,
'storageClass': value.storageClass,
};
}

14 changes: 14 additions & 0 deletions generated-sources/api/src/models/ModuleInfo.ts
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,12 @@
*/

import { exists, mapValues } from '../runtime';
import type { SubscribeRequirements } from './SubscribeRequirements';
import {
SubscribeRequirementsFromJSON,
SubscribeRequirementsFromJSONTyped,
SubscribeRequirementsToJSON,
} from './SubscribeRequirements';
import type { Support } from './Support';
import {
SupportFromJSON,
Expand Down Expand Up @@ -44,6 +50,12 @@ export interface ModuleInfo {
* @memberof ModuleInfo
*/
support: Support;
/**
*
* @type {SubscribeRequirements}
* @memberof ModuleInfo
*/
subscribeRequirements?: SubscribeRequirements;
}

/**
Expand Down Expand Up @@ -71,6 +83,7 @@ export function ModuleInfoFromJSONTyped(json: any, ignoreDiscriminator: boolean)
'displayName': json['displayName'],
'baseURL': json['baseURL'],
'support': SupportFromJSON(json['support']),
'subscribeRequirements': !exists(json, 'subscribeRequirements') ? undefined : SubscribeRequirementsFromJSON(json['subscribeRequirements']),
};
}

Expand All @@ -86,6 +99,7 @@ export function ModuleInfoToJSON(value?: ModuleInfo | null): any {
'displayName': value.displayName,
'baseURL': value.baseURL,
'support': SupportToJSON(value.support),
'subscribeRequirements': SubscribeRequirementsToJSON(value.subscribeRequirements),
};
}

1 change: 1 addition & 0 deletions generated-sources/api/src/models/NotificationEventType.ts
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@ export const NotificationEventType = {
ReadTriggeredDone: 'read.triggered.done',
ReadTriggeredError: 'read.triggered.error',
WriteAsyncDone: 'write.async.done',
SubscribeCreateError: 'subscribe.create.error',
DestinationWebhookDisabled: 'destination.webhook.disabled'
} as const;
export type NotificationEventType = typeof NotificationEventType[keyof typeof NotificationEventType];
Expand Down
Loading
Loading