X-Git-Url: http://git.rot13.org/?p=angular-mojolicious.git;a=blobdiff_plain;f=angular-server.pl;h=1f253a3f2dbbe18a4ba641e4aa6b14d5ca45ec13;hp=a70e3b7a36d31f2b5aec470d7ab5a6749fc89080;hb=0f3d8e74e07518d7440b8bbad55c13011f34d502;hpb=024a77d04a5416b236970602222d08925194ac6b diff --git a/angular-server.pl b/angular-server.pl index a70e3b7..1f253a3 100755 --- a/angular-server.pl +++ b/angular-server.pl @@ -1,15 +1,70 @@ #!/usr/bin/env perl +use lib 'common/mojo/lib'; + use Mojolicious::Lite; use Data::Dump qw(dump); +use Time::HiRes; +use Clone qw(clone); + +sub new_uuid { Time::HiRes::time * 100000 } # based on # http://docs.getangular.com/REST.Basic # http://angular.getangular.com/data -our $data; +my $couchdb = 'http://localhost:5984'; +my $client = Mojo::Client->new; + +sub _couchdb_put { + my ( $url, $data ) = @_; + + $data->{'$entity'} = $1 if $url =~ m{/(\w+)\.\d+/$/}; + + my $json = Mojo::JSON->new->encode( $data ); + + my $rev; + + warn "# _couchdb_put $url = $json"; + $client->put( "$couchdb/$url" => $json => sub { + my ($client,$tx) = @_; + my ($message, $code) = $tx->error; + my $response = $tx->res->json; + warn "## response $code ",dump($response); + if ($tx->error) { + die "ERROR $code $message"; + } + return + $rev = $response->{rev}; + })->process; + + warn "## rev = $rev"; + return $rev; +} + +sub _couchdb_get { + my ( $url ) = @_; + my $return = $client->get( "$couchdb/$url" )->res->json; + warn "# _couchdb_get $url = ",dump($return); + return $return; +} -get '/' => 'index'; + +our $id2nr; + + +sub _render_jsonp { + my ( $self, $json ) = @_; +#warn "## _render_json ",dump($json); + my $data = $self->render( json => $json, partial => 1 ); +warn "## _render_json $data"; + if ( my $callback = $self->param('callback') ) { + $data = "$callback($data)"; + } + $self->render( data => $data, format => 'js' ); +} + +#get '/' => 'index'; get '/_replicate' => sub { my $self = shift; @@ -17,7 +72,6 @@ get '/_replicate' => sub { if ( my $from = $self->param('from') ) { my $got = $self->client->get( $from )->res->json; warn "# from $from ",dump($got); - $self->render_json( $got ); my $database = $got->{name}; my $entities = $got->{entities}; @@ -25,60 +79,114 @@ get '/_replicate' => sub { if ( $database && $entities ) { foreach my $entity ( keys %$entities ) { my $url = $from; - $url =~ s{/+$}{/}; + $url =~ s{/?$}{/}; # add slash at end $url .= $entity; - my $e = $self->client->get( $url )->res->json; - warn "# replicated $url ", dump($e); - $data->{$database}->{$entity} = $e; + my $all = $self->client->get( $url )->res->json; + warn "# replicated $url ", dump($all); + foreach my $e ( @$all ) { + delete $e->{_id}; # sanitize data from older implementation + _couchdb_put( "/$database/$entity." . $e->{'$id'} => $e ); + } } } + _render_jsonp( $self, $got ); } }; -get '/_data' => sub { - shift->render_json( $data ) -}; - get '/data/' => sub { my $self = shift; - $self->render_json( [ keys %$data ] ); + _render_jsonp( $self, _couchdb_get('/_all_dbs') ); }; get '/data/:database' => sub { my $self = shift; my $database = $self->param('database'); + my $list_databases = { name => $database }; - foreach my $entity ( keys %{ $data->{ $database }} ) { -warn "# entry $entity ", dump( $data->{$database}->{$entity} ); - my $count = $#{ $data->{$database}->{$entity} } + 1; - $list_databases->{entities}->{$entity} = $count; - $list_databases->{document_count} += $count; + + my $counts = _couchdb_get("/$database/_design/entity/_view/counts?group=true"); + if ( exists $counts->{error} ) { + warn "creating CouchDB view because of ", dump($counts); + _couchdb_put "/$database/_design/entity", { + _id => '_design/entity', + language => 'javascript', + views => { + counts => { + map => q| function(doc) { emit(doc.$entity,1); } |, + reduce => q| function(keys,values,rereduce) { return sum(values); } |, + } + } + }; + $counts = _couchdb_get("/$database/_design/entity/_view/counts?group=true") + || die "give up!"; + } + + warn "# counts ",dump($counts); + + foreach my $row ( @{ $counts->{rows} } ) { + my $n = $row->{value}; + $list_databases->{entities}->{ $row->{key} } = $n; + $list_databases->{document_counts} += $n; } warn dump($list_databases); - $self->render_json( $list_databases ); + _render_jsonp( $self, $list_databases ); }; get '/data/:database/:entity' => sub { my $self = shift; - $self->render_json( $data->{ $self->param('database') }->{ $self->param('entity' ) } ); + + my $database = $self->param('database'); + my $entity = $self->param('entity'); + + my $endkey = $entity; + $endkey++; + + my $counts = _couchdb_get qq|/$database/_all_docs?startkey="$entity";endkey="$endkey";include_docs=true|; + warn "# counts ",dump($counts); + + _render_jsonp( $self, [ map { $_->{doc} } @{ $counts->{rows} } ] ) }; get '/data/:database/:entity/:id' => sub { my $self = shift; + my $database = $self->param('database'); + my $entity = $self->param('entity'); + my $id = $self->param('id'); + + _render_jsonp( $self, _couchdb_get( "/$database/$entity.$id" ) ); }; -any [ 'put' ] => '/data/:database/:entity/:id' => sub { +any [ 'post' ] => '/data/:database/:entity' => sub { my $self = shift; - $data->{ $self->param('database') }->{ $self->param('entity') }->{ $self->param('id') } = $self->req->json; - dumper $data; + my $database = $self->param('database'); + my $entity = $self->param('entity'); + my $json = $self->req->json; + my $id = $json->{'$id'} # XXX we don't get it back from angular.js + || new_uuid; + warn "## $database $entity $id body ",dump($self->req->body, $json); + + $json->{'$id'} ||= $id; # make sure $id is in there + + my $rev = _couchdb_put "/$database/$entity.$id" => $json; + $json->{_rev} = $rev; + + _render_jsonp( $self, $json ); }; -get '/demo/:groovy' => sub { + +get '/' => sub { shift->redirect_to('/Cookbook') }; + +get '/Cookbook' => 'Cookbook'; +get '/Cookbook/:example' => sub { my $self = shift; - $self->render(text => $self->param('groovy'), layout => 'funky'); + $self->render( "Cookbook/" . $self->param('example'), layout => 'angular' ); }; +get '/conference/:page' => sub { + my $self = shift; + $self->render( "conference/" . $self->param('page'), layout => 'angular' ); +}; app->start; __DATA__ @@ -92,3 +200,15 @@ Yea baby! Funky! <%== content %> + +@@ layouts/angular.html.ep + + + + +% my $ANGULAR_JS = $ENV{ANGULAR_JS} || ( -e 'public/angular/build/angular.js' ? '/angular/build/angular.js' : '/angular/src/angular-bootstrap.js' ); + + + <%== content %> +