/** @module connect */ import { IConfigurable } from 'pip-services3-commons-nodex'; import { IReferenceable } from 'pip-services3-commons-nodex'; import { IReferences } from 'pip-services3-commons-nodex'; import { ConfigParams } from 'pip-services3-commons-nodex'; import { ConnectionResolver } from 'pip-services3-components-nodex'; import { CredentialResolver } from 'pip-services3-components-nodex'; import { AwsConnectionParams } from './AwsConnectionParams'; /** * Helper class to retrieve AWS connection and credential parameters, * validate them and compose a [[AwsConnectionParams]] value. * * ### Configuration parameters ### * * - connections: * - discovery_key: (optional) a key to retrieve the connection from [[https://pip-services3-node.github.io/pip-services3-components-nodex/interfaces/connect.idiscovery.html IDiscovery]] * - region: (optional) AWS region * - partition: (optional) AWS partition * - service: (optional) AWS service * - resource_type: (optional) AWS resource type * - resource: (optional) AWS resource id * - arn: (optional) AWS resource ARN * - credentials: * - store_key: (optional) a key to retrieve the credentials from [[https://pip-services3-nodex.github.io/pip-services3-components-nodex/interfaces/auth.icredentialstore.html ICredentialStore]] * - access_id: AWS access/client id * - access_key: AWS access/client id * * ### References ### * * - \*:discovery:\*:\*:1.0 (optional) [[https://pip-services3-nodex.github.io/pip-services3-components-nodex/interfaces/connect.idiscovery.html IDiscovery]] services to resolve connections * - \*:credential-store:\*:\*:1.0 (optional) Credential stores to resolve credentials * * @see [[https://pip-services3-nodex.github.io/pip-services3-components-nodex/classes/connect.connectionparams.html ConnectionParams]] (in the Pip.Services components package) * @see [[https://pip-services3-nodex.github.io/pip-services3-components-nodex/interfaces/connect.idiscovery.html IDiscovery]] (in the Pip.Services components package) * * ### Example ### * * let config = ConfigParams.fromTuples( * "connection.region", "us-east1", * "connection.service", "s3", * "connection.bucket", "mybucket", * "credential.access_id", "XXXXXXXXXX", * "credential.access_key", "XXXXXXXXXX" * ); * * let connectionResolver = new AwsConnectionResolver(); * connectionResolver.configure(config); * connectionResolver.setReferences(references); * * const connectionParams = await connectionResolver.resolve("123"); */ export class AwsConnectionResolver implements IConfigurable, IReferenceable { /** * The connection resolver. */ protected _connectionResolver: ConnectionResolver = new ConnectionResolver(); /** * The credential resolver. */ protected _credentialResolver: CredentialResolver = new CredentialResolver(); /** * Configures component by passing configuration parameters. * * @param config configuration parameters to be set. */ public configure(config: ConfigParams): void { this._connectionResolver.configure(config); this._credentialResolver.configure(config); } /** * Sets references to dependent components. * * @param references references to locate the component dependencies. */ public setReferences(references: IReferences): void { this._connectionResolver.setReferences(references); this._credentialResolver.setReferences(references); } /** * Resolves connection and credential parameters and generates a single * AWSConnectionParams value. * * @param correlationId (optional) transaction id to trace execution through call chain. * * @return {AwsConnectionParams} callback function that receives AWSConnectionParams value or error. * * @see [[https://pip-services3-nodex.github.io/pip-services3-components-nodex/interfaces/connect.idiscovery.html IDiscovery]] (in the Pip.Services components package) */ public async resolve(correlationId: string): Promise { let connection = new AwsConnectionParams(); const connectionParams = await this._connectionResolver.resolve(correlationId); connection.append(connectionParams); const credentialParams = await this._credentialResolver.lookup(correlationId); connection.append(credentialParams); // Force ARN parsing connection.setArn(connection.getArn()); // Perform validation connection.validate(correlationId); return connection; } }