-
Notifications
You must be signed in to change notification settings - Fork 6
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: Maxime Dufour <[email protected]>
- Loading branch information
1 parent
925c8e7
commit 917c55b
Showing
10 changed files
with
713 additions
and
48 deletions.
There are no files selected for viewing
Large diffs are not rendered by default.
Oops, something went wrong.
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,313 @@ | ||
| import * as vscode from 'vscode'; | ||
| import { getConfigurationParameter, OSC_COST_PARAMETER } from "../configuration/utils"; | ||
| import { pathExists } from "../config_file/utils"; | ||
| import { ACCESSKEY_FOLDER_NAME } from "../flat/folders/simple/node.folder.accesskey"; | ||
| import { APIACCESSRULES_FOLDER_NAME } from "../flat/folders/simple/node.folder.apiaccessrule"; | ||
| import { CA_FOLDER_NAME } from "../flat/folders/simple/node.folder.ca"; | ||
| import { CLIENTGATEWAYS_FOLDER_NAME } from "../flat/folders/simple/node.folder.clientgateway"; | ||
| import { DHCPOPTIONS_FOLDER_NAME } from "../flat/folders/simple/node.folder.dhcpoption"; | ||
| import { DIRECTLINKS_FOLDER_NAME } from "../flat/folders/simple/node.folder.directlink"; | ||
| import { DIRECTLINKINTERFACES_FOLDER_NAME } from "../flat/folders/simple/node.folder.directlinkinterface"; | ||
| import { IMAGES_FOLDER_NAME } from "../flat/folders/simple/node.folder.image"; | ||
| import { KEYPAIRS_FOLDER_NAME } from "../flat/folders/simple/node.folder.keypair"; | ||
| import { LOADBALANCER_FOLDER_NAME } from "../flat/folders/simple/node.folder.loadbalancer"; | ||
| import { NATSERVICES_FOLDER_NAME } from "../flat/folders/simple/node.folder.natservice"; | ||
| import { NETACCESSPOINTS_FOLDER_NAME } from "../flat/folders/simple/node.folder.netaccesspoint"; | ||
| import { NETPEERINGS_FOLDER_NAME } from "../flat/folders/simple/node.folder.netpeering"; | ||
| import { SNAPSHOTS_FOLDER_NAME } from "../flat/folders/simple/node.folder.snapshot"; | ||
| import { SUBNETS_FOLDER_NAME } from "../flat/folders/simple/node.folder.subnet"; | ||
| import { VPNCONNECTIONS_FOLDER_NAME } from "../flat/folders/simple/node.folder.vpnconnection"; | ||
| import { FLEXIBLEGPUS_FOLDER_NAME } from "../flat/folders/specific/node.folder.flexiblegpu"; | ||
| import { INTERNETSERVICES_FOLDER_NAME } from "../flat/folders/specific/node.folder.internetservice"; | ||
| import { NET_FOLDER_NAME } from "../flat/folders/specific/node.folder.net"; | ||
| import { NICS_FOLDER_NAME } from "../flat/folders/specific/node.folder.nic"; | ||
| import { PUBLICIP_FOLDER_NAME } from "../flat/folders/specific/node.folder.publicip"; | ||
| import { ROUTETABLES_FOLDER_NAME } from "../flat/folders/specific/node.folder.routetable"; | ||
| import { SECURITYGROUPS_FOLDER_NAME } from "../flat/folders/specific/node.folder.securitygroup"; | ||
| import { VIRTUALGATEWAYS_FOLDER_NAME } from "../flat/folders/specific/node.folder.virtualgateway"; | ||
| import { VM_FOLDER_NAME } from "../flat/folders/specific/node.folder.vm"; | ||
| import { VOLUME_FOLDER_NAME } from "../flat/folders/specific/node.folder.volume"; | ||
| import { Profile, ResourceNodeType } from "../flat/node"; | ||
| import { OutputChannel } from "../logs/output_channel"; | ||
| import { shell } from "./shell"; | ||
|
|
||
| export type ResourceCost = number; | ||
| export type ResourcesTypeCost = { globalPrice: number, values: Map<string, ResourceCost> }; | ||
|
|
||
| const DEFAULT_OPTIONS_OSC_COST = new Map<string, string>([ | ||
| ['v0.1.0', '--format json'], | ||
| ['v0.2.0', '--format json --skip-resource Oos'], | ||
| ]); | ||
|
|
||
| export class AccountCost { | ||
| accountCost: number; | ||
| region: string; | ||
| resourcesCost: Map<string, ResourcesTypeCost>; | ||
|
|
||
| constructor() { | ||
| this.resourcesCost = new Map(); | ||
| this.accountCost = 0; | ||
| this.region = ""; | ||
| } | ||
|
|
||
| getResourceType(resourceType: string): ResourcesTypeCost | undefined { | ||
| return this.resourcesCost.get(resourceType); | ||
| } | ||
|
|
||
| setResourceType(resourceType: string, value: ResourcesTypeCost) { | ||
| this.resourcesCost.set(resourceType, value); | ||
| } | ||
|
|
||
| getResourceTypeCost(folderName: string): string | undefined { | ||
| const resourceType = folderNameToOscCostResourceType(folderName); | ||
| if (typeof resourceType === 'undefined') { | ||
| return undefined; | ||
| } | ||
| const resourceTypeCost = this.getResourceType(resourceType); | ||
| if (typeof resourceTypeCost === 'undefined') { | ||
| return undefined; | ||
| } | ||
| return formatPrice(resourceTypeCost.globalPrice, getCurrency(this.region)); | ||
| } | ||
|
|
||
| getResourceIdCost(resourceNodeType: ResourceNodeType, resourceId: string): string | undefined { | ||
| const resourceType = resourceNodeTypeToOscCostResourceType(resourceNodeType); | ||
| if (typeof resourceType === 'undefined') { | ||
| return undefined; | ||
| } | ||
|
|
||
| const resourceTypeCost = this.getResourceType(resourceType); | ||
| if (typeof resourceTypeCost === 'undefined') { | ||
| return undefined; | ||
| } | ||
|
|
||
| const resourceCost = resourceTypeCost.values.get(resourceId); | ||
| if (typeof resourceCost === 'undefined') { | ||
| return undefined; | ||
| } | ||
|
|
||
| return formatPrice(resourceCost, getCurrency(this.region)); | ||
| } | ||
|
|
||
| getAccountCost(): string { | ||
| return formatPrice(this.accountCost, getCurrency(this.region)); | ||
| } | ||
|
|
||
|
|
||
| } | ||
|
|
||
| function formatPrice(price: number, currency: string): string { | ||
| return "~" + price.toFixed(2) + currency; | ||
| } | ||
|
|
||
| export function getCurrency(region: string): string { | ||
| switch (region) { | ||
| case "eu-west-2": | ||
| case "cloudgouv-eu-west-1": | ||
| return "€"; | ||
| case "ap-northeast-1": | ||
| return "¥"; | ||
| case "us-east-2": | ||
| case "us-west-1": | ||
| return "$"; | ||
| default: | ||
| return "€"; | ||
| } | ||
| } | ||
|
|
||
| function folderNameToOscCostResourceType(folderName: string): string | undefined { | ||
| switch (folderName) { | ||
| case VM_FOLDER_NAME: | ||
| return "Vm"; | ||
| case VOLUME_FOLDER_NAME: | ||
| return "Volume"; | ||
| case PUBLICIP_FOLDER_NAME: | ||
| return "PublicIp"; | ||
| case SNAPSHOTS_FOLDER_NAME: | ||
| return "Snapshot"; | ||
| case LOADBALANCER_FOLDER_NAME: | ||
| return "LoadBalancer"; | ||
| case FLEXIBLEGPUS_FOLDER_NAME: | ||
| return "FlexibleGpu"; | ||
| case VPNCONNECTIONS_FOLDER_NAME: | ||
| return "FlexibleGpu"; | ||
| case NATSERVICES_FOLDER_NAME: | ||
| return "NatServices"; | ||
| case ACCESSKEY_FOLDER_NAME: | ||
| case CLIENTGATEWAYS_FOLDER_NAME: | ||
| case IMAGES_FOLDER_NAME: | ||
| case INTERNETSERVICES_FOLDER_NAME: | ||
| case KEYPAIRS_FOLDER_NAME: | ||
| case NET_FOLDER_NAME: | ||
| case NICS_FOLDER_NAME: | ||
| case ROUTETABLES_FOLDER_NAME: | ||
| case SECURITYGROUPS_FOLDER_NAME: | ||
| case SUBNETS_FOLDER_NAME: | ||
| case VIRTUALGATEWAYS_FOLDER_NAME: | ||
| case DHCPOPTIONS_FOLDER_NAME: | ||
| case DIRECTLINKS_FOLDER_NAME: | ||
| case DIRECTLINKINTERFACES_FOLDER_NAME: | ||
| case NETPEERINGS_FOLDER_NAME: | ||
| case APIACCESSRULES_FOLDER_NAME: | ||
| case NETACCESSPOINTS_FOLDER_NAME: | ||
| case CA_FOLDER_NAME: | ||
| return undefined; | ||
| default: | ||
| OutputChannel.getInstance().appendLine(`The folder '${folderName}' is not handle for osc-cost conversion. Report it to the developpers`); | ||
| return undefined; | ||
| } | ||
| } | ||
|
|
||
| function resourceNodeTypeToOscCostResourceType(resourceNodeType: ResourceNodeType): string | undefined { | ||
| switch (resourceNodeType) { | ||
| case 'vms': | ||
| return "Vm"; | ||
| case 'volumes': | ||
| return "Volume"; | ||
| case 'eips': | ||
| return "PublicIp"; | ||
| case 'snapshots': | ||
| return "Snapshot"; | ||
| case 'loadbalancers': | ||
| return "LoadBalancer"; | ||
| case 'FlexibleGpu': | ||
| return "FlexibleGpu"; | ||
| case 'VpnConnection': | ||
| return "FlexibleGpu"; | ||
| case 'NatService': | ||
| return "NatServices"; | ||
| case 'AccessKey': | ||
| case 'ClientGateway': | ||
| case 'omis': | ||
| case 'InternetService': | ||
| case 'keypairs': | ||
| case 'vpc': | ||
| case 'Nic': | ||
| case 'routetables': | ||
| case 'securitygroups': | ||
| case 'Subnet': | ||
| case 'VirtualGateway': | ||
| case 'DhcpOption': | ||
| case 'DirectLink': | ||
| case 'DirectLinkInterface': | ||
| case 'NetPeering': | ||
| case 'ApiAccessRule': | ||
| case 'NetAccessPoint': | ||
| case 'Ca': | ||
| return undefined; | ||
| default: | ||
| OutputChannel.getInstance().appendLine(`The resourceNodeType '${resourceNodeType}' is not handle for osc-cost conversion. Report it to the developpers`); | ||
| return undefined; | ||
| } | ||
| } | ||
|
|
||
|
|
||
| function jsonToAccountCost(oscCostOutput: string): AccountCost | undefined { | ||
| const accountCost = new AccountCost(); | ||
| for (const jsonString of oscCostOutput.split('\n')) { | ||
| OutputChannel.getInstance().appendLine(`The jsonString is ${jsonString}`); | ||
| let json; | ||
| try { | ||
| json = JSON.parse(jsonString); | ||
| } catch { | ||
| OutputChannel.getInstance().appendLine(`Could not parse the json string ${jsonString}`); | ||
| return undefined; | ||
| } | ||
|
|
||
| if (typeof json === "undefined") { | ||
| OutputChannel.getInstance().appendLine(`Could not parse the json string ${jsonString}`); | ||
| return undefined; | ||
| } | ||
|
|
||
| //OutputChannel.getInstance().appendLine(`The json is ${json}`); | ||
|
|
||
|
|
||
| const resourceType = json.resource_type; | ||
| const resourceId = json.resource_id; | ||
| const pricePerMonth = json.price_per_month; | ||
| const region = json.region; | ||
|
|
||
| if (typeof resourceType !== 'string') { | ||
| OutputChannel.getInstance().appendLine(`Could not parse the resource type ${resourceType}`); | ||
| return undefined; | ||
| } | ||
|
|
||
| if (typeof resourceId !== 'string') { | ||
| OutputChannel.getInstance().appendLine(`Could not parse the resource id ${resourceId}`); | ||
| return undefined; | ||
| } | ||
|
|
||
| if (typeof region !== 'string') { | ||
| OutputChannel.getInstance().appendLine(`Could not parse the region ${region}`); | ||
| return undefined; | ||
| } | ||
|
|
||
| if (typeof pricePerMonth !== 'number') { | ||
| OutputChannel.getInstance().appendLine(`Could not parse the price per month ${pricePerMonth}`); | ||
| return undefined; | ||
| } | ||
|
|
||
|
|
||
| let resourceElement = accountCost.getResourceType(resourceType); | ||
| if (typeof resourceElement === 'undefined') { | ||
| resourceElement = { | ||
| globalPrice: 0, | ||
| values: new Map() | ||
| }; | ||
| } | ||
|
|
||
| resourceElement.values.set(resourceId, pricePerMonth); | ||
| resourceElement.globalPrice += pricePerMonth; | ||
| accountCost.accountCost += pricePerMonth; | ||
| accountCost.region = region; | ||
| accountCost.setResourceType(resourceType, resourceElement); | ||
| } | ||
|
|
||
|
|
||
| return accountCost; | ||
| } | ||
|
|
||
| export async function fetchAccountCost(profile: Profile): Promise<AccountCost | undefined> { | ||
|
|
||
| const oscCostPath = getOscCostPath(); | ||
|
|
||
| if (typeof oscCostPath === 'undefined') { | ||
| vscode.window.showErrorMessage("Cannot find osc-cost binary. Please install it."); | ||
| return Promise.resolve(undefined); | ||
| } | ||
|
|
||
| const res = await shell.exec(`osc-cost --format json --profile ${profile.name}`); | ||
| if (typeof res === "undefined") { | ||
| return res; | ||
| } | ||
|
|
||
| return Promise.resolve(jsonToAccountCost(res.stdout.trim())); | ||
| } | ||
|
|
||
|
|
||
| export function isOscCostEnabled(): boolean { | ||
| const isEnabled = getConfigurationParameter<boolean>(OSC_COST_PARAMETER + ".enabled"); | ||
| if (typeof isEnabled === 'undefined') { | ||
| return false; | ||
| } | ||
| OutputChannel.getInstance().appendLine("IsEnabled:" + isEnabled); | ||
| return isEnabled; | ||
| } | ||
|
|
||
| export function getOscCostPath(): string | undefined { | ||
| const userOscCostPath = getConfigurationParameter<string>(OSC_COST_PARAMETER + ".oscCostPath"); | ||
| if (typeof userOscCostPath === 'undefined' || userOscCostPath === "") { | ||
| const systemOscCostPath = shell.which("osc-cost"); | ||
| if (systemOscCostPath === null) { | ||
| return undefined; | ||
| } | ||
| OutputChannel.getInstance().appendLine(systemOscCostPath); | ||
| return systemOscCostPath; | ||
| } | ||
| // Check exist | ||
| if (! pathExists(userOscCostPath)) { | ||
| return undefined; | ||
| } | ||
| OutputChannel.getInstance().appendLine(userOscCostPath); | ||
| return userOscCostPath; | ||
| } |
Oops, something went wrong.