import { waitFor } from '@testing-library/dom'import { assert, expect, it, vi } from 'vitest'import { atom, createStore } from 'jotai/vanilla'import type { Getter } from 'jotai/vanilla'
it('should not fire on subscribe', async () => { const store = createStore() const countAtom = atom(0) const callback1 = vi.fn() const callback2 = vi.fn() store.sub(countAtom, callback1) store.sub(countAtom, callback2) expect(callback1).not.toHaveBeenCalled() expect(callback2).not.toHaveBeenCalled()})
it('should not fire subscription if primitive atom value is the same', async () => { const store = createStore() const countAtom = atom(0) const callback = vi.fn() store.sub(countAtom, callback) const calledTimes = callback.mock.calls.length store.set(countAtom, 0) expect(callback).toHaveBeenCalledTimes(calledTimes)})
it('should not fire subscription if derived atom value is the same', async () => { const store = createStore() const countAtom = atom(0) const derivedAtom = atom((get) => get(countAtom) * 0) const callback = vi.fn() store.sub(derivedAtom, callback) const calledTimes = callback.mock.calls.length store.set(countAtom, 1) expect(callback).toHaveBeenCalledTimes(calledTimes)})
it('should unmount with store.get', async () => { const store = createStore() const countAtom = atom(0) const callback = vi.fn() const unsub = store.sub(countAtom, callback) store.get(countAtom) unsub() const result = Array.from(store.dev_get_mounted_atoms?.() ?? []) expect(result).toEqual([])})
it('should unmount dependencies with store.get', async () => { const store = createStore() const countAtom = atom(0) const derivedAtom = atom((get) => get(countAtom) * 2) const callback = vi.fn() const unsub = store.sub(derivedAtom, callback) store.get(derivedAtom) unsub() const result = Array.from(store.dev_get_mounted_atoms?.() ?? []) expect(result).toEqual([])})
it('should update async atom with delay (#1813)', async () => { const countAtom = atom(0)
const resolve: (() => void)[] = [] const delayedAtom = atom(async (get) => { const count = get(countAtom) await new Promise<void>((r) => resolve.push(r)) return count })
const store = createStore() store.get(delayedAtom) store.set(countAtom, 1) resolve.splice(0).forEach((fn) => fn()) await new Promise<void>((r) => setTimeout(r)) const promise = store.get(delayedAtom) resolve.splice(0).forEach((fn) => fn()) expect(await promise).toBe(1)})
it('should override a promise by setting', async () => { const store = createStore() const countAtom = atom(Promise.resolve(0)) const infinitePending = new Promise<never>(() => {}) store.set(countAtom, infinitePending) const promise = store.get(countAtom) store.set(countAtom, Promise.resolve(1)) expect(await promise).toBe(1)})
it('should update async atom with deps after await (#1905)', async () => { const countAtom = atom(0) const resolve: (() => void)[] = [] const delayedAtom = atom(async (get) => { await new Promise<void>((r) => resolve.push(r)) const count = get(countAtom) return count }) const derivedAtom = atom(async (get) => { const count = await get(delayedAtom) return count })
const store = createStore() let lastValue = store.get(derivedAtom) const unsub = store.sub(derivedAtom, () => { lastValue = store.get(derivedAtom) }) store.set(countAtom, 1) resolve.splice(0).forEach((fn) => fn()) expect(await lastValue).toBe(1) store.set(countAtom, 2) resolve.splice(0).forEach((fn) => fn()) expect(await lastValue).toBe(2) store.set(countAtom, 3) resolve.splice(0).forEach((fn) => fn()) expect(await lastValue).toBe(3) unsub()})
it('should not fire subscription when async atom promise is the same', async () => { const promise = Promise.resolve() const promiseAtom = atom(promise) const derivedGetter = vi.fn((get: Getter) => get(promiseAtom)) const derivedAtom = atom(derivedGetter)
const store = createStore()
expect(derivedGetter).not.toHaveBeenCalled()
const promiseListener = vi.fn() const promiseUnsub = store.sub(promiseAtom, promiseListener) const derivedListener = vi.fn() const derivedUnsub = store.sub(derivedAtom, derivedListener)
expect(derivedGetter).toHaveBeenCalledOnce() expect(promiseListener).not.toHaveBeenCalled() expect(derivedListener).not.toHaveBeenCalled()
store.get(promiseAtom) store.get(derivedAtom)
expect(derivedGetter).toHaveBeenCalledOnce() expect(promiseListener).not.toHaveBeenCalled() expect(derivedListener).not.toHaveBeenCalled()
store.set(promiseAtom, promise)
expect(derivedGetter).toHaveBeenCalledOnce() expect(promiseListener).not.toHaveBeenCalled() expect(derivedListener).not.toHaveBeenCalled()
store.set(promiseAtom, promise)
expect(derivedGetter).toHaveBeenCalledOnce() expect(promiseListener).not.toHaveBeenCalled() expect(derivedListener).not.toHaveBeenCalled()
promiseUnsub() derivedUnsub()})
it('should notify subscription with tree dependencies (#1956)', async () => { const valueAtom = atom(1) const dep1Atom = atom((get) => get(valueAtom) * 2) const dep2Atom = atom((get) => get(valueAtom) + get(dep1Atom)) const dep3Atom = atom((get) => get(dep1Atom))
const cb = vi.fn() const store = createStore() store.sub(dep2Atom, vi.fn()) store.sub(dep3Atom, cb)
expect(cb).toBeCalledTimes(0) expect(store.get(dep3Atom)).toBe(2) store.set(valueAtom, (c) => c + 1) expect(cb).toBeCalledTimes(1) expect(store.get(dep3Atom)).toBe(4)})
it('should notify subscription with tree dependencies with bail-out', async () => { const valueAtom = atom(1) const dep1Atom = atom((get) => get(valueAtom) * 2) const dep2Atom = atom((get) => get(valueAtom) * 0) const dep3Atom = atom((get) => get(dep1Atom) + get(dep2Atom))
const cb = vi.fn() const store = createStore() store.sub(dep1Atom, vi.fn()) store.sub(dep3Atom, cb)
expect(cb).toBeCalledTimes(0) expect(store.get(dep3Atom)).toBe(2) store.set(valueAtom, (c) => c + 1) expect(cb).toBeCalledTimes(1) expect(store.get(dep3Atom)).toBe(4)})
it('should bail out with the same value with chained dependency (#2014)', async () => { const store = createStore() const objAtom = atom({ count: 1 }) const countAtom = atom((get) => get(objAtom).count) const deriveFn = vi.fn((get: Getter) => get(countAtom)) const derivedAtom = atom(deriveFn) const deriveFurtherFn = vi.fn((get: Getter) => { get(objAtom) return get(derivedAtom) }) const derivedFurtherAtom = atom(deriveFurtherFn) const callback = vi.fn() store.sub(derivedFurtherAtom, callback) expect(store.get(derivedAtom)).toBe(1) expect(store.get(derivedFurtherAtom)).toBe(1) expect(callback).toHaveBeenCalledTimes(0) expect(deriveFn).toHaveBeenCalledTimes(1) expect(deriveFurtherFn).toHaveBeenCalledTimes(1) store.set(objAtom, (obj) => ({ ...obj })) expect(callback).toHaveBeenCalledTimes(0) expect(deriveFn).toHaveBeenCalledTimes(1) expect(deriveFurtherFn).toHaveBeenCalledTimes(2)})
it('should not call read function for unmounted atoms (#2076)', async () => { const store = createStore() const countAtom = atom(1) const derive1Fn = vi.fn((get: Getter) => get(countAtom)) const derived1Atom = atom(derive1Fn) const derive2Fn = vi.fn((get: Getter) => get(countAtom)) const derived2Atom = atom(derive2Fn) expect(store.get(derived1Atom)).toBe(1) expect(store.get(derived2Atom)).toBe(1) expect(derive1Fn).toHaveBeenCalledTimes(1) expect(derive2Fn).toHaveBeenCalledTimes(1) store.sub(derived2Atom, vi.fn()) store.set(countAtom, (c) => c + 1) expect(derive1Fn).toHaveBeenCalledTimes(1) expect(derive2Fn).toHaveBeenCalledTimes(2)})
it('should update with conditional dependencies (#2084)', async () => { const store = createStore() const f1 = atom(false) const f2 = atom(false) const f3 = atom( (get) => get(f1) && get(f2), (_get, set, val: boolean) => { set(f1, val) set(f2, val) }, ) store.sub(f1, vi.fn()) store.sub(f2, vi.fn()) store.sub(f3, vi.fn()) store.set(f3, true) expect(store.get(f3)).toBe(true)})
it("should recompute dependents' state after onMount (#2098)", async () => { const store = createStore()
const condAtom = atom(false) const baseAtom = atom(false) baseAtom.onMount = (set) => set(true) const derivedAtom = atom( (get) => get(baseAtom), (_get, set, update: boolean) => set(baseAtom, update), ) const finalAtom = atom( (get) => (get(condAtom) ? get(derivedAtom) : undefined), (_get, set, value: boolean) => set(derivedAtom, value), )
store.sub(finalAtom, () => {}) expect(store.get(baseAtom)).toBe(false) expect(store.get(derivedAtom)).toBe(false) expect(store.get(finalAtom)).toBe(undefined)
store.set(condAtom, true) expect(store.get(baseAtom)).toBe(true) expect(store.get(derivedAtom)).toBe(true) expect(store.get(finalAtom)).toBe(true)
store.set(finalAtom, false) expect(store.get(baseAtom)).toBe(false) expect(store.get(derivedAtom)).toBe(false) expect(store.get(finalAtom)).toBe(false)})
it('should update derived atoms during write (#2107)', async () => { const store = createStore()
const baseCountAtom = atom(1) const countAtom = atom( (get) => get(baseCountAtom), (get, set, newValue: number) => { set(baseCountAtom, newValue) if (get(countAtom) !== newValue) { throw new Error('mismatch') } }, )
store.sub(countAtom, () => {}) expect(store.get(countAtom)).toBe(1) store.set(countAtom, 2) expect(store.get(countAtom)).toBe(2)})
it('resolves dependencies reliably after a delay (#2192)', async () => { expect.assertions(1) const countAtom = atom(0) let result: number | null = null
const resolve: (() => void)[] = [] const asyncAtom = atom(async (get) => { const count = get(countAtom) await new Promise<void>((r) => resolve.push(r)) return count })
const derivedAtom = atom( async (get, { setSelf }) => { get(countAtom) await Promise.resolve() result = await get(asyncAtom) if (result === 2) setSelf() }, () => {}, )
const store = createStore() store.sub(derivedAtom, () => {})
await waitFor(() => assert(resolve.length === 1))
resolve[0]!() const increment = (c: number) => c + 1 store.set(countAtom, increment) store.set(countAtom, increment)
await waitFor(() => assert(resolve.length === 3))
resolve[1]!() resolve[2]!() await waitFor(() => assert(result === 2))
store.set(countAtom, increment) store.set(countAtom, increment)
await waitFor(() => assert(resolve.length === 5))
resolve[3]!() resolve[4]!()
await new Promise(setImmediate) await waitFor(() => assert(store.get(countAtom) === 4))
expect(result).toBe(4) })
it('should not recompute a derived atom value if unchanged (#2168)', async () => { const store = createStore() const countAtom = atom(1) const derived1Atom = atom((get) => get(countAtom) * 0) const derive2Fn = vi.fn((get: Getter) => get(derived1Atom)) const derived2Atom = atom(derive2Fn) expect(store.get(derived2Atom)).toBe(0) store.set(countAtom, (c) => c + 1) expect(store.get(derived2Atom)).toBe(0) expect(derive2Fn).toHaveBeenCalledTimes(1)})
it('should mount once with atom creator atom (#2314)', async () => { const countAtom = atom(1) countAtom.onMount = vi.fn((setAtom: (v: number) => void) => { setAtom(2) }) const atomCreatorAtom = atom((get) => { const derivedAtom = atom((get) => get(countAtom)) get(derivedAtom) }) const store = createStore() store.sub(atomCreatorAtom, () => {}) expect(countAtom.onMount).toHaveBeenCalledTimes(1)})
it('should flush pending write triggered asynchronously and indirectly (#2451)', async () => { const store = createStore() const anAtom = atom('initial')
const callbackFn = vi.fn((_value: string) => {}) const unsub = store.sub(anAtom, () => { callbackFn(store.get(anAtom)) })
const actionAtom = atom(null, async (_get, set) => { await Promise.resolve() set(indirectSetAtom) })
const indirectSetAtom = atom(null, (_get, set) => { set(anAtom, 'next') })
await store.set(actionAtom)
expect(callbackFn).toHaveBeenCalledOnce() expect(callbackFn).toHaveBeenCalledWith('next') unsub()})