1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
|
;;;; main.lisp -- oneliners.cli entrypoint
(defpackage oneliners.cli
(:use :cl)
(:local-nicknames (#:api #:oneliners.api-client)
(#:a #:alexandria)))
(in-package :oneliners.cli)
;;; CONFIG AND RESULTS FILE LOCATIONS
(defvar *config* nil
"A configuration plist")
(defun make-config (&key host api-token editor)
(append (when host (list :host host))
(when api-token (list :api-token api-token))
(when editor (list :editor editor))))
(defun valid-config-p (config)
(and (listp config)
(evenp (length config))
(stringp (getf config :host))
t))
(defun write-default-config-to-disk ()
(let ((conf-file (config-file)))
(ensure-directories-exist conf-file)
(with-open-file (out conf-file :direction :output)
(print (make-config :host "http://localhost:8888") out))))
(defun write-config-to-disk ()
(let ((conf-file (config-file)))
(ensure-directories-exist conf-file)
(with-open-file (out conf-file :direction :output :if-exists :supersede)
(print *config* out))))
(defun fetch-config-from-disk ()
(let ((conf
(uiop:with-safe-io-syntax ()
(uiop:read-file-form (config-file)))))
(assert (valid-config-p conf) () "Invalid configuration file")
(setf *config* conf)))
(defun ensure-config ()
(unless (uiop:file-exists-p (config-file))
(write-default-config-to-disk))
(fetch-config-from-disk))
(defun host () (getf *config* :host))
(defun api-token () (getf *config* :api-token))
(defun (setf api-token) (newval)
(setf (getf *config* :api-token) newval))
(defun make-temp-file-name ()
(namestring
(merge-pathnames (format nil "~a" (gensym "oneliners")) (uiop:temporary-directory))))
(defun string-from-editor ()
(let ((filename (make-temp-file-name)))
(unwind-protect
(magic-ed:magic-ed filename :eval nil :output :string)
(uiop:delete-file-if-exists filename))))
(defun config-file ()
(merge-pathnames ".config/oneliners.config" (user-homedir-pathname)))
(defun last-search-file ()
(merge-pathnames ".last_oneliners_search" (user-homedir-pathname)))
(defun fetch-nth-oneliner (n)
"Returns nil if there is no nth oneliner from the search history."
(when (uiop:file-exists-p (last-search-file))
(nth n (uiop:read-file-form (last-search-file)))))
(defun executable-on-system-p (name)
"A hack that heuristically determins whether or not an executable
with the provided name is on the system. It is not perfect. It
consults the environment PATH, and looks for the command in any of
the directories that appear in the value of that variable."
#+unix
(loop for path in (str:split ":" (uiop:getenv "PATH"))
for directory = (cons :absolute
(cdr (str:split "/" path)))
thereis (uiop:file-exists-p
(make-pathname :name name :directory directory))))
(defun tags-from-oneliner (oneliner)
(remove-if-not #'executable-on-system-p (ppcre:split " +" oneliner)))
(defun prompt (prompt &key (out-stream *standard-output*) (in-stream *standard-input*))
(princ prompt out-stream) (force-output out-stream)
(read-line in-stream))
;;; API REQUEST FUNCTIONS
;; (defun flag-item (item-number)
;; (ensure-config)
;; (api:request-with
;; (:host (host))
;; (a:if-let ((token (api-token))
;; (oneliner (history item-number)))
;; (api:patch--flag-oneliner (getf oneliner :id) :token token))))
(defun add-new-oneliner ()
(ensure-config)
(assert (api-token) () "Cannot add a oneliner without an api token.")
(let* ((oneliner
(prompt "Oneliner: "))
(init-tags
(tags-from-oneliner oneliner))
(brief
(prompt "Brief Description: "))
(tags
(append init-tags
(when (y-or-n-p "Add tags in addition to: ~{~a ~}?" init-tags)
(ppcre:split " +" (prompt "(e.g. foo bar goo): ")))))
(explanation
(when (y-or-n-p "Provide an explanation?")
(string-from-editor))))
(api:request-with
(:host (host)
:body (jonathan:to-json
(list :oneliner oneliner
:tags tags
:brief brief
:explanation explanation))
:content-type "application/json")
(api:post--add-oneliner :token (api-token))
(format t "Added~%"))))
(defun request-invite-code ()
(ensure-config)
(api:request-with
(:host (host))
(format t "Invite Code: ~a~%"
(getf (jonathan:parse (api:post--make-invite :token (api-token))) :code))))
(defun login (user pass)
(ensure-config)
(a:when-let (response (jonathan:parse
(api:request-with
(:host (host))
(api:post--token-contributor user :password pass))))
(setf (api-token) (getf response :token))
(write-config-to-disk)
(format t "Access token written to ~a~%" (config-file))))
(defun redeem-invite (token name pass)
(ensure-config )
(api:request-with
(:host (host))
(api:post--redeem-invite token
:username name
:password1 pass
:password2 pass)))
(defun cache-search-results-to-last-search-file (results)
(with-open-file (output (last-search-file) :direction :output :if-exists :supersede)
(print results output)))
(defun print-oneliner-result-for-user (number oneliner)
(format t "~3a~a~a: ~a"
number
(if (getf oneliner :isflagged)
"⚠" " ")
(if (getf oneliner :islocked)
"🔒" " ")
(getf oneliner :brief))
(format t "~% ~a~%~%" (getf oneliner :oneliner)))
(defun search-for-oneliners (terms limit not-flagged-p)
(assert (loop for term in terms never (find #\, term) ))
(ensure-config)
(let ((response
(api:request-with
(:host (host))
(api:get--search :tags (str:join "," terms)
:limit limit
:notflagged (if not-flagged-p "true" "false")))))
(handler-case
(a:when-let (oneliners
(getf (jonathan:parse response) :oneliners))
(cache-search-results-to-last-search-file
(loop for number from 1
for oneliner in oneliners
collect (list* :result-number number oneliner)
do (print-oneliner-result-for-user number oneliner)))))))
;;; RUNNING COMMANDS
(defun parent-process-name ()
"Prints the name of the parent process of the current process."
(let ((ppidfile (format nil "/proc/~a/status" (osicat-posix:getppid))))
(first (last
(ppcre:split "\\s"
(with-open-file (input ppidfile)
(read-line input)))))))
(defmacro wait-until ((&key (timeout 1) (poll-every 0.01)) &body check)
"Run CHECK every POLL-EVERY seconds until either TIMEOUT seconds
have passed or CHECK returns non-nil."
(let ((clockvar (gensym))
(var (gensym)))
`(loop
for ,clockvar from 0 by ,poll-every to ,timeout
for ,var = (progn ,@check)
when ,var
return ,var
do (sleep ,poll-every))))
(defun run-with-shell
(command
&key
(shell-name (parent-process-name))
(await-output-p 0.8)
(output-stream *standard-output*))
"run COMMAND, a string, in a fresh shell environment, initialized
with SHELL-NAME. The output from the command read line by line and is
printed to OUTPUT-STREAM. "
(let ((shell
(uiop:launch-program shell-name :input :stream :output :stream)))
(symbol-macrolet ((shell-input (uiop:process-info-input shell))
(shell-output (uiop:process-info-output shell)))
(write-line command shell-input)
(finish-output shell-input)
(when await-output-p
(wait-until (:timeout await-output-p :poll-every 0.005)
(listen shell-output))
(loop while (listen shell-output)
do (princ (read-line shell-output) output-stream)
(terpri output-stream))))))
|
