import type { GConstructor, EntityServerClientBase } from "../../client/base.js"; /** transactionSubmit 의 단일 작업. data 안의 "$tx.{i}" 는 i 번째 submit 결과 seq 로 치환됩니다. */ export interface TransactionSubmitOp { entity: string; action?: "submit" | "delete"; data?: Record; seq?: number; hard?: boolean; } /** transactionSubmit 응답. results 는 op 순서대로 실행 결과(seq 포함). */ export interface TransactionSubmitResult { ok: boolean; results: Array<{ index: number; entity: string; action: "submit" | "delete"; seq: number; }>; } export declare function TransactionMixin>(Base: TBase): { new (...args: any[]): { /** 트랜잭션을 시작하고 transaction_id를 반환합니다. */ transactionStart(body?: Record): Promise; /** * 여러 엔티티 op 를 큐 없이 단일 DB 트랜잭션으로 한 번에 실행합니다. (start/commit 왕복 없이 1요청) * * op.data 안에 "$tx.{i}" 문자열을 쓰면 i 번째 submit 결과 seq 로 치환됩니다. * 예) 부모-자식 1왕복 생성: * transactionSubmit([ * { entity: "stock_order", data: { ...header } }, // op[0] * { entity: "stock_order_item", data: { order_seq: "$tx.0", ... } }, // op[1] * ]) * 하나라도 실패하면 전체 롤백됩니다. */ transactionSubmit(ops: TransactionSubmitOp[]): Promise; /** 지정한 트랜잭션을 커밋합니다. */ transactionCommit(transactionId: string): Promise; /** 지정한 트랜잭션을 롤백합니다. */ transactionRollback(transactionId: string): Promise; baseUrl: string; token: string; anonymousPacketToken: string; apiKey: string; hmacSecret: string; encryptRequests: boolean; debugPlainSecret: string; csrfEnabled: boolean; csrfHeaderName: string; csrfCookieName: string; csrfRefresher: (() => Promise) | null; requestAbortControllers: Map; activeTxId: string | null; initialHealthFired: boolean; keepSession: boolean; refreshBuffer: number; onTokenRefreshed?: (accessToken: string, expiresIn: number) => void; onSessionExpired?: (error: Error) => void; onHealthChange?: (online: boolean) => void; sessionRefreshToken: string | null; refreshTimer: ReturnType | null; healthTickTimer: ReturnType | null; healthTickPromise: Promise | null; realtimeEnabled: boolean; realtimePath: string; realtimeAutoReconnect: boolean; realtimeReconnectDelayMs: number; realtimeStatus: import("../../types.js").RealtimeConnectionStatus; realtimeSocket: WebSocket | null; realtimeConnectPromise: Promise | null; realtimeReconnectTimer: ReturnType | null; realtimeShouldReconnect: boolean; realtimeMessageListeners: Set; realtimeStatusListeners: Set; realtimeEventListeners: Map>; configure(options: Partial): void; fireInitialHealth(): void; setToken(token: string): void; setAccessTokenFromResponse(token: string): void; syncRealtimeWithToken(): void; setAnonymousPacketToken(token: string): void; setApiKey(apiKey: string): void; setHmacSecret(secret: string): void; setEncryptRequests(value: boolean): void; setCsrfEnabled(enabled: boolean): void; addRealtimeListener(listener: import("../../types.js").RealtimeMessageListener): void; removeRealtimeListener(listener: import("../../types.js").RealtimeMessageListener): void; addRealtimeStatusListener(listener: import("../../types.js").RealtimeStatusListener): void; removeRealtimeStatusListener(listener: import("../../types.js").RealtimeStatusListener): void; addRealtimeEventListener(eventName: string, listener: import("../../types.js").RealtimeMessageListener): void; removeRealtimeEventListener(eventName: string, listener: import("../../types.js").RealtimeMessageListener): void; connectRealtime(): Promise; disconnectRealtime(reason?: string): void; sendRealtime(message: import("../../types.js").RealtimeEnvelope | Record): boolean; subscribeRealtime(subscriptions: string[]): boolean; unsubscribeRealtime(subscriptions: string[]): boolean; startHealthTick(intervalMs?: number, runImmediately?: boolean): void; stopHealthTick(): void; scheduleKeepSession(refreshToken: string, expiresIn: number, refreshFn: (rt: string) => Promise<{ access_token: string; expires_in: number; }>): void; clearRefreshTimer(): void; stopKeepSession(): void; applyRealtimeOptions(options?: boolean | import("../../types.js").RealtimeClientOptions): void; buildRealtimeUrl(): string; handleRealtimeMessage(payload: unknown): void; scheduleRealtimeReconnect(reason: string): void; clearRealtimeReconnectTimer(): void; setRealtimeStatus(status: import("../../types.js").RealtimeConnectionStatus, reason?: string, error?: Error): void; applyCsrfHealth(): void; readRequestBody>(body: ArrayBuffer | Uint8Array | string | T | null | undefined, contentType?: string, requireEncrypted?: boolean): T; get reqOpts(): import("../../client/request.js").RequestOptions; prepareRequest(_withAuth: boolean): Promise; get http(): { get(path: string, withAuth?: boolean, extraHeaders?: Record, requestConfig?: import("../../client/request.js").EntityRequestConfig): Promise; post(path: string, body?: unknown, withAuth?: boolean, extraHeaders?: Record, requestConfig?: import("../../client/request.js").EntityRequestConfig): Promise; put(path: string, body?: unknown, withAuth?: boolean, extraHeaders?: Record, requestConfig?: import("../../client/request.js").EntityRequestConfig): Promise; patch(path: string, body?: unknown, withAuth?: boolean, extraHeaders?: Record, requestConfig?: import("../../client/request.js").EntityRequestConfig): Promise; delete(path: string, body?: unknown, withAuth?: boolean, extraHeaders?: Record, requestConfig?: import("../../client/request.js").EntityRequestConfig): Promise; }; request(method: string, path: string, body?: unknown, withAuth?: boolean, extraHeaders?: Record, requestConfig?: import("../../client/request.js").EntityRequestConfig): Promise; requestBinary(method: string, path: string, body?: unknown, withAuth?: boolean): Promise; requestForm(method: string, path: string, form: FormData, withAuth?: boolean, onUploadProgress?: (loaded: number, total: number) => void): Promise; requestFormBinary(method: string, path: string, form: FormData, withAuth?: boolean): Promise; }; } & TBase;