/** * RefMap is a collection of helpers for working with Refs that manage a ReadonlyMap. * @since 0.12.0 */ import { Endomorphism } from 'fp-ts/Endomorphism' import { Eq } from 'fp-ts/Eq' import * as O from 'fp-ts/Option' import { Predicate } from 'fp-ts/Predicate' import * as RM from 'fp-ts/ReadonlyMap' import { fst, snd } from 'fp-ts/Tuple2' import * as E from './Env' import * as EO from './EnvOption' import { flow, pipe } from './function' import * as Ref from './Ref' /** * @since 0.12.0 * @category Model */ export interface RefMap extends Ref.Ref> {} /** * @since 0.12.0 * @category Combinator */ export const deleteAt = (Eq: Eq) => { return (key: K) => { const deleteAtKey = RM.deleteAt(Eq)(key) return (rm: RefMap) => pipe(rm.get, E.map(deleteAtKey), EO.chainFirstEnvK(rm.set)) } } /** * @since 0.12.0 * @category Combinator */ export function filter(predicate: Predicate) { return (rm: RefMap) => rm.update(flow(RM.filter(predicate), E.of)) } /** * @since 0.12.0 * @category Combinator */ export function filterWithIndex(predicate: (k: K, v: V) => boolean) { return (rm: RefMap) => rm.update(flow(RM.filterWithIndex(predicate), E.of)) } /** * @since 0.12.0 * @category Combinator */ export const insertAt = (Eq: Eq) => { return (key: K, value: V) => { const insertAtKey = RM.insertAt(Eq)(key, value) return (rm: RefMap) => pipe(rm.get, E.map(insertAtKey), EO.chainFirstEnvK(rm.set)) } } /** * @since 0.12.0 * @category Combinator */ export const modifyAt = (Eq: Eq) => { return (key: K, f: Endomorphism) => { const modifyAtKey = RM.modifyAt(Eq)(key, f) return (rm: RefMap) => pipe(rm.get, E.map(modifyAtKey), EO.chainFirstEnvK(rm.set)) } } /** * @since 0.12.0 * @category Combinator */ export const pop = (Eq: Eq) => (k: K) => { const popWithKey = RM.pop(Eq)(k) return (rm: RefMap): E.Env> => pipe(rm.get, E.map(popWithKey), EO.chainFirstEnvK(flow(snd, rm.set)), EO.map(fst)) } /** * @since 0.12.0 * @category Combinator */ export const updateAt = (Eq: Eq) => { return (key: K, value: V) => { const updateAtKey = RM.updateAt(Eq)(key, value) return (rm: RefMap) => pipe(rm.get, E.map(updateAtKey), EO.chainFirstEnvK(rm.set)) } } /** * @since 0.12.0 * @category Combinator */ export const upsertAt = (Eq: Eq) => { return (key: K, value: V) => { const upsertAtKey = RM.upsertAt(Eq)(key, value) return (rm: RefMap) => rm.update(flow(upsertAtKey, E.of)) } } /** * @since 0.12.1 * @category Combinator */ export const getOrCreate = (Eq: Eq) => { return (key: K, create: E.Env) => { const lookup = RM.lookup(Eq)(key) const upsert = upsertAt(Eq) return (rm: RefMap) => pipe( rm.get, E.map(lookup), EO.matchEW( () => pipe( create, E.chainFirstW((v) => pipe(rm, upsert(key, v))), ), E.of, ), ) } }