@uoj-lk/utils-node


> Comprehensive shared utilities for University of Jaffna microservices

Provides standardized, production-ready implementations for message brokering, logging, caching, error handling, validation, and response formatting across all microservices.

✨ Features

- 🚀 Message Broker - RabbitMQ integration with automatic reconnection
- 📝 Logger - Winston-based logging with daily rotation and multiple transports
- ⚡ Cache - Redis operations with TTL support and automatic serialization
- ❌ Error Handling - Standardized error creation with Boom integration
- ✅ Validation - Joi-based schema validation with detailed error messages
- 📬 Response Handler - Consistent API response formatting
- 🔧 Helpers - Utility functions for common operations
- 📘 TypeScript Support - Full type definitions included
- 🔄 ES Modules & CommonJS - Supports both module systems

📦 Installation

``bash
npm install @uoj-lk/utils-node
`

🚀 Quick Start

`javascript
import {
logger,
cache,
messageBroker,
response,
validation,
} from "@uoj-lk/utils-node";

// Initialize services
await cache.initCache({ host: "localhost", port: 6379 });
await messageBroker.connectToMessageBroker("events-queue");

// Use logger
logger.info("Service initialized");

// Use cache
await cache.set("user:123", { name: "John" }, 3600);
const user = await cache.get("user:123");

// Send message
await messageBroker.sendToQueue("events-queue", {
event: "user.created",
data: user,
});
`

📚 Module System Support

$3

`javascript
// Import entire package
import utils from "@uoj-lk/utils-node";

// Import specific modules
import { logger, cache, messageBroker } from "@uoj-lk/utils-node";

// Import from submodules directly
import { initLogger } from "@uoj-lk/utils-node/logger";
import { connectToMessageBroker } from "@uoj-lk/utils-node/messageBroker";
`

$3

`javascript
// Import entire package
const utils = require("@uoj-lk/utils-node");

// Import specific modules
const { logger, cache } = require("@uoj-lk/utils-node");

// Import from submodules
const { initLogger } = require("@uoj-lk/utils-node/logger");
`

📖 Usage

$3

`javascript
import { messageBroker } from "@uoj-lk/utils-node";

// Connect to a queue
await messageBroker.connectToMessageBroker("QUEUE_NAME");

// Send message to queue
await messageBroker.sendToQueue("QUEUE_NAME", { data: "value" });

// Consume messages
await messageBroker.consumeFromMessageBroker(async (message) => {
console.log("Received:", message);
}, "QUEUE_NAME");
`

$3

`javascript
import { logger } from "@uoj-lk/utils-node";

logger.info("Message", { data: "value" });
logger.error("Error message", error);
logger.debug("Debug info");
`

$3

`javascript
import { cache } from "@uoj-lk/utils-node";

await cache.initCache();

// Set with 1 hour TTL
await cache.set("key", { data: "value" }, 3600);

// Get value
const value = await cache.get("key");

// Delete key
await cache.del("key");
`

$3

`javascript
import { error } from "@uoj-lk/utils-node";

const customError = error.createError("Not found", 404);

const boomError = error.ErrorHelper({
message: "Validation failed",
statusCode: 400,
data: { field: "email" },
});
`

$3

`javascript
import { validation } from "@uoj-lk/utils-node";
import Joi from "joi";

const schema = Joi.object({
email: Joi.string().email().required(),
name: Joi.string().required(),
});

// Returns validated and sanitized data directly
const validatedData = await validation.validate(schema, data);
`

$3

`javascript
import { response } from "@uoj-lk/utils-node";

const handler = response.createResponseHandler();

// Send success response
handler.resolve(res, { message: "Success" }, 200);

// Send error response
handler.reject(error, res);
`

$3

`javascript
import { helpers } from "@uoj-lk/utils-node";

// Convert string to camelCase
helpers.toCamel("hello_world"); // 'helloWorld'

// Pad number with zeros
helpers.padWithZero(5, 3); // '005'

// CSV to JSON
const json = helpers.csvToJson("name,age\nJohn,30");

// Async forEach
await helpers.asyncForEach(array, async (item) => {
console.log(item);
});
`

Environment Variables

The package uses these environment variables:

$3

- RABBIT_MQ_HOST - RabbitMQ host (default: localhost)
- RABBIT_MQ_PORT - RabbitMQ port (default: 5672)
- RABBIT_MQ_USER - RabbitMQ username (default: guest)
- RABBIT_MQ_PASS - RabbitMQ password (default: guest)
- RABBIT_MQ_VHOST - RabbitMQ virtual host (default: /)

$3

- LOG_LEVEL - Log level (default: info)
- LOG_DIR - Log directory (default: ./logs)
- NODE_ENV - Environment (default: development)

$3

- REDIS_HOST - Redis host (default: localhost)
- REDIS_PORT - Redis port (default: 6379)
- REDIS_DB - Redis database (default: 0)
- REDIS_PASS - Redis password

API Documentation

See individual module documentation in src/` directory.

Contributing

Please follow the existing code style and add tests for new features.

License

MIT