analysis-uplift (#570)

Summary:

- Client driven `async`.
- Better test diagnostics.
- New `anysdk` API.
- `base64` encoding correction.
- Improved `any-sdk`.

Author: general-kroll-4-life

go.mod

@@ -16,7 +16,7 @@ require (
 	github.com/spf13/cobra v1.4.0
 	github.com/spf13/pflag v1.0.5
 	github.com/spf13/viper v1.10.1
-	github.com/stackql/any-sdk v0.2.2-beta01
+	github.com/stackql/any-sdk v0.2.2-beta05
 	github.com/stackql/go-suffix-map v0.0.1-alpha01
 	github.com/stackql/psql-wire v0.1.1-beta23
 	github.com/stackql/stackql-parser v0.0.15-alpha06

go.sum

@@ -461,8 +461,8 @@ github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
 github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
 github.com/spf13/viper v1.10.1 h1:nuJZuYpG7gTj/XqiUwg8bA0cp1+M2mC3J4g5luUYBKk=
 github.com/spf13/viper v1.10.1/go.mod h1:IGlFPqhNAPKRxohIzWpI5QEy4kuI7tcl5WvR+8qy1rU=
-github.com/stackql/any-sdk v0.2.2-beta01 h1:h5VIvulaqujDmFAN0j0KS0VONE3pwARIzPs6EFiM5G0=
-github.com/stackql/any-sdk v0.2.2-beta01/go.mod h1:m1o5TCfyKkdt2bREB3itwPv1MhM+lk4eu24KpPohFoY=
+github.com/stackql/any-sdk v0.2.2-beta05 h1:xUQH2EMgTBFWRbyu6QlKxFzJ3btMtqO+Lc9VkUmYPc4=
+github.com/stackql/any-sdk v0.2.2-beta05/go.mod h1:m1o5TCfyKkdt2bREB3itwPv1MhM+lk4eu24KpPohFoY=
 github.com/stackql/go-suffix-map v0.0.1-alpha01 h1:TDUDS8bySu41Oo9p0eniUeCm43mnRM6zFEd6j6VUaz8=
 github.com/stackql/go-suffix-map v0.0.1-alpha01/go.mod h1:QAi+SKukOyf4dBtWy8UMy+hsXXV+yyEE4vmBkji2V7g=
 github.com/stackql/psql-wire v0.1.1-beta23 h1:1ayYMjZArfDcIMyEOKnm+Bp1zRCISw8pguvTFuUhhVQ=

internal/stackql/drm/drm_cfg.go

@@ -496,11 +496,13 @@ func (dc *staticDRMConfig) obtainAddressSpace(
 }
 
 func (dc *staticDRMConfig) obtainRelationFromAddressSpace(
+	isAwait bool,
 	addressSpace anysdk.AddressSpace,
 	isNilResponseAllowed bool,
 ) (anysdk.Relation, error) {
 	inferredRelation, inferredRelationErr := addressSpace.ToRelation(
 		radix_tree_address_space.NewStandardAddressSpaceExpansionConfig(
+			isAwait,
 			true, // TODO: switch this off at the appropriate time
 			isNilResponseAllowed,
 		))
@@ -541,7 +543,7 @@ func (dc *staticDRMConfig) genRelationalTable(
 			return nil, err
 		}
 	}
-	inferredRelation, inferredRelationErr := dc.obtainRelationFromAddressSpace(addressSpace, isNilResponseAllowed)
+	inferredRelation, inferredRelationErr := dc.obtainRelationFromAddressSpace(isAwait, addressSpace, isNilResponseAllowed)
 	if inferredRelationErr != nil {
 		return nil, inferredRelationErr
 	}
@@ -635,6 +637,7 @@ func (dc *staticDRMConfig) GenerateInsertDML(
 			return nil, addressSpaceErr
 		}
 		inferredRelation, relationErr := dc.obtainRelationFromAddressSpace(
+			isAsync,
 			addressSpace,
 			isNilResponseAllowed,
 		)

internal/stackql/primitivebuilder/generic_http_reversal.go

@@ -133,7 +133,9 @@ func (gh *genericHTTPReversal) Build() error {
 			if !httpPreparatorExists {
 				break
 			}
-			httpArmoury, httpErr := httpPreparator.BuildHTTPRequestCtx()
+			httpArmoury, httpErr := httpPreparator.BuildHTTPRequestCtx(
+				anysdk.NewHTTPPreparatorConfig(false),
+			)
 			if httpErr != nil {
 				return internaldto.NewErroneousExecutorOutput(httpErr)
 			}

internal/stackql/primitivebuilder/generic_http_stream_input.go

@@ -269,7 +269,9 @@ func (gh *genericHTTPStreamInput) Build() error {
 				nil,
 				logging.GetLogger(),
 			)
-			httpArmoury, httpErr := httpPreparator.BuildHTTPRequestCtx()
+			httpArmoury, httpErr := httpPreparator.BuildHTTPRequestCtx(
+				anysdk.NewHTTPPreparatorConfig(false),
+			)
 			if httpErr != nil {
 				return internaldto.NewErroneousExecutorOutput(httpErr)
 			}

internal/stackql/primitivegenerator/statement_analyzer.go

@@ -1018,7 +1018,9 @@ func (pb *standardPrimitiveGenerator) buildRequestContextFromMapArray(
 				execContext,
 				logging.GetLogger(),
 			)
-			httpArmoury, httpErr := httpPreparator.BuildHTTPRequestCtx()
+			httpArmoury, httpErr := httpPreparator.BuildHTTPRequestCtx(
+				anysdk.NewHTTPPreparatorConfig(false),
+			)
 			if httpErr != nil {
 				return nil, httpErr
 			}

internal/stackql/primitivegenerator/unary_selection.go

@@ -208,6 +208,7 @@ func (pb *standardPrimitiveGenerator) analyzeUnarySelection(
 		}
 		inferredRelation, inferredRelationErr := addressSpace.ToRelation(
 			radix_tree_address_space.NewStandardAddressSpaceExpansionConfig(
+				methodAnalysisOutput.IsAwait(),
 				true, // TODO: switch this off at the appropriate time
 				false,
 			))

internal/stackql/psqlwire/server.go

@@ -64,9 +64,9 @@ func MakeWireServer(sbe sqlbackend.SQLBackendFactory, cfg dto.RuntimeCtx) (IWire
 			cp = x509.NewCertPool()
 			for _, pemStr := range tlsCfg.ClientCAs {
 				var b []byte
-				b, err = base64.RawStdEncoding.DecodeString(pemStr)
+				b, err = base64.StdEncoding.DecodeString(pemStr)
 				if err != nil {
-					return nil, err
+					return nil, fmt.Errorf("failed to decode Client CA PEM: %w, with string '%s'", err, pemStr)
 				}
 				ok := cp.AppendCertsFromPEM(b)
 				if !ok {

internal/stackql/taxonomy/annotation_context.go

@@ -179,7 +179,9 @@ func (ac *standardAnnotationCtx) Prepare(
 					nil,
 					logging.GetLogger(),
 				)
-				httpArmoury, armouryErr := httpPreparator.BuildHTTPRequestCtxFromAnnotation()
+				httpArmoury, armouryErr := httpPreparator.BuildHTTPRequestCtx(
+					anysdk.NewHTTPPreparatorConfig(true),
+				)
 				return httpArmoury, armouryErr
 			},
 		)
@@ -211,7 +213,9 @@ func (ac *standardAnnotationCtx) Prepare(
 				nil,
 				logging.GetLogger(),
 			)
-			httpArmoury, armouryErr := httpPreparator.BuildHTTPRequestCtxFromAnnotation()
+			httpArmoury, armouryErr := httpPreparator.BuildHTTPRequestCtx(
+				anysdk.NewHTTPPreparatorConfig(true),
+			)
 			if armouryErr != nil {
 				return nil, armouryErr
 			}