aboutsummaryrefslogtreecommitdiffhomepage
path: root/packages/peertube-runner/shared
diff options
context:
space:
mode:
authorChocobozzz <me@florianbigard.com>2023-05-02 13:51:06 +0200
committerChocobozzz <chocobozzz@cpy.re>2023-05-09 08:57:34 +0200
commit3a0c2a77b1a6626699514ddaf8135f4397175443 (patch)
tree60bec7ef8e9cdc008b0a4a56aa403617d036bfab /packages/peertube-runner/shared
parent9a3db678f56eda37d222cf2d2232ae0ef5d533d2 (diff)
downloadPeerTube-3a0c2a77b1a6626699514ddaf8135f4397175443.tar.gz
PeerTube-3a0c2a77b1a6626699514ddaf8135f4397175443.tar.zst
PeerTube-3a0c2a77b1a6626699514ddaf8135f4397175443.zip
Enable external plugins to test the PR
Diffstat (limited to 'packages/peertube-runner/shared')
-rw-r--r--packages/peertube-runner/shared/http.ts2
-rw-r--r--packages/peertube-runner/shared/ipc/ipc-server.ts4
2 files changed, 3 insertions, 3 deletions
diff --git a/packages/peertube-runner/shared/http.ts b/packages/peertube-runner/shared/http.ts
index d3fff70d1..df64dc168 100644
--- a/packages/peertube-runner/shared/http.ts
+++ b/packages/peertube-runner/shared/http.ts
@@ -47,7 +47,7 @@ export function downloadFile (options: {
47 47
48 request.on('error', err => { 48 request.on('error', err => {
49 remove(destination) 49 remove(destination)
50 .catch(err => console.error(err)) 50 .catch(err => logger.error(err))
51 51
52 return rej(err) 52 return rej(err)
53 }) 53 })
diff --git a/packages/peertube-runner/shared/ipc/ipc-server.ts b/packages/peertube-runner/shared/ipc/ipc-server.ts
index bc340198b..922dc93e5 100644
--- a/packages/peertube-runner/shared/ipc/ipc-server.ts
+++ b/packages/peertube-runner/shared/ipc/ipc-server.ts
@@ -27,7 +27,7 @@ export class IPCServer {
27 27
28 this.sendReponse(res, { success: true, data }) 28 this.sendReponse(res, { success: true, data })
29 } catch (err) { 29 } catch (err) {
30 console.error('Cannot execute RPC call', err) 30 logger.error('Cannot execute RPC call', err)
31 this.sendReponse(res, { success: false, error: err.message }) 31 this.sendReponse(res, { success: false, error: err.message })
32 } 32 }
33 }) 33 })
@@ -56,6 +56,6 @@ export class IPCServer {
56 body: IPCReponse<T> 56 body: IPCReponse<T>
57 ) { 57 ) {
58 response(body) 58 response(body)
59 .catch(err => console.error('Cannot send response after IPC request', err)) 59 .catch(err => logger.error('Cannot send response after IPC request', err))
60 } 60 }
61} 61}