mirror of https://codeberg.org/cage/tinmop/
- [rpc] added 'gemini-stream-parsed-line'.
This commit is contained in:
parent
a6a8b0ad8f
commit
cbb447a84e
|
@ -213,7 +213,6 @@
|
||||||
(loop for line in lines
|
(loop for line in lines
|
||||||
collect
|
collect
|
||||||
(let ((flattened (mapcar #'rearrange-for-encoding (a:flatten line))))
|
(let ((flattened (mapcar #'rearrange-for-encoding (a:flatten line))))
|
||||||
(misc:dbg "flattened ~s ~s" flattened (contains-chldren-p flattened))
|
|
||||||
(when flattened
|
(when flattened
|
||||||
(if (contains-chldren-p flattened)
|
(if (contains-chldren-p flattened)
|
||||||
(append (list (cons "type" (first flattened)))
|
(append (list (cons "type" (first flattened)))
|
||||||
|
@ -262,6 +261,16 @@
|
||||||
(cons "fragment" fragment)
|
(cons "fragment" fragment)
|
||||||
(cons "host" host)))))
|
(cons "host" host)))))
|
||||||
|
|
||||||
|
(defun gemini-stream-parsed-line (iri line-number)
|
||||||
|
(a:when-let* ((stream-wrapper (gw:find-db-stream-url iri))
|
||||||
|
(parsed-lines (gw:parsed-lines stream-wrapper)))
|
||||||
|
(when (and (integerp line-number)
|
||||||
|
(>= line-number 0)
|
||||||
|
(< line-number (length parsed-lines)))
|
||||||
|
(let ((res (rearrange-parsed-line-for-encoding (list (elt parsed-lines line-number)))))
|
||||||
|
(misc:dbg "res ~a res")
|
||||||
|
res))))
|
||||||
|
|
||||||
(defun gemini-stream-info (iri)
|
(defun gemini-stream-info (iri)
|
||||||
(a:when-let ((stream-wrapper (gw:find-db-stream-url iri)))
|
(a:when-let ((stream-wrapper (gw:find-db-stream-url iri)))
|
||||||
(rpc::render-as-list stream-wrapper)))
|
(rpc::render-as-list stream-wrapper)))
|
||||||
|
@ -282,4 +291,8 @@
|
||||||
(gen-rpc "gemini-stream-info"
|
(gen-rpc "gemini-stream-info"
|
||||||
'gemini-stream-info
|
'gemini-stream-info
|
||||||
"iri" 0)
|
"iri" 0)
|
||||||
|
(gen-rpc "gemini-stream-parsed-line"
|
||||||
|
'gemini-stream-parsed-line
|
||||||
|
"iri" 0
|
||||||
|
"line-number" 1)
|
||||||
,@body))
|
,@body))
|
||||||
|
|
Loading…
Reference in New Issue