mirror of
https://github.com/fiddlerwoaroof/data-lens.git
synced 2025-11-08 10:16:32 +00:00
Compare commits
1 Commits
befab03521
...
gh-pages
| Author | SHA1 | Date | |
|---|---|---|---|
| 4f974d2fc5 |
26
README.org
26
README.org
@ -1,26 +0,0 @@
|
||||
* Intro
|
||||
|
||||
This library provides a language for expressing data manipulations as
|
||||
the composition of more primitive operations.
|
||||
|
||||
#+BEGIN_SRC lisp
|
||||
DATA-LENS> (funcall (on (alexandria:compose
|
||||
(over (transform-tail (over (slice 1))))
|
||||
(compress-runs :collector 'combine-matching-lists))
|
||||
(alexandria:compose
|
||||
(over (juxt (element 0)
|
||||
'identity))
|
||||
(sorted 'char<
|
||||
:key (element 0))))
|
||||
'("January" "February" "March" "April"
|
||||
"May" "June" "July" "August"
|
||||
"September" "October" "November" "December"))
|
||||
#| ==> ((#\A "pril" "ugust")
|
||||
(#\D "ecember")
|
||||
(#\F "ebruary")
|
||||
(#\J "anuary" "une" "uly")
|
||||
(#\M "arch" "ay")
|
||||
(#\N "ovember")
|
||||
(#\O "ctober")
|
||||
(#\S "eptember")) |#
|
||||
#+END_SRC
|
||||
@ -1,10 +0,0 @@
|
||||
(asdf:defsystem #:data-lens
|
||||
:description "Utilities for building data transormations from composable functions, modeled on lenses and transducers"
|
||||
:author "Edward Langley <el-cl@elangley.org>"
|
||||
:license "MIT"
|
||||
:depends-on (:cl-ppcre
|
||||
:alexandria
|
||||
:serapeum)
|
||||
:serial t
|
||||
:components ((:file "lens")))
|
||||
|
||||
515
lens.lisp
515
lens.lisp
@ -1,515 +0,0 @@
|
||||
(defpackage :data-lens.lenses
|
||||
(:shadow :set)
|
||||
(:use :cl)
|
||||
(:export :over :set :view :make-alist-lens :make-plist-lens :make-hash-table-lens))
|
||||
(in-package :data-lens.lenses)
|
||||
|
||||
#+fw.dev
|
||||
(progn
|
||||
;; maybe functor implementation
|
||||
(defclass maybe ()
|
||||
())
|
||||
(defclass just (maybe)
|
||||
((%v :initarg :value :reader value)))
|
||||
(defclass nothing (maybe)
|
||||
())
|
||||
|
||||
(defun just (value)
|
||||
(make-instance 'just :value value))
|
||||
(defun nothing (&optional value)
|
||||
(declare (ignore value))
|
||||
(make-instance 'nothing))
|
||||
|
||||
(defgeneric maybe (default value)
|
||||
(:method (default (value just))
|
||||
(value value))
|
||||
(:method (default (value nothing))
|
||||
default))
|
||||
|
||||
(defgeneric maybe-apply (function value)
|
||||
(:method (function (value just))
|
||||
(just (funcall function (value value))))
|
||||
(:method (function (value nothing))
|
||||
value))
|
||||
|
||||
(defmethod print-object ((o just) s)
|
||||
(format s "#.(~s ~s)"
|
||||
'just
|
||||
(value o)))
|
||||
|
||||
(defmethod print-object ((o nothing) s)
|
||||
(format s "#.(~s)"
|
||||
'nothing)))
|
||||
|
||||
;; identity functor, necessary for set and over
|
||||
(defclass identity- ()
|
||||
((%v :initarg :value :reader unidentity)))
|
||||
|
||||
(defun wrap-identity (v)
|
||||
(make-instance 'identity- :value v))
|
||||
|
||||
(defmethod print-object ((o identity-) s)
|
||||
(format s "#.(~s ~s)"
|
||||
'wrap-identity
|
||||
(unidentity o)))
|
||||
|
||||
;; constant functor, necessary for view
|
||||
(defclass constant- ()
|
||||
((%v :initarg :value :reader unconstant)))
|
||||
|
||||
(defun wrap-constant (v)
|
||||
(make-instance 'constant- :value v))
|
||||
|
||||
(defmethod print-object ((o constant-) s)
|
||||
(format s "#.(~s ~s)"
|
||||
'wrap-constant
|
||||
(unconstant o)))
|
||||
|
||||
(defgeneric fmap (function data)
|
||||
(:method (function (data identity-))
|
||||
(wrap-identity
|
||||
(funcall function
|
||||
(unidentity data))))
|
||||
(:method (function (data constant-))
|
||||
data)
|
||||
(:method (function (data list))
|
||||
(mapcar function data))
|
||||
(:method (function (data vector))
|
||||
(map 'vector function data))
|
||||
#+fw.dev
|
||||
(:method (function (data maybe))
|
||||
(maybe-apply function data)))
|
||||
|
||||
(defun over (lens cb rec)
|
||||
"Given a lens, a callback and a record, apply the lens to the
|
||||
record, transform it by the callback and return copy of the record,
|
||||
updated to contain the result of the callback. This is the fundamental
|
||||
operation on a lens and SET and VIEW are implemented in terms of it.
|
||||
|
||||
A lens is any function of the form (lambda (fun) (lambda (rec) ...))
|
||||
that obeys the lens laws (where == is some reasonable equality
|
||||
operator):
|
||||
|
||||
(== (view lens (set lens value rec))
|
||||
value)
|
||||
|
||||
(== (set lens (view lens rec) rec)
|
||||
rec)
|
||||
|
||||
(== (set lens value2 (set lens value1 rec))
|
||||
(set lens value2 rec))
|
||||
|
||||
The inner lambda returns a functor that determines the policy to be
|
||||
applied to the focused part. By default, this only uses IDENTITY- and
|
||||
CONSTANT- in order to implement the lens operations over, set and
|
||||
view.
|
||||
|
||||
If these conditions are met, (over (data-lens:<>1 lens1 lens2) ...) is
|
||||
equivalent to using lens2 to focus the part lens1 focuses: note that
|
||||
composition is \"backwards\" from what one might expect: this is
|
||||
because composition composes the wrapper lambdas and applies the
|
||||
lambda that actually pulls a value out of a record later."
|
||||
(unidentity
|
||||
(funcall (funcall lens (lambda (x) (wrap-identity (funcall cb x))))
|
||||
rec)))
|
||||
|
||||
(defun view (lens rec)
|
||||
"Given a lens and a rec, return the focused value"
|
||||
(unconstant
|
||||
(funcall (funcall lens (lambda (x) (wrap-constant x)))
|
||||
rec)))
|
||||
|
||||
(defun set (lens v rec)
|
||||
"Given a lens, a value and a rec, immutably update the rec to
|
||||
contain the new value at the location focused by the lens."
|
||||
(unidentity
|
||||
(funcall (funcall lens (lambda (_) _ (wrap-identity v)))
|
||||
rec)))
|
||||
|
||||
#+fw.dev
|
||||
(progn
|
||||
;; "fake" functors that don't assume a functor result to their
|
||||
;; callback
|
||||
(defun over* (lens cb rec)
|
||||
(funcall (funcall lens cb)
|
||||
rec))
|
||||
|
||||
(defun set* (lens value rec)
|
||||
(over lens
|
||||
(lambda (_)
|
||||
(declare (ignore _))
|
||||
value)
|
||||
rec))
|
||||
|
||||
(defun view* (lens rec)
|
||||
(over lens
|
||||
(lambda (value)
|
||||
(return-from view*
|
||||
value))
|
||||
rec)))
|
||||
|
||||
(defun make-alist-history-lens (key)
|
||||
"A lens for updating a alist, preserving previous values"
|
||||
(lambda (cb)
|
||||
(lambda (alist)
|
||||
(fmap (lambda (new)
|
||||
(cons (cons key new)
|
||||
alist))
|
||||
(funcall cb (serapeum:assocdr key alist))))))
|
||||
|
||||
(defun make-alist-lens (key)
|
||||
"A lens for updating a alist, discarding previous values"
|
||||
(lambda (cb)
|
||||
(lambda (alist)
|
||||
(fmap (lambda (new)
|
||||
(remove-duplicates (cons (cons key new)
|
||||
alist)
|
||||
:key #'car
|
||||
:from-end t))
|
||||
(funcall cb (serapeum:assocdr key alist))))))
|
||||
|
||||
(defun make-plist-lens (key)
|
||||
"A lens for updating a plist, preserving previous values"
|
||||
(lambda (cb)
|
||||
(lambda (plist)
|
||||
(fmap (lambda (new)
|
||||
(list* key new
|
||||
plist))
|
||||
(funcall cb (getf plist key))))))
|
||||
|
||||
(defun make-hash-table-lens (key)
|
||||
"A lens for updating a hash-table, discarding previous values"
|
||||
(lambda (cb)
|
||||
(lambda (old-hash)
|
||||
(fmap (lambda (new)
|
||||
(let ((new-hash (alexandria:copy-hash-table old-hash)))
|
||||
(prog1 new-hash
|
||||
(setf (gethash key new-hash)
|
||||
new))))
|
||||
(funcall cb (gethash key old-hash))))))
|
||||
|
||||
;; imagine a lens here that uses the MOP to immutably update a class...
|
||||
(defgeneric clone (obj &rest new-initargs &key)
|
||||
(:method :around (obj &rest new-initargs &key)
|
||||
(apply #'reinitialize-instance (call-next-method) new-initargs)))
|
||||
|
||||
#+fw.demo
|
||||
(progn
|
||||
(defclass foo ()
|
||||
((a :initarg :a :accessor a)))
|
||||
(defmethod clone ((obj foo) &key)
|
||||
(make-instance 'foo :a (a obj)))
|
||||
|
||||
;;; needs to be updated for functor-based lens
|
||||
(defun a-lens (cb)
|
||||
(lambda (foo)
|
||||
(fw.lu:prog1-bind (new (clone foo))
|
||||
(setf (a new)
|
||||
(funcall cb (a foo))))))
|
||||
(view 'a-lens
|
||||
(over 'a-lens '1+
|
||||
(set 'a-lens 2
|
||||
(make-instance 'foo :a 1)))) #|
|
||||
==> 3 |#)
|
||||
|
||||
|
||||
|
||||
(defpackage :data-lens
|
||||
(:use :cl)
|
||||
(:import-from #:serapeum #:op #:defalias)
|
||||
(:export #:regex-match #:include #:exclude #:pick #:key-transform
|
||||
#:combine #:derive #:cumsum #:over #:on #:shortcut #:defun-ct #:key
|
||||
#:extract-key #:element #:let-fn #:juxt #:transform-tail #:slice
|
||||
#:compress-runs #:combine-matching-lists #:sorted #:applicable-when
|
||||
#:of-length #:of-min-length #:of-max-length #:transform-head
|
||||
#:maximizing #:zipping #:applying #:splice-elt #:transform-elt #:denest
|
||||
#:op #:defalias #:<> #:<>1))
|
||||
(in-package :data-lens)
|
||||
|
||||
|
||||
(declaim
|
||||
(inline data-lens:over data-lens:transform-tail
|
||||
data-lens:applicable-when data-lens:of-min-length
|
||||
data-lens:on data-lens:over data-lens:slice
|
||||
data-lens:compress-runs data-lens:combine-matching-lists
|
||||
data-lens:juxt data-lens:element data-lens:sorted))
|
||||
|
||||
;;; TODO: consider making this wrap defalias?
|
||||
(defmacro shortcut (name function &body bound-args)
|
||||
`(eval-when (:load-toplevel :compile-toplevel :execute)
|
||||
(setf (fdefinition ',name)
|
||||
(,function ,@bound-args))))
|
||||
|
||||
(defmacro defun-ct (name (&rest args) &body body)
|
||||
`(eval-when (:load-toplevel :compile-toplevel :execute)
|
||||
(defun ,name ,args
|
||||
,@body)))
|
||||
|
||||
(defmacro let-fn ((&rest bindings) &body body)
|
||||
(let ((binding-forms (mapcar (lambda (form)
|
||||
`(,(car form) ,(cadr form)
|
||||
(funcall ,@(cddr form) ,@(cadr form))))
|
||||
bindings)))
|
||||
`(labels ,binding-forms
|
||||
,@body)))
|
||||
|
||||
(defgeneric extract-key (map key)
|
||||
(:method ((map hash-table) key)
|
||||
(gethash key map))
|
||||
(:method ((map list) key)
|
||||
(typecase (car map)
|
||||
(cons (cdr (assoc key map :test 'equal)))
|
||||
(t (loop for (a-key . value) on map by #'cddr
|
||||
when (equal key a-key) do
|
||||
(return (car value)))))))
|
||||
|
||||
(defun-ct deduplicate (&optional (test 'eql))
|
||||
(lambda (it)
|
||||
(remove-duplicates it :test test)))
|
||||
|
||||
(defun cons-new (&key (test 'eql) (key 'identity))
|
||||
(lambda (acc next)
|
||||
(if (and acc
|
||||
(funcall test
|
||||
(funcall key (car acc))
|
||||
(funcall key next)))
|
||||
acc
|
||||
(cons next acc))))
|
||||
|
||||
(defun matching-list-reducer (test acc next)
|
||||
(if (and acc
|
||||
(funcall test (caar acc) (car next)))
|
||||
(cons (cons (caar acc)
|
||||
(append (cdar acc)
|
||||
(cdr next)))
|
||||
(cdr acc))
|
||||
(cons next acc)))
|
||||
|
||||
(defun combine-matching-lists (&key (test 'eql) &allow-other-keys)
|
||||
(lambda (acc next)
|
||||
(matching-list-reducer test acc next)))
|
||||
|
||||
(defun-ct compress-runs (&key (collector 'cons-new) (test 'eql) (key 'identity))
|
||||
(lambda (it)
|
||||
(nreverse
|
||||
(reduce (funcall collector :test test :key key)
|
||||
it
|
||||
:initial-value ()))))
|
||||
|
||||
(defun-ct of-length (len)
|
||||
(lambda (it)
|
||||
(= (length it)
|
||||
len)))
|
||||
|
||||
(defun-ct of-min-length (len)
|
||||
(lambda (it)
|
||||
(>= (length it)
|
||||
len)))
|
||||
|
||||
(defun-ct of-max-length (len)
|
||||
(lambda (it)
|
||||
(>= (length it)
|
||||
len)))
|
||||
|
||||
(defun-ct applicable-when (fun test)
|
||||
(lambda (it)
|
||||
(if (funcall test it)
|
||||
(funcall fun it)
|
||||
it)))
|
||||
|
||||
(defun-ct sorted (comparator &rest r &key key)
|
||||
(declare (ignore key))
|
||||
(lambda (it)
|
||||
(apply #'stable-sort (copy-seq it) comparator r)))
|
||||
|
||||
(defun-ct element (num)
|
||||
(lambda (it)
|
||||
(elt it num)))
|
||||
|
||||
(defun-ct key (key)
|
||||
(lambda (map)
|
||||
(declare (dynamic-extent map))
|
||||
(extract-key map key)))
|
||||
|
||||
(defun-ct regex-match (regex)
|
||||
(lambda (data)
|
||||
(cl-ppcre:scan-to-strings regex data)))
|
||||
|
||||
(defun-ct include (pred)
|
||||
(lambda (seq)
|
||||
(remove-if-not pred seq)))
|
||||
|
||||
(defun-ct exclude (pred)
|
||||
(lambda (seq)
|
||||
(remove-if pred seq)))
|
||||
|
||||
(defun-ct pick (selector)
|
||||
(lambda (seq)
|
||||
(map 'list selector seq)))
|
||||
|
||||
(defun slice (start &optional end)
|
||||
(lambda (it)
|
||||
(subseq it start end)))
|
||||
|
||||
(defun-ct update (thing fun &rest args)
|
||||
(apply fun thing args))
|
||||
|
||||
(define-modify-macro updatef (fun &rest args)
|
||||
update)
|
||||
|
||||
(defun-ct transform-head (fun)
|
||||
(lambda (it)
|
||||
(typecase it
|
||||
(list (list* (funcall fun (car it))
|
||||
(cdr it)))
|
||||
(vector (let ((result (copy-seq it)))
|
||||
(prog1 result
|
||||
(updatef (elt result 0) fun)))))))
|
||||
|
||||
(defun-ct transform-tail (fun)
|
||||
(lambda (it)
|
||||
(typecase it
|
||||
(list (list* (car it)
|
||||
(funcall fun (cdr it))))
|
||||
(vector (let ((result (copy-seq it)))
|
||||
(prog1 result
|
||||
(updatef (subseq result 1)
|
||||
fun)))))))
|
||||
|
||||
(defun-ct splice-elt (elt fun)
|
||||
(lambda (it)
|
||||
(append (subseq it 0 elt)
|
||||
(funcall fun (nth elt it))
|
||||
(subseq it (1+ elt)))))
|
||||
|
||||
(defun-ct transform-elt (elt fun)
|
||||
(lambda (it)
|
||||
(append (subseq it 0 elt)
|
||||
(list (funcall fun (nth elt it)))
|
||||
(subseq it (1+ elt)))))
|
||||
|
||||
(defun-ct key-transform (fun key-get key-set)
|
||||
(lambda (it)
|
||||
(let ((key-val (funcall key-get it)))
|
||||
(funcall key-set
|
||||
(funcall fun key-val)))))
|
||||
|
||||
(defun-ct juxt (fun1 &rest r)
|
||||
(lambda (&rest args)
|
||||
(list* (apply fun1 args)
|
||||
(when r
|
||||
(mapcar (lambda (f)
|
||||
(apply f args))
|
||||
r)))))
|
||||
|
||||
(defun =>> (fun1 fun2)
|
||||
(lambda (i)
|
||||
(prog1 (funcall fun1 i)
|
||||
(funcall fun2))))
|
||||
|
||||
(defun-ct derive (diff-fun &key (key #'identity))
|
||||
(lambda (seq)
|
||||
(typecase seq
|
||||
(list (cons (cons nil (car seq))
|
||||
(mapcar (lambda (next cur)
|
||||
(cons (funcall diff-fun
|
||||
(funcall key next)
|
||||
(funcall key cur))
|
||||
next))
|
||||
(cdr seq)
|
||||
seq)))
|
||||
(vector (coerce (loop for cur = nil then next
|
||||
for next across seq
|
||||
if cur
|
||||
collect (cons (funcall diff-fun
|
||||
(funcall key next)
|
||||
(funcall key cur))
|
||||
cur)
|
||||
else collect (cons nil next))
|
||||
'vector)))))
|
||||
|
||||
(defun-ct cumsum
|
||||
(&key (add-fun #'+) (key #'identity) (combine (lambda (x y) y x)) (zero 0))
|
||||
(lambda (seq)
|
||||
(nreverse
|
||||
(reduce (lambda (accum next)
|
||||
(let ((key-val (funcall key next))
|
||||
(old-val (if accum
|
||||
(funcall key (car accum))
|
||||
zero)))
|
||||
(cons (funcall combine
|
||||
(funcall add-fun old-val key-val)
|
||||
next)
|
||||
accum)))
|
||||
seq
|
||||
:initial-value ()))))
|
||||
|
||||
(defun-ct over (fun &key (result-type 'list))
|
||||
(lambda (seq)
|
||||
(map result-type fun seq)))
|
||||
|
||||
(defun-ct denest (&key (result-type 'list))
|
||||
(lambda (seq)
|
||||
(apply #'concatenate result-type
|
||||
seq)))
|
||||
|
||||
(defmacro applying (fun &rest args)
|
||||
(alexandria:with-gensyms (seq)
|
||||
`(lambda (,seq)
|
||||
(apply ,fun ,@args ,seq))))
|
||||
|
||||
(defun-ct on (fun key)
|
||||
(lambda (it)
|
||||
(funcall fun (funcall key it))))
|
||||
|
||||
(defun filler (length1 length2 fill-value)
|
||||
(if (< length1 length2)
|
||||
(make-sequence 'vector (- length2 length1) :initial-element fill-value)
|
||||
#()))
|
||||
|
||||
(defun-ct zipping (result-type &key (fill-value nil fill-value-p))
|
||||
(lambda (seq1 seq2)
|
||||
(let ((length1 (when fill-value-p (length seq1)))
|
||||
(length2 (when fill-value-p (length seq2))))
|
||||
(let ((seq1 (if fill-value-p
|
||||
(concatenate result-type
|
||||
seq1
|
||||
(filler length1 length2 fill-value))
|
||||
seq1))
|
||||
(seq2 (if fill-value-p
|
||||
(concatenate result-type
|
||||
seq2
|
||||
(filler length2 length1 fill-value))
|
||||
seq2)))
|
||||
(map result-type #'list
|
||||
seq1 seq2)))))
|
||||
|
||||
(defun-ct maximizing (relation measure)
|
||||
(lambda (it)
|
||||
(let ((it-length (length it)))
|
||||
(when (> it-length 0)
|
||||
(values-list
|
||||
(reduce (lambda (|arg1764| |arg1765|)
|
||||
(destructuring-bind (cur-max max-idx) |arg1764|
|
||||
(destructuring-bind (next next-idx) |arg1765|
|
||||
(if (funcall relation (funcall measure cur-max) (funcall measure next))
|
||||
(list next next-idx)
|
||||
(list cur-max max-idx)))))
|
||||
(funcall (zipping 'vector)
|
||||
it
|
||||
(alexandria:iota it-length))))))))
|
||||
|
||||
#+nil
|
||||
(defmacro <> (arity &rest funs)
|
||||
(let ((arg-syms (loop repeat arity collect (gensym))))
|
||||
`(lambda (,@arg-syms)
|
||||
(declare (dynamic-extent ,@arg-syms))
|
||||
,(fw.lu:rollup-list (mapcar (lambda (x)
|
||||
(etypecase x
|
||||
(list `(funcall ,x))
|
||||
(symbol (list x))))
|
||||
funs)
|
||||
arg-syms))))
|
||||
|
||||
(defmacro <>1 (&rest funs)
|
||||
`(alexandria:compose ,@funs))
|
||||
Reference in New Issue
Block a user