n8n/packages/nodes-base/nodes/Aws/Cognito/GenericFunctions.ts

Ignoring revisions in .git-blame-ignore-revs. Click here to bypass and see the normal blame view.

824 lines
24 KiB
TypeScript
Raw Normal View History

2024-11-17 08:14:42 -08:00
import type {
ILoadOptionsFunctions,
INodeListSearchItems,
INodeListSearchResult,
IPollFunctions,
IDataObject,
IExecuteSingleFunctions,
IHttpRequestOptions,
INodeExecutionData,
IN8nHttpFullResponse,
JsonObject,
DeclarativeRestApiSettings,
IExecutePaginationFunctions,
} from 'n8n-workflow';
2024-11-29 06:13:45 -08:00
import { ApplicationError, jsonParse, NodeApiError, NodeOperationError } from 'n8n-workflow';
2024-11-17 08:14:42 -08:00
2025-01-06 05:38:03 -08:00
export async function presendTest(
this: IExecuteSingleFunctions,
requestOptions: IHttpRequestOptions,
): Promise<IHttpRequestOptions> {
console.log('requestOptions', requestOptions);
return requestOptions;
}
2024-11-17 08:14:42 -08:00
/*
* Helper function which stringifies the body before sending the request.
* It is added to the routing property in the "resource" parameter thus for all requests.
*/
export async function presendStringifyBody(
this: IExecuteSingleFunctions,
requestOptions: IHttpRequestOptions,
): Promise<IHttpRequestOptions> {
if (requestOptions.body) {
requestOptions.body = JSON.stringify(requestOptions.body);
}
return requestOptions;
}
export async function presendFilter(
this: IExecuteSingleFunctions,
requestOptions: IHttpRequestOptions,
): Promise<IHttpRequestOptions> {
const additionalFields = this.getNodeParameter('additionalFields', {}) as IDataObject;
2025-01-06 05:38:03 -08:00
const filterAttribute = additionalFields.filters as string;
2024-11-17 08:14:42 -08:00
let filterType = additionalFields.filterType as string;
const filterValue = additionalFields.filterValue as string;
2025-01-06 05:38:03 -08:00
const hasAnyFilter = filterAttribute || filterType || filterValue;
if (!hasAnyFilter) {
return requestOptions;
}
if (hasAnyFilter && (!filterAttribute || !filterType || !filterValue)) {
2024-12-05 11:15:33 -08:00
throw new NodeOperationError(
this.getNode(),
2025-01-06 05:38:03 -08:00
'If filtering is used, please provide Filter Attribute, Filter Type, and Filter Value.',
2024-12-05 11:15:33 -08:00
);
}
const filterTypeMapping: { [key: string]: string } = {
exactMatch: '=',
startsWith: '^=',
};
filterType = filterTypeMapping[filterType] || filterType;
let body: IDataObject;
if (typeof requestOptions.body === 'string') {
try {
body = JSON.parse(requestOptions.body) as IDataObject;
} catch (error) {
throw new NodeOperationError(this.getNode(), 'Failed to parse requestOptions body');
}
2024-11-17 08:14:42 -08:00
} else {
2024-12-05 11:15:33 -08:00
body = requestOptions.body as IDataObject;
}
requestOptions.body = JSON.stringify({
...body,
Filter: `${filterAttribute} ${filterType} "${filterValue}"`,
});
return requestOptions;
}
2025-01-06 05:38:03 -08:00
export async function presendAdditionalFields(
2024-12-05 11:15:33 -08:00
this: IExecuteSingleFunctions,
requestOptions: IHttpRequestOptions,
): Promise<IHttpRequestOptions> {
2025-01-06 05:38:03 -08:00
const additionalFields = this.getNodeParameter('additionalFields', {}) as IDataObject;
2024-12-05 11:15:33 -08:00
2025-01-06 05:38:03 -08:00
const hasOptions = Object.keys(additionalFields).length > 0;
2024-12-05 11:15:33 -08:00
if (!hasOptions) {
throw new NodeOperationError(
this.getNode(),
2025-01-06 05:38:03 -08:00
'At least one of the additional fields must be provided to update the group.',
2024-12-05 11:15:33 -08:00
);
}
return requestOptions;
}
2025-01-06 05:38:03 -08:00
export async function presendVerifyPath(
2024-12-05 11:15:33 -08:00
this: IExecuteSingleFunctions,
requestOptions: IHttpRequestOptions,
): Promise<IHttpRequestOptions> {
const path = this.getNodeParameter('path', '/') as string;
if (path.length < 1 || path.length > 512) {
throw new NodeOperationError(this.getNode(), 'Path must be between 1 and 512 characters.');
}
if (!/^\/$|^\/[\u0021-\u007E]+\/$/.test(path)) {
throw new NodeOperationError(
this.getNode(),
'Path must begin and end with a forward slash and contain valid ASCII characters.',
);
2024-11-17 08:14:42 -08:00
}
return requestOptions;
}
2024-11-27 00:33:23 -08:00
/* Helper function to process attributes in UserAttributes */
export async function processAttributes(
this: IExecuteSingleFunctions,
requestOptions: IHttpRequestOptions,
): Promise<IHttpRequestOptions> {
let body: Record<string, any>;
if (typeof requestOptions.body === 'string') {
try {
body = JSON.parse(requestOptions.body);
} catch (error) {
throw new ApplicationError('Invalid JSON body: Unable to parse.');
}
} else if (typeof requestOptions.body === 'object' && requestOptions.body !== null) {
body = requestOptions.body;
} else {
throw new ApplicationError('Invalid request body: Expected a JSON string or object.');
}
const attributes = this.getNodeParameter('UserAttributes.attributes', []) as Array<{
Name: string;
Value: string;
}>;
const processedAttributes = attributes.map((attribute) => ({
Name: attribute.Name.startsWith('custom:') ? attribute.Name : attribute.Name,
Value: attribute.Value,
}));
body.UserAttributes = processedAttributes;
requestOptions.body = JSON.stringify(body);
return requestOptions;
}
2024-11-17 08:14:42 -08:00
/* Helper function to handle pagination */
2024-11-28 11:07:25 -08:00
const possibleRootProperties = ['Users', 'Groups'];
2024-11-17 08:14:42 -08:00
export async function handlePagination(
this: IExecutePaginationFunctions,
resultOptions: DeclarativeRestApiSettings.ResultOptions,
): Promise<INodeExecutionData[]> {
const aggregatedResult: IDataObject[] = [];
let nextPageToken: string | undefined;
const returnAll = this.getNodeParameter('returnAll') as boolean;
2024-11-29 06:13:45 -08:00
let limit = 60;
2024-11-17 08:14:42 -08:00
if (!returnAll) {
limit = this.getNodeParameter('limit') as number;
2024-11-29 06:13:45 -08:00
resultOptions.maxResults = limit > 60 ? 60 : limit;
2024-11-17 08:14:42 -08:00
}
resultOptions.paginate = true;
2024-11-29 06:13:45 -08:00
const resource = this.getNodeParameter('resource') as string;
const tokenKey = resource === 'group' ? 'NextToken' : 'PaginationToken';
2024-11-28 11:07:25 -08:00
2024-11-29 06:13:45 -08:00
do {
2024-11-17 08:14:42 -08:00
if (nextPageToken) {
2024-11-29 06:13:45 -08:00
resultOptions.options.body = JSON.stringify({
...(typeof resultOptions.options.body === 'string'
? jsonParse(resultOptions.options.body)
: resultOptions.options.body),
[tokenKey]: nextPageToken,
});
2024-11-17 08:14:42 -08:00
}
const responseData = await this.makeRoutingRequest(resultOptions);
for (const page of responseData) {
for (const prop of possibleRootProperties) {
if (page.json[prop]) {
const currentData = page.json[prop] as IDataObject[];
aggregatedResult.push(...currentData);
}
}
if (!returnAll && aggregatedResult.length >= limit) {
return aggregatedResult.slice(0, limit).map((item) => ({ json: item }));
}
nextPageToken = page.json.PaginationToken as string | undefined;
}
} while (nextPageToken);
return aggregatedResult.map((item) => ({ json: item }));
}
/* Helper functions to handle errors */
2024-11-22 03:13:54 -08:00
export async function handleErrorPostReceive(
this: IExecuteSingleFunctions,
data: INodeExecutionData[],
response: IN8nHttpFullResponse,
): Promise<INodeExecutionData[]> {
if (String(response.statusCode).startsWith('4') || String(response.statusCode).startsWith('5')) {
const resource = this.getNodeParameter('resource') as string;
const operation = this.getNodeParameter('operation') as string;
const responseBody = response.body as IDataObject;
const errorType = responseBody.__type ?? response.headers?.['x-amzn-errortype'];
const errorMessage = responseBody.message ?? response.headers?.['x-amzn-errormessage'];
if (resource === 'group') {
if (operation === 'delete') {
if (errorType === 'ResourceNotFoundException' || errorType === 'NoSuchEntity') {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The group you are deleting could not be found.',
description: 'Adjust the "Group" parameter setting to delete the group correctly.',
});
}
} else if (operation === 'get') {
if (errorType === 'ResourceNotFoundException' || errorType === 'NoSuchEntity') {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The group you are requesting could not be found.',
description: 'Adjust the "Group" parameter setting to retrieve the group correctly.',
});
}
} else if (operation === 'update') {
if (errorType === 'ResourceNotFoundException' || errorType === 'NoSuchEntity') {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The group you are updating could not be found.',
description: 'Adjust the "Group" parameter setting to update the group correctly.',
});
}
} else if (operation === 'create') {
if (errorType === 'EntityAlreadyExists' || errorType === 'GroupExistsException') {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The group you are trying to create already exists',
description: 'Adjust the "Group Name" parameter setting to create the group correctly.',
});
}
}
} else if (resource === 'user') {
if (operation === 'create') {
2024-12-09 06:16:01 -08:00
if (errorType === 'UserNotFoundException') {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
message: "'Message Action: Resend' needs an existing user",
description: 'Adjust the "User Name" parameter setting to create the user correctly.',
});
}
if (
errorType === 'UsernameExistsException' &&
errorMessage === 'User account already exists'
) {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The user you are trying to create already exists',
description: 'Adjust the "User Name" parameter setting to create the user correctly.',
});
}
} else if (operation === 'addToGroup') {
if (errorType === 'UserNotFoundException') {
const user = this.getNodeParameter('user.value', '') as string;
if (typeof errorMessage === 'string' && errorMessage.includes(user)) {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The user you are requesting could not be found.',
description: 'Adjust the "User" parameter setting to retrieve the post correctly.',
});
}
} else if (errorType === 'ResourceNotFoundException') {
const group = this.getNodeParameter('group.value', '') as string;
if (typeof errorMessage === 'string' && errorMessage.includes(group)) {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The group you are requesting could not be found.',
description: 'Adjust the "Group" parameter setting to retrieve the post correctly.',
});
}
}
} else if (operation === 'delete') {
if (errorType === 'UserNotFoundException') {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The user you are requesting could not be found.',
description: 'Adjust the "User" parameter setting to retrieve the post correctly.',
});
}
} else if (operation === 'get') {
if (errorType === 'UserNotFoundException') {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The user you are requesting could not be found.',
description: 'Adjust the "User" parameter setting to retrieve the post correctly.',
});
}
} else if (operation === 'removeFromGroup') {
if (errorType === 'UserNotFoundException') {
const user = this.getNodeParameter('user.value', '') as string;
if (typeof errorMessage === 'string' && errorMessage.includes(user)) {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The user you are deleting could not be found.',
description: 'Adjust the "User" parameter setting to delete the user correctly.',
});
}
} else if (errorType === 'ResourceNotFoundException') {
const group = this.getNodeParameter('group.value', '') as string;
if (typeof errorMessage === 'string' && errorMessage.includes(group)) {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The group you are requesting could not be found.',
description: 'Adjust the "Group" parameter setting to delete the user correctly.',
});
}
}
} else if (operation === 'update') {
if (errorType === 'UserNotFoundException') {
throw new NodeApiError(this.getNode(), response as unknown as JsonObject, {
2024-12-05 11:15:33 -08:00
message: 'The user you are updating could not be found.',
description: 'Adjust the "User" parameter setting to update the user correctly.',
});
}
}
}
2024-11-22 03:13:54 -08:00
throw new NodeApiError(this.getNode(), response as unknown as JsonObject);
2024-11-17 08:14:42 -08:00
}
2024-11-17 08:14:42 -08:00
return data;
}
/* Helper function used in listSearch methods */
export async function awsRequest(
2025-01-06 05:38:03 -08:00
this: ILoadOptionsFunctions | IPollFunctions | IExecuteSingleFunctions,
2024-11-17 08:14:42 -08:00
opts: IHttpRequestOptions,
): Promise<IDataObject> {
const region = (await this.getCredentials('aws')).region as string;
const requestOptions: IHttpRequestOptions = {
...opts,
baseURL: `https://cognito-idp.${region}.amazonaws.com`,
json: true,
headers: {
'Content-Type': 'application/x-amz-json-1.1',
...opts.headers,
},
};
try {
return (await this.helpers.requestWithAuthentication.call(
this,
'aws',
requestOptions,
)) as IDataObject;
} catch (error) {
const statusCode = (error.statusCode || error.cause?.statusCode) as number;
let errorMessage = (error.response?.body?.message ||
error.response?.body?.Message ||
error.message) as string;
if (statusCode === 403) {
if (errorMessage === 'The security token included in the request is invalid.') {
throw new ApplicationError('The AWS credentials are not valid!', { level: 'warning' });
} else if (
errorMessage.startsWith(
'The request signature we calculated does not match the signature you provided',
)
) {
throw new ApplicationError('The AWS credentials are not valid!', { level: 'warning' });
}
}
if (error.cause?.error) {
try {
errorMessage = error.cause?.error?.message as string;
} catch (ex) {}
}
throw new ApplicationError(`AWS error response [${statusCode}]: ${errorMessage}`, {
level: 'warning',
});
}
}
export async function searchUserPools(
this: ILoadOptionsFunctions,
filter?: string,
paginationToken?: string,
): Promise<INodeListSearchResult> {
const opts: IHttpRequestOptions = {
2024-12-05 11:15:33 -08:00
url: '',
2024-11-17 08:14:42 -08:00
method: 'POST',
headers: {
'X-Amz-Target': 'AWSCognitoIdentityProviderService.ListUserPools',
},
body: JSON.stringify({
2024-12-05 11:15:33 -08:00
MaxResults: 60,
2024-11-17 08:14:42 -08:00
NextToken: paginationToken ?? undefined,
}),
};
const responseData: IDataObject = await awsRequest.call(this, opts);
const userPools = responseData.UserPools as Array<{ Name: string; Id: string }>;
const results: INodeListSearchItems[] = userPools
.map((a) => ({
name: a.Name,
value: a.Id,
}))
.filter(
(a) =>
!filter ||
a.name.toLowerCase().includes(filter.toLowerCase()) ||
a.value.toLowerCase().includes(filter.toLowerCase()),
)
.sort((a, b) => {
if (a.name.toLowerCase() < b.name.toLowerCase()) return -1;
if (a.name.toLowerCase() > b.name.toLowerCase()) return 1;
return 0;
});
2024-12-05 11:15:33 -08:00
return { results, paginationToken: responseData.NextToken };
2024-11-17 08:14:42 -08:00
}
2024-11-26 04:09:45 -08:00
export async function searchUsers(
this: ILoadOptionsFunctions,
filter?: string,
paginationToken?: string,
): Promise<INodeListSearchResult> {
2024-11-26 08:42:22 -08:00
const userPoolIdRaw = this.getNodeParameter('userPoolId', '') as IDataObject;
const userPoolId = userPoolIdRaw.value as string;
if (!userPoolId) {
throw new ApplicationError('User Pool ID is required to search users');
}
2024-11-26 04:09:45 -08:00
const opts: IHttpRequestOptions = {
2024-12-05 11:15:33 -08:00
url: '',
2024-11-26 04:09:45 -08:00
method: 'POST',
headers: {
'X-Amz-Target': 'AWSCognitoIdentityProviderService.ListUsers',
},
body: JSON.stringify({
2024-11-26 08:42:22 -08:00
UserPoolId: userPoolId,
MaxResults: 60,
2024-11-26 04:09:45 -08:00
NextToken: paginationToken ?? undefined,
}),
};
2024-11-26 08:42:22 -08:00
2024-11-26 04:09:45 -08:00
const responseData: IDataObject = await awsRequest.call(this, opts);
2024-11-26 08:42:22 -08:00
const users = responseData.Users as IDataObject[] | undefined;
2024-11-26 04:09:45 -08:00
2024-11-26 08:42:22 -08:00
if (!users) {
return { results: [] };
}
2024-11-26 04:09:45 -08:00
const results: INodeListSearchItems[] = users
2024-11-26 08:42:22 -08:00
.map((user) => {
const attributes = user.Attributes as Array<{ Name: string; Value: string }> | undefined;
const email = attributes?.find((attr) => attr.Name === 'email')?.Value;
const sub = attributes?.find((attr) => attr.Name === 'sub')?.Value;
const username = user.Username as string;
const name = email || sub || username;
const value = username;
return { name, value };
})
2024-11-26 04:09:45 -08:00
.filter(
2024-11-26 08:42:22 -08:00
(user) =>
2024-11-26 04:09:45 -08:00
!filter ||
2024-11-26 08:42:22 -08:00
user.name.toLowerCase().includes(filter.toLowerCase()) ||
user.value.toLowerCase().includes(filter.toLowerCase()),
2024-11-26 04:09:45 -08:00
)
.sort((a, b) => {
2024-11-26 08:42:22 -08:00
return a.name.toLowerCase().localeCompare(b.name.toLowerCase());
2024-11-26 04:09:45 -08:00
});
2024-11-26 08:42:22 -08:00
return { results, paginationToken: responseData.NextToken as string | undefined };
2024-11-26 04:09:45 -08:00
}
export async function searchGroups(
this: ILoadOptionsFunctions,
filter?: string,
paginationToken?: string,
): Promise<INodeListSearchResult> {
const userPoolIdRaw = this.getNodeParameter('userPoolId', '') as IDataObject;
const userPoolId = userPoolIdRaw.value as string;
if (!userPoolId) {
throw new ApplicationError('User Pool ID is required to search groups');
}
2024-11-26 04:09:45 -08:00
const opts: IHttpRequestOptions = {
2024-11-26 16:04:52 -08:00
url: '',
2024-11-26 04:09:45 -08:00
method: 'POST',
headers: {
'X-Amz-Target': 'AWSCognitoIdentityProviderService.ListGroups',
},
body: JSON.stringify({
UserPoolId: userPoolId,
MaxResults: 60,
2024-11-26 04:09:45 -08:00
NextToken: paginationToken ?? undefined,
}),
};
2024-11-26 04:09:45 -08:00
const responseData: IDataObject = await awsRequest.call(this, opts);
const groups = responseData.Groups as Array<{ GroupName?: string }> | undefined;
if (!groups) {
return { results: [] };
}
2024-11-26 04:09:45 -08:00
const results: INodeListSearchItems[] = groups
.filter((group) => group.GroupName)
.map((group) => ({
name: group.GroupName as string,
value: group.GroupName as string,
2024-11-26 04:09:45 -08:00
}))
.filter(
(group) =>
2024-11-26 04:09:45 -08:00
!filter ||
group.name.toLowerCase().includes(filter.toLowerCase()) ||
group.value.toLowerCase().includes(filter.toLowerCase()),
2024-11-26 04:09:45 -08:00
)
.sort((a, b) => {
return a.name.toLowerCase().localeCompare(b.name.toLowerCase());
2024-11-26 04:09:45 -08:00
});
return { results, paginationToken: responseData.NextToken };
2024-11-26 04:09:45 -08:00
}
2025-01-06 05:38:03 -08:00
export async function simplifyData(
this: IExecuteSingleFunctions,
items: INodeExecutionData[],
response: IN8nHttpFullResponse,
): Promise<INodeExecutionData[]> {
const simple = this.getNodeParameter('simple') as boolean;
type UserPool = {
Arn: string;
CreationDate: number;
DeletionProtection: string;
Domain: string;
EstimatedNumberOfUsers: number;
Id: string;
LastModifiedDate: number;
MfaConfiguration: string;
Name: string;
};
type User = {
Enabled: boolean;
UserAttributes?: Array<{ Name: string; Value: string }>;
Attributes?: Array<{ Name: string; Value: string }>;
UserCreateDate: number;
UserLastModifiedDate: number;
UserStatus: string;
Username: string;
};
function mapUserAttributes(userAttributes: Array<{ Name: string; Value: string }>): {
[key: string]: string;
} {
return userAttributes?.reduce(
(acc, { Name, Value }) => {
if (Name !== 'sub') {
acc[Name] = Value;
}
return acc;
},
{} as { [key: string]: string },
);
}
if (!simple) {
return items;
}
const resource = this.getNodeParameter('resource');
const operation = this.getNodeParameter('operation');
const simplifiedItems = items
.map((item) => {
const data = item.json?.UserPool as UserPool | undefined;
const userData = item.json as User | undefined;
const users = item.json?.Users as User[] | undefined;
switch (resource) {
case 'userPool':
if (data) {
return {
json: {
UserPool: {
Arn: data.Arn,
CreationDate: data.CreationDate,
DeletionProtection: data.DeletionProtection,
Domain: data.Domain,
EstimatedNumberOfUsers: data.EstimatedNumberOfUsers,
Id: data.Id,
LastModifiedDate: data.LastModifiedDate,
MfaConfiguration: data.MfaConfiguration,
Name: data.Name,
},
},
};
}
break;
case 'user':
if (userData) {
if (operation === 'get') {
const userAttributes = userData.UserAttributes
? mapUserAttributes(userData.UserAttributes)
: {};
return {
json: {
User: {
Enabled: userData.Enabled,
...Object.fromEntries(Object.entries(userAttributes).slice(0, 6)),
UserCreateDate: userData.UserCreateDate,
UserLastModifiedDate: userData.UserLastModifiedDate,
UserStatus: userData.UserStatus,
Username: userData.Username,
},
},
};
} else if (operation === 'getAll') {
if (users && Array.isArray(users)) {
const processedUsers: User[] = [];
users.forEach((user) => {
const userAttributes = user.Attributes ? mapUserAttributes(user.Attributes) : {};
processedUsers.push({
Enabled: userData.Enabled,
...Object.fromEntries(Object.entries(userAttributes).slice(0, 6)),
UserCreateDate: userData.UserCreateDate,
UserLastModifiedDate: userData.UserLastModifiedDate,
UserStatus: userData.UserStatus,
Username: userData.Username,
});
});
return {
json: {
Users: processedUsers,
},
};
}
}
}
break;
}
return undefined;
})
.filter((item) => item !== undefined)
.flat();
return simplifiedItems;
}
export async function listUsersInGroup(
this: IExecuteSingleFunctions,
groupName: string,
userPoolId: string,
): Promise<IDataObject> {
if (!userPoolId) {
throw new ApplicationError('User Pool ID is required');
}
const opts: IHttpRequestOptions = {
url: '',
method: 'POST',
headers: {
'X-Amz-Target': 'AWSCognitoIdentityProviderService.ListUsersInGroup',
},
body: JSON.stringify({
UserPoolId: userPoolId,
GroupName: groupName,
MaxResults: 60,
}),
};
const responseData: IDataObject = await awsRequest.call(this, opts);
const users = responseData.Users as IDataObject[] | undefined;
if (!users) {
return { results: [] };
}
const results: INodeListSearchItems[] = users
.map((user) => {
const attributes = user.Attributes as Array<{ Name: string; Value: string }> | undefined;
const email = attributes?.find((attr) => attr.Name === 'email')?.Value;
const sub = attributes?.find((attr) => attr.Name === 'sub')?.Value;
const username = user.Username as string;
const name = email || sub || username;
const value = username;
return { name, value };
})
.sort((a, b) => {
return a.name.toLowerCase().localeCompare(b.name.toLowerCase());
});
return { results, paginationToken: responseData.NextToken as string | undefined };
}
export async function getUsersForGroup(
this: IExecuteSingleFunctions,
groupName: string,
userPoolId: string,
): Promise<IDataObject[]> {
const users = await listUsersInGroup.call(this, groupName, userPoolId);
if (users && users.results && Array.isArray(users.results) && users.results.length > 0) {
return users.results as IDataObject[];
}
return [] as IDataObject[];
}
export async function processUsersForGroups(
this: IExecuteSingleFunctions,
items: INodeExecutionData[],
response: IN8nHttpFullResponse,
): Promise<INodeExecutionData[]> {
const userPoolIdRaw = this.getNodeParameter('userPoolId') as IDataObject;
const userPoolId = userPoolIdRaw.value as string;
const include = this.getNodeParameter('includeUsers', 0) as boolean;
if (!include) {
return items;
}
const processedGroups: IDataObject[] = [];
if (response.body && typeof response.body === 'object') {
if ('Group' in response.body) {
const group = (response.body as { Group: IDataObject }).Group;
const usersResponse = await getUsersForGroup.call(
this,
group.GroupName as string,
userPoolId,
);
if (usersResponse.length > 0) {
return items.map((item) => ({
json: { ...item.json, Users: usersResponse },
}));
} else {
return items.map((item) => ({
json: { ...item.json },
}));
}
} else {
const groups = (response.body as { Groups: IDataObject[] }).Groups;
for (const group of groups) {
const usersResponse = await getUsersForGroup.call(
this,
group.GroupName as string,
userPoolId,
);
if (usersResponse.length > 0) {
processedGroups.push({
...group,
Users: usersResponse,
});
} else {
processedGroups.push(group);
}
}
}
}
return items.map((item) => ({
json: { ...item.json, Groups: processedGroups },
}));
}
//Check if needed
export async function fetchUserPoolConfig(
this: IExecuteSingleFunctions,
requestOptions: IHttpRequestOptions,
): Promise<IHttpRequestOptions> {
const userPoolIdRaw = this.getNodeParameter('userPoolId') as IDataObject;
const userPoolId = userPoolIdRaw.value as string;
if (!userPoolId) {
throw new ApplicationError('User Pool ID is required');
}
const opts: IHttpRequestOptions = {
url: '',
method: 'POST',
body: JSON.stringify({
UserPoolId: userPoolId,
}),
headers: {
'X-Amz-Target': 'AWSCognitoIdentityProviderService.DescribeUserPool',
},
};
const responseData: IDataObject = await awsRequest.call(this, opts);
return requestOptions;
}