JavaScript / Node.js

npm install @streamlogia/javascript-sdk
# or
yarn add @streamlogia/javascript-sdk
# or
pnpm add @streamlogia/javascript-sdk

import { LogIngestorClient } from "@streamlogia/javascript-sdk";

const client = new LogIngestorClient({
  apiKey:    process.env.LOGINGESTOR_API_KEY,
  projectId: process.env.LOGINGESTOR_PROJECT_ID,
  source:    "my-service",
});

await client.debug("Cache miss", { meta: { key: "user:abc" } });
await client.info("Order created", { meta: { orderId: "ord_99" }, tags: ["orders"] });
await client.warn("Disk usage above 80%");
await client.error("Payment failed", { meta: { code: "card_declined" }, tags: ["payments"] });

// Drain the internal queue immediately
await client.flush();

// Flush and stop the background timer — call before process exit
await client.close();

import express from "express";
import { LogIngestorClient } from "@streamlogia/javascript-sdk";
import winston from "winston";

const client = new LogIngestorClient({
  apiKey:    process.env.LOGINGESTOR_API_KEY,
  projectId: process.env.LOGINGESTOR_PROJECT_ID,
  source:    "my-service",
  console:   false, // winston handles console output
});

const logger = winston.createLogger({
  transports: [
    new winston.transports.Console(),
    client.createWinstonTransport(
      (await import("winston-transport")).default
    ),
  ],
});

process.on("SIGTERM", async () => { await client.close(); process.exit(0); });

const app = express();

// Mount once at the top — logs method, path, status, duration, IP, user agent
app.use(client.expressMiddleware());

app.post("/payments", async (req, res) => {
  try {
    const paymentId = `pay_${Math.random().toString(36).slice(2)}`;
    logger.info("payment processed", { paymentId });
    res.status(201).json({ paymentId });
  } catch (err) {
    logger.error("payment failed", { error: err.message });
    res.status(500).json({ error: "payment failed" });
  }
});

import winston from "winston";
import WinstonTransport from "winston-transport";
import { LogIngestorClient } from "@streamlogia/javascript-sdk";

const client = new LogIngestorClient({
  apiKey:    process.env.LOGINGESTOR_API_KEY,
  projectId: process.env.LOGINGESTOR_PROJECT_ID,
  source:    "my-service",
  console:   false,
});

const logger = winston.createLogger({
  transports: [
    new winston.transports.Console(),
    client.createWinstonTransport(WinstonTransport),
  ],
});

logger.error("Something went wrong", { orderId: "ord_99" });
// ↑ Automatically ingested as level=ERROR

import pino from "pino";
import { LogIngestorClient } from "@streamlogia/javascript-sdk";

const client = new LogIngestorClient({
  apiKey:    process.env.LOGINGESTOR_API_KEY,
  projectId: process.env.LOGINGESTOR_PROJECT_ID,
  source:    "my-service",
});

const logger = pino({ level: "debug" }, client.pinoDestination());

logger.info({ userId: "usr_abc" }, "User logged in");

const entry = {
  projectId: process.env.LOGINGESTOR_PROJECT_ID,
  level:     "INFO",
  message:   "Hello, Streamlogia!",
  source:    "my-service",
  timestamp: new Date().toISOString(),
  tags:      [],
  meta:      {},
};

fetch("https://api.streamlogia.com/v1/ingest", {
  method:  "POST",
  headers: {
    "Authorization": `Bearer ${process.env.LOGINGESTOR_API_KEY}`,
    "Content-Type":  "application/json",
  },
  body: JSON.stringify([entry]),
}).catch(() => {});