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

@sebspark/pubsub

Package Overview
Dependencies
Maintainers
0
Versions
28
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@sebspark/pubsub - npm Package Compare versions

Comparing version 1.1.1 to 1.1.2

13

dist/index.js

@@ -30,3 +30,2 @@ "use strict";

var import_pubsub = require("@google-cloud/pubsub");
var import_avsc = require("avsc");
var schemaIdPattern = /^(?!goog)[a-zA-Z][a-zA-Z0-9-._~%+]{2,254}$/;

@@ -71,3 +70,2 @@ var syncTopicSchema = async (client, cloudSchema) => {

let _topic;
let _type;
const ensureInitiated = async (name, schema) => {

@@ -81,6 +79,2 @@ if (!_topic) {

}
if (schema && !_type) {
const schemaType = import_avsc.Type.forSchema(JSON.parse(schema.avroDefinition));
_type = schemaType;
}
};

@@ -95,8 +89,3 @@ const typedClient = {

await ensureInitiated(name, schema);
if (_type) {
const data = _type.toBuffer(json);
await _topic.publishMessage({ data });
} else {
await _topic.publishMessage({ json });
}
await _topic.publishMessage({ json });
}

@@ -103,0 +92,0 @@ };

2

package.json
{
"name": "@sebspark/pubsub",
"version": "1.1.1",
"version": "1.1.2",
"license": "Apache-2.0",

@@ -5,0 +5,0 @@ "main": "dist/index.js",

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