Updated dart-stream.

dart-stream/README.md

@@ -5,12 +5,12 @@ This test adds [Stream](https://github.com/rikulo/stream), a lightweight Dart we
 ## Versions
 
 * [Dart SDK version 0.8.7.0_r29341](https://launchpad.net/~hachre/+archive/dart)
-* [Dart args version 0.8.7](http://pub.dartlang.org/packages/args)
-* [Dart crypto version 0.8.7](http://pub.dartlang.org/packages/crypto)
-* [Dart mongo_dart version 0.1.31](http://pub.dartlang.org/packages/mongo_dart)
-* [Dart postgresql version 0.2.9](http://pub.dartlang.org/packages/postgresql)
-* [Dart stream version 0.8.6+2](http://pub.dartlang.org/packages/start)
-* [Dart yaml version 0.8.7](http://pub.dartlang.org/packages/yaml)
+* [Dart args version 0.9.0](http://pub.dartlang.org/packages/args)
+* [Dart crypto version 0.9.0](http://pub.dartlang.org/packages/crypto)
+* [Dart mongo_dart version 0.1.35](http://pub.dartlang.org/packages/mongo_dart)
+* [Dart postgresql version 0.2.11](http://pub.dartlang.org/packages/postgresql)
+* [Dart stream version 1.0.0](http://pub.dartlang.org/packages/start)
+* [Dart yaml version 0.9.0](http://pub.dartlang.org/packages/yaml)
 
 ## Test URLs
 

dart-stream/pubspec.yaml

@@ -7,5 +7,6 @@ dependencies:
   crypto: 0.9.0
   mongo_dart: 0.1.35
   postgresql: 0.2.11
-  stream: 0.8.7+2
+  rikulo_commons: 1.0.0
+  stream: 1.0.0
   yaml: 0.9.0

dart-stream/server.dart

@@ -153,7 +153,7 @@ _updatesTest(HttpConnect connect) {
             return _connectionPool.connect()
               .then((connection) {
                 return connection.execute(
-                      'UPDATE "World" SET "randomnumber" = @randomnumber WHERE "id" = @id;',
+                      'UPDATE world SET randomnumber = @randomnumber WHERE id = @id;',
                       { 
                         'randomnumber': world.randomnumber,
                         'id': world.id 
@@ -170,7 +170,7 @@ _updatesTest(HttpConnect connect) {
 _fortunesTest(HttpConnect connect) {
   
   return _connectionPool.connect().then((connection) {
-    return connection.query('SELECT "id", "message" FROM "Fortune";')
+    return connection.query('SELECT id, message FROM fortune;')
         .map((row) => new Fortune(row[0], row[1]))
           .toList()
             .whenComplete(() { connection.close(); });
@@ -284,14 +284,14 @@ _htmlHeadersFilter(HttpConnect connect, Future chain(HttpConnect conn)) {
 
 // parse queries param
 _parseQueriesParam(param) {
-  return param.isEmpty ? 1 : int.parse(param, radix: 10, onError: (_) => 1).clamp(1, 500);
+  return (param == null || param.isEmpty) ? 1 : int.parse(param, radix: 10, onError: (_) => 1).clamp(1, 500);
 }
 
 // runs a query and returns a promise
 _query() {
   return _connectionPool.connect().then((connection) {
     return connection
-      .query('SELECT "id", "randomnumber" FROM "World" WHERE id = @id;', { 'id': _RANDOM.nextInt(_WORLD_TABLE_SIZE) + 1 })
+      .query('SELECT id, randomnumber FROM world WHERE id = @id;', { 'id': _RANDOM.nextInt(_WORLD_TABLE_SIZE) + 1 })
       .single
       .then((row) =>new World(row[0], row[1]))
       .whenComplete(() {