logaritmisk/pure
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'upstream/master'

Browse Source
This commit is contained in:
logaritmisk
2015-11-19 16:18:58 +01:00
parent 8971ec6e8f 22c4f0b403
commit 70b7a67057
4 changed files with 127 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files

133
async.zsh
View File

@@ -3,7 +3,7 @@
# #
# zsh-async # zsh-async
# #
# version: 1.0.0 # version: 1.1.0
# author: Mathias Fredriksson # author: Mathias Fredriksson
# url: https://github.com/mafredri/zsh-async # url: https://github.com/mafredri/zsh-async
# #
@@ -36,8 +36,8 @@ _async_job() {
duration=$(( EPOCHREALTIME - duration )) duration=$(( EPOCHREALTIME - duration ))
# stip all null-characters from stdout and stderr # stip all null-characters from stdout and stderr
stdout="${stdout//$'\0'/}" stdout=${stdout//$'\0'/}
stderr="${stderr//$'\0'/}" stderr=${stderr//$'\0'/}
# if ret is missing for some unknown reason, set it to -1 to indicate we # if ret is missing for some unknown reason, set it to -1 to indicate we
# have run into a bug # have run into a bug
@@ -60,11 +60,11 @@ _async_worker() {
# Process option parameters passed to worker # Process option parameters passed to worker
while getopts "np:u" opt; do while getopts "np:u" opt; do
case "$opt" in case $opt in
# Use SIGWINCH since many others seem to cause zsh to freeze, e.g. ALRM, INFO, etc. # Use SIGWINCH since many others seem to cause zsh to freeze, e.g. ALRM, INFO, etc.
n) trap 'kill -WINCH $ASYNC_WORKER_PARENT_PID' CHLD;; n) trap 'kill -WINCH $ASYNC_WORKER_PARENT_PID' CHLD;;
p) ASYNC_WORKER_PARENT_PID=$OPTARG;; p) ASYNC_WORKER_PARENT_PID=$OPTARG;;
u) unique=1;; u) unique=1;;
esac esac
done done
@@ -79,26 +79,33 @@ _async_worker() {
local job=$cmd[1] local job=$cmd[1]
# Check for non-job commands sent to worker # Check for non-job commands sent to worker
case "$job" in case $job in
_killjobs) _unset_trap)
kill -KILL ${${(v)jobstates##*:*:}%\=*} &>/dev/null trap - CHLD; continue;;
continue _killjobs)
;; # Do nothing in the worker when receiving the TERM signal
trap '' TERM
# Send TERM to the entire process group (PID and all children)
kill -TERM -$$ &>/dev/null
# Reset trap
trap - TERM
continue
;;
esac esac
# If worker should perform unique jobs # If worker should perform unique jobs
if ((unique)); then if (( unique )); then
# Check if a previous job is still running, if yes, let it finnish # Check if a previous job is still running, if yes, let it finnish
for pid in ${${(v)jobstates##*:*:}%\=*}; do for pid in ${${(v)jobstates##*:*:}%\=*}; do
if [[ "${storage[$job]}" == "$pid" ]]; then if [[ ${storage[$job]} == $pid ]]; then
continue 2 continue 2
fi fi
done done
fi fi
# run task in background # Run task in background
_async_job $cmd & _async_job $cmd &
# store pid because zsh job manager is extremely unflexible (show jobname as non-unique '$job')... # Store pid because zsh job manager is extremely unflexible (show jobname as non-unique '$job')...
storage[$job]=$! storage[$job]=$!
done done
} }
@@ -118,6 +125,8 @@ _async_worker() {
# $5 = resulting stderr from execution # $5 = resulting stderr from execution
# #
async_process_results() { async_process_results() {
setopt localoptions noshwordsplit
integer count=0 integer count=0
local worker=$1 local worker=$1
local callback=$2 local callback=$2
@@ -126,7 +135,7 @@ async_process_results() {
typeset -gA ASYNC_PROCESS_BUFFER typeset -gA ASYNC_PROCESS_BUFFER
# Read output from zpty and parse it if available # Read output from zpty and parse it if available
while zpty -rt "$worker" line 2>/dev/null; do while zpty -rt $worker line 2>/dev/null; do
# Remove unwanted \r from output # Remove unwanted \r from output
ASYNC_PROCESS_BUFFER[$worker]+=${line//$'\r'$'\n'/$'\n'} ASYNC_PROCESS_BUFFER[$worker]+=${line//$'\r'$'\n'/$'\n'}
# Split buffer on null characters, preserve empty elements # Split buffer on null characters, preserve empty elements
@@ -139,22 +148,34 @@ async_process_results() {
# Work through all results # Work through all results
while (( ${#items} > 0 )); do while (( ${#items} > 0 )); do
"$callback" "${(@)=items[1,5]}" $callback "${(@)=items[1,5]}"
shift 5 items shift 5 items
count+=1 count+=1
done done
# Empty the buffer # Empty the buffer
ASYNC_PROCESS_BUFFER[$worker]="" unset "ASYNC_PROCESS_BUFFER[$worker]"
done done
# If we processed any results, return success # If we processed any results, return success
(( $count )) && return 0 (( count )) && return 0
# No results were processed # No results were processed
return 1 return 1
} }
# Watch worker for output
_async_zle_watcher() {
setopt localoptions noshwordsplit
typeset -gA ASYNC_PTYS ASYNC_CALLBACKS
local worker=$ASYNC_PTYS[$1]
local callback=$ASYNC_CALLBACKS[$worker]
if [[ -n $callback ]]; then
async_process_results $worker $callback
fi
}
# #
# Start a new asynchronous job on specified worker, assumes the worker is running. # Start a new asynchronous job on specified worker, assumes the worker is running.
# #
@@ -162,14 +183,18 @@ async_process_results() {
# async_job <worker_name> <my_function> [<function_params>] # async_job <worker_name> <my_function> [<function_params>]
# #
async_job() { async_job() {
setopt localoptions noshwordsplit
local worker=$1; shift local worker=$1; shift
zpty -w "$worker" "$@" zpty -w $worker $@
} }
# This function traps notification signals and calls all registered callbacks # This function traps notification signals and calls all registered callbacks
_async_notify_trap() { _async_notify_trap() {
setopt localoptions noshwordsplit
for k in ${(k)ASYNC_CALLBACKS}; do for k in ${(k)ASYNC_CALLBACKS}; do
async_process_results "${k}" "${ASYNC_CALLBACKS[$k]}" async_process_results $k ${ASYNC_CALLBACKS[$k]}
done done
} }
@@ -181,12 +206,16 @@ _async_notify_trap() {
# async_register_callback <worker_name> <callback_function> # async_register_callback <worker_name> <callback_function>
# #
async_register_callback() { async_register_callback() {
setopt localoptions noshwordsplit nolocaltraps
typeset -gA ASYNC_CALLBACKS typeset -gA ASYNC_CALLBACKS
local worker=$1; shift local worker=$1; shift
ASYNC_CALLBACKS[$worker]="$*" ASYNC_CALLBACKS[$worker]="$*"
trap '_async_notify_trap' WINCH if (( ! ASYNC_USE_ZLE_HANDLER )); then
trap '_async_notify_trap' WINCH
fi
} }
# #
@@ -209,20 +238,22 @@ async_unregister_callback() {
# async_flush_jobs <worker_name> # async_flush_jobs <worker_name>
# #
async_flush_jobs() { async_flush_jobs() {
setopt localoptions noshwordsplit
local worker=$1; shift local worker=$1; shift
# Check if the worker exists # Check if the worker exists
zpty -t "$worker" &>/dev/null || return 1 zpty -t $worker &>/dev/null || return 1
# Send kill command to worker # Send kill command to worker
zpty -w "$worker" "_killjobs" zpty -w $worker "_killjobs"
# Clear all output buffers # Clear all output buffers
while zpty -r "$worker" line; do true; done while zpty -r $worker line; do true; done
# Clear any partial buffers # Clear any partial buffers
typeset -gA ASYNC_PROCESS_BUFFER typeset -gA ASYNC_PROCESS_BUFFER
ASYNC_PROCESS_BUFFER[$worker]="" unset "ASYNC_PROCESS_BUFFER[$worker]"
} }
# #
@@ -238,8 +269,25 @@ async_flush_jobs() {
# -p pid to notify (defaults to current pid) # -p pid to notify (defaults to current pid)
# #
async_start_worker() { async_start_worker() {
setopt localoptions noshwordsplit
local worker=$1; shift local worker=$1; shift
zpty -t "$worker" &>/dev/null || zpty -b "$worker" _async_worker -p $$ "$@" || async_stop_worker "$worker" zpty -t $worker &>/dev/null && return
typeset -gA ASYNC_PTYS
typeset -h REPLY
zpty -b $worker _async_worker -p $$ $@ || {
async_stop_worker $worker
return 1
}
if (( ASYNC_USE_ZLE_HANDLER )); then
ASYNC_PTYS[$REPLY]=$worker
zle -F $REPLY _async_zle_watcher
# If worker was called with -n, disable trap in favor of zle handler
async_job $worker _unset_trap
fi
} }
# #
@@ -249,10 +297,19 @@ async_start_worker() {
# async_stop_worker <worker_name_1> [<worker_name_2>] # async_stop_worker <worker_name_1> [<worker_name_2>]
# #
async_stop_worker() { async_stop_worker() {
setopt localoptions noshwordsplit
local ret=0 local ret=0
for worker in "$@"; do for worker in $@; do
async_unregister_callback "$worker" # Find and unregister the zle handler for the worker
zpty -d "$worker" 2>/dev/null || ret=$? for k v in ${(@kv)ASYNC_PTYS}; do
if [[ $v == $worker ]]; then
zle -F $k
unset "ASYNC_PTYS[$k]"
fi
done
async_unregister_callback $worker
zpty -d $worker 2>/dev/null || ret=$?
done done
return $ret return $ret
@@ -265,8 +322,20 @@ async_stop_worker() {
# async_init # async_init
# #
async_init() { async_init() {
(( ASYNC_INIT_DONE )) && return
ASYNC_INIT_DONE=1
zmodload zsh/zpty zmodload zsh/zpty
zmodload zsh/datetime zmodload zsh/datetime
# Check if zsh/zpty returns a file descriptor or not, shell must also be interactive
ASYNC_USE_ZLE_HANDLER=0
[[ -o interactive ]] && {
typeset -h REPLY
zpty _async_test cat
(( REPLY )) && ASYNC_USE_ZLE_HANDLER=1
zpty -d _async_test
}
} }
async() { async() {

2
package.json
View File

@@ -1,6 +1,6 @@
{ {
"name": "pure-prompt", "name": "pure-prompt",
"version": "1.2.0", "version": "1.3.0",
"description": "Pretty, minimal and fast ZSH prompt", "description": "Pretty, minimal and fast ZSH prompt",
"license": "MIT", "license": "MIT",
"repository": "sindresorhus/pure", "repository": "sindresorhus/pure",

34
pure.zsh
View File

@@ -84,17 +84,29 @@ prompt_pure_check_git_arrows() {
[[ -n $arrows ]] && prompt_pure_git_arrows=" ${arrows}" [[ -n $arrows ]] && prompt_pure_git_arrows=" ${arrows}"
} }
prompt_pure_set_title() {
# tell the terminal we are setting the title
print -n '\e]0;'
# show hostname if connected through ssh
[[ -n $SSH_CONNECTION ]] && print -Pn '(%m) '
case $1 in
expand-prompt)
print -Pn $2;;
ignore-escape)
print -rn $2;;
esac
# end set title
print -n '\a'
}
prompt_pure_preexec() { prompt_pure_preexec() {
# attempt to detect and prevent prompt_pure_async_git_fetch from interfering with user initiated git or hub fetch
[[ $2 =~ (git|hub)\ .*(pull|fetch) ]] && async_flush_jobs 'prompt_pure'
prompt_pure_cmd_timestamp=$EPOCHSECONDS prompt_pure_cmd_timestamp=$EPOCHSECONDS
# tell the terminal we are setting the title # shows the current dir and executed command in the title while a process is active
print -Pn "\e]0;" prompt_pure_set_title 'ignore-escape' "$PWD:t: $2"
# show hostname if connected through ssh
[[ "$SSH_CONNECTION" != '' ]] && print -Pn "(%m) "
# shows the current dir and executed command in the title when a process is active
# (use print -r to disable potential evaluation of escape characters in cmd)
print -nr "$PWD:t: $2"
print -Pn "\a"
} }
# string length ignoring ansi escapes # string length ignoring ansi escapes
@@ -190,12 +202,8 @@ prompt_pure_precmd() {
# check for git arrows # check for git arrows
prompt_pure_check_git_arrows prompt_pure_check_git_arrows
# tell the terminal we are setting the title
print -Pn "\e]0;"
# show hostname if connected through ssh
[[ "$SSH_CONNECTION" != '' ]] && print -Pn "(%m) "
# shows the full path in the title # shows the full path in the title
print -Pn "%~\a" prompt_pure_set_title 'expand-prompt' '%~'
# get vcs info # get vcs info
vcs_info vcs_info

7
readme.md
View File

@@ -134,9 +134,10 @@ To have commands colorized as seen in the screenshot install [zsh-syntax-highlig
### [oh-my-zsh](https://github.com/robbyrussell/oh-my-zsh) ### [oh-my-zsh](https://github.com/robbyrussell/oh-my-zsh)
1. Symlink (or copy) `pure.zsh` to `~/.oh-my-zsh/custom/pure.zsh-theme` 1. Remove competing theme included in oh-my-zsh `~/.oh-my-zsh/themes/pure.zsh-theme`
2. Symlink (or copy) `async.zsh` to `~/.oh-my-zsh/custom/async.zsh` 2. Symlink (or copy) `pure.zsh` to `~/.oh-my-zsh/custom/pure.zsh-theme`
3. Add `ZSH_THEME="pure"` to your `.zshrc` file. 3. Symlink (or copy) `async.zsh` to `~/.oh-my-zsh/custom/async.zsh`
4. Add `ZSH_THEME="pure"` to your `.zshrc` file.
### [prezto](https://github.com/sorin-ionescu/prezto) ### [prezto](https://github.com/sorin-ionescu/prezto)