node-core 🧬
Core libraries for Node.js backend services.
See docs for further instructions on how to use.
Overview
HTTP Client
The library provides methods to implement the client side of HTTP protocols. Public methods available are:
buildClient()
, which returns a Client instance and should be called before any of the following methods with parameters:
sendGet()
;sendPost()
;sendPut()
;sendPutBinary()
;sendDelete()
;sendPatch()
.
All send methods accept a type parameter and the following arguments:
-
client
, the return value of buildClient()
;
-
path
;
-
options
– (optional). Possible values are:
headers
;query
, query string params to be embedded in the request URL;timeout
, the timeout after which a request will time out, in milliseconds;throwOnError
;`reqContext
;safeParseJson
, used when the response content-type is application/json
. If true
, the response body will be parsed as JSON and a ResponseError
will be thrown in case of syntax errors. If false
, errors are not handled;blobResponseBody
, used when the response body should be returned as Blob;requestLabel
, this string will be returned together with any thrown or returned Error to provide additional context about what request was being executed when the error has happened;disableKeepAlive
;`retryConfig
, defined by:
maxAttempts
, the maximum number of times a request should be retried;delayBetweenAttemptsInMsecs
;statusCodesToRetry
, the status codes that trigger a retry;retryOnTimeout
;
clientOptions
;responseSchema
, used both for inferring the response type of the call, and also (if validateResponse
is true
) for validating the response structure;validateResponse
;
The following options are applied by default:
validateResponse: true,
throwOnError: true,
timeout: 30000,
retryConfig: {
maxAttemps: 1,
delayBetweenAttemptsInMsecs: 0,
statusCodesToRetry: [],
retryOnTimeout: false,
}
Additionally, sendPost()
, sendPut()
, sendPutBinary()
, and sendPatch()
also accept a body
parameter.
The response of any send method will be resolved to always have result
set, but only have error
set in case something went wrong. See Either for more information.
Default Logging Configuration
The library provides methods to resolve the default logging configuration. Public methods available are:
-
resolveLoggerConfiguration()
, which accepts as parameter an appConfig
, defined by the logLevel
and the nodeEnv
. If the environment is production, the output will be logged in JSON format to be friendly with any data storage. Otherwise, the output will be logged with coloring and formatting to be visible for debugging purposes and help developers.
The method returns a logger configuration that should be used with pino
library as in the following example:
const loggerConfig = resolveLoggerConfiguration({
logLevel: 'warn',
nodeEnv: 'production',
})
const logger = pino(loggerConfig)
-
resolveMonorepoLoggerConfiguration()
, which accepts as parameter an appConfig
, defined by the logLevel
and the nodeEnv
. It mostly behaves the same as resolveLoggerConfiguration
, with the exception of execution in development environments
. Since monorepo services are usually ran concurrently, logs from stdout
aren't easily accessible. For this reason this logging configuration writes development logs into files.
The method returns a logger configuration that should be used with pino
library as in the following example:
const loggerConfig = resolveMonorepoLoggerConfiguration({
logLevel: 'warn',
nodeEnv: 'production',
append: false,
})
const logger = pino(loggerConfig)
ConfigScope
ConfigScope
is a class that provides a way to encapsulate a single config source (e. g. process.env
) and produce a set of values out of it, defining constraints and transformations for them.
Once the class is instantiated, you can leverage the following ConfigScope
methods:
Mandatory Configuration Parameters
getMandatory()
, returns the value of a mandatory configuration parameter. If the value is missing, an InternalError
is thrown. Parameters are:
param
, the configuration parameter name;
getMandatoryInteger()
, returns the value of a mandatory configuration parameter and validates that it is a number. If the value is missing or is not a number, an InternalError
is thrown. Parameters are:
param
, the configuration parameter name;
getMandatoryOneOf()
, returns the value a mandatory configuration parameter and validates that it is one of the supported values. If the value is missing or is not supported, an InternalError
is thrown. The method also serves as a type guard, narrowing the type of the passed value down to one of the supported options. Parameters are:
param
, the configuration parameter name;supportedValues
;
getMandatoryValidatedInteger()
, similar to getMandatoryInteger()
, but also takes a validator
in input and will throw an InternalError
if the number is not valid. See Validators and Transformers for more information. Parameters are:
param
, the configuration parameter name;validator
;
getMandatoryTransformed()
, calls getMandatory()
and returns the result of the transformer
function applied to the configuration parameter value. See Validators and Transformers for more information. Parameters are:
param
, the configuration parameter name;transformer
.
Optional Configuration Parameters
getOptionalNullable()
, returns the value of an optional configuration parameter. If the value is missing, it is set to the provided default value.Parameters are:
param
, the configuration parameter name;defaultValue
, which can be nullable;
getOptional()
, similar to getOptionalNullable()
, but defaultValue
cannot be nullable. The return value is always a string;getOptionalIntegerNullable()
, returns the value of an optional configuration parameter and validates that it is a number. If the value is missing, it is set to the provided default value. If it is not a number, an InternalError
is thrown. Parameters are:
param
, the configuration parameter name;defaultValue
, which can be nullable;
getOptionalInteger
, similar to getOptionalIntegerNullable()
, but defaultValue
cannot be nullable. The return value is always a number;getOptionalValidated()
, similar to getOptional()
, but also takes a validator
in input and will throw an InternalError
if the value is not valid. See Validators and Transformers for more information. Parameters are:
param
, the configuration parameter name;validator
;
getOptionalValidatedInteger()
, similar to getOptionalValidated()
, but expects and returns number
instead. See Validators and Transformers for more information. Parameters are:
param
, the configuration parameter name;validator
;
getOptionalTransformed()
, similar to getOptional()
, but also takes a transformer
in input and the result of the transformer
function applied to the configuration parameter value. See Validators and Transformers for more information. Parameters are:
param
, the configuration parameter name;defaultValue
,transformer
;
getOptionalBoolean()
, returns the value of an optional configuration parameter and validates that it is a boolean. It the value is missing, it is assigned the defaultValue
. If it is not a boolean, an InternalError
is thrown. Parameters are:
param
, the configuration parameter name;defaultValue
.
getOptionalOneOf()
, returns the value of an optional configuration parameter, if the value is missing, it falls back to the specified default value, and validates that it is one of the supported values. If the value is not supported, an InternalError
is thrown. Parameters are:
param
, the configuration parameter name;defaultValue
supportedValues
;
Environment Configuration Parameter
isProduction()
, returns true if the environment is production;isDevelopment()
, returns true if the environment is not production;isTest()
, returns true if the environment is test.
Validators and Transformers
Ad-hoc validators and transformers can be built leveraging the EnvValueValidator
and the EnvValueTransformer
types exposed by the library. Alternatively, the following validators and transformers are already provided out of the box:
Validators
createRangeValidator()
, which accepts greaterOrEqualThan
and lessOrEqualThan
and validates that a numeric value ranges between those numbers.
Transformers
ensureClosingSlashTransformer()
, which accepts a value
as parameter, that can be a string or nullable, and adds a closing slash if it is missing and the value is defined.
Error Handling
The library provides classes and methods for error handling.
Global Error Handler
Public methods to leverage a global error handler are provided to be used when the process is run outside of the context of the request (e. g. in a queue where no one would catch an error if thrown):
resolveGlobalErrorLogObject()
, which accepts err
and optionally correlationID
as parameters and converts the plain error into a serializable object. If the error is not a built-in Error
type and doesn't have any message, a fixed string is returned instead;executeAndHandleGlobalErrors()
, which accepts the operation
parameter and will return the result of executing such operation. If an error is thrown during the execution of the operation, resolveGlobalErrorLogObject()
is called to log the error and the process is terminated;executeAsyncAndHandleGlobalErrors()
, which accepts operation
and optionally stopOnError
as parameters and will return the result of executing such operation asynchronously. If an error is thrown during the execution of the operation, resolveGlobalErrorLogObject()
is called to log the error and the process is terminated only if stopOnError
is true
. stopOnError
defaults to true
if not provided.
Errors
The library exposes classes for the following errors:
InternalError
, which issues a 500
status code and is not exposed in the global error handler. It expects the following parameters:
message
;errorCode
;details
– (optional).
PublicNonRecoverableError
, which issues the HTTP status code provided and signals that the user did something wrong, hence the error is returned to the consumer of the API. It expects the following parameters:
message
;errorCode
;details
– (optional);httpStatusCode
– (optional). Defaults to 500
;
Either
The library provides the type Either
for error handling in the functional paradigm. The two possible values are:
result
is defined, error
is undefined;error
is defined, result
is undefined.
It's up to the caller of the function to handle the received error or throw an error.
Read this article for more information on how Either
works and its benefits.
Additionally, DefiniteEither
is also provided. It is a variation of the aforementioned Either
, which may or may not have error
set, but always has result
.
waitAndRetry
There is helper function available for writing event-driven assertions in automated tests, which rely on something eventually happening:
import { waitAndRetry } from '@lokalise/node-core'
const result = await waitAndRetry(
() => {
return someEventEmitter.emittedEvents.length > 0
},
20,
30,
)
expect(result).toBe(false)
expect(someEventEmitter.emittedEvents.length).toBe(1)