Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

amqp-extension

Package Overview
Dependencies
Maintainers
1
Versions
26
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

amqp-extension - npm Package Compare versions

Comparing version 2.0.0 to 2.0.1

tsconfig.eslint.json

7

CHANGELOG.md

@@ -0,1 +1,8 @@

## [2.0.1](https://github.com/Tada5hi/amqp-extension/compare/v2.0.0...v2.0.1) (2023-11-05)
### Bug Fixes
* bump (dev-) dependencies & resolved linting issues ([25b74ce](https://github.com/Tada5hi/amqp-extension/commit/25b74ceb3b83581b1f67bc7b09c6c68029e87252))
# [2.0.0](https://github.com/Tada5hi/amqp-extension/compare/v1.1.1...v2.0.0) (2023-02-03)

@@ -2,0 +9,0 @@

2

commitlint.config.js

@@ -9,3 +9,3 @@ /*

module.exports = {
extends: ['@commitlint/config-angular'],
extends: ['@tada5hi/commitlint-config'],
};

@@ -1,4 +0,4 @@

import { Config, ConfigInput } from './type';
import type { Config, ConfigInput } from './type';
export declare function setConfig(key: string | ConfigInput, value?: ConfigInput): Config;
export declare function hasConfig(key?: string): boolean;
export declare function getConfig(key?: string | ConfigInput): Config;

@@ -1,4 +0,4 @@

import { Options } from 'amqplib';
import { ExchangeOptions } from '../exchange';
import { ConsumeOptions, PublishOptions } from '../type';
import type { Options } from 'amqplib';
import type { ExchangeOptions } from '../exchange';
import type { ConsumeOptions, PublishOptions } from '../type';
export type Config = {

@@ -5,0 +5,0 @@ alias: string;

@@ -1,3 +0,3 @@

import { Config, ConfigInput } from './type';
import type { Config, ConfigInput } from './type';
export declare function getConfigKey(alias?: string): string;
export declare function extendConfig(input: ConfigInput): Config;

@@ -1,3 +0,3 @@

import RabbitMQ, { Connection, Options } from 'amqplib';
import { ConfigInput } from '../config';
import type { Connection, Options } from 'amqplib';
import type { ConfigInput } from '../config';
export declare function clearConnections(): Promise<void>;

@@ -7,2 +7,2 @@ export declare function hasConnection(key?: string): boolean;

export declare function useConnection(key: string | ConfigInput): Promise<Connection>;
export declare function createConnection(config: Options.Connect | string): Promise<RabbitMQ.Connection>;
export declare function createConnection(config: Options.Connect | string): Promise<Connection>;

@@ -1,3 +0,3 @@

import { ConsumeOptions } from '../type';
import { ConsumeHandlers } from './type';
import type { ConsumeOptions } from '../type';
import type { ConsumeHandlers } from './type';
export declare function consume(options: ConsumeOptions, handlers: ConsumeHandlers): Promise<void>;
import type { Channel, ConsumeMessage } from 'amqplib';
import { ConsumeHandlerAnyKey } from './static';
import type { ConsumeHandlerAnyKey } from './static';
export { ConsumeMessage, };

@@ -4,0 +4,0 @@ export type ConsumeMessageHandler = (message: ConsumeMessage, channel: Channel) => Promise<void>;

@@ -1,3 +0,3 @@

import { Options } from 'amqplib';
import { ConsumeOptions } from '../type';
import type { Options } from 'amqplib';
import type { ConsumeOptions } from '../type';
export declare function buildDriverConsumeOptions(options: ConsumeOptions): Options.Consume;

@@ -11,2 +11,2 @@ "use strict";

ExchangeType["MATCH"] = "match";
})(ExchangeType = exports.ExchangeType || (exports.ExchangeType = {}));
})(ExchangeType || (exports.ExchangeType = ExchangeType = {}));

@@ -1,3 +0,3 @@

import { Options } from 'amqplib';
import { ExchangeType } from './constants';
import type { Options } from 'amqplib';
import type { ExchangeType } from './constants';
export type ExchangeOptions = {

@@ -4,0 +4,0 @@ name: string;

@@ -1,5 +0,5 @@

import { Options } from 'amqplib';
import type { Options } from 'amqplib';
import { ExchangeType } from './constants';
import { ExchangeOptions } from './type';
import type { ExchangeOptions } from './type';
export declare function isDefaultExchange(exchange?: `${ExchangeType}`): boolean;
export declare function buildDriverExchangeOptions(options: ExchangeOptions): Options.AssertExchange;

@@ -1,2 +0,2 @@

import { PublishOptionsExtended } from './type';
import type { PublishOptionsExtended } from './type';
export declare function publish(options: PublishOptionsExtended): Promise<void>;

@@ -1,2 +0,2 @@

import { PublishOptions } from '../type';
import type { PublishOptions } from '../type';
export type PublishOptionsExtended<T = any> = {

@@ -3,0 +3,0 @@ /**

@@ -1,3 +0,3 @@

import { Options } from 'amqplib';
import { PublishOptionsExtended } from './type';
import type { Options } from 'amqplib';
import type { PublishOptionsExtended } from './type';
export declare function buildDriverPublishOptions(options: PublishOptionsExtended): Options.Publish;

@@ -1,4 +0,4 @@

import { Options } from 'amqplib';
import { ConfigInput } from './config';
import { ExchangeOptions } from './exchange';
import type { Options } from 'amqplib';
import type { ConfigInput } from './config';
import type { ExchangeOptions } from './exchange';
type CommonOptions = {

@@ -5,0 +5,0 @@ /**

{
"name": "amqp-extension",
"version": "2.0.0",
"version": "2.0.1",
"description": "An amqp extension with functions and utility functions to consume and publish queue messages.",

@@ -38,35 +38,23 @@ "main": "./dist/index.js",

"dependencies": {
"@types/amqplib": "^0.10.1",
"@types/amqplib": "^0.10.3",
"amqplib": "^0.10.3",
"smob": "^0.1.0",
"uuid": "^9.0.0"
"smob": "^1.4.1",
"uuid": "^9.0.1"
},
"devDependencies": {
"@commitlint/cli": "^17.4.2",
"@commitlint/config-angular": "^17.4.2",
"@commitlint/config-conventional": "^17.4.2",
"@commitlint/cz-commitlint": "^17.4.2",
"@semantic-release/changelog": "^6.0.1",
"@semantic-release/git": "^10.0.1",
"@semantic-release/release-notes-generator": "^10.0.3",
"@tada5hi/eslint-config-typescript": "^1.1.1",
"@tada5hi/tsconfig": "^0.4.0",
"@types/jest": "^27.4.1",
"@types/node": "^18.11.9",
"@tada5hi/commitlint-config": "^1.1.3",
"@tada5hi/eslint-config-typescript": "^1.2.6",
"@tada5hi/semantic-release": "^0.3.0",
"@tada5hi/tsconfig": "^0.5.0",
"@types/jest": "^29.5.7",
"@types/node": "^20.8.10",
"@types/uuid": "^8.3.4",
"codecov": "^3.8.3",
"coveralls": "^3.1.0",
"cross-env": "^7.0.3",
"eslint": "^8.33.0",
"husky": "^8.0.2",
"jest": "^27.5.1",
"semantic-release": "^19.0.5",
"ts-jest": "^27.1.4",
"typescript": "^4.9.5"
},
"config": {
"commitizen": {
"path": "@commitlint/cz-commitlint"
}
"eslint": "^8.53.0",
"husky": "^8.0.3",
"jest": "^29.7.0",
"semantic-release": "^22.0.7",
"ts-jest": "^29.1.1",
"typescript": "^5.2.2"
}
}
module.exports = {
"plugins": [
"@semantic-release/commit-analyzer",
"@semantic-release/release-notes-generator",
"@semantic-release/changelog",
"@semantic-release/npm",
"@semantic-release/git",
"@semantic-release/github"
]
"extends": "@tada5hi/semantic-release"
}

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc