Skip to content

Commit 9305a88

Browse files
committed
chore - deno 2
1 parent b32cd3e commit 9305a88

9 files changed

Lines changed: 33 additions & 20 deletions

File tree

src/core/schema/types-from-schema.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,9 +27,9 @@ export function typeNameFromSchemaName(schemaName: string) {
2727
}
2828

2929
function fmtSource(source: string) {
30-
return Deno.run({
31-
cmd: [Deno.execPath(), "fmt", source],
32-
}).status();
30+
return new Deno.Command(Deno.execPath(), {
31+
args: ["fmt", source],
32+
}).output();
3333
}
3434

3535
export const generatedSrcMessage =

src/core/schema/validate-document.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,7 @@ export async function validateDocumentFromSource(
9797
}
9898
});
9999
} catch (e) {
100+
if (!(e instanceof Error)) throw e;
100101
if (e.name === "NoExprTag") {
101102
const err = e as NoExprTag;
102103
error(tidyverseFormatError(err.niceError), { colorize: false });

src/core/temp.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ export function initSessionTempDir() {
2727
ensureDirSync(tmpEnv);
2828
}
2929
} catch (err) {
30+
if (!(err instanceof Error)) throw err;
3031
if (err.message) {
3132
debug("Error attempting to create TMPDIR: " + err.message);
3233
}

src/core/watch.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -99,6 +99,7 @@ export function watchForFileChanges(
9999
}
100100
}
101101
} catch (err) {
102+
if (!(err instanceof Error)) throw err;
102103
error(
103104
"Unexpected error while scanning for file changes: " + err.message,
104105
);

src/core/yaml.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ export function readYaml(file: string) {
6161
JSON.stringify(result);
6262
return result;
6363
} catch (e) {
64+
if (!(e instanceof Error)) throw e;
6465
throw new Error(
6566
`Circular structures not allowed.\nFile ${file}\n${
6667
e.message.split("\n").slice(1).join("\n")
@@ -296,6 +297,9 @@ function parseWithNiceErrors(
296297
try {
297298
return parse(content, options || { json: true, schema: QuartoJSONSchema });
298299
} catch (e) {
300+
if (!(e instanceof Error)) {
301+
throw e;
302+
}
299303
throw improveYamlParseErrorMessage(e);
300304
}
301305
}

src/deno_ral/fs.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,9 @@ export function safeMoveSync(
8484
): void {
8585
try {
8686
Deno.renameSync(src, dest);
87-
} catch (err) {
87+
// deno-lint-ignore no-explicit-any
88+
} catch (err: any) {
89+
// code isn't part of the generic error object, which is why we use `: any`
8890
if (err.code !== "EXDEV") {
8991
throw err;
9092
}

src/execute/engine.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -216,6 +216,7 @@ export async function fileExecutionEngine(
216216
flags,
217217
);
218218
} catch (error) {
219+
if (!(error instanceof Error)) throw error;
219220
if (error.name === "YAMLError") {
220221
error.message = `${file}:\n${error.message}`;
221222
}

src/execute/jupyter/jupyter-kernel.ts

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -72,12 +72,12 @@ export async function executeKernelKeepalive(
7272
options: JupyterExecuteOptions,
7373
): Promise<void> {
7474
// if we are in debug mode then tail follow the log file
75-
let serverLogProcess: Deno.Process | undefined;
75+
let serverLogProcess: Deno.ChildProcess | undefined;
7676
if (options.format.execute[kExecuteDebug]) {
7777
if (!isWindows) {
78-
serverLogProcess = Deno.run({
79-
cmd: ["tail", "-F", "-n", "0", kernelLogFile()],
80-
});
78+
serverLogProcess = new Deno.Command("tail", {
79+
args: ["-F", "-n", "0", kernelLogFile()],
80+
}).spawn();
8181
}
8282
}
8383

@@ -156,10 +156,7 @@ export async function executeKernelKeepalive(
156156
} finally {
157157
conn.close();
158158

159-
if (serverLogProcess) {
160-
// deno-lint-ignore no-explicit-any
161-
(serverLogProcess as any).kill("SIGKILL");
162-
}
159+
serverLogProcess?.kill("SIGKILL");
163160
}
164161
}
165162

@@ -191,10 +188,12 @@ async function execJupyter(
191188
kernelspec: JupyterKernelspec,
192189
): Promise<ProcessResult> {
193190
try {
191+
const cmd = await pythonExec(kernelspec);
194192
const result = await execProcess(
195193
{
196-
cmd: [
197-
...(await pythonExec(kernelspec)),
194+
cmd: cmd[0],
195+
args: [
196+
...cmd.slice(1),
198197
resourcePath("jupyter/jupyter.py"),
199198
],
200199
env: {
@@ -218,6 +217,7 @@ async function execJupyter(
218217
}
219218
return result;
220219
} catch (e) {
220+
if (!(e instanceof Error)) throw e;
221221
if (e?.message) {
222222
info("");
223223
error(e.message);
@@ -358,6 +358,7 @@ function readKernelTransportFile(
358358
throw new Error("Invalid file format");
359359
}
360360
} catch (e) {
361+
if (!(e instanceof Error)) throw e;
361362
error(
362363
"Error reading kernel transport file: " + e.toString() +
363364
"(removing file)",
@@ -454,6 +455,7 @@ async function connectToKernel(
454455
try {
455456
return await denoConnectToKernel(kernelTransport);
456457
} catch (e) {
458+
if (!(e instanceof Error)) throw e;
457459
// remove the transport file
458460
safeRemoveSync(transportFile);
459461
error("Error connecting to Jupyter kernel: " + e.toString());

src/execute/ojs/extract-resources.ts

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -335,9 +335,8 @@ async function resolveImport(
335335
projectRoot = projectRoot ?? dirname(referent);
336336

337337
const deno = Deno.execPath();
338-
const p = Deno.run({
339-
cmd: [
340-
deno,
338+
const p = new Deno.Command(deno, {
339+
args: [
341340
"check",
342341
file,
343342
"-c",
@@ -346,8 +345,9 @@ async function resolveImport(
346345
],
347346
stderr: "piped",
348347
});
349-
const [status, stderr] = await Promise.all([p.status(), p.stderrOutput()]);
350-
if (!status.success) {
348+
const output = await p.output();
349+
const stderr = output.stderr;
350+
if (!output.success) {
351351
error("Compilation of typescript dependencies in ojs cell failed.");
352352

353353
let errStr = new TextDecoder().decode(stderr);
@@ -547,7 +547,7 @@ export async function extractResourceDescriptionsFromOJSChunk(
547547
const [thisResolvedImportPath, importResource]: [
548548
string,
549549
ResourceDescription,
550-
] = imports.entries().next().value;
550+
] = imports.entries().next().value!;
551551
imports.delete(thisResolvedImportPath);
552552
if (handled.has(thisResolvedImportPath)) {
553553
continue;
@@ -580,6 +580,7 @@ export async function extractResourceDescriptionsFromOJSChunk(
580580
try {
581581
safeRemoveSync(res.filename);
582582
} catch (e) {
583+
if (!(e instanceof Error)) throw e;
583584
if (e.name !== "NotFound") {
584585
throw e;
585586
}

0 commit comments

Comments
 (0)