Big Sky

Vim に入った channel 機能を使ってテキスト編集中も流れる twitter タイムラインの表示を考えてみた。


function! s:append(line)

  let wn = bufwinnr("tweets")

  if wn == -1

    return 0

  endif

  exe wn 'wincmd w'

  try

    let o = jsondecode(a:line)

    let ts = type(o) == 3 ? o : [o]

    for t in ts

      1put!=t.user.screen_name . ': ' . t.text

    endfor

  finally

    wincmd p

  endtry

endfunction



if bufwinnr("tweets") == -1

  10new tweets

  setlocal buftype=nofile bufhidden=hide noswapfile

  wincmd p

endif



function! TweetsCallback(handle, msg)

  for line in split(a:msg, "\n")

    call s:append(line)

  endfor

  redraw

endfunction



if exists('s:handle')

  call ch_close(s:handle)

endif

let s:handle = ch_open("127.0.0.1:7777", "raw", "TweetsCallback")

こんな Vim script を用意しておき、別のターミナルで


$ twty -S -json | nc -l -p 7777

twty を -json オプション付きでストリーミングさせる。

そして上記 Vim script を :so % で実行すると、テキスト編集中もどんどん流れる twitter タイムラインが出来上がる。

※タイムラインの内容は公開出来ないので興味のある方はご自分でお試し下さい。

13年前、僕は vim-dev (Vim の開発グループ)に Vim からソケット通信が出来る関数群のパッチを書いて送りました。

Socket functions for vim. - Yahoo! Groups
https://groups.yahoo.com/neo/groups/vimdev/conversations/topics/32576

その時は Bram (vimboss) に「Python や Perl インタフェースを使えるやないか、もしくは外部コマンドとか」と返されてしまいました。確かに言語拡張を使えば出来ますし、それに処理がブロッキングだったので実はそれほど有益では無かったかも知れません。

その後、このソケット通信のパッチは vimproc の一部に取り込まれ、シーケンシャルなソケット通信は出来る様になりました。しかし Vim には非同期インタフェースがありません。自分でイベントを投げ続けてソケットをハンドリングするしかありませんでした。しかし本日リリースされたパッチ 7.4.1191 で channel という機能により、非同期ソケット通信が出来る様になりました。

Patch 7.4.1191 - Google Groups
https://groups.google.com/forum/#!topic/vim_dev/t6RbXywJZRo

あのパッチを送った頃を知っている KoRoN さんや ynkdir さんは恐らく感慨深い思いではないかと思います。

channel は以下の様に使います。


function! Callback(handle, msg)

  echo a:msg

endfunction

let handle = ch_open("127.0.0.1:5000", "raw")

call ch_sendraw(handle, "GET / HTTP/1.0\r\n\r\n", "Callback")

ローカルにウェブサーバを立てておき、このコードを実行すると以下の様に表示されます。

raw だけでなく json も扱えます。先日入った jsonencode() を使う事も出来ます。接続関数 ch_open の第二引数に raw を指定すると文字列がそのまま送受信されます。json を指定すると json エンコードされた文字列が送信されます。送信関数は2つあり、ch_sendraw() は生の文字列を、ch_sendexpr() はハンドルと文字列をペアにした配列を送信します。サーバ側はこのハンドルに対して応答を返すと、複数のハンドルを持った vim のどちらに応答するか、といった事が可能になります。

今日はこの ch_sendexpr を使って時刻通知機能を作ってみました。まずサーバを書きます。


package main



import (

    "encoding/json"

    "log"

    "net"

    "time"

)



func main() {

    l, err := net.Listen("tcp", ":8888")

    if err != nil {

        log.Fatal(err)

    }

    for {

        conn, err := l.Accept()

        if err != nil {

            continue

        }

        go func(conn net.Conn) {

            defer conn.Close()

            var b [500]byte

            // リクエストを受け取る

            // フォーマットは JSON の配列

            // [handle, msg]

            n, err := conn.Read(b[:])

            if err != nil {

                log.Println(err)

                return

            }

            var v [2]interface{}

            err = json.Unmarshal(b[:n], &v)

            if err != nil {

                log.Println(err)

                return

            }

            // v の1個目には handle が入っているのでそのまま使う

            for {

                // v の2個目を更新して送信する

                v[1] = time.Now().String()

                err = json.NewEncoder(conn).Encode(v)

                if err != nil {

                    break

                }

                time.Sleep(1 * time.Second)

            }

        }(conn)

    }

}

サーバは Accept すると1行リクエストを受け取ってハンドル番号を得ます。その後、そのハンドル番号を指定して現在時刻を送り続けます。Vim script 側は以下の様に書きます。


function! Callback(handle, msg)

  echo "ただ今:" . a:msg

endfunction

let handle = ch_open("127.0.0.1:8888", "json", "Callback")

echo ch_sendexpr(handle, "GET", "Callback")