feat: allow passing options (#49)

Author: alexbarnsley

__tests__/mocks/node.ts

@@ -15,5 +15,6 @@ export const mockNode = (host: string) => {
 
 	nock(host)
 		.get("/node/fees")
+		.query({ days: 30 })
 		.reply(200, { data: [] });
 };

__tests__/resources/node.test.ts

@@ -3,7 +3,7 @@ import { configureMocks } from "../mocks";
 
 const resource: Node = configureMocks<Node>(Node);
 
-describe("API - 2.0 - Resources - Loader", () => {
+describe("API - 2.0 - Resources - Node", () => {
 	it("should call \"status\" method", async () => {
 		const response = await resource.status();
 

src/connection.ts

@@ -5,6 +5,8 @@ import { IResponse } from "./interfaces";
 import { Resources } from "./resources";
 
 export class Connection {
+	private opts: Record<string, any>;
+
 	public constructor(private readonly host: string) {
 		if (!isUrl(host)) {
 			throw new Error(`${host} is not a valid URL.`);
@@ -18,6 +20,12 @@ export class Connection {
 		return new Resources[name](this);
 	}
 
+	public withOptions(opts: Record<string, any>): this {
+		this.opts = opts;
+
+		return this;
+	}
+
 	public async get<T = any>(url: string, opts?: Record<string, any>): Promise<IResponse<T>> {
 		return this.sendRequest("get", url, opts);
 	}
@@ -27,10 +35,7 @@ export class Connection {
 	}
 
 	private async sendRequest<T>(method: string, url: string, opts?: Record<string, any>): Promise<IResponse<T>> {
-		if (!opts) {
-			// @ts-ignore
-			opts = {};
-		}
+		opts = { ...this.opts, ...(opts || {}) };
 
 		if (opts.body && typeof opts !== "string") {
 			// @ts-ignore

src/resources/blocks.ts

@@ -3,18 +3,18 @@ import { Resource } from "./resource";
 
 export class Blocks extends Resource {
 	public async all<T = any>(query?: Record<string, any>): Promise<IResponse<T>> {
-		return this.connection.get("blocks", query);
+		return this.sendGet("blocks", query);
 	}
 
 	public async get<T = any>(id: string): Promise<IResponse<T>> {
-		return this.connection.get(`blocks/${id}`);
+		return this.sendGet(`blocks/${id}`);
 	}
 
 	public async transactions<T = any>(id: string, query?: Record<string, any>): Promise<IResponse<T>> {
-		return this.connection.get(`blocks/${id}/transactions`, query);
+		return this.sendGet(`blocks/${id}/transactions`, query);
 	}
 
 	public async search<T = any>(payload?: Record<string, any>): Promise<IResponse<T>> {
-		return this.connection.post("blocks/search", payload);
+		return this.sendPost("blocks/search", payload);
 	}
 }

src/resources/delegates.ts

@@ -3,18 +3,18 @@ import { Resource } from "./resource";
 
 export class Delegates extends Resource {
 	public async all<T = any>(query?: Record<string, any>): Promise<IResponse<T>> {
-		return this.connection.get("delegates", query);
+		return this.sendGet("delegates", query);
 	}
 
 	public async get<T = any>(id: string): Promise<IResponse<T>> {
-		return this.connection.get(`delegates/${id}`);
+		return this.sendGet(`delegates/${id}`);
 	}
 
 	public async blocks<T = any>(id: string, query?: Record<string, any>): Promise<IResponse<T>> {
-		return this.connection.get(`delegates/${id}/blocks`, query);
+		return this.sendGet(`delegates/${id}/blocks`, query);
 	}
 
 	public async voters<T = any>(id: string, query?: Record<string, any>): Promise<IResponse<T>> {
-		return this.connection.get(`delegates/${id}/voters`, query);
+		return this.sendGet(`delegates/${id}/voters`, query);
 	}
 }

src/resources/node.ts

@@ -3,19 +3,19 @@ import { Resource } from "./resource";
 
 export class Node extends Resource {
 	public async status<T = any>(): Promise<IResponse<T>> {
-		return this.connection.get("node/status");
+		return this.sendGet("node/status");
 	}
 
 	public async syncing<T = any>(): Promise<IResponse<T>> {
-		return this.connection.get("node/syncing");
+		return this.sendGet("node/syncing");
 	}
 
 	public async configuration<T = any>(): Promise<IResponse<T>> {
-		return this.connection.get("node/configuration");
+		return this.sendGet("node/configuration");
 	}
 
 	public async fees<T = any>(days: number): Promise<IResponse<T>> {
-		return this.connection.get("node/fees", {
+		return this.sendGet("node/fees", {
 			days,
 		});
 	}

src/resources/peers.ts

@@ -3,10 +3,10 @@ import { Resource } from "./resource";
 
 export class Peers extends Resource {
 	public async all<T = any>(query?: Record<string, any>): Promise<IResponse<T>> {
-		return this.connection.get("peers", query);
+		return this.sendGet("peers", query);
 	}
 
 	public async get<T = any>(ip: string): Promise<IResponse<T>> {
-		return this.connection.get(`peers/${ip}`);
+		return this.sendGet(`peers/${ip}`);
 	}
 }

src/resources/resource.ts

@@ -1,5 +1,36 @@
 import { Connection } from "../connection";
+import { IResponse } from "../interfaces";
 
 export class Resource {
+	private opts: Record<string, any> = {};
+
 	public constructor(protected readonly connection: Connection) {}
+
+	public withOptions(opts: Record<string, any>): this {
+		this.opts = opts;
+
+		return this;
+	}
+
+	public resetOptions(): this {
+		this.opts = {};
+
+		return this;
+	}
+
+	public async sendGet<T = any>(url: string, query?: Record<string, any>): Promise<IResponse<T>> {
+		const response = await this.connection.get(url, { ...this.opts, ...{ query } });
+
+		this.resetOptions();
+
+		return response;
+	}
+
+	public async sendPost<T = any>(url: string, body?: Record<string, any>): Promise<IResponse<T>> {
+		const response = await this.connection.post(url, { ...this.opts, ...{ body } });
+
+		this.resetOptions();
+
+		return response;
+	}
 }

src/resources/transactions.ts

@@ -3,34 +3,34 @@ import { Resource } from "./resource";
 
 export class Transactions extends Resource {
 	public async all<T = any>(query?: Record<string, any>): Promise<IResponse<T>> {
-		return this.connection.get("transactions", query);
+		return this.sendGet("transactions", query);
 	}
 
 	public async create<T = any>(payload: object[]): Promise<IResponse<T>> {
-		return this.connection.post("transactions", payload);
+		return this.sendPost("transactions", payload);
 	}
 
 	public async get<T = any>(id: string): Promise<IResponse<T>> {
-		return this.connection.get(`transactions/${id}`);
+		return this.sendGet(`transactions/${id}`);
 	}
 
 	public async allUnconfirmed<T = any>(query?: Record<string, any>): Promise<IResponse<T>> {
-		return this.connection.get("transactions/unconfirmed", query);
+		return this.sendGet("transactions/unconfirmed", query);
 	}
 
 	public async getUnconfirmed<T = any>(id: string): Promise<IResponse<T>> {
-		return this.connection.get(`transactions/unconfirmed/${id}`);
+		return this.sendGet(`transactions/unconfirmed/${id}`);
 	}
 
 	public async search<T = any>(payload: Record<string, any>): Promise<IResponse<T>> {
-		return this.connection.post("transactions/search", payload);
+		return this.sendPost("transactions/search", payload);
 	}
 
 	public async types<T = any>(): Promise<IResponse<T>> {
-		return this.connection.get("transactions/types");
+		return this.sendGet("transactions/types");
 	}
 
 	public async fees<T = any>(): Promise<IResponse<T>> {
-		return this.connection.get("transactions/fees");
+		return this.sendGet("transactions/fees");
 	}
 }

src/resources/votes.ts

@@ -3,10 +3,10 @@ import { Resource } from "./resource";
 
 export class Votes extends Resource {
 	public async all<T = any>(query?: Record<string, any>): Promise<IResponse<T>> {
-		return this.connection.get("votes", query);
+		return this.sendGet("votes", query);
 	}
 
 	public async get<T = any>(id: string): Promise<IResponse<T>> {
-		return this.connection.get(`votes/${id}`);
+		return this.sendGet(`votes/${id}`);
 	}
 }