@ovotech/castle - npm Package Compare versions

Comparing version 0.4.7 to 0.5.0

dist/castle.d.ts

 /// <reference types="node" />
-import { AvroProducerRecord } from '@ovotech/avro-kafkajs';
+import { ProducerRecord } from 'kafkajs';
 import { CastleConsumerConfig, CastleConfig, Castle, CastleSender, CastleEachMessagePayload, CastleEachBatchPayload, FinalCastleConsumerConfig, OptionalCastleConsumerConfig } from './types';
-export declare const produce: <T>(config: Pick<AvroProducerRecord<T, string | Buffer | null | undefined>, "topic" | "acks" | "timeout" | "compression" | "schema" | "keySchema">) => CastleSender<T, string | Buffer | null | undefined>;
+export declare const produce: <T>(config: (Pick<ProducerRecord, "topic" | "acks" | "timeout" | "compression"> & {
+    schema: import("avsc/types").Schema;
+    keySchema?: string | import("avsc/types").Type | import("avsc/types").schema.NamedType | import("avsc/types").schema.RecordType | import("avsc/types").schema.EnumType | import("avsc/types").schema.MapType | import("avsc/types").schema.ArrayType | import("avsc/types").schema.FixedType | (import("avsc/types").schema.NamedType & import("avsc/types").schema.LogicalTypeExtension) | (import("avsc/types").schema.RecordType & import("avsc/types").schema.LogicalTypeExtension) | (import("avsc/types").schema.EnumType & import("avsc/types").schema.LogicalTypeExtension) | (import("avsc/types").schema.MapType & import("avsc/types").schema.LogicalTypeExtension) | (import("avsc/types").schema.ArrayType & import("avsc/types").schema.LogicalTypeExtension) | (import("avsc/types").schema.FixedType & import("avsc/types").schema.LogicalTypeExtension) | import("avsc/types").schema.DefinedType[] | undefined;
+}) | (Pick<ProducerRecord, "topic" | "acks" | "timeout" | "compression"> & {
+    subject: string;
+    keySubject?: string | undefined;
+})) => CastleSender<T, string | Buffer | null | undefined>;
 export declare const toFinalCastleConsumerConfig: (config: CastleConsumerConfig<any, any>) => FinalCastleConsumerConfig<any, any>;
@@ -6,0 +12,0 @@ export declare const optionalConsumers: (configs: OptionalCastleConsumerConfig<any, any>[]) => CastleConsumerConfig<any, any>[];

dist/castle.js

@@ -15,2 +15,3 @@ "use strict";
 exports.produce = (config) => {
+    config;
     return (producer, messages) => producer.send({ ...config, messages });
@@ -17,0 +18,0 @@ };

package.json

 {
   "name": "@ovotech/castle",
-  "version": "0.4.7",
+  "version": "0.5.0",
   "main": "dist/index.js",
@@ -11,20 +11,20 @@ "types": "dist/index.d.ts",
   "devDependencies": {
-    "@types/jest": "^25.1.4",
+    "@types/jest": "^25.2.3",
     "@types/lodash.chunk": "^4.2.6",
-    "@types/node": "^13.9.8",
+    "@types/node": "^14.0.5",
     "@types/pg": "^7.14.3",
-    "@types/uuid": "^7.0.2",
-    "@typescript-eslint/eslint-plugin": "^2.26.0",
-    "@typescript-eslint/parser": "^2.26.0",
-    "eslint": "^6.8.0",
-    "eslint-config-prettier": "^6.10.1",
-    "jest": "^25.2.6",
-    "pg": "^8.0.0",
-    "prettier": "^2.0.2",
+    "@types/uuid": "^8.0.0",
+    "@typescript-eslint/eslint-plugin": "^3.0.2",
+    "@typescript-eslint/parser": "^3.0.2",
+    "eslint": "^7.1.0",
+    "eslint-config-prettier": "^6.11.0",
+    "jest": "^26.0.1",
+    "pg": "^8.2.1",
+    "prettier": "^2.0.5",
     "slonik": "^22.4.4",
-    "ts-jest": "^25.3.0",
-    "ts-node": "^8.8.1",
-    "ts-retry-promise": "^0.3.1",
+    "ts-jest": "^26.0.0",
+    "ts-node": "^8.10.1",
+    "ts-retry-promise": "^0.4.0",
     "typescript": "^3.8.3",
-    "uuid": "^7.0.3",
+    "uuid": "^8.1.0",
     "winston": "^3.2.1"
@@ -44,7 +44,7 @@ },
   "dependencies": {
-    "@ovotech/avro-kafkajs": "^0.4.0",
+    "@ovotech/avro-kafkajs": "^0.5.0",
     "kafkajs": "^1.12.0",
     "lodash.chunk": "^4.2.0"
   },
-  "gitHead": "c7f755edaa2af5cb91138b0710bac52b23f506da"
+  "gitHead": "e838a3db1446110a4b67357f3600832118e4180c"
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

29027

increased by3.61%

Lines of code

329

increased by3.13%

Dependency changes

• + Added@ovotech/avro-kafkajs@0.5.5(transitive)

• + Addedlong@4.0.0(transitive)

• - Removed@ovotech/avro-kafkajs@0.4.0(transitive)

• Updated@ovotech/avro-kafkajs@^0.5.0