changes to proxyset for new typescript impl

Author: overthemike

src/vanilla/utils/proxySet.ts

@@ -4,18 +4,24 @@ const { proxyStateMap, snapCache } = unstable_getInternalStates()
 const maybeProxify = (x: any) => (typeof x === 'object' ? proxy({ x }).x : x)
 const isProxy = (x: any) => proxyStateMap.has(x)
 
+type RSetLike<T> = { has(value: T): boolean }
+
 type InternalProxySet<T> = Set<T> & {
   data: T[]
-  toJSON: object
+  toJSON: () => object
   index: number
   epoch: number
-  intersection: (other: Set<T>) => Set<T>
-  union: (other: Set<T>) => Set<T>
-  difference: (other: Set<T>) => Set<T>
-  symmetricDifference: (other: Set<T>) => Set<T>
-  isSubsetOf: (other: Set<T>) => boolean
-  isSupersetOf: (other: Set<T>) => boolean
-  isDisjointFrom: (other: Set<T>) => boolean
+  intersection<U>(other: RSetLike<U>): Set<T & U>
+  intersection(other: Set<T>): Set<T>
+  union<U>(other: RSetLike<U>): Set<T | U>
+  union(other: Set<T>): Set<T>
+  difference<U>(other: RSetLike<U>): Set<T>
+  difference(other: Set<T>): Set<T>
+  symmetricDifference<U>(other: RSetLike<U>): Set<T | U>
+  symmetricDifference(other: Set<T>): Set<T>
+  isSubsetOf(other: RSetLike<T>): boolean
+  isSupersetOf(other: RSetLike<T>): boolean
+  isDisjointFrom(other: RSetLike<T>): boolean
 }
 
 /**
@@ -55,6 +61,7 @@ export const isProxySet = (obj: object): boolean => {
  *   set: proxySet()
  * })
  */
+
 export function proxySet<T>(initialValues?: Iterable<T> | null) {
   const initialData: T[] = []
   const indexMap = new Map<T, number>()
@@ -84,6 +91,82 @@ export function proxySet<T>(initialValues?: Iterable<T> | null) {
     }
   }
 
+  const hasIterator = (o: unknown): o is Iterable<unknown> =>
+    typeof o === 'object' && o !== null && Symbol.iterator in (o as object)
+
+  const hasForEach = <U>(o: RSetLike<U>): o is RSetLike<U> & { forEach: (cb: (v: U) => void) => void } =>
+    typeof (o as { forEach?: unknown }).forEach === 'function'
+
+  const asIterable = <U>(other: RSetLike<U> | Set<U>): Iterable<U> => {
+    if (hasIterator(other)) return other as Iterable<U>
+    if (hasForEach(other)) {
+      const acc: U[] = []
+      other.forEach((v) => acc.push(v))
+      return acc
+    }
+    throw new TypeError('Expected an iterable')
+  }
+
+  function intersectionImpl<T, U>(this: InternalProxySet<T>, other: RSetLike<U>): Set<T & U>
+  function intersectionImpl<T>(this: InternalProxySet<T>, other: Set<T>): Set<T>
+  function intersectionImpl<T>(
+    this: InternalProxySet<T>,
+    other: RSetLike<unknown> | Set<T>
+  ): Set<unknown> {
+    this.epoch
+    const otherSet = proxySet(asIterable(other))
+    const result = proxySet<T>()
+    for (const value of this.values()) {
+      if (otherSet.has(value)) {
+        result.add(value)
+      }
+    }
+    return proxySet(result)
+  }
+
+  function unionImpl<T, U>(this: InternalProxySet<T>, other: RSetLike<U>): Set<T | U>
+  function unionImpl<T>(this: InternalProxySet<T>, other: Set<T>): Set<T>
+  function unionImpl<T>(
+    this: InternalProxySet<T>,
+    other: RSetLike<unknown> | Set<T>
+  ): Set<unknown> {
+    this.epoch
+    const otherSet = proxySet(asIterable(other))
+    const result = proxySet<unknown>()
+    for (const v of this.values()) result.add(v)
+    for (const v of otherSet.values()) result.add(v)
+    return proxySet(result)
+  }
+
+  function differenceImpl<T, U>(this: InternalProxySet<T>, _other: RSetLike<U>): Set<T>
+  function differenceImpl<T>(this: InternalProxySet<T>, other: Set<T>): Set<T>
+  function differenceImpl<T>(
+    this: InternalProxySet<T>,
+    other: RSetLike<unknown> | Set<T>
+  ): Set<T> {
+    this.epoch
+    const otherSet = proxySet(asIterable(other))
+    const result = proxySet<T>()
+    for (const v of this.values()) if (!otherSet.has(v)) result.add(v)
+    return proxySet(result)
+  }
+
+  function symmetricDifferenceImpl<T, U>(this: InternalProxySet<T>, other: RSetLike<U>): Set<T | U>
+  function symmetricDifferenceImpl<T>(this: InternalProxySet<T>, other: Set<T>): Set<T>
+  function symmetricDifferenceImpl<T>(
+    this: InternalProxySet<T>,
+    other: RSetLike<unknown> | Set<T>
+  ): Set<unknown> {
+    this.epoch
+    const otherSet = proxySet(asIterable(other))
+    const result = proxySet<unknown>()
+    for (const v of this.values()) if (!otherSet.has(v)) result.add(v)
+    for (const v of otherSet.values()) if (!this.has(v as T)) result.add(v)
+    return proxySet(result)
+  }
+
+
+
   const vObject: InternalProxySet<T> = {
     data: initialData,
     index: initialIndex,
@@ -97,7 +180,7 @@ export function proxySet<T>(initialValues?: Iterable<T> | null) {
     has(value: T) {
       const map = getMapForThis(this)
       const v = maybeProxify(value)
-      this.epoch // touch property for tracking
+      this.epoch
       return map.has(v)
     },
     add(value: T) {
@@ -130,31 +213,31 @@ export function proxySet<T>(initialValues?: Iterable<T> | null) {
       if (!isProxy(this)) {
         throw new Error('Cannot perform mutations on a snapshot')
       }
-      this.data.length = 0 // empty array
+      this.data.length = 0
       this.index = 0
       this.epoch++
       indexMap.clear()
     },
-    forEach(cb) {
-      this.epoch // touch property for tracking
+    forEach(cb: (value: T, valueAgain: T, set: Set<T>) => void) {
+      this.epoch
       const map = getMapForThis(this)
       map.forEach((index) => {
         cb(this.data[index]!, this.data[index]!, this)
       })
     },
     *values(): SetIterator<T> {
-      this.epoch // touch property for tracking
+      this.epoch
       const map = getMapForThis(this)
       for (const index of map.values()) {
         yield this.data[index]!
       }
     },
     keys(): SetIterator<T> {
-      this.epoch // touch property for tracking
+      this.epoch
       return this.values()
     },
     *entries(): SetIterator<[T, T]> {
-      this.epoch // touch property for tracking
+      this.epoch
       const map = getMapForThis(this)
       for (const index of map.values()) {
         const value = this.data[index]!
@@ -170,76 +253,25 @@ export function proxySet<T>(initialValues?: Iterable<T> | null) {
     get [Symbol.toStringTag]() {
       return 'Set'
     },
-    intersection(other: Set<T>): Set<T> {
-      this.epoch // touch property for tracking
-      const otherSet = proxySet<T>(other)
-      const resultSet = proxySet<T>()
-      for (const value of this.values()) {
-        if (otherSet.has(value)) {
-          resultSet.add(value)
-        }
-      }
-      return proxySet(resultSet)
-    },
-    union(other: Set<T>) {
-      this.epoch // touch property for tracking
-      const resultSet = proxySet<T>()
-      const otherSet = proxySet<T>(other)
-      for (const value of this.values()) {
-        resultSet.add(value)
-      }
-      for (const value of otherSet) {
-        resultSet.add(value)
-      }
-      return proxySet(resultSet)
-    },
-    difference(other: Set<T>) {
-      this.epoch // touch property for tracking
-      const resultSet = proxySet<T>()
-      const otherSet = proxySet<T>(other)
-      for (const value of this.values()) {
-        if (!otherSet.has(value)) {
-          resultSet.add(value)
-        }
-      }
-      return proxySet(resultSet)
-    },
-    symmetricDifference(other: Set<T>) {
-      this.epoch // touch property for tracking
-      const resultSet = proxySet<T>()
-      const otherSet = proxySet<T>(other)
-      for (const value of this.values()) {
-        if (!otherSet.has(value)) {
-          resultSet.add(value)
-        }
-      }
-      for (const value of otherSet.values()) {
-        if (!this.has(value)) {
-          resultSet.add(value)
-        }
-      }
-      return proxySet(resultSet)
-    },
-    isSubsetOf(other: Set<T>) {
-      this.epoch // touch property for tracking
-      const otherSet = proxySet<T>(other)
-      return (
-        this.size <= other.size &&
-        [...this.values()].every((value) => otherSet.has(value))
-      )
+    intersection: intersectionImpl,
+    union: unionImpl,
+    difference: differenceImpl,
+    symmetricDifference: symmetricDifferenceImpl,
+    isSubsetOf(other: RSetLike<T>) {
+      this.epoch
+      for (const v of this.values()) if (!other.has(v)) return false
+      return true
     },
-    isSupersetOf(other: Set<T>) {
-      this.epoch // touch property for tracking
-      const otherSet = proxySet<T>(other)
-      return (
-        this.size >= other.size &&
-        [...otherSet].every((value) => this.has(value))
-      )
+    isSupersetOf(other: RSetLike<T>) {
+      this.epoch
+      const it = asIterable(other)
+      for (const v of it) if (!this.has(v)) return false
+      return true
     },
-    isDisjointFrom(other: Set<T>): boolean {
-      this.epoch // touch property for tracking
-      const otherSet = proxySet<T>(other)
-      return [...this.values()].every((value) => !otherSet.has(value))
+    isDisjointFrom(other: RSetLike<T>) {
+      this.epoch
+      for (const v of this.values()) if (other.has(v)) return false
+      return true
     },
   }
 
@@ -253,7 +285,7 @@ export function proxySet<T>(initialValues?: Iterable<T> | null) {
   })
   Object.seal(proxiedObject)
 
-  return proxiedObject as unknown as InternalProxySet<T> & {
+  return proxiedObject as InternalProxySet<T> & {
     $$valtioSnapshot: Omit<InternalProxySet<T>, 'set' | 'delete' | 'clear'>
   }
 }

tsconfig.json

@@ -1,6 +1,6 @@
 {
   "compilerOptions": {
-    "target": "es2021" /* FIXME we want to make it esnext */,
+    "target": "esnext",
     "strict": true,
     "jsx": "react-jsx",
     "esModuleInterop": true,
@@ -13,14 +13,26 @@
     "verbatimModuleSyntax": true,
     "declaration": true,
     "isolatedDeclarations": true,
-    "types": ["@testing-library/jest-dom"],
+    "types": [
+      "@testing-library/jest-dom"
+    ],
     "noEmit": true,
     "baseUrl": ".",
     "paths": {
-      "valtio": ["./src/index.ts"],
-      "valtio/*": ["./src/*.ts"]
+      "valtio": [
+        "./src/index.ts"
+      ],
+      "valtio/*": [
+        "./src/*.ts"
+      ]
     }
   },
-  "include": ["src/**/*", "tests/**/*"],
-  "exclude": ["node_modules", "dist"]
-}
+  "include": [
+    "src/**/*",
+    "tests/**/*"
+  ],
+  "exclude": [
+    "node_modules",
+    "dist"
+  ]
+}