Function fetchSyncDelta

engine/server/fetchSyncDelta.ts:27–39

(
  context: SyncRequestContext
)

  | EntityCreateRequest;

export async function fetchSyncDelta(
  context: SyncRequestContext
): Promise<EntityDelta[]> {
  const { db, schema, lastSyncId } = context;

  const syncRequests = await db
    .table("sync")
    .select("*")
    .where("id", ">", lastSyncId)
    .andWhere("user_id", "=", context.userId);

  return syncRequests;
}