NodeJS Quickstart

import { LytixRequestWrapper } from "@lytix/client";

....
const app = express();
...

/**
 * Pass the logger in as the 4th argument here
 * @note The 4th argument is a boolean that can be set to true to collect metrics 
 * related to your server
 */
app.use((req, res, next) => {
  return LytixRequestWrapper(req, res, next, false);
});

import { LLogger } from "@lytix/client";


const logger = new LLogger("mainEntrypoint");

const main = async () => {
  logger.info(`Log from the main process`);
  await someBackgroundProcess();
};

/**
 * All we need to do is wrap our entrypoint and everything will
 * be accessable
 */
logger.runInAsyncContext(main);

...
app.get("/test", async (req, res) => {
  const logger = new LLogger('testRoute');
  /**
   * Lets pretend an error happend
   */
  try {
    logger.info("Some process is starting");
    throw new LError("An unexpeted error", { env: "prod" });
  } catch (err) {
    logger.error("crazy unexpeted error with this user: 123", err);
    res.sendStatus(500);
    return;
  }

  /**
   * Magically if we ended here, we'd reply with a 200
   */
  res.send("Hello World");
});
...

import { LErrorIncrement, LLogger } from "@lytix/client";

/**
 * An example background process
 */
const backgroundProcess = async () => {
  const logger = new LLogger("backgroundProcessExample", { userId: "123" });
  try {
    logger.info("Background process started for user!");
    throw new Error("Unexpected error!");
  } catch (err) {
    /**
     * Just increment to get the logs as well as the error
     */
    logger.error(`Unexpected error happened`, err);
    LErrorIncrement("Unexpected error");
  }
};

import { MetricCollector } from "@lytix/client";

await MetricCollector.captureModelIO({
  modelName: "testModelName",
  modelInput: "Some user input",
  modelOutput: "Some model output",
  metricMetadata: {
    /**
     * Optional extra data
     */
    env: "prod",
  }
);

import { MetricCollector } from "@lytix/client";

const response = await MetricCollector.captureModelTrace({
  modelName: "testModelName",
  modelInput: "Some user input",
  generateModelOutput: async () => {
    const openai = new OpenAI();
    ...
    /**
     * This callback is expecting the model output to be returned
     */
    return response;
  }
});

import { MetricCollector } from "@lytix/client";

await MetricCollector.increment("testMetic", 1, { env: "prod" });