diff --git a/back/api/dependence.ts b/back/api/dependence.ts index 5ee1b971..2d9dc465 100644 --- a/back/api/dependence.ts +++ b/back/api/dependence.ts @@ -11,11 +11,12 @@ export default (app: Router) => { route.get( '/', celebrate({ - query: Joi.object({ - searchValue: Joi.string().optional().allow(''), - type: Joi.string().optional().allow(''), - status: Joi.string().optional().allow(''), - }), + query: + Joi.object({ + searchValue: Joi.string().optional().allow(''), + type: Joi.string().optional().allow(''), + status: Joi.string().optional().allow(''), + }), }), async (req: Request, res: Response, next: NextFunction) => { const logger: Logger = Container.get('logger'); diff --git a/back/api/script.ts b/back/api/script.ts index de9169c0..419ace4a 100644 --- a/back/api/script.ts +++ b/back/api/script.ts @@ -71,8 +71,7 @@ export default (app: Router) => { logger.error('🔥 error: %o', e); return next(e); } - }, - ); + }); route.get( '/detail', @@ -86,7 +85,7 @@ export default (app: Router) => { try { const scriptService = Container.get(ScriptService); const content = await scriptService.getFile( - (req.query?.path as string) || '', + req.query?.path as string || '', req.query.file as string, ); res.send({ code: 200, data: content }); @@ -110,7 +109,7 @@ export default (app: Router) => { try { const scriptService = Container.get(ScriptService); const content = await scriptService.getFile( - (req.query?.path as string) || '', + req.query?.path as string || '', req.params.file, ); res.send({ code: 200, data: content }); diff --git a/back/app.ts b/back/app.ts index 87ea1a2e..0859140c 100644 --- a/back/app.ts +++ b/back/app.ts @@ -28,18 +28,12 @@ class Application { constructor() { this.app = express(); // 创建一个全局中间件,删除查询参数中的t - this.app.use( - ( - req: express.Request, - res: express.Response, - next: express.NextFunction, - ) => { - if (req.query.t) { - delete req.query.t; - } - next(); - }, - ); + this.app.use((req: express.Request, res: express.Response, next: express.NextFunction) => { + if (req.query.t) { + delete req.query.t; + } + next(); + }); } async start() { @@ -67,8 +61,7 @@ class Application { if (metadata) { if (!this.isShuttingDown) { Logger.error( - `${metadata.serviceType} worker ${worker.process.pid} died (${ - signal || code + `${metadata.serviceType} worker ${worker.process.pid} died (${signal || code }). Restarting...`, ); const newWorker = this.forkWorker(metadata.serviceType); @@ -103,11 +96,9 @@ class Application { } private setupMiddlewares() { - this.app.use( - helmet({ - contentSecurityPolicy: false, - }), - ); + this.app.use(helmet({ + contentSecurityPolicy: false, + })); this.app.use(cors(config.cors)); this.app.use(compression()); this.app.use(monitoringMiddleware); diff --git a/back/config/share.ts b/back/config/share.ts index f997a417..8577feea 100644 --- a/back/config/share.ts +++ b/back/config/share.ts @@ -81,4 +81,4 @@ export function createRandomString(min: number, max: number): string { } return newArr.join(''); -} +} \ No newline at end of file diff --git a/back/data/cron.ts b/back/data/cron.ts index 30124029..b234d59c 100644 --- a/back/data/cron.ts +++ b/back/data/cron.ts @@ -55,7 +55,7 @@ export enum CrontabStatus { 'disabled', } -export interface CronInstance extends Model, Crontab {} +export interface CronInstance extends Model, Crontab { } export const CrontabModel = sequelize.define('Crontab', { name: { unique: 'compositeIndex', diff --git a/back/data/open.ts b/back/data/open.ts index 1b552850..2c0ba9aa 100644 --- a/back/data/open.ts +++ b/back/data/open.ts @@ -24,13 +24,7 @@ export interface AppToken { expiration: number; } -export type AppScope = - | 'envs' - | 'crons' - | 'configs' - | 'scripts' - | 'logs' - | 'system'; +export type AppScope = 'envs' | 'crons' | 'configs' | 'scripts' | 'logs' | 'system'; export interface AppInstance extends Model, App {} export const AppModel = sequelize.define('App', { diff --git a/back/loaders/deps.ts b/back/loaders/deps.ts index 4b2e5440..767b9dfd 100644 --- a/back/loaders/deps.ts +++ b/back/loaders/deps.ts @@ -13,7 +13,7 @@ async function linkToNodeModule(src: string, dst?: string) { if (!stats) { await fs.symlink(source, target, 'dir'); } - } catch (error) {} + } catch (error) { } } async function linkCommand() { @@ -41,7 +41,7 @@ async function linkCommand() { if (stats) { await fs.unlink(tmpTarget); } - } catch (error) {} + } catch (error) { } await fs.symlink(source, tmpTarget); await fs.rename(tmpTarget, target); } diff --git a/back/protos/api.ts b/back/protos/api.ts index 24ded95f..9a7fb443 100644 --- a/back/protos/api.ts +++ b/back/protos/api.ts @@ -5,7 +5,7 @@ // source: back/protos/api.proto /* eslint-disable */ -import { BinaryReader, BinaryWriter } from '@bufbuild/protobuf/wire'; +import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire"; import { type CallOptions, ChannelCredentials, @@ -17,9 +17,9 @@ import { Metadata, type ServiceError, type UntypedServiceImplementation, -} from '@grpc/grpc-js'; +} from "@grpc/grpc-js"; -export const protobufPackage = 'com.ql.api'; +export const protobufPackage = "com.ql.api"; export enum NotificationMode { gotify = 0, @@ -49,70 +49,70 @@ export enum NotificationMode { export function notificationModeFromJSON(object: any): NotificationMode { switch (object) { case 0: - case 'gotify': + case "gotify": return NotificationMode.gotify; case 1: - case 'goCqHttpBot': + case "goCqHttpBot": return NotificationMode.goCqHttpBot; case 2: - case 'serverChan': + case "serverChan": return NotificationMode.serverChan; case 3: - case 'pushDeer': + case "pushDeer": return NotificationMode.pushDeer; case 4: - case 'bark': + case "bark": return NotificationMode.bark; case 5: - case 'chat': + case "chat": return NotificationMode.chat; case 6: - case 'telegramBot': + case "telegramBot": return NotificationMode.telegramBot; case 7: - case 'dingtalkBot': + case "dingtalkBot": return NotificationMode.dingtalkBot; case 8: - case 'weWorkBot': + case "weWorkBot": return NotificationMode.weWorkBot; case 9: - case 'weWorkApp': + case "weWorkApp": return NotificationMode.weWorkApp; case 10: - case 'aibotk': + case "aibotk": return NotificationMode.aibotk; case 11: - case 'iGot': + case "iGot": return NotificationMode.iGot; case 12: - case 'pushPlus': + case "pushPlus": return NotificationMode.pushPlus; case 13: - case 'wePlusBot': + case "wePlusBot": return NotificationMode.wePlusBot; case 14: - case 'email': + case "email": return NotificationMode.email; case 15: - case 'pushMe': + case "pushMe": return NotificationMode.pushMe; case 16: - case 'feishu': + case "feishu": return NotificationMode.feishu; case 17: - case 'webhook': + case "webhook": return NotificationMode.webhook; case 18: - case 'chronocat': + case "chronocat": return NotificationMode.chronocat; case 19: - case 'ntfy': + case "ntfy": return NotificationMode.ntfy; case 20: - case 'wxPusherBot': + case "wxPusherBot": return NotificationMode.wxPusherBot; case -1: - case 'UNRECOGNIZED': + case "UNRECOGNIZED": default: return NotificationMode.UNRECOGNIZED; } @@ -121,50 +121,50 @@ export function notificationModeFromJSON(object: any): NotificationMode { export function notificationModeToJSON(object: NotificationMode): string { switch (object) { case NotificationMode.gotify: - return 'gotify'; + return "gotify"; case NotificationMode.goCqHttpBot: - return 'goCqHttpBot'; + return "goCqHttpBot"; case NotificationMode.serverChan: - return 'serverChan'; + return "serverChan"; case NotificationMode.pushDeer: - return 'pushDeer'; + return "pushDeer"; case NotificationMode.bark: - return 'bark'; + return "bark"; case NotificationMode.chat: - return 'chat'; + return "chat"; case NotificationMode.telegramBot: - return 'telegramBot'; + return "telegramBot"; case NotificationMode.dingtalkBot: - return 'dingtalkBot'; + return "dingtalkBot"; case NotificationMode.weWorkBot: - return 'weWorkBot'; + return "weWorkBot"; case NotificationMode.weWorkApp: - return 'weWorkApp'; + return "weWorkApp"; case NotificationMode.aibotk: - return 'aibotk'; + return "aibotk"; case NotificationMode.iGot: - return 'iGot'; + return "iGot"; case NotificationMode.pushPlus: - return 'pushPlus'; + return "pushPlus"; case NotificationMode.wePlusBot: - return 'wePlusBot'; + return "wePlusBot"; case NotificationMode.email: - return 'email'; + return "email"; case NotificationMode.pushMe: - return 'pushMe'; + return "pushMe"; case NotificationMode.feishu: - return 'feishu'; + return "feishu"; case NotificationMode.webhook: - return 'webhook'; + return "webhook"; case NotificationMode.chronocat: - return 'chronocat'; + return "chronocat"; case NotificationMode.ntfy: - return 'ntfy'; + return "ntfy"; case NotificationMode.wxPusherBot: - return 'wxPusherBot'; + return "wxPusherBot"; case NotificationMode.UNRECOGNIZED: default: - return 'UNRECOGNIZED'; + return "UNRECOGNIZED"; } } @@ -392,10 +392,7 @@ function createBaseEnvItem(): EnvItem { } export const EnvItem: MessageFns = { - encode( - message: EnvItem, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: EnvItem, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.id !== undefined) { writer.uint32(8).int32(message.id); } @@ -418,8 +415,7 @@ export const EnvItem: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): EnvItem { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseEnvItem(); while (reader.pos < end) { @@ -487,15 +483,9 @@ export const EnvItem: MessageFns = { id: isSet(object.id) ? globalThis.Number(object.id) : undefined, name: isSet(object.name) ? globalThis.String(object.name) : undefined, value: isSet(object.value) ? globalThis.String(object.value) : undefined, - remarks: isSet(object.remarks) - ? globalThis.String(object.remarks) - : undefined, - status: isSet(object.status) - ? globalThis.Number(object.status) - : undefined, - position: isSet(object.position) - ? globalThis.Number(object.position) - : undefined, + remarks: isSet(object.remarks) ? globalThis.String(object.remarks) : undefined, + status: isSet(object.status) ? globalThis.Number(object.status) : undefined, + position: isSet(object.position) ? globalThis.Number(object.position) : undefined, }; }, @@ -538,23 +528,19 @@ export const EnvItem: MessageFns = { }; function createBaseGetEnvsRequest(): GetEnvsRequest { - return { searchValue: '' }; + return { searchValue: "" }; } export const GetEnvsRequest: MessageFns = { - encode( - message: GetEnvsRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { - if (message.searchValue !== '') { + encode(message: GetEnvsRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { + if (message.searchValue !== "") { writer.uint32(10).string(message.searchValue); } return writer; }, decode(input: BinaryReader | Uint8Array, length?: number): GetEnvsRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseGetEnvsRequest(); while (reader.pos < end) { @@ -578,31 +564,23 @@ export const GetEnvsRequest: MessageFns = { }, fromJSON(object: any): GetEnvsRequest { - return { - searchValue: isSet(object.searchValue) - ? globalThis.String(object.searchValue) - : '', - }; + return { searchValue: isSet(object.searchValue) ? globalThis.String(object.searchValue) : "" }; }, toJSON(message: GetEnvsRequest): unknown { const obj: any = {}; - if (message.searchValue !== '') { + if (message.searchValue !== "") { obj.searchValue = message.searchValue; } return obj; }, - create, I>>( - base?: I, - ): GetEnvsRequest { + create, I>>(base?: I): GetEnvsRequest { return GetEnvsRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): GetEnvsRequest { + fromPartial, I>>(object: I): GetEnvsRequest { const message = createBaseGetEnvsRequest(); - message.searchValue = object.searchValue ?? ''; + message.searchValue = object.searchValue ?? ""; return message; }, }; @@ -612,10 +590,7 @@ function createBaseCreateEnvRequest(): CreateEnvRequest { } export const CreateEnvRequest: MessageFns = { - encode( - message: CreateEnvRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: CreateEnvRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { for (const v of message.envs) { EnvItem.encode(v!, writer.uint32(10).fork()).join(); } @@ -623,8 +598,7 @@ export const CreateEnvRequest: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): CreateEnvRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseCreateEnvRequest(); while (reader.pos < end) { @@ -648,11 +622,7 @@ export const CreateEnvRequest: MessageFns = { }, fromJSON(object: any): CreateEnvRequest { - return { - envs: globalThis.Array.isArray(object?.envs) - ? object.envs.map((e: any) => EnvItem.fromJSON(e)) - : [], - }; + return { envs: globalThis.Array.isArray(object?.envs) ? object.envs.map((e: any) => EnvItem.fromJSON(e)) : [] }; }, toJSON(message: CreateEnvRequest): unknown { @@ -663,14 +633,10 @@ export const CreateEnvRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): CreateEnvRequest { + create, I>>(base?: I): CreateEnvRequest { return CreateEnvRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): CreateEnvRequest { + fromPartial, I>>(object: I): CreateEnvRequest { const message = createBaseCreateEnvRequest(); message.envs = object.envs?.map((e) => EnvItem.fromPartial(e)) || []; return message; @@ -682,10 +648,7 @@ function createBaseUpdateEnvRequest(): UpdateEnvRequest { } export const UpdateEnvRequest: MessageFns = { - encode( - message: UpdateEnvRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: UpdateEnvRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.env !== undefined) { EnvItem.encode(message.env, writer.uint32(10).fork()).join(); } @@ -693,8 +656,7 @@ export const UpdateEnvRequest: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): UpdateEnvRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseUpdateEnvRequest(); while (reader.pos < end) { @@ -718,9 +680,7 @@ export const UpdateEnvRequest: MessageFns = { }, fromJSON(object: any): UpdateEnvRequest { - return { - env: isSet(object.env) ? EnvItem.fromJSON(object.env) : undefined, - }; + return { env: isSet(object.env) ? EnvItem.fromJSON(object.env) : undefined }; }, toJSON(message: UpdateEnvRequest): unknown { @@ -731,19 +691,12 @@ export const UpdateEnvRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): UpdateEnvRequest { + create, I>>(base?: I): UpdateEnvRequest { return UpdateEnvRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): UpdateEnvRequest { + fromPartial, I>>(object: I): UpdateEnvRequest { const message = createBaseUpdateEnvRequest(); - message.env = - object.env !== undefined && object.env !== null - ? EnvItem.fromPartial(object.env) - : undefined; + message.env = (object.env !== undefined && object.env !== null) ? EnvItem.fromPartial(object.env) : undefined; return message; }, }; @@ -753,10 +706,7 @@ function createBaseDeleteEnvsRequest(): DeleteEnvsRequest { } export const DeleteEnvsRequest: MessageFns = { - encode( - message: DeleteEnvsRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: DeleteEnvsRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { writer.uint32(10).fork(); for (const v of message.ids) { writer.int32(v); @@ -766,8 +716,7 @@ export const DeleteEnvsRequest: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): DeleteEnvsRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseDeleteEnvsRequest(); while (reader.pos < end) { @@ -801,11 +750,7 @@ export const DeleteEnvsRequest: MessageFns = { }, fromJSON(object: any): DeleteEnvsRequest { - return { - ids: globalThis.Array.isArray(object?.ids) - ? object.ids.map((e: any) => globalThis.Number(e)) - : [], - }; + return { ids: globalThis.Array.isArray(object?.ids) ? object.ids.map((e: any) => globalThis.Number(e)) : [] }; }, toJSON(message: DeleteEnvsRequest): unknown { @@ -816,14 +761,10 @@ export const DeleteEnvsRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): DeleteEnvsRequest { + create, I>>(base?: I): DeleteEnvsRequest { return DeleteEnvsRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): DeleteEnvsRequest { + fromPartial, I>>(object: I): DeleteEnvsRequest { const message = createBaseDeleteEnvsRequest(); message.ids = object.ids?.map((e) => e) || []; return message; @@ -835,10 +776,7 @@ function createBaseMoveEnvRequest(): MoveEnvRequest { } export const MoveEnvRequest: MessageFns = { - encode( - message: MoveEnvRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: MoveEnvRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.id !== 0) { writer.uint32(8).int32(message.id); } @@ -852,8 +790,7 @@ export const MoveEnvRequest: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): MoveEnvRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseMoveEnvRequest(); while (reader.pos < end) { @@ -895,9 +832,7 @@ export const MoveEnvRequest: MessageFns = { fromJSON(object: any): MoveEnvRequest { return { id: isSet(object.id) ? globalThis.Number(object.id) : 0, - fromIndex: isSet(object.fromIndex) - ? globalThis.Number(object.fromIndex) - : 0, + fromIndex: isSet(object.fromIndex) ? globalThis.Number(object.fromIndex) : 0, toIndex: isSet(object.toIndex) ? globalThis.Number(object.toIndex) : 0, }; }, @@ -916,14 +851,10 @@ export const MoveEnvRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): MoveEnvRequest { + create, I>>(base?: I): MoveEnvRequest { return MoveEnvRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): MoveEnvRequest { + fromPartial, I>>(object: I): MoveEnvRequest { const message = createBaseMoveEnvRequest(); message.id = object.id ?? 0; message.fromIndex = object.fromIndex ?? 0; @@ -937,10 +868,7 @@ function createBaseDisableEnvsRequest(): DisableEnvsRequest { } export const DisableEnvsRequest: MessageFns = { - encode( - message: DisableEnvsRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: DisableEnvsRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { writer.uint32(10).fork(); for (const v of message.ids) { writer.int32(v); @@ -949,12 +877,8 @@ export const DisableEnvsRequest: MessageFns = { return writer; }, - decode( - input: BinaryReader | Uint8Array, - length?: number, - ): DisableEnvsRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + decode(input: BinaryReader | Uint8Array, length?: number): DisableEnvsRequest { + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseDisableEnvsRequest(); while (reader.pos < end) { @@ -988,11 +912,7 @@ export const DisableEnvsRequest: MessageFns = { }, fromJSON(object: any): DisableEnvsRequest { - return { - ids: globalThis.Array.isArray(object?.ids) - ? object.ids.map((e: any) => globalThis.Number(e)) - : [], - }; + return { ids: globalThis.Array.isArray(object?.ids) ? object.ids.map((e: any) => globalThis.Number(e)) : [] }; }, toJSON(message: DisableEnvsRequest): unknown { @@ -1003,14 +923,10 @@ export const DisableEnvsRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): DisableEnvsRequest { + create, I>>(base?: I): DisableEnvsRequest { return DisableEnvsRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): DisableEnvsRequest { + fromPartial, I>>(object: I): DisableEnvsRequest { const message = createBaseDisableEnvsRequest(); message.ids = object.ids?.map((e) => e) || []; return message; @@ -1022,10 +938,7 @@ function createBaseEnableEnvsRequest(): EnableEnvsRequest { } export const EnableEnvsRequest: MessageFns = { - encode( - message: EnableEnvsRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: EnableEnvsRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { writer.uint32(10).fork(); for (const v of message.ids) { writer.int32(v); @@ -1035,8 +948,7 @@ export const EnableEnvsRequest: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): EnableEnvsRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseEnableEnvsRequest(); while (reader.pos < end) { @@ -1070,11 +982,7 @@ export const EnableEnvsRequest: MessageFns = { }, fromJSON(object: any): EnableEnvsRequest { - return { - ids: globalThis.Array.isArray(object?.ids) - ? object.ids.map((e: any) => globalThis.Number(e)) - : [], - }; + return { ids: globalThis.Array.isArray(object?.ids) ? object.ids.map((e: any) => globalThis.Number(e)) : [] }; }, toJSON(message: EnableEnvsRequest): unknown { @@ -1085,14 +993,10 @@ export const EnableEnvsRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): EnableEnvsRequest { + create, I>>(base?: I): EnableEnvsRequest { return EnableEnvsRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): EnableEnvsRequest { + fromPartial, I>>(object: I): EnableEnvsRequest { const message = createBaseEnableEnvsRequest(); message.ids = object.ids?.map((e) => e) || []; return message; @@ -1100,31 +1004,24 @@ export const EnableEnvsRequest: MessageFns = { }; function createBaseUpdateEnvNamesRequest(): UpdateEnvNamesRequest { - return { ids: [], name: '' }; + return { ids: [], name: "" }; } export const UpdateEnvNamesRequest: MessageFns = { - encode( - message: UpdateEnvNamesRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: UpdateEnvNamesRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { writer.uint32(10).fork(); for (const v of message.ids) { writer.int32(v); } writer.join(); - if (message.name !== '') { + if (message.name !== "") { writer.uint32(18).string(message.name); } return writer; }, - decode( - input: BinaryReader | Uint8Array, - length?: number, - ): UpdateEnvNamesRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + decode(input: BinaryReader | Uint8Array, length?: number): UpdateEnvNamesRequest { + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseUpdateEnvNamesRequest(); while (reader.pos < end) { @@ -1167,10 +1064,8 @@ export const UpdateEnvNamesRequest: MessageFns = { fromJSON(object: any): UpdateEnvNamesRequest { return { - ids: globalThis.Array.isArray(object?.ids) - ? object.ids.map((e: any) => globalThis.Number(e)) - : [], - name: isSet(object.name) ? globalThis.String(object.name) : '', + ids: globalThis.Array.isArray(object?.ids) ? object.ids.map((e: any) => globalThis.Number(e)) : [], + name: isSet(object.name) ? globalThis.String(object.name) : "", }; }, @@ -1179,23 +1074,19 @@ export const UpdateEnvNamesRequest: MessageFns = { if (message.ids?.length) { obj.ids = message.ids.map((e) => Math.round(e)); } - if (message.name !== '') { + if (message.name !== "") { obj.name = message.name; } return obj; }, - create, I>>( - base?: I, - ): UpdateEnvNamesRequest { + create, I>>(base?: I): UpdateEnvNamesRequest { return UpdateEnvNamesRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): UpdateEnvNamesRequest { + fromPartial, I>>(object: I): UpdateEnvNamesRequest { const message = createBaseUpdateEnvNamesRequest(); message.ids = object.ids?.map((e) => e) || []; - message.name = object.name ?? ''; + message.name = object.name ?? ""; return message; }, }; @@ -1205,10 +1096,7 @@ function createBaseGetEnvByIdRequest(): GetEnvByIdRequest { } export const GetEnvByIdRequest: MessageFns = { - encode( - message: GetEnvByIdRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: GetEnvByIdRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.id !== 0) { writer.uint32(8).int32(message.id); } @@ -1216,8 +1104,7 @@ export const GetEnvByIdRequest: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): GetEnvByIdRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseGetEnvByIdRequest(); while (reader.pos < end) { @@ -1252,14 +1139,10 @@ export const GetEnvByIdRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): GetEnvByIdRequest { + create, I>>(base?: I): GetEnvByIdRequest { return GetEnvByIdRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): GetEnvByIdRequest { + fromPartial, I>>(object: I): GetEnvByIdRequest { const message = createBaseGetEnvByIdRequest(); message.id = object.id ?? 0; return message; @@ -1271,10 +1154,7 @@ function createBaseEnvsResponse(): EnvsResponse { } export const EnvsResponse: MessageFns = { - encode( - message: EnvsResponse, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: EnvsResponse, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.code !== 0) { writer.uint32(8).int32(message.code); } @@ -1288,8 +1168,7 @@ export const EnvsResponse: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): EnvsResponse { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseEnvsResponse(); while (reader.pos < end) { @@ -1331,12 +1210,8 @@ export const EnvsResponse: MessageFns = { fromJSON(object: any): EnvsResponse { return { code: isSet(object.code) ? globalThis.Number(object.code) : 0, - data: globalThis.Array.isArray(object?.data) - ? object.data.map((e: any) => EnvItem.fromJSON(e)) - : [], - message: isSet(object.message) - ? globalThis.String(object.message) - : undefined, + data: globalThis.Array.isArray(object?.data) ? object.data.map((e: any) => EnvItem.fromJSON(e)) : [], + message: isSet(object.message) ? globalThis.String(object.message) : undefined, }; }, @@ -1354,14 +1229,10 @@ export const EnvsResponse: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): EnvsResponse { + create, I>>(base?: I): EnvsResponse { return EnvsResponse.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): EnvsResponse { + fromPartial, I>>(object: I): EnvsResponse { const message = createBaseEnvsResponse(); message.code = object.code ?? 0; message.data = object.data?.map((e) => EnvItem.fromPartial(e)) || []; @@ -1375,10 +1246,7 @@ function createBaseEnvResponse(): EnvResponse { } export const EnvResponse: MessageFns = { - encode( - message: EnvResponse, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: EnvResponse, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.code !== 0) { writer.uint32(8).int32(message.code); } @@ -1392,8 +1260,7 @@ export const EnvResponse: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): EnvResponse { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseEnvResponse(); while (reader.pos < end) { @@ -1436,9 +1303,7 @@ export const EnvResponse: MessageFns = { return { code: isSet(object.code) ? globalThis.Number(object.code) : 0, data: isSet(object.data) ? EnvItem.fromJSON(object.data) : undefined, - message: isSet(object.message) - ? globalThis.String(object.message) - : undefined, + message: isSet(object.message) ? globalThis.String(object.message) : undefined, }; }, @@ -1459,15 +1324,10 @@ export const EnvResponse: MessageFns = { create, I>>(base?: I): EnvResponse { return EnvResponse.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): EnvResponse { + fromPartial, I>>(object: I): EnvResponse { const message = createBaseEnvResponse(); message.code = object.code ?? 0; - message.data = - object.data !== undefined && object.data !== null - ? EnvItem.fromPartial(object.data) - : undefined; + message.data = (object.data !== undefined && object.data !== null) ? EnvItem.fromPartial(object.data) : undefined; message.message = object.message ?? undefined; return message; }, @@ -1478,10 +1338,7 @@ function createBaseResponse(): Response { } export const Response: MessageFns = { - encode( - message: Response, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: Response, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.code !== 0) { writer.uint32(8).int32(message.code); } @@ -1492,8 +1349,7 @@ export const Response: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): Response { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseResponse(); while (reader.pos < end) { @@ -1527,9 +1383,7 @@ export const Response: MessageFns = { fromJSON(object: any): Response { return { code: isSet(object.code) ? globalThis.Number(object.code) : 0, - message: isSet(object.message) - ? globalThis.String(object.message) - : undefined, + message: isSet(object.message) ? globalThis.String(object.message) : undefined, }; }, @@ -1556,23 +1410,19 @@ export const Response: MessageFns = { }; function createBaseExtraScheduleItem(): ExtraScheduleItem { - return { schedule: '' }; + return { schedule: "" }; } export const ExtraScheduleItem: MessageFns = { - encode( - message: ExtraScheduleItem, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { - if (message.schedule !== '') { + encode(message: ExtraScheduleItem, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { + if (message.schedule !== "") { writer.uint32(10).string(message.schedule); } return writer; }, decode(input: BinaryReader | Uint8Array, length?: number): ExtraScheduleItem { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseExtraScheduleItem(); while (reader.pos < end) { @@ -1596,31 +1446,23 @@ export const ExtraScheduleItem: MessageFns = { }, fromJSON(object: any): ExtraScheduleItem { - return { - schedule: isSet(object.schedule) - ? globalThis.String(object.schedule) - : '', - }; + return { schedule: isSet(object.schedule) ? globalThis.String(object.schedule) : "" }; }, toJSON(message: ExtraScheduleItem): unknown { const obj: any = {}; - if (message.schedule !== '') { + if (message.schedule !== "") { obj.schedule = message.schedule; } return obj; }, - create, I>>( - base?: I, - ): ExtraScheduleItem { + create, I>>(base?: I): ExtraScheduleItem { return ExtraScheduleItem.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): ExtraScheduleItem { + fromPartial, I>>(object: I): ExtraScheduleItem { const message = createBaseExtraScheduleItem(); - message.schedule = object.schedule ?? ''; + message.schedule = object.schedule ?? ""; return message; }, }; @@ -1645,10 +1487,7 @@ function createBaseCronItem(): CronItem { } export const CronItem: MessageFns = { - encode( - message: CronItem, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: CronItem, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.id !== undefined) { writer.uint32(8).int32(message.id); } @@ -1695,8 +1534,7 @@ export const CronItem: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): CronItem { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseCronItem(); while (reader.pos < end) { @@ -1755,9 +1593,7 @@ export const CronItem: MessageFns = { break; } - message.extra_schedules.push( - ExtraScheduleItem.decode(reader, reader.uint32()), - ); + message.extra_schedules.push(ExtraScheduleItem.decode(reader, reader.uint32())); continue; } case 8: { @@ -1828,38 +1664,20 @@ export const CronItem: MessageFns = { fromJSON(object: any): CronItem { return { id: isSet(object.id) ? globalThis.Number(object.id) : undefined, - command: isSet(object.command) - ? globalThis.String(object.command) - : undefined, - schedule: isSet(object.schedule) - ? globalThis.String(object.schedule) - : undefined, + command: isSet(object.command) ? globalThis.String(object.command) : undefined, + schedule: isSet(object.schedule) ? globalThis.String(object.schedule) : undefined, name: isSet(object.name) ? globalThis.String(object.name) : undefined, - labels: globalThis.Array.isArray(object?.labels) - ? object.labels.map((e: any) => globalThis.String(e)) - : [], - sub_id: isSet(object.sub_id) - ? globalThis.Number(object.sub_id) - : undefined, + labels: globalThis.Array.isArray(object?.labels) ? object.labels.map((e: any) => globalThis.String(e)) : [], + sub_id: isSet(object.sub_id) ? globalThis.Number(object.sub_id) : undefined, extra_schedules: globalThis.Array.isArray(object?.extra_schedules) ? object.extra_schedules.map((e: any) => ExtraScheduleItem.fromJSON(e)) : [], - task_before: isSet(object.task_before) - ? globalThis.String(object.task_before) - : undefined, - task_after: isSet(object.task_after) - ? globalThis.String(object.task_after) - : undefined, - status: isSet(object.status) - ? globalThis.Number(object.status) - : undefined, - log_path: isSet(object.log_path) - ? globalThis.String(object.log_path) - : undefined, + task_before: isSet(object.task_before) ? globalThis.String(object.task_before) : undefined, + task_after: isSet(object.task_after) ? globalThis.String(object.task_after) : undefined, + status: isSet(object.status) ? globalThis.Number(object.status) : undefined, + log_path: isSet(object.log_path) ? globalThis.String(object.log_path) : undefined, pid: isSet(object.pid) ? globalThis.Number(object.pid) : undefined, - last_running_time: isSet(object.last_running_time) - ? globalThis.Number(object.last_running_time) - : undefined, + last_running_time: isSet(object.last_running_time) ? globalThis.Number(object.last_running_time) : undefined, last_execution_time: isSet(object.last_execution_time) ? globalThis.Number(object.last_execution_time) : undefined, @@ -1887,9 +1705,7 @@ export const CronItem: MessageFns = { obj.sub_id = Math.round(message.sub_id); } if (message.extra_schedules?.length) { - obj.extra_schedules = message.extra_schedules.map((e) => - ExtraScheduleItem.toJSON(e), - ); + obj.extra_schedules = message.extra_schedules.map((e) => ExtraScheduleItem.toJSON(e)); } if (message.task_before !== undefined) { obj.task_before = message.task_before; @@ -1926,9 +1742,7 @@ export const CronItem: MessageFns = { message.name = object.name ?? undefined; message.labels = object.labels?.map((e) => e) || []; message.sub_id = object.sub_id ?? undefined; - message.extra_schedules = - object.extra_schedules?.map((e) => ExtraScheduleItem.fromPartial(e)) || - []; + message.extra_schedules = object.extra_schedules?.map((e) => ExtraScheduleItem.fromPartial(e)) || []; message.task_before = object.task_before ?? undefined; message.task_after = object.task_after ?? undefined; message.status = object.status ?? undefined; @@ -1942,8 +1756,8 @@ export const CronItem: MessageFns = { function createBaseCreateCronRequest(): CreateCronRequest { return { - command: '', - schedule: '', + command: "", + schedule: "", name: undefined, labels: [], sub_id: undefined, @@ -1954,14 +1768,11 @@ function createBaseCreateCronRequest(): CreateCronRequest { } export const CreateCronRequest: MessageFns = { - encode( - message: CreateCronRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { - if (message.command !== '') { + encode(message: CreateCronRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { + if (message.command !== "") { writer.uint32(10).string(message.command); } - if (message.schedule !== '') { + if (message.schedule !== "") { writer.uint32(18).string(message.schedule); } if (message.name !== undefined) { @@ -1986,8 +1797,7 @@ export const CreateCronRequest: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): CreateCronRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseCreateCronRequest(); while (reader.pos < end) { @@ -2038,9 +1848,7 @@ export const CreateCronRequest: MessageFns = { break; } - message.extra_schedules.push( - ExtraScheduleItem.decode(reader, reader.uint32()), - ); + message.extra_schedules.push(ExtraScheduleItem.decode(reader, reader.uint32())); continue; } case 7: { @@ -2070,35 +1878,25 @@ export const CreateCronRequest: MessageFns = { fromJSON(object: any): CreateCronRequest { return { - command: isSet(object.command) ? globalThis.String(object.command) : '', - schedule: isSet(object.schedule) - ? globalThis.String(object.schedule) - : '', + command: isSet(object.command) ? globalThis.String(object.command) : "", + schedule: isSet(object.schedule) ? globalThis.String(object.schedule) : "", name: isSet(object.name) ? globalThis.String(object.name) : undefined, - labels: globalThis.Array.isArray(object?.labels) - ? object.labels.map((e: any) => globalThis.String(e)) - : [], - sub_id: isSet(object.sub_id) - ? globalThis.Number(object.sub_id) - : undefined, + labels: globalThis.Array.isArray(object?.labels) ? object.labels.map((e: any) => globalThis.String(e)) : [], + sub_id: isSet(object.sub_id) ? globalThis.Number(object.sub_id) : undefined, extra_schedules: globalThis.Array.isArray(object?.extra_schedules) ? object.extra_schedules.map((e: any) => ExtraScheduleItem.fromJSON(e)) : [], - task_before: isSet(object.task_before) - ? globalThis.String(object.task_before) - : undefined, - task_after: isSet(object.task_after) - ? globalThis.String(object.task_after) - : undefined, + task_before: isSet(object.task_before) ? globalThis.String(object.task_before) : undefined, + task_after: isSet(object.task_after) ? globalThis.String(object.task_after) : undefined, }; }, toJSON(message: CreateCronRequest): unknown { const obj: any = {}; - if (message.command !== '') { + if (message.command !== "") { obj.command = message.command; } - if (message.schedule !== '') { + if (message.schedule !== "") { obj.schedule = message.schedule; } if (message.name !== undefined) { @@ -2111,9 +1909,7 @@ export const CreateCronRequest: MessageFns = { obj.sub_id = Math.round(message.sub_id); } if (message.extra_schedules?.length) { - obj.extra_schedules = message.extra_schedules.map((e) => - ExtraScheduleItem.toJSON(e), - ); + obj.extra_schedules = message.extra_schedules.map((e) => ExtraScheduleItem.toJSON(e)); } if (message.task_before !== undefined) { obj.task_before = message.task_before; @@ -2124,23 +1920,17 @@ export const CreateCronRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): CreateCronRequest { + create, I>>(base?: I): CreateCronRequest { return CreateCronRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): CreateCronRequest { + fromPartial, I>>(object: I): CreateCronRequest { const message = createBaseCreateCronRequest(); - message.command = object.command ?? ''; - message.schedule = object.schedule ?? ''; + message.command = object.command ?? ""; + message.schedule = object.schedule ?? ""; message.name = object.name ?? undefined; message.labels = object.labels?.map((e) => e) || []; message.sub_id = object.sub_id ?? undefined; - message.extra_schedules = - object.extra_schedules?.map((e) => ExtraScheduleItem.fromPartial(e)) || - []; + message.extra_schedules = object.extra_schedules?.map((e) => ExtraScheduleItem.fromPartial(e)) || []; message.task_before = object.task_before ?? undefined; message.task_after = object.task_after ?? undefined; return message; @@ -2162,10 +1952,7 @@ function createBaseUpdateCronRequest(): UpdateCronRequest { } export const UpdateCronRequest: MessageFns = { - encode( - message: UpdateCronRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: UpdateCronRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.id !== 0) { writer.uint32(8).int32(message.id); } @@ -2197,8 +1984,7 @@ export const UpdateCronRequest: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): UpdateCronRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseUpdateCronRequest(); while (reader.pos < end) { @@ -2257,9 +2043,7 @@ export const UpdateCronRequest: MessageFns = { break; } - message.extra_schedules.push( - ExtraScheduleItem.decode(reader, reader.uint32()), - ); + message.extra_schedules.push(ExtraScheduleItem.decode(reader, reader.uint32())); continue; } case 8: { @@ -2290,28 +2074,16 @@ export const UpdateCronRequest: MessageFns = { fromJSON(object: any): UpdateCronRequest { return { id: isSet(object.id) ? globalThis.Number(object.id) : 0, - command: isSet(object.command) - ? globalThis.String(object.command) - : undefined, - schedule: isSet(object.schedule) - ? globalThis.String(object.schedule) - : undefined, + command: isSet(object.command) ? globalThis.String(object.command) : undefined, + schedule: isSet(object.schedule) ? globalThis.String(object.schedule) : undefined, name: isSet(object.name) ? globalThis.String(object.name) : undefined, - labels: globalThis.Array.isArray(object?.labels) - ? object.labels.map((e: any) => globalThis.String(e)) - : [], - sub_id: isSet(object.sub_id) - ? globalThis.Number(object.sub_id) - : undefined, + labels: globalThis.Array.isArray(object?.labels) ? object.labels.map((e: any) => globalThis.String(e)) : [], + sub_id: isSet(object.sub_id) ? globalThis.Number(object.sub_id) : undefined, extra_schedules: globalThis.Array.isArray(object?.extra_schedules) ? object.extra_schedules.map((e: any) => ExtraScheduleItem.fromJSON(e)) : [], - task_before: isSet(object.task_before) - ? globalThis.String(object.task_before) - : undefined, - task_after: isSet(object.task_after) - ? globalThis.String(object.task_after) - : undefined, + task_before: isSet(object.task_before) ? globalThis.String(object.task_before) : undefined, + task_after: isSet(object.task_after) ? globalThis.String(object.task_after) : undefined, }; }, @@ -2336,9 +2108,7 @@ export const UpdateCronRequest: MessageFns = { obj.sub_id = Math.round(message.sub_id); } if (message.extra_schedules?.length) { - obj.extra_schedules = message.extra_schedules.map((e) => - ExtraScheduleItem.toJSON(e), - ); + obj.extra_schedules = message.extra_schedules.map((e) => ExtraScheduleItem.toJSON(e)); } if (message.task_before !== undefined) { obj.task_before = message.task_before; @@ -2349,14 +2119,10 @@ export const UpdateCronRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): UpdateCronRequest { + create, I>>(base?: I): UpdateCronRequest { return UpdateCronRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): UpdateCronRequest { + fromPartial, I>>(object: I): UpdateCronRequest { const message = createBaseUpdateCronRequest(); message.id = object.id ?? 0; message.command = object.command ?? undefined; @@ -2364,9 +2130,7 @@ export const UpdateCronRequest: MessageFns = { message.name = object.name ?? undefined; message.labels = object.labels?.map((e) => e) || []; message.sub_id = object.sub_id ?? undefined; - message.extra_schedules = - object.extra_schedules?.map((e) => ExtraScheduleItem.fromPartial(e)) || - []; + message.extra_schedules = object.extra_schedules?.map((e) => ExtraScheduleItem.fromPartial(e)) || []; message.task_before = object.task_before ?? undefined; message.task_after = object.task_after ?? undefined; return message; @@ -2378,10 +2142,7 @@ function createBaseDeleteCronsRequest(): DeleteCronsRequest { } export const DeleteCronsRequest: MessageFns = { - encode( - message: DeleteCronsRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: DeleteCronsRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { writer.uint32(10).fork(); for (const v of message.ids) { writer.int32(v); @@ -2390,12 +2151,8 @@ export const DeleteCronsRequest: MessageFns = { return writer; }, - decode( - input: BinaryReader | Uint8Array, - length?: number, - ): DeleteCronsRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + decode(input: BinaryReader | Uint8Array, length?: number): DeleteCronsRequest { + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseDeleteCronsRequest(); while (reader.pos < end) { @@ -2429,11 +2186,7 @@ export const DeleteCronsRequest: MessageFns = { }, fromJSON(object: any): DeleteCronsRequest { - return { - ids: globalThis.Array.isArray(object?.ids) - ? object.ids.map((e: any) => globalThis.Number(e)) - : [], - }; + return { ids: globalThis.Array.isArray(object?.ids) ? object.ids.map((e: any) => globalThis.Number(e)) : [] }; }, toJSON(message: DeleteCronsRequest): unknown { @@ -2444,14 +2197,10 @@ export const DeleteCronsRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): DeleteCronsRequest { + create, I>>(base?: I): DeleteCronsRequest { return DeleteCronsRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): DeleteCronsRequest { + fromPartial, I>>(object: I): DeleteCronsRequest { const message = createBaseDeleteCronsRequest(); message.ids = object.ids?.map((e) => e) || []; return message; @@ -2463,10 +2212,7 @@ function createBaseCronsResponse(): CronsResponse { } export const CronsResponse: MessageFns = { - encode( - message: CronsResponse, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: CronsResponse, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.code !== 0) { writer.uint32(8).int32(message.code); } @@ -2480,8 +2226,7 @@ export const CronsResponse: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): CronsResponse { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseCronsResponse(); while (reader.pos < end) { @@ -2523,12 +2268,8 @@ export const CronsResponse: MessageFns = { fromJSON(object: any): CronsResponse { return { code: isSet(object.code) ? globalThis.Number(object.code) : 0, - data: globalThis.Array.isArray(object?.data) - ? object.data.map((e: any) => CronItem.fromJSON(e)) - : [], - message: isSet(object.message) - ? globalThis.String(object.message) - : undefined, + data: globalThis.Array.isArray(object?.data) ? object.data.map((e: any) => CronItem.fromJSON(e)) : [], + message: isSet(object.message) ? globalThis.String(object.message) : undefined, }; }, @@ -2546,14 +2287,10 @@ export const CronsResponse: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): CronsResponse { + create, I>>(base?: I): CronsResponse { return CronsResponse.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): CronsResponse { + fromPartial, I>>(object: I): CronsResponse { const message = createBaseCronsResponse(); message.code = object.code ?? 0; message.data = object.data?.map((e) => CronItem.fromPartial(e)) || []; @@ -2567,10 +2304,7 @@ function createBaseCronResponse(): CronResponse { } export const CronResponse: MessageFns = { - encode( - message: CronResponse, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: CronResponse, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.code !== 0) { writer.uint32(8).int32(message.code); } @@ -2584,8 +2318,7 @@ export const CronResponse: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): CronResponse { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseCronResponse(); while (reader.pos < end) { @@ -2628,9 +2361,7 @@ export const CronResponse: MessageFns = { return { code: isSet(object.code) ? globalThis.Number(object.code) : 0, data: isSet(object.data) ? CronItem.fromJSON(object.data) : undefined, - message: isSet(object.message) - ? globalThis.String(object.message) - : undefined, + message: isSet(object.message) ? globalThis.String(object.message) : undefined, }; }, @@ -2648,43 +2379,32 @@ export const CronResponse: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): CronResponse { + create, I>>(base?: I): CronResponse { return CronResponse.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): CronResponse { + fromPartial, I>>(object: I): CronResponse { const message = createBaseCronResponse(); message.code = object.code ?? 0; - message.data = - object.data !== undefined && object.data !== null - ? CronItem.fromPartial(object.data) - : undefined; + message.data = (object.data !== undefined && object.data !== null) ? CronItem.fromPartial(object.data) : undefined; message.message = object.message ?? undefined; return message; }, }; function createBaseCronDetailRequest(): CronDetailRequest { - return { log_path: '' }; + return { log_path: "" }; } export const CronDetailRequest: MessageFns = { - encode( - message: CronDetailRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { - if (message.log_path !== '') { + encode(message: CronDetailRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { + if (message.log_path !== "") { writer.uint32(10).string(message.log_path); } return writer; }, decode(input: BinaryReader | Uint8Array, length?: number): CronDetailRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseCronDetailRequest(); while (reader.pos < end) { @@ -2708,31 +2428,23 @@ export const CronDetailRequest: MessageFns = { }, fromJSON(object: any): CronDetailRequest { - return { - log_path: isSet(object.log_path) - ? globalThis.String(object.log_path) - : '', - }; + return { log_path: isSet(object.log_path) ? globalThis.String(object.log_path) : "" }; }, toJSON(message: CronDetailRequest): unknown { const obj: any = {}; - if (message.log_path !== '') { + if (message.log_path !== "") { obj.log_path = message.log_path; } return obj; }, - create, I>>( - base?: I, - ): CronDetailRequest { + create, I>>(base?: I): CronDetailRequest { return CronDetailRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): CronDetailRequest { + fromPartial, I>>(object: I): CronDetailRequest { const message = createBaseCronDetailRequest(); - message.log_path = object.log_path ?? ''; + message.log_path = object.log_path ?? ""; return message; }, }; @@ -2742,10 +2454,7 @@ function createBaseCronDetailResponse(): CronDetailResponse { } export const CronDetailResponse: MessageFns = { - encode( - message: CronDetailResponse, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: CronDetailResponse, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.code !== 0) { writer.uint32(8).int32(message.code); } @@ -2758,12 +2467,8 @@ export const CronDetailResponse: MessageFns = { return writer; }, - decode( - input: BinaryReader | Uint8Array, - length?: number, - ): CronDetailResponse { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + decode(input: BinaryReader | Uint8Array, length?: number): CronDetailResponse { + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseCronDetailResponse(); while (reader.pos < end) { @@ -2806,9 +2511,7 @@ export const CronDetailResponse: MessageFns = { return { code: isSet(object.code) ? globalThis.Number(object.code) : 0, data: isSet(object.data) ? CronItem.fromJSON(object.data) : undefined, - message: isSet(object.message) - ? globalThis.String(object.message) - : undefined, + message: isSet(object.message) ? globalThis.String(object.message) : undefined, }; }, @@ -2826,20 +2529,13 @@ export const CronDetailResponse: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): CronDetailResponse { + create, I>>(base?: I): CronDetailResponse { return CronDetailResponse.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): CronDetailResponse { + fromPartial, I>>(object: I): CronDetailResponse { const message = createBaseCronDetailResponse(); message.code = object.code ?? 0; - message.data = - object.data !== undefined && object.data !== null - ? CronItem.fromPartial(object.data) - : undefined; + message.data = (object.data !== undefined && object.data !== null) ? CronItem.fromPartial(object.data) : undefined; message.message = object.message ?? undefined; return message; }, @@ -2919,10 +2615,7 @@ function createBaseNotificationInfo(): NotificationInfo { } export const NotificationInfo: MessageFns = { - encode( - message: NotificationInfo, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: NotificationInfo, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.type !== 0) { writer.uint32(8).int32(message.type); } @@ -3131,8 +2824,7 @@ export const NotificationInfo: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): NotificationInfo { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseNotificationInfo(); while (reader.pos < end) { @@ -3694,63 +3386,25 @@ export const NotificationInfo: MessageFns = { fromJSON(object: any): NotificationInfo { return { type: isSet(object.type) ? notificationModeFromJSON(object.type) : 0, - gotifyUrl: isSet(object.gotifyUrl) - ? globalThis.String(object.gotifyUrl) - : undefined, - gotifyToken: isSet(object.gotifyToken) - ? globalThis.String(object.gotifyToken) - : undefined, - gotifyPriority: isSet(object.gotifyPriority) - ? globalThis.Number(object.gotifyPriority) - : undefined, - goCqHttpBotUrl: isSet(object.goCqHttpBotUrl) - ? globalThis.String(object.goCqHttpBotUrl) - : undefined, - goCqHttpBotToken: isSet(object.goCqHttpBotToken) - ? globalThis.String(object.goCqHttpBotToken) - : undefined, - goCqHttpBotQq: isSet(object.goCqHttpBotQq) - ? globalThis.String(object.goCqHttpBotQq) - : undefined, - serverChanKey: isSet(object.serverChanKey) - ? globalThis.String(object.serverChanKey) - : undefined, - pushDeerKey: isSet(object.pushDeerKey) - ? globalThis.String(object.pushDeerKey) - : undefined, - pushDeerUrl: isSet(object.pushDeerUrl) - ? globalThis.String(object.pushDeerUrl) - : undefined, - synologyChatUrl: isSet(object.synologyChatUrl) - ? globalThis.String(object.synologyChatUrl) - : undefined, - barkPush: isSet(object.barkPush) - ? globalThis.String(object.barkPush) - : undefined, - barkIcon: isSet(object.barkIcon) - ? globalThis.String(object.barkIcon) - : undefined, - barkSound: isSet(object.barkSound) - ? globalThis.String(object.barkSound) - : undefined, - barkGroup: isSet(object.barkGroup) - ? globalThis.String(object.barkGroup) - : undefined, - barkLevel: isSet(object.barkLevel) - ? globalThis.String(object.barkLevel) - : undefined, - barkUrl: isSet(object.barkUrl) - ? globalThis.String(object.barkUrl) - : undefined, - barkArchive: isSet(object.barkArchive) - ? globalThis.String(object.barkArchive) - : undefined, - telegramBotToken: isSet(object.telegramBotToken) - ? globalThis.String(object.telegramBotToken) - : undefined, - telegramBotUserId: isSet(object.telegramBotUserId) - ? globalThis.String(object.telegramBotUserId) - : undefined, + gotifyUrl: isSet(object.gotifyUrl) ? globalThis.String(object.gotifyUrl) : undefined, + gotifyToken: isSet(object.gotifyToken) ? globalThis.String(object.gotifyToken) : undefined, + gotifyPriority: isSet(object.gotifyPriority) ? globalThis.Number(object.gotifyPriority) : undefined, + goCqHttpBotUrl: isSet(object.goCqHttpBotUrl) ? globalThis.String(object.goCqHttpBotUrl) : undefined, + goCqHttpBotToken: isSet(object.goCqHttpBotToken) ? globalThis.String(object.goCqHttpBotToken) : undefined, + goCqHttpBotQq: isSet(object.goCqHttpBotQq) ? globalThis.String(object.goCqHttpBotQq) : undefined, + serverChanKey: isSet(object.serverChanKey) ? globalThis.String(object.serverChanKey) : undefined, + pushDeerKey: isSet(object.pushDeerKey) ? globalThis.String(object.pushDeerKey) : undefined, + pushDeerUrl: isSet(object.pushDeerUrl) ? globalThis.String(object.pushDeerUrl) : undefined, + synologyChatUrl: isSet(object.synologyChatUrl) ? globalThis.String(object.synologyChatUrl) : undefined, + barkPush: isSet(object.barkPush) ? globalThis.String(object.barkPush) : undefined, + barkIcon: isSet(object.barkIcon) ? globalThis.String(object.barkIcon) : undefined, + barkSound: isSet(object.barkSound) ? globalThis.String(object.barkSound) : undefined, + barkGroup: isSet(object.barkGroup) ? globalThis.String(object.barkGroup) : undefined, + barkLevel: isSet(object.barkLevel) ? globalThis.String(object.barkLevel) : undefined, + barkUrl: isSet(object.barkUrl) ? globalThis.String(object.barkUrl) : undefined, + barkArchive: isSet(object.barkArchive) ? globalThis.String(object.barkArchive) : undefined, + telegramBotToken: isSet(object.telegramBotToken) ? globalThis.String(object.telegramBotToken) : undefined, + telegramBotUserId: isSet(object.telegramBotUserId) ? globalThis.String(object.telegramBotUserId) : undefined, telegramBotProxyHost: isSet(object.telegramBotProxyHost) ? globalThis.String(object.telegramBotProxyHost) : undefined, @@ -3760,141 +3414,57 @@ export const NotificationInfo: MessageFns = { telegramBotProxyAuth: isSet(object.telegramBotProxyAuth) ? globalThis.String(object.telegramBotProxyAuth) : undefined, - telegramBotApiHost: isSet(object.telegramBotApiHost) - ? globalThis.String(object.telegramBotApiHost) - : undefined, - dingtalkBotToken: isSet(object.dingtalkBotToken) - ? globalThis.String(object.dingtalkBotToken) - : undefined, - dingtalkBotSecret: isSet(object.dingtalkBotSecret) - ? globalThis.String(object.dingtalkBotSecret) - : undefined, - weWorkBotKey: isSet(object.weWorkBotKey) - ? globalThis.String(object.weWorkBotKey) - : undefined, - weWorkOrigin: isSet(object.weWorkOrigin) - ? globalThis.String(object.weWorkOrigin) - : undefined, - weWorkAppKey: isSet(object.weWorkAppKey) - ? globalThis.String(object.weWorkAppKey) - : undefined, - aibotkKey: isSet(object.aibotkKey) - ? globalThis.String(object.aibotkKey) - : undefined, - aibotkType: isSet(object.aibotkType) - ? globalThis.String(object.aibotkType) - : undefined, - aibotkName: isSet(object.aibotkName) - ? globalThis.String(object.aibotkName) - : undefined, - iGotPushKey: isSet(object.iGotPushKey) - ? globalThis.String(object.iGotPushKey) - : undefined, - pushPlusToken: isSet(object.pushPlusToken) - ? globalThis.String(object.pushPlusToken) - : undefined, - pushPlusUser: isSet(object.pushPlusUser) - ? globalThis.String(object.pushPlusUser) - : undefined, - pushPlusTemplate: isSet(object.pushPlusTemplate) - ? globalThis.String(object.pushPlusTemplate) - : undefined, - pushplusChannel: isSet(object.pushplusChannel) - ? globalThis.String(object.pushplusChannel) - : undefined, - pushplusWebhook: isSet(object.pushplusWebhook) - ? globalThis.String(object.pushplusWebhook) - : undefined, + telegramBotApiHost: isSet(object.telegramBotApiHost) ? globalThis.String(object.telegramBotApiHost) : undefined, + dingtalkBotToken: isSet(object.dingtalkBotToken) ? globalThis.String(object.dingtalkBotToken) : undefined, + dingtalkBotSecret: isSet(object.dingtalkBotSecret) ? globalThis.String(object.dingtalkBotSecret) : undefined, + weWorkBotKey: isSet(object.weWorkBotKey) ? globalThis.String(object.weWorkBotKey) : undefined, + weWorkOrigin: isSet(object.weWorkOrigin) ? globalThis.String(object.weWorkOrigin) : undefined, + weWorkAppKey: isSet(object.weWorkAppKey) ? globalThis.String(object.weWorkAppKey) : undefined, + aibotkKey: isSet(object.aibotkKey) ? globalThis.String(object.aibotkKey) : undefined, + aibotkType: isSet(object.aibotkType) ? globalThis.String(object.aibotkType) : undefined, + aibotkName: isSet(object.aibotkName) ? globalThis.String(object.aibotkName) : undefined, + iGotPushKey: isSet(object.iGotPushKey) ? globalThis.String(object.iGotPushKey) : undefined, + pushPlusToken: isSet(object.pushPlusToken) ? globalThis.String(object.pushPlusToken) : undefined, + pushPlusUser: isSet(object.pushPlusUser) ? globalThis.String(object.pushPlusUser) : undefined, + pushPlusTemplate: isSet(object.pushPlusTemplate) ? globalThis.String(object.pushPlusTemplate) : undefined, + pushplusChannel: isSet(object.pushplusChannel) ? globalThis.String(object.pushplusChannel) : undefined, + pushplusWebhook: isSet(object.pushplusWebhook) ? globalThis.String(object.pushplusWebhook) : undefined, pushplusCallbackUrl: isSet(object.pushplusCallbackUrl) ? globalThis.String(object.pushplusCallbackUrl) : undefined, - pushplusTo: isSet(object.pushplusTo) - ? globalThis.String(object.pushplusTo) - : undefined, - wePlusBotToken: isSet(object.wePlusBotToken) - ? globalThis.String(object.wePlusBotToken) - : undefined, - wePlusBotReceiver: isSet(object.wePlusBotReceiver) - ? globalThis.String(object.wePlusBotReceiver) - : undefined, - wePlusBotVersion: isSet(object.wePlusBotVersion) - ? globalThis.String(object.wePlusBotVersion) - : undefined, - emailService: isSet(object.emailService) - ? globalThis.String(object.emailService) - : undefined, - emailUser: isSet(object.emailUser) - ? globalThis.String(object.emailUser) - : undefined, - emailPass: isSet(object.emailPass) - ? globalThis.String(object.emailPass) - : undefined, - emailTo: isSet(object.emailTo) - ? globalThis.String(object.emailTo) - : undefined, - pushMeKey: isSet(object.pushMeKey) - ? globalThis.String(object.pushMeKey) - : undefined, - pushMeUrl: isSet(object.pushMeUrl) - ? globalThis.String(object.pushMeUrl) - : undefined, - chronocatURL: isSet(object.chronocatURL) - ? globalThis.String(object.chronocatURL) - : undefined, - chronocatQQ: isSet(object.chronocatQQ) - ? globalThis.String(object.chronocatQQ) - : undefined, - chronocatToken: isSet(object.chronocatToken) - ? globalThis.String(object.chronocatToken) - : undefined, - webhookHeaders: isSet(object.webhookHeaders) - ? globalThis.String(object.webhookHeaders) - : undefined, - webhookBody: isSet(object.webhookBody) - ? globalThis.String(object.webhookBody) - : undefined, - webhookUrl: isSet(object.webhookUrl) - ? globalThis.String(object.webhookUrl) - : undefined, - webhookMethod: isSet(object.webhookMethod) - ? globalThis.String(object.webhookMethod) - : undefined, - webhookContentType: isSet(object.webhookContentType) - ? globalThis.String(object.webhookContentType) - : undefined, - larkKey: isSet(object.larkKey) - ? globalThis.String(object.larkKey) - : undefined, - ntfyUrl: isSet(object.ntfyUrl) - ? globalThis.String(object.ntfyUrl) - : undefined, - ntfyTopic: isSet(object.ntfyTopic) - ? globalThis.String(object.ntfyTopic) - : undefined, - ntfyPriority: isSet(object.ntfyPriority) - ? globalThis.String(object.ntfyPriority) - : undefined, - ntfyToken: isSet(object.ntfyToken) - ? globalThis.String(object.ntfyToken) - : undefined, - ntfyUsername: isSet(object.ntfyUsername) - ? globalThis.String(object.ntfyUsername) - : undefined, - ntfyPassword: isSet(object.ntfyPassword) - ? globalThis.String(object.ntfyPassword) - : undefined, - ntfyActions: isSet(object.ntfyActions) - ? globalThis.String(object.ntfyActions) - : undefined, + pushplusTo: isSet(object.pushplusTo) ? globalThis.String(object.pushplusTo) : undefined, + wePlusBotToken: isSet(object.wePlusBotToken) ? globalThis.String(object.wePlusBotToken) : undefined, + wePlusBotReceiver: isSet(object.wePlusBotReceiver) ? globalThis.String(object.wePlusBotReceiver) : undefined, + wePlusBotVersion: isSet(object.wePlusBotVersion) ? globalThis.String(object.wePlusBotVersion) : undefined, + emailService: isSet(object.emailService) ? globalThis.String(object.emailService) : undefined, + emailUser: isSet(object.emailUser) ? globalThis.String(object.emailUser) : undefined, + emailPass: isSet(object.emailPass) ? globalThis.String(object.emailPass) : undefined, + emailTo: isSet(object.emailTo) ? globalThis.String(object.emailTo) : undefined, + pushMeKey: isSet(object.pushMeKey) ? globalThis.String(object.pushMeKey) : undefined, + pushMeUrl: isSet(object.pushMeUrl) ? globalThis.String(object.pushMeUrl) : undefined, + chronocatURL: isSet(object.chronocatURL) ? globalThis.String(object.chronocatURL) : undefined, + chronocatQQ: isSet(object.chronocatQQ) ? globalThis.String(object.chronocatQQ) : undefined, + chronocatToken: isSet(object.chronocatToken) ? globalThis.String(object.chronocatToken) : undefined, + webhookHeaders: isSet(object.webhookHeaders) ? globalThis.String(object.webhookHeaders) : undefined, + webhookBody: isSet(object.webhookBody) ? globalThis.String(object.webhookBody) : undefined, + webhookUrl: isSet(object.webhookUrl) ? globalThis.String(object.webhookUrl) : undefined, + webhookMethod: isSet(object.webhookMethod) ? globalThis.String(object.webhookMethod) : undefined, + webhookContentType: isSet(object.webhookContentType) ? globalThis.String(object.webhookContentType) : undefined, + larkKey: isSet(object.larkKey) ? globalThis.String(object.larkKey) : undefined, + ntfyUrl: isSet(object.ntfyUrl) ? globalThis.String(object.ntfyUrl) : undefined, + ntfyTopic: isSet(object.ntfyTopic) ? globalThis.String(object.ntfyTopic) : undefined, + ntfyPriority: isSet(object.ntfyPriority) ? globalThis.String(object.ntfyPriority) : undefined, + ntfyToken: isSet(object.ntfyToken) ? globalThis.String(object.ntfyToken) : undefined, + ntfyUsername: isSet(object.ntfyUsername) ? globalThis.String(object.ntfyUsername) : undefined, + ntfyPassword: isSet(object.ntfyPassword) ? globalThis.String(object.ntfyPassword) : undefined, + ntfyActions: isSet(object.ntfyActions) ? globalThis.String(object.ntfyActions) : undefined, wxPusherBotAppToken: isSet(object.wxPusherBotAppToken) ? globalThis.String(object.wxPusherBotAppToken) : undefined, wxPusherBotTopicIds: isSet(object.wxPusherBotTopicIds) ? globalThis.String(object.wxPusherBotTopicIds) : undefined, - wxPusherBotUids: isSet(object.wxPusherBotUids) - ? globalThis.String(object.wxPusherBotUids) - : undefined, + wxPusherBotUids: isSet(object.wxPusherBotUids) ? globalThis.String(object.wxPusherBotUids) : undefined, }; }, @@ -4107,14 +3677,10 @@ export const NotificationInfo: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): NotificationInfo { + create, I>>(base?: I): NotificationInfo { return NotificationInfo.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): NotificationInfo { + fromPartial, I>>(object: I): NotificationInfo { const message = createBaseNotificationInfo(); message.type = object.type ?? 0; message.gotifyUrl = object.gotifyUrl ?? undefined; @@ -4189,35 +3755,25 @@ export const NotificationInfo: MessageFns = { }; function createBaseSystemNotifyRequest(): SystemNotifyRequest { - return { title: '', content: '', notificationInfo: undefined }; + return { title: "", content: "", notificationInfo: undefined }; } export const SystemNotifyRequest: MessageFns = { - encode( - message: SystemNotifyRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { - if (message.title !== '') { + encode(message: SystemNotifyRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { + if (message.title !== "") { writer.uint32(10).string(message.title); } - if (message.content !== '') { + if (message.content !== "") { writer.uint32(18).string(message.content); } if (message.notificationInfo !== undefined) { - NotificationInfo.encode( - message.notificationInfo, - writer.uint32(26).fork(), - ).join(); + NotificationInfo.encode(message.notificationInfo, writer.uint32(26).fork()).join(); } return writer; }, - decode( - input: BinaryReader | Uint8Array, - length?: number, - ): SystemNotifyRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + decode(input: BinaryReader | Uint8Array, length?: number): SystemNotifyRequest { + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseSystemNotifyRequest(); while (reader.pos < end) { @@ -4244,10 +3800,7 @@ export const SystemNotifyRequest: MessageFns = { break; } - message.notificationInfo = NotificationInfo.decode( - reader, - reader.uint32(), - ); + message.notificationInfo = NotificationInfo.decode(reader, reader.uint32()); continue; } } @@ -4261,20 +3814,18 @@ export const SystemNotifyRequest: MessageFns = { fromJSON(object: any): SystemNotifyRequest { return { - title: isSet(object.title) ? globalThis.String(object.title) : '', - content: isSet(object.content) ? globalThis.String(object.content) : '', - notificationInfo: isSet(object.notificationInfo) - ? NotificationInfo.fromJSON(object.notificationInfo) - : undefined, + title: isSet(object.title) ? globalThis.String(object.title) : "", + content: isSet(object.content) ? globalThis.String(object.content) : "", + notificationInfo: isSet(object.notificationInfo) ? NotificationInfo.fromJSON(object.notificationInfo) : undefined, }; }, toJSON(message: SystemNotifyRequest): unknown { const obj: any = {}; - if (message.title !== '') { + if (message.title !== "") { obj.title = message.title; } - if (message.content !== '') { + if (message.content !== "") { obj.content = message.content; } if (message.notificationInfo !== undefined) { @@ -4283,21 +3834,16 @@ export const SystemNotifyRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): SystemNotifyRequest { + create, I>>(base?: I): SystemNotifyRequest { return SystemNotifyRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): SystemNotifyRequest { + fromPartial, I>>(object: I): SystemNotifyRequest { const message = createBaseSystemNotifyRequest(); - message.title = object.title ?? ''; - message.content = object.content ?? ''; - message.notificationInfo = - object.notificationInfo !== undefined && object.notificationInfo !== null - ? NotificationInfo.fromPartial(object.notificationInfo) - : undefined; + message.title = object.title ?? ""; + message.content = object.content ?? ""; + message.notificationInfo = (object.notificationInfo !== undefined && object.notificationInfo !== null) + ? NotificationInfo.fromPartial(object.notificationInfo) + : undefined; return message; }, }; @@ -4305,157 +3851,129 @@ export const SystemNotifyRequest: MessageFns = { export type ApiService = typeof ApiService; export const ApiService = { getEnvs: { - path: '/com.ql.api.Api/GetEnvs', + path: "/com.ql.api.Api/GetEnvs", requestStream: false, responseStream: false, - requestSerialize: (value: GetEnvsRequest) => - Buffer.from(GetEnvsRequest.encode(value).finish()), + requestSerialize: (value: GetEnvsRequest) => Buffer.from(GetEnvsRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => GetEnvsRequest.decode(value), - responseSerialize: (value: EnvsResponse) => - Buffer.from(EnvsResponse.encode(value).finish()), + responseSerialize: (value: EnvsResponse) => Buffer.from(EnvsResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => EnvsResponse.decode(value), }, createEnv: { - path: '/com.ql.api.Api/CreateEnv', + path: "/com.ql.api.Api/CreateEnv", requestStream: false, responseStream: false, - requestSerialize: (value: CreateEnvRequest) => - Buffer.from(CreateEnvRequest.encode(value).finish()), + requestSerialize: (value: CreateEnvRequest) => Buffer.from(CreateEnvRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => CreateEnvRequest.decode(value), - responseSerialize: (value: EnvsResponse) => - Buffer.from(EnvsResponse.encode(value).finish()), + responseSerialize: (value: EnvsResponse) => Buffer.from(EnvsResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => EnvsResponse.decode(value), }, updateEnv: { - path: '/com.ql.api.Api/UpdateEnv', + path: "/com.ql.api.Api/UpdateEnv", requestStream: false, responseStream: false, - requestSerialize: (value: UpdateEnvRequest) => - Buffer.from(UpdateEnvRequest.encode(value).finish()), + requestSerialize: (value: UpdateEnvRequest) => Buffer.from(UpdateEnvRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => UpdateEnvRequest.decode(value), - responseSerialize: (value: EnvResponse) => - Buffer.from(EnvResponse.encode(value).finish()), + responseSerialize: (value: EnvResponse) => Buffer.from(EnvResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => EnvResponse.decode(value), }, deleteEnvs: { - path: '/com.ql.api.Api/DeleteEnvs', + path: "/com.ql.api.Api/DeleteEnvs", requestStream: false, responseStream: false, - requestSerialize: (value: DeleteEnvsRequest) => - Buffer.from(DeleteEnvsRequest.encode(value).finish()), + requestSerialize: (value: DeleteEnvsRequest) => Buffer.from(DeleteEnvsRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => DeleteEnvsRequest.decode(value), - responseSerialize: (value: Response) => - Buffer.from(Response.encode(value).finish()), + responseSerialize: (value: Response) => Buffer.from(Response.encode(value).finish()), responseDeserialize: (value: Buffer) => Response.decode(value), }, moveEnv: { - path: '/com.ql.api.Api/MoveEnv', + path: "/com.ql.api.Api/MoveEnv", requestStream: false, responseStream: false, - requestSerialize: (value: MoveEnvRequest) => - Buffer.from(MoveEnvRequest.encode(value).finish()), + requestSerialize: (value: MoveEnvRequest) => Buffer.from(MoveEnvRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => MoveEnvRequest.decode(value), - responseSerialize: (value: EnvResponse) => - Buffer.from(EnvResponse.encode(value).finish()), + responseSerialize: (value: EnvResponse) => Buffer.from(EnvResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => EnvResponse.decode(value), }, disableEnvs: { - path: '/com.ql.api.Api/DisableEnvs', + path: "/com.ql.api.Api/DisableEnvs", requestStream: false, responseStream: false, - requestSerialize: (value: DisableEnvsRequest) => - Buffer.from(DisableEnvsRequest.encode(value).finish()), + requestSerialize: (value: DisableEnvsRequest) => Buffer.from(DisableEnvsRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => DisableEnvsRequest.decode(value), - responseSerialize: (value: Response) => - Buffer.from(Response.encode(value).finish()), + responseSerialize: (value: Response) => Buffer.from(Response.encode(value).finish()), responseDeserialize: (value: Buffer) => Response.decode(value), }, enableEnvs: { - path: '/com.ql.api.Api/EnableEnvs', + path: "/com.ql.api.Api/EnableEnvs", requestStream: false, responseStream: false, - requestSerialize: (value: EnableEnvsRequest) => - Buffer.from(EnableEnvsRequest.encode(value).finish()), + requestSerialize: (value: EnableEnvsRequest) => Buffer.from(EnableEnvsRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => EnableEnvsRequest.decode(value), - responseSerialize: (value: Response) => - Buffer.from(Response.encode(value).finish()), + responseSerialize: (value: Response) => Buffer.from(Response.encode(value).finish()), responseDeserialize: (value: Buffer) => Response.decode(value), }, updateEnvNames: { - path: '/com.ql.api.Api/UpdateEnvNames', + path: "/com.ql.api.Api/UpdateEnvNames", requestStream: false, responseStream: false, - requestSerialize: (value: UpdateEnvNamesRequest) => - Buffer.from(UpdateEnvNamesRequest.encode(value).finish()), + requestSerialize: (value: UpdateEnvNamesRequest) => Buffer.from(UpdateEnvNamesRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => UpdateEnvNamesRequest.decode(value), - responseSerialize: (value: Response) => - Buffer.from(Response.encode(value).finish()), + responseSerialize: (value: Response) => Buffer.from(Response.encode(value).finish()), responseDeserialize: (value: Buffer) => Response.decode(value), }, getEnvById: { - path: '/com.ql.api.Api/GetEnvById', + path: "/com.ql.api.Api/GetEnvById", requestStream: false, responseStream: false, - requestSerialize: (value: GetEnvByIdRequest) => - Buffer.from(GetEnvByIdRequest.encode(value).finish()), + requestSerialize: (value: GetEnvByIdRequest) => Buffer.from(GetEnvByIdRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => GetEnvByIdRequest.decode(value), - responseSerialize: (value: EnvResponse) => - Buffer.from(EnvResponse.encode(value).finish()), + responseSerialize: (value: EnvResponse) => Buffer.from(EnvResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => EnvResponse.decode(value), }, systemNotify: { - path: '/com.ql.api.Api/SystemNotify', + path: "/com.ql.api.Api/SystemNotify", requestStream: false, responseStream: false, - requestSerialize: (value: SystemNotifyRequest) => - Buffer.from(SystemNotifyRequest.encode(value).finish()), + requestSerialize: (value: SystemNotifyRequest) => Buffer.from(SystemNotifyRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => SystemNotifyRequest.decode(value), - responseSerialize: (value: Response) => - Buffer.from(Response.encode(value).finish()), + responseSerialize: (value: Response) => Buffer.from(Response.encode(value).finish()), responseDeserialize: (value: Buffer) => Response.decode(value), }, getCronDetail: { - path: '/com.ql.api.Api/GetCronDetail', + path: "/com.ql.api.Api/GetCronDetail", requestStream: false, responseStream: false, - requestSerialize: (value: CronDetailRequest) => - Buffer.from(CronDetailRequest.encode(value).finish()), + requestSerialize: (value: CronDetailRequest) => Buffer.from(CronDetailRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => CronDetailRequest.decode(value), - responseSerialize: (value: CronDetailResponse) => - Buffer.from(CronDetailResponse.encode(value).finish()), + responseSerialize: (value: CronDetailResponse) => Buffer.from(CronDetailResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => CronDetailResponse.decode(value), }, createCron: { - path: '/com.ql.api.Api/CreateCron', + path: "/com.ql.api.Api/CreateCron", requestStream: false, responseStream: false, - requestSerialize: (value: CreateCronRequest) => - Buffer.from(CreateCronRequest.encode(value).finish()), + requestSerialize: (value: CreateCronRequest) => Buffer.from(CreateCronRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => CreateCronRequest.decode(value), - responseSerialize: (value: CronResponse) => - Buffer.from(CronResponse.encode(value).finish()), + responseSerialize: (value: CronResponse) => Buffer.from(CronResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => CronResponse.decode(value), }, updateCron: { - path: '/com.ql.api.Api/UpdateCron', + path: "/com.ql.api.Api/UpdateCron", requestStream: false, responseStream: false, - requestSerialize: (value: UpdateCronRequest) => - Buffer.from(UpdateCronRequest.encode(value).finish()), + requestSerialize: (value: UpdateCronRequest) => Buffer.from(UpdateCronRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => UpdateCronRequest.decode(value), - responseSerialize: (value: CronResponse) => - Buffer.from(CronResponse.encode(value).finish()), + responseSerialize: (value: CronResponse) => Buffer.from(CronResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => CronResponse.decode(value), }, deleteCrons: { - path: '/com.ql.api.Api/DeleteCrons', + path: "/com.ql.api.Api/DeleteCrons", requestStream: false, responseStream: false, - requestSerialize: (value: DeleteCronsRequest) => - Buffer.from(DeleteCronsRequest.encode(value).finish()), + requestSerialize: (value: DeleteCronsRequest) => Buffer.from(DeleteCronsRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => DeleteCronsRequest.decode(value), - responseSerialize: (value: Response) => - Buffer.from(Response.encode(value).finish()), + responseSerialize: (value: Response) => Buffer.from(Response.encode(value).finish()), responseDeserialize: (value: Buffer) => Response.decode(value), }, } as const; @@ -4630,27 +4148,18 @@ export interface ApiClient extends Client { ): ClientUnaryCall; getCronDetail( request: CronDetailRequest, - callback: ( - error: ServiceError | null, - response: CronDetailResponse, - ) => void, + callback: (error: ServiceError | null, response: CronDetailResponse) => void, ): ClientUnaryCall; getCronDetail( request: CronDetailRequest, metadata: Metadata, - callback: ( - error: ServiceError | null, - response: CronDetailResponse, - ) => void, + callback: (error: ServiceError | null, response: CronDetailResponse) => void, ): ClientUnaryCall; getCronDetail( request: CronDetailRequest, metadata: Metadata, options: Partial, - callback: ( - error: ServiceError | null, - response: CronDetailResponse, - ) => void, + callback: (error: ServiceError | null, response: CronDetailResponse) => void, ): ClientUnaryCall; createCron( request: CreateCronRequest, @@ -4699,52 +4208,31 @@ export interface ApiClient extends Client { ): ClientUnaryCall; } -export const ApiClient = makeGenericClientConstructor( - ApiService, - 'com.ql.api.Api', -) as unknown as { - new ( - address: string, - credentials: ChannelCredentials, - options?: Partial, - ): ApiClient; +export const ApiClient = makeGenericClientConstructor(ApiService, "com.ql.api.Api") as unknown as { + new (address: string, credentials: ChannelCredentials, options?: Partial): ApiClient; service: typeof ApiService; serviceName: string; }; -type Builtin = - | Date - | Function - | Uint8Array - | string - | number - | boolean - | undefined; +type Builtin = Date | Function | Uint8Array | string | number | boolean | undefined; -export type DeepPartial = T extends Builtin - ? T - : T extends globalThis.Array - ? globalThis.Array> - : T extends ReadonlyArray - ? ReadonlyArray> - : T extends {} - ? { [K in keyof T]?: DeepPartial } +export type DeepPartial = T extends Builtin ? T + : T extends globalThis.Array ? globalThis.Array> + : T extends ReadonlyArray ? ReadonlyArray> + : T extends {} ? { [K in keyof T]?: DeepPartial } : Partial; type KeysOfUnion = T extends T ? keyof T : never; -export type Exact = P extends Builtin - ? P - : P & { [K in keyof P]: Exact } & { - [K in Exclude>]: never; - }; +export type Exact = P extends Builtin ? P + : P & { [K in keyof P]: Exact } & { [K in Exclude>]: never }; function longToNumber(int64: { toString(): string }): number { const num = globalThis.Number(int64.toString()); if (num > globalThis.Number.MAX_SAFE_INTEGER) { - throw new globalThis.Error('Value is larger than Number.MAX_SAFE_INTEGER'); + throw new globalThis.Error("Value is larger than Number.MAX_SAFE_INTEGER"); } if (num < globalThis.Number.MIN_SAFE_INTEGER) { - throw new globalThis.Error('Value is smaller than Number.MIN_SAFE_INTEGER'); + throw new globalThis.Error("Value is smaller than Number.MIN_SAFE_INTEGER"); } return num; } diff --git a/back/protos/cron.ts b/back/protos/cron.ts index 25c98ba9..8524dfaf 100644 --- a/back/protos/cron.ts +++ b/back/protos/cron.ts @@ -5,7 +5,7 @@ // source: back/protos/cron.proto /* eslint-disable */ -import { BinaryReader, BinaryWriter } from '@bufbuild/protobuf/wire'; +import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire"; import { type CallOptions, ChannelCredentials, @@ -17,9 +17,9 @@ import { Metadata, type ServiceError, type UntypedServiceImplementation, -} from '@grpc/grpc-js'; +} from "@grpc/grpc-js"; -export const protobufPackage = 'com.ql.cron'; +export const protobufPackage = "com.ql.cron"; export interface ISchedule { schedule: string; @@ -37,32 +37,30 @@ export interface AddCronRequest { crons: ICron[]; } -export interface AddCronResponse {} +export interface AddCronResponse { +} export interface DeleteCronRequest { ids: string[]; } -export interface DeleteCronResponse {} +export interface DeleteCronResponse { +} function createBaseISchedule(): ISchedule { - return { schedule: '' }; + return { schedule: "" }; } export const ISchedule: MessageFns = { - encode( - message: ISchedule, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { - if (message.schedule !== '') { + encode(message: ISchedule, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { + if (message.schedule !== "") { writer.uint32(10).string(message.schedule); } return writer; }, decode(input: BinaryReader | Uint8Array, length?: number): ISchedule { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseISchedule(); while (reader.pos < end) { @@ -86,16 +84,12 @@ export const ISchedule: MessageFns = { }, fromJSON(object: any): ISchedule { - return { - schedule: isSet(object.schedule) - ? globalThis.String(object.schedule) - : '', - }; + return { schedule: isSet(object.schedule) ? globalThis.String(object.schedule) : "" }; }, toJSON(message: ISchedule): unknown { const obj: any = {}; - if (message.schedule !== '') { + if (message.schedule !== "") { obj.schedule = message.schedule; } return obj; @@ -104,45 +98,39 @@ export const ISchedule: MessageFns = { create, I>>(base?: I): ISchedule { return ISchedule.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): ISchedule { + fromPartial, I>>(object: I): ISchedule { const message = createBaseISchedule(); - message.schedule = object.schedule ?? ''; + message.schedule = object.schedule ?? ""; return message; }, }; function createBaseICron(): ICron { - return { id: '', schedule: '', command: '', extra_schedules: [], name: '' }; + return { id: "", schedule: "", command: "", extra_schedules: [], name: "" }; } export const ICron: MessageFns = { - encode( - message: ICron, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { - if (message.id !== '') { + encode(message: ICron, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { + if (message.id !== "") { writer.uint32(10).string(message.id); } - if (message.schedule !== '') { + if (message.schedule !== "") { writer.uint32(18).string(message.schedule); } - if (message.command !== '') { + if (message.command !== "") { writer.uint32(26).string(message.command); } for (const v of message.extra_schedules) { ISchedule.encode(v!, writer.uint32(34).fork()).join(); } - if (message.name !== '') { + if (message.name !== "") { writer.uint32(42).string(message.name); } return writer; }, decode(input: BinaryReader | Uint8Array, length?: number): ICron { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseICron(); while (reader.pos < end) { @@ -177,9 +165,7 @@ export const ICron: MessageFns = { break; } - message.extra_schedules.push( - ISchedule.decode(reader, reader.uint32()), - ); + message.extra_schedules.push(ISchedule.decode(reader, reader.uint32())); continue; } case 5: { @@ -201,35 +187,31 @@ export const ICron: MessageFns = { fromJSON(object: any): ICron { return { - id: isSet(object.id) ? globalThis.String(object.id) : '', - schedule: isSet(object.schedule) - ? globalThis.String(object.schedule) - : '', - command: isSet(object.command) ? globalThis.String(object.command) : '', + id: isSet(object.id) ? globalThis.String(object.id) : "", + schedule: isSet(object.schedule) ? globalThis.String(object.schedule) : "", + command: isSet(object.command) ? globalThis.String(object.command) : "", extra_schedules: globalThis.Array.isArray(object?.extra_schedules) ? object.extra_schedules.map((e: any) => ISchedule.fromJSON(e)) : [], - name: isSet(object.name) ? globalThis.String(object.name) : '', + name: isSet(object.name) ? globalThis.String(object.name) : "", }; }, toJSON(message: ICron): unknown { const obj: any = {}; - if (message.id !== '') { + if (message.id !== "") { obj.id = message.id; } - if (message.schedule !== '') { + if (message.schedule !== "") { obj.schedule = message.schedule; } - if (message.command !== '') { + if (message.command !== "") { obj.command = message.command; } if (message.extra_schedules?.length) { - obj.extra_schedules = message.extra_schedules.map((e) => - ISchedule.toJSON(e), - ); + obj.extra_schedules = message.extra_schedules.map((e) => ISchedule.toJSON(e)); } - if (message.name !== '') { + if (message.name !== "") { obj.name = message.name; } return obj; @@ -240,12 +222,11 @@ export const ICron: MessageFns = { }, fromPartial, I>>(object: I): ICron { const message = createBaseICron(); - message.id = object.id ?? ''; - message.schedule = object.schedule ?? ''; - message.command = object.command ?? ''; - message.extra_schedules = - object.extra_schedules?.map((e) => ISchedule.fromPartial(e)) || []; - message.name = object.name ?? ''; + message.id = object.id ?? ""; + message.schedule = object.schedule ?? ""; + message.command = object.command ?? ""; + message.extra_schedules = object.extra_schedules?.map((e) => ISchedule.fromPartial(e)) || []; + message.name = object.name ?? ""; return message; }, }; @@ -255,10 +236,7 @@ function createBaseAddCronRequest(): AddCronRequest { } export const AddCronRequest: MessageFns = { - encode( - message: AddCronRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: AddCronRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { for (const v of message.crons) { ICron.encode(v!, writer.uint32(10).fork()).join(); } @@ -266,8 +244,7 @@ export const AddCronRequest: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): AddCronRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseAddCronRequest(); while (reader.pos < end) { @@ -291,11 +268,7 @@ export const AddCronRequest: MessageFns = { }, fromJSON(object: any): AddCronRequest { - return { - crons: globalThis.Array.isArray(object?.crons) - ? object.crons.map((e: any) => ICron.fromJSON(e)) - : [], - }; + return { crons: globalThis.Array.isArray(object?.crons) ? object.crons.map((e: any) => ICron.fromJSON(e)) : [] }; }, toJSON(message: AddCronRequest): unknown { @@ -306,14 +279,10 @@ export const AddCronRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): AddCronRequest { + create, I>>(base?: I): AddCronRequest { return AddCronRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): AddCronRequest { + fromPartial, I>>(object: I): AddCronRequest { const message = createBaseAddCronRequest(); message.crons = object.crons?.map((e) => ICron.fromPartial(e)) || []; return message; @@ -325,16 +294,12 @@ function createBaseAddCronResponse(): AddCronResponse { } export const AddCronResponse: MessageFns = { - encode( - _: AddCronResponse, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(_: AddCronResponse, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { return writer; }, decode(input: BinaryReader | Uint8Array, length?: number): AddCronResponse { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseAddCronResponse(); while (reader.pos < end) { @@ -358,14 +323,10 @@ export const AddCronResponse: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): AddCronResponse { + create, I>>(base?: I): AddCronResponse { return AddCronResponse.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - _: I, - ): AddCronResponse { + fromPartial, I>>(_: I): AddCronResponse { const message = createBaseAddCronResponse(); return message; }, @@ -376,10 +337,7 @@ function createBaseDeleteCronRequest(): DeleteCronRequest { } export const DeleteCronRequest: MessageFns = { - encode( - message: DeleteCronRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: DeleteCronRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { for (const v of message.ids) { writer.uint32(10).string(v!); } @@ -387,8 +345,7 @@ export const DeleteCronRequest: MessageFns = { }, decode(input: BinaryReader | Uint8Array, length?: number): DeleteCronRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseDeleteCronRequest(); while (reader.pos < end) { @@ -412,11 +369,7 @@ export const DeleteCronRequest: MessageFns = { }, fromJSON(object: any): DeleteCronRequest { - return { - ids: globalThis.Array.isArray(object?.ids) - ? object.ids.map((e: any) => globalThis.String(e)) - : [], - }; + return { ids: globalThis.Array.isArray(object?.ids) ? object.ids.map((e: any) => globalThis.String(e)) : [] }; }, toJSON(message: DeleteCronRequest): unknown { @@ -427,14 +380,10 @@ export const DeleteCronRequest: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): DeleteCronRequest { + create, I>>(base?: I): DeleteCronRequest { return DeleteCronRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): DeleteCronRequest { + fromPartial, I>>(object: I): DeleteCronRequest { const message = createBaseDeleteCronRequest(); message.ids = object.ids?.map((e) => e) || []; return message; @@ -446,19 +395,12 @@ function createBaseDeleteCronResponse(): DeleteCronResponse { } export const DeleteCronResponse: MessageFns = { - encode( - _: DeleteCronResponse, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(_: DeleteCronResponse, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { return writer; }, - decode( - input: BinaryReader | Uint8Array, - length?: number, - ): DeleteCronResponse { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + decode(input: BinaryReader | Uint8Array, length?: number): DeleteCronResponse { + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseDeleteCronResponse(); while (reader.pos < end) { @@ -482,14 +424,10 @@ export const DeleteCronResponse: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): DeleteCronResponse { + create, I>>(base?: I): DeleteCronResponse { return DeleteCronResponse.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - _: I, - ): DeleteCronResponse { + fromPartial, I>>(_: I): DeleteCronResponse { const message = createBaseDeleteCronResponse(); return message; }, @@ -498,25 +436,21 @@ export const DeleteCronResponse: MessageFns = { export type CronService = typeof CronService; export const CronService = { addCron: { - path: '/com.ql.cron.Cron/addCron', + path: "/com.ql.cron.Cron/addCron", requestStream: false, responseStream: false, - requestSerialize: (value: AddCronRequest) => - Buffer.from(AddCronRequest.encode(value).finish()), + requestSerialize: (value: AddCronRequest) => Buffer.from(AddCronRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => AddCronRequest.decode(value), - responseSerialize: (value: AddCronResponse) => - Buffer.from(AddCronResponse.encode(value).finish()), + responseSerialize: (value: AddCronResponse) => Buffer.from(AddCronResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => AddCronResponse.decode(value), }, delCron: { - path: '/com.ql.cron.Cron/delCron', + path: "/com.ql.cron.Cron/delCron", requestStream: false, responseStream: false, - requestSerialize: (value: DeleteCronRequest) => - Buffer.from(DeleteCronRequest.encode(value).finish()), + requestSerialize: (value: DeleteCronRequest) => Buffer.from(DeleteCronRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => DeleteCronRequest.decode(value), - responseSerialize: (value: DeleteCronResponse) => - Buffer.from(DeleteCronResponse.encode(value).finish()), + responseSerialize: (value: DeleteCronResponse) => Buffer.from(DeleteCronResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => DeleteCronResponse.decode(value), }, } as const; @@ -544,68 +478,38 @@ export interface CronClient extends Client { ): ClientUnaryCall; delCron( request: DeleteCronRequest, - callback: ( - error: ServiceError | null, - response: DeleteCronResponse, - ) => void, + callback: (error: ServiceError | null, response: DeleteCronResponse) => void, ): ClientUnaryCall; delCron( request: DeleteCronRequest, metadata: Metadata, - callback: ( - error: ServiceError | null, - response: DeleteCronResponse, - ) => void, + callback: (error: ServiceError | null, response: DeleteCronResponse) => void, ): ClientUnaryCall; delCron( request: DeleteCronRequest, metadata: Metadata, options: Partial, - callback: ( - error: ServiceError | null, - response: DeleteCronResponse, - ) => void, + callback: (error: ServiceError | null, response: DeleteCronResponse) => void, ): ClientUnaryCall; } -export const CronClient = makeGenericClientConstructor( - CronService, - 'com.ql.cron.Cron', -) as unknown as { - new ( - address: string, - credentials: ChannelCredentials, - options?: Partial, - ): CronClient; +export const CronClient = makeGenericClientConstructor(CronService, "com.ql.cron.Cron") as unknown as { + new (address: string, credentials: ChannelCredentials, options?: Partial): CronClient; service: typeof CronService; serviceName: string; }; -type Builtin = - | Date - | Function - | Uint8Array - | string - | number - | boolean - | undefined; +type Builtin = Date | Function | Uint8Array | string | number | boolean | undefined; -export type DeepPartial = T extends Builtin - ? T - : T extends globalThis.Array - ? globalThis.Array> - : T extends ReadonlyArray - ? ReadonlyArray> - : T extends {} - ? { [K in keyof T]?: DeepPartial } +export type DeepPartial = T extends Builtin ? T + : T extends globalThis.Array ? globalThis.Array> + : T extends ReadonlyArray ? ReadonlyArray> + : T extends {} ? { [K in keyof T]?: DeepPartial } : Partial; type KeysOfUnion = T extends T ? keyof T : never; -export type Exact = P extends Builtin - ? P - : P & { [K in keyof P]: Exact } & { - [K in Exclude>]: never; - }; +export type Exact = P extends Builtin ? P + : P & { [K in keyof P]: Exact } & { [K in Exclude>]: never }; function isSet(value: any): boolean { return value !== null && value !== undefined; diff --git a/back/protos/health.ts b/back/protos/health.ts index de34dc23..adaf9761 100644 --- a/back/protos/health.ts +++ b/back/protos/health.ts @@ -5,7 +5,7 @@ // source: back/protos/health.proto /* eslint-disable */ -import { BinaryReader, BinaryWriter } from '@bufbuild/protobuf/wire'; +import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire"; import { type CallOptions, ChannelCredentials, @@ -19,9 +19,9 @@ import { Metadata, type ServiceError, type UntypedServiceImplementation, -} from '@grpc/grpc-js'; +} from "@grpc/grpc-js"; -export const protobufPackage = 'com.ql.health'; +export const protobufPackage = "com.ql.health"; export interface HealthCheckRequest { service: string; @@ -39,68 +39,57 @@ export enum HealthCheckResponse_ServingStatus { UNRECOGNIZED = -1, } -export function healthCheckResponse_ServingStatusFromJSON( - object: any, -): HealthCheckResponse_ServingStatus { +export function healthCheckResponse_ServingStatusFromJSON(object: any): HealthCheckResponse_ServingStatus { switch (object) { case 0: - case 'UNKNOWN': + case "UNKNOWN": return HealthCheckResponse_ServingStatus.UNKNOWN; case 1: - case 'SERVING': + case "SERVING": return HealthCheckResponse_ServingStatus.SERVING; case 2: - case 'NOT_SERVING': + case "NOT_SERVING": return HealthCheckResponse_ServingStatus.NOT_SERVING; case 3: - case 'SERVICE_UNKNOWN': + case "SERVICE_UNKNOWN": return HealthCheckResponse_ServingStatus.SERVICE_UNKNOWN; case -1: - case 'UNRECOGNIZED': + case "UNRECOGNIZED": default: return HealthCheckResponse_ServingStatus.UNRECOGNIZED; } } -export function healthCheckResponse_ServingStatusToJSON( - object: HealthCheckResponse_ServingStatus, -): string { +export function healthCheckResponse_ServingStatusToJSON(object: HealthCheckResponse_ServingStatus): string { switch (object) { case HealthCheckResponse_ServingStatus.UNKNOWN: - return 'UNKNOWN'; + return "UNKNOWN"; case HealthCheckResponse_ServingStatus.SERVING: - return 'SERVING'; + return "SERVING"; case HealthCheckResponse_ServingStatus.NOT_SERVING: - return 'NOT_SERVING'; + return "NOT_SERVING"; case HealthCheckResponse_ServingStatus.SERVICE_UNKNOWN: - return 'SERVICE_UNKNOWN'; + return "SERVICE_UNKNOWN"; case HealthCheckResponse_ServingStatus.UNRECOGNIZED: default: - return 'UNRECOGNIZED'; + return "UNRECOGNIZED"; } } function createBaseHealthCheckRequest(): HealthCheckRequest { - return { service: '' }; + return { service: "" }; } export const HealthCheckRequest: MessageFns = { - encode( - message: HealthCheckRequest, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { - if (message.service !== '') { + encode(message: HealthCheckRequest, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { + if (message.service !== "") { writer.uint32(10).string(message.service); } return writer; }, - decode( - input: BinaryReader | Uint8Array, - length?: number, - ): HealthCheckRequest { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + decode(input: BinaryReader | Uint8Array, length?: number): HealthCheckRequest { + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseHealthCheckRequest(); while (reader.pos < end) { @@ -124,29 +113,23 @@ export const HealthCheckRequest: MessageFns = { }, fromJSON(object: any): HealthCheckRequest { - return { - service: isSet(object.service) ? globalThis.String(object.service) : '', - }; + return { service: isSet(object.service) ? globalThis.String(object.service) : "" }; }, toJSON(message: HealthCheckRequest): unknown { const obj: any = {}; - if (message.service !== '') { + if (message.service !== "") { obj.service = message.service; } return obj; }, - create, I>>( - base?: I, - ): HealthCheckRequest { + create, I>>(base?: I): HealthCheckRequest { return HealthCheckRequest.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): HealthCheckRequest { + fromPartial, I>>(object: I): HealthCheckRequest { const message = createBaseHealthCheckRequest(); - message.service = object.service ?? ''; + message.service = object.service ?? ""; return message; }, }; @@ -156,22 +139,15 @@ function createBaseHealthCheckResponse(): HealthCheckResponse { } export const HealthCheckResponse: MessageFns = { - encode( - message: HealthCheckResponse, - writer: BinaryWriter = new BinaryWriter(), - ): BinaryWriter { + encode(message: HealthCheckResponse, writer: BinaryWriter = new BinaryWriter()): BinaryWriter { if (message.status !== 0) { writer.uint32(8).int32(message.status); } return writer; }, - decode( - input: BinaryReader | Uint8Array, - length?: number, - ): HealthCheckResponse { - const reader = - input instanceof BinaryReader ? input : new BinaryReader(input); + decode(input: BinaryReader | Uint8Array, length?: number): HealthCheckResponse { + const reader = input instanceof BinaryReader ? input : new BinaryReader(input); let end = length === undefined ? reader.len : reader.pos + length; const message = createBaseHealthCheckResponse(); while (reader.pos < end) { @@ -195,11 +171,7 @@ export const HealthCheckResponse: MessageFns = { }, fromJSON(object: any): HealthCheckResponse { - return { - status: isSet(object.status) - ? healthCheckResponse_ServingStatusFromJSON(object.status) - : 0, - }; + return { status: isSet(object.status) ? healthCheckResponse_ServingStatusFromJSON(object.status) : 0 }; }, toJSON(message: HealthCheckResponse): unknown { @@ -210,14 +182,10 @@ export const HealthCheckResponse: MessageFns = { return obj; }, - create, I>>( - base?: I, - ): HealthCheckResponse { + create, I>>(base?: I): HealthCheckResponse { return HealthCheckResponse.fromPartial(base ?? ({} as any)); }, - fromPartial, I>>( - object: I, - ): HealthCheckResponse { + fromPartial, I>>(object: I): HealthCheckResponse { const message = createBaseHealthCheckResponse(); message.status = object.status ?? 0; return message; @@ -227,25 +195,21 @@ export const HealthCheckResponse: MessageFns = { export type HealthService = typeof HealthService; export const HealthService = { check: { - path: '/com.ql.health.Health/Check', + path: "/com.ql.health.Health/Check", requestStream: false, responseStream: false, - requestSerialize: (value: HealthCheckRequest) => - Buffer.from(HealthCheckRequest.encode(value).finish()), + requestSerialize: (value: HealthCheckRequest) => Buffer.from(HealthCheckRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => HealthCheckRequest.decode(value), - responseSerialize: (value: HealthCheckResponse) => - Buffer.from(HealthCheckResponse.encode(value).finish()), + responseSerialize: (value: HealthCheckResponse) => Buffer.from(HealthCheckResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => HealthCheckResponse.decode(value), }, watch: { - path: '/com.ql.health.Health/Watch', + path: "/com.ql.health.Health/Watch", requestStream: false, responseStream: true, - requestSerialize: (value: HealthCheckRequest) => - Buffer.from(HealthCheckRequest.encode(value).finish()), + requestSerialize: (value: HealthCheckRequest) => Buffer.from(HealthCheckRequest.encode(value).finish()), requestDeserialize: (value: Buffer) => HealthCheckRequest.decode(value), - responseSerialize: (value: HealthCheckResponse) => - Buffer.from(HealthCheckResponse.encode(value).finish()), + responseSerialize: (value: HealthCheckResponse) => Buffer.from(HealthCheckResponse.encode(value).finish()), responseDeserialize: (value: Buffer) => HealthCheckResponse.decode(value), }, } as const; @@ -258,32 +222,20 @@ export interface HealthServer extends UntypedServiceImplementation { export interface HealthClient extends Client { check( request: HealthCheckRequest, - callback: ( - error: ServiceError | null, - response: HealthCheckResponse, - ) => void, + callback: (error: ServiceError | null, response: HealthCheckResponse) => void, ): ClientUnaryCall; check( request: HealthCheckRequest, metadata: Metadata, - callback: ( - error: ServiceError | null, - response: HealthCheckResponse, - ) => void, + callback: (error: ServiceError | null, response: HealthCheckResponse) => void, ): ClientUnaryCall; check( request: HealthCheckRequest, metadata: Metadata, options: Partial, - callback: ( - error: ServiceError | null, - response: HealthCheckResponse, - ) => void, + callback: (error: ServiceError | null, response: HealthCheckResponse) => void, ): ClientUnaryCall; - watch( - request: HealthCheckRequest, - options?: Partial, - ): ClientReadableStream; + watch(request: HealthCheckRequest, options?: Partial): ClientReadableStream; watch( request: HealthCheckRequest, metadata?: Metadata, @@ -291,44 +243,23 @@ export interface HealthClient extends Client { ): ClientReadableStream; } -export const HealthClient = makeGenericClientConstructor( - HealthService, - 'com.ql.health.Health', -) as unknown as { - new ( - address: string, - credentials: ChannelCredentials, - options?: Partial, - ): HealthClient; +export const HealthClient = makeGenericClientConstructor(HealthService, "com.ql.health.Health") as unknown as { + new (address: string, credentials: ChannelCredentials, options?: Partial): HealthClient; service: typeof HealthService; serviceName: string; }; -type Builtin = - | Date - | Function - | Uint8Array - | string - | number - | boolean - | undefined; +type Builtin = Date | Function | Uint8Array | string | number | boolean | undefined; -export type DeepPartial = T extends Builtin - ? T - : T extends globalThis.Array - ? globalThis.Array> - : T extends ReadonlyArray - ? ReadonlyArray> - : T extends {} - ? { [K in keyof T]?: DeepPartial } +export type DeepPartial = T extends Builtin ? T + : T extends globalThis.Array ? globalThis.Array> + : T extends ReadonlyArray ? ReadonlyArray> + : T extends {} ? { [K in keyof T]?: DeepPartial } : Partial; type KeysOfUnion = T extends T ? keyof T : never; -export type Exact = P extends Builtin - ? P - : P & { [K in keyof P]: Exact } & { - [K in Exclude>]: never; - }; +export type Exact = P extends Builtin ? P + : P & { [K in keyof P]: Exact } & { [K in Exclude>]: never }; function isSet(value: any): boolean { return value !== null && value !== undefined; diff --git a/back/schedule/api.ts b/back/schedule/api.ts index 345312a3..dd80e44c 100644 --- a/back/schedule/api.ts +++ b/back/schedule/api.ts @@ -231,8 +231,7 @@ export const systemNotify = async ( const data = await systemService.notify({ title: call.request.title, content: call.request.content, - notificationInfo: call.request - .notificationInfo as unknown as NotificationInfo, + notificationInfo: call.request.notificationInfo as unknown as NotificationInfo, }); callback(null, data); } catch (e: any) { diff --git a/back/schedule/delCron.ts b/back/schedule/delCron.ts index c379aaf8..6e35c080 100644 --- a/back/schedule/delCron.ts +++ b/back/schedule/delCron.ts @@ -9,8 +9,11 @@ const delCron = ( ) => { for (const id of call.request.ids) { if (scheduleStacks.has(id)) { - Logger.info('[schedule][取消定时任务] 任务ID: %s', id); - scheduleStacks.get(id)?.forEach((x) => x.cancel()); + Logger.info( + '[schedule][取消定时任务] 任务ID: %s', + id, + ); + scheduleStacks.get(id)?.forEach(x => x.cancel()); scheduleStacks.delete(id); } } diff --git a/back/schedule/health.ts b/back/schedule/health.ts index b21d7539..9dcad88f 100644 --- a/back/schedule/health.ts +++ b/back/schedule/health.ts @@ -24,9 +24,7 @@ const check = async ( `tail -n 300 ~/.pm2/logs/schedule-error.log`, ); return callback( - new Error( - `${scheduleErrLog || ''}\n${panelErrLog || ''}\n${res}`.trim(), - ), + new Error(`${scheduleErrLog || ''}\n${panelErrLog || ''}\n${res}`.trim()), ); default: diff --git a/back/services/dependence.ts b/back/services/dependence.ts index 3a02ba20..1cb7e559 100644 --- a/back/services/dependence.ts +++ b/back/services/dependence.ts @@ -28,7 +28,7 @@ export default class DependenceService { constructor( @Inject('logger') private logger: winston.Logger, private sockService: SockService, - ) {} + ) { } public async create(payloads: Dependence[]): Promise { const tabs = payloads.map((x) => { diff --git a/back/services/metrics.ts b/back/services/metrics.ts index 27bb3d55..7ed44664 100644 --- a/back/services/metrics.ts +++ b/back/services/metrics.ts @@ -16,7 +16,7 @@ class MetricsService { // 定期清理旧数据 setInterval(() => { const oneHourAgo = Date.now() - 3600000; - this.metrics = this.metrics.filter((m) => m.timestamp > oneHourAgo); + this.metrics = this.metrics.filter(m => m.timestamp > oneHourAgo); }, 60000); } @@ -46,11 +46,7 @@ class MetricsService { } } - async measureAsync( - name: string, - fn: () => Promise, - tags?: Record, - ) { + async measureAsync(name: string, fn: () => Promise, tags?: Record) { const start = performance.now(); try { await fn(); @@ -62,26 +58,23 @@ class MetricsService { getMetrics(name?: string, tags?: Record) { let filtered = this.metrics; - + if (name) { - filtered = filtered.filter((m) => m.name === name); + filtered = filtered.filter(m => m.name === name); } - + if (tags) { - filtered = filtered.filter((m) => { + filtered = filtered.filter(m => { if (!m.tags) return false; - return Object.entries(tags).every( - ([key, value]) => m.tags![key] === value, - ); + return Object.entries(tags).every(([key, value]) => m.tags![key] === value); }); } return { count: filtered.length, - average: - filtered.reduce((acc, curr) => acc + curr.value, 0) / filtered.length, - min: Math.min(...filtered.map((m) => m.value)), - max: Math.max(...filtered.map((m) => m.value)), + average: filtered.reduce((acc, curr) => acc + curr.value, 0) / filtered.length, + min: Math.min(...filtered.map(m => m.value)), + max: Math.max(...filtered.map(m => m.value)), metrics: filtered, }; } @@ -96,4 +89,4 @@ class MetricsService { } } -export const metricsService = MetricsService.getInstance(); +export const metricsService = MetricsService.getInstance(); \ No newline at end of file diff --git a/back/services/sock.ts b/back/services/sock.ts index 60e78929..b09a43bb 100644 --- a/back/services/sock.ts +++ b/back/services/sock.ts @@ -7,7 +7,7 @@ import { SockMessage } from '../data/sock'; export default class SockService { private clients: Connection[] = []; - constructor(@Inject('logger') private logger: winston.Logger) {} + constructor(@Inject('logger') private logger: winston.Logger) { } public getClients() { return this.clients; diff --git a/back/services/system.ts b/back/services/system.ts index e5b6efb8..f7d83797 100644 --- a/back/services/system.ts +++ b/back/services/system.ts @@ -47,7 +47,7 @@ export default class SystemService { @Inject('logger') private logger: winston.Logger, private scheduleService: ScheduleService, private sockService: SockService, - ) {} + ) { } public async getSystemConfig() { const doc = await this.getDb({ type: AuthDataType.systemConfig }); @@ -287,7 +287,7 @@ export default class SystemService { ); const text = await body.text(); lastVersionContent = parseContentVersion(text); - } catch (error) {} + } catch (error) { } if (!lastVersionContent) { lastVersionContent = currentVersionContent; @@ -401,23 +401,16 @@ export default class SystemService { } } - public async run( - { command, logPath }: { command: string; logPath?: string }, - callback: TaskCallbacks, - ) { + public async run({ command, logPath }: { command: string; logPath?: string }, callback: TaskCallbacks) { if (!command.startsWith(TASK_COMMAND)) { command = `${TASK_COMMAND} ${command}`; } - const logPathPrefix = logPath ? `real_log_path=${logPath}` : ''; - this.scheduleService.runTask( - `${logPathPrefix} real_time=true ${command}`, - callback, - { - command, - id: command.replace(/ /g, '-'), - runOrigin: 'system', - }, - ); + const logPathPrefix = logPath ? `real_log_path=${logPath}` : '' + this.scheduleService.runTask(`${logPathPrefix} real_time=true ${command}`, callback, { + command, + id: command.replace(/ /g, '-'), + runOrigin: 'system', + }); } public async stop({ command, pid }: { command: string; pid: number }) { @@ -450,8 +443,7 @@ export default class SystemService { } const dataPaths = dataDirs.map((dir) => `data/${dir}`); await promiseExec( - `cd ${config.dataPath} && cd ../ && tar -zcvf ${ - config.dataTgzFile + `cd ${config.dataPath} && cd ../ && tar -zcvf ${config.dataTgzFile } ${dataPaths.join(' ')}`, ); res.download(config.dataTgzFile); @@ -545,7 +537,7 @@ export default class SystemService { try { const finalPath = path.join(config.dependenceCachePath, type); await fs.promises.rm(finalPath, { recursive: true }); - } catch (error) {} + } catch (error) { } return { code: 200 }; } } diff --git a/back/types/express.d.ts b/back/types/express.d.ts index 3899d0bd..4a8fd216 100644 --- a/back/types/express.d.ts +++ b/back/types/express.d.ts @@ -8,4 +8,4 @@ declare global { platform: 'desktop' | 'mobile'; } } -} +} \ No newline at end of file diff --git a/nodemon.json b/nodemon.json index e2e6c597..e88c44ac 100644 --- a/nodemon.json +++ b/nodemon.json @@ -1,5 +1,8 @@ { - "watch": ["back", ".env"], + "watch": [ + "back", + ".env" + ], "ext": "js,ts,json", "env": { "NODE_ENV": "development", @@ -9,4 +12,4 @@ "execMap": { "ts": "node --require ts-node/register" } -} +} \ No newline at end of file diff --git a/sample/notify.js b/sample/notify.js index 51990874..8dfe8851 100644 --- a/sample/notify.js +++ b/sample/notify.js @@ -1262,15 +1262,7 @@ function ntfyNotify(text, desp) { } return new Promise((resolve) => { - const { - NTFY_URL, - NTFY_TOPIC, - NTFY_PRIORITY, - NTFY_TOKEN, - NTFY_USERNAME, - NTFY_PASSWORD, - NTFY_ACTIONS, - } = push_config; + const { NTFY_URL, NTFY_TOPIC, NTFY_PRIORITY, NTFY_TOKEN, NTFY_USERNAME, NTFY_PASSWORD, NTFY_ACTIONS } = push_config; if (NTFY_TOPIC) { const options = { url: `${NTFY_URL || 'https://ntfy.sh'}/${NTFY_TOPIC}`, @@ -1285,9 +1277,7 @@ function ntfyNotify(text, desp) { if (NTFY_TOKEN) { options.headers['Authorization'] = `Bearer ${NTFY_TOKEN}`; } else if (NTFY_USERNAME && NTFY_PASSWORD) { - options.headers['Authorization'] = `Basic ${Buffer.from( - `${NTFY_USERNAME}:${NTFY_PASSWORD}`, - ).toString('base64')}`; + options.headers['Authorization'] = `Basic ${Buffer.from(`${NTFY_USERNAME}:${NTFY_PASSWORD}`).toString('base64')}`; } if (NTFY_ACTIONS) { options.headers['Actions'] = encodeRFC2047(NTFY_ACTIONS); diff --git a/src/app.ts b/src/app.ts index 8a462903..8aa3dfac 100644 --- a/src/app.ts +++ b/src/app.ts @@ -4,16 +4,14 @@ import intl from 'react-intl-universal'; export function rootContainer(container: any) { const locales = { - en: require('./locales/en-US.json'), - zh: require('./locales/zh-CN.json'), + 'en': require('./locales/en-US.json'), + 'zh': require('./locales/zh-CN.json'), }; - let currentLocale = intl - .determineLocale({ - urlLocaleKey: 'lang', - cookieLocaleKey: 'lang', - localStorageLocaleKey: 'lang', - }) - .slice(0, 2); + let currentLocale = intl.determineLocale({ + urlLocaleKey: 'lang', + cookieLocaleKey: 'lang', + localStorageLocaleKey: 'lang', + }).slice(0, 2); if (!currentLocale || !Object.keys(locales).includes(currentLocale)) { currentLocale = 'zh'; diff --git a/src/pages/config/index.tsx b/src/pages/config/index.tsx index 9b16e548..69217bf4 100644 --- a/src/pages/config/index.tsx +++ b/src/pages/config/index.tsx @@ -136,7 +136,7 @@ const Config = () => { lineNumbersMinChars: 3, folding: false, glyphMargin: false, - accessibilitySupport: 'off', + accessibilitySupport: 'off' }} onMount={(editor) => { editorRef.current = editor; diff --git a/src/pages/crontab/logModal.tsx b/src/pages/crontab/logModal.tsx index 0f9a3c8d..59844305 100644 --- a/src/pages/crontab/logModal.tsx +++ b/src/pages/crontab/logModal.tsx @@ -1,5 +1,5 @@ -import intl from 'react-intl-universal'; -import React, { useEffect, useRef, useState } from 'react'; +import intl from "react-intl-universal"; +import React, { useEffect, useRef, useState } from "react"; import { Modal, message, @@ -8,17 +8,17 @@ import { Statistic, Button, Typography, -} from 'antd'; -import { request } from '@/utils/http'; -import config from '@/utils/config'; +} from "antd"; +import { request } from "@/utils/http"; +import config from "@/utils/config"; import { Loading3QuartersOutlined, CheckCircleOutlined, -} from '@ant-design/icons'; -import { PageLoading } from '@ant-design/pro-layout'; -import { logEnded } from '@/utils'; -import { CrontabStatus } from './type'; -import Ansi from 'ansi-to-react'; +} from "@ant-design/icons"; +import { PageLoading } from "@ant-design/pro-layout"; +import { logEnded } from "@/utils"; +import { CrontabStatus } from "./type"; +import Ansi from "ansi-to-react"; const { Countdown } = Statistic; @@ -33,7 +33,7 @@ const CronLogModal = ({ data?: string; logUrl?: string; }) => { - const [value, setValue] = useState(intl.get('启动中...')); + const [value, setValue] = useState(intl.get("启动中...")); const [loading, setLoading] = useState(true); const [executing, setExecuting] = useState(true); const [isPhone, setIsPhone] = useState(false); @@ -49,15 +49,15 @@ const CronLogModal = ({ .then(({ code, data }) => { if ( code === 200 && - localStorage.getItem('logCron') === uniqPath && + localStorage.getItem("logCron") === uniqPath && data !== value ) { const log = data as string; - setValue(log || intl.get('暂无日志')); + setValue(log || intl.get("暂无日志")); const hasNext = Boolean( - log && !logEnded(log) && !log.includes('日志不存在'), + log && !logEnded(log) && !log.includes("日志不存在"), ); - if (!hasNext && !logEnded(value) && value !== intl.get('启动中...')) { + if (!hasNext && !logEnded(value) && value !== intl.get("启动中...")) { setTimeout(() => { autoScroll(); }); @@ -85,13 +85,13 @@ const CronLogModal = ({ setTimeout(() => { document - .querySelector('#log-flag') - ?.scrollIntoView({ behavior: 'smooth' }); + .querySelector("#log-flag") + ?.scrollIntoView({ behavior: "smooth" }); }, 600); }; const cancel = () => { - localStorage.removeItem('logCron'); + localStorage.removeItem("logCron"); handleCancel(); }; @@ -107,7 +107,7 @@ const CronLogModal = ({ const titleElement = () => { return ( -
+
{(executing || loading) && } {!executing && !loading && } @@ -144,7 +144,7 @@ const CronLogModal = ({ onCancel={() => cancel()} footer={[ , ]} > @@ -156,9 +156,9 @@ const CronLogModal = ({ style={ isPhone ? { - fontFamily: 'Source Code Pro', - zoom: 0.83, - } + fontFamily: "Source Code Pro", + zoom: 0.83, + } : {} } > diff --git a/src/pages/crontab/modal.tsx b/src/pages/crontab/modal.tsx index 7114b0c1..6a7c0492 100644 --- a/src/pages/crontab/modal.tsx +++ b/src/pages/crontab/modal.tsx @@ -312,3 +312,4 @@ const CronLabelModal = ({ }; export { CronLabelModal, CronModal as default }; + diff --git a/src/pages/dependence/type.ts b/src/pages/dependence/type.ts index 19a8c09a..238ca17a 100644 --- a/src/pages/dependence/type.ts +++ b/src/pages/dependence/type.ts @@ -18,4 +18,4 @@ export enum Status { '删除失败', '队列中', '已取消', -} +} \ No newline at end of file diff --git a/src/pages/diff/index.tsx b/src/pages/diff/index.tsx index 04936744..5897cb2e 100644 --- a/src/pages/diff/index.tsx +++ b/src/pages/diff/index.tsx @@ -26,9 +26,7 @@ const Diff = () => { const getConfig = () => { request - .get( - `${config.apiPrefix}configs/detail?path=${encodeURIComponent(current)}`, - ) + .get(`${config.apiPrefix}configs/detail?path=${encodeURIComponent(current)}`) .then(({ code, data }) => { if (code === 200) { setCurrentValue(data); @@ -38,9 +36,7 @@ const Diff = () => { const getSample = () => { request - .get( - `${config.apiPrefix}configs/detail?path=${encodeURIComponent(origin)}`, - ) + .get(`${config.apiPrefix}configs/detail?path=${encodeURIComponent(origin)}`) .then(({ code, data }) => { if (code === 200) { setOriginValue(data); diff --git a/src/pages/env/editNameModal.tsx b/src/pages/env/editNameModal.tsx index 6ef8294e..9a0fa260 100644 --- a/src/pages/env/editNameModal.tsx +++ b/src/pages/env/editNameModal.tsx @@ -1,4 +1,4 @@ -import intl from 'react-intl-universal'; +import intl from 'react-intl-universal' import React, { useEffect, useState } from 'react'; import { Modal, message, Input, Form } from 'antd'; import { request } from '@/utils/http'; @@ -55,9 +55,7 @@ const EditNameModal = ({
diff --git a/src/pages/script/components/UnsupportedFilePreview/index.module.less b/src/pages/script/components/UnsupportedFilePreview/index.module.less index 17e46f9f..688e4857 100644 --- a/src/pages/script/components/UnsupportedFilePreview/index.module.less +++ b/src/pages/script/components/UnsupportedFilePreview/index.module.less @@ -64,4 +64,4 @@ .warningIcon { font-size: 14px; color: #faad14; -} +} \ No newline at end of file diff --git a/src/pages/script/components/UnsupportedFilePreview/index.tsx b/src/pages/script/components/UnsupportedFilePreview/index.tsx index 95c74f6b..4cac37ff 100644 --- a/src/pages/script/components/UnsupportedFilePreview/index.tsx +++ b/src/pages/script/components/UnsupportedFilePreview/index.tsx @@ -17,10 +17,12 @@ const UnsupportedFilePreview: React.FC = ({
-
{intl.get('当前文件不支持预览')}
+
+ {intl.get('当前文件不支持预览')} +
- ); diff --git a/src/pages/setting/notification.tsx b/src/pages/setting/notification.tsx index 2bfae998..81baa8fe 100644 --- a/src/pages/setting/notification.tsx +++ b/src/pages/setting/notification.tsx @@ -76,9 +76,7 @@ const NotificationSetting = ({ data }: any) => { > {x.items ? (