-
Notifications
You must be signed in to change notification settings - Fork 14
/
Copy pathremove.ts
118 lines (100 loc) · 3.22 KB
/
remove.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
import ora from 'ora';
import inquirer from 'inquirer';
import Command from '../../base.js';
import { Flags } from '@oclif/core';
import { createDebugLogger } from '../../utils/output.js';
import IGetDatabasesResponse from '../../types/get-dbs-response.js';
import { ux } from '@oclif/core';
export default class Remove extends Command {
static description = 'remove a database';
static PATH = 'v1/databases/{database-id}';
static aliases = ['db:rm'];
static flags = {
...Command.flags,
name: Flags.string({
char: 'n',
description: 'name of your database',
}),
yes: Flags.boolean({
char: 'y',
description: 'say yes to continue prompt',
}),
};
async run(): Promise<void> {
this.spinner = ora();
const { flags } = await this.parse(Remove);
const debug = createDebugLogger(flags.debug);
await this.setGotConfig(flags);
const account = await this.getCurrentAccount();
((account && account.region === 'germany') || flags.region === 'germany') &&
this.error('We do not support germany any more.');
const hostname = flags.name || (await this.promptHostname());
const sayYes = flags.yes;
try {
const database = await this.getDatabaseByHostname(hostname);
if (database === undefined) {
this.log(`Database ${hostname} not found`);
return;
}
const tableData = [
{
type: database.type,
hostname: database.hostname,
status: database.status.toString(),
},
];
const tableConfig = {
Hostname: { get: (row: any) => row.hostname },
Type: { get: (row: any) => row.type },
status: { get: (row: any) => row.status },
};
ux.table(tableData, tableConfig, {
title: 'Database Specification',
});
if (!sayYes && (await this.promptContinue()) === 'n') {
this.log('Operation cancelled');
return;
}
const databaseID = database._id;
await this.got.delete(Remove.PATH.replace('{database-id}', databaseID));
this.log(`Database ${hostname} removed.`);
} catch (error) {
debug(error.message);
if (error.response && error.response.body) {
debug(JSON.stringify(error.response.body));
}
this.error(`Could not remove the database. Please try again.`);
}
}
async promptHostname() {
const { name } = (await inquirer.prompt({
name: 'name',
type: 'input',
message: 'Enter name:',
validate: (input) => input.length > 2,
})) as { name: string };
return name;
}
async promptContinue() {
const { yes } = (await inquirer.prompt({
name: 'yes',
type: 'input',
message: 'continue? (y/n):',
validate: (input) => input === 'y' || input === 'n',
})) as { yes: string };
return yes;
}
async getDatabaseByHostname(hostname: string) {
const { databases } = await this.got(
'v1/databases'
).json<IGetDatabasesResponse>();
if (!databases.length) {
this.error(`Not found any database.
Please open up https://console.liara.ir/databases and create the database, first.`);
}
const database = databases.find(
(database) => database.hostname === hostname
);
return database;
}
}