AIDK API Reference / aidk-server / MessageRepository

Interface: MessageRepository

Defined in: packages/server/src/types.ts:133

Methods

create()

create(data: Omit<MessageEntity, "createdAt"> & {
  createdAt?: Date;
}): Promise<MessageEntity>;

Defined in: packages/server/src/types.ts:134

Parameters

Parameter	Type
data	Omit<MessageEntity, "createdAt"> & { createdAt?: Date; }

Returns

Promise<MessageEntity>

---

findByExecutionId()

findByExecutionId(executionId: string): Promise<MessageEntity[]>;

Defined in: packages/server/src/types.ts:136

Parameters

Parameter	Type
executionId	string

Returns

Promise<MessageEntity[]>

---

findByThreadId()

findByThreadId(threadId: string, limit?: number): Promise<MessageEntity[]>;

Defined in: packages/server/src/types.ts:135

Parameters

Parameter	Type
threadId	string
limit?	number

Returns

Promise<MessageEntity[]>

---

findByThreadIdWithGlobalEvents()

findByThreadIdWithGlobalEvents(
   threadId: string, 
   userId: string, 
   limit?: number): Promise<MessageEntity[]>;

Defined in: packages/server/src/types.ts:142

Find messages for a thread, including user-global events. Returns thread-specific messages + any events with threadId = GLOBAL_THREAD_ID for this user. Results are ordered by createdAt for proper interleaving.

Parameters

Parameter	Type
threadId	string
userId	string
limit?	number

Returns

Promise<MessageEntity[]>