@@ -4,33 +4,103 @@ import os from 'os';
44import fs from 'fs' ;
55import path from 'path' ;
66import process from 'process' ;
7- import childProcess from 'child_process' ;
87import esbuild from 'esbuild' ;
98import packageJSON from '../package.json' assert { type : 'json ' } ;
109import { fileURLToPath } from 'url' ;
10+ import { $ } from "execa" ;
11+ import tscOutputParser from '@aivenio/tsc-output-parser' ;
1112
1213const platform = os . platform ( ) ;
1314const __filename = fileURLToPath ( import . meta. url ) ;
1415const __dirname = path . dirname ( __filename ) ;
1516
17+ const pemReadFilePlugin = {
18+ name : 'base64-plugin' ,
19+ setup ( build ) {
20+ build . onLoad ( { filter : / \. j s $ / } , async ( args ) => {
21+ let contents = fs . readFileSync ( args . path , 'utf8' ) ;
22+
23+ const regex = / a w a i t \s + f s \. p r o m i s e s \. r e a d F i l e \( \s * p a t h \. r e s o l v e \( _ _ d i r n a m e , \s * [ ' " ` ] ( .* \. p e m ) [ ' " ` ] \s * \) \) / g;
24+ let match ;
25+
26+ while ( ( match = regex . exec ( contents ) ) !== null ) {
27+ const pemFilePath = path . resolve ( path . dirname ( args . path ) , match [ 1 ] ) ;
28+ const pemContents = fs . readFileSync ( pemFilePath , 'utf8' ) ;
29+ const base64Contents = Buffer . from ( pemContents ) . toString ( 'base64' ) ;
30+ contents = contents . replace ( match [ 0 ] , `await Promise.resolve(Buffer.from("${ base64Contents } ) ;
31+ }
32+
33+ return {
34+ contents,
35+ loader : 'js' ,
36+ } ;
37+ } ) ;
38+ } ,
39+ } ;
40+
41+ const tscDiagnosticToEsbuild = async (
42+ diagnostic ,
43+ ) => {
44+ const lineText =
45+ await $ `sed -n ${ diagnostic . value . cursor . value . line } ${ diagnostic . value . path . value } ;
46+
47+ const [ firstLine , rest ] = diagnostic . value . message . value . split ( "\n" , 2 ) ;
48+
49+ return {
50+ location : {
51+ column : diagnostic . value . cursor . value . col - 1 ,
52+ line : diagnostic . value . cursor . value . line ,
53+ file : diagnostic . value . path . value ,
54+ lineText : lineText . stdout ,
55+ } ,
56+ notes : rest && rest . trim ( ) . length > 0 ? [ { text : rest } ] : [ ] ,
57+ text : `${ firstLine } ${ diagnostic . value . tsError . value . errorString } ,
58+ } ;
59+ } ;
60+
61+ const checkTypesPlugin = ( ) => {
62+ return {
63+ name : 'check-types' ,
64+ setup ( build ) {
65+ build . onEnd ( async ( result ) => {
66+ if ( result . errors . length > 0 ) {
67+ return ;
68+ }
69+
70+ const buildArgs = [ '--noEmit' , '-p' , './tsconfig.build.json' , '--pretty' , 'false' ] ;
71+ try {
72+ await $ ( 'tsc' , buildArgs ) ;
73+ } catch ( err ) {
74+ const tscOutput = tscOutputParser . parse ( err . stdout ) ;
75+ const messages = await Promise . all ( tscOutput . map ( output => tscDiagnosticToEsbuild ( output ) ) ) ;
76+ const formatted = await esbuild . formatMessages (
77+ messages ,
78+ {
79+ kind : 'error' ,
80+ color : true ,
81+ terminalWidth : 100 ,
82+ }
83+ ) ;
84+ console . log ( formatted . join ( '\n' ) ) ;
85+ process . exit ( 1 ) ;
86+ }
87+ } ) ;
88+ } ,
89+ } ;
90+ } ;
91+
1692async function main ( argv = process . argv ) {
1793 argv = argv . slice ( 2 ) ;
1894 const projectRoot = path . join ( __dirname , '..' ) ;
19- const buildPath = path . join ( projectRoot , 'build ' ) ;
95+ const srcPath = path . join ( projectRoot , 'src ' ) ;
2096 const distPath = path . join ( projectRoot , 'dist' ) ;
2197 const gitPath = process . env . GIT_DIR ?? path . join ( projectRoot , '.git' ) ;
2298 await fs . promises . rm ( distPath , {
2399 recursive : true ,
24100 force : true ,
25101 } ) ;
26- const buildArgs = [ '-p' , './tsconfig.build.json' , ...argv ] ;
27- console . error ( 'Running tsc:' ) ;
28- console . error ( [ 'tsc' , ...buildArgs ] . join ( ' ' ) ) ;
29- childProcess . execFileSync ( 'tsc' , buildArgs , {
30- stdio : [ 'inherit' , 'inherit' , 'inherit' ] ,
31- windowsHide : true ,
32- encoding : 'utf-8' ,
33- shell : platform === 'win32' ? true : false ,
102+ await fs . promises . mkdir ( distPath , {
103+ recursive : true ,
34104 } ) ;
35105 // This collects the build metadata and adds it to the build folder so that dynamic imports to it will resolve correctly.
36106 let gitHead = process . env . COMMIT_HASH ;
@@ -52,17 +122,17 @@ async function main(argv = process.argv) {
52122 console . error ( 'Writing build metadata (build.json):' ) ;
53123 console . error ( buildJSON ) ;
54124 await fs . promises . writeFile (
55- path . join ( buildPath , 'build.json' ) ,
125+ path . join ( distPath , 'build.json' ) ,
56126 JSON . stringify ( buildJSON , null , 2 ) ,
57127 ) ;
58128 // This specifies import paths that is left as an external require
59129 // This is kept to packages that have a native binding
60130 const externalDependencies = Object . keys ( packageJSON . nativeDependencies ?? { } ) ;
61131 const esbuildOptions = {
62132 entryPoints : [
63- path . join ( buildPath , ' index.js' ) ,
133+ 'src/ index.ts'
64134 ] ,
65- sourceRoot : buildPath ,
135+ sourceRoot : srcPath ,
66136 bundle : true ,
67137 platform : 'node' ,
68138 format : 'cjs' ,
@@ -74,7 +144,8 @@ async function main(argv = process.argv) {
74144 minify : true ,
75145 keepNames : true ,
76146 outfile : path . join ( distPath , 'index.cjs' ) ,
77- metafile : true
147+ metafile : true ,
148+ plugins : [ checkTypesPlugin ( ) , pemReadFilePlugin ] ,
78149 } ;
79150 console . error ( 'Running esbuild:' ) ;
80151 console . error ( esbuildOptions ) ;
0 commit comments