Transport Writeable Stream sending log data

AlexanderKaran commented 3 years ago

Hi Everyone

Brand new to pino and been creating a transport to send data to Cloudwatch-logs. Doing this as the old package has not been updated for a while and is now legacy.

The code works fine, I guess I am asking if what I am doing is correct. I have created a transport that inside its writeable stream formats the data for Cloudwatch and then sends it on its way. Is there a better way?

Here is the code. createClient() just returns the AWS connection.

const stream = async (options) => {
    const client = createClient();
    let token = undefined;
    const myTransportStream = new Writable({
        async write(chunk, enc, cb) {
            const formatted = chunk
                .toString()
                .replace(/\r?\n|\r/g, "")
                .replace(/}/g, "},");
            const data = JSON.parse(
                `[${formatted.substring(0, formatted.length - 1)}]`,
            );
            const command = new PutLogEventsCommand({
                logGroupName: "api",
                logStreamName: `executive-${Config.env}-${Config.location}`,
                logEvents: data.map((log) => ({
                    message: log.msg,
                    timestamp: log.time,
                })),
                sequenceToken: token,
            });
            const response = await client.send(command);
            token = response.nextSequenceToken;
            cb();
        },
    });
    return myTransportStream;
};