Spaces:
Runtime error
Runtime error
File size: 2,794 Bytes
46252cd | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 | import { Entity, PrimaryGeneratedColumn, Column, CreateDateColumn, Index, ValueTransformer } from 'typeorm';
import { jsonColumnType } from '../../../common/utils/column-types';
/**
* A `bigint` column reads back as a string on PostgreSQL (pg avoids >2^53 precision loss) but as a
* number on SQLite. WhatsApp epoch-seconds are far below 2^53, so coerce reads to a number for a
* consistent REST/SDK/MCP contract (entity, DTO, all three SDKs, and dashboard declare `number`).
* Writes pass through unchanged; null stays null.
*/
export const bigintToNumberTransformer: ValueTransformer = {
to: (value: number | null | undefined): number | null | undefined => value,
from: (value: string | number | null): number | null => {
if (value == null) return null;
const n = Number(value);
// Defensive: a bigint column can only return null or a numeric value, so NaN is unreachable —
// but coerce a hypothetical non-numeric read to null rather than leak NaN into the contract.
return Number.isNaN(n) ? null : n;
},
};
export enum MessageDirection {
INCOMING = 'incoming',
OUTGOING = 'outgoing',
}
export enum MessageStatus {
PENDING = 'pending',
SENT = 'sent',
DELIVERED = 'delivered',
READ = 'read',
FAILED = 'failed',
}
@Entity('messages')
@Index(['sessionId', 'createdAt'])
@Index(['chatId'])
// Composite index for the ack-driven status UPDATE (scoped by sessionId + waMessageId).
// Without it every ack does a full table scan of a hot table.
@Index('UQ_messages_sessionId_waMessageId', ['sessionId', 'waMessageId'], { unique: true })
export class Message {
@PrimaryGeneratedColumn('uuid')
id: string;
// No standalone @Index here: sessionId-only lookups are already served by the composite indexes
// that lead with sessionId — (sessionId, createdAt) above and the unique (sessionId, waMessageId).
@Column()
sessionId: string;
@Column({ nullable: true })
waMessageId: string;
@Column()
chatId: string;
/** Human-readable name for the chat (contact pushName, group name, etc). Populated on save when available — null for legacy rows. */
@Column({ nullable: true })
chatName?: string;
@Column()
from: string;
@Column()
to: string;
@Column({ type: 'text', nullable: true })
body: string;
@Column({ default: 'text' })
type: string;
@Column({
type: 'varchar',
default: MessageDirection.OUTGOING,
})
direction: MessageDirection;
@Column({ type: 'bigint', nullable: true, transformer: bigintToNumberTransformer })
timestamp: number;
@Column({ type: jsonColumnType(), nullable: true })
metadata: Record<string, unknown>;
@Column({
type: 'varchar',
default: MessageStatus.SENT,
})
@Index()
status: MessageStatus;
@CreateDateColumn()
createdAt: Date;
}
|