1 Commits

Author SHA1 Message Date
d4e9f48751 Add tribufu client class 2025-05-16 20:38:01 -03:00
12 changed files with 182 additions and 66 deletions

View File

@ -1,17 +1,15 @@
root = true root = true
[*] [*]
charset = utf-8
end_of_line = lf end_of_line = lf
indent_size = 4
indent_style = space indent_style = space
insert_final_newline = true indent_size = 4
max_line_length = 120 charset = utf-8
trim_trailing_whitespace = true trim_trailing_whitespace = true
insert_final_newline = true
[*.md] [*.md]
indent_size = 1
trim_trailing_whitespace = false trim_trailing_whitespace = false
[.env*] [*.env*]
insert_final_newline = false insert_final_newline = false

View File

@ -8,7 +8,9 @@ dotenv.config();
async function main() { async function main() {
const tribufu = TribufuApi.fromEnv(); const tribufu = TribufuApi.fromEnv();
console.log(await tribufu.getUserInfo()); console.log(
await tribufu.getServerByAddressAndQueryPort("mine.tribufu.com", 25565),
);
} }
main(); main();

14
examples/client.js Normal file
View File

@ -0,0 +1,14 @@
// Copyright (c) Tribufu. All Rights Reserved.
// SPDX-License-Identifier: MIT AND Apache-2.0
import dotenv from "dotenv";
import { TribufuClient } from "../build/index.mjs";
dotenv.config();
async function main() {
const tribufu = TribufuClient.fromEnv();
console.log(await tribufu.getClientInfo());
}
main();

View File

@ -1,6 +1,6 @@
{ {
"name": "tribufu", "name": "tribufu",
"version": "1.0.2", "version": "1.0.0",
"description": "Tribufu JS SDK", "description": "Tribufu JS SDK",
"repository": "https://github.com/Tribufu/TribufuJs", "repository": "https://github.com/Tribufu/TribufuJs",
"author": "Tribufu <contact@Tribufu.com>", "author": "Tribufu <contact@Tribufu.com>",

View File

@ -92,10 +92,12 @@ export abstract class TribufuApiBase {
* @returns * @returns
*/ */
protected transformOptions(options: RequestInit) { protected transformOptions(options: RequestInit) {
if (this.apiKey) {
options.headers = { options.headers = {
...options.headers, ...options.headers,
...this.getHeaders(), ...this.getHeaders(),
}; };
}
return Promise.resolve(options); return Promise.resolve(options);
} }

View File

@ -8,7 +8,7 @@
/* eslint-disable */ /* eslint-disable */
// ReSharper disable InconsistentNaming // ReSharper disable InconsistentNaming
import { TribufuApiBase } from "./base"; import { TribufuApiBase } from "./api.base";
export class TribufuApiGenerated extends TribufuApiBase { export class TribufuApiGenerated extends TribufuApiBase {
private http: { fetch(url: RequestInfo, init?: RequestInit): Promise<Response> }; private http: { fetch(url: RequestInfo, init?: RequestInit): Promise<Response> };
@ -447,7 +447,7 @@ export class TribufuApiGenerated extends TribufuApiBase {
* Get a list of games. * Get a list of games.
* @return OK * @return OK
*/ */
getGames(): Promise<Game[]> { getGames(): Promise<Application[]> {
let url_ = this.baseUrl + "/v1/games"; let url_ = this.baseUrl + "/v1/games";
url_ = url_.replace(/[?&]$/, ""); url_ = url_.replace(/[?&]$/, "");
@ -465,13 +465,13 @@ export class TribufuApiGenerated extends TribufuApiBase {
}); });
} }
protected processGetGames(response: Response): Promise<Game[]> { protected processGetGames(response: Response): Promise<Application[]> {
const status = response.status; const status = response.status;
let _headers: any = {}; if (response.headers && response.headers.forEach) { response.headers.forEach((v: any, k: any) => _headers[k] = v); }; let _headers: any = {}; if (response.headers && response.headers.forEach) { response.headers.forEach((v: any, k: any) => _headers[k] = v); };
if (status === 200) { if (status === 200) {
return response.text().then((_responseText) => { return response.text().then((_responseText) => {
let result200: any = null; let result200: any = null;
result200 = _responseText === "" ? null : JSON.parse(_responseText, this.jsonParseReviver) as Game[]; result200 = _responseText === "" ? null : JSON.parse(_responseText, this.jsonParseReviver) as Application[];
return result200; return result200;
}); });
} else if (status !== 200 && status !== 204) { } else if (status !== 200 && status !== 204) {
@ -479,14 +479,14 @@ export class TribufuApiGenerated extends TribufuApiBase {
return throwException("An unexpected server error occurred.", status, _responseText, _headers); return throwException("An unexpected server error occurred.", status, _responseText, _headers);
}); });
} }
return Promise.resolve<Game[]>(null as any); return Promise.resolve<Application[]>(null as any);
} }
/** /**
* Get a game by id. * Get a game by id.
* @return OK * @return OK
*/ */
getGameById(id: string): Promise<Game> { getGameById(id: string): Promise<Application> {
let url_ = this.baseUrl + "/v1/games/{id}"; let url_ = this.baseUrl + "/v1/games/{id}";
if (id === undefined || id === null) if (id === undefined || id === null)
throw new Error("The parameter 'id' must be defined."); throw new Error("The parameter 'id' must be defined.");
@ -507,13 +507,13 @@ export class TribufuApiGenerated extends TribufuApiBase {
}); });
} }
protected processGetGameById(response: Response): Promise<Game> { protected processGetGameById(response: Response): Promise<Application> {
const status = response.status; const status = response.status;
let _headers: any = {}; if (response.headers && response.headers.forEach) { response.headers.forEach((v: any, k: any) => _headers[k] = v); }; let _headers: any = {}; if (response.headers && response.headers.forEach) { response.headers.forEach((v: any, k: any) => _headers[k] = v); };
if (status === 200) { if (status === 200) {
return response.text().then((_responseText) => { return response.text().then((_responseText) => {
let result200: any = null; let result200: any = null;
result200 = _responseText === "" ? null : JSON.parse(_responseText, this.jsonParseReviver) as Game; result200 = _responseText === "" ? null : JSON.parse(_responseText, this.jsonParseReviver) as Application;
return result200; return result200;
}); });
} else if (status !== 200 && status !== 204) { } else if (status !== 200 && status !== 204) {
@ -521,7 +521,7 @@ export class TribufuApiGenerated extends TribufuApiBase {
return throwException("An unexpected server error occurred.", status, _responseText, _headers); return throwException("An unexpected server error occurred.", status, _responseText, _headers);
}); });
} }
return Promise.resolve<Game>(null as any); return Promise.resolve<Application>(null as any);
} }
/** /**
@ -2746,40 +2746,6 @@ export interface CryptoViewModel {
decoded: string | null; decoded: string | null;
} }
export interface Game {
game_port: number | null;
query_port: number | null;
rcon_port: number | null;
server_count: number;
steam_app_id: number | null;
steam_server_app_id: number | null;
enable_servers: boolean;
rust_gamedig_id: string | null;
node_gamedig_id: string | null;
server_connect_url: string | null;
server_tags: string | null;
id: string;
name: string | null;
description: string | null;
type: ApplicationType;
organization_id: string | null;
icon_url: string | null;
banner_url: string | null;
capsule_image_url: string | null;
library_image_url: string | null;
parent_id: string | null;
slug: string | null;
visibility: number;
password: string | null;
primary: number;
user_count: number;
achievement_count: number;
badge_count: number | null;
download_count: number;
created: string;
updated: string | null;
}
export interface GameServer { export interface GameServer {
id: string; id: string;
name: string | null; name: string | null;
@ -2853,7 +2819,6 @@ export interface Group {
export interface GroupGame { export interface GroupGame {
group_id: string; group_id: string;
application_id: string; application_id: string;
application: Application;
stats: any | null; stats: any | null;
acquired: string; acquired: string;
last_used: string | null; last_used: string | null;

1
src/api/api.include.ts Normal file
View File

@ -0,0 +1 @@
import { TribufuApiBase } from "./api.base";

View File

@ -4,7 +4,7 @@
"documentGenerator": { "documentGenerator": {
"fromDocument": { "fromDocument": {
"json": "", "json": "",
"url": "http://localhost:5000/openapi.json", "url": "http://localhost:5000/v1/openapi.json",
"output": null, "output": null,
"newLineBehavior": "Auto" "newLineBehavior": "Auto"
} }
@ -48,7 +48,7 @@
"useLeafType": false, "useLeafType": false,
"classTypes": [], "classTypes": [],
"extendedClasses": [], "extendedClasses": [],
"extensionCode": "include.ts", "extensionCode": "api.include.ts",
"generateDefaultValues": true, "generateDefaultValues": true,
"excludedTypeNames": [], "excludedTypeNames": [],
"excludedParameterNames": [], "excludedParameterNames": [],
@ -67,7 +67,7 @@
"templateDirectory": null, "templateDirectory": null,
"serviceHost": null, "serviceHost": null,
"serviceSchemes": null, "serviceSchemes": null,
"output": "generated.ts", "output": "api.generated.ts",
"newLineBehavior": "LF" "newLineBehavior": "LF"
} }
} }

133
src/api/client.ts Normal file
View File

@ -0,0 +1,133 @@
// Copyright (c) Tribufu. All Rights Reserved.
// SPDX-License-Identifier: MIT
import { TribufuApi } from ".";
import { GrantType, TokenHintType } from "./generated";
/**
* **Tribufu Client**
*
* Use this class to interact with Tribufu OAuth service.
*/
export class TribufuClient extends TribufuApi {
private clientId: string | null = null;
private clientSecret: string | null = null;
private accessToken: string | null = null;
private refreshToken: string | null = null;
private expiresIn: number = 0;
constructor(clientId: string, clientSecret: string) {
if (!clientId || !clientSecret) {
throw new Error("ClientId and ClientSecret are required");
}
super({ credentials: `Basic ${Buffer.from(`${clientId}:${clientSecret}`).toString("base64")}` });
this.clientId = clientId;
this.clientSecret = clientSecret;
}
/**
* Try to create a TribufuClient from environment variables.
*
* - This will only work if the environment variables are set.
*
* @param prefix A prefix for the environment variables. Default is `TRIBUFU`.
* @returns TribufuClient | null
* @example
* ```ts
* // process.env.TRIBUFU_CLIENT_ID
* // process.env.TRIBUFU_CLIENT_SECRET
* const client = TribufuClient.fromEnv();
* ```
*/
public static fromEnv(prefix?: string | null): TribufuApi | null {
if (typeof process === "undefined") {
return null;
}
const clientId = process.env[`${prefix || "TRIBUFU"}_CLIENT_ID`];
const clientSecret = process.env[`${prefix || "TRIBUFU"}_CLIENT_SECRET`];
if (clientId && clientSecret) {
return new TribufuClient(clientId, clientSecret);
}
return null;
}
private useClientCredentials(): void {
if (this.clientId && this.clientSecret) {
this.credentials = `Basic ${Buffer.from(`${this.clientId}:${this.clientSecret}`).toString("base64")}`;
}
}
private useBearerCredentials(): void {
if (this.accessToken) {
this.credentials = `Bearer ${this.accessToken}`;
}
}
public async login(username: string, password: string): Promise<boolean> {
this.useClientCredentials();
const response = await this.createToken({
grant_type: GrantType.Password,
code: null,
username,
password,
refresh_token: null,
client_id: this.clientId,
redirect_uri: null,
code_verifier: null,
});
if (response) {
this.accessToken = response.access_token;
this.refreshToken = response.refresh_token;
this.expiresIn = response.expires_in;
this.useBearerCredentials();
}
return !!response;
}
public async refresh(): Promise<boolean> {
this.useClientCredentials();
const response = await this.createToken({
grant_type: GrantType.Refresh_token,
code: null,
username: null,
password: null,
refresh_token: this.refreshToken,
client_id: this.clientId,
redirect_uri: null,
code_verifier: null,
});
if (response) {
this.accessToken = response.access_token;
this.refreshToken = response.refresh_token;
this.expiresIn = response.expires_in;
this.useBearerCredentials();
}
return !!response;
}
public logout(): Promise<any> {
this.useClientCredentials();
const response = this.revokeToken({
token: this.refreshToken,
token_type_hint: TokenHintType.Refresh_token,
});
this.accessToken = null;
this.refreshToken = null;
this.expiresIn = 0;
return response;
}
}

View File

@ -1 +0,0 @@
import { TribufuApiBase } from "./base";

View File

@ -2,8 +2,8 @@
// SPDX-License-Identifier: MIT // SPDX-License-Identifier: MIT
import { TRIBUFU_API_URL } from ".."; import { TRIBUFU_API_URL } from "..";
import { TribufuApiBase } from "./base"; import { TribufuApiBase } from "./api.base";
import { TribufuApiGenerated } from "./generated"; import { TribufuApiGenerated } from "./api.generated";
import { TribufuApiOptions } from "../options"; import { TribufuApiOptions } from "../options";
/** /**
@ -98,6 +98,8 @@ export class TribufuApi extends TribufuApiGenerated {
} }
const baseUrl = process.env[`TRIBUFU_API_URL`] || null; const baseUrl = process.env[`TRIBUFU_API_URL`] || null;
return TribufuApiBase.debugEnabled() && baseUrl ? baseUrl : TRIBUFU_API_URL; return TribufuApiBase.debugEnabled() && baseUrl
? baseUrl
: TRIBUFU_API_URL;
} }
} }

View File

@ -22,9 +22,9 @@ export {
TribufuApiSingleton, TribufuApiSingleton,
}; };
export * from "./api/base"; export * from "./api/api.base";
export * from "./api/generated"; export * from "./api/api.generated";
export * from "./api/include"; export * from "./api/api.include";
export * from "./api/index"; export * from "./api/index";
export * from "./api/singletion"; export * from "./api/singletion";
export * from "./http/headers"; export * from "./http/headers";