Skip to main content

@idpass/data-collect-core / EntityStore

Interface: EntityStore

Defined in: interfaces/types.ts:494

Entity store interface for managing current entity state.

Stores the materialized view of entities derived from applying events. Optimized for fast queries and lookups.

Methods

initialize()

initialize(): Promise<void>

Defined in: interfaces/types.ts:496

Initialize the entity store (create tables, indexes, etc.)

Returns

Promise<void>


saveEntity()

saveEntity(initial, modified): Promise<void>

Defined in: interfaces/types.ts:498

Save entity with both initial and current state

Parameters

initial

EntityDoc

modified

EntityDoc

Returns

Promise<void>


getEntity()

getEntity(id): Promise<EntityPair | null>

Defined in: interfaces/types.ts:500

Get entity by internal ID

Parameters

id

string

Returns

Promise<EntityPair | null>


getEntityByExternalId()

getEntityByExternalId(externalId): Promise<EntityPair | null>

Defined in: interfaces/types.ts:502

Get entity by external system ID

Parameters

externalId

string

Returns

Promise<EntityPair | null>


searchEntities()

searchEntities(criteria): Promise<EntityPair[]>

Defined in: interfaces/types.ts:504

Search entities using query criteria

Parameters

criteria

SearchCriteria

Returns

Promise<EntityPair[]>


getAllEntities()

getAllEntities(): Promise<EntityPair[]>

Defined in: interfaces/types.ts:506

Get all entities in the store

Returns

Promise<EntityPair[]>


getModifiedEntitiesSince()

getModifiedEntitiesSince(timestamp): Promise<EntityPair[]>

Defined in: interfaces/types.ts:508

Get entities modified since a timestamp (for sync)

Parameters

timestamp

string

Returns

Promise<EntityPair[]>


markEntityAsSynced()

markEntityAsSynced(id): Promise<void>

Defined in: interfaces/types.ts:510

Mark an entity as synced with remote server

Parameters

id

string

Returns

Promise<void>


deleteEntity()

deleteEntity(id): Promise<void>

Defined in: interfaces/types.ts:512

Delete an entity by ID

Parameters

id

string

Returns

Promise<void>


savePotentialDuplicates()

savePotentialDuplicates(duplicates): Promise<void>

Defined in: interfaces/types.ts:514

Save potential duplicate entity pairs for review

Parameters

duplicates

object[]

Returns

Promise<void>


getPotentialDuplicates()

getPotentialDuplicates(): Promise<object[]>

Defined in: interfaces/types.ts:516

Get all potential duplicate pairs

Returns

Promise<object[]>


resolvePotentialDuplicates()

resolvePotentialDuplicates(duplicates): Promise<void>

Defined in: interfaces/types.ts:518

Resolve potential duplicate pairs (mark as reviewed)

Parameters

duplicates

object[]

Returns

Promise<void>


clearStore()

clearStore(): Promise<void>

Defined in: interfaces/types.ts:520

Clear all data from the store (for testing)

Returns

Promise<void>


closeConnection()

closeConnection(): Promise<void>

Defined in: interfaces/types.ts:522

Close database connections and cleanup resources

Returns

Promise<void>