Compare commits

..

No commits in common. "v0.1.0-develop.25" and "v0.1.0-develop.24" have entirely different histories.

6 changed files with 7 additions and 74 deletions

View File

@ -1,11 +1,3 @@
# [0.1.0-develop.25](https://git.lumeweb.com/LumeWeb/libkernel/compare/v0.1.0-develop.24...v0.1.0-develop.25) (2023-07-23)
### Features
* add getNetworkModuleStatus to fetch a network module status, either one time or continuous ([19167ac](https://git.lumeweb.com/LumeWeb/libkernel/commit/19167acec25fd1e9caa6023e539f10b8c0e0fb02))
* create abstract NetworkClient with register, status, and ready methods. status calls getNetworkModuleStatus ([711b134](https://git.lumeweb.com/LumeWeb/libkernel/commit/711b1341b80da16cc500ca1e6ba856a145f50037))
# [0.1.0-develop.24](https://git.lumeweb.com/LumeWeb/libkernel/compare/v0.1.0-develop.23...v0.1.0-develop.24) (2023-07-21)

7
npm-shrinkwrap.json generated
View File

@ -1,16 +1,15 @@
{
"name": "@lumeweb/libkernel",
"version": "0.1.0-develop.25",
"version": "0.1.0-develop.24",
"lockfileVersion": 3,
"requires": true,
"packages": {
"": {
"name": "@lumeweb/libkernel",
"version": "0.1.0-develop.25",
"version": "0.1.0-develop.24",
"dependencies": {
"@lumeweb/libweb": "0.2.0-develop.27",
"emittery": "^1.0.1",
"p-defer": "^4.0.0"
"emittery": "^1.0.1"
},
"devDependencies": {
"@lumeweb/node-library-preset": "^0.2.7",

View File

@ -1,6 +1,6 @@
{
"name": "@lumeweb/libkernel",
"version": "0.1.0-develop.25",
"version": "0.1.0-develop.24",
"main": "lib/index.js",
"type": "module",
"types": "lib/index.d.ts",
@ -35,8 +35,7 @@
},
"dependencies": {
"@lumeweb/libweb": "0.2.0-develop.27",
"emittery": "^1.0.1",
"p-defer": "^4.0.0"
"emittery": "^1.0.1"
},
"publishConfig": {
"access": "public"

View File

@ -10,8 +10,6 @@ import {
log as logModule,
logErr as logErrModule,
} from "#module/index.js";
import defer, { DeferredPromise } from "p-defer";
import { connectModuleBound } from "#module/client.js";
// @ts-ignore
const kernelEnv = typeof window !== "undefined" && window?.document;
@ -22,42 +20,3 @@ export const connectModule = kernelEnv
: connectModuleModule;
export const log = kernelEnv ? logKernel : logModule;
export const logErr = kernelEnv ? logErrKernel : logErrModule;
export async function getNetworkModuleStatus(
callback?: any,
module?: string,
// @ts-ignore
CM: connectModuleBound = connectModule.bind(null, module),
): Promise<void | (() => Promise<void>)> {
let recvUpdate = (data) => {
callback?.(data);
};
const [close, resp] = CM("status", null, (data) => {
recvUpdate(data);
});
if (!callback) {
return new Promise(async (resolve) => {
const d = defer();
recvUpdate = (data) => {
resolve(data);
d.resolve();
};
await d.promise;
close();
});
}
let closed = false;
return async () => {
if (closed) {
return;
}
closed = true;
close();
};
}

View File

@ -2,8 +2,8 @@ import Emittery from "emittery";
import { callModule, connectModule, log, logErr } from "../api.js";
import { DataFn, ErrTuple } from "@lumeweb/libweb";
export type callModuleBound = (method: string, data?: any) => Promise<ErrTuple>;
export type connectModuleBound = (
type callModuleBound = (method: string, data?: any) => Promise<ErrTuple>;
type connectModuleBound = (
method: string,
data: any,
receiveUpdate: DataFn,

View File

@ -1,16 +0,0 @@
import { Client } from "../client.js";
import { getNetworkModuleStatus } from "#api.js";
export default abstract class NetworkClient extends Client {
public async register() {
return this.callModuleReturn("register");
}
public async status(callback?: any): Promise<void | (() => Promise<void>)> {
return getNetworkModuleStatus(callback, undefined, this.connectModule);
}
public async ready() {
return this.callModuleReturn("ready");
}
}