v1.1.6 fix: NOAUTH Authentication required.

2881099 · Aug 11, 2023 · a8ec958 · a8ec958
1 parent 0bf7b56
commit a8ec958
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 3 deletions.
diff --git a/src/FreeRedis/FreeRedis.csproj b/src/FreeRedis/FreeRedis.csproj
@@ -5,7 +5,7 @@
 		<AssemblyName>FreeRedis</AssemblyName>
 		<PackageId>FreeRedis</PackageId>
 		<RootNamespace>FreeRedis</RootNamespace>
-		<Version>1.1.5</Version>
+		<Version>1.1.6</Version>
 		<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
 		<PackageProjectUrl>https://github.com/2881099/FreeRedis</PackageProjectUrl>
 		<Description>FreeRedis is .NET redis client, supports cluster, sentinel, master-slave, pipeline, transaction and connection pool.</Description>

diff --git a/src/FreeRedis/Internal/RespHelper.cs b/src/FreeRedis/Internal/RespHelper.cs
@@ -214,7 +214,13 @@ public RedisResult ReadObject(Encoding encoding)
                         case '$': return new RedisResult(ReadBlobString(c, encoding, null, 1024), false, RedisMessageType.BlobString);
                         case '+': return new RedisResult(ReadSimpleString(), false, RedisMessageType.SimpleString);
                         case '=': return new RedisResult(ReadBlobString(c, encoding, null, 1024), false, RedisMessageType.VerbatimString);
-                        case '-': return new RedisResult(ReadSimpleString(), false, RedisMessageType.SimpleError);
+                        case '-':
+                            {
+                                var simpleError = ReadSimpleString();
+                                if (simpleError == "NOAUTH Authentication required.")
+                                    throw new ProtocolViolationException(simpleError);
+                                return new RedisResult(simpleError, false, RedisMessageType.SimpleError);
+                            }
                         case '!': return new RedisResult(ReadBlobString(c, encoding, null, 1024), false, RedisMessageType.BlobError);
                         case ':': return new RedisResult(ReadNumber(c), false, RedisMessageType.Number);
                         case '(': return new RedisResult(ReadBigNumber(c), false, RedisMessageType.BigNumber);

diff --git a/src/FreeRedis/Internal/RespHelperAsync.cs b/src/FreeRedis/Internal/RespHelperAsync.cs
@@ -146,7 +146,13 @@ async public Task<RedisResult> ReadObjectAsync(Encoding encoding)
                         case '$': return new RedisResult(await ReadBlobStringAsync(c, encoding, null, 1024), false, RedisMessageType.BlobString);
                         case '+': return new RedisResult(ReadSimpleString(), false, RedisMessageType.SimpleString);
                         case '=': return new RedisResult(await ReadBlobStringAsync(c, encoding, null, 1024), false, RedisMessageType.VerbatimString);
-                        case '-': return new RedisResult(ReadSimpleString(), false, RedisMessageType.SimpleError);
+                        case '-':
+                            {
+                                var simpleError = ReadSimpleString();
+                                if (simpleError == "NOAUTH Authentication required.")
+                                    throw new ProtocolViolationException(simpleError);
+                                return new RedisResult(simpleError, false, RedisMessageType.SimpleError);
+                            }
                         case '!': return new RedisResult(await ReadBlobStringAsync(c, encoding, null, 1024), false, RedisMessageType.BlobError);
                         case ':': return new RedisResult(ReadNumber(c), false, RedisMessageType.Number);
                         case '(': return new RedisResult(ReadBigNumber(c), false, RedisMessageType.BigNumber);