2
2
// Licensed under the MIT License.
3
3
4
4
import { access , constants } from 'fs' ;
5
- import { pathExists } from 'fs-extra' ;
6
5
import * as path from 'path' ;
7
6
import { AzureFunctionsRpcMessages as rpc } from '../../azure-functions-language-worker-protobuf/src/rpc' ;
8
- import { loadScriptFile } from '../loadScriptFile' ;
9
- import { ensureErrorType , isError } from '../utils/ensureErrorType' ;
10
- import { nonNullProp } from '../utils/nonNull' ;
7
+ import { isError } from '../utils/ensureErrorType' ;
11
8
import { WorkerChannel } from '../WorkerChannel' ;
12
9
import { EventHandler } from './EventHandler' ;
13
10
import LogCategory = rpc . RpcLog . RpcLogCategory ;
@@ -33,34 +30,9 @@ export class WorkerInitHandler extends EventHandler<'workerInitRequest', 'worker
33
30
} ) ;
34
31
35
32
logColdStartWarning ( channel ) ;
36
- const functionAppDirectory = nonNullProp ( msg , 'functionAppDirectory' ) ;
37
- await channel . updatePackageJson ( functionAppDirectory ) ;
38
-
39
- const entryPointFile = channel . packageJson . main ;
40
- if ( entryPointFile ) {
41
- channel . log ( {
42
- message : `Loading entry point "${ entryPointFile } "` ,
43
- level : LogLevel . Debug ,
44
- logCategory : LogCategory . System ,
45
- } ) ;
46
- try {
47
- const entryPointFullPath = path . join ( functionAppDirectory , entryPointFile ) ;
48
- if ( ! ( await pathExists ( entryPointFullPath ) ) ) {
49
- throw new Error ( `file does not exist` ) ;
50
- }
51
-
52
- await loadScriptFile ( entryPointFullPath , channel . packageJson ) ;
53
- channel . log ( {
54
- message : `Loaded entry point "${ entryPointFile } "` ,
55
- level : LogLevel . Debug ,
56
- logCategory : LogCategory . System ,
57
- } ) ;
58
- } catch ( err ) {
59
- const error = ensureErrorType ( err ) ;
60
- error . isAzureFunctionsInternalException = true ;
61
- error . message = `Worker was unable to load entry point "${ entryPointFile } ": ${ error . message } ` ;
62
- throw error ;
63
- }
33
+ const functionAppDirectory = msg . functionAppDirectory ;
34
+ if ( functionAppDirectory ) {
35
+ await channel . updatePackageJson ( functionAppDirectory ) ;
64
36
}
65
37
66
38
response . capabilities = {
0 commit comments