@huddle01/web-core - npm Package Compare versions

Comparing version 1.0.0-alpha.34 to 1.0.0-alpha.35

dist/Consumer.js

 import {
   Consumer_default
-} from "./chunk-FE7RZJBI.js";
+} from "./chunk-ISGZIUR3.js";
+import "./chunk-7OTQAFXE.js";
 import "./chunk-EVXWMCNT.js";
-import "./chunk-7OTQAFXE.js";
 import "./chunk-UXIASGQL.js";
@@ -7,0 +7,0 @@ export {

dist/DeviceHandler.js

 import {
   DeviceHandler_default
-} from "./chunk-SOT5VN77.js";
+} from "./chunk-XU22MCQF.js";
 import "./chunk-A3HCACHA.js";
 import "./chunk-XHXVBEEH.js";
+import "./chunk-7OTQAFXE.js";
 import "./chunk-EVXWMCNT.js";
-import "./chunk-7OTQAFXE.js";
 import "./chunk-UXIASGQL.js";
@@ -9,0 +9,0 @@ export {

dist/HuddleClient.d.ts

@@ -5,3 +5,2 @@ import LocalPeer from './LocalPeer.js';
 import 'mediasoup-client/lib/types';
-import 'mediasoup-client';
 import 'types/dist/common.types';
@@ -12,2 +11,3 @@ import 'types/dist/socket.types';
 import './Transport.js';
+import 'mediasoup-client';
 import 'types/dist';
@@ -14,0 +14,0 @@ import './Consumer.js';

dist/HuddleClient.js

 import {
   HuddleClient_default
-} from "./chunk-XUEEQMEJ.js";
-import "./chunk-IMNYWQ3C.js";
-import "./chunk-KIIMBSNE.js";
+} from "./chunk-OKR2PZUE.js";
+import "./chunk-MEQWZ2B7.js";
+import "./chunk-6H7CO2TR.js";
+import "./chunk-GZLJOUZ3.js";
 import "./chunk-7PO7E25R.js";
-import "./chunk-GZLJOUZ3.js";
-import "./chunk-FE7RZJBI.js";
-import "./chunk-SOT5VN77.js";
+import "./chunk-ISGZIUR3.js";
+import "./chunk-XU22MCQF.js";
 import "./chunk-A3HCACHA.js";
 import "./chunk-XHXVBEEH.js";
-import "./chunk-4KYYRYQ7.js";
-import "./chunk-BCLDPOUD.js";
+import "./chunk-A73FFKYZ.js";
+import "./chunk-IV5CYBGO.js";
 import "./chunk-PYD4CES4.js";
-import "./chunk-GAFMQRFA.js";
+import "./chunk-SSCVNXAL.js";
+import "./chunk-7OTQAFXE.js";
 import "./chunk-EVXWMCNT.js";
-import "./chunk-7OTQAFXE.js";
 import "./chunk-UXIASGQL.js";
@@ -19,0 +19,0 @@ export {

dist/index.d.ts

@@ -14,3 +14,2 @@ export { default as HuddleClient } from './HuddleClient.js';
 import 'mediasoup-client/lib/types';
-import 'mediasoup-client';
 import 'types/dist/common.types';
@@ -21,4 +20,5 @@ import 'types/dist/socket.types';
 import 'types/dist/sushiToClientEvents.types';
+import 'mediasoup-client';
 import 'types/dist';
 import 'types/dist/mq/response.types';
 import './common-js/EnhancedMap.js';

dist/index.js

 import {
   HuddleClient_default
-} from "./chunk-XUEEQMEJ.js";
+} from "./chunk-OKR2PZUE.js";
 import {
@@ -8,14 +8,14 @@ LocalPeer_default,
   Room_default
-} from "./chunk-IMNYWQ3C.js";
+} from "./chunk-MEQWZ2B7.js";
 import {
   Transport_default
-} from "./chunk-KIIMBSNE.js";
+} from "./chunk-6H7CO2TR.js";
+import "./chunk-GZLJOUZ3.js";
 import "./chunk-7PO7E25R.js";
-import "./chunk-GZLJOUZ3.js";
 import {
   Consumer_default
-} from "./chunk-FE7RZJBI.js";
+} from "./chunk-ISGZIUR3.js";
 import {
   DeviceHandler_default
-} from "./chunk-SOT5VN77.js";
+} from "./chunk-XU22MCQF.js";
 import "./chunk-A3HCACHA.js";
@@ -25,10 +25,10 @@ import "./chunk-XHXVBEEH.js";
   Permissions_default
-} from "./chunk-4KYYRYQ7.js";
+} from "./chunk-A73FFKYZ.js";
 import {
   Socket_default
-} from "./chunk-BCLDPOUD.js";
+} from "./chunk-IV5CYBGO.js";
 import "./chunk-PYD4CES4.js";
-import "./chunk-GAFMQRFA.js";
+import "./chunk-SSCVNXAL.js";
+import "./chunk-7OTQAFXE.js";
 import "./chunk-EVXWMCNT.js";
-import "./chunk-7OTQAFXE.js";
 import "./chunk-UXIASGQL.js";
@@ -35,0 +35,0 @@ export {

dist/LocalPeer.d.ts

@@ -1,4 +0,3 @@
-import { Producer, AppData } from 'mediasoup-client/lib/types';
-import { Device } from 'mediasoup-client';
-import { TDataMessage, TPermissions } from 'types/dist/common.types';
+import { Producer, Device, AppData, DataProducer } from 'mediasoup-client/lib/types';
+import { TDataMessage, TVolatileDataMessage, TPermissions } from 'types/dist/common.types';
 import { ESocketCloseCode } from 'types/dist/socket.types';
@@ -10,2 +9,3 @@ import DeviceHandler, { CustomMediaKind } from './DeviceHandler.js';
 import { EnhancedEventEmitter } from './common-js/EnhancedEventEmitter.js';
+import 'mediasoup-client';
 import 'types/dist';
@@ -52,2 +52,3 @@ import 'types/dist/mq/response.types';
     'receive-data': [data: TDataMessage];
+    'receive-volatile-data': [data: TVolatileDataMessage];
     reconnected: [data: Socket];
@@ -125,2 +126,3 @@ 'metadata-updated': [data: {
     private __pendingProducerTasks;
+    private __pendingDataProducerTasks;
     /**
@@ -280,2 +282,6 @@ * Pending Transport Tasks, Stores the transportType and the promise of the transport
     }) => Promise<Producer<AppData>>;
+    produceData: (data: {
+        label: string;
+        appData?: AppData | undefined;
+    }) => Promise<DataProducer<AppData>>;
     /**
@@ -410,2 +416,7 @@ * Enables the local web cam and starts producing the stream with the label `video`
     }) => void;
+    sendVolatileData: (data: {
+        to?: string[] | '*';
+        label: string;
+        payload: unknown;
+    }) => Promise<void>;
     sendData: (data: {
@@ -435,2 +446,4 @@ to: string[] | '*';
     private __createProducer;
+    activateVolatileMessages: () => Promise<void>;
+    private __createDataProducer;
     private __createTransportOnServer;
@@ -437,0 +450,0 @@ private __setRemotePeers;

dist/LocalPeer.js

 import {
   LocalPeer_default
-} from "./chunk-IMNYWQ3C.js";
-import "./chunk-KIIMBSNE.js";
+} from "./chunk-MEQWZ2B7.js";
+import "./chunk-6H7CO2TR.js";
+import "./chunk-GZLJOUZ3.js";
 import "./chunk-7PO7E25R.js";
-import "./chunk-GZLJOUZ3.js";
-import "./chunk-FE7RZJBI.js";
-import "./chunk-SOT5VN77.js";
+import "./chunk-ISGZIUR3.js";
+import "./chunk-XU22MCQF.js";
 import "./chunk-A3HCACHA.js";
 import "./chunk-XHXVBEEH.js";
-import "./chunk-4KYYRYQ7.js";
-import "./chunk-BCLDPOUD.js";
+import "./chunk-A73FFKYZ.js";
+import "./chunk-IV5CYBGO.js";
 import "./chunk-PYD4CES4.js";
-import "./chunk-GAFMQRFA.js";
+import "./chunk-SSCVNXAL.js";
+import "./chunk-7OTQAFXE.js";
 import "./chunk-EVXWMCNT.js";
-import "./chunk-7OTQAFXE.js";
 import "./chunk-UXIASGQL.js";
@@ -18,0 +18,0 @@ export {

dist/Permissions.js

 import {
   Permissions_default,
   checkPermissions
-} from "./chunk-4KYYRYQ7.js";
+} from "./chunk-A73FFKYZ.js";
+import "./chunk-7OTQAFXE.js";
 import "./chunk-EVXWMCNT.js";
-import "./chunk-7OTQAFXE.js";
 import "./chunk-UXIASGQL.js";
@@ -8,0 +8,0 @@ export {

dist/RemotePeer.js

 import {
   RemotePeer_default
-} from "./chunk-IMNYWQ3C.js";
-import "./chunk-KIIMBSNE.js";
+} from "./chunk-MEQWZ2B7.js";
+import "./chunk-6H7CO2TR.js";
+import "./chunk-GZLJOUZ3.js";
 import "./chunk-7PO7E25R.js";
-import "./chunk-GZLJOUZ3.js";
-import "./chunk-FE7RZJBI.js";
-import "./chunk-SOT5VN77.js";
+import "./chunk-ISGZIUR3.js";
+import "./chunk-XU22MCQF.js";
 import "./chunk-A3HCACHA.js";
 import "./chunk-XHXVBEEH.js";
-import "./chunk-4KYYRYQ7.js";
-import "./chunk-BCLDPOUD.js";
+import "./chunk-A73FFKYZ.js";
+import "./chunk-IV5CYBGO.js";
 import "./chunk-PYD4CES4.js";
-import "./chunk-GAFMQRFA.js";
+import "./chunk-SSCVNXAL.js";
+import "./chunk-7OTQAFXE.js";
 import "./chunk-EVXWMCNT.js";
-import "./chunk-7OTQAFXE.js";
 import "./chunk-UXIASGQL.js";
@@ -18,0 +18,0 @@ export {

dist/Room.js

 import {
   Room_default
-} from "./chunk-IMNYWQ3C.js";
-import "./chunk-KIIMBSNE.js";
+} from "./chunk-MEQWZ2B7.js";
+import "./chunk-6H7CO2TR.js";
+import "./chunk-GZLJOUZ3.js";
 import "./chunk-7PO7E25R.js";
-import "./chunk-GZLJOUZ3.js";
-import "./chunk-FE7RZJBI.js";
-import "./chunk-SOT5VN77.js";
+import "./chunk-ISGZIUR3.js";
+import "./chunk-XU22MCQF.js";
 import "./chunk-A3HCACHA.js";
 import "./chunk-XHXVBEEH.js";
-import "./chunk-4KYYRYQ7.js";
-import "./chunk-BCLDPOUD.js";
+import "./chunk-A73FFKYZ.js";
+import "./chunk-IV5CYBGO.js";
 import "./chunk-PYD4CES4.js";
-import "./chunk-GAFMQRFA.js";
+import "./chunk-SSCVNXAL.js";
+import "./chunk-7OTQAFXE.js";
 import "./chunk-EVXWMCNT.js";
-import "./chunk-7OTQAFXE.js";
 import "./chunk-UXIASGQL.js";
@@ -18,0 +18,0 @@ export {

dist/Socket.js

 import {
   Socket_default
-} from "./chunk-BCLDPOUD.js";
+} from "./chunk-IV5CYBGO.js";
 import "./chunk-PYD4CES4.js";
-import "./chunk-GAFMQRFA.js";
+import "./chunk-SSCVNXAL.js";
+import "./chunk-7OTQAFXE.js";
 import "./chunk-EVXWMCNT.js";
-import "./chunk-7OTQAFXE.js";
 import "./chunk-UXIASGQL.js";
@@ -9,0 +9,0 @@ export {

dist/Transport.d.ts

@@ -8,3 +8,3 @@ import * as mediasoup from 'mediasoup-client';
 import Consumer from './Consumer.js';
-import { TConsumeResponseData } from 'types/dist/mq/response.types';
+import { TConsumeResponseData, TConsumeDataResponseData } from 'types/dist/mq/response.types';
 import { EnhancedMap } from './common-js/EnhancedMap.js';
@@ -45,2 +45,14 @@ import 'types/dist/clientToSushiEvents.types';
     /**
+     * Map of DataProducers, which handles the dataProducers. ( Sending out Data )
+     *
+     * `Mapped with {label => DataProducer}`
+     */
+    private readonly __dataProducers;
+    /**
+     * Map of DataConsumers, which handles the dataConsumers. ( Receiving Media Streams )
+     *
+     * `Mapped with {label:label => DataConsumer}`
+     */
+    private readonly __dataConsumers;
+    /**
      * Map of Consumers, which handles the consumers. ( Receiving Media Streams )
@@ -85,2 +97,3 @@ *
     get producers(): Map<string, mediasoup.types.Producer<mediasoup.types.AppData>>;
+    get dataProducers(): Map<string, mediasoup.types.DataProducer<mediasoup.types.AppData>>;
     get consumers(): EnhancedMap<Consumer>;
@@ -122,2 +135,3 @@ getProducerById(producerId: string): Producer;
     private __listenTransportProduce;
+    private __listenTransportDataProduce;
     produce: (data: {
@@ -131,2 +145,9 @@ stream: MediaStream;
     }>>;
+    produceData: (data: {
+        label: string;
+        appData?: AppData;
+    }) => Promise<mediasoup.types.DataProducer<{
+        producerPeerId: string;
+        label: string;
+    }>>;
     consume: (data: TConsumeResponseData) => Promise<{
@@ -136,2 +157,3 @@ consumer: Consumer;
     }>;
+    consumeData: (data: TConsumeDataResponseData) => Promise<mediasoup.types.DataConsumer<mediasoup.types.AppData>>;
     closeConsumer: (data: {
@@ -138,0 +160,0 @@ label: string;

dist/Transport.js

 import {
   Transport_default
-} from "./chunk-KIIMBSNE.js";
+} from "./chunk-6H7CO2TR.js";
+import "./chunk-GZLJOUZ3.js";
 import "./chunk-7PO7E25R.js";
-import "./chunk-GZLJOUZ3.js";
-import "./chunk-FE7RZJBI.js";
+import "./chunk-ISGZIUR3.js";
 import "./chunk-XHXVBEEH.js";
-import "./chunk-BCLDPOUD.js";
+import "./chunk-IV5CYBGO.js";
 import "./chunk-PYD4CES4.js";
-import "./chunk-GAFMQRFA.js";
+import "./chunk-SSCVNXAL.js";
+import "./chunk-7OTQAFXE.js";
 import "./chunk-EVXWMCNT.js";
-import "./chunk-7OTQAFXE.js";
 import "./chunk-UXIASGQL.js";
@@ -14,0 +14,0 @@ export {

dist/types/index.d.ts

@@ -15,3 +15,2 @@ export { Producer } from 'mediasoup-client/lib/types';
 import '../common-js/EnhancedEventEmitter.js';
-import 'mediasoup-client';
 import 'types/dist/common.types';
@@ -21,4 +20,5 @@ import 'types/dist/socket.types';
 import 'types/dist/sushiToClientEvents.types';
+import 'mediasoup-client';
 import 'types/dist';
 import 'types/dist/mq/response.types';
 import '../common-js/EnhancedMap.js';

dist/types/socket.types.js

 import "../chunk-PYD4CES4.js";
 import {
   ConnectionParameterSchema
-} from "../chunk-GAFMQRFA.js";
+} from "../chunk-SSCVNXAL.js";
 import "../chunk-UXIASGQL.js";
@@ -6,0 +6,0 @@

dist/validators/common.validators.d.ts

@@ -35,4 +35,33 @@ import { z } from 'zod';
 }>;
+declare const VolatileDataMessageSchema: z.ZodObject<{
+    from: z.ZodString;
+    payload: z.ZodUnknown;
+    label: z.ZodOptional<z.ZodString>;
+    to: z.ZodOptional<z.ZodUnion<[z.ZodLiteral<"*">, z.ZodArray<z.ZodString, "many">]>>;
+}, "strip", z.ZodTypeAny, {
+    from: string;
+    payload?: unknown;
+    label?: string | undefined;
+    to?: string[] | "*" | undefined;
+}, {
+    from: string;
+    payload?: unknown;
+    label?: string | undefined;
+    to?: string[] | "*" | undefined;
+}>;
+declare const DataMessageSchema: z.ZodObject<{
+    from: z.ZodString;
+    payload: z.ZodString;
+    label: z.ZodOptional<z.ZodString>;
+}, "strip", z.ZodTypeAny, {
+    from: string;
+    payload: string;
+    label?: string | undefined;
+}, {
+    from: string;
+    payload: string;
+    label?: string | undefined;
+}>;
 type IConnectionParameter = z.infer<typeof ConnectionParameterSchema>;
 
-export { ConnectionParameterSchema, GeolocationSchema, IConnectionParameter };
+export { ConnectionParameterSchema, DataMessageSchema, GeolocationSchema, IConnectionParameter, VolatileDataMessageSchema };

dist/validators/common.validators.js

 import {
   ConnectionParameterSchema,
-  GeolocationSchema
-} from "../chunk-GAFMQRFA.js";
+  DataMessageSchema,
+  GeolocationSchema,
+  VolatileDataMessageSchema
+} from "../chunk-SSCVNXAL.js";
 import "../chunk-UXIASGQL.js";
 export {
   ConnectionParameterSchema,
-  GeolocationSchema
+  DataMessageSchema,
+  GeolocationSchema,
+  VolatileDataMessageSchema
 };
 //# sourceMappingURL=common.validators.js.map

dist/validators/index.d.ts

@@ -1,2 +0,2 @@
-export { ConnectionParameterSchema, GeolocationSchema, IConnectionParameter } from './common.validators.js';
+export { ConnectionParameterSchema, DataMessageSchema, GeolocationSchema, IConnectionParameter, VolatileDataMessageSchema } from './common.validators.js';
 import 'zod';

dist/validators/index.js

 import "../chunk-PYD4CES4.js";
 import {
   ConnectionParameterSchema,
-  GeolocationSchema
-} from "../chunk-GAFMQRFA.js";
+  DataMessageSchema,
+  GeolocationSchema,
+  VolatileDataMessageSchema
+} from "../chunk-SSCVNXAL.js";
 import "../chunk-UXIASGQL.js";
 export {
   ConnectionParameterSchema,
-  GeolocationSchema
+  DataMessageSchema,
+  GeolocationSchema,
+  VolatileDataMessageSchema
 };
 //# sourceMappingURL=index.js.map

package.json

 {
   "name": "@huddle01/web-core",
-  "version": "1.0.0-alpha.34",
+  "version": "1.0.0-alpha.35",
   "description": "",
@@ -5,0 +5,0 @@ "type": "module",

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

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

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

532430

increased by5.24%

Lines of code

7536

increased by4.97%

Worsened metrics

Number of medium supply chain risk alerts

3

increased by50%

No dependency changes