import { ADMIN_API_TOKEN, ADMIN_API_URL, OPID_PROFILE_SCREEN_PROVIDER } from "../Enum/EnvironmentVariable"; import Axios, { AxiosResponse } from "axios"; import { isMapDetailsData, MapDetailsData } from "../Messages/JsonMessages/MapDetailsData"; import { isRoomRedirect, RoomRedirect } from "../Messages/JsonMessages/RoomRedirect"; import { AdminApiData, isAdminApiData } from "../Messages/JsonMessages/AdminApiData"; import { z } from "zod"; import { isWokaDetail } from "../Messages/JsonMessages/PlayerTextures"; import qs from "qs"; export interface AdminBannedData { is_banned: boolean; message: string; } export const isFetchMemberDataByUuidResponse = z.object({ email: z.string(), userUuid: z.string(), tags: z.array(z.string()), visitCardUrl: z.nullable(z.string()), textures: z.array(isWokaDetail), messages: z.array(z.unknown()), anonymous: z.optional(z.boolean()), userRoomToken: z.optional(z.string()), }); export type FetchMemberDataByUuidResponse = z.infer; class AdminApi { private locale: string = 'en'; setLocale(locale: string){ //console.info('PUSHER LOCALE SET TO :', locale); this.locale = locale; } /** * @var playUri: is url of the room * @var userId: can to be undefined or email or uuid * @return MapDetailsData|RoomRedirect */ async fetchMapDetails(playUri: string, userId?: string): Promise { if (!ADMIN_API_URL) { return Promise.reject(new Error("No admin backoffice set!")); } const params: { playUri: string; userId?: string } = { playUri, userId, }; const res = await Axios.get>(ADMIN_API_URL + "/api/map", { headers: { Authorization: `${ADMIN_API_TOKEN}`, 'Accept-Language': this.locale }, params, }); const mapDetailData = isMapDetailsData.safeParse(res.data); const roomRedirect = isRoomRedirect.safeParse(res.data); if (mapDetailData.success) { return mapDetailData.data; } if (roomRedirect.success) { return roomRedirect.data; } console.error(mapDetailData.error.issues); console.error(roomRedirect.error.issues); throw new Error( "Invalid answer received from the admin for the /api/map endpoint. Received: " + JSON.stringify(res.data) ); } async fetchMemberDataByUuid( userIdentifier: string | null, playUri: string, ipAddress: string, characterLayers: string[] ): Promise { if (!ADMIN_API_URL) { return Promise.reject(new Error("No admin backoffice set!")); } const res = await Axios.get>(ADMIN_API_URL + "/api/room/access", { params: { userIdentifier, playUri, ipAddress, characterLayers, }, headers: { Authorization: `${ADMIN_API_TOKEN}`, 'Accept-Language': this.locale }, paramsSerializer: (p) => { return qs.stringify(p, { arrayFormat: "brackets" }); }, }); const fetchMemberDataByUuidResponse = isFetchMemberDataByUuidResponse.safeParse(res.data); if (fetchMemberDataByUuidResponse.success) { return fetchMemberDataByUuidResponse.data; } console.error(fetchMemberDataByUuidResponse.error.issues); throw new Error( "Invalid answer received from the admin for the /api/room/access endpoint. Received: " + JSON.stringify(res.data) ); } async fetchMemberDataByToken(organizationMemberToken: string, playUri: string | null): Promise { if (!ADMIN_API_URL) { return Promise.reject(new Error("No admin backoffice set!")); } //todo: this call can fail if the corresponding world is not activated or if the token is invalid. Handle that case. const res = await Axios.get(ADMIN_API_URL + "/api/login-url/" + organizationMemberToken, { params: { playUri }, headers: { Authorization: `${ADMIN_API_TOKEN}`, 'Accept-Language': this.locale }, }); const adminApiData = isAdminApiData.safeParse(res.data); if (adminApiData.success) { return adminApiData.data; } console.error(adminApiData.error.issues); console.error("Message received from /api/login-url is not in the expected format. Message: ", res.data); throw new Error("Message received from /api/login-url is not in the expected format."); } reportPlayer( reportedUserUuid: string, reportedUserComment: string, reporterUserUuid: string, reportWorldSlug: string ) { if (!ADMIN_API_URL) { return Promise.reject(new Error("No admin backoffice set!")); } return Axios.post( `${ADMIN_API_URL}/api/report`, { reportedUserUuid, reportedUserComment, reporterUserUuid, reportWorldSlug, }, { headers: { Authorization: `${ADMIN_API_TOKEN}`, 'Accept-Language': this.locale }, } ); } async verifyBanUser(userUuid: string, ipAddress: string, roomUrl: string): Promise { if (!ADMIN_API_URL) { return Promise.reject(new Error("No admin backoffice set!")); } //todo: this call can fail if the corresponding world is not activated or if the token is invalid. Handle that case. return Axios.get( ADMIN_API_URL + "/api/ban" + "?ipAddress=" + encodeURIComponent(ipAddress) + "&token=" + encodeURIComponent(userUuid) + "&roomUrl=" + encodeURIComponent(roomUrl), { headers: { Authorization: `${ADMIN_API_TOKEN}`, 'Accept-Language': this.locale } } ).then((data) => { return data.data; }); } async getUrlRoomsFromSameWorld(roomUrl: string): Promise { if (!ADMIN_API_URL) { return Promise.reject(new Error("No admin backoffice set!")); } return Axios.get(ADMIN_API_URL + "/api/room/sameWorld" + "?roomUrl=" + encodeURIComponent(roomUrl), { headers: { Authorization: `${ADMIN_API_TOKEN}`, 'Accept-Language': this.locale }, }).then((data) => { return data.data; }); } /** * * @param accessToken */ getProfileUrl(accessToken: string): string { if (!OPID_PROFILE_SCREEN_PROVIDER) { throw new Error("No admin backoffice set!"); } return `${OPID_PROFILE_SCREEN_PROVIDER}?accessToken=${accessToken}`; } async logoutOauth(token: string) { await Axios.get(ADMIN_API_URL + `/oauth/logout?token=${token}`); } } export const adminApi = new AdminApi();