feat: change methods to appear on object prototype

Author: HomelessDinosaur

src/api/events/v0/events.ts

@@ -69,7 +69,7 @@ export class Topic {
    * }
    * ```
    */
-  publish = async (event: NitricEvent): Promise<NitricEvent> => {
+  async publish(event: NitricEvent): Promise<NitricEvent> {
     const { id, payloadType = 'none', payload } = event;
     const request = new EventPublishRequest();
     const evt = new PbEvent();
@@ -140,7 +140,7 @@ export class Eventing {
    * ```
    *
    */
-  topic = (name: string): Topic => {
+  public topic(name: string): Topic {
     if (!name) {
       throw new InvalidArgumentError('A topic name is needed to use a Topic.');
     }
@@ -162,7 +162,7 @@ export class Eventing {
    * const topics = await eventing.topics();
    * ```
    */
-  topics = async (): Promise<Topic[]> => {
+  public async topics(): Promise<Topic[]> {
     return new Promise((resolve, reject) => {
       this.TopicServiceClient.list(null, (error, response) => {
         if (error) {

src/api/queues/v0/queues.ts

@@ -109,9 +109,9 @@ export class Queue {
    *   };
    * });
    */
-  async send(tasks: Task[]): Promise<FailedMessage[]>;
-  async send(tasks: Task): Promise<void>;
-  async send(tasks: Task | Task[]): Promise<void | FailedMessage[]> {
+  public async send(tasks: Task[]): Promise<FailedMessage[]>;
+  public async send(tasks: Task): Promise<void>;
+  public async send(tasks: Task | Task[]): Promise<void | FailedMessage[]> {
     return new Promise((resolve, reject) => {
       const request = new QueueSendBatchRequest();
 
@@ -170,7 +170,7 @@ export class Queue {
    * // do something with task
    * ```
    */
-  receive = async (depth?: number): Promise<ReceivedTask[]> => {
+  public async receive(depth?: number): Promise<ReceivedTask[]> {
     return new Promise((resolve, reject) => {
       const request = new QueueReceiveRequest();
 
@@ -243,7 +243,7 @@ export class ReceivedTask implements Task {
    * await task.complete();
    * ```
    */
-  complete = async (): Promise<void> => {
+  public async complete(): Promise<void> {
     try {
       const request = new QueueCompleteRequest();
 

src/api/secrets/v0/secrets.ts

@@ -51,7 +51,7 @@ export class Secrets {
    * const secret = secrets().secret("my-secret");
    * ```
    */
-  secret = (name: string): Secret => {
+  public secret = (name: string): Secret => {
     if (!name) {
       throw new InvalidArgumentError('A name is required to use a Secret.');
     }
@@ -86,7 +86,7 @@ export class Secret {
    * }
    * ```
    */
-  put = async (secret: string | Uint8Array) => {
+  public async put(secret: string | Uint8Array) {
     return new Promise<SecretVersion>((resolve, reject) => {
       const secretBuff =
         typeof secret === 'string' ? ENCODER.encode(secret) : secret;
@@ -128,7 +128,7 @@ export class Secret {
    * ```
    *
    */
-  latest = () => {
+  public latest() {
     return this.version('latest');
   };
 
@@ -146,7 +146,7 @@ export class Secret {
    * ```
    *
    */
-  version = (version: string) => {
+  public version(version: string) {
     if (!version) {
       throw new InvalidArgumentError(
         'A version is required to create a version reference.'
@@ -193,7 +193,7 @@ class SecretVersion {
    * }
    * ```
    */
-  access = async (): Promise<SecretValue> => {
+  public async access(): Promise<SecretValue> {
     return new Promise((resolve, reject) => {
       const request = new SecretAccessRequest();
       request.setSecretVersion(SecretVersion.toWire(this));
@@ -259,7 +259,7 @@ class SecretValue {
    * }
    * ```
    */
-  asBytes = () => {
+  public asBytes = () => {
     return this.val;
   };
 
@@ -277,7 +277,7 @@ class SecretValue {
    * }
    * ```
    */
-  asString = () => {
+  public asString = () => {
     return DECODER.decode(this.asBytes());
   };
 }

src/api/storage/v0/storage.ts

@@ -41,7 +41,7 @@ export class Storage {
    * @param name of the bucket to reference
    * @returns a bucket reference
    */
-  bucket = (name: string): Bucket => {
+  public bucket(name: string): Bucket {
     if (!name) {
       throw new InvalidArgumentError(
         'A bucket name is required to use a Bucket.'
@@ -63,7 +63,7 @@ export class Bucket {
     this.name = name;
   }
 
-  file = (name: string) => {
+  public file(name: string) {
     if (!name) {
       throw new InvalidArgumentError(
         'A file name/path is required to use a File.'
@@ -107,10 +107,10 @@ export class File {
   /**
    * Create a presigned url for reading or writing for the given file reference
    */
-  signUrl = async (
+  public async signUrl(
     mode: FileMode,
     opts: SignUrlOptions = DEFAULT_SIGN_URL_OPTS
-  ): Promise<string> => {
+  ): Promise<string> {
     const { expiry } = {
       // inject default options in case where some are undefined
       ...DEFAULT_SIGN_URL_OPTS,
@@ -151,7 +151,7 @@ export class File {
    * await storage.bucket("my-bucket").file("my-item").write(buf);
    * ```
    */
-  write = async (body: Uint8Array): Promise<void> => {
+  public async write (body: Uint8Array): Promise<void> {
     const request = new StorageWriteRequest();
     request.setBucketName(this.bucket.name);
     request.setKey(this.name);
@@ -181,7 +181,7 @@ export class File {
    * const bytes = await storage.bucket("my-bucket").file("my-item").read();
    * ```
    */
-  read = async (): Promise<Uint8Array> => {
+  public async read(): Promise<Uint8Array> {
     const request = new StorageReadRequest();
     request.setBucketName(this.bucket.name);
     request.setKey(this.name);
@@ -210,7 +210,7 @@ export class File {
    * const bytes = await storage.bucket("my-bucket").file("my-item").delete();
    * ```
    */
-  delete = async (): Promise<void> => {
+  public async delete(): Promise<void> {
     const request = new StorageDeleteRequest();
     request.setBucketName(this.bucket.name);
     request.setKey(this.name);

src/resources/bucket.ts

@@ -30,7 +30,7 @@ const everything: BucketPermission[] = ['reading', 'writing', 'deleting'];
 /**
  * Cloud storage bucket resource for large file storage.
  */
-class BucketResource extends Base<BucketPermission> {
+export class BucketResource extends Base<BucketPermission> {
   /**
    * Register this bucket as a required resource for the calling function/container
    * @returns a promise that resolves when the registration is complete

src/resources/collection.ts

@@ -31,7 +31,7 @@ const everything: CollectionPermission[] = ['reading', 'writing', 'deleting'];
 /**
  * A document collection resources, such as a collection/table in a document database.
  */
-class CollectionResource<T extends DocumentStructure> extends Base<CollectionPermission> {
+export class CollectionResource<T extends DocumentStructure> extends Base<CollectionPermission> {
   /**
    * Register this collection as a required resource for the calling function/container
    * @returns a promise that resolves when the registration is complete

src/resources/secret.ts

@@ -30,7 +30,7 @@ const everything: SecretPermission[] = ['put', 'access'];
 /**
  * Cloud secret resource for secret storage
  */
-class SecretResource extends Base<SecretPermission> {
+export class SecretResource extends Base<SecretPermission> {
   protected async register(): Promise<Resource> {
     const req = new ResourceDeclareRequest();
     const resource = new Resource();
@@ -70,7 +70,7 @@ class SecretResource extends Base<SecretPermission> {
       }, []);
   }
 
-  protected for(...perms: SecretPermission[]): Secret {
+  public for(...perms: SecretPermission[]): Secret {
     this.registerPolicy(...perms);
 
     return secrets().secret(this.name);

src/resources/topic.ts

@@ -53,7 +53,7 @@ class Subscription {
 /**
  * Topic resource for pub/sub async messaging.
  */
-class TopicResource extends Base<TopicPermission> {
+export class TopicResource extends Base<TopicPermission> {
   /**
    * Register this topic as a required resource for the calling function/container
    * @returns a promise that resolves when the registration is complete