/** * RefMapM is a collection of helpers for working with Refs that manage a mutable Map. * It utilizes standard JS reference-based keys. * @since 0.13.4 */ import { Endomorphism } from 'fp-ts/Endomorphism' import * as O from 'fp-ts/Option' import { Predicate } from 'fp-ts/Predicate' import * as E from './Env' import * as EO from './EnvOption' import { pipe } from './function' import * as Ref from './Ref' /** * @since 0.13.4 * @category Model */ export interface RefMapM extends Ref.Ref> {} /** * @since 0.13.4 * @category Combinator */ export const deleteAt = (key: K) => (rm: RefMapM) => pipe( rm.get, E.tap((m) => m.delete(key)), E.chainFirstW(rm.set), ) /** * @since 0.13.4 * @category Combinator */ export function filter(predicate: Predicate) { return (rm: RefMapM) => rm.update((m) => { m.forEach((value, key) => { if (!predicate(value)) { m.delete(key) } }) return E.of(m) }) } /** * @since 0.13.4 * @category Combinator */ export function filterWithIndex(predicate: (k: K, v: V) => boolean) { return (rm: RefMapM) => rm.update((m) => { m.forEach((value, key) => { if (!predicate(key, value)) { m.delete(key) } }) return E.of(m) }) } /** * @since 0.13.4 * @category Combinator */ export const insertAt = (key: K, value: V) => (rm: RefMapM) => pipe( rm.get, E.chainW((map) => E.fromIO(() => { if (map.has(key)) { return O.none } map.set(key, value) return O.some(map) }), ), EO.chainFirstEnvK(rm.set), ) /** * @since 0.13.4 * @category Combinator */ export const modifyAt = (key: K, f: Endomorphism) => { return (rm: RefMapM) => pipe( rm.get, E.chainW((map) => E.fromIO(() => { if (!map.has(key)) { return O.none } const v = map.get(key)! return O.some(map.set(key, f(v))) }), ), EO.chainFirstEnvK(rm.set), ) } /** * @since 0.13.4 * @category Combinator */ export const updateAt = (key: K, value: V) => { return (rm: RefMapM) => pipe( rm.get, E.chainW((map) => E.fromIO(() => { if (!map.has(key)) { return O.none } return O.some(map.set(key, value)) }), ), EO.chainFirstEnvK(rm.set), ) } /** * @since 0.13.4 * @category Combinator */ export const upsertAt = (key: K, value: V) => (rm: RefMapM) => rm.update((map) => E.fromIO(() => { map.set(key, value) return map }), ) /** * @since 0.13.4 * @category Combinator */ export const getOrCreate = (key: K, create: E.Env) => (rm: RefMapM) => pipe( rm.get, E.map((map) => (map.has(key) ? O.some(map.get(key)!) : O.none)), EO.matchEW( () => pipe( create, E.chainFirstW((v) => pipe(rm, upsertAt(key, v))), ), E.of, ), )