langfuse

1
import Fastify from "fastify";
2
import consumer from "./redis-consumer";
3

4
import { getLogger } from "./logger";
5
import redis from "@fastify/redis";
6
import { db } from "./database";
7

8
const fastify = Fastify({
9
  logger: getLogger("development") ?? true, // defaults to true if no entry matches in the map
10
});
11

12
fastify.register(redis, {
13
  host: process.env.REDIS_URL,
14
  port: process.env.REDIS_PORT ? parseInt(process.env.REDIS_PORT) : 6379,
15
  password: process.env.REDIS_AUTH,
16
});
17
fastify.register(consumer);
18

19
const start = async () => {
20
  try {
21
    // listen to 0.0.0.0 is required for docker
22
    await fastify.listen({
23
      port: process.env.PORT ? parseInt(process.env.PORT) : 3030,
24
      host: "0.0.0.0",
25
    });
26
  } catch (err) {
27
    fastify.log.error(err);
28
    process.exit(1);
29
  }
30
};
31

32
start();
33

34
fastify.get("/", async (request, reply) => {
35
  return { hello: "world" };
36
});
37