Adding the BindComplete message.

Aurynn Shaw · Aurynn Shaw · commit 98cfd120139d · 2010-08-30T21:26:28.000-07:00
Verified node 0.2.0 support.
diff --git a/lib/postgres-pure.js b/lib/postgres-pure.js
@@ -197,85 +197,90 @@ function parse_response(code, buffer) {
       break;
     }
     break;
-  case 'E':
-    type = "ErrorResponse";
-    args = [{}];
-    reader.multicstring().forEach(function (field) {
-      args[0][field[0]] = field.substr(1);
-    });
-    break;
-  case 't':
-    type = "ParameterDescription",
-    num_fields = reader.int16();
-    data = [];
-    for (var i = 0; i < num_fields; i++) {
-        data.push(reader.int32());
-    }
-    args = [data];
-    break;
-  case 'S':
-    type = "ParameterStatus";
-    args = [reader.cstring(), reader.cstring()];
-    break;
-  case 'K':
-    type = "BackendKeyData";
-    args = [reader.int32(), reader.int32()];
-    break;
-  case 'Z':
-    type = "ReadyForQuery";
-    args = [reader.string(1)];
-    break;
-  case 'T':
-    type = "RowDescription";
-    num_fields = reader.int16();
-    data = [];
-    for (var i = 0; i < num_fields; i += 1) {
-        data.push({
-            field: reader.cstring(),
-            table_id: reader.int32(),
-            column_id: reader.int16(),
-            type_id: reader.int32(),
-            type_size: reader.int16(),
-            type_modifier: reader.int32(),
-            format_code: reader.int16()
+    case 'E':
+        type = "ErrorResponse";
+        args = [{}];
+        reader.multicstring().forEach(function (field) {
+          args[0][field[0]] = field.substr(1);
         });
-    }
-    args = [data];
-    break;
-  case 'D':
-    type = "DataRow";
-    data = [];
-    num_fields = reader.int16();
-    for (i = 0; i < num_fields; i += 1) {
-      size = reader.int32();
-      if (size === -1) {
-        data.push(null);
-      } else {
-        data.push(reader.string(size));
-      }
-    }
-    args = [data];
-    break;
-  case 'C':
-    type = "CommandComplete";
-    args = [reader.cstring()];
-    break;
-  case 'N':
-    type = "NoticeResponse";
-    args = [{}];
-    reader.multicstring().forEach(function (field) {
-      args[0][field[0]] = field.substr(1);
-    });
-    break;
-  case '1':
-    type = 'ParseComplete';
-    args = [{}];
-    break;
-  case 'n':
-    type = 'NoData';
-    args = [];
-    break;
+        break;
+    case 't':
+        type = "ParameterDescription",
+        num_fields = reader.int16();
+        data = [];
+        for (var i = 0; i < num_fields; i++) {
+            data.push(reader.int32());
+        }
+        args = [data];
+        break;
+    case 'S':
+        type = "ParameterStatus";
+        args = [reader.cstring(), reader.cstring()];
+        break;
+    case 'K':
+        type = "BackendKeyData";
+        args = [reader.int32(), reader.int32()];
+        break;
+    case 'Z':
+        type = "ReadyForQuery";
+        args = [reader.string(1)];
+        break;
+    case 'T':
+        type = "RowDescription";
+        num_fields = reader.int16();
+        data = [];
+        for (var i = 0; i < num_fields; i += 1) {
+            data.push({
+                field: reader.cstring(),
+                table_id: reader.int32(),
+                column_id: reader.int16(),
+                type_id: reader.int32(),
+                type_size: reader.int16(),
+                type_modifier: reader.int32(),
+                format_code: reader.int16()
+            });
+        }
+        args = [data];
+        break;
+    case 'D':
+        type = "DataRow";
+        data = [];
+        num_fields = reader.int16();
+        for (i = 0; i < num_fields; i += 1) {
+          size = reader.int32();
+          if (size === -1) {
+            data.push(null);
+          } else {
+            data.push(reader.string(size));
+          }
+        }
+        args = [data];
+        break;
+    case 'C':
+        type = "CommandComplete";
+        args = [reader.cstring()];
+        break;
+    case 'N':
+        type = "NoticeResponse";
+        args = [{}];
+        reader.multicstring().forEach(function (field) {
+          args[0][field[0]] = field.substr(1);
+        });
+        break;
+    case '1':
+        type = 'ParseComplete';
+        args = [{}];
+        break;
+    case 'n':
+        type = 'NoData';
+        args = [];
+        break;
+    case '2':
+          type = "BindComplete";
+          args = [{}];
+          break;
   }
+
   
   if (!type) {
       sys.debug("Unknown response " + code);  
