@wundergraph/cosmo-connect - npm Package Compare versions

Comparing version 0.68.0 to 0.69.0

dist/node/v1/node_pb.d.ts

@@ -427,5 +427,5 @@ import type { BinaryReadOptions, FieldList, JsonReadOptions, JsonValue, PartialMessage, PlainMessage } from "@bufbuild/protobuf";
     /**
-     * @generated from field: wg.cosmo.node.v1.DataSourceCustom_Events custom_events = 13;
+     * @generated from field: wg.cosmo.node.v1.DataSourceCustomEvents custom_events = 13;
      */
-    customEvents?: DataSourceCustom_Events;
+    customEvents?: DataSourceCustomEvents;
     /**
@@ -752,5 +752,5 @@ * @generated from field: repeated wg.cosmo.node.v1.EntityInterfaceConfiguration entity_interfaces = 14;
 /**
- * @generated from message wg.cosmo.node.v1.StreamConfiguration
+ * @generated from message wg.cosmo.node.v1.NatsStreamConfiguration
  */
-export declare class StreamConfiguration extends Message<StreamConfiguration> {
+export declare class NatsStreamConfiguration extends Message<NatsStreamConfiguration> {
     /**
@@ -764,64 +764,106 @@ * @generated from field: string consumer_name = 1;
     streamName: string;
-    constructor(data?: PartialMessage<StreamConfiguration>);
+    constructor(data?: PartialMessage<NatsStreamConfiguration>);
     static readonly runtime: typeof proto3;
-    static readonly typeName = "wg.cosmo.node.v1.StreamConfiguration";
+    static readonly typeName = "wg.cosmo.node.v1.NatsStreamConfiguration";
     static readonly fields: FieldList;
-    static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): StreamConfiguration;
-    static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): StreamConfiguration;
-    static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): StreamConfiguration;
-    static equals(a: StreamConfiguration | PlainMessage<StreamConfiguration> | undefined, b: StreamConfiguration | PlainMessage<StreamConfiguration> | undefined): boolean;
+    static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): NatsStreamConfiguration;
+    static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): NatsStreamConfiguration;
+    static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): NatsStreamConfiguration;
+    static equals(a: NatsStreamConfiguration | PlainMessage<NatsStreamConfiguration> | undefined, b: NatsStreamConfiguration | PlainMessage<NatsStreamConfiguration> | undefined): boolean;
 }
 /**
- * @generated from message wg.cosmo.node.v1.EventConfiguration
+ * @generated from message wg.cosmo.node.v1.NatsEventConfiguration
  */
-export declare class EventConfiguration extends Message<EventConfiguration> {
+export declare class NatsEventConfiguration extends Message<NatsEventConfiguration> {
     /**
-     * @generated from field: wg.cosmo.node.v1.EventType type = 1;
+     * @generated from field: wg.cosmo.node.v1.EngineEventConfiguration engine_event_configuration = 1;
      */
-    type: EventType;
+    engineEventConfiguration?: EngineEventConfiguration;
     /**
-     * @generated from field: string type_name = 2;
+     * @generated from field: repeated string subjects = 2;
      */
-    typeName: string;
+    subjects: string[];
     /**
-     * @generated from field: string field_name = 3;
+     * @generated from field: wg.cosmo.node.v1.NatsStreamConfiguration stream_configuration = 3;
      */
-    fieldName: string;
+    streamConfiguration?: NatsStreamConfiguration;
+    constructor(data?: PartialMessage<NatsEventConfiguration>);
+    static readonly runtime: typeof proto3;
+    static readonly typeName = "wg.cosmo.node.v1.NatsEventConfiguration";
+    static readonly fields: FieldList;
+    static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): NatsEventConfiguration;
+    static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): NatsEventConfiguration;
+    static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): NatsEventConfiguration;
+    static equals(a: NatsEventConfiguration | PlainMessage<NatsEventConfiguration> | undefined, b: NatsEventConfiguration | PlainMessage<NatsEventConfiguration> | undefined): boolean;
+}
+/**
+ * @generated from message wg.cosmo.node.v1.KafkaEventConfiguration
+ */
+export declare class KafkaEventConfiguration extends Message<KafkaEventConfiguration> {
     /**
-     * @generated from field: repeated string subjects = 4;
+     * @generated from field: wg.cosmo.node.v1.EngineEventConfiguration engine_event_configuration = 1;
      */
-    subjects: string[];
+    engineEventConfiguration?: EngineEventConfiguration;
     /**
-     * @generated from field: string source_name = 5;
+     * @generated from field: repeated string topics = 2;
      */
-    sourceName: string;
+    topics: string[];
+    constructor(data?: PartialMessage<KafkaEventConfiguration>);
+    static readonly runtime: typeof proto3;
+    static readonly typeName = "wg.cosmo.node.v1.KafkaEventConfiguration";
+    static readonly fields: FieldList;
+    static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): KafkaEventConfiguration;
+    static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): KafkaEventConfiguration;
+    static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): KafkaEventConfiguration;
+    static equals(a: KafkaEventConfiguration | PlainMessage<KafkaEventConfiguration> | undefined, b: KafkaEventConfiguration | PlainMessage<KafkaEventConfiguration> | undefined): boolean;
+}
+/**
+ * @generated from message wg.cosmo.node.v1.EngineEventConfiguration
+ */
+export declare class EngineEventConfiguration extends Message<EngineEventConfiguration> {
     /**
-     * @generated from field: wg.cosmo.node.v1.StreamConfiguration stream_configuration = 6;
+     * @generated from field: string provider_id = 1;
      */
-    streamConfiguration?: StreamConfiguration;
-    constructor(data?: PartialMessage<EventConfiguration>);
+    providerId: string;
+    /**
+     * @generated from field: wg.cosmo.node.v1.EventType type = 2;
+     */
+    type: EventType;
+    /**
+     * @generated from field: string type_name = 3;
+     */
+    typeName: string;
+    /**
+     * @generated from field: string field_name = 4;
+     */
+    fieldName: string;
+    constructor(data?: PartialMessage<EngineEventConfiguration>);
     static readonly runtime: typeof proto3;
-    static readonly typeName = "wg.cosmo.node.v1.EventConfiguration";
+    static readonly typeName = "wg.cosmo.node.v1.EngineEventConfiguration";
     static readonly fields: FieldList;
-    static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): EventConfiguration;
-    static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): EventConfiguration;
-    static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): EventConfiguration;
-    static equals(a: EventConfiguration | PlainMessage<EventConfiguration> | undefined, b: EventConfiguration | PlainMessage<EventConfiguration> | undefined): boolean;
+    static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): EngineEventConfiguration;
+    static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): EngineEventConfiguration;
+    static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): EngineEventConfiguration;
+    static equals(a: EngineEventConfiguration | PlainMessage<EngineEventConfiguration> | undefined, b: EngineEventConfiguration | PlainMessage<EngineEventConfiguration> | undefined): boolean;
 }
 /**
- * @generated from message wg.cosmo.node.v1.DataSourceCustom_Events
+ * @generated from message wg.cosmo.node.v1.DataSourceCustomEvents
  */
-export declare class DataSourceCustom_Events extends Message<DataSourceCustom_Events> {
+export declare class DataSourceCustomEvents extends Message<DataSourceCustomEvents> {
     /**
-     * @generated from field: repeated wg.cosmo.node.v1.EventConfiguration events = 1;
+     * @generated from field: repeated wg.cosmo.node.v1.NatsEventConfiguration nats = 1;
      */
-    events: EventConfiguration[];
-    constructor(data?: PartialMessage<DataSourceCustom_Events>);
+    nats: NatsEventConfiguration[];
+    /**
+     * @generated from field: repeated wg.cosmo.node.v1.KafkaEventConfiguration kafka = 2;
+     */
+    kafka: KafkaEventConfiguration[];
+    constructor(data?: PartialMessage<DataSourceCustomEvents>);
     static readonly runtime: typeof proto3;
-    static readonly typeName = "wg.cosmo.node.v1.DataSourceCustom_Events";
+    static readonly typeName = "wg.cosmo.node.v1.DataSourceCustomEvents";
     static readonly fields: FieldList;
-    static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): DataSourceCustom_Events;
-    static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): DataSourceCustom_Events;
-    static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): DataSourceCustom_Events;
-    static equals(a: DataSourceCustom_Events | PlainMessage<DataSourceCustom_Events> | undefined, b: DataSourceCustom_Events | PlainMessage<DataSourceCustom_Events> | undefined): boolean;
+    static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): DataSourceCustomEvents;
+    static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): DataSourceCustomEvents;
+    static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): DataSourceCustomEvents;
+    static equals(a: DataSourceCustomEvents | PlainMessage<DataSourceCustomEvents> | undefined, b: DataSourceCustomEvents | PlainMessage<DataSourceCustomEvents> | undefined): boolean;
 }
@@ -828,0 +870,0 @@ /**

dist/node/v1/node_pb.js

@@ -628,3 +628,3 @@ // @generated by protoc-gen-es v1.4.1 with parameter "target=ts"
     /**
-     * @generated from field: wg.cosmo.node.v1.DataSourceCustom_Events custom_events = 13;
+     * @generated from field: wg.cosmo.node.v1.DataSourceCustomEvents custom_events = 13;
      */
@@ -659,3 +659,3 @@ customEvents;
         { no: 12, name: "requires", kind: "message", T: RequiredField, repeated: true },
-        { no: 13, name: "custom_events", kind: "message", T: DataSourceCustom_Events },
+        { no: 13, name: "custom_events", kind: "message", T: DataSourceCustomEvents },
         { no: 14, name: "entity_interfaces", kind: "message", T: EntityInterfaceConfiguration, repeated: true },
@@ -1148,5 +1148,5 @@ { no: 15, name: "interface_objects", kind: "message", T: EntityInterfaceConfiguration, repeated: true },
 /**
- * @generated from message wg.cosmo.node.v1.StreamConfiguration
+ * @generated from message wg.cosmo.node.v1.NatsStreamConfiguration
  */
-export class StreamConfiguration extends Message {
+export class NatsStreamConfiguration extends Message {
     /**
@@ -1165,3 +1165,3 @@ * @generated from field: string consumer_name = 1;
     static runtime = proto3;
-    static typeName = "wg.cosmo.node.v1.StreamConfiguration";
+    static typeName = "wg.cosmo.node.v1.NatsStreamConfiguration";
     static fields = proto3.util.newFieldList(() => [
@@ -1172,42 +1172,109 @@ { no: 1, name: "consumer_name", kind: "scalar", T: 9 /* ScalarType.STRING */ },
     static fromBinary(bytes, options) {
-        return new StreamConfiguration().fromBinary(bytes, options);
+        return new NatsStreamConfiguration().fromBinary(bytes, options);
     }
     static fromJson(jsonValue, options) {
-        return new StreamConfiguration().fromJson(jsonValue, options);
+        return new NatsStreamConfiguration().fromJson(jsonValue, options);
     }
     static fromJsonString(jsonString, options) {
-        return new StreamConfiguration().fromJsonString(jsonString, options);
+        return new NatsStreamConfiguration().fromJsonString(jsonString, options);
     }
     static equals(a, b) {
-        return proto3.util.equals(StreamConfiguration, a, b);
+        return proto3.util.equals(NatsStreamConfiguration, a, b);
     }
 }
 /**
- * @generated from message wg.cosmo.node.v1.EventConfiguration
+ * @generated from message wg.cosmo.node.v1.NatsEventConfiguration
  */
-export class EventConfiguration extends Message {
+export class NatsEventConfiguration extends Message {
     /**
-     * @generated from field: wg.cosmo.node.v1.EventType type = 1;
+     * @generated from field: wg.cosmo.node.v1.EngineEventConfiguration engine_event_configuration = 1;
      */
-    type = EventType.PUBLISH;
+    engineEventConfiguration;
     /**
-     * @generated from field: string type_name = 2;
+     * @generated from field: repeated string subjects = 2;
      */
-    typeName = "";
+    subjects = [];
     /**
-     * @generated from field: string field_name = 3;
+     * @generated from field: wg.cosmo.node.v1.NatsStreamConfiguration stream_configuration = 3;
      */
-    fieldName = "";
+    streamConfiguration;
+    constructor(data) {
+        super();
+        proto3.util.initPartial(data, this);
+    }
+    static runtime = proto3;
+    static typeName = "wg.cosmo.node.v1.NatsEventConfiguration";
+    static fields = proto3.util.newFieldList(() => [
+        { no: 1, name: "engine_event_configuration", kind: "message", T: EngineEventConfiguration },
+        { no: 2, name: "subjects", kind: "scalar", T: 9 /* ScalarType.STRING */, repeated: true },
+        { no: 3, name: "stream_configuration", kind: "message", T: NatsStreamConfiguration },
+    ]);
+    static fromBinary(bytes, options) {
+        return new NatsEventConfiguration().fromBinary(bytes, options);
+    }
+    static fromJson(jsonValue, options) {
+        return new NatsEventConfiguration().fromJson(jsonValue, options);
+    }
+    static fromJsonString(jsonString, options) {
+        return new NatsEventConfiguration().fromJsonString(jsonString, options);
+    }
+    static equals(a, b) {
+        return proto3.util.equals(NatsEventConfiguration, a, b);
+    }
+}
+/**
+ * @generated from message wg.cosmo.node.v1.KafkaEventConfiguration
+ */
+export class KafkaEventConfiguration extends Message {
     /**
-     * @generated from field: repeated string subjects = 4;
+     * @generated from field: wg.cosmo.node.v1.EngineEventConfiguration engine_event_configuration = 1;
      */
-    subjects = [];
+    engineEventConfiguration;
     /**
-     * @generated from field: string source_name = 5;
+     * @generated from field: repeated string topics = 2;
      */
-    sourceName = "";
+    topics = [];
+    constructor(data) {
+        super();
+        proto3.util.initPartial(data, this);
+    }
+    static runtime = proto3;
+    static typeName = "wg.cosmo.node.v1.KafkaEventConfiguration";
+    static fields = proto3.util.newFieldList(() => [
+        { no: 1, name: "engine_event_configuration", kind: "message", T: EngineEventConfiguration },
+        { no: 2, name: "topics", kind: "scalar", T: 9 /* ScalarType.STRING */, repeated: true },
+    ]);
+    static fromBinary(bytes, options) {
+        return new KafkaEventConfiguration().fromBinary(bytes, options);
+    }
+    static fromJson(jsonValue, options) {
+        return new KafkaEventConfiguration().fromJson(jsonValue, options);
+    }
+    static fromJsonString(jsonString, options) {
+        return new KafkaEventConfiguration().fromJsonString(jsonString, options);
+    }
+    static equals(a, b) {
+        return proto3.util.equals(KafkaEventConfiguration, a, b);
+    }
+}
+/**
+ * @generated from message wg.cosmo.node.v1.EngineEventConfiguration
+ */
+export class EngineEventConfiguration extends Message {
     /**
-     * @generated from field: wg.cosmo.node.v1.StreamConfiguration stream_configuration = 6;
+     * @generated from field: string provider_id = 1;
      */
-    streamConfiguration;
+    providerId = "";
+    /**
+     * @generated from field: wg.cosmo.node.v1.EventType type = 2;
+     */
+    type = EventType.PUBLISH;
+    /**
+     * @generated from field: string type_name = 3;
+     */
+    typeName = "";
+    /**
+     * @generated from field: string field_name = 4;
+     */
+    fieldName = "";
     constructor(data) {
@@ -1218,32 +1285,34 @@ super();
     static runtime = proto3;
-    static typeName = "wg.cosmo.node.v1.EventConfiguration";
+    static typeName = "wg.cosmo.node.v1.EngineEventConfiguration";
     static fields = proto3.util.newFieldList(() => [
-        { no: 1, name: "type", kind: "enum", T: proto3.getEnumType(EventType) },
-        { no: 2, name: "type_name", kind: "scalar", T: 9 /* ScalarType.STRING */ },
-        { no: 3, name: "field_name", kind: "scalar", T: 9 /* ScalarType.STRING */ },
-        { no: 4, name: "subjects", kind: "scalar", T: 9 /* ScalarType.STRING */, repeated: true },
-        { no: 5, name: "source_name", kind: "scalar", T: 9 /* ScalarType.STRING */ },
-        { no: 6, name: "stream_configuration", kind: "message", T: StreamConfiguration },
+        { no: 1, name: "provider_id", kind: "scalar", T: 9 /* ScalarType.STRING */ },
+        { no: 2, name: "type", kind: "enum", T: proto3.getEnumType(EventType) },
+        { no: 3, name: "type_name", kind: "scalar", T: 9 /* ScalarType.STRING */ },
+        { no: 4, name: "field_name", kind: "scalar", T: 9 /* ScalarType.STRING */ },
     ]);
     static fromBinary(bytes, options) {
-        return new EventConfiguration().fromBinary(bytes, options);
+        return new EngineEventConfiguration().fromBinary(bytes, options);
     }
     static fromJson(jsonValue, options) {
-        return new EventConfiguration().fromJson(jsonValue, options);
+        return new EngineEventConfiguration().fromJson(jsonValue, options);
     }
     static fromJsonString(jsonString, options) {
-        return new EventConfiguration().fromJsonString(jsonString, options);
+        return new EngineEventConfiguration().fromJsonString(jsonString, options);
     }
     static equals(a, b) {
-        return proto3.util.equals(EventConfiguration, a, b);
+        return proto3.util.equals(EngineEventConfiguration, a, b);
     }
 }
 /**
- * @generated from message wg.cosmo.node.v1.DataSourceCustom_Events
+ * @generated from message wg.cosmo.node.v1.DataSourceCustomEvents
  */
-export class DataSourceCustom_Events extends Message {
+export class DataSourceCustomEvents extends Message {
     /**
-     * @generated from field: repeated wg.cosmo.node.v1.EventConfiguration events = 1;
+     * @generated from field: repeated wg.cosmo.node.v1.NatsEventConfiguration nats = 1;
      */
-    events = [];
+    nats = [];
+    /**
+     * @generated from field: repeated wg.cosmo.node.v1.KafkaEventConfiguration kafka = 2;
+     */
+    kafka = [];
     constructor(data) {
@@ -1254,17 +1323,18 @@ super();
     static runtime = proto3;
-    static typeName = "wg.cosmo.node.v1.DataSourceCustom_Events";
+    static typeName = "wg.cosmo.node.v1.DataSourceCustomEvents";
     static fields = proto3.util.newFieldList(() => [
-        { no: 1, name: "events", kind: "message", T: EventConfiguration, repeated: true },
+        { no: 1, name: "nats", kind: "message", T: NatsEventConfiguration, repeated: true },
+        { no: 2, name: "kafka", kind: "message", T: KafkaEventConfiguration, repeated: true },
     ]);
     static fromBinary(bytes, options) {
-        return new DataSourceCustom_Events().fromBinary(bytes, options);
+        return new DataSourceCustomEvents().fromBinary(bytes, options);
     }
     static fromJson(jsonValue, options) {
-        return new DataSourceCustom_Events().fromJson(jsonValue, options);
+        return new DataSourceCustomEvents().fromJson(jsonValue, options);
     }
     static fromJsonString(jsonString, options) {
-        return new DataSourceCustom_Events().fromJsonString(jsonString, options);
+        return new DataSourceCustomEvents().fromJsonString(jsonString, options);
     }
     static equals(a, b) {
-        return proto3.util.equals(DataSourceCustom_Events, a, b);
+        return proto3.util.equals(DataSourceCustomEvents, a, b);
     }
@@ -1271,0 +1341,0 @@ }

package.json

 {
   "name": "@wundergraph/cosmo-connect",
-  "version": "0.68.0",
+  "version": "0.69.0",
   "description": "TypeScript Connect client for WunderGraph Cosmo",
@@ -43,3 +43,3 @@ "scripts": {
   },
-  "gitHead": "da53dd4fec58959cbcbed71f3b627812384cb722"
+  "gitHead": "96800747c83017ee16639aff45fd06d72de832d0"
 }

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

1843689

increased by0.4%

Lines of code

31050

increased by0.36%

No dependency changes