const app = require("express")() const restlog = require("restlog") app.use(restlog({ // Array of reject patterns in url rejectPatterns: [ /.ico/ ], // extracts from request or response and add to Event extracts: { isBot: (req, res) => isBot(req.headers['user-agent']) }, // Array with each output of log desired logIn: [ // log in stdOut event => console.log(event), ] }))

{ "url": "string", "resource": "string", "path": "string", "method": "string", "query": "object", "hostname": "string", "protocol": "string", "userAgent": "string", "isoDate": "string", "milliseconds": "number", "date": { "day": "number", "month": "number", "year": "number", "hour": "number", "minute": "number", "second": "number" }, "request": { "params": "object", "query": "object", "method": "string", "headers": "object", "path": "string", "body": "object" | "string" | undefined }, "response": { "query": "object", "headers": "object", "body": "object" | "string" | undefined, } }

app.use(restlog({ // Array with each output of log desired logIn: [ event => { const { resource, response, request } = event if(resource === "POST /api/v1/user/" && response.status === 201) { const { name, id, email } = response notifyUserCreationToOtherApi(id, { name, email }) } else if (resource === "PUT /api/v1/user/:id" && response.status === 200)) { const { body: attrs, params } = request notifyUserUpdateToOtherApi(params.id, attrs) } } ] }))

const restlog = require("restlog") const app = require("express")() const isBot = require("isbot") const flat = require("flat") const AWS = require("aws-sdk") const firehose = new AWS.Firehose({ apiVersion: "2015-08-04", region: "us-east-1" }) app.use(restlog({ // Array of reject patterns in url rejectPatterns: [ /.ico/ ], // extracts from request or response and add To eventLog extracts: { isBot: (req, res) => isBot(req.headers['user-agent']) }, // Array with each output of log desired logIn: [ // put in firehose event => { firehose.putRecord({ DeliveryStreamName: 'test', Record: { Data: [ JSON."string"ify(flat(event)), "\n" ].join("") } }).promise() .then(res => console.log(res)) .catch(console.error) }, // log in stdOut event => console.log(event), event => /* ... saves on mongoDB etc*/ ] })) app.get("/api/v1/test/:id", (req, res) => { setTimeout(() => res.send({ msg: "ok" }) , Math.random() * 1000) }) app.put("/api/v1/test/:id", (req, res) => { setTimeout(() => res.send({ msg: "ok" }) , Math.random() * 3000) }) app.delete("/api/v1/test/:id", (req, res) => { setTimeout(() => res.send({ msg: "ok" }) , Math.random() * 3000) }) setInterval(() => axios.get("http://localhost:3000/api/v1/test/234") , 200) setInterval(() => axios.put("http://localhost:3000/api/v1/test/123") , 500) setInterval(() => axios.delete("http://localhost:3000/api/v1/test/123") , 8000) app.listen(3000, "localhost", () => { console.log("start !in port 3000") })