Function testPluginConnection

cli/cmd/test_connection.go:216–259

(ctx context.Context, client plugin.PluginClient, spec map[string]any)

}

func testPluginConnection(ctx context.Context, client plugin.PluginClient, spec map[string]any) (*testConnectionResult, error) {
	specBytes, err := marshalSpec(spec)
	if err != nil {
		return nil, err
	}

	in := &plugin.TestConnection_Request{
		Spec: specBytes,
	}

	resp, err := client.TestConnection(ctx, in)
	if err != nil {
		if gRPCErr, ok := grpcstatus.FromError(err); ok {
			if gRPCErr.Code() == codes.Unimplemented {
				if !env.IsCloud() {
					return &testConnectionResult{
						Success:            false,
						FailureCode:        "UNIMPLEMENTED",
						FailureDescription: gRPCErr.Message(),
					}, nil
				}
				err := initPlugin(ctx, client, spec, false, invocationUUID.String())
				if err != nil {
					return &testConnectionResult{
						Success:            false,
						FailureCode:        "OTHER",
						FailureDescription: secretAwareRedactor.RedactStr(err.Error()),
					}, nil
				}

				return &testConnectionResult{
					Success: true,
				}, nil
			}
		}
		return nil, err
	}

	return &testConnectionResult{
		Success:            resp.Success,
		FailureCode:        resp.FailureCode,
		FailureDescription: secretAwareRedactor.RedactStr(resp.FailureDescription),
	}, nil
}