feat: export all types

src/client/Binding.ts

@@ -23,7 +23,7 @@ import {
 } from '../types/Binding';
 import { convertMapToKVString } from '../utils';
 
-export default class Binding extends RuntimeAPI {
+export class Binding extends RuntimeAPI {
   async invoke(request: InvokeBindingRequest): Promise<InvokeBindingResponse> {
     const req = new InvokeBindingRequestPB();
     req.setName(request.name);

src/client/Client.ts

@@ -19,17 +19,17 @@ import { ChannelCredentials } from '@grpc/grpc-js';
 import { RuntimeClient } from '../../proto/runtime/v1/runtime_grpc_pb';
 import { ObjectStorageServiceClient } from '../../proto/extension/v1/s3/oss_grpc_pb';
 import { CryptionServiceClient } from '../../proto/extension/v1/cryption/cryption_grpc_pb';
-import State from './State';
-import Hello from './Hello';
-import Invoker from './Invoker';
-import Lock from './Lock';
-import Sequencer from './Sequencer';
-import Configuration from './Configuration';
-import PubSub from './PubSub';
-import File from './File';
-import Binding from './Binding';
-import Oss, { OssOptions } from './Oss';
-import Cryption, { CryptionOptions } from './Cryption';
+import { State } from './State';
+import { Hello } from './Hello';
+import { Invoker } from './Invoker';
+import { Lock } from './Lock';
+import { Sequencer } from './Sequencer';
+import { Configuration } from './Configuration';
+import { PubSub } from './PubSub';
+import { File } from './File';
+import { Binding } from './Binding';
+import { Oss, OssOptions } from './Oss';
+import { Cryption, CryptionOptions } from './Cryption';
 import type { CreateMetadataHook } from './API';
 
 const debug = debuglog('layotto:client:main');
@@ -43,7 +43,7 @@ export interface ClientOptions {
   createMetadataHook?: CreateMetadataHook;
 }
 
-export default class Client {
+export class Client {
   readonly host: string;
   readonly port: string;
   protected readonly localStorage?: AsyncLocalStorage<any>;

src/client/Configuration.ts

@@ -34,7 +34,7 @@ import { convertArrayToKVString } from '../types/common';
 
 const debug = debuglog('layotto:client:configuration');
 
-export default class Configuration extends RuntimeAPI {
+export class Configuration extends RuntimeAPI {
   // GetConfiguration gets configuration from configuration store.
   async get(request: GetConfigurationRequest): Promise<GetConfigurationItem[]> {
     const req = new GetConfigurationRequestPB();

src/client/Cryption.ts

@@ -1,36 +1,24 @@
 import {
   EncryptRequest as EncryptRequestPB,
-  EncryptResponse,
+  EncryptResponse as EncryptResponsePB,
   DecryptRequest as DecryptRequestPB,
   DecryptResponse as DecryptResponsePB,
 } from '../../proto/extension/v1/cryption/cryption_pb';
 import { CryptionServiceClient } from '../../proto/extension/v1/cryption/cryption_grpc_pb';
 import { API, APIOptions } from './API';
-import { RequestWithMeta } from '../types/common';
-
-export type EncryptRequest = RequestWithMeta<{
-  plainText: Uint8Array | string;
-  keyId?: string;
-}>;
-
-export type DecryptRequest = RequestWithMeta<{
-  cipherText: Uint8Array | string;
-}>;
-
-export type DecryptResponse = {
-  plainText: Uint8Array;
-  keyId: string,
-  keyVersionId: string,
-  requestId: string,
-};
+import {
+  EncryptRequest,
+  DecryptRequest,
+  DecryptResponse,
+} from '../types/Cryption';
 
-export type CryptionOptions = {
+export interface CryptionOptions {
   componentName: string;
   // set default metadata on every request
   defaultRequestMeta?: Record<string, string>;
-};
+}
 
-export default class Cryption extends API {
+export class Cryption extends API {
   private readonly cryptionClient: CryptionServiceClient;
   private readonly options: CryptionOptions;
 
@@ -40,7 +28,7 @@ export default class Cryption extends API {
     this.cryptionClient = cryptionClient;
   }
 
-  async encrypt(request: EncryptRequest): Promise<EncryptResponse.AsObject> {
+  async encrypt(request: EncryptRequest): Promise<EncryptResponsePB.AsObject> {
     const req = new EncryptRequestPB();
     req.setComponentName(this.options.componentName);
     let plainText = request.plainText;
@@ -54,7 +42,7 @@ export default class Cryption extends API {
 
     const metadata = this.createMetadata(request, this.options.defaultRequestMeta);
     return new Promise((resolve, reject) => {
-      this.cryptionClient.encrypt(req, metadata, (err, res: EncryptResponse) => {
+      this.cryptionClient.encrypt(req, metadata, (err, res: EncryptResponsePB) => {
         if (err) return reject(err);
         resolve(res.toObject());
       });

src/client/File.ts

@@ -27,7 +27,7 @@ import { GetFileRequest, ListFileResponse, PutFileRequest } from '../types/File'
 
 const debug = debuglog('layotto:client:file');
 
-export default class File extends RuntimeAPI {
+export class File extends RuntimeAPI {
   // Get a file stream
   async get(request: GetFileRequest): Promise<Readable> {
     const req = new GetFileRequestPB();

src/client/Hello.ts

@@ -19,7 +19,7 @@ import {
 import { RuntimeAPI } from './RuntimeAPI';
 import { SayHelloRequest } from '../types/Hello';
 
-export default class Hello extends RuntimeAPI {
+export class Hello extends RuntimeAPI {
   async sayHello(request?: SayHelloRequest): Promise<string> {
     const req = new SayHelloRequestPB();
     if (!request) request = {};

src/client/Invoker.ts

@@ -22,7 +22,7 @@ import {
 import { RuntimeAPI } from './RuntimeAPI';
 import { InvokeServiceRequest, InvokeResponse } from '../types/Invoker';
 
-export default class Invoker extends RuntimeAPI {
+export class Invoker extends RuntimeAPI {
   async invoke(request: InvokeServiceRequest): Promise<InvokeResponse> {
     const message = new CommonInvokeRequestPB();
     message.setMethod(request.method);

src/client/Lock.ts

@@ -22,7 +22,7 @@ import {
 import { RuntimeAPI } from './RuntimeAPI';
 import { TryLockRequest, UnlockRequest } from '../types/Lock';
 
-export default class Lock extends RuntimeAPI {
+export class Lock extends RuntimeAPI {
   // A non-blocking method trying to get a lock with ttl
   // expire is the time before expire. The time unit is second.
   async tryLock(request: TryLockRequest): Promise<boolean> {

src/client/Oss.ts

@@ -31,12 +31,12 @@ import {
 import { ObjectStorageServiceClient } from '../../proto/extension/v1/s3/oss_grpc_pb';
 import { API, APIOptions } from './API';
 
-export type OssOptions = {
+export interface OssOptions {
   // set default metadata on every request
   defaultRequestMeta?: Record<string, string>;
-};
+}
 
-export default class Oss extends API {
+export class Oss extends API {
   private readonly ossClient: ObjectStorageServiceClient;
   private readonly options: OssOptions;
 

src/client/PubSub.ts

@@ -18,7 +18,7 @@ import {
 import { RuntimeAPI } from './RuntimeAPI';
 import { PublishEventRequest } from '../types/PubSub';
 
-export default class PubSub extends RuntimeAPI {
+export class PubSub extends RuntimeAPI {
   async publish(request: PublishEventRequest): Promise<void> {
     const req = new PublishEventRequestPB();
     req.setPubsubName(request.pubsubName);

src/client/Sequencer.ts

@@ -20,7 +20,7 @@ import {
 import { RuntimeAPI } from './RuntimeAPI';
 import { GetNextIdRequest } from '../types/Sequencer';
 
-export default class Sequencer extends RuntimeAPI {
+export class Sequencer extends RuntimeAPI {
   // Get next unique id with some auto-increment guarantee
   async getNextId(request: GetNextIdRequest): Promise<string> {
     const req = new GetNextIdRequestPB();

src/client/State.ts

@@ -39,7 +39,7 @@ import {
 } from '../types/State';
 import { isEmptyPBMessage, convertMapToKVString } from '../utils';
 
-export default class State extends RuntimeAPI {
+export class State extends RuntimeAPI {
   // Saves an array of state objects
   async save(request: SaveStateRequest): Promise<void> {
     let states = request.states;

src/client/index.ts

@@ -0,0 +1,14 @@
+export * from './API';
+export * from './Binding';
+export * from './Client';
+export * from './Configuration';
+export * from './Cryption';
+export * from './File';
+export * from './Hello';
+export * from './Invoker';
+export * from './Lock';
+export * from './Oss';
+export * from './PubSub';
+export * from './RuntimeAPI';
+export * from './Sequencer';
+export * from './State';

src/index.ts

@@ -12,12 +12,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import Client, { ClientOptions } from './client/Client';
-import Server, { ServerOptions } from './server/Server';
-import GRPCServerImpl, { GRPCServerOptions } from './server/GRPCServerImpl';
+import { Client, ClientOptions } from './client/Client';
+import { Server, ServerOptions } from './server/Server';
+import { GRPCServerImpl, GRPCServerOptions } from './server/GRPCServerImpl';
 import * as utils from './utils';
 import * as RuntimeTypes from '../proto/runtime/v1/runtime_pb';
 import * as Types from './types';
+import * as Clients from './client';
+import * as Servers from './server';
 
 export {
   Client,
@@ -29,4 +31,6 @@ export {
   utils,
   RuntimeTypes,
   Types,
+  Clients,
+  Servers,
 };

src/server/GRPCServerImpl.ts

@@ -36,7 +36,7 @@ export interface GRPCServerOptions {
 
 // eslint-disable-next-line @typescript-eslint/ban-ts-comment
 // @ts-ignore
-export default class GRPCServerImpl implements IAppCallbackServer {
+export class GRPCServerImpl implements IAppCallbackServer {
   protected readonly handlersTopics: Record<string, PubSubCallback> = {};
   protected readonly subscriptionsList: TopicSubscription[] = [];
   protected readonly localStorage?: AsyncLocalStorage<any>;

src/server/PubSub.ts

@@ -11,15 +11,14 @@
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
- *
  */
 import { debuglog } from 'node:util';
 import { PubSubCallback } from '../types/PubSub';
-import GRPCServerImpl from './GRPCServerImpl';
+import { GRPCServerImpl } from './GRPCServerImpl';
 
 const debug = debuglog('layotto:server:pubsub');
 
-export default class PubSub {
+export class PubSub {
   readonly server: GRPCServerImpl;
 
   constructor(server: GRPCServerImpl) {

src/server/Server.ts

@@ -17,8 +17,8 @@ import { debuglog } from 'node:util';
 import { AsyncLocalStorage } from 'node:async_hooks';
 import { ServerCredentials, Server as GRPCServer } from '@grpc/grpc-js';
 import { AppCallbackService } from '../../proto/runtime/v1/appcallback_grpc_pb';
-import GRPCServerImpl from './GRPCServerImpl';
-import PubSub from './PubSub';
+import { GRPCServerImpl } from './GRPCServerImpl';
+import { PubSub } from './PubSub';
 
 const debug = debuglog('layotto:server:main');
 
@@ -27,7 +27,7 @@ export interface ServerOptions {
   localStorage?: AsyncLocalStorage<any>;
 }
 
-export default class Server {
+export class Server {
   readonly port: string;
   readonly pubsub: PubSub;
   protected readonly localStorage?: AsyncLocalStorage<any>;

src/server/index.ts

@@ -0,0 +1,3 @@
+export * from './GRPCServerImpl';
+export * from './PubSub';
+export * from './Server';

src/types/Cryption.ts

@@ -0,0 +1,17 @@
+import { RequestWithMeta } from './common';
+
+export type EncryptRequest = RequestWithMeta<{
+  plainText: Uint8Array | string;
+  keyId?: string;
+}>;
+
+export type DecryptRequest = RequestWithMeta<{
+  cipherText: Uint8Array | string;
+}>;
+
+export type DecryptResponse = {
+  plainText: Uint8Array;
+  keyId: string,
+  keyVersionId: string,
+  requestId: string,
+};

src/types/index.ts

@@ -9,4 +9,4 @@ export * as PubSub from './PubSub';
 export * as File from './File';
 export * as Binding from './Binding';
 export * as Oss from './Oss';
-
+export * as Cryption from './Cryption';

test/unit/index.test.ts

@@ -0,0 +1,31 @@
+import { strict as assert } from 'node:assert';
+import {
+  Clients, Client,
+  Servers, Server,
+} from '../../src';
+
+describe('index.test.ts', () => {
+  describe('Clients', () => {
+    it('should export Cryption Class', async () => {
+      assert(Clients.Cryption);
+      assert.equal(typeof Clients.Cryption.prototype.encrypt, 'function');
+    });
+
+    it('should export Client Class', async () => {
+      assert(Clients.Client);
+      assert.equal(Clients.Client, Client);
+    });
+  });
+
+  describe('Servers', () => {
+    it('should export PubSub Class', async () => {
+      assert(Servers.PubSub);
+      assert.equal(typeof Clients.PubSub.prototype.publish, 'function');
+    });
+
+    it('should export Server Class', async () => {
+      assert(Servers.Server);
+      assert.equal(Servers.Server, Server);
+    });
+  });
+});

tsconfig.json

@@ -3,8 +3,8 @@
   "compilerOptions": {
     "rootDir": "./src",
     "outDir": "./dist",
-    "module": "CommonJS",
-    "moduleResolution": "Node"
+    "module": "NodeNext",
+    "moduleResolution": "NodeNext"
   },
   "include": [ "src" ],
   "exclude": ["node_modules", "**/test/*"]