协议修改

This commit is contained in:
chen wei bo
2025-08-25 11:31:15 +08:00
parent da18ae3155
commit 6a6510e34a
11 changed files with 6533 additions and 21936 deletions
+1 -1
View File
@@ -5,7 +5,7 @@ import { AppConfigShape, Env } from "./env";
export const devConfig: AppConfigShape = {
env: Env.Dev,
endpoints: {
httpBase: "http://43.139.27.67:8081/",
httpBase: "http://120.25.215.205:20600/",
socketBase: "ws://127.0.0.1:9001/ws/",
cdn: {
bgm: "http://127.0.0.1:8081/BGM/",
+1 -1
View File
@@ -5,7 +5,7 @@ import { AppConfigShape, Env } from "./env";
export const testConfig: AppConfigShape = {
env: Env.Test,
endpoints: {
httpBase: "http://43.139.27.67:8081/",
httpBase: "http://120.25.215.205:20600/",
socketBase: "wss://www.confessioncontract.com/test/game/ai/response/",
cdn: {
bgm: "https://test-cdn.example.com/BGM/",
+13
View File
@@ -8,6 +8,8 @@ export class LoginData extends BaseData {
private _loginState = 0;
// token
private _token = "";
// refresh token
private _refreshToken = "";
// 操作类型,1:登录界面;2:断线重连;3:其他
private _operateType = 1;
// 公网IP
@@ -43,6 +45,17 @@ export class LoginData extends BaseData {
public get token(): string {
return this._token;
}
/** 设置登录refresh token */
public set refreshToken(value: string) {
this._refreshToken = value;
console.log("设置登录refresh token", this._refreshToken);
}
/** 获取登录refresh token */
public get refreshToken(): string {
return this._refreshToken;
}
/** 设置操作类型 */
public set operateType(value: number) {
@@ -15,7 +15,7 @@ export class ApiClient {
}
private constructor(private http = HttpManager.I) {}
private get baseUrl() { return AppConfig.I.getHttpBase() }
private get token() { return DataManager.I.getDataById<LoginData>(DataId.Login).getToken();}
private get token() { return DataManager.I.getDataById<LoginData>(DataId.Login).token;}
public async call<Req, Res>(ep: Endpoint<Req, Res>, req: Req): Promise<ApiResponse<Res>> {
const url = `${this.baseUrl}/${ep.path.replace(/^\/+/, "")}`;
@@ -67,12 +67,12 @@ export class ApiClient {
if (parsed && typeof parsed === "object" && typeof parsed.code === "number") {
return {
code: parsed.code,
msg: parsed.msg ?? (parsed.code === 1 ? "ok" : "error"),
data: parsed.Data as Res
msg: parsed.msg ?? (parsed.code === 0 ? "ok" : "error"),
data: parsed.data as Res
};
}
// 否则我们包一层
return { code: ApiCode.OK, msg: "ok", data: parsed.Data as Res };
return { code: ApiCode.OK, msg: "ok", data: parsed.data as Res };
} else if (ep.codec === "proto") {
const data = ProtoCodec.decode<Res>(ep.resType!, r.body);
// proto 场景一般没有 {code,msg} 包装,我们统一包一层
@@ -5,7 +5,7 @@ export interface ApiResponse<T = any> {
}
export const ApiCode = {
OK: 1,
OK: 0,
AUTH_EXPIRED: -401,
HTTP_ERROR: -400,
TIMEOUT: -408,
@@ -12,9 +12,9 @@ export class AuthService {
private constructor(private api = ApiClient.I) {}
// 登录
public async login(req: proto.ProtoMsg.ILoginReq): Promise<ApiResponse<proto.ProtoMsg.ILoginRsp>> {
let epData: Endpoint<proto.ProtoMsg.ILoginReq, proto.ProtoMsg.ILoginRsp> = {
path: "login",
public async login(req: proto.cs.ICSLoginReq): Promise<ApiResponse<proto.cs.ICSLoginRes>> {
let epData: Endpoint<proto.cs.ICSLoginReq, proto.cs.ICSLoginRes> = {
path: "api/acc/login",
method: "POST",
codec: "json",
needsAuth: false
@@ -48,13 +48,10 @@ export class HttpManager {
xhr.open(method, url, true);
if (sys.isNative) {
xhr.setRequestHeader("Accept-Encoding", "gzip,deflate");
xhr.setRequestHeader("content-type", "text/html;charset=utf-8");
xhr.setRequestHeader("Content-type", "text/html;charset=utf-8");
}
} else {
xhr.open(method, url, true);
if (!opt.rawBody) {
xhr.setRequestHeader("Content-Type", "application/json");
}
}
if (opt.headers) {
Object.keys(opt.headers).forEach(k => xhr.setRequestHeader(k, opt.headers![k]));