No encryption offlaod support

cmd/yproxy/main.go

@@ -27,7 +27,9 @@ var rootCmd = &cobra.Command{
 
 		instance := core.NewInstance()
 
-		ylogger.ReloadLogger(instanceCnf.LogPath)
+		if instanceCnf.LogPath != "" {
+			ylogger.ReloadLogger(instanceCnf.LogPath)
+		}
 		if logLevel == "" {
 			logLevel = instanceCnf.LogLevel
 		}

pkg/core/core.go

@@ -104,8 +104,11 @@ func (i *Instance) Run(instanceCnf *config.Instance) error {
 		&instanceCnf.StorageCnf,
 	)
 
-	cr, err := crypt.NewCrypto(&instanceCnf.CryptoCnf)
-
+	var cr crypt.Crypter = nil
+	if instanceCnf.CryptoCnf.GPGKeyPath != "" {
+		cr, err = crypt.NewCrypto(&instanceCnf.CryptoCnf)
+	}
+
 	if err != nil {
 		return err
 	}

pkg/proc/interaction.go

@@ -46,6 +46,11 @@ func ProcConn(s storage.StorageInteractor, cr crypt.Crypter, ycl client.YproxyCl
 		defer yr.Close()
 
 		if msg.Decrypt {
+			if cr == nil {
+				_ = ycl.ReplyError(err, "failed to decrypt object, decrypter not configured")
+				ycl.Close()
+				return nil
+			}
 			ylogger.Zero.Debug().Str("object-path", msg.Name).Msg("decrypt object")
 			contentReader, err = cr.Decrypt(yr)
 			if err != nil {
@@ -83,6 +88,12 @@ func ProcConn(s storage.StorageInteractor, cr crypt.Crypter, ycl client.YproxyCl
 
 			var ww io.WriteCloser = w
 			if msg.Encrypt {
+				if cr == nil {
+					_ = ycl.ReplyError(err, "failed to encrypt, crypter not configured")
+					ycl.Close()
+					return
+				}
+
 				var err error
 				ww, err = cr.Encrypt(w)
 				if err != nil {
@@ -91,6 +102,8 @@ func ProcConn(s storage.StorageInteractor, cr crypt.Crypter, ycl client.YproxyCl
 					ycl.Close()
 					return
 				}
+			} else {
+				ylogger.Zero.Debug().Str("path", msg.Name).Msg("omit encryption for chunk")
 			}
 
 			defer w.Close()

pkg/proc/yrreader.go

@@ -22,7 +22,10 @@ type YRestartReader struct {
 
 // Close implements RestartReader.
 func (y *YRestartReader) Close() error {
-	return y.underlying.Close()
+	if y.underlying != nil {
+		return y.underlying.Close()
+	}
+	return nil
 }
 
 // Read implements RestartReader.