Skip to content

Commit

Permalink
rpc npm: rename shutdown method to close and add muteStdErr opt…
Browse files Browse the repository at this point in the history
…ion to mute the stderr output (#5588)
  • Loading branch information
Simon-Laux committed May 17, 2024
1 parent 424ac60 commit d8e9827
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 5 deletions.
7 changes: 5 additions & 2 deletions deltachat-rpc-server/npm-package/index.d.ts
Original file line number Diff line number Diff line change
Expand Up @@ -20,17 +20,20 @@ export function getRPCServerPath(


export type DeltaChatOverJsonRpcServer = StdioDeltaChat & {
shutdown: () => Promise<void>;
readonly pathToServerBinary: string;
};

export interface StartOptions {
/** whether to disable outputting stderr to the parent process's stderr */
muteStdErr: boolean;
}

/**
*
* @param directory directory for accounts folder
* @param options
*/
export function startDeltaChat(directory: string, options?: Partial<SearchOptions> ): Promise<DeltaChatOverJsonRpcServer>
export function startDeltaChat(directory: string, options?: Partial<SearchOptions & StartOptions> ): Promise<DeltaChatOverJsonRpcServer>


export namespace FnTypes {
Expand Down
5 changes: 2 additions & 3 deletions deltachat-rpc-server/npm-package/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -130,6 +130,7 @@ export async function startDeltaChat(directory, options) {
RUST_LOG: process.env.RUST_LOG || "info",
DC_ACCOUNTS_PATH: directory,
},
stdio: ["pipe", "pipe", options.muteStdErr ? "ignore" : "inherit"],
});

server.on("error", (err) => {
Expand All @@ -144,13 +145,11 @@ export async function startDeltaChat(directory, options) {
throw new Error("Server quit");
});

server.stderr.pipe(process.stderr);

/** @type {import('./index').DeltaChatOverJsonRpcServer} */
//@ts-expect-error
const dc = new StdioDeltaChat(server.stdin, server.stdout, true);

dc.shutdown = async () => {
dc.close = () => {
shouldClose = true;
if (!server.kill()) {
console.log("server termination failed");
Expand Down

0 comments on commit d8e9827

Please sign in to comment.