iframe-proxy | Sunbelt Computer Software

176 lines (149 loc) · 4.63 KB
import fs from 'fs';
import os from 'os';
import macaddress from "macaddress";
	CloudWatchLogsClient,
	CloudWatchLogsClientConfig,
	PutLogEventsCommand,
	PutLogEventsRequest
} from "@aws-sdk/client-cloudwatch-logs";
	LOG_AFTER_X_TIMES,
} from './constants';
import { readYML, isEmpty } from './utils/common';
import { generateSettings, PLUGIN_USER } from "./settings";
import { UserState } from './utils/user_utils';
import { getSystemConfig } from './utils/setup_utils';
let macAddress = "";
macaddress.one().then(mac => macAddress = mac);
let cloudWatchClient = <CloudWatchLogsClient>{};
const logErrorMsgTypes = {
	CRITICAL: "CRITICAL",
	ERROR: "ERROR",
	WARNING: "WARNING",
	INFO: "INFO",
	DEBUG: "DEBUG"
export class CodeSyncLogger {
	  DEBUG: for developer oriented messages, only usable for brief testing of new features and should be removed once new features are fully tested.
	  INFO: Informational messages, could be useful while debugging but can be ignore during normal execution.
	  WARNING: Mild errors that do not affect the user but should be fixed in some time frame
	  ERROR: Errors that cause a bad UX and should be fixed soon.
	  CRITICAL: Errors that are blocking for the normal operation of the plugin and should be fixed immediately.
	static async debug (msg: string, additionalMsg="", logStream?: string) {
		await putLogEvent(msg, logErrorMsgTypes.DEBUG, additionalMsg, logStream);
	static async info (msg: string, additionalMsg="", logStream?: string) {
		await putLogEvent(msg, logErrorMsgTypes.INFO, additionalMsg, logStream);
	static async warning (msg: string, additionalMsg="", logStream?: string) {
		await putLogEvent(msg, logErrorMsgTypes.WARNING, additionalMsg, logStream);
	static async error (msg: string, additionalMsg="", logStream?: string) {
		await putLogEvent(msg, logErrorMsgTypes.ERROR, additionalMsg, logStream);
	static async critical (msg: string, additionalMsg="", logStream?: string) {
		await putLogEvent(msg, logErrorMsgTypes.CRITICAL, additionalMsg, logStream);
const putLogEvent = async (msg: string, eventType: string, additionalMsg="", logStream?: string) => {
	let eventMsg = msg;
	if (additionalMsg) {
		eventMsg = `${msg}, ${additionalMsg}`;
	console.log(eventMsg);
	let email = "";
	let accessKey = "";
	let secretKey = "";
	const settings = generateSettings();
	if (!fs.existsSync(settings.USER_PATH)) return;
	const users = readYML(settings.USER_PATH);
	if (logStream) {
		const user = users[logStream];
		if (user && user.is_active) {
			email = logStream;
			accessKey = user.access_key;
			secretKey = user.secret_key;
		const userState = new UserState();
		const activeUser = userState.getUser();
		if (activeUser) {
			email = activeUser.email;
			accessKey = users[email].access_key;
			secretKey = users[email].secret_key;
	// Set default user for logging
	if (!(accessKey && secretKey && email)) {
		email = PLUGIN_USER.logStream;
		const pluginUser = users[email];
		if (!pluginUser) return;
		accessKey = pluginUser.access_key;
		secretKey = pluginUser.secret_key;
	if (isEmpty(cloudWatchClient)) {
		cloudWatchClient = __createClient(accessKey, secretKey);
		// Recreate client if accessKey is changed
		const credentials = await cloudWatchClient.config.credentials();
		if (credentials.accessKeyId !== accessKey) {
			cloudWatchClient = __createClient(accessKey, secretKey);
	const logGroupName = getSystemConfig().CW_LOGS_GROUP;
	const logStreamName = email;
	const CWEventMsg = {
		msg: eventMsg,
		type: eventType,
		source: VSCODE,
		version: VERSION,
		platform: os.platform(),
		mac_address: macAddress
	const logEvents = [ /* required */
			message: JSON.stringify(CWEventMsg), /* required */
			timestamp: new Date().getTime() /* required */
	const params = <PutLogEventsRequest>{
		logEvents,
		logGroupName,
		logStreamName
	const command = new PutLogEventsCommand(params);
		await cloudWatchClient.send(command);
	} catch (err) {
		// eslint-disable-next-line @typescript-eslint/ban-ts-comment
		// @ts-ignore
		console.log(`Failed to log: ${err}`);
export const logErrorMsg = (msg: string, errCount: number) => {
	if (errCount === 0 || errCount > LOG_AFTER_X_TIMES) {
		CodeSyncLogger.error(msg);
	if (errCount > LOG_AFTER_X_TIMES) {
		errCount = 0;
		return errCount;
	errCount += 1;
	return errCount;
const __createClient = (accessKeyId: string, secretAccessKey: string) => {
	const config: CloudWatchLogsClientConfig =
			region: getSystemConfig().AWS_REGION,
			credentials: {
				accessKeyId,
				secretAccessKey
	return new CloudWatchLogsClient(config);
Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

logger.ts

Latest commit

History

logger.ts

File metadata and controls
