amqp-extension
Advanced tools
Comparing version 2.0.0 to 2.0.1
@@ -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 @@ |
@@ -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
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
14
54
659
39627
+ Addedsmob@1.5.0(transitive)
- Removedsmob@0.1.0(transitive)
Updated@types/amqplib@^0.10.3
Updatedsmob@^1.4.1
Updateduuid@^9.0.1