New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

@blockprotocol/core

Package Overview
Dependencies
Maintainers
8
Versions
61
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@blockprotocol/core - npm Package Compare versions

Comparing version 0.0.10 to 0.0.11

dist/cjs/tsconfig.build.cjs.tsbuildinfo
dist/esm/tsconfig.build.esm.tsbuildinfo

7

dist/cjs/core-block-handler.js

@@ -36,3 +36,8 @@ "use strict";

void this.callCallback({
message: Object.assign(Object.assign({}, message), { data: data[serviceName][messageName], messageName, service: serviceName }),
message: {
...message,
data: data[serviceName][messageName],
messageName,
service: serviceName,
},
});

@@ -39,0 +44,0 @@ }

105

dist/cjs/core-handler.js
"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
Object.defineProperty(exports, "__esModule", { value: true });

@@ -58,8 +49,7 @@ exports.CoreHandler = void 0;

static registerService({ element, service, }) {
var _a, _b;
var _c;
var _a;
const { serviceName } = service;
const handler = (_a = this.instanceMap.get(element)) !== null && _a !== void 0 ? _a : Reflect.construct(this, [{ element }]);
const handler = this.instanceMap.get(element) ?? Reflect.construct(this, [{ element }]);
handler.services.set(serviceName, service);
(_b = (_c = handler.messageCallbacksByService)[serviceName]) !== null && _b !== void 0 ? _b : (_c[serviceName] = new Map());
(_a = handler.messageCallbacksByService)[serviceName] ?? (_a[serviceName] = new Map());
return handler;

@@ -82,4 +72,3 @@ }

removeEventListeners() {
var _a;
(_a = this.element) === null || _a === void 0 ? void 0 : _a.removeEventListener(CoreHandler.customEventName, this.eventListener);
this.element?.removeEventListener(CoreHandler.customEventName, this.eventListener);
}

@@ -91,4 +80,3 @@ /**

var _a;
var _b;
(_a = (_b = this.messageCallbacksByService)[serviceName]) !== null && _a !== void 0 ? _a : (_b[serviceName] = new Map());
(_a = this.messageCallbacksByService)[serviceName] ?? (_a[serviceName] = new Map());
this.messageCallbacksByService[serviceName].set(messageName, callback);

@@ -106,3 +94,10 @@ }

}
const fullMessage = Object.assign(Object.assign({}, partialMessage), { requestId: requestId !== null && requestId !== void 0 ? requestId : (0, uuid_1.v4)(), respondedToBy: "respondedToBy" in args ? args.respondedToBy : undefined, service: sender.serviceName, source: this.sourceType, timestamp: new Date().toISOString() });
const fullMessage = {
...partialMessage,
requestId: requestId ?? (0, uuid_1.v4)(),
respondedToBy: "respondedToBy" in args ? args.respondedToBy : undefined,
service: sender.serviceName,
source: this.sourceType,
timestamp: new Date().toISOString(),
};
const event = new CustomEvent(CoreHandler.customEventName, {

@@ -134,44 +129,42 @@ bubbles: true,

*/
callCallback({ message }) {
var _a, _b, _c;
return __awaiter(this, void 0, void 0, function* () {
const { errors, messageName, data, requestId, respondedToBy, service } = message;
const callback = (_b = (_a = this.messageCallbacksByService[service]) === null || _a === void 0 ? void 0 : _a.get(messageName)) !== null && _b !== void 0 ? _b : this.defaultMessageCallback;
if (respondedToBy && !callback) {
throw new Error(`Message '${messageName}' expected a response, but no callback for '${messageName}' provided.`);
async callCallback({ message }) {
const { errors, messageName, data, requestId, respondedToBy, service } = message;
const callback = this.messageCallbacksByService[service]?.get(messageName) ??
this.defaultMessageCallback;
if (respondedToBy && !callback) {
throw new Error(`Message '${messageName}' expected a response, but no callback for '${messageName}' provided.`);
}
if (!callback) {
return;
}
// Produce and send a response, if this message requires one and a callback for it has been registered.
if (respondedToBy) {
const serviceHandler = this.services.get(service);
if (!serviceHandler) {
throw new Error(`Handler for service ${service} not registered.`);
}
if (!callback) {
return;
try {
const { data: responsePayload, errors: responseErrors } = (await callback({ data, errors })) ?? {};
this.sendMessage({
partialMessage: {
messageName: respondedToBy,
data: responsePayload,
errors: responseErrors, // @todo fix this cast
},
requestId,
sender: serviceHandler,
});
}
// Produce and send a response, if this message requires one and a callback for it has been registered.
if (respondedToBy) {
const serviceHandler = this.services.get(service);
if (!serviceHandler) {
throw new Error(`Handler for service ${service} not registered.`);
}
try {
const { data: responsePayload, errors: responseErrors } = (_c = (yield callback({ data, errors }))) !== null && _c !== void 0 ? _c : {};
this.sendMessage({
partialMessage: {
messageName: respondedToBy,
data: responsePayload,
errors: responseErrors, // @todo fix this cast
},
requestId,
sender: serviceHandler,
});
}
catch (err) {
throw new Error(`Could not produce response to '${messageName}' message: ${err.message}`);
}
catch (err) {
throw new Error(`Could not produce response to '${messageName}' message: ${err.message}`);
}
else {
try {
yield callback({ data, errors });
}
catch (err) {
throw new Error(`Error calling callback for message '${messageName}: ${err}`);
}
}
else {
try {
await callback({ data, errors });
}
});
catch (err) {
throw new Error(`Error calling callback for message '${messageName}: ${err}`);
}
}
}

@@ -178,0 +171,0 @@ /**

26

dist/cjs/html.js
"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
Object.defineProperty(exports, "__esModule", { value: true });

@@ -51,5 +42,4 @@ exports.assignBlockProtocolGlobals = exports.teardownBlockProtocol = exports.renderHtmlBlock = exports.markBlockScripts = exports.markScript = exports.getBlockUrl = exports.getBlockContainer = void 0;

const getBlockContainer = (ref) => {
var _a;
const blockId = getIdForRef(ref);
const container = (_a = blocks.get(blockId)) === null || _a === void 0 ? void 0 : _a.container;
const container = blocks.get(blockId)?.container;
if (!container) {

@@ -70,5 +60,4 @@ throw new Error("Cannot find block container");

const getBlockUrl = (ref) => {
var _a;
const blockId = getIdForRef(ref);
const url = (_a = blocks.get(blockId)) === null || _a === void 0 ? void 0 : _a.url;
const url = blocks.get(blockId)?.url;
if (!url) {

@@ -141,3 +130,3 @@ throw new Error("Cannot find block url");

const [imports] = (0, es_module_lexer_1.parse)(html);
const relevantImports = imports.filter((imp) => { var _a; return !(imp.d > -1) && ((_a = imp.n) === null || _a === void 0 ? void 0 : _a.startsWith(".")); });
const relevantImports = imports.filter((imp) => !(imp.d > -1) && imp.n?.startsWith("."));
script.innerHTML = relevantImports.reduce((prevSource, imp, idx) => {

@@ -165,8 +154,7 @@ let nextSource = prevSource;

*/
const renderHtmlBlock = (node, definition, signal) => __awaiter(void 0, void 0, void 0, function* () {
var _a;
const baseUrl = new URL((_a = definition.url) !== null && _a !== void 0 ? _a : window.location.toString(), window.location.toString());
const renderHtmlBlock = async (node, definition, signal) => {
const baseUrl = new URL(definition.url ?? window.location.toString(), window.location.toString());
const htmlString = "source" in definition && definition.source
? definition.source
: yield fetch(definition.url, { signal }).then((resp) => resp.text());
: await fetch(definition.url, { signal }).then((resp) => resp.text());
const range = document.createRange();

@@ -183,3 +171,3 @@ range.selectNodeContents(node);

node.appendChild(parent);
});
};
exports.renderHtmlBlock = renderHtmlBlock;

@@ -186,0 +174,0 @@ const blockProtocolGlobals = {

2

dist/cjs/service-handler.d.ts

@@ -45,3 +45,3 @@ import { CoreHandler } from "./core-handler";

/** Register callbacks with the CoreHandler to handle incoming messages of specific types */
protected registerCallbacks(this: ServiceHandler, callbacks: Record<string, GenericMessageCallback>): void;
registerCallbacks(this: ServiceHandler, callbacks: Record<string, GenericMessageCallback>): void;
/** Register a callback with the CoreHandler to handle an incoming messages of a specific type */

@@ -48,0 +48,0 @@ protected registerCallback(this: ServiceHandler, { messageName, callback, }: {

2

dist/cjs/service-handler.js

@@ -13,3 +13,3 @@ "use strict";

constructor({ element, serviceName, sourceType, }) {
this.element = element !== null && element !== void 0 ? element : null;
this.element = element ?? null;
this.serviceName = serviceName;

@@ -16,0 +16,0 @@ this.sourceType = sourceType;

7

dist/esm/core-block-handler.js

@@ -33,3 +33,8 @@ import { CoreHandler } from "./core-handler";

void this.callCallback({
message: Object.assign(Object.assign({}, message), { data: data[serviceName][messageName], messageName, service: serviceName }),
message: {
...message,
data: data[serviceName][messageName],
messageName,
service: serviceName,
},
});

@@ -36,0 +41,0 @@ }

105

dist/esm/core-handler.js

@@ -1,10 +0,1 @@

var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
import { v4 as uuid } from "uuid";

@@ -55,8 +46,7 @@ /**

static registerService({ element, service, }) {
var _a, _b;
var _c;
var _a;
const { serviceName } = service;
const handler = (_a = this.instanceMap.get(element)) !== null && _a !== void 0 ? _a : Reflect.construct(this, [{ element }]);
const handler = this.instanceMap.get(element) ?? Reflect.construct(this, [{ element }]);
handler.services.set(serviceName, service);
(_b = (_c = handler.messageCallbacksByService)[serviceName]) !== null && _b !== void 0 ? _b : (_c[serviceName] = new Map());
(_a = handler.messageCallbacksByService)[serviceName] ?? (_a[serviceName] = new Map());
return handler;

@@ -79,4 +69,3 @@ }

removeEventListeners() {
var _a;
(_a = this.element) === null || _a === void 0 ? void 0 : _a.removeEventListener(CoreHandler.customEventName, this.eventListener);
this.element?.removeEventListener(CoreHandler.customEventName, this.eventListener);
}

@@ -88,4 +77,3 @@ /**

var _a;
var _b;
(_a = (_b = this.messageCallbacksByService)[serviceName]) !== null && _a !== void 0 ? _a : (_b[serviceName] = new Map());
(_a = this.messageCallbacksByService)[serviceName] ?? (_a[serviceName] = new Map());
this.messageCallbacksByService[serviceName].set(messageName, callback);

@@ -103,3 +91,10 @@ }

}
const fullMessage = Object.assign(Object.assign({}, partialMessage), { requestId: requestId !== null && requestId !== void 0 ? requestId : uuid(), respondedToBy: "respondedToBy" in args ? args.respondedToBy : undefined, service: sender.serviceName, source: this.sourceType, timestamp: new Date().toISOString() });
const fullMessage = {
...partialMessage,
requestId: requestId ?? uuid(),
respondedToBy: "respondedToBy" in args ? args.respondedToBy : undefined,
service: sender.serviceName,
source: this.sourceType,
timestamp: new Date().toISOString(),
};
const event = new CustomEvent(CoreHandler.customEventName, {

@@ -131,44 +126,42 @@ bubbles: true,

*/
callCallback({ message }) {
var _a, _b, _c;
return __awaiter(this, void 0, void 0, function* () {
const { errors, messageName, data, requestId, respondedToBy, service } = message;
const callback = (_b = (_a = this.messageCallbacksByService[service]) === null || _a === void 0 ? void 0 : _a.get(messageName)) !== null && _b !== void 0 ? _b : this.defaultMessageCallback;
if (respondedToBy && !callback) {
throw new Error(`Message '${messageName}' expected a response, but no callback for '${messageName}' provided.`);
async callCallback({ message }) {
const { errors, messageName, data, requestId, respondedToBy, service } = message;
const callback = this.messageCallbacksByService[service]?.get(messageName) ??
this.defaultMessageCallback;
if (respondedToBy && !callback) {
throw new Error(`Message '${messageName}' expected a response, but no callback for '${messageName}' provided.`);
}
if (!callback) {
return;
}
// Produce and send a response, if this message requires one and a callback for it has been registered.
if (respondedToBy) {
const serviceHandler = this.services.get(service);
if (!serviceHandler) {
throw new Error(`Handler for service ${service} not registered.`);
}
if (!callback) {
return;
try {
const { data: responsePayload, errors: responseErrors } = (await callback({ data, errors })) ?? {};
this.sendMessage({
partialMessage: {
messageName: respondedToBy,
data: responsePayload,
errors: responseErrors, // @todo fix this cast
},
requestId,
sender: serviceHandler,
});
}
// Produce and send a response, if this message requires one and a callback for it has been registered.
if (respondedToBy) {
const serviceHandler = this.services.get(service);
if (!serviceHandler) {
throw new Error(`Handler for service ${service} not registered.`);
}
try {
const { data: responsePayload, errors: responseErrors } = (_c = (yield callback({ data, errors }))) !== null && _c !== void 0 ? _c : {};
this.sendMessage({
partialMessage: {
messageName: respondedToBy,
data: responsePayload,
errors: responseErrors, // @todo fix this cast
},
requestId,
sender: serviceHandler,
});
}
catch (err) {
throw new Error(`Could not produce response to '${messageName}' message: ${err.message}`);
}
catch (err) {
throw new Error(`Could not produce response to '${messageName}' message: ${err.message}`);
}
else {
try {
yield callback({ data, errors });
}
catch (err) {
throw new Error(`Error calling callback for message '${messageName}: ${err}`);
}
}
else {
try {
await callback({ data, errors });
}
});
catch (err) {
throw new Error(`Error calling callback for message '${messageName}: ${err}`);
}
}
}

@@ -175,0 +168,0 @@ /**

26

dist/esm/html.js

@@ -1,10 +0,1 @@

var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
import { parse as parseModules } from "es-module-lexer";

@@ -48,5 +39,4 @@ import { v4 as uuid } from "uuid";

export const getBlockContainer = (ref) => {
var _a;
const blockId = getIdForRef(ref);
const container = (_a = blocks.get(blockId)) === null || _a === void 0 ? void 0 : _a.container;
const container = blocks.get(blockId)?.container;
if (!container) {

@@ -66,5 +56,4 @@ throw new Error("Cannot find block container");

export const getBlockUrl = (ref) => {
var _a;
const blockId = getIdForRef(ref);
const url = (_a = blocks.get(blockId)) === null || _a === void 0 ? void 0 : _a.url;
const url = blocks.get(blockId)?.url;
if (!url) {

@@ -135,3 +124,3 @@ throw new Error("Cannot find block url");

const [imports] = parseModules(html);
const relevantImports = imports.filter((imp) => { var _a; return !(imp.d > -1) && ((_a = imp.n) === null || _a === void 0 ? void 0 : _a.startsWith(".")); });
const relevantImports = imports.filter((imp) => !(imp.d > -1) && imp.n?.startsWith("."));
script.innerHTML = relevantImports.reduce((prevSource, imp, idx) => {

@@ -158,8 +147,7 @@ let nextSource = prevSource;

*/
export const renderHtmlBlock = (node, definition, signal) => __awaiter(void 0, void 0, void 0, function* () {
var _a;
const baseUrl = new URL((_a = definition.url) !== null && _a !== void 0 ? _a : window.location.toString(), window.location.toString());
export const renderHtmlBlock = async (node, definition, signal) => {
const baseUrl = new URL(definition.url ?? window.location.toString(), window.location.toString());
const htmlString = "source" in definition && definition.source
? definition.source
: yield fetch(definition.url, { signal }).then((resp) => resp.text());
: await fetch(definition.url, { signal }).then((resp) => resp.text());
const range = document.createRange();

@@ -176,3 +164,3 @@ range.selectNodeContents(node);

node.appendChild(parent);
});
};
const blockProtocolGlobals = {

@@ -179,0 +167,0 @@ getBlockContainer,

2

dist/esm/service-handler.d.ts

@@ -45,3 +45,3 @@ import { CoreHandler } from "./core-handler";

/** Register callbacks with the CoreHandler to handle incoming messages of specific types */
protected registerCallbacks(this: ServiceHandler, callbacks: Record<string, GenericMessageCallback>): void;
registerCallbacks(this: ServiceHandler, callbacks: Record<string, GenericMessageCallback>): void;
/** Register a callback with the CoreHandler to handle an incoming messages of a specific type */

@@ -48,0 +48,0 @@ protected registerCallback(this: ServiceHandler, { messageName, callback, }: {

2

dist/esm/service-handler.js

@@ -10,3 +10,3 @@ import { CoreBlockHandler } from "./core-block-handler";

constructor({ element, serviceName, sourceType, }) {
this.element = element !== null && element !== void 0 ? element : null;
this.element = element ?? null;
this.serviceName = serviceName;

@@ -13,0 +13,0 @@ this.sourceType = sourceType;

12

package.json
{
"name": "@blockprotocol/core",
"version": "0.0.10",
"version": "0.0.11",
"description": "Implementation of the Block Protocol Core specification for blocks and embedding applications",

@@ -32,7 +32,6 @@ "keywords": [

"build": "yarn clean && yarn build:cjs && yarn build:esm",
"build:cjs": "tsc --module commonjs --outDir dist/cjs ",
"build:esm": "tsc",
"build:cjs": "tsc --project tsconfig.build.cjs.json",
"build:esm": "tsc --project tsconfig.build.esm.json",
"clean": "rimraf ./dist/",
"lint:tsc": "tsc --noEmit",
"prepare": "yarn build"
"lint:tsc": "tsc --noEmit"
},

@@ -44,5 +43,6 @@ "dependencies": {

"devDependencies": {
"@local/tsconfig": "0.0.0-private",
"rimraf": "^3.0.2",
"typescript": "4.7.4"
"typescript": "4.8.2"
}
}
dist/cjs/core-block-handler.js.map

Sorry, the diff of this file is not supported yet

dist/cjs/core-handler.js.map

Sorry, the diff of this file is not supported yet

dist/cjs/html.js.map

Sorry, the diff of this file is not supported yet

dist/cjs/service-handler.js.map

Sorry, the diff of this file is not supported yet

dist/esm/core-block-handler.js.map

Sorry, the diff of this file is not supported yet

dist/esm/core-handler.js.map

Sorry, the diff of this file is not supported yet

dist/esm/html.js.map

Sorry, the diff of this file is not supported yet

dist/esm/service-handler.js.map

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc