「覚えられません」と書くと覚えられる法則に基づき「覚えられません」と書いておきます。tar xzvf の x を c に変えるだけなんだけど、そのあとの引数が覚えられない……

tar cvfz foo.tar.gz dir

もともと userChrome.js で同じようなのを書いていたのだけど、Fx4 になって動かなくなったので、JetPack で作りなおしてみた。

• https://github.com/cho45/manyproxiesswitcher/blob/master/lib/main.js
• https://github.com/downloads/cho45/manyproxiesswitcher/manyproxiesswitcher.xpi

Panel は他ウィンドウフォーカスすると消えてしまうので、普通の Window のほうがいい気がしたけど、やりかたがわからなかった。showModalDialog とかなのかもしれないけど、変にハマりたくなったので凝ったことはしてない、つもりだけど権限の問題で全体的に message のやりとりばかりになってしまう。仕方ないけど読みにくいですね。

今の JetPack Add-on sdk はよくできてて、セットアップして cfx init したあとは、cfx run を繰替えし、できたら cfx xpi すればいいので簡単 (cfx コマンドは SDK に入っている)

できた xpi はインストール時に再起動がいらない (Add-ons bar だけ再起動する) ので便利

これは XHR にもあてはまってしまう。

マジでヤバい場合以外 50x を返さないということが必要になってしまう。バックエンドが応答できない場合特定のレスポンスを 200 で返したい、とかいうのは nginx でできるのか?

あるいはそもそも、1度 50x がでたらちゃんと待てばいいんだろうか?

1. 小さいものは美しい
2. 各スニペットが一つのことをうまくやるようにせよ
3. できる限り最小限のプロトタイプを作れ
4. コード量よりも移植のしやすさを選べ
5. 単純なオブジェクトにデータを格納せよ
6. 最小限のコードで最大限のことをすることに優位性を見出せ
7. 効率と移植性を高めるためにコールバックを利用せよ
8. 束縛するインターフェースは作るな
9. 全てのスニペットは限りなく独立して動くようにせよ

Mike Gancarz の UNIX哲学の改変です

Twitter でマジメな話ができないので、変な議論を呼びそうだなーとか、フローに流しても仕方ないこととか、ここに書いていこうという気持ちだけど、それに対して Twitter で返信されたらどうしたらいいのだろうなあ。追記するだけだと相手が気付かないし……

binding を書いた (まだブランチに入れてある)

• https://github.com/cho45/jsdeferred/blob/jetpack/jsdeferred.jetpack.js#L368

• setTimeout/clearTimeout がないので nsITimer で実装 (これでいいのか?)
• Deferred.postie という utility を追加

Deferred.postie(constructor, options) を使って widget/panel をつくるとメソッドが増えます。

• post(args..., function) //=> Deferred
  • function をレシーバの content context 内で args と共に呼び、結果を取得
• bind(selector, event, function) //=> Deferred
  • content 内の selector でマッチする要素全てで、 event が発火時 function (chrome context) を呼びだす

以下のように書けます。post に渡す関数は文字列化されて content に渡されるので、スコープを外部と共有していない。args も JSON で表現できるものしか渡せない。この点わかりにくいのでイマイチかもしれない。

完全に message のやりとりを置き換えられるわけではないけど、ちょっとしたイベント処理とかは直列で簡単に書けるようになるので、便利な場合は便利かもしれない。

const Deferred = require("jsdeferred").Deferred;
Deferred.define(this); //define 使う場合必ず引数に this を渡す必用あり

widget = Deferred.postie(widgets.Widget, {
	label      : "Foo",
	contentURL : 'http://example.com/',
	width      : 32,
	onClick    : function () {
		var self = this;

		next(function () {
			return self.
				post(1, 2, function (a, b) { // content context 
					return a + b;
				}).
				next(function (res) { // chrome context
					console.log(res);
				});
		}).
		next(function () {
			return wait(1);
		}).
		next(function () {
			return self.
				post(function (a, b) {
					throw "foo";
				}).
				next(function (res) {
					console.log(res);
				}).
				error(function (e) {
					console.log(e);
				});
		});
	},
	onMessage : function (message) {
		console.log(message);
	},
	contentScript : 'setTimeout(function () { postMessage("custom message") }, 1000)',
});

widget.post(function () {
	var d = new Deferred();
	setTimeout(function () {
		d.call(1);
	}, 1000);
	return d;
}).
next(function (a) {
	console.log("Hello! " + a);
}).
error(function (e) {
	console.log(e);
});

widget.bind("body", "click", function (e) {
	console.log("body clicked" + e);
}).
error(function (e) {
	console.log(e);
});

Q4M って DBI 使うとブロックしちゃうけど、非同期にするにはどうしたらいいんだろう。AnyEvent::Worker|AnyEvent::DBI (=fork) 使うのがいいのかな。スタンダードな方法がわからない

LDR Streaming API では自力で MQ 作ったというのを見たけど、これ使っとけ的なのはないのかなあ……

Memo

• http://wiki.secondlife.com/wiki/Message_Queue_Evaluation_Notes

かなりざっくり書くと以下のような感じになる気がするけど、こういう HTTP ベースの内部用途の pub/sub サーバって既に良いのはあるのかな……

package Buspub;

use strict;
use warnings;
sub route ($$);
use Router::Simple;
use Tie::IxHash;
use AnyEvent::HTTP;
use HTTP::Request::Common;
use JSON::XS;
use POSIX ();

use MongoDB;
my $connection = MongoDB::Connection->new(host => 'localhost', port => 27017);
my $subscriptions = $connection->get_database('pubsub')->subscriptions;
$subscriptions->ensure_index(Tie::IxHash->new( key => 1, created => -1 ), { background => 1 });

route '/sub' => {
	action => sub {
		my ($r) = @_;
		my $key = $r->req->param('key') or return $r->json({ error => "key required"});;
		my $callback = $r->req->param('callback') or return $r->json({ error => "callback required"});;
		my $id = $subscriptions->insert({
			key      => $key,
			messages => [],
			callback => $callback,
			max      => 25,
			created  => scalar time(),
		});
		LOG("SUB:: %s with callback: %s", $key, $callback);
		$r->json({ id => "$id" });
	}
};

route '/pub' => {
	action => sub {
		my ($r) = @_;
		my $key = $r->req->param('key') or return $r->json({ error => "key required"});;
		my $message = decode_json $r->req->param('message');

		my $cursor = $subscriptions->query({ key => $key });
		my %count;
		while (my $obj = $cursor->next) {
			$count{all}++;
			my $id  = $obj->{_id} . "";
			my $uri = $obj->{callback};
			my $messages = [ @{$obj->{messages}}, $message ];
			my $req = POST $uri, [ id => $id, messages => encode_json($messages) ];

			LOG("PUB:: => %s => %s with %d messages", $key, $req->uri, scalar @$messages);
			http_request $req->method => $req->uri,
				body => $req->content,
				headers => {
					map { $_ => $req->header($_), } $req->headers->header_field_names
				},
				timeout => 20,
				sub {
					my ($body, $headers) = @_;
					LOG("PUB:: <= %s <= %s with status:%d", $key, $req->uri, $headers->{Status});
					if ($headers->{Status} =~ /^2/) {
						$subscriptions->update({ _id => $obj->{_id} }, { '$pullAll' => { messages => $obj->{messages} } });
					} elsif ($headers->{Status} =~ /^4/) {
						$subscriptions->remove({ _id => $obj->{_id} });
					} elsif ($headers->{Status} =~ /^5/) {
						if (@$messages > $obj->{max}) {
							$subscriptions->remove({ _id => $obj->{_id} });
						} else {
							$subscriptions->update({ _id => $obj->{_id} }, { '$push' => { messages => $message } });
						}
					}
				}
			;
		}
		$r->json({ key => $key, delivered => \%count });
	}
};

route '/test/callback' =>  {
	action => sub {
		my ($r) = @_;
		use Data::Dumper;
		warn Dumper $r->req->param('id') ;
		warn Dumper decode_json $r->req->param('messages') ;
		$r->res->status($r->req->param('code') || 404);
		$r->res->content_type('application/json; charset=utf8');
		$r->res->content('{}');
		$r->res->finalize;
	}
};


BEGIN {
	my $router = Router::Simple->new;
	sub route ($$) { $router->connect(@_) };

	sub run {
		my ($env) = @_;
		if ( my $handler = $router->match($env) ) {
			my $c = Buspub::Context->new($env);
			$handler->{action}->($c);
		} else {
			[ 404, [ 'Content-Type' => 'text/html' ], ['Not Found'] ];
		}
	}

	sub LOG {
		my ($message, @args) = @_;
		print sprintf("[%s] $message", POSIX::strftime("%Y-%m-%d %H:%M:%S", localtime), @args), "\n";
	}
};

package Buspub::Request;
use parent qw(Plack::Request);

package Buspub::Response;
use parent qw(Plack::Response);

package Buspub::Context;
use JSON::XS;

sub new {
	my ($class, $env) = @_;
	bless {
		req => Buspub::Request->new($env),
		res => Buspub::Response->new(200),
	}, $class;
}

sub req { $_[0]->{req} }
sub res { $_[0]->{res} }

sub json {
	my ($self, $vars) = @_;
	my $body = JSON::XS->new->ascii(1)->encode($vars);
	$self->res->content_type('application/json; charset=utf8');
	$self->res->content($body);
	$self->res->finalize;
}

\&Buspub::run;

バイナリもう1つ作って Contents/Info.plist のそれっぽいエントリを消したり、s/Firefox/XXXXX/g したりするとうまくいくようだ……

ウェブ側からリンクを貼って特定のアプリを起動させる場合、独自スキームを使うというのは自然な流れでまぁ普通そうしたい感じですが、対象アプリが入っているか否かをウェブ側から取得することができないため (できるの?)、アプリが入ってないユーザさんに対してブラウザのそっけないエラー画面になってしまうのであまり好ましくありません (アプリが入っていることがほぼ確実ならこれでいいけど)

現状でこの方法は簡単には解決できなくて、おそらく現状のベストプラクティス的には http を併用するのかと思っています。

• fooscheme:openapp をアプリケーションでハンドリング
  • 確実にアプリが入ってることが判定できる場合に使う?
    • 普通にインテント使えばいいので、たぶんあんまり使うケースない……
  • スキーム無闇に増やすと怒られる
• http://mydomain/openapp をアプリケーションでハンドリング
  • ウェブからアプリを起動したいときに使う
  • URLには「アプリケーションをインストールする」ページを作っておく
  • このURLにアクセスすると Browser とアプリ2つ表示されてしまうので、デフォルトでアプリを開くようにユーザを促す

        <activity android:name=".PostEntryActivity"
                  android:label="@string/app_name"
                  android:screenOrientation="portrait" android:configChanges="orientation">
            <intent-filter>
                <action android:name="android.intent.action.VIEW" />
                <category android:name="android.intent.category.DEFAULT" />
                <category android:name="android.intent.category.ALTERNATIVE" />
                <category android:name="android.intent.category.BROWSABLE" />

                <data android:scheme="fooapp" android:host="open"/>
                <data android:scheme="http" android:host="fooapp.example.com" android:pathPattern="/openapp"/>
            </intent-filter>
        </activity>

とはいえ、この方法モノリスでやるときにとろうとしたんですけど、何かがうまくいかなかった気がするので本当にこれでいけるか不安です。(今試した感じ想像通りに動いたので、うまくいかなかったのは当時の勘違いだったかもしれない。あるいは Android1.6 だとブラウザ内の http:// に関しては確実に Browser が制御を奪ってしまっていたような気がする)

Text::Xatena の nytprof 結果を眺めていたら CORE::qr がやたら呼ばれていたので、use constant で qr// をループの外に出したら速度が多少改善した。通常の正規表現マッチは勝手にいい感じに定数っぽくしてくれるけど、正規表現パターンはしてくれないのかな。

• https://github.com/cho45/Text-Xatena/commit/9d1e6d01bfb3217da0f0ad780da1f0de88b9e4cf

before
-Rate   Hatena  Textile Markdown   Xatena
-Hatena   26.8/s       --     -84%     -86%     -89%
-Textile   171/s     537%       --      -8%     -27%
-Markdown  186/s     594%       9%       --     -20%
-Xatena    233/s     770%      37%      25%       --

after
+           Rate   Hatena  Textile Markdown   Xatena
+Hatena   26.5/s       --     -85%     -86%     -93%
+Textile   175/s     563%       --      -8%     -56%
+Markdown  191/s     621%       9%       --     -52%
+Xatena    395/s    1393%     125%     107%       --

Benchmark.javascript - jsdo.it - share JavaScript, HTML5 and CSS

ベンチマーク計るやつを jsdo.it に置いときました。jsdo.it だと HTML も含めてセットにできるのでいいですね。Fork していくつか関数を定義するだけでベンチ計れるので、ぜひお使いください……

(jsdo.it のブログパーツがはれるようになったみたいですね)