create backend-dev-utils with cli ipc client

Co-authored-by: Fredrik Adelöw <freben@gmail.com>
Signed-off-by: Patrik Oldsberg <poldsberg@gmail.com>
This commit is contained in:
Patrik Oldsberg
2023-01-30 15:54:30 +01:00
parent 1e84c75dc9
commit 9d9cdea117
8 changed files with 212 additions and 0 deletions
+5
View File
@@ -0,0 +1,5 @@
---
'@backstage/backend-dev-utils': minor
---
Introduced a new package for backend development utilities. Similar to how `@backstage/dev-utils` is used in the frontend.
+1
View File
@@ -0,0 +1 @@
module.exports = require('@backstage/cli/config/eslint-factory')(__dirname);
+5
View File
@@ -0,0 +1,5 @@
# backend-dev-utils
Welcome to the backend-dev-utils package!
_This package is experimental._
+36
View File
@@ -0,0 +1,36 @@
{
"name": "@backstage/backend-dev-utils",
"version": "0.0.0",
"main": "src/index.ts",
"types": "src/index.ts",
"license": "Apache-2.0",
"publishConfig": {
"access": "public",
"main": "dist/index.cjs.js",
"types": "dist/index.d.ts"
},
"backstage": {
"role": "node-library"
},
"homepage": "https://backstage.io",
"repository": {
"type": "git",
"url": "https://github.com/backstage/backstage",
"directory": "packages/backend-dev-utils"
},
"scripts": {
"start": "backstage-cli package start",
"build": "backstage-cli package build",
"lint": "backstage-cli package lint",
"test": "backstage-cli package test",
"clean": "backstage-cli package clean",
"prepack": "backstage-cli package prepack",
"postpack": "backstage-cli package postpack"
},
"devDependencies": {
"@backstage/cli": "workspace:^"
},
"files": [
"dist"
]
}
+21
View File
@@ -0,0 +1,21 @@
/*
* Copyright 2023 The Backstage Authors
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/**
* Local development helpers for backend.
*
* @packageDocumentation
*/
+120
View File
@@ -0,0 +1,120 @@
/*
* Copyright 2023 The Backstage Authors
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
type SendMessage = Exclude<typeof process.send, undefined>;
interface Request {
id: number;
method: string;
body: unknown;
type: string;
}
type Response =
| {
type: string;
id: number;
body: unknown;
}
| {
type: string;
id: number;
error: Error;
};
const requestType = '@backstage/cli/channel/request';
const responseType = '@backstage/cli/channel/response';
/**
* The client side of an IPC communication channel.
*
* @internal
*/
export class BackstageIpcClient {
#messageId = 0;
#sendMessage: SendMessage;
/**
* Creates a new client if we're in a child process with IPC and BACKSTAGE_CLI_CHANNEL is set.
*/
static create(): BackstageIpcClient | undefined {
const sendMessage = process.send?.bind(process);
return sendMessage && process.env.BACKSTAGE_CLI_CHANNEL
? new BackstageIpcClient(sendMessage)
: undefined;
}
constructor(sendMessage: SendMessage) {
this.#sendMessage = sendMessage;
}
/**
* Send a request to the parent process and wait for a response.
*/
async request<TRequestBody, TResponseBody>(
method: string,
body: TRequestBody,
): Promise<TResponseBody> {
return new Promise((resolve, reject) => {
const id = this.#messageId++;
const request: Request = {
type: requestType,
id,
method,
body,
};
this.#sendMessage(request, (e: Error) => {
if (e) {
reject(e);
return;
}
const timeout = setTimeout(() => {
reject(new Error('IPC request timed out'));
}, 1000);
timeout.unref();
const messageHandler = (response: Response) => {
if (response?.type !== responseType) {
return;
}
if (response.id !== id) {
return;
}
if ('error' in response) {
const error = new Error(response.error.message);
if (response.error.name) {
error.name = response.error.name;
}
reject(error);
} else {
resolve(response.body as TResponseBody);
}
clearTimeout(timeout);
process.removeListener('message', messageHandler);
};
process.addListener('message', messageHandler as () => void);
});
});
}
}
export const ipcClient = BackstageIpcClient.create();
@@ -0,0 +1,16 @@
/*
* Copyright 2023 The Backstage Authors
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
export {};
+8
View File
@@ -3519,6 +3519,14 @@ __metadata:
languageName: unknown
linkType: soft
"@backstage/backend-dev-utils@workspace:packages/backend-dev-utils":
version: 0.0.0-use.local
resolution: "@backstage/backend-dev-utils@workspace:packages/backend-dev-utils"
dependencies:
"@backstage/cli": "workspace:^"
languageName: unknown
linkType: soft
"@backstage/backend-plugin-api@workspace:^, @backstage/backend-plugin-api@workspace:packages/backend-plugin-api":
version: 0.0.0-use.local
resolution: "@backstage/backend-plugin-api@workspace:packages/backend-plugin-api"