Handle remaining/unhandled postgresql wire message types from server

sumeetchhetri · sumeetchhetri · commit 0a67b4cab55e · 2024-07-14T19:43:53.000+05:30
[docker_verify][skip_build]
diff --git a/src/modules/sdorm/sql/libpq/LibpqDataSourceImpl.cpp b/src/modules/sdorm/sql/libpq/LibpqDataSourceImpl.cpp
@@ -2310,6 +2310,10 @@ int FpgWire::handleResponse() {
 		}
 		default:
 			cmd = '\0';
+			if(!isMessageReady(ml)) {
+				return -1;
+			}
+			pos += (ml - 4);
 			break;
 	}
 	//std::cout << "buffer.size " << buffer.length() << " pos " << pos << std::endl;

Original file line number	Diff line number	Diff line change
`@@ -2310,6 +2310,10 @@ int FpgWire::handleResponse() {`
`2310`	`2310`	`}`
`2311`	`2311`	`default:`
`2312`	`2312`	`cmd = '\0';`
	`2313`	`+ if(!isMessageReady(ml)) {`
	`2314`	`+ return -1;`
	`2315`	`+ }`
	`2316`	`+ pos += (ml - 4);`
`2313`	`2317`	`break;`
`2314`	`2318`	`}`
`2315`	`2319`	`//std::cout << "buffer.size " << buffer.length() << " pos " << pos << std::endl;`