Skip to content

Commit

Permalink
feat: Console
Browse files Browse the repository at this point in the history
Update CHANGELOG.md
Update response.dev.js
Update request.dev.js
Update setENV.mjs
Update request.js
  • Loading branch information
VirgilClyne committed Nov 28, 2024
1 parent 7ec9abe commit 46463e0
Show file tree
Hide file tree
Showing 5 changed files with 54 additions and 50 deletions.
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -9,3 +9,4 @@
* 升级了 `@nsnanocat/util`
* `util``submodule` 更改为 `package`
* `$platform` 改为 `$app`
* 使用了全新的 `Console` polyfill
9 changes: 5 additions & 4 deletions src/function/setENV.mjs
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { Lodash as _, getStorage, log } from "@nsnanocat/util";
import { Lodash as _, getStorage, Console } from "@nsnanocat/util";

/**
* Set Environment Variables
Expand All @@ -9,12 +9,13 @@ import { Lodash as _, getStorage, log } from "@nsnanocat/util";
* @return {Object} { Settings, Caches, Configs }
*/
export default function setENV(name, platforms, database) {
log("☑️ Set Environment Variables", "");
Console.info("☑️ Set Environment Variables");
const { Settings, Caches, Configs } = getStorage(name, platforms, database);
/***************** Settings *****************/
log(`✅ Set Environment Variables, Settings: ${typeof Settings}, Settings内容: ${JSON.stringify(Settings)}`, "");
Console.debug(`Settings: ${typeof Settings}, Settings内容: ${JSON.stringify(Settings)}`);
/***************** Caches *****************/
//log(`✅ Set Environment Variables, Caches: ${typeof Caches}, Caches内容: ${JSON.stringify(Caches)}`, "");
//Console.debug(`Caches: ${typeof Caches}, Caches内容: ${JSON.stringify(Caches)}`);
/***************** Configs *****************/
Console.info("✅ Set Environment Variables");
return { Settings, Caches, Configs };
};
31 changes: 16 additions & 15 deletions src/request.dev.js
Original file line number Diff line number Diff line change
@@ -1,19 +1,20 @@
import { $app, Lodash as _, Storage, fetch, notification, log, logError, wait, done, gRPC } from "@nsnanocat/util";
import { $app, Lodash as _, Storage, Console, fetch, notification, wait, done, gRPC } from "@nsnanocat/util";
import { URL } from "@nsnanocat/url";
import database from "./function/database.mjs";
import setENV from "./function/setENV.mjs";
// 构造回复数据
let $response = undefined;
Console.debug = (...msg) => { };
/***************** Processing *****************/
// 解构URL
const url = new URL($request.url);
log(`⚠ url: ${url.toJSON()}`, "");
Console.debug(`url: ${url.toJSON()}`);
// 获取连接参数
const PATHs = url.pathname.split("/").filter(Boolean);
log(`⚠ PATHs: ${PATHs}`, "");
Console.debug(`PATHs: ${PATHs}`);
// 解析格式
const FORMAT = ($request.headers?.["Content-Type"] ?? $request.headers?.["content-type"])?.split(";")?.[0];
log(`⚠ FORMAT: ${FORMAT}`, "");
Console.debug(`FORMAT: ${FORMAT}`);
!(async () => {
/**
* 设置
Expand Down Expand Up @@ -42,7 +43,7 @@ log(`⚠ FORMAT: ${FORMAT}`, "");
case "application/vnd.apple.mpegurl":
case "audio/mpegurl":
//body = M3U8.parse($request.body);
//log(`🚧 body: ${JSON.stringify(body)}`, "");
//Console.debug(`body: ${JSON.stringify(body)}`);
//$request.body = M3U8.stringify(body);
break;
case "text/xml":
Expand All @@ -52,19 +53,19 @@ log(`⚠ FORMAT: ${FORMAT}`, "");
case "application/plist":
case "application/x-plist":
//body = XML.parse($request.body);
//log(`🚧 body: ${JSON.stringify(body)}`, "");
//Console.debug(`body: ${JSON.stringify(body)}`);
//$request.body = XML.stringify(body);
break;
case "text/vtt":
case "application/vtt":
//body = VTT.parse($request.body);
//log(`🚧 body: ${JSON.stringify(body)}`, "");
//Console.debug(`body: ${JSON.stringify(body)}`);
//$request.body = VTT.stringify(body);
break;
case "text/json":
case "application/json":
//body = JSON.parse($request.body ?? "{}");
//log(`🚧 body: ${JSON.stringify(body)}`, "");
//Console.debug(`body: ${JSON.stringify(body)}`);
//$request.body = JSON.stringify(body);
break;
case "application/protobuf":
Expand All @@ -74,9 +75,9 @@ log(`⚠ FORMAT: ${FORMAT}`, "");
case "application/grpc+proto":
case "application/vnd.apple.flatbuffer":
case "application/octet-stream": {
//log(`🚧 $request.body: ${JSON.stringify($request.body)}`, "");
//Console.debug(`$request.body: ${JSON.stringify($request.body)}`);
let rawBody = $app === "Quantumult X" ? new Uint8Array($request.bodyBytes ?? []) : ($request.body ?? new Uint8Array());
//log(`🚧 isBuffer? ${ArrayBuffer.isView(rawBody)}: ${JSON.stringify(rawBody)}`, "");
//Console.debug(`isBuffer? ${ArrayBuffer.isView(rawBody)}: ${JSON.stringify(rawBody)}`);
switch (FORMAT) {
case "application/protobuf":
case "application/x-protobuf":
Expand Down Expand Up @@ -172,13 +173,13 @@ log(`⚠ FORMAT: ${FORMAT}`, "");
}
if ($request.headers?.Host) $request.headers.Host = url.hostname;
$request.url = url.toString();
log("🚧 调试信息", `$request.url: ${$request.url}`, "");
Console.debug(`$request.url: ${$request.url}`);
})()
.catch(e => logError(e))
.catch(e => Console.error(e))
.finally(() => {
switch (typeof $response) {
case "object": // 有构造回复数据,返回构造的回复数据
//log("🚧 finally", `echo $response: ${JSON.stringify($response, null, 2)}`, "");
//Console.debug("🚧 finally", `echo $response: ${JSON.stringify($response, null, 2)}`);
if ($response.headers?.["Content-Encoding"]) $response.headers["Content-Encoding"] = "identity";
if ($response.headers?.["content-encoding"]) $response.headers["content-encoding"] = "identity";
switch ($app) {
Expand All @@ -195,11 +196,11 @@ log(`⚠ FORMAT: ${FORMAT}`, "");
}
break;
case "undefined": // 无构造回复数据,发送修改的请求数据
//log("🚧 finally", `$request: ${JSON.stringify($request, null, 2)}`, "");
//Console.debug("🚧 finally", `$request: ${JSON.stringify($request, null, 2)}`);
done($request);
break;
default:
logError(`不合法的 $response 类型: ${typeof $response}`, "");
Console.error(`不合法的 $response 类型: ${typeof $response}`);
break;
}
});
33 changes: 17 additions & 16 deletions src/request.js
Original file line number Diff line number Diff line change
@@ -1,19 +1,20 @@
import { $app, Lodash as _, Storage, fetch, notification, log, logError, wait, done } from "@nsnanocat/util";
import { $app, Lodash as _, Storage, Console, fetch, notification, wait, done } from "@nsnanocat/util";
import { URL } from "@nsnanocat/url";
import database from "./function/database.mjs";
import setENV from "./function/setENV.mjs";
// 构造回复数据
let $response = undefined;
Console.debug = (...msg) => { };
/***************** Processing *****************/
// 解构URL
const url = new URL($request.url);
//log(`⚠ url: ${url.toJSON()}`, "");
Console.debug(`url: ${url.toJSON()}`);
// 获取连接参数
const PATHs = url.pathname.split("/").filter(Boolean);
log(`⚠ PATHs: ${PATHs}`, "");
Console.debug(`PATHs: ${PATHs}`);
// 解析格式
const FORMAT = ($request.headers?.["Content-Type"] ?? $request.headers?.["content-type"])?.split(";")?.[0];
//log(`⚠ FORMAT: ${FORMAT}`, "");
Console.debug(`FORMAT: ${FORMAT}`);
!(async () => {
/**
* 设置
Expand Down Expand Up @@ -42,7 +43,7 @@ const FORMAT = ($request.headers?.["Content-Type"] ?? $request.headers?.["conten
case "application/vnd.apple.mpegurl":
case "audio/mpegurl":
//body = M3U8.parse($request.body);
//log(`🚧 body: ${JSON.stringify(body)}`, "");
//Console.debug(`body: ${JSON.stringify(body)}`);
//$request.body = M3U8.stringify(body);
break;
case "text/xml":
Expand All @@ -52,19 +53,19 @@ const FORMAT = ($request.headers?.["Content-Type"] ?? $request.headers?.["conten
case "application/plist":
case "application/x-plist":
//body = XML.parse($request.body);
//log(`🚧 body: ${JSON.stringify(body)}`, "");
//Console.debug(`body: ${JSON.stringify(body)}`);
//$request.body = XML.stringify(body);
break;
case "text/vtt":
case "application/vtt":
//body = VTT.parse($request.body);
//log(`🚧 body: ${JSON.stringify(body)}`, "");
//Console.debug(`body: ${JSON.stringify(body)}`);
//$request.body = VTT.stringify(body);
break;
case "text/json":
case "application/json":
//body = JSON.parse($request.body ?? "{}");
//log(`🚧 body: ${JSON.stringify(body)}`, "");
//Console.debug(`body: ${JSON.stringify(body)}`);
//$request.body = JSON.stringify(body);
break;
case "application/protobuf":
Expand All @@ -74,9 +75,9 @@ const FORMAT = ($request.headers?.["Content-Type"] ?? $request.headers?.["conten
case "application/grpc+proto":
case "application/vnd.apple.flatbuffer":
case "application/octet-stream": {
//log(`🚧 $request.body: ${JSON.stringify($request.body)}`, "");
//Console.debug(`$request.body: ${JSON.stringify($request.body)}`);
let rawBody = $app === "Quantumult X" ? new Uint8Array($request.bodyBytes ?? []) : ($request.body ?? new Uint8Array());
//log(`🚧 isBuffer? ${ArrayBuffer.isView(rawBody)}: ${JSON.stringify(rawBody)}`, "");
//Console.debug(`isBuffer? ${ArrayBuffer.isView(rawBody)}: ${JSON.stringify(rawBody)}`);
switch (FORMAT) {
case "application/protobuf":
case "application/x-protobuf":
Expand Down Expand Up @@ -170,13 +171,13 @@ const FORMAT = ($request.headers?.["Content-Type"] ?? $request.headers?.["conten
}
if ($request.headers?.Host) $request.headers.Host = url.hostname;
$request.url = url.toString();
//log("🚧 调试信息", `$request.url: ${$request.url}`, "");
Console.debug(`$request.url: ${$request.url}`);
})()
.catch(e => logError(e))
.finally(() => {
.catch(e => Console.error(e))
.finally(() => {
switch (typeof $response) {
case "object": // 有构造回复数据,返回构造的回复数据
//log("🚧 finally", `echo $response: ${JSON.stringify($response, null, 2)}`, "");
//Console.debug("🚧 finally", `echo $response: ${JSON.stringify($response, null, 2)}`);
if ($response.headers?.["Content-Encoding"]) $response.headers["Content-Encoding"] = "identity";
if ($response.headers?.["content-encoding"]) $response.headers["content-encoding"] = "identity";
switch ($app) {
Expand All @@ -193,11 +194,11 @@ const FORMAT = ($request.headers?.["Content-Type"] ?? $request.headers?.["conten
}
break;
case "undefined": // 无构造回复数据,发送修改的请求数据
//log("🚧 finally", `$request: ${JSON.stringify($request, null, 2)}`, "");
//Console.debug("🚧 finally", `$request: ${JSON.stringify($request, null, 2)}`);
done($request);
break;
default:
logError(`不合法的 $response 类型: ${typeof $response}`, "");
Console.error(`不合法的 $response 类型: ${typeof $response}`);
break;
}
});
30 changes: 15 additions & 15 deletions src/response.dev.js
Original file line number Diff line number Diff line change
@@ -1,20 +1,20 @@
import { $app, Lodash as _, Storage, fetch, notification, log, logError, wait, done, gRPC } from "@nsnanocat/util";
import { $app, Lodash as _, Storage, Console, fetch, notification, wait, done, gRPC } from "@nsnanocat/util";
import database from "./function/database.mjs";
import setENV from "./function/setENV.mjs";
import { WireType, UnknownFieldHandler, reflectionMergePartial, MESSAGE_TYPE, MessageType, BinaryReader, isJsonObject, typeofJsonValue, jsonWriteOptions } from "@protobuf-ts/runtime/build/es2015/index.js";
import { Any } from "./protobuf/google/protobuf/any.js";
/***************** Processing *****************/
// 解构URL
const url = new URL($request.url);
log(`⚠ url: ${url.toJSON()}`, "");
Console.debug(`url: ${url.toJSON()}`, "");
// 获取连接参数
const HOST = url.hostname,
PATH = url.pathname,
PATHs = url.pathname.split("/").filter(Boolean);
log(`⚠ HOST: ${HOST}, PATH: ${PATH}`, "");
Console.debug(`HOST: ${HOST}, PATH: ${PATH}`, "");
// 解析格式
const FORMAT = ($response.headers?.["Content-Type"] ?? $response.headers?.["content-type"])?.split(";")?.[0];
log(`⚠ FORMAT: ${FORMAT}`, "");
Console.debug(`FORMAT: ${FORMAT}`, "");
!(async () => {
/**
* 设置
Expand Down Expand Up @@ -48,7 +48,7 @@ log(`⚠ FORMAT: ${FORMAT}`, "");
case "application/vnd.apple.mpegurl":
case "audio/mpegurl":
//body = M3U8.parse($response.body);
//log(`🚧 body: ${JSON.stringify(body)}`, "");
//Console.debug(`body: ${JSON.stringify(body)}`, "");
//$response.body = M3U8.stringify(body);
break;
case "text/xml":
Expand All @@ -58,13 +58,13 @@ log(`⚠ FORMAT: ${FORMAT}`, "");
case "application/plist":
case "application/x-plist":
//body = XML.parse($response.body);
//log(`🚧 body: ${JSON.stringify(body)}`, "");
//Console.debug(`body: ${JSON.stringify(body)}`, "");
//$response.body = XML.stringify(body);
break;
case "text/vtt":
case "application/vtt":
//body = VTT.parse($response.body);
//log(`🚧 body: ${JSON.stringify(body)}`, "");
//Console.debug(`body: ${JSON.stringify(body)}`, "");
//$response.body = VTT.stringify(body);
break;
case "text/json":
Expand Down Expand Up @@ -119,9 +119,9 @@ log(`⚠ FORMAT: ${FORMAT}`, "");
case "application/grpc+proto":
case "application/vnd.apple.flatbuffer":
case "application/octet-stream": {
//log(`🚧 $response.body: ${JSON.stringify($response.body)}`, "");
//Console.debug(`$response.body: ${JSON.stringify($response.body)}`, "");
let rawBody = $app === "Quantumult X" ? new Uint8Array($response.bodyBytes ?? []) : ($response.body ?? new Uint8Array());
//log(`🚧 isBuffer? ${ArrayBuffer.isView(rawBody)}: ${JSON.stringify(rawBody)}`, "");
//Console.debug(`isBuffer? ${ArrayBuffer.isView(rawBody)}: ${JSON.stringify(rawBody)}`, "");
switch (FORMAT) {
case "application/protobuf":
case "application/x-protobuf":
Expand Down Expand Up @@ -280,17 +280,17 @@ log(`⚠ FORMAT: ${FORMAT}`, "");
const PlayViewUniteReply = new PlayViewUniteReply$Type();
/****************** initialization finish *******************/
let data = PlayViewUniteReply.fromBinary(body);
log(`🚧 data: ${JSON.stringify(data)}`, "");
Console.debug(`data: ${JSON.stringify(data)}`, "");
let UF = UnknownFieldHandler.list(data);
//log(`🚧 UF: ${JSON.stringify(UF)}`, "");
//Console.debug(`UF: ${JSON.stringify(UF)}`, "");
if (UF) {
UF = UF.map(uf => {
//uf.no; // 22
//uf.wireType; // WireType.Varint
// use the binary reader to decode the raw data:
let reader = new BinaryReader(uf.data);
let addedNumber = reader.int32(); // 7777
log(`🚧 no: ${uf.no}, wireType: ${uf.wireType}, addedNumber: ${addedNumber}`, "");
Console.debug(`no: ${uf.no}, wireType: ${uf.wireType}, addedNumber: ${addedNumber}`, "");
});
}
data.vodInfo.streamList = data.vodInfo.streamList.map(stream => {
Expand All @@ -307,7 +307,7 @@ log(`⚠ FORMAT: ${FORMAT}`, "");
}
return stream;
});
log(`🚧 data: ${JSON.stringify(data)}`, "");
Console.debug(`data: ${JSON.stringify(data)}`, "");
body = PlayViewUniteReply.toBinary(data);
break;
}
Expand Down Expand Up @@ -376,7 +376,7 @@ log(`⚠ FORMAT: ${FORMAT}`, "");
break;
}
}
log(`🚧 信息组, infoGroup: ${JSON.stringify(infoGroup)}`, "");
Console.debug(`信息组, infoGroup: ${JSON.stringify(infoGroup)}`, "");
})()
.catch(e => logError(e))
.catch(e => Console.error(e))
.finally(() => done($response));

0 comments on commit 46463e0

Please sign in to comment.