AIDK API Reference / aidk-server / InMemoryMessageRepository

Class: InMemoryMessageRepository

Defined in: packages/server/src/persistence/in-memory.ts:203

Implements

• MessageRepository

Constructors

Constructor

new InMemoryMessageRepository(store: InMemoryStore): InMemoryMessageRepository;

Defined in: packages/server/src/persistence/in-memory.ts:204

Parameters

Parameter	Type
store	InMemoryStore

Returns

InMemoryMessageRepository

Methods

create()

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

Defined in: packages/server/src/persistence/in-memory.ts:206

Parameters

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

Returns

Promise<MessageEntity>

Implementation of

MessageRepository.create

---

findByExecutionId()

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

Defined in: packages/server/src/persistence/in-memory.ts:224

Parameters

Parameter	Type
executionId	string

Returns

Promise<MessageEntity[]>

Implementation of

MessageRepository.findByExecutionId

---

findByThreadId()

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

Defined in: packages/server/src/persistence/in-memory.ts:217

Parameters

Parameter	Type	Default value
threadId	string	undefined
limit	number	100

Returns

Promise<MessageEntity[]>

Implementation of

MessageRepository.findByThreadId

---

findByThreadIdWithGlobalEvents()

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

Defined in: packages/server/src/persistence/in-memory.ts:237

Find messages for a thread, including user-global events.

User-global events (threadId = nil UUID) are interleaved with thread-specific messages by timestamp, providing the agent with full context of what happened across all the user's conversations.

Parameters

Parameter	Type	Default value
threadId	string	undefined
userId	string	undefined
limit	number	100

Returns

Promise<MessageEntity[]>

Implementation of

MessageRepository.findByThreadIdWithGlobalEvents