Prefix proxy and updater logs

src/container-service.ts

@@ -2,6 +2,7 @@ import * as core from '@actions/core'
 import {Container} from 'dockerode'
 import {pack} from 'tar-stream'
 import {FileFetcherInput, FileUpdaterInput, ProxyConfig} from './file-types'
+import {outStream, errStream} from './utils'
 
 export const ContainerService = {
   async storeInput(
@@ -35,7 +36,11 @@ export const ContainerService = {
         stdout: true,
         stderr: true
       })
-      container.modem.demuxStream(stream, process.stdout, process.stderr)
+      container.modem.demuxStream(
+        stream,
+        outStream('updater'),
+        errStream('updater')
+      )
 
       await container.start()
       await container.wait()

src/proxy.ts

@@ -9,6 +9,7 @@ import {
 import {ContainerService} from './container-service'
 import {Credential, JobDetails} from './api-client'
 import {pki} from 'node-forge'
+import {outStream, errStream} from './utils'
 
 const KEY_SIZE = 2048
 const KEY_EXPIRY_YEARS = 2
@@ -77,7 +78,11 @@ export class ProxyBuilder {
       stdout: true,
       stderr: true
     })
-    container.modem.demuxStream(stream, process.stdout, process.stderr)
+    container.modem.demuxStream(
+      stream,
+      outStream('  proxy'),
+      errStream('  proxy')
+    )
 
     container.start()
     const url = `http://${config.proxy_auth.username}:${config.proxy_auth.password}@${name}:1080`

src/utils.ts

@@ -1,3 +1,4 @@
+import stream, {Writable} from 'stream'
 import {DependencyFile} from './file-types'
 
 const base64Decode = (str: string): string =>
@@ -10,3 +11,21 @@ export const base64DecodeDependencyFile = (
   fileCopy.content = base64Decode(fileCopy.content)
   return fileCopy
 }
+
+export const outStream = (prefix: string): Writable => {
+  return new stream.Writable({
+    write(chunk, _, next) {
+      process.stderr.write(`${prefix} | ${chunk.toString()}`)
+      next()
+    }
+  })
+}
+
+export const errStream = (prefix: string): Writable => {
+  return new stream.Writable({
+    write(chunk, _, next) {
+      process.stderr.write(`${prefix} | ${chunk.toString()}`)
+      next()
+    }
+  })
+}