Function handler

src/commands/schema/update.ts:61–115

(argv: ArgumentsCamelCase<CommandArgs>)

		.epilog(buildEpilog({ command, apiDocs: 'putAppsByEndpointAppId' }))

const handler = async (argv: ArgumentsCamelCase<CommandArgs>): Promise<void> => {
	const command = await apiOrganizationCommand(argv)

	const id = await chooseSchemaApp(command, argv.id)

	const { schemaApp: original, organizationWasUpdated } = await getSchemaAppEnsuringOrganization(command, id, argv)
	if (original.certificationStatus === 'wwst' ||
			original.certificationStatus === 'cst' ||
			original.certificationStatus === 'review') {
		const cancelMsgBase =
			'Schema Apps that have already been certified cannot be updated via the CLI'
		const cancelMsg = organizationWasUpdated
			? cancelMsgBase + ' so further updates are not possible.'
			: cancelMsgBase + '.'
		return cancelCommand(cancelMsg)
	}

	const getInputFromUser = async (): Promise<SchemaAppRequest> =>
		getSchemaAppUpdateFromUser(command, original, !!argv.dryRun)

	// We use `inputItem` instead of `inputAndOutputItem` because the API does not return the
	// updated object like most other APIs.
	const [request, defaultIOFormat] =
		await inputItem<SchemaAppWithOrganization>(argv, userInputProcessor(getInputFromUser))
	if (argv.dryRun) {
		const outputFormatter = buildOutputFormatter(command.flags, command.cliConfig, defaultIOFormat)
		await writeOutput(outputFormatter(request), command.flags.output)
		return
	}

	if (argv.authorize) {
		if (request.hostingType === 'lambda') {
			if (request.lambdaArn) {
				await addSchemaPermission(request.lambdaArn, argv.principal, argv.statement)
			}
			if (request.lambdaArnAP) {
				await addSchemaPermission(request.lambdaArnAP, argv.principal, argv.statement)
			}
			if (request.lambdaArnCN) {
				await addSchemaPermission(request.lambdaArnCN, argv.principal, argv.statement)
			}
			if (request.lambdaArnEU) {
				await addSchemaPermission(request.lambdaArnEU, argv.principal, argv.statement)
			}
		} else {
			return fatalError('Authorization is not applicable to WebHook schema connectors.')
		}
	}
	const { organizationId, ...data } = request
	const result = await command.client.schema.update(id, data, organizationId)
	if (result.status !== 'success') {
		return fatalError(`Error ${result.status} updating ${id}.`)
	}
	console.log(`Schema ${id} updated.`)
}

const cmd: CommandModule<object, CommandArgs> = { command, describe, builder, handler }
export default cmd