Function createEntityClient

core/client.ts:53–193

(
  definition: EntityDefinition<Data, View>,
  { db, cleanup }: EntityClientConfig
)

 * It also initializes synchronization and persistance.
 */
export function createEntityClient<Data, View>(
  definition: EntityDefinition<Data, View>,
  { db, cleanup }: EntityClientConfig
): EntityClient<Data, View> {
  const store = createEntityStore<Data, View>(definition, db, cleanup);

  // Allow listening to CRUD updates in the store
  const events = createEventsEmmiter<EntityStoreEvents<Data, View>>(
    definition.config.name
  );

  const { created, removed, updated } = definition.config.events ?? {};

  if (created) {
    cleanup.next = events.on("created", created);
  }

  if (removed) {
    cleanup.next = events.on("removed", removed);
  }

  if (updated) {
    cleanup.next = events.on("updated", updated);
  }

  cleanup.next = events.onOneOf(["created", "removed", "updated"], (change) => {
    const currentTransaction = getCurrentTransaction();

    if (!db.events.hasListeners("transaction")) {
      if (currentTransaction) {
        console.warn(
          "running runTransaction with operations on db that is not listening to transactions."
        );
      }
      return;
    }

    if (!currentTransaction) {
      // Emit change as one-step transaction
      const transaction = createTransactionWithChanges([
        change as EntityChangeEvent<unknown, unknown>,
      ]);

      db.events.emit("transaction", { type: "transaction", transaction });
      return;
    }

    currentTransaction.pushChange(
      change as EntityChangeEvent<unknown, unknown>
    );
  });

  cleanup.next = events.removeAllListeners;

  const { query, findById, sort, find, findFirst } = store;

  function createStoreEntity(input: Partial<Data>) {
    return createEntity<Data, View>({ data: input, client });