micro_protocols

Micro connections

This is just a library to handle the connections for microservices

Installation

npm install micro_protocols

NATS Usage

import { NatsMethods, LogType } from "micro_protocols";

// you can inject any logger as longs as it meets the LogType
const logger = (logger: LogType, message: string, data?: unknown) => {
  if (logger === "info") {
    console.log("@@@info", message, data);
  }

  if (logger === "warn") {
    console.log("@@@warn", message, data);
  }

  if (logger === "error") {
    console.log("@@@error", message, data);
  }
};

export const BusMethods = NatsMethods(
  EnvVars.NATS_HOSTS,
  EnvVars.NATS_TOKEN,
  logger
);

interface IResponse {
  message: string;
}

interface IRequest {
  message: string;
}

const { publish, request } = await BusMethods;

publish("employee", {
  fname: "Oscar",
  lname: "Lopez"
});

const result = await request<IRequest, IResponse>("hello", {
  message: "Hello there"
});

Contributing

Pull requests are welcome. For major changes, please open an issue first to discuss what you would like to change.

License

MIT