This repository has been archived by the owner on Dec 22, 2021. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
10 changed files
with
302 additions
and
66 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
File renamed without changes.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,212 @@ | ||
| /* eslint-disable no-await-in-loop */ | ||
| /* eslint-disable require-atomic-updates */ | ||
| import { ILogger, HLogger, spinner, getState, setState } from '@serverless-devs/core'; | ||
| import _ from 'lodash'; | ||
| import Client from '../utils/client'; | ||
| import { IProperties } from '../common/entity'; | ||
| import { promptForConfirmOrDetails } from '../utils/utils'; | ||
|
|
||
| const errorCode = ['ServiceNotFound', 'FunctionNotFound', 'TriggerNotFound']; | ||
| interface RemoveInputsProps { | ||
| force?: boolean; | ||
| silent?: boolean; | ||
| triggerName?: string; | ||
| } | ||
|
|
||
| export default class Component { | ||
| @HLogger('FC-BASE-SDK') logger: ILogger; | ||
| fcClient: any; | ||
| region: any; | ||
|
|
||
| constructor(region) { | ||
| this.region = region; | ||
| this.fcClient = Client.fcClient(); | ||
| } | ||
|
|
||
| async trigger(props: IProperties, { force, silent, triggerName }: RemoveInputsProps, command?: string) { | ||
| const { service, function: functionConfig, triggers = [] } = props; | ||
| const serviceName = service?.name || functionConfig?.service; | ||
| const functionName = functionConfig?.name; | ||
|
|
||
| if (_.isEmpty(serviceName)) { | ||
| throw new Error('Delete trigger, service name cannot be empty'); | ||
| } | ||
| if (_.isEmpty(functionName)) { | ||
| throw new Error('Delete trigger, function name cannot be empty'); | ||
| } | ||
|
|
||
| if (triggerName) { | ||
| return await this.deleteTrigger(serviceName, functionName, triggerName); | ||
| } | ||
|
|
||
| if (silent || command === 'trigger') { | ||
| for (const { name } of triggers) { | ||
| await this.deleteTrigger(serviceName, functionName, name); | ||
| } | ||
| return; | ||
| } | ||
|
|
||
| let deleteTriggerList: string[]; | ||
| const yamlTriggerNames = triggers.map(({ name }) => name); | ||
| const listTrigger = await this.getListData(`/services/${serviceName}/functions/${functionName}/triggers`, 'triggers'); | ||
| const listTriggerNames = listTrigger.map((item) => item.triggerName); | ||
|
|
||
| if (force) { | ||
| deleteTriggerList = Array.from(yamlTriggerNames.concat(listTriggerNames)); | ||
| } else { | ||
| const prompt = `${serviceName}/${functionName} has triggers outside the configuration, delete all?`; | ||
| deleteTriggerList = await this.getDeleteList(yamlTriggerNames, listTriggerNames, prompt); | ||
| } | ||
|
|
||
| this.logger.debug(`delete trigger list: ${JSON.stringify(deleteTriggerList)}`); | ||
| for (const name of deleteTriggerList) { | ||
| await this.deleteTrigger(serviceName, functionName, name); | ||
| } | ||
| } | ||
|
|
||
| async function(props: IProperties, { force, silent }: RemoveInputsProps, command?: string) { | ||
| const serviceName = props.service?.name || props.function?.service; | ||
| const functionName = props.function?.name || ''; | ||
|
|
||
| if (_.isEmpty(serviceName)) { | ||
| throw new Error('Delete function, service name cannot be empty'); | ||
| } | ||
| if (silent || command === 'function') { | ||
| if (_.isEmpty(functionName)) { | ||
| throw new Error('Delete function, function name cannot be empty'); | ||
| } | ||
| await this.trigger(props, { force, silent }, 'function'); | ||
| return await this.deleteFunction(serviceName, functionName); | ||
| } | ||
|
|
||
| const listFunctions = await this.getListData(`/services/${serviceName}/functions`, 'functions'); | ||
| const listFunctionNames = listFunctions.map((item) => item.functionName); | ||
|
|
||
| let deleteFunctionList: string[]; | ||
| if (force) { | ||
| deleteFunctionList = listFunctionNames; | ||
| } else { | ||
| const prompt = `${serviceName} has function outside the configuration, delete all?`; | ||
| const yamlNames = _.isEmpty(functionName) ? [] : [functionName]; | ||
| deleteFunctionList = await this.getDeleteList(yamlNames, listFunctionNames, prompt); | ||
| } | ||
|
|
||
| this.logger.debug(`delete function list: ${JSON.stringify(deleteFunctionList)}`); | ||
| for (const name of deleteFunctionList) { | ||
| const cloneProps = _.cloneDeep(props); | ||
| if (_.isEmpty(cloneProps.function)) { | ||
| cloneProps.function = { | ||
| name, | ||
| handler: '', | ||
| runtime: '', | ||
| }; | ||
| } else { | ||
| cloneProps.function.name = name; | ||
| } | ||
|
|
||
| await this.trigger(cloneProps, { force, silent }, 'function'); | ||
| await this.deleteFunction(serviceName, name); | ||
| } | ||
| } | ||
|
|
||
| async service(props: IProperties, { force, silent }: RemoveInputsProps) { | ||
| const serviceName = props.service?.name; | ||
| if (_.isEmpty(serviceName)) { | ||
| throw new Error('Delete service, service name cannot be empty'); | ||
| } | ||
|
|
||
| await this.function(props, { force, silent }, 'service'); | ||
| await this.deleteService(serviceName); | ||
| } | ||
|
|
||
| private async deleteService(serviceName) { | ||
| const vm = spinner(`Delete service ${serviceName}...`); | ||
| try { | ||
| await this.fcClient.deleteService(serviceName); | ||
| vm.succeed(`Delete service ${serviceName} success.`); | ||
|
|
||
| const stateId = `${this.fcClient.accountid}-${this.region}-${serviceName}`; | ||
| await this.unsetState(stateId); | ||
| } catch (ex) { | ||
| if (!errorCode.includes(ex.code)) { | ||
| vm.fail(); | ||
| throw ex; | ||
| } | ||
| vm.warn(`[${ex.code}], ${ex.message}`); | ||
| } | ||
| } | ||
|
|
||
| private async deleteFunction(serviceName, functionName) { | ||
| const vm = spinner(`Delete function ${serviceName}/${functionName}...`); | ||
| try { | ||
| await this.fcClient.deleteFunction(serviceName, functionName); | ||
| vm.succeed(`Delete function ${serviceName}/${functionName} success.`); | ||
|
|
||
| const stateId = `${this.fcClient.accountid}-${this.region}-${serviceName}-${functionName}`; | ||
| await this.unsetState(stateId); | ||
| } catch (ex) { | ||
| if (!errorCode.includes(ex.code)) { | ||
| vm.fail(); | ||
| throw ex; | ||
| } | ||
| vm.warn(`[${ex.code}], ${ex.message}`); | ||
| } | ||
| } | ||
|
|
||
| private async deleteTrigger(serviceName, functionName, triggerName) { | ||
| const vm = spinner(`Delete trigger ${serviceName}/${functionName}/${triggerName}...`); | ||
| try { | ||
| await this.fcClient.deleteTrigger(serviceName, functionName, triggerName); | ||
| vm.succeed(`Delete trigger ${serviceName}/${functionName}/${triggerName} success.`); | ||
|
|
||
| const stateId = `${this.fcClient.accountid}-${this.region}-${serviceName}-${functionName}-${triggerName}`; | ||
| await this.unsetState(stateId); | ||
| } catch (ex) { | ||
| if (!errorCode.includes(ex.code)) { | ||
| vm.fail(); | ||
| throw ex; | ||
| } | ||
| vm.warn(`[${ex.code}], ${ex.message}`); | ||
| } | ||
| } | ||
|
|
||
| private async unsetState(stateId: string): Promise<void> { | ||
| const state: any = await getState(stateId); | ||
| if (!_.isEmpty(state)) { | ||
| await setState(stateId, {}); | ||
| } | ||
| } | ||
|
|
||
| private async getDeleteList(yamlArr: string[], arr: string[], prompt: string) { | ||
| for (const name of arr) { | ||
| if (!yamlArr.includes(name)) { | ||
| if (await promptForConfirmOrDetails(prompt)) { | ||
| return Array.from(yamlArr.concat(arr)); | ||
| } else { | ||
| return yamlArr; | ||
| } | ||
| } | ||
| } | ||
| return yamlArr; | ||
| } | ||
|
|
||
| private async getListData(path, dataKeyword, options: { [key: string]: any } = {}, headers?) { | ||
| try { | ||
| let data = []; | ||
| do { | ||
| const res = await this.fcClient.get(path, options, headers); | ||
| const keywordData = res.data?.[dataKeyword]; | ||
| options.nextToken = res.data?.nextToken; | ||
|
|
||
| if (!_.isEmpty(keywordData)) { | ||
| data = data.concat(keywordData); | ||
| } | ||
| } while (options.nextToken); | ||
|
|
||
| return data; | ||
| } catch (ex) { | ||
| this.logger.warn(`get ${path} error: ${ex.code}\n${ex.message}`); | ||
| return []; | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.