From 82968f13fd74079f7ec286cc4a78a214c878b88d Mon Sep 17 00:00:00 2001 From: gudaoxuri Date: Thu, 7 Jan 2021 12:59:10 +0800 Subject: [PATCH] Try publishing to npm. --- terminals/packages/sdk/src/module/CacheSDK.ts | 134 ++++++++++-------- terminals/packages/sdk/src/module/RelDBSDK.ts | 23 +-- terminals/packages/sdk/src/module/TaskSDK.ts | 59 ++++---- 3 files changed, 124 insertions(+), 92 deletions(-) diff --git a/terminals/packages/sdk/src/module/CacheSDK.ts b/terminals/packages/sdk/src/module/CacheSDK.ts index 5177e2fd..d9752980 100644 --- a/terminals/packages/sdk/src/module/CacheSDK.ts +++ b/terminals/packages/sdk/src/module/CacheSDK.ts @@ -24,67 +24,83 @@ export function init(appId: number): void { } export function cacheSDK() { - return CacheSDK(_appId + ".cache.default") + return new CacheSDK(_appId + ".cache.default") } -function CacheSDK(resourceSubjectCode: string) { - - return { - exists(key: string): Promise { - checkKey(key) - return cache("existsCache", resourceSubjectCode, OptActionKind.EXISTS, key) - }, - hexists(key: string, fieldName: string): Promise { - checkKey(key) - return cache("hexistsCache", resourceSubjectCode, OptActionKind.EXISTS, key + "/" + fieldName) - }, - get(key: string): Promise { - checkKey(key) - return cache("getCache", resourceSubjectCode, OptActionKind.FETCH, key) - }, - hgetall(key: string): Promise { - checkKey(key) - return cache("hgetallCache", resourceSubjectCode, OptActionKind.FETCH, key + '/*') - }, - hget(key: string, fieldName: string): Promise { - checkKey(key) - return cache("hgetCache", resourceSubjectCode, OptActionKind.FETCH, key + '/' + fieldName) - }, - del(key: string): Promise { - checkKey(key) - return cache("delCache", resourceSubjectCode, OptActionKind.DELETE, key) - }, - hdel(key: string, fieldName: string): Promise { - checkKey(key) - return cache("hdelCache", resourceSubjectCode, OptActionKind.DELETE, key + '/' + fieldName) - }, - incrby(key: string, step: number): Promise { - checkKey(key) - return cache("incrbyCache", resourceSubjectCode, OptActionKind.CREATE, key + '?incr=true', step + '') - }, - hincrby(key: string, fieldName: string, step: number): Promise { - checkKey(key) - return cache("hincrbyCache", resourceSubjectCode, OptActionKind.CREATE, key + '/' + fieldName + '?incr=true', step + '') - }, - set(key: string, value: any): Promise { - checkKey(key) - return cache("setCache", resourceSubjectCode, OptActionKind.CREATE, key, value) - }, - hset(key: string, fieldName: string, value: any): Promise { - checkKey(key) - return cache("hsetCache", resourceSubjectCode, OptActionKind.CREATE, key + '/' + fieldName, value) - }, - setex(key: string, value: any, expireSec: number): Promise { - checkKey(key) - return cache("setexCache", resourceSubjectCode, OptActionKind.CREATE, key + '?expire=' + expireSec, value) - }, - expire(key: string, expireSec: number): Promise { - checkKey(key) - return cache("expireCache", resourceSubjectCode, OptActionKind.CREATE, key + '?expire=' + expireSec) - }, - subject(resourceSubject: string) { - return CacheSDK(resourceSubject) - } +export class CacheSDK { + constructor(resourceSubjectCode: string) { + this.resourceSubjectCode = resourceSubjectCode; + } + + private readonly resourceSubjectCode: string + + exists(key: string): Promise { + checkKey(key) + return cache("existsCache", this.resourceSubjectCode, OptActionKind.EXISTS, key) + } + + hexists(key: string, fieldName: string): Promise { + checkKey(key) + return cache("hexistsCache", this.resourceSubjectCode, OptActionKind.EXISTS, key + "/" + fieldName) + } + + get(key: string): Promise { + checkKey(key) + return cache("getCache", this.resourceSubjectCode, OptActionKind.FETCH, key) + } + + hgetall(key: string): Promise { + checkKey(key) + return cache("hgetallCache", this.resourceSubjectCode, OptActionKind.FETCH, key + '/*') + } + + hget(key: string, fieldName: string): Promise { + checkKey(key) + return cache("hgetCache", this.resourceSubjectCode, OptActionKind.FETCH, key + '/' + fieldName) + } + + del(key: string): Promise { + checkKey(key) + return cache("delCache", this.resourceSubjectCode, OptActionKind.DELETE, key) + } + + hdel(key: string, fieldName: string): Promise { + checkKey(key) + return cache("hdelCache", this.resourceSubjectCode, OptActionKind.DELETE, key + '/' + fieldName) + } + + incrby(key: string, step: number): Promise { + checkKey(key) + return cache("incrbyCache", this.resourceSubjectCode, OptActionKind.CREATE, key + '?incr=true', step + '') + } + + hincrby(key: string, fieldName: string, step: number): Promise { + checkKey(key) + return cache("hincrbyCache", this.resourceSubjectCode, OptActionKind.CREATE, key + '/' + fieldName + '?incr=true', step + '') + } + + set(key: string, value: any): Promise { + checkKey(key) + return cache("setCache", this.resourceSubjectCode, OptActionKind.CREATE, key, value) + } + + hset(key: string, fieldName: string, value: any): Promise { + checkKey(key) + return cache("hsetCache", this.resourceSubjectCode, OptActionKind.CREATE, key + '/' + fieldName, value) + } + + setex(key: string, value: any, expireSec: number): Promise { + checkKey(key) + return cache("setexCache", this.resourceSubjectCode, OptActionKind.CREATE, key + '?expire=' + expireSec, value) + } + + expire(key: string, expireSec: number): Promise { + checkKey(key) + return cache("expireCache", this.resourceSubjectCode, OptActionKind.CREATE, key + '?expire=' + expireSec) + } + + subject(resourceSubject: string) { + return new CacheSDK(resourceSubject) } } diff --git a/terminals/packages/sdk/src/module/RelDBSDK.ts b/terminals/packages/sdk/src/module/RelDBSDK.ts index bb95c6ee..bad3e732 100644 --- a/terminals/packages/sdk/src/module/RelDBSDK.ts +++ b/terminals/packages/sdk/src/module/RelDBSDK.ts @@ -25,18 +25,23 @@ export function init(appId: number): void { } export function reldbSDK() { - return RelDBSDK(_appId + ".reldb.default") + return new RelDBSDK(_appId + ".reldb.default") } -function RelDBSDK(resourceSubjectCode: string) { +export class RelDBSDK { - return { - exec(encryptedSql: string, parameters: any[]): Promise { - return doExec(resourceSubjectCode, encryptedSql, parameters) - }, - subject(resourceSubject: string) { - return RelDBSDK(resourceSubject) - } + constructor(resourceSubjectCode: string) { + this.resourceSubjectCode = resourceSubjectCode; + } + + private readonly resourceSubjectCode: string + + exec(encryptedSql: string, parameters: any[]): Promise { + return doExec(this.resourceSubjectCode, encryptedSql, parameters) + } + + subject(resourceSubject: string) { + return new RelDBSDK(resourceSubject) } } diff --git a/terminals/packages/sdk/src/module/TaskSDK.ts b/terminals/packages/sdk/src/module/TaskSDK.ts index 03f1f8ee..6fed8ad4 100644 --- a/terminals/packages/sdk/src/module/TaskSDK.ts +++ b/terminals/packages/sdk/src/module/TaskSDK.ts @@ -25,32 +25,43 @@ export function init(appId: number): void { } export function taskSDK() { - return TaskSDK(_appId + ".task.default") + return new TaskSDK(_appId + ".task.default") } -function TaskSDK(resourceSubjectCode: string) { - - return { - create(taskCode: string, fun: string, cron?: string): Promise { - let query = '' - if (cron) { - query = '?cron=' + encodeURIComponent(cron) - } - return task("createTask", resourceSubjectCode, OptActionKind.CREATE, 'task/' + taskCode + query, fun) - }, - modify(taskCode: string, fun: string, cron?: string): Promise { - let query = '' - if (cron) { - query = '?cron=' + encodeURIComponent(cron) - } - return task("modifyTask", resourceSubjectCode, OptActionKind.MODIFY, 'task/' + taskCode + query, fun) - }, - delete(taskCode: string): Promise { - return task("deleteTask", resourceSubjectCode, OptActionKind.DELETE, 'task/' + taskCode) - }, - execute(taskCode: string): Promise { - return task("executeTask", resourceSubjectCode, OptActionKind.CREATE, 'exec/' + taskCode) - }, +export class TaskSDK { + + constructor(resourceSubjectCode: string) { + this.resourceSubjectCode = resourceSubjectCode; + } + + private readonly resourceSubjectCode: string + + create(taskCode: string, fun: string, cron?: string): Promise { + let query = '' + if (cron) { + query = '?cron=' + encodeURIComponent(cron) + } + return task("createTask", this.resourceSubjectCode, OptActionKind.CREATE, 'task/' + taskCode + query, fun) + } + + modify(taskCode: string, fun: string, cron?: string): Promise { + let query = '' + if (cron) { + query = '?cron=' + encodeURIComponent(cron) + } + return task("modifyTask", this.resourceSubjectCode, OptActionKind.MODIFY, 'task/' + taskCode + query, fun) + } + + delete(taskCode: string): Promise { + return task("deleteTask", this.resourceSubjectCode, OptActionKind.DELETE, 'task/' + taskCode) + } + + execute(taskCode: string): Promise { + return task("executeTask", this.resourceSubjectCode, OptActionKind.CREATE, 'exec/' + taskCode) + } + + subject(resourceSubject: string) { + return new TaskSDK(resourceSubject) } }