|
1 | 1 | /* eslint-disable @microsoft/spfx/no-async-await */ |
| 2 | +import { IDropdownOption } from "@fluentui/react"; |
2 | 3 | import { ServiceKey } from "@microsoft/sp-core-library"; |
3 | 4 | import { Logger } from "@pnp/logging"; |
4 | 5 | import { SPFI } from "@pnp/sp"; |
5 | 6 | import * as AppSettings from "AppSettings"; |
6 | 7 | import { getSP } from "../middleware"; |
7 | | -import { isTriggerConfigValid, ITriggerConfig } from "../models"; |
| 8 | +import { IRequestedUserInput, isTriggerConfigValid, ITriggerConfig, SupportedInputTypes } from "../models"; |
8 | 9 |
|
9 | 10 | export interface ISPOService { |
10 | 11 | getTriggerConfig(): Promise<ITriggerConfig[]>; |
@@ -47,39 +48,106 @@ export class SPOService implements ISPOService { |
47 | 48 | .getByTitle(this._configListTitle) |
48 | 49 | .items.top(flowLimit)() |
49 | 50 | .then((response): Promise<ITriggerConfig[]> => { |
| 51 | + return Promise.all(response.map(async (triggerConfigListItem) => { |
| 52 | + try { |
| 53 | + const flowConfig: ITriggerConfig = { |
| 54 | + title: triggerConfigListItem?.Title, |
| 55 | + triggerUrl: triggerConfigListItem?.TriggerURL, |
| 56 | + httpMethod: triggerConfigListItem?.HTTPType, |
| 57 | + originSecret: triggerConfigListItem?.OriginSecret, |
| 58 | + listWhitelist: triggerConfigListItem?.ListWhitelist, |
| 59 | + folderWhitelist: triggerConfigListItem?.FolderWhitelist, |
| 60 | + contentTypeBlacklist: triggerConfigListItem?.ContentTypeBlacklist, |
| 61 | + fileExtensionBlacklist: triggerConfigListItem?.FileExtensionBlacklist, |
| 62 | + selectionLimit: triggerConfigListItem?.SelectionLimit, |
| 63 | + requestedUserInput: triggerConfigListItem?.RequestedUserInput ? JSON.parse(triggerConfigListItem?.RequestedUserInput) : undefined |
| 64 | + }; |
| 65 | + |
| 66 | + if (!isTriggerConfigValid(flowConfig)) { |
| 67 | + throw new Error(`Flow configuration for '${flowConfig.title}' is invalid.`); |
| 68 | + } else if (flowConfig.requestedUserInput) { |
| 69 | + return await this._processRequestedUserInput(flowConfig.requestedUserInput).then((processedRequestedInput: IRequestedUserInput[]) => { |
| 70 | + flowConfig.requestedUserInput = processedRequestedInput; |
| 71 | + return Promise.resolve(flowConfig); |
| 72 | + }); |
| 73 | + } else { |
| 74 | + return Promise.resolve(flowConfig); |
| 75 | + } |
| 76 | + } |
| 77 | + catch (err) { |
| 78 | + Logger.error(err); |
| 79 | + return Promise.reject(); |
| 80 | + } |
| 81 | + })); |
| 82 | + }); |
| 83 | + } catch (err) { |
| 84 | + Logger.error(err); |
| 85 | + return Promise.reject(null); |
| 86 | + } |
| 87 | + } |
| 88 | + |
| 89 | + /** |
| 90 | + * Processes the requested user input fields for the flow trigger. |
| 91 | + * @param requestedUserInput The requested user input fields for the flow trigger. |
| 92 | + */ |
| 93 | + private _processRequestedUserInput = async (requestedUserInput: IRequestedUserInput[]): Promise<IRequestedUserInput[]> => { |
| 94 | + try { |
| 95 | + return await Promise.all(requestedUserInput.map(async (requestedInput: IRequestedUserInput): Promise<IRequestedUserInput> => { |
| 96 | + if (requestedInput.type === SupportedInputTypes.Lookup || requestedInput.type === SupportedInputTypes.MultiLookup) { |
| 97 | + return await this._getLookupOptions(requestedInput.lookupListName, requestedInput.lookupDisplayColumn).then((options: IDropdownOption[]) => { |
| 98 | + const processedRequestedInput: IRequestedUserInput = requestedInput; |
| 99 | + processedRequestedInput.options = options; |
| 100 | + return Promise.resolve(processedRequestedInput); |
| 101 | + }); |
| 102 | + } else { |
| 103 | + return Promise.resolve(requestedInput); |
| 104 | + } |
| 105 | + })); |
| 106 | + } catch (err) { |
| 107 | + Logger.error(err); |
| 108 | + return Promise.reject(requestedUserInput); |
| 109 | + } |
| 110 | + } |
| 111 | + |
| 112 | + /** |
| 113 | + * Fetches the lookup options for the requested user input for the flow trigger. |
| 114 | + * @param list The list to fetch the lookup options from. |
| 115 | + * @param displayField The column of the lookup list to display in the option set. |
| 116 | + */ |
| 117 | + private _getLookupOptions = async (list: string, displayField: string): Promise<IDropdownOption[]> => { |
| 118 | + try { |
| 119 | + if (!this._sp) { |
| 120 | + throw new Error("Context is invalid."); |
| 121 | + } |
| 122 | + |
| 123 | + return await this._sp.web.lists |
| 124 | + .getByTitle(list) |
| 125 | + .select(`Id, ${displayField}`) |
| 126 | + .items() |
| 127 | + .then((response): Promise<IDropdownOption[]> => { |
50 | 128 | return new Promise((resolve, reject): void => { |
51 | | - const flowConfigs: ITriggerConfig[] = []; |
| 129 | + const lookupOptions: IDropdownOption[] = []; |
52 | 130 |
|
53 | | - response.forEach((triggerConfigListItem): void => { |
| 131 | + response.forEach((item): void => { |
54 | 132 | try { |
55 | | - const flowConfig: ITriggerConfig = { |
56 | | - title: triggerConfigListItem?.Title, |
57 | | - triggerUrl: triggerConfigListItem?.TriggerURL, |
58 | | - httpMethod: triggerConfigListItem?.HTTPType, |
59 | | - originSecret: triggerConfigListItem?.OriginSecret, |
60 | | - listWhitelist: triggerConfigListItem?.ListWhitelist, |
61 | | - folderWhitelist: triggerConfigListItem?.FolderWhitelist, |
62 | | - contentTypeBlacklist: triggerConfigListItem?.ContentTypeBlacklist, |
63 | | - fileExtensionBlacklist: triggerConfigListItem?.FileExtensionBlacklist, |
64 | | - selectionLimit: triggerConfigListItem?.SelectionLimit, |
65 | | - requestedUserInput: triggerConfigListItem?.RequestedUserInput ? JSON.parse(triggerConfigListItem?.RequestedUserInput) : undefined |
| 133 | + const lookupOption: IDropdownOption = { |
| 134 | + key: item.Id, |
| 135 | + text: item[displayField].toString() |
66 | 136 | }; |
67 | 137 |
|
68 | | - if (!isTriggerConfigValid(flowConfig)) { |
69 | | - throw new Error(`Flow configuration for '${flowConfig.title}' is invalid.`); |
70 | | - } else { |
71 | | - flowConfigs.push(flowConfig); |
72 | | - } |
| 138 | + lookupOptions.push(lookupOption); |
73 | 139 | } |
74 | 140 | catch (err) { |
75 | 141 | Logger.error(err); |
76 | 142 | } |
77 | 143 | }); |
78 | | - resolve(flowConfigs); |
| 144 | + resolve(lookupOptions); |
79 | 145 | }); |
80 | 146 | }); |
| 147 | + |
81 | 148 | } catch (err) { |
82 | 149 | Logger.error(err); |
| 150 | + console.log(`EnhancedPowerAutomateTrigger -> Could not fetch lookup options for list '${list}'.`); |
83 | 151 | return null |
84 | 152 | } |
85 | 153 | } |
|
0 commit comments