Try publishing to npm.

ideal-world · Jan 7, 2021 · 82968f1 · 82968f1
1 parent eaa9f6b
commit 82968f1
Show file tree

Hide file tree

Showing 3 changed files with 124 additions and 92 deletions.
diff --git 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<boolean> {
-            checkKey(key)
-            return cache<boolean>("existsCache", resourceSubjectCode, OptActionKind.EXISTS, key)
-        },
-        hexists(key: string, fieldName: string): Promise<boolean> {
-            checkKey(key)
-            return cache<boolean>("hexistsCache", resourceSubjectCode, OptActionKind.EXISTS, key + "/" + fieldName)
-        },
-        get<T>(key: string): Promise<T> {
-            checkKey(key)
-            return cache<T>("getCache", resourceSubjectCode, OptActionKind.FETCH, key)
-        },
-        hgetall<T>(key: string): Promise<T> {
-            checkKey(key)
-            return cache<T>("hgetallCache", resourceSubjectCode, OptActionKind.FETCH, key + '/*')
-        },
-        hget<T>(key: string, fieldName: string): Promise<T> {
-            checkKey(key)
-            return cache<T>("hgetCache", resourceSubjectCode, OptActionKind.FETCH, key + '/' + fieldName)
-        },
-        del(key: string): Promise<void> {
-            checkKey(key)
-            return cache<void>("delCache", resourceSubjectCode, OptActionKind.DELETE, key)
-        },
-        hdel(key: string, fieldName: string): Promise<void> {
-            checkKey(key)
-            return cache<void>("hdelCache", resourceSubjectCode, OptActionKind.DELETE, key + '/' + fieldName)
-        },
-        incrby(key: string, step: number): Promise<number> {
-            checkKey(key)
-            return cache<number>("incrbyCache", resourceSubjectCode, OptActionKind.CREATE, key + '?incr=true', step + '')
-        },
-        hincrby(key: string, fieldName: string, step: number): Promise<number> {
-            checkKey(key)
-            return cache<number>("hincrbyCache", resourceSubjectCode, OptActionKind.CREATE, key + '/' + fieldName + '?incr=true', step + '')
-        },
-        set(key: string, value: any): Promise<void> {
-            checkKey(key)
-            return cache<void>("setCache", resourceSubjectCode, OptActionKind.CREATE, key, value)
-        },
-        hset(key: string, fieldName: string, value: any): Promise<void> {
-            checkKey(key)
-            return cache<void>("hsetCache", resourceSubjectCode, OptActionKind.CREATE, key + '/' + fieldName, value)
-        },
-        setex(key: string, value: any, expireSec: number): Promise<void> {
-            checkKey(key)
-            return cache<void>("setexCache", resourceSubjectCode, OptActionKind.CREATE, key + '?expire=' + expireSec, value)
-        },
-        expire(key: string, expireSec: number): Promise<void> {
-            checkKey(key)
-            return cache<void>("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<boolean> {
+        checkKey(key)
+        return cache<boolean>("existsCache", this.resourceSubjectCode, OptActionKind.EXISTS, key)
+    }
+
+    hexists(key: string, fieldName: string): Promise<boolean> {
+        checkKey(key)
+        return cache<boolean>("hexistsCache", this.resourceSubjectCode, OptActionKind.EXISTS, key + "/" + fieldName)
+    }
+
+    get<T>(key: string): Promise<T> {
+        checkKey(key)
+        return cache<T>("getCache", this.resourceSubjectCode, OptActionKind.FETCH, key)
+    }
+
+    hgetall<T>(key: string): Promise<T> {
+        checkKey(key)
+        return cache<T>("hgetallCache", this.resourceSubjectCode, OptActionKind.FETCH, key + '/*')
+    }
+
+    hget<T>(key: string, fieldName: string): Promise<T> {
+        checkKey(key)
+        return cache<T>("hgetCache", this.resourceSubjectCode, OptActionKind.FETCH, key + '/' + fieldName)
+    }
+
+    del(key: string): Promise<void> {
+        checkKey(key)
+        return cache<void>("delCache", this.resourceSubjectCode, OptActionKind.DELETE, key)
+    }
+
+    hdel(key: string, fieldName: string): Promise<void> {
+        checkKey(key)
+        return cache<void>("hdelCache", this.resourceSubjectCode, OptActionKind.DELETE, key + '/' + fieldName)
+    }
+
+    incrby(key: string, step: number): Promise<number> {
+        checkKey(key)
+        return cache<number>("incrbyCache", this.resourceSubjectCode, OptActionKind.CREATE, key + '?incr=true', step + '')
+    }
+
+    hincrby(key: string, fieldName: string, step: number): Promise<number> {
+        checkKey(key)
+        return cache<number>("hincrbyCache", this.resourceSubjectCode, OptActionKind.CREATE, key + '/' + fieldName + '?incr=true', step + '')
+    }
+
+    set(key: string, value: any): Promise<void> {
+        checkKey(key)
+        return cache<void>("setCache", this.resourceSubjectCode, OptActionKind.CREATE, key, value)
+    }
+
+    hset(key: string, fieldName: string, value: any): Promise<void> {
+        checkKey(key)
+        return cache<void>("hsetCache", this.resourceSubjectCode, OptActionKind.CREATE, key + '/' + fieldName, value)
+    }
+
+    setex(key: string, value: any, expireSec: number): Promise<void> {
+        checkKey(key)
+        return cache<void>("setexCache", this.resourceSubjectCode, OptActionKind.CREATE, key + '?expire=' + expireSec, value)
+    }
+
+    expire(key: string, expireSec: number): Promise<void> {
+        checkKey(key)
+        return cache<void>("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
@@ -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<T>(encryptedSql: string, parameters: any[]): Promise<T[]> {
-            return doExec<T>(resourceSubjectCode, encryptedSql, parameters)
-        },
-        subject(resourceSubject: string) {
-            return RelDBSDK(resourceSubject)
-        }
+    constructor(resourceSubjectCode: string) {
+        this.resourceSubjectCode = resourceSubjectCode;
+    }
+
+    private readonly resourceSubjectCode: string
+
+    exec<T>(encryptedSql: string, parameters: any[]): Promise<T[]> {
+        return doExec<T>(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
@@ -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<void> {
-            let query = ''
-            if (cron) {
-                query = '?cron=' + encodeURIComponent(cron)
-            }
-            return task<void>("createTask", resourceSubjectCode, OptActionKind.CREATE, 'task/' + taskCode + query, fun)
-        },
-        modify(taskCode: string, fun: string, cron?: string): Promise<void> {
-            let query = ''
-            if (cron) {
-                query = '?cron=' + encodeURIComponent(cron)
-            }
-            return task<void>("modifyTask", resourceSubjectCode, OptActionKind.MODIFY, 'task/' + taskCode + query, fun)
-        },
-        delete(taskCode: string): Promise<void> {
-            return task<void>("deleteTask", resourceSubjectCode, OptActionKind.DELETE, 'task/' + taskCode)
-        },
-        execute(taskCode: string): Promise<void> {
-            return task<void>("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<void> {
+        let query = ''
+        if (cron) {
+            query = '?cron=' + encodeURIComponent(cron)
+        }
+        return task<void>("createTask", this.resourceSubjectCode, OptActionKind.CREATE, 'task/' + taskCode + query, fun)
+    }
+
+    modify(taskCode: string, fun: string, cron?: string): Promise<void> {
+        let query = ''
+        if (cron) {
+            query = '?cron=' + encodeURIComponent(cron)
+        }
+        return task<void>("modifyTask", this.resourceSubjectCode, OptActionKind.MODIFY, 'task/' + taskCode + query, fun)
+    }
+
+    delete(taskCode: string): Promise<void> {
+        return task<void>("deleteTask", this.resourceSubjectCode, OptActionKind.DELETE, 'task/' + taskCode)
+    }
+
+    execute(taskCode: string): Promise<void> {
+        return task<void>("executeTask", this.resourceSubjectCode, OptActionKind.CREATE, 'exec/' + taskCode)
+    }
+
+    subject(resourceSubject: string) {
+        return new TaskSDK(resourceSubject)
     }
 
 }