Merge pull request #178 from kerberos-io/fix/secondary-vault-initialization

Fix/Add kstorage_secondary configuration field and initialize in environment vars

README.md

@@ -190,68 +190,73 @@ Next to attaching the configuration file, it is also possible to override the co
 
 | Name                                    | Description                                                                                     | Default Value                  |
 | --------------------------------------- | ----------------------------------------------------------------------------------------------- | ------------------------------ |
-| `LOG_LEVEL`                             | Level for logging, could be "info", "warning", "debug", "error" or "fatal".                     | "info"                         |
-| `LOG_OUTPUT`                            | Logging output format "json" or "text".                                                         | "text"                         |
-| `AGENT_MODE`                            | You can choose to run this in 'release' for production, and or 'demo' for showcasing.           | "release"                      |
-| `AGENT_TLS_INSECURE`                    | Specify if you want to use `InsecureSkipVerify` for the internal HTTP client.                   | "false"                        |
-| `AGENT_USERNAME`                        | The username used to authenticate against the Kerberos Agent login page.                        | "root"                         |
-| `AGENT_PASSWORD`                        | The password used to authenticate against the Kerberos Agent login page.                        | "root"                         |
-| `AGENT_KEY`                             | A unique identifier for your Kerberos Agent, this is auto-generated but can be overriden.       | ""                             |
-| `AGENT_NAME`                            | The agent friendly-name.                                                                        | "agent"                        |
-| `AGENT_TIMEZONE`                        | Timezone which is used for converting time.                                                     | "Africa/Ceuta"                 |
-| `AGENT_REMOVE_AFTER_UPLOAD`             | When enabled, recordings uploaded successfully to a storage will be removed from disk.          | "true"                         |
-| `AGENT_OFFLINE`                         | Makes sure no external connection is made.                                                      | "false"                        |
-| `AGENT_AUTO_CLEAN`                      | Cleans up the recordings directory.                                                             | "true"                         |
-| `AGENT_AUTO_CLEAN_MAX_SIZE`             | If `AUTO_CLEAN` enabled, set the max size of the recordings directory (in MB).                  | "100"                          |
-| `AGENT_TIME`                            | Enable the timetable for Kerberos Agent                                                         | "false"                        |
-| `AGENT_TIMETABLE`                       | A (weekly) time table to specify when to make recordings "start1,end1,start2,end2;start1..      | ""                             |
-| `AGENT_REGION_POLYGON`                  | A single polygon set for motion detection: "x1,y1;x2,y2;x3,y3;...                               | ""                             |
-| `AGENT_CAPTURE_IPCAMERA_RTSP`           | Full-HD RTSP endpoint to the camera you're targetting.                                          | ""                             |
-| `AGENT_CAPTURE_IPCAMERA_SUB_RTSP`       | Sub-stream RTSP endpoint used for livestreaming (WebRTC).                                       | ""                             |
-| `AGENT_CAPTURE_IPCAMERA_ONVIF`          | Mark as a compliant ONVIF device.                                                               | ""                             |
-| `AGENT_CAPTURE_IPCAMERA_ONVIF_XADDR`    | ONVIF endpoint/address running on the camera.                                                   | ""                             |
-| `AGENT_CAPTURE_IPCAMERA_ONVIF_USERNAME` | ONVIF username to authenticate against.                                                         | ""                             |
-| `AGENT_CAPTURE_IPCAMERA_ONVIF_PASSWORD` | ONVIF password to authenticate against.                                                         | ""                             |
-| `AGENT_CAPTURE_MOTION`                  | Toggle for enabling or disabling motion.                                                        | "true"                         |
-| `AGENT_CAPTURE_LIVEVIEW`                | Toggle for enabling or disabling liveview.                                                      | "true"                         |
-| `AGENT_CAPTURE_SNAPSHOTS`               | Toggle for enabling or disabling snapshot generation.                                           | "true"                         |
-| `AGENT_CAPTURE_RECORDING`               | Toggle for enabling making recordings.                                                          | "true"                         |
-| `AGENT_CAPTURE_CONTINUOUS`              | Toggle for enabling continuous "true" or motion "false".                                        | "false"                        |
-| `AGENT_CAPTURE_PRERECORDING`            | If `CONTINUOUS` set to `false`, specify the recording time (seconds) before/after motion event. | "10"                           |
-| `AGENT_CAPTURE_POSTRECORDING`           | If `CONTINUOUS` set to `false`, specify the recording time (seconds) after motion event.        | "20"                           |
-| `AGENT_CAPTURE_MAXLENGTH`               | The maximum length of a single recording (seconds).                                             | "30"                           |
-| `AGENT_CAPTURE_PIXEL_CHANGE`            | If `CONTINUOUS` set to `false`, the number of pixel require to change before motion triggers.   | "150"                          |
-| `AGENT_CAPTURE_FRAGMENTED`              | Set the format of the recorded MP4 to fragmented (suitable for HLS).                            | "false"                        |
-| `AGENT_CAPTURE_FRAGMENTED_DURATION`     | If `AGENT_CAPTURE_FRAGMENTED` set to `true`, define the duration (seconds) of a fragment.       | "8"                            |
-| `AGENT_MQTT_URI`                        | An MQTT broker endpoint that is used for bi-directional communication (live view, onvif, etc)   | "tcp://mqtt.kerberos.io:1883"  |
-| `AGENT_MQTT_USERNAME`                   | Username of the MQTT broker.                                                                    | ""                             |
-| `AGENT_MQTT_PASSWORD`                   | Password of the MQTT broker.                                                                    | ""                             |
-| `AGENT_REALTIME_PROCESSING`             | If `AGENT_REALTIME_PROCESSING` set to `true`, the agent will send key frames to the topic       | ""                             |
-| `AGENT_REALTIME_PROCESSING_TOPIC`       | The topic to which keyframes will be sent in base64 encoded format.                             | ""                             |
-| `AGENT_STUN_URI`                        | When using WebRTC, you'll need to provide a STUN server.                                        | "stun:turn.kerberos.io:8443"   |
-| `AGENT_FORCE_TURN`                      | Force using a TURN server, by generating relay candidates only.                                 | "false"                        |
-| `AGENT_TURN_URI`                        | When using WebRTC, you'll need to provide a TURN server.                                        | "turn:turn.kerberos.io:8443"   |
-| `AGENT_TURN_USERNAME`                   | TURN username used for WebRTC.                                                                  | "username1"                    |
-| `AGENT_TURN_PASSWORD`                   | TURN password used for WebRTC.                                                                  | "password1"                    |
-| `AGENT_CLOUD`                           | Store recordings in Kerberos Hub (s3), Kerberos Vault (kstorage), or Dropbox (dropbox).         | "s3"                           |
-| `AGENT_HUB_ENCRYPTION`                  | Turning on/off encryption of traffic from your Kerberos Agent to Kerberos Hub.                  | "true"                         |
-| `AGENT_HUB_URI`                         | The Kerberos Hub API, defaults to our Kerberos Hub SAAS.                                        | "https://api.hub.domain.com"   |
-| `AGENT_HUB_KEY`                         | The access key linked to your account in Kerberos Hub.                                          | ""                             |
-| `AGENT_HUB_PRIVATE_KEY`                 | The secret access key linked to your account in Kerberos Hub.                                   | ""                             |
-| `AGENT_HUB_REGION`                      | The Kerberos Hub region, to which you want to upload.                                           | ""                             |
-| `AGENT_HUB_SITE`                        | The site ID of a site you've created in your Kerberos Hub account.                              | ""                             |
-| `AGENT_KERBEROSVAULT_URI`               | The Kerberos Vault API url.                                                                     | "https://vault.domain.com/api" |
-| `AGENT_KERBEROSVAULT_ACCESS_KEY`        | The access key of a Kerberos Vault account.                                                     | ""                             |
-| `AGENT_KERBEROSVAULT_SECRET_KEY`        | The secret key of a Kerberos Vault account.                                                     | ""                             |
-| `AGENT_KERBEROSVAULT_PROVIDER`          | A Kerberos Vault provider you have created (optional).                                          | ""                             |
-| `AGENT_KERBEROSVAULT_DIRECTORY`         | The directory, in the Kerberos vault, where the recordings will be stored.                      | ""                             |
-| `AGENT_DROPBOX_ACCESS_TOKEN`            | The Access Token from your Dropbox app, that is used to leverage the Dropbox SDK.               | ""                             |
-| `AGENT_DROPBOX_DIRECTORY`               | The directory, in Dropbox, where the recordings will be stored.                                 | ""                             |
-| `AGENT_ENCRYPTION`                      | Enable 'true' or disable 'false' end-to-end encryption for MQTT messages.                       | "false"                        |
-| `AGENT_ENCRYPTION_RECORDINGS`           | Enable 'true' or disable 'false' end-to-end encryption for recordings.                          | "false"                        |
-| `AGENT_ENCRYPTION_FINGERPRINT`          | The fingerprint of the keypair (public/private keys), so you know which one to use.             | ""                             |
-| `AGENT_ENCRYPTION_PRIVATE_KEY`          | The private key (assymetric/RSA) to decrypt and sign requests send over MQTT.                   | ""                             |
-| `AGENT_ENCRYPTION_SYMMETRIC_KEY`        | The symmetric key (AES) to encrypt and decrypt requests sent over MQTT.                         | ""                             |
+| `LOG_LEVEL`                                 | Level for logging, could be "info", "warning", "debug", "error" or "fatal".                     | "info"                         |
+| `LOG_OUTPUT`                                | Logging output format "json" or "text".                                                         | "text"                         |
+| `AGENT_MODE`                                | You can choose to run this in 'release' for production, and or 'demo' for showcasing.           | "release"                      |
+| `AGENT_TLS_INSECURE`                        | Specify if you want to use `InsecureSkipVerify` for the internal HTTP client.                   | "false"                        |
+| `AGENT_USERNAME`                            | The username used to authenticate against the Kerberos Agent login page.                        | "root"                         |
+| `AGENT_PASSWORD`                            | The password used to authenticate against the Kerberos Agent login page.                        | "root"                         |
+| `AGENT_KEY`                                 | A unique identifier for your Kerberos Agent, this is auto-generated but can be overriden.       | ""                             |
+| `AGENT_NAME`                                | The agent friendly-name.                                                                        | "agent"                        |
+| `AGENT_TIMEZONE`                            | Timezone which is used for converting time.                                                     | "Africa/Ceuta"                 |
+| `AGENT_REMOVE_AFTER_UPLOAD`                 | When enabled, recordings uploaded successfully to a storage will be removed from disk.          | "true"                         |
+| `AGENT_OFFLINE`                             | Makes sure no external connection is made.                                                      | "false"                        |
+| `AGENT_AUTO_CLEAN`                          | Cleans up the recordings directory.                                                             | "true"                         |
+| `AGENT_AUTO_CLEAN_MAX_SIZE`                 | If `AUTO_CLEAN` enabled, set the max size of the recordings directory (in MB).                  | "100"                          |
+| `AGENT_TIME`                                | Enable the timetable for Kerberos Agent                                                         | "false"                        |
+| `AGENT_TIMETABLE`                           | A (weekly) time table to specify when to make recordings "start1,end1,start2,end2;start1..      | ""                             |
+| `AGENT_REGION_POLYGON`                      | A single polygon set for motion detection: "x1,y1;x2,y2;x3,y3;...                               | ""                             |
+| `AGENT_CAPTURE_IPCAMERA_RTSP`               | Full-HD RTSP endpoint to the camera you're targetting.                                          | ""                             |
+| `AGENT_CAPTURE_IPCAMERA_SUB_RTSP`           | Sub-stream RTSP endpoint used for livestreaming (WebRTC).                                       | ""                             |
+| `AGENT_CAPTURE_IPCAMERA_ONVIF`              | Mark as a compliant ONVIF device.                                                               | ""                             |
+| `AGENT_CAPTURE_IPCAMERA_ONVIF_XADDR`        | ONVIF endpoint/address running on the camera.                                                   | ""                             |
+| `AGENT_CAPTURE_IPCAMERA_ONVIF_USERNAME`     | ONVIF username to authenticate against.                                                         | ""                             |
+| `AGENT_CAPTURE_IPCAMERA_ONVIF_PASSWORD`     | ONVIF password to authenticate against.                                                         | ""                             |
+| `AGENT_CAPTURE_MOTION`                      | Toggle for enabling or disabling motion.                                                        | "true"                         |
+| `AGENT_CAPTURE_LIVEVIEW`                    | Toggle for enabling or disabling liveview.                                                      | "true"                         |
+| `AGENT_CAPTURE_SNAPSHOTS`                   | Toggle for enabling or disabling snapshot generation.                                           | "true"                         |
+| `AGENT_CAPTURE_RECORDING`                   | Toggle for enabling making recordings.                                                          | "true"                         |
+| `AGENT_CAPTURE_CONTINUOUS`                  | Toggle for enabling continuous "true" or motion "false".                                        | "false"                        |
+| `AGENT_CAPTURE_PRERECORDING`                | If `CONTINUOUS` set to `false`, specify the recording time (seconds) before/after motion event. | "10"                           |
+| `AGENT_CAPTURE_POSTRECORDING`               | If `CONTINUOUS` set to `false`, specify the recording time (seconds) after motion event.        | "20"                           |
+| `AGENT_CAPTURE_MAXLENGTH`                   | The maximum length of a single recording (seconds).                                             | "30"                           |
+| `AGENT_CAPTURE_PIXEL_CHANGE`                | If `CONTINUOUS` set to `false`, the number of pixel require to change before motion triggers.   | "150"                          |
+| `AGENT_CAPTURE_FRAGMENTED`                  | Set the format of the recorded MP4 to fragmented (suitable for HLS).                            | "false"                        |
+| `AGENT_CAPTURE_FRAGMENTED_DURATION`         | If `AGENT_CAPTURE_FRAGMENTED` set to `true`, define the duration (seconds) of a fragment.       | "8"                            |
+| `AGENT_MQTT_URI`                            | An MQTT broker endpoint that is used for bi-directional communication (live view, onvif, etc)   | "tcp://mqtt.kerberos.io:1883"  |
+| `AGENT_MQTT_USERNAME`                       | Username of the MQTT broker.                                                                    | ""                             |
+| `AGENT_MQTT_PASSWORD`                       | Password of the MQTT broker.                                                                    | ""                             |
+| `AGENT_REALTIME_PROCESSING`                 | If `AGENT_REALTIME_PROCESSING` set to `true`, the agent will send key frames to the topic       | ""                             |
+| `AGENT_REALTIME_PROCESSING_TOPIC`           | The topic to which keyframes will be sent in base64 encoded format.                             | ""                             |
+| `AGENT_STUN_URI`                            | When using WebRTC, you'll need to provide a STUN server.                                        | "stun:turn.kerberos.io:8443"   |
+| `AGENT_FORCE_TURN`                          | Force using a TURN server, by generating relay candidates only.                                 | "false"                        |
+| `AGENT_TURN_URI`                            | When using WebRTC, you'll need to provide a TURN server.                                        | "turn:turn.kerberos.io:8443"   |
+| `AGENT_TURN_USERNAME`                       | TURN username used for WebRTC.                                                                  | "username1"                    |
+| `AGENT_TURN_PASSWORD`                       | TURN password used for WebRTC.                                                                  | "password1"                    |
+| `AGENT_CLOUD`                               | Store recordings in Kerberos Hub (s3), Kerberos Vault (kstorage), or Dropbox (dropbox).         | "s3"                           |
+| `AGENT_HUB_ENCRYPTION`                      | Turning on/off encryption of traffic from your Kerberos Agent to Kerberos Hub.                  | "true"                         |
+| `AGENT_HUB_URI`                             | The Kerberos Hub API, defaults to our Kerberos Hub SAAS.                                        | "https://api.hub.domain.com"   |
+| `AGENT_HUB_KEY`                             | The access key linked to your account in Kerberos Hub.                                          | ""                             |
+| `AGENT_HUB_PRIVATE_KEY`                     | The secret access key linked to your account in Kerberos Hub.                                   | ""                             |
+| `AGENT_HUB_REGION`                          | The Kerberos Hub region, to which you want to upload.                                           | ""                             |
+| `AGENT_HUB_SITE`                            | The site ID of a site you've created in your Kerberos Hub account.                              | ""                             |
+| `AGENT_KERBEROSVAULT_URI`                   | The Kerberos Vault API url.                                                                     | "https://vault.domain.com/api" |
+| `AGENT_KERBEROSVAULT_ACCESS_KEY`            | The access key of a Kerberos Vault account.                                                     | ""                             |
+| `AGENT_KERBEROSVAULT_SECRET_KEY`            | The secret key of a Kerberos Vault account.                                                     | ""                             |
+| `AGENT_KERBEROSVAULT_PROVIDER`              | A Kerberos Vault provider you have created (optional).                                          | ""                             |
+| `AGENT_KERBEROSVAULT_DIRECTORY`             | The directory, in the Kerberos vault, where the recordings will be stored.                      | ""                             |
+| `AGENT_KERBEROSVAULT_SECONDARY_URI`         | The Kerberos Vault API url.                                                                     | "https://vault.domain.com/api" |
+| `AGENT_KERBEROSVAULT_SECONDARY_ACCESS_KEY`  | The access key of a secondary Kerberos Vault account.                                           | ""                             |
+| `AGENT_KERBEROSVAULT_SECONDARY_SECRET_KEY`  | The secret key of a secondary Kerberos Vault account.                                           | ""                             |
+| `AGENT_KERBEROSVAULT_SECONDARY_PROVIDER`    | A secondary Kerberos Vault provider you have created (optional).                                | ""                             |
+| `AGENT_KERBEROSVAULT_SECONDARY_DIRECTORY`   | The directory, in the secondary Kerberos vault, where the recordings will be stored.            | ""                             |
+| `AGENT_DROPBOX_ACCESS_TOKEN`                | The Access Token from your Dropbox app, that is used to leverage the Dropbox SDK.               | ""                             |
+| `AGENT_DROPBOX_DIRECTORY`                   | The directory, in Dropbox, where the recordings will be stored.                                 | ""                             |
+| `AGENT_ENCRYPTION`                          | Enable 'true' or disable 'false' end-to-end encryption for MQTT messages.                       | "false"                        |
+| `AGENT_ENCRYPTION_RECORDINGS`               | Enable 'true' or disable 'false' end-to-end encryption for recordings.                          | "false"                        |
+| `AGENT_ENCRYPTION_FINGERPRINT`              | The fingerprint of the keypair (public/private keys), so you know which one to use.             | ""                             |
+| `AGENT_ENCRYPTION_PRIVATE_KEY`              | The private key (assymetric/RSA) to decrypt and sign requests send over MQTT.                   | ""                             |
+| `AGENT_ENCRYPTION_SYMMETRIC_KEY`            | The symmetric key (AES) to encrypt and decrypt requests sent over MQTT.                         | ""                             |
 
 ## Encryption
 

machinery/data/config/config.json

@@ -98,6 +98,7 @@
 		"region": "eu-west-1"
 	},
 	"kstorage": {},
+	"kstorage_secondary": {},
 	"dropbox": {},
 	"mqtturi": "tcp://mqtt.kerberos.io:1883",
 	"mqtt_username": "",

machinery/src/cloud/Cloud.go

@@ -1162,3 +1162,184 @@ func VerifyPersistence(c *gin.Context, configDirectory string) {
 		})
 	}
 }
+
+// VerifySecondaryPersistence godoc
+// @Router /api/persistence/secondary/verify [post]
+// @ID verify-persistence
+// @Security Bearer
+// @securityDefinitions.apikey Bearer
+// @in header
+// @name Authorization
+// @Tags persistence
+// @Param config body models.Config true "Config"
+// @Summary Will verify the secondary persistence.
+// @Description Will verify the secondary persistence.
+// @Success 200 {object} models.APIResponse
+func VerifySecondaryPersistence(c *gin.Context, configDirectory string) {
+
+	var config models.Config
+	err := c.BindJSON(&config)
+	if err != nil || config.Cloud != "" {
+
+		if config.Cloud == "kstorage" || config.Cloud == "kerberosvault" {
+
+			if config.KStorageSecondary == nil {
+				msg := "cloud.VerifySecondaryPersistence(kerberosvault): please fill-in the required Kerberos Vault credentials."
+				log.Log.Error(msg)
+				c.JSON(400, models.APIResponse{
+					Data: msg,
+				})
+
+			} else {
+
+				uri := config.KStorageSecondary.URI
+				accessKey := config.KStorageSecondary.AccessKey
+				secretAccessKey := config.KStorageSecondary.SecretAccessKey
+				directory := config.KStorageSecondary.Directory
+				provider := config.KStorageSecondary.Provider
+
+				if err == nil && uri != "" && accessKey != "" && secretAccessKey != "" {
+
+					var client *http.Client
+					if os.Getenv("AGENT_TLS_INSECURE") == "true" {
+						tr := &http.Transport{
+							TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
+						}
+						client = &http.Client{Transport: tr}
+					} else {
+						client = &http.Client{}
+					}
+
+					req, err := http.NewRequest("POST", uri+"/ping", nil)
+					if err == nil {
+						req.Header.Add("X-Kerberos-Storage-AccessKey", accessKey)
+						req.Header.Add("X-Kerberos-Storage-SecretAccessKey", secretAccessKey)
+						resp, err := client.Do(req)
+
+						if err == nil {
+							body, err := io.ReadAll(resp.Body)
+							defer resp.Body.Close()
+							if err == nil && resp.StatusCode == http.StatusOK {
+
+								if provider != "" || directory != "" {
+
+									// Generate a random name.
+									timestamp := time.Now().Unix()
+									fileName := strconv.FormatInt(timestamp, 10) +
+										"_6-967003_" + config.Name + "_200-200-400-400_24_769.mp4"
+
+									// Open test-480p.mp4
+									file, err := os.Open(configDirectory + "/data/test-480p.mp4")
+									if err != nil {
+										msg := "cloud.VerifyPersistence(kerberosvault): error reading test-480p.mp4: " + err.Error()
+										log.Log.Error(msg)
+										c.JSON(400, models.APIResponse{
+											Data: msg,
+										})
+									}
+									defer file.Close()
+
+									req, err := http.NewRequest("POST", uri+"/storage", file)
+									if err == nil {
+
+										req.Header.Set("Content-Type", "video/mp4")
+										req.Header.Set("X-Kerberos-Storage-CloudKey", config.HubKey)
+										req.Header.Set("X-Kerberos-Storage-AccessKey", accessKey)
+										req.Header.Set("X-Kerberos-Storage-SecretAccessKey", secretAccessKey)
+										req.Header.Set("X-Kerberos-Storage-Provider", provider)
+										req.Header.Set("X-Kerberos-Storage-FileName", fileName)
+										req.Header.Set("X-Kerberos-Storage-Device", config.Key)
+										req.Header.Set("X-Kerberos-Storage-Capture", "IPCamera")
+										req.Header.Set("X-Kerberos-Storage-Directory", directory)
+
+										var client *http.Client
+										if os.Getenv("AGENT_TLS_INSECURE") == "true" {
+											tr := &http.Transport{
+												TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
+											}
+											client = &http.Client{Transport: tr}
+										} else {
+											client = &http.Client{}
+										}
+
+										resp, err := client.Do(req)
+
+										if err == nil {
+											if resp != nil {
+												body, err := io.ReadAll(resp.Body)
+												defer resp.Body.Close()
+												if err == nil {
+													if resp.StatusCode == 200 {
+														msg := "cloud.VerifySecondaryPersistence(kerberosvault): Upload allowed using the credentials provided (" + accessKey + ", " + secretAccessKey + ")"
+														log.Log.Info(msg)
+														c.JSON(200, models.APIResponse{
+															Data: body,
+														})
+													} else {
+														msg := "cloud.VerifySecondaryPersistence(kerberosvault): Something went wrong while verifying your persistence settings. Make sure your provider is the same as the storage provider in your Kerberos Vault, and the relevant storage provider is configured properly."
+														log.Log.Error(msg)
+														c.JSON(400, models.APIResponse{
+															Data: msg,
+														})
+													}
+												}
+											}
+										} else {
+											msg := "cloud.VerifySecondaryPersistence(kerberosvault): Upload of fake recording failed: " + err.Error()
+											log.Log.Error(msg)
+											c.JSON(400, models.APIResponse{
+												Data: msg,
+											})
+										}
+									} else {
+										msg := "cloud.VerifySecondaryPersistence(kerberosvault): Something went wrong while creating /storage POST request." + err.Error()
+										log.Log.Error(msg)
+										c.JSON(400, models.APIResponse{
+											Data: msg,
+										})
+									}
+								} else {
+									msg := "cloud.VerifySecondaryPersistence(kerberosvault): Provider and/or directory is missing from the request."
+									log.Log.Error(msg)
+									c.JSON(400, models.APIResponse{
+										Data: msg,
+									})
+								}
+							} else {
+								msg := "cloud.VerifySecondaryPersistence(kerberosvault): Something went wrong while verifying storage credentials: " + string(body)
+								log.Log.Error(msg)
+								c.JSON(400, models.APIResponse{
+									Data: msg,
+								})
+							}
+						} else {
+							msg := "cloud.VerifySecondaryPersistence(kerberosvault): Something went wrong while verifying storage credentials:" + err.Error()
+							log.Log.Error(msg)
+							c.JSON(400, models.APIResponse{
+								Data: msg,
+							})
+						}
+					} else {
+						msg := "cloud.VerifySecondaryPersistence(kerberosvault): Something went wrong while verifying storage credentials:" + err.Error()
+						log.Log.Error(msg)
+						c.JSON(400, models.APIResponse{
+							Data: msg,
+						})
+					}
+				} else {
+					msg := "cloud.VerifySecondaryPersistence(kerberosvault): please fill-in the required Kerberos Vault credentials."
+					log.Log.Error(msg)
+					c.JSON(400, models.APIResponse{
+						Data: msg,
+					})
+				}
+			}
+		}
+	} else {
+		msg := "cloud.VerifySecondaryPersistence(): No persistence was specified, so do not know what to verify:" + err.Error()
+		log.Log.Error(msg)
+		c.JSON(400, models.APIResponse{
+			Data: msg,
+		})
+	}
+}

machinery/src/cloud/kerberos_vault.go

@@ -48,7 +48,6 @@ func UploadKerberosVault(configuration *models.Configuration, fileName string) (
 	}
 
 	publicKey := config.KStorage.CloudKey
-	// This is the new way ;)
 	if config.HubKey != "" {
 		publicKey = config.HubKey
 	}
@@ -93,13 +92,78 @@ func UploadKerberosVault(configuration *models.Configuration, fileName string) (
 					return true, true, nil
 				} else {
 					log.Log.Info("UploadKerberosVault: Upload Failed, " + resp.Status + ", " + string(body))
-					return false, true, nil
+				}
+			}
+		}
+	} else {
+		log.Log.Info("UploadKerberosVault: Upload Failed, " + err.Error())
+	}
+
+	// We might need to check if we can upload to our secondary storage.
+
+	if config.KStorageSecondary.AccessKey == "" ||
+		config.KStorageSecondary.SecretAccessKey == "" ||
+		config.KStorageSecondary.Directory == "" ||
+		config.KStorageSecondary.URI == "" {
+		log.Log.Info("UploadKerberosVault: Secondary Kerberos Vault not properly configured.")
+	} else {
+		log.Log.Info("UploadKerberosVault: Uploading to Secondary Kerberos Vault (" + config.KStorageSecondary.URI + ")")
+
+		file, err = os.OpenFile(fullname, os.O_RDWR, 0755)
+		if file != nil {
+			defer file.Close()
+		}
+		if err != nil {
+			err := "UploadKerberosVault: Upload Failed, file doesn't exists anymore."
+			log.Log.Info(err)
+			return false, false, errors.New(err)
+		}
+
+		req, err := http.NewRequest("POST", config.KStorageSecondary.URI+"/storage", file)
+		if err != nil {
+			errorMessage := "UploadKerberosVault: error reading request, " + config.KStorageSecondary.URI + "/storage: " + err.Error()
+			log.Log.Error(errorMessage)
+			return false, true, errors.New(errorMessage)
+		}
+		req.Header.Set("Content-Type", "video/mp4")
+		req.Header.Set("X-Kerberos-Storage-CloudKey", publicKey)
+		req.Header.Set("X-Kerberos-Storage-AccessKey", config.KStorageSecondary.AccessKey)
+		req.Header.Set("X-Kerberos-Storage-SecretAccessKey", config.KStorageSecondary.SecretAccessKey)
+		req.Header.Set("X-Kerberos-Storage-Provider", config.KStorageSecondary.Provider)
+		req.Header.Set("X-Kerberos-Storage-FileName", fileName)
+		req.Header.Set("X-Kerberos-Storage-Device", config.Key)
+		req.Header.Set("X-Kerberos-Storage-Capture", "IPCamera")
+		req.Header.Set("X-Kerberos-Storage-Directory", config.KStorageSecondary.Directory)
+
+		var client *http.Client
+		if os.Getenv("AGENT_TLS_INSECURE") == "true" {
+			tr := &http.Transport{
+				TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
+			}
+			client = &http.Client{Transport: tr}
+		} else {
+			client = &http.Client{}
+		}
+
+		resp, err := client.Do(req)
+		if resp != nil {
+			defer resp.Body.Close()
+		}
+
+		if err == nil {
+			if resp != nil {
+				body, err := ioutil.ReadAll(resp.Body)
+				if err == nil {
+					if resp.StatusCode == 200 {
+						log.Log.Info("UploadKerberosVault: Upload Finished to secondary, " + resp.Status + ", " + string(body))
+						return true, true, nil
+					} else {
+						log.Log.Info("UploadKerberosVault: Upload Failed to secondary, " + resp.Status + ", " + string(body))
+					}
 				}
 			}
 		}
 	}
 
-	errorMessage := "UploadKerberosVault: Upload Failed, " + err.Error()
-	log.Log.Info(errorMessage)
-	return false, true, errors.New(errorMessage)
+	return false, true, nil
 }

machinery/src/components/Kerberos.go

@@ -254,7 +254,7 @@ func RunAgent(configDirectory string, configuration *models.Configuration, commu
 	}
 
 	// Handle livestream HD (high resolution over WEBRTC)
-	communication.HandleLiveHDHandshake = make(chan models.RequestHDStreamPayload, 1)
+	communication.HandleLiveHDHandshake = make(chan models.RequestHDStreamPayload, 10)
 	if subStreamEnabled {
 		livestreamHDCursor := subQueue.Latest()
 		go cloud.HandleLiveStreamHD(livestreamHDCursor, configuration, communication, mqttClient, rtspSubClient)
@@ -267,7 +267,7 @@ func RunAgent(configDirectory string, configuration *models.Configuration, commu
 	go capture.HandleRecordStream(queue, configDirectory, configuration, communication, rtspClient)
 
 	// Handle processing of motion
-	communication.HandleMotion = make(chan models.MotionDataPartial, 1)
+	communication.HandleMotion = make(chan models.MotionDataPartial, 10)
 	if subStreamEnabled {
 		motionCursor := subQueue.Latest()
 		go computervision.ProcessMotion(motionCursor, configuration, communication, mqttClient, rtspSubClient)
@@ -289,10 +289,10 @@ func RunAgent(configDirectory string, configuration *models.Configuration, commu
 	go cloud.HandleUpload(configDirectory, configuration, communication)
 
 	// Handle ONVIF actions
-	communication.HandleONVIF = make(chan models.OnvifAction, 1)
+	communication.HandleONVIF = make(chan models.OnvifAction, 10)
 	go onvif.HandleONVIFActions(configuration, communication)
 
-	communication.HandleAudio = make(chan models.AudioDataPartial, 1)
+	communication.HandleAudio = make(chan models.AudioDataPartial, 10)
 	if rtspBackChannelClient.HasBackChannel {
 		communication.HasBackChannel = true
 		go WriteAudioToBackchannel(communication, rtspBackChannelClient)

machinery/src/config/main.go

@@ -183,15 +183,19 @@ func OpenConfig(configDirectory string, configuration *models.Configuration) {
 			}
 			jsonFile.Close()
 		}
-
 	}
-
 	return
 }
 
 // This function will override the configuration with environment variables.
 func OverrideWithEnvironmentVariables(configuration *models.Configuration) {
 	environmentVariables := os.Environ()
+
+	// Initialize the configuration for some new fields.
+	if configuration.Config.KStorageSecondary == nil {
+		configuration.Config.KStorageSecondary = &models.KStorage{}
+	}
+
 	for _, env := range environmentVariables {
 		if strings.Contains(env, "AGENT_") {
 			key := strings.Split(env, "=")[0]
@@ -436,7 +440,7 @@ func OverrideWithEnvironmentVariables(configuration *models.Configuration) {
 				configuration.Config.S3.Region = value
 				break
 
-			/* When storing in a Kerberos Vault */
+			/* When storing in a Vault */
 			case "AGENT_KERBEROSVAULT_URI":
 				configuration.Config.KStorage.URI = value
 				break
@@ -453,6 +457,23 @@ func OverrideWithEnvironmentVariables(configuration *models.Configuration) {
 				configuration.Config.KStorage.Directory = value
 				break
 
+			/* When storing in a secondary Vault */
+			case "AGENT_KERBEROSVAULT_SECONDARY_URI":
+				configuration.Config.KStorageSecondary.URI = value
+				break
+			case "AGENT_KERBEROSVAULT_SECONDARY_ACCESS_KEY":
+				configuration.Config.KStorageSecondary.AccessKey = value
+				break
+			case "AGENT_KERBEROSVAULT_SECONDARY_SECRET_KEY":
+				configuration.Config.KStorageSecondary.SecretAccessKey = value
+				break
+			case "AGENT_KERBEROSVAULT_SECONDARY_PROVIDER":
+				configuration.Config.KStorageSecondary.Provider = value
+				break
+			case "AGENT_KERBEROSVAULT_SECONDARY_DIRECTORY":
+				configuration.Config.KStorageSecondary.Directory = value
+				break
+
 			/* When storing in dropbox */
 			case "AGENT_DROPBOX_ACCESS_TOKEN":
 				configuration.Config.Dropbox.AccessToken = value

machinery/src/models/Config.go

@@ -28,6 +28,7 @@ type Config struct {
 	Cloud                   string       `json:"cloud" bson:"cloud"`
 	S3                      *S3          `json:"s3,omitempty" bson:"s3,omitempty"`
 	KStorage                *KStorage    `json:"kstorage,omitempty" bson:"kstorage,omitempty"`
+	KStorageSecondary       *KStorage    `json:"kstorage_secondary,omitempty" bson:"kstorage_secondary,omitempty"`
 	Dropbox                 *Dropbox     `json:"dropbox,omitempty" bson:"dropbox,omitempty"`
 	MQTTURI                 string       `json:"mqtturi" bson:"mqtturi,omitempty"`
 	MQTTUsername            string       `json:"mqtt_username" bson:"mqtt_username"`
@@ -152,12 +153,12 @@ type S3 struct {
 // KStorage contains the credentials of the Kerberos Storage/Kerberos Cloud instance.
 // By defining KStorage you can make your recordings available in the cloud, at a centrel place.
 type KStorage struct {
-	URI             string `json:"uri,omitempty" bson:"uri,omitempty"`
-	CloudKey        string `json:"cloud_key,omitempty" bson:"cloud_key,omitempty"` /* old way, remove this */
-	AccessKey       string `json:"access_key,omitempty" bson:"access_key,omitempty"`
-	SecretAccessKey string `json:"secret_access_key,omitempty" bson:"secret_access_key,omitempty"`
-	Provider        string `json:"provider,omitempty" bson:"provider,omitempty"`
-	Directory       string `json:"directory,omitempty" bson:"directory,omitempty"`
+	URI             string `json:"uri" bson:"uri"`
+	CloudKey        string `json:"cloud_key" bson:"cloud_key"` /* old way, remove this */
+	AccessKey       string `json:"access_key" bson:"access_key"`
+	SecretAccessKey string `json:"secret_access_key" bson:"secret_access_key"`
+	Provider        string `json:"provider" bson:"provider"`
+	Directory       string `json:"directory" bson:"directory"`
 }
 
 // Dropbox integration

machinery/src/routers/http/routes.go

@@ -54,16 +54,21 @@ func AddRoutes(r *gin.Engine, authMiddleware *jwt.GinJWTMiddleware, configDirect
 			components.UpdateConfig(c, configDirectory, configuration, communication)
 		})
 
-		// Will verify the current hub settings.
+		// Will verify the hub settings.
 		api.POST("/hub/verify", func(c *gin.Context) {
 			cloud.VerifyHub(c)
 		})
 
-		// Will verify the current persistence settings.
+		// Will verify the persistence settings.
 		api.POST("/persistence/verify", func(c *gin.Context) {
 			cloud.VerifyPersistence(c, configDirectory)
 		})
 
+		// Will verify the secondary persistence settings.
+		api.POST("/persistence/secondary/verify", func(c *gin.Context) {
+			cloud.VerifySecondaryPersistence(c, configDirectory)
+		})
+
 		// Camera specific methods. Doesn't require any authorization.
 		// These are available for anyone, but require the agent, to reach
 		// the camera.

machinery/src/routers/mqtt/main.go

@@ -391,7 +391,8 @@ func HandleRequestConfig(mqttClient mqtt.Client, hubKey string, payload models.P
 
 			// We need a fix for the width and height if a substream.
 			// The ROI requires the width and height of the sub stream.
-			if configuration.Config.Capture.IPCamera.SubRTSP != "" {
+			if configuration.Config.Capture.IPCamera.SubRTSP != "" &&
+				configuration.Config.Capture.IPCamera.SubRTSP != configuration.Config.Capture.IPCamera.RTSP {
 				deepCopy.Capture.IPCamera.Width = configuration.Config.Capture.IPCamera.SubWidth
 				deepCopy.Capture.IPCamera.Height = configuration.Config.Capture.IPCamera.SubHeight
 			}

ui/public/locales/en/translation.json

@@ -189,6 +189,8 @@
       "description_kerberoshub": "Kerberos Agents can send heartbeats to a central",
       "description2_kerberoshub": "installation. Heartbeats and other relevant information are synced to Kerberos Hub to show realtime information about your video landscape.",
       "persistence": "Persistence",
+      "secondary_persistence": "Secondary Persistence",
+      "description_secondary_persistence": "Recordings will be sent to secondary persistence if the primary persistence is unavailable or fails. This can be useful for failover purposes.",
       "saasoffering": "Kerberos Hub (SAAS offering)",
       "description_persistence": "Having the ability to store your recordings is the beginning of everything. You can choose between our",
       "description2_persistence": ", or a 3rd party provider",

ui/public/locales/it/translation.json

@@ -226,4 +226,4 @@
       "remove_after_upload_enabled": "Abilita cancellazione al caricamento"
     }
   }
-}
+}

ui/public/locales/ja/translation.json

@@ -226,4 +226,4 @@
       "remove_after_upload_enabled": "Enabled delete on upload"
     }
   }
-}
+}

ui/public/locales/vi/translation.json

@@ -1,234 +1,234 @@
-{
-  "breadcrumb": {
-    "watch_recordings": "Xem bản ghi",
-    "configure": "Cấu hình"
-  },
-  "buttons": {
-    "save": "Lưu",
-    "verify_connection": "Xác minh kết nối"
-  },
-  "navigation": {
-    "profile": "Hồ sơ",
-    "admin": "Quản trị",
-    "management": "Quản lý",
-    "dashboard": "Bảng điều khiển",
-    "recordings": "Bản ghi",
-    "settings": "Cài đặt",
-    "help_support": "Trợ giúp & Hỗ trợ",
-    "swagger": "API Swagger",
-    "documentation": "Tài liệu",
-    "ui_library": "Thư viện UI",
-    "layout": "Ngôn ngữ & Bố cục",
-    "choose_language": "Chọn ngôn ngữ"
-  },
-  "dashboard": {
-    "title": "Bảng điều khiển",
-    "heading": "Tổng quan về giám sát video của bạn",
-    "number_of_days": "Số ngày",
-    "total_recordings": "Tổng số bản ghi",
-    "connected": "Đã kết nối",
-    "not_connected": "Chưa kết nối",
-    "offline_mode": "Chế độ ngoại tuyến",
-    "latest_events": "Sự kiện gần đây",
-    "configure_connection": "Cấu hình kết nối",
-    "no_events": "Không có sự kiện",
-    "no_events_description": "Không tìm thấy bản ghi nào, hãy đảm bảo Kerberos Agent của bạn được cấu hình đúng cách.",
-    "motion_detected": "Phát hiện chuyển động",
-    "live_view": "Xem trực tiếp",
-    "loading_live_view": "Đang tải xem trực tiếp",
-    "loading_live_view_description": "Vui lòng chờ trong khi chúng tôi tải xem trực tiếp của bạn. Nếu bạn chưa cấu hình kết nối camera, hãy cập nhật trong trang cài đặt.",
-    "time": "Thời gian",
-    "description": "Mô tả",
-    "name": "Tên"
-  },
-  "recordings": {
-    "title": "Bản ghi",
-    "heading": "Tất cả bản ghi của bạn ở một nơi",
-    "search_media": "Tìm kiếm phương tiện"
-  },
-  "settings": {
-    "title": "Cài đặt",
-    "heading": "Thiết lập camera của bạn",
-    "submenu": {
-		"all": "Tất cả",
-		"overview": "Tổng quan",
-		"camera": "Camera",
-		"recording": "Ghi hình",
-		"streaming": "Truyền phát",
-		"conditions": "Điều kiện",
-		"persistence": "Lưu trữ"
-    },
-    "info": {
-		"kerberos_hub_demo": "Xem thử môi trường demo của Kerberos Hub để thấy Kerberos Hub hoạt động như thế nào!",
-		"configuration_updated_success": "Cấu hình của bạn đã được cập nhật thành công.",
-		"configuration_updated_error": "Đã xảy ra lỗi khi lưu.",
-		"verify_hub": "Đang xác minh cài đặt Kerberos Hub của bạn.",
-		"verify_hub_success": "Cài đặt Kerberos Hub đã được xác minh thành công.",
-		"verify_hub_error": "Đã xảy ra lỗi khi xác minh Kerberos Hub",
-		"verify_persistence": "Đang xác minh cài đặt lưu trữ.",
-		"verify_persistence_success": "Cài đặt lưu trữ đã được xác minh thành công.",
-		"verify_persistence_error": "Đã xảy ra lỗi khi xác minh lưu trữ",
-		"verify_camera": "Đang xác minh cài đặt camera.",
-		"verify_camera_success": "Cài đặt camera đã được xác minh thành công.",
-		"verify_camera_error": "Đã xảy ra lỗi khi xác minh cài đặt camera",
-		"verify_onvif": "Đang xác minh cài đặt ONVIF.",
-		"verify_onvif_success": "Cài đặt ONVIF đã được xác minh thành công.",
-		"verify_onvif_error": "Đã xảy ra lỗi khi xác minh cài đặt ONVIF"
-    },
-	"overview": {
-		"general": "Chung",
-		"description_general": "Cài đặt chung cho Kerberos Agent của bạn",
-		"key": "Khóa",
-		"camera_name": "Tên camera",
-		"camera_friendly_name": "Tên thân thiện",
-		"timezone": "Múi giờ",
-		"select_timezone": "Chọn múi giờ",
-		"advanced_configuration": "Cấu hình nâng cao",
-		"description_advanced_configuration": "Tùy chọn cấu hình chi tiết để bật hoặc tắt các phần cụ thể của Kerberos Agent",
-		"offline_mode": "Chế độ ngoại tuyến",
-		"description_offline_mode": "Vô hiệu hóa toàn bộ lưu lượng đi",
-		"encryption": "Mã hóa",
-		"description_encryption": "Bật mã hóa cho toàn bộ lưu lượng đi. Các tin nhắn MQTT và/hoặc bản ghi sẽ được mã hóa bằng AES-256. Một khóa riêng tư được sử dụng để ký.",
-		"encryption_enabled": "Bật mã hóa MQTT",
-		"description_encryption_enabled": "Bật mã hóa cho toàn bộ tin nhắn MQTT.",
-		"encryption_recordings_enabled": "Bật mã hóa bản ghi",
-		"description_encryption_recordings_enabled": "Bật mã hóa cho tất cả các bản ghi.",
-		"encryption_fingerprint": "Dấu vân tay",
-		"encryption_privatekey": "Khóa riêng tư",
-		"encryption_symmetrickey": "Khóa đối xứng"
-	},
-	"camera": {
-		"camera": "Camera",
-		"description_camera": "Cài đặt camera là bắt buộc để kết nối với camera bạn chọn.",
-		"only_h264": "Hiện tại chỉ hỗ trợ luồng RTSP H264/H265.",
-		"rtsp_url": "URL RTSP",
-		"rtsp_h264": "Kết nối RTSP H264/H265 với camera của bạn.",
-		"sub_rtsp_url": "URL RTSP phụ (dùng để phát trực tiếp)",
-		"sub_rtsp_h264": "Kết nối RTSP phụ với độ phân giải thấp của camera.",
-		"onvif": "ONVIF",
-		"description_onvif": "Thông tin xác thực để giao tiếp với các chức năng ONVIF. Chúng được sử dụng cho PTZ hoặc các khả năng khác do camera cung cấp.",
-		"onvif_xaddr": "Địa chỉ ONVIF",
-		"onvif_username": "Tên người dùng ONVIF",
-		"onvif_password": "Mật khẩu ONVIF",
-		"verify_connection": "Xác minh kết nối",
-		"verify_sub_connection": "Xác minh kết nối phụ"
-	},
-	"recording": {
-		"recording": "Ghi hình",
-		"description_recording": "Chỉ định cách bạn muốn thực hiện ghi hình. Có thể ghi liên tục 24/7 hoặc dựa trên chuyển động.",
-		"continuous_recording": "Ghi hình liên tục",
-		"description_continuous_recording": "Ghi hình liên tục 24/7 hoặc dựa trên chuyển động.",
-		"max_duration": "Thời lượng video tối đa (giây)",
-		"description_max_duration": "Thời lượng tối đa của một bản ghi.",
-		"pre_recording": "Ghi trước (khung hình chính được lưu vào bộ đệm)",
-		"description_pre_recording": "Số giây trước khi sự kiện xảy ra.",
-		"post_recording": "Ghi sau (giây)",
-		"description_post_recording": "Số giây sau khi sự kiện xảy ra.",
-		"threshold": "Ngưỡng ghi hình (pixel)",
-		"description_threshold": "Số pixel thay đổi cần đạt để bắt đầu ghi hình.",
-		"autoclean": "Tự động dọn dẹp",
-		"description_autoclean": "Chỉ định xem Kerberos Agent có thể dọn dẹp các bản ghi khi dung lượng lưu trữ đạt giới hạn nhất định (MB) hay không. Hệ thống sẽ xóa bản ghi cũ nhất khi đạt giới hạn.",
-		"autoclean_enable": "Bật tự động dọn dẹp",
-		"autoclean_description_enable": "Xóa bản ghi cũ nhất khi đạt giới hạn dung lượng.",
-		"autoclean_max_directory_size": "Dung lượng thư mục tối đa (MB)",
-		"autoclean_description_max_directory_size": "Dung lượng tối đa (MB) của các bản ghi được lưu trữ.",
-		"fragmentedrecordings": "Ghi hình phân đoạn",
-		"description_fragmentedrecordings": "Khi các bản ghi được phân đoạn, chúng phù hợp để phát trực tuyến HLS. Khi bật, định dạng MP4 sẽ có một số khác biệt.",
-		"fragmentedrecordings_enable": "Bật ghi hình phân đoạn",
-		"fragmentedrecordings_description_enable": "Ghi hình phân đoạn là bắt buộc đối với HLS.",
-		"fragmentedrecordings_duration": "Thời lượng phân đoạn",
-		"fragmentedrecordings_description_duration": "Thời lượng của một phân đoạn duy nhất."
-	},
-	"streaming": {
-		"stun_turn": "STUN/TURN cho WebRTC",
-		"description_stun_turn": "Để phát trực tiếp độ phân giải đầy đủ, chúng tôi sử dụng khái niệm WebRTC. Một trong những tính năng chính là ICE-candidate, cho phép vượt qua NAT bằng STUN/TURN.",
-		"stun_server": "Máy chủ STUN",
-		"turn_server": "Máy chủ TURN",
-		"turn_username": "Tên người dùng",
-		"turn_password": "Mật khẩu",
-		"force_turn": "Buộc sử dụng TURN",
-		"force_turn_description": "Buộc sử dụng TURN ngay cả khi STUN có sẵn.",
-		"stun_turn_forward": "Chuyển tiếp và mã hóa",
-		"stun_turn_description_forward": "Tối ưu hóa và cải thiện giao tiếp TURN/STUN.",
-		"stun_turn_webrtc": "Chuyển tiếp đến WebRTC broker",
-		"stun_turn_description_webrtc": "Chuyển tiếp luồng H264 qua MQTT",
-		"stun_turn_transcode": "Chuyển mã luồng",
-		"stun_turn_description_transcode": "Chuyển đổi luồng sang độ phân giải thấp hơn",
-		"stun_turn_downscale": "Giảm độ phân giải (theo % của độ phân giải gốc)",
-		"mqtt": "MQTT",
-		"description_mqtt": "Một MQTT broker được sử dụng để giao tiếp từ",
-		"description2_mqtt": "đến Kerberos Agent, nhằm hỗ trợ phát trực tiếp hoặc chức năng ONVIF (PTZ).",
-		"mqtt_brokeruri": "Broker Uri",
-		"mqtt_username": "Tên người dùng",
-		"mqtt_password": "Mật khẩu",
-		"realtimeprocessing": "Xử lý thời gian thực",
-		"description_realtimeprocessing": "Bằng cách bật xử lý thời gian thực, bạn sẽ nhận được các khung hình video thời gian thực qua kết nối MQTT đã chỉ định.",
-		"realtimeprocessing_topic": "Chủ đề để xuất bản",
-		"realtimeprocessing_enabled": "Bật xử lý thời gian thực",
-		"description_realtimeprocessing_enabled": "Gửi khung hình video thời gian thực qua MQTT."
-	},
-	"conditions": {
-		"timeofinterest": "Thời gian quan tâm",
-		"description_timeofinterest": "Chỉ ghi hình trong các khoảng thời gian cụ thể (dựa trên múi giờ).",
-		"timeofinterest_enabled": "Đã bật",
-		"timeofinterest_description_enabled": "Nếu bật, bạn có thể chỉ định các khoảng thời gian ghi hình.",
-		"sunday": "Chủ nhật",
-		"monday": "Thứ hai",
-		"tuesday": "Thứ ba",
-		"wednesday": "Thứ tư",
-		"thursday": "Thứ năm",
-		"friday": "Thứ sáu",
-		"saturday": "Thứ bảy",
-		"externalcondition": "Điều kiện bên ngoài",
-		"description_externalcondition": "Tùy thuộc vào một dịch vụ web bên ngoài, việc ghi hình có thể được bật hoặc tắt.",
-		"regionofinterest": "Khu vực quan tâm",
-		"description_regionofinterest": "Bằng cách xác định một hoặc nhiều khu vực, hệ thống sẽ chỉ theo dõi chuyển động trong các khu vực bạn đã chọn."
-	},
-	"persistence": {
-		"kerberoshub": "Kerberos Hub",
-		"description_kerberoshub": "Các Kerberos Agent có thể gửi tín hiệu nhịp tim đến một hệ thống trung tâm",
-		"description2_kerberoshub": "để đồng bộ hóa thông tin quan trọng với Kerberos Hub, giúp hiển thị trạng thái giám sát video theo thời gian thực.",
-		"persistence": "Lưu trữ",
-		"saasoffering": "Kerberos Hub (dịch vụ SAAS)",
-		"description_persistence": "Khả năng lưu trữ bản ghi là bước khởi đầu của mọi thứ. Bạn có thể chọn giữa dịch vụ của chúng tôi",
-		"description2_persistence": "hoặc một nhà cung cấp bên thứ ba.",
-		"select_persistence": "Chọn phương thức lưu trữ",
-		"kerberoshub_encryption": "Mã hóa",
-		"kerberoshub_encryption_description": "Tất cả lưu lượng đến/từ Kerberos Hub sẽ được mã hóa bằng AES-256.",
-		"kerberoshub_proxyurl": "URL Proxy Kerberos Hub",
-		"kerberoshub_description_proxyurl": "Điểm cuối Proxy để tải bản ghi lên.",
-		"kerberoshub_apiurl": "URL API Kerberos Hub",
-		"kerberoshub_description_apiurl": "Điểm cuối API để tải bản ghi lên.",
-		"kerberoshub_publickey": "Khóa công khai",
-		"kerberoshub_description_publickey": "Khóa công khai được cấp cho tài khoản Kerberos Hub của bạn.",
-		"kerberoshub_privatekey": "Khóa riêng tư",
-		"kerberoshub_description_privatekey": "Khóa riêng tư được cấp cho tài khoản Kerberos Hub của bạn.",
-		"kerberoshub_site": "Trang web",
-		"kerberoshub_description_site": "ID trang web mà các Kerberos Agent thuộc về trong Kerberos Hub.",
-		"kerberoshub_region": "Khu vực",
-		"kerberoshub_description_region": "Khu vực nơi chúng tôi lưu trữ bản ghi.",
-		"kerberoshub_bucket": "Kho lưu trữ",
-		"kerberoshub_description_bucket": "Kho lưu trữ nơi chúng tôi lưu trữ bản ghi.",
-		"kerberoshub_username": "Tên người dùng / Thư mục (phải khớp với tên người dùng Kerberos Hub)",
-		"kerberoshub_description_username": "Tên người dùng tài khoản Kerberos Hub của bạn.",
-		"kerberosvault_apiurl": "URL API Kerberos Vault",
-		"kerberosvault_description_apiurl": "API của Kerberos Vault",
-		"kerberosvault_provider": "Nhà cung cấp",
-		"kerberosvault_description_provider": "Nhà cung cấp nơi bản ghi của bạn sẽ được gửi đến.",
-		"kerberosvault_directory": "Thư mục (phải khớp với tên người dùng Kerberos Hub)",
-		"kerberosvault_description_directory": "Thư mục con nơi các bản ghi sẽ được lưu trữ trong nhà cung cấp của bạn.",
-		"kerberosvault_accesskey": "Khóa truy cập",
-		"kerberosvault_description_accesskey": "Khóa truy cập của tài khoản Kerberos Vault của bạn.",
-		"kerberosvault_secretkey": "Khóa bí mật",
-		"kerberosvault_description_secretkey": "Khóa bí mật của tài khoản Kerberos Vault của bạn.",
-		"dropbox_directory": "Thư mục",
-		"dropbox_description_directory": "Thư mục con nơi bản ghi sẽ được lưu trữ trong tài khoản Dropbox của bạn.",
-		"dropbox_accesstoken": "Mã truy cập",
-		"dropbox_description_accesstoken": "Mã truy cập của tài khoản / ứng dụng Dropbox của bạn.",
-		"verify_connection": "Xác minh kết nối",
-		"remove_after_upload": "Sau khi bản ghi được tải lên một hệ thống lưu trữ, bạn có thể muốn xóa chúng khỏi Kerberos Agent cục bộ.",
-		"remove_after_upload_description": "Xóa bản ghi sau khi chúng được tải lên thành công.",
-		"remove_after_upload_enabled": "Bật xóa sau khi tải lên"
-	}
-  }
-}
+{
+  "breadcrumb": {
+    "watch_recordings": "Xem bản ghi",
+    "configure": "Cấu hình"
+  },
+  "buttons": {
+    "save": "Lưu",
+    "verify_connection": "Xác minh kết nối"
+  },
+  "navigation": {
+    "profile": "Hồ sơ",
+    "admin": "Quản trị",
+    "management": "Quản lý",
+    "dashboard": "Bảng điều khiển",
+    "recordings": "Bản ghi",
+    "settings": "Cài đặt",
+    "help_support": "Trợ giúp & Hỗ trợ",
+    "swagger": "API Swagger",
+    "documentation": "Tài liệu",
+    "ui_library": "Thư viện UI",
+    "layout": "Ngôn ngữ & Bố cục",
+    "choose_language": "Chọn ngôn ngữ"
+  },
+  "dashboard": {
+    "title": "Bảng điều khiển",
+    "heading": "Tổng quan về giám sát video của bạn",
+    "number_of_days": "Số ngày",
+    "total_recordings": "Tổng số bản ghi",
+    "connected": "Đã kết nối",
+    "not_connected": "Chưa kết nối",
+    "offline_mode": "Chế độ ngoại tuyến",
+    "latest_events": "Sự kiện gần đây",
+    "configure_connection": "Cấu hình kết nối",
+    "no_events": "Không có sự kiện",
+    "no_events_description": "Không tìm thấy bản ghi nào, hãy đảm bảo Kerberos Agent của bạn được cấu hình đúng cách.",
+    "motion_detected": "Phát hiện chuyển động",
+    "live_view": "Xem trực tiếp",
+    "loading_live_view": "Đang tải xem trực tiếp",
+    "loading_live_view_description": "Vui lòng chờ trong khi chúng tôi tải xem trực tiếp của bạn. Nếu bạn chưa cấu hình kết nối camera, hãy cập nhật trong trang cài đặt.",
+    "time": "Thời gian",
+    "description": "Mô tả",
+    "name": "Tên"
+  },
+  "recordings": {
+    "title": "Bản ghi",
+    "heading": "Tất cả bản ghi của bạn ở một nơi",
+    "search_media": "Tìm kiếm phương tiện"
+  },
+  "settings": {
+    "title": "Cài đặt",
+    "heading": "Thiết lập camera của bạn",
+    "submenu": {
+      "all": "Tất cả",
+      "overview": "Tổng quan",
+      "camera": "Camera",
+      "recording": "Ghi hình",
+      "streaming": "Truyền phát",
+      "conditions": "Điều kiện",
+      "persistence": "Lưu trữ"
+    },
+    "info": {
+      "kerberos_hub_demo": "Xem thử môi trường demo của Kerberos Hub để thấy Kerberos Hub hoạt động như thế nào!",
+      "configuration_updated_success": "Cấu hình của bạn đã được cập nhật thành công.",
+      "configuration_updated_error": "Đã xảy ra lỗi khi lưu.",
+      "verify_hub": "Đang xác minh cài đặt Kerberos Hub của bạn.",
+      "verify_hub_success": "Cài đặt Kerberos Hub đã được xác minh thành công.",
+      "verify_hub_error": "Đã xảy ra lỗi khi xác minh Kerberos Hub",
+      "verify_persistence": "Đang xác minh cài đặt lưu trữ.",
+      "verify_persistence_success": "Cài đặt lưu trữ đã được xác minh thành công.",
+      "verify_persistence_error": "Đã xảy ra lỗi khi xác minh lưu trữ",
+      "verify_camera": "Đang xác minh cài đặt camera.",
+      "verify_camera_success": "Cài đặt camera đã được xác minh thành công.",
+      "verify_camera_error": "Đã xảy ra lỗi khi xác minh cài đặt camera",
+      "verify_onvif": "Đang xác minh cài đặt ONVIF.",
+      "verify_onvif_success": "Cài đặt ONVIF đã được xác minh thành công.",
+      "verify_onvif_error": "Đã xảy ra lỗi khi xác minh cài đặt ONVIF"
+    },
+    "overview": {
+      "general": "Chung",
+      "description_general": "Cài đặt chung cho Kerberos Agent của bạn",
+      "key": "Khóa",
+      "camera_name": "Tên camera",
+      "camera_friendly_name": "Tên thân thiện",
+      "timezone": "Múi giờ",
+      "select_timezone": "Chọn múi giờ",
+      "advanced_configuration": "Cấu hình nâng cao",
+      "description_advanced_configuration": "Tùy chọn cấu hình chi tiết để bật hoặc tắt các phần cụ thể của Kerberos Agent",
+      "offline_mode": "Chế độ ngoại tuyến",
+      "description_offline_mode": "Vô hiệu hóa toàn bộ lưu lượng đi",
+      "encryption": "Mã hóa",
+      "description_encryption": "Bật mã hóa cho toàn bộ lưu lượng đi. Các tin nhắn MQTT và/hoặc bản ghi sẽ được mã hóa bằng AES-256. Một khóa riêng tư được sử dụng để ký.",
+      "encryption_enabled": "Bật mã hóa MQTT",
+      "description_encryption_enabled": "Bật mã hóa cho toàn bộ tin nhắn MQTT.",
+      "encryption_recordings_enabled": "Bật mã hóa bản ghi",
+      "description_encryption_recordings_enabled": "Bật mã hóa cho tất cả các bản ghi.",
+      "encryption_fingerprint": "Dấu vân tay",
+      "encryption_privatekey": "Khóa riêng tư",
+      "encryption_symmetrickey": "Khóa đối xứng"
+    },
+    "camera": {
+      "camera": "Camera",
+      "description_camera": "Cài đặt camera là bắt buộc để kết nối với camera bạn chọn.",
+      "only_h264": "Hiện tại chỉ hỗ trợ luồng RTSP H264/H265.",
+      "rtsp_url": "URL RTSP",
+      "rtsp_h264": "Kết nối RTSP H264/H265 với camera của bạn.",
+      "sub_rtsp_url": "URL RTSP phụ (dùng để phát trực tiếp)",
+      "sub_rtsp_h264": "Kết nối RTSP phụ với độ phân giải thấp của camera.",
+      "onvif": "ONVIF",
+      "description_onvif": "Thông tin xác thực để giao tiếp với các chức năng ONVIF. Chúng được sử dụng cho PTZ hoặc các khả năng khác do camera cung cấp.",
+      "onvif_xaddr": "Địa chỉ ONVIF",
+      "onvif_username": "Tên người dùng ONVIF",
+      "onvif_password": "Mật khẩu ONVIF",
+      "verify_connection": "Xác minh kết nối",
+      "verify_sub_connection": "Xác minh kết nối phụ"
+    },
+    "recording": {
+      "recording": "Ghi hình",
+      "description_recording": "Chỉ định cách bạn muốn thực hiện ghi hình. Có thể ghi liên tục 24/7 hoặc dựa trên chuyển động.",
+      "continuous_recording": "Ghi hình liên tục",
+      "description_continuous_recording": "Ghi hình liên tục 24/7 hoặc dựa trên chuyển động.",
+      "max_duration": "Thời lượng video tối đa (giây)",
+      "description_max_duration": "Thời lượng tối đa của một bản ghi.",
+      "pre_recording": "Ghi trước (khung hình chính được lưu vào bộ đệm)",
+      "description_pre_recording": "Số giây trước khi sự kiện xảy ra.",
+      "post_recording": "Ghi sau (giây)",
+      "description_post_recording": "Số giây sau khi sự kiện xảy ra.",
+      "threshold": "Ngưỡng ghi hình (pixel)",
+      "description_threshold": "Số pixel thay đổi cần đạt để bắt đầu ghi hình.",
+      "autoclean": "Tự động dọn dẹp",
+      "description_autoclean": "Chỉ định xem Kerberos Agent có thể dọn dẹp các bản ghi khi dung lượng lưu trữ đạt giới hạn nhất định (MB) hay không. Hệ thống sẽ xóa bản ghi cũ nhất khi đạt giới hạn.",
+      "autoclean_enable": "Bật tự động dọn dẹp",
+      "autoclean_description_enable": "Xóa bản ghi cũ nhất khi đạt giới hạn dung lượng.",
+      "autoclean_max_directory_size": "Dung lượng thư mục tối đa (MB)",
+      "autoclean_description_max_directory_size": "Dung lượng tối đa (MB) của các bản ghi được lưu trữ.",
+      "fragmentedrecordings": "Ghi hình phân đoạn",
+      "description_fragmentedrecordings": "Khi các bản ghi được phân đoạn, chúng phù hợp để phát trực tuyến HLS. Khi bật, định dạng MP4 sẽ có một số khác biệt.",
+      "fragmentedrecordings_enable": "Bật ghi hình phân đoạn",
+      "fragmentedrecordings_description_enable": "Ghi hình phân đoạn là bắt buộc đối với HLS.",
+      "fragmentedrecordings_duration": "Thời lượng phân đoạn",
+      "fragmentedrecordings_description_duration": "Thời lượng của một phân đoạn duy nhất."
+    },
+    "streaming": {
+      "stun_turn": "STUN/TURN cho WebRTC",
+      "description_stun_turn": "Để phát trực tiếp độ phân giải đầy đủ, chúng tôi sử dụng khái niệm WebRTC. Một trong những tính năng chính là ICE-candidate, cho phép vượt qua NAT bằng STUN/TURN.",
+      "stun_server": "Máy chủ STUN",
+      "turn_server": "Máy chủ TURN",
+      "turn_username": "Tên người dùng",
+      "turn_password": "Mật khẩu",
+      "force_turn": "Buộc sử dụng TURN",
+      "force_turn_description": "Buộc sử dụng TURN ngay cả khi STUN có sẵn.",
+      "stun_turn_forward": "Chuyển tiếp và mã hóa",
+      "stun_turn_description_forward": "Tối ưu hóa và cải thiện giao tiếp TURN/STUN.",
+      "stun_turn_webrtc": "Chuyển tiếp đến WebRTC broker",
+      "stun_turn_description_webrtc": "Chuyển tiếp luồng H264 qua MQTT",
+      "stun_turn_transcode": "Chuyển mã luồng",
+      "stun_turn_description_transcode": "Chuyển đổi luồng sang độ phân giải thấp hơn",
+      "stun_turn_downscale": "Giảm độ phân giải (theo % của độ phân giải gốc)",
+      "mqtt": "MQTT",
+      "description_mqtt": "Một MQTT broker được sử dụng để giao tiếp từ",
+      "description2_mqtt": "đến Kerberos Agent, nhằm hỗ trợ phát trực tiếp hoặc chức năng ONVIF (PTZ).",
+      "mqtt_brokeruri": "Broker Uri",
+      "mqtt_username": "Tên người dùng",
+      "mqtt_password": "Mật khẩu",
+      "realtimeprocessing": "Xử lý thời gian thực",
+      "description_realtimeprocessing": "Bằng cách bật xử lý thời gian thực, bạn sẽ nhận được các khung hình video thời gian thực qua kết nối MQTT đã chỉ định.",
+      "realtimeprocessing_topic": "Chủ đề để xuất bản",
+      "realtimeprocessing_enabled": "Bật xử lý thời gian thực",
+      "description_realtimeprocessing_enabled": "Gửi khung hình video thời gian thực qua MQTT."
+    },
+    "conditions": {
+      "timeofinterest": "Thời gian quan tâm",
+      "description_timeofinterest": "Chỉ ghi hình trong các khoảng thời gian cụ thể (dựa trên múi giờ).",
+      "timeofinterest_enabled": "Đã bật",
+      "timeofinterest_description_enabled": "Nếu bật, bạn có thể chỉ định các khoảng thời gian ghi hình.",
+      "sunday": "Chủ nhật",
+      "monday": "Thứ hai",
+      "tuesday": "Thứ ba",
+      "wednesday": "Thứ tư",
+      "thursday": "Thứ năm",
+      "friday": "Thứ sáu",
+      "saturday": "Thứ bảy",
+      "externalcondition": "Điều kiện bên ngoài",
+      "description_externalcondition": "Tùy thuộc vào một dịch vụ web bên ngoài, việc ghi hình có thể được bật hoặc tắt.",
+      "regionofinterest": "Khu vực quan tâm",
+      "description_regionofinterest": "Bằng cách xác định một hoặc nhiều khu vực, hệ thống sẽ chỉ theo dõi chuyển động trong các khu vực bạn đã chọn."
+    },
+    "persistence": {
+      "kerberoshub": "Kerberos Hub",
+      "description_kerberoshub": "Các Kerberos Agent có thể gửi tín hiệu nhịp tim đến một hệ thống trung tâm",
+      "description2_kerberoshub": "để đồng bộ hóa thông tin quan trọng với Kerberos Hub, giúp hiển thị trạng thái giám sát video theo thời gian thực.",
+      "persistence": "Lưu trữ",
+      "saasoffering": "Kerberos Hub (dịch vụ SAAS)",
+      "description_persistence": "Khả năng lưu trữ bản ghi là bước khởi đầu của mọi thứ. Bạn có thể chọn giữa dịch vụ của chúng tôi",
+      "description2_persistence": "hoặc một nhà cung cấp bên thứ ba.",
+      "select_persistence": "Chọn phương thức lưu trữ",
+      "kerberoshub_encryption": "Mã hóa",
+      "kerberoshub_encryption_description": "Tất cả lưu lượng đến/từ Kerberos Hub sẽ được mã hóa bằng AES-256.",
+      "kerberoshub_proxyurl": "URL Proxy Kerberos Hub",
+      "kerberoshub_description_proxyurl": "Điểm cuối Proxy để tải bản ghi lên.",
+      "kerberoshub_apiurl": "URL API Kerberos Hub",
+      "kerberoshub_description_apiurl": "Điểm cuối API để tải bản ghi lên.",
+      "kerberoshub_publickey": "Khóa công khai",
+      "kerberoshub_description_publickey": "Khóa công khai được cấp cho tài khoản Kerberos Hub của bạn.",
+      "kerberoshub_privatekey": "Khóa riêng tư",
+      "kerberoshub_description_privatekey": "Khóa riêng tư được cấp cho tài khoản Kerberos Hub của bạn.",
+      "kerberoshub_site": "Trang web",
+      "kerberoshub_description_site": "ID trang web mà các Kerberos Agent thuộc về trong Kerberos Hub.",
+      "kerberoshub_region": "Khu vực",
+      "kerberoshub_description_region": "Khu vực nơi chúng tôi lưu trữ bản ghi.",
+      "kerberoshub_bucket": "Kho lưu trữ",
+      "kerberoshub_description_bucket": "Kho lưu trữ nơi chúng tôi lưu trữ bản ghi.",
+      "kerberoshub_username": "Tên người dùng / Thư mục (phải khớp với tên người dùng Kerberos Hub)",
+      "kerberoshub_description_username": "Tên người dùng tài khoản Kerberos Hub của bạn.",
+      "kerberosvault_apiurl": "URL API Kerberos Vault",
+      "kerberosvault_description_apiurl": "API của Kerberos Vault",
+      "kerberosvault_provider": "Nhà cung cấp",
+      "kerberosvault_description_provider": "Nhà cung cấp nơi bản ghi của bạn sẽ được gửi đến.",
+      "kerberosvault_directory": "Thư mục (phải khớp với tên người dùng Kerberos Hub)",
+      "kerberosvault_description_directory": "Thư mục con nơi các bản ghi sẽ được lưu trữ trong nhà cung cấp của bạn.",
+      "kerberosvault_accesskey": "Khóa truy cập",
+      "kerberosvault_description_accesskey": "Khóa truy cập của tài khoản Kerberos Vault của bạn.",
+      "kerberosvault_secretkey": "Khóa bí mật",
+      "kerberosvault_description_secretkey": "Khóa bí mật của tài khoản Kerberos Vault của bạn.",
+      "dropbox_directory": "Thư mục",
+      "dropbox_description_directory": "Thư mục con nơi bản ghi sẽ được lưu trữ trong tài khoản Dropbox của bạn.",
+      "dropbox_accesstoken": "Mã truy cập",
+      "dropbox_description_accesstoken": "Mã truy cập của tài khoản / ứng dụng Dropbox của bạn.",
+      "verify_connection": "Xác minh kết nối",
+      "remove_after_upload": "Sau khi bản ghi được tải lên một hệ thống lưu trữ, bạn có thể muốn xóa chúng khỏi Kerberos Agent cục bộ.",
+      "remove_after_upload_description": "Xóa bản ghi sau khi chúng được tải lên thành công.",
+      "remove_after_upload_enabled": "Bật xóa sau khi tải lên"
+    }
+  }
+}

ui/src/actions/agent.js

@@ -4,6 +4,7 @@ import {
   doVerifyOnvif,
   doVerifyHub,
   doVerifyPersistence,
+  doVerifySecondaryPersistence,
   doGetKerberosAgentTags,
   doGetDashboardInformation,
   doGetEvents,
@@ -107,6 +108,28 @@ export const verifyPersistence = (config, onSuccess, onError) => {
   };
 };
 
+export const verifySecondaryPersistence = (config, onSuccess, onError) => {
+  return (dispatch) => {
+    doVerifySecondaryPersistence(
+      config,
+      () => {
+        dispatch({
+          type: 'VERIFY_SECONDARY_PERSISTENCE',
+        });
+        if (onSuccess) {
+          onSuccess();
+        }
+      },
+      (error) => {
+        const { data } = error.response.data;
+        if (onError) {
+          onError(data);
+        }
+      }
+    );
+  };
+};
+
 export const verifyHub = (config, onSuccess, onError) => {
   return (dispatch) => {
     doVerifyHub(

ui/src/api/agent.js

@@ -72,6 +72,25 @@ export function doVerifyPersistence(config, onSuccess, onError) {
     });
 }
 
+export function doVerifySecondaryPersistence(config, onSuccess, onError) {
+  const endpoint = API.post(`persistence/secondary/verify`, {
+    ...config,
+  });
+  endpoint
+    .then((res) => {
+      if (res.status !== 200) {
+        throw new Error(res.data);
+      }
+      return res.data;
+    })
+    .then((data) => {
+      onSuccess(data);
+    })
+    .catch((error) => {
+      onError(error);
+    });
+}
+
 export function doVerifyHub(config, onSuccess, onError) {
   const endpoint = API.post(`hub/verify`, {
     ...config,

ui/src/config.js

@@ -9,9 +9,9 @@ const dev = {
   ENV: 'dev',
   // Comment the below lines, when using codespaces or other special DNS names (which you can't control)
   HOSTNAME: hostname,
-  API_URL: `${protocol}//${hostname}:80/api`,
-  URL: `${protocol}//${hostname}:80`,
-  WS_URL: `${websocketprotocol}//${hostname}:80/ws`,
+  API_URL: `${protocol}//${hostname}:8080/api`,
+  URL: `${protocol}//${hostname}:8080`,
+  WS_URL: `${websocketprotocol}//${hostname}:8080/ws`,
   MODE: window['env']['mode'],
   // Uncomment, and comment the above lines, when using codespaces or other special DNS names (which you can't control)
   // HOSTNAME: externalHost,

ui/src/pages/Settings/Settings.jsx

@@ -33,6 +33,7 @@ import {
   verifyCamera,
   verifyHub,
   verifyPersistence,
+  verifySecondaryPersistence,
   getConfig,
   updateConfig,
 } from '../../actions/agent';
@@ -63,6 +64,9 @@ class Settings extends React.Component {
       verifyPersistenceSuccess: false,
       verifyPersistenceError: false,
       verifyPersistenceMessage: '',
+      verifySecondaryPersistenceSuccess: false,
+      verifySecondaryPersistenceError: false,
+      verifySecondaryPersistenceMessage: '',
       verifyCameraSuccess: false,
       verifyCameraError: false,
       verifyCameraMessage: '',
@@ -70,6 +74,7 @@ class Settings extends React.Component {
       verifyOnvifError: false,
       verifyOnvifErrorMessage: '',
       loading: false,
+      loadingSecondary: false,
       loadingHub: false,
       loadingCamera: false,
     };
@@ -125,6 +130,8 @@ class Settings extends React.Component {
     this.onUpdateTimeline = this.onUpdateTimeline.bind(this);
     this.initialiseLiveview = this.initialiseLiveview.bind(this);
     this.verifyPersistenceSettings = this.verifyPersistenceSettings.bind(this);
+    this.verifySecondaryPersistenceSettings =
+      this.verifySecondaryPersistenceSettings.bind(this);
     this.verifyHubSettings = this.verifyHubSettings.bind(this);
     this.verifyCameraSettings = this.verifyCameraSettings.bind(this);
     this.verifySubCameraSettings = this.verifySubCameraSettings.bind(this);
@@ -350,6 +357,8 @@ class Settings extends React.Component {
       configSuccess: false,
       configError: false,
       loadingCamera: false,
+      loading: false,
+      loadingSecondary: false,
       loadingOnvif: true,
     });
 
@@ -390,6 +399,8 @@ class Settings extends React.Component {
         configError: false,
         verifyPersistenceSuccess: false,
         verifyPersistenceError: false,
+        verifySecondaryPersistenceSuccess: false,
+        verifySecondaryPersistenceError: false,
         verifyHubSuccess: false,
         verifyHubError: false,
         verifyHubErrorMessage: '',
@@ -401,6 +412,8 @@ class Settings extends React.Component {
         verifyOnvifSuccess: false,
         verifyOnvifError: false,
         loadingHub: true,
+        loading: false,
+        loadingSecondary: false,
       });
 
       // .... test fields
@@ -441,6 +454,8 @@ class Settings extends React.Component {
         verifyHubError: false,
         verifyPersistenceSuccess: false,
         verifyPersistenceError: false,
+        verifySecondaryPersistenceSuccess: false,
+        verifySecondaryPersistenceError: false,
         persistenceSuccess: false,
         persistenceError: false,
         verifyCameraSuccess: false,
@@ -449,6 +464,7 @@ class Settings extends React.Component {
         verifyOnvifError: false,
         verifyCameraErrorMessage: '',
         loading: true,
+        loadingSecondary: false,
       });
 
       dispatchVerifyPersistence(
@@ -461,6 +477,7 @@ class Settings extends React.Component {
             persistenceSuccess: false,
             persistenceError: false,
             loading: false,
+            loadingSecondary: false,
           });
         },
         (error) => {
@@ -471,6 +488,58 @@ class Settings extends React.Component {
             persistenceSuccess: false,
             persistenceError: false,
             loading: false,
+            loadingSecondary: false,
+          });
+        }
+      );
+    }
+  }
+
+  verifySecondaryPersistenceSettings() {
+    const { config, dispatchVerifySecondaryPersistence } = this.props;
+    if (config) {
+      this.setState({
+        configSuccess: false,
+        configError: false,
+        verifyHubSuccess: false,
+        verifyHubError: false,
+        verifyPersistenceSuccess: false,
+        verifyPersistenceError: false,
+        verifySecondaryPersistenceSuccess: false,
+        verifySecondaryPersistenceError: false,
+        persistenceSuccess: false,
+        persistenceError: false,
+        verifyCameraSuccess: false,
+        verifyCameraError: false,
+        verifyOnvifSuccess: false,
+        verifyOnvifError: false,
+        verifyCameraErrorMessage: '',
+        loading: false,
+        loadingSecondary: true,
+      });
+
+      dispatchVerifySecondaryPersistence(
+        config.config,
+        () => {
+          this.setState({
+            verifySecondaryPersistenceSuccess: true,
+            verifySecondaryPersistenceError: false,
+            verifySecondaryPersistenceMessage: '',
+            persistenceSuccess: false,
+            persistenceError: false,
+            loading: false,
+            loadingSecondary: false,
+          });
+        },
+        (error) => {
+          this.setState({
+            verifySecondaryPersistenceSuccess: false,
+            verifySecondaryPersistenceError: true,
+            verifySecondaryPersistenceMessage: error,
+            persistenceSuccess: false,
+            persistenceError: false,
+            loading: false,
+            loadingSecondary: false,
           });
         }
       );
@@ -537,6 +606,9 @@ class Settings extends React.Component {
       verifyPersistenceSuccess,
       verifyPersistenceError,
       verifyPersistenceMessage,
+      verifySecondaryPersistenceSuccess,
+      verifySecondaryPersistenceError,
+      verifySecondaryPersistenceMessage,
       verifyCameraSuccess,
       verifyCameraError,
       verifyCameraErrorMessage,
@@ -546,6 +618,7 @@ class Settings extends React.Component {
       verifyOnvifErrorMessage,
       loadingCamera,
       loading,
+      loadingSecondary,
       loadingHub,
     } = this.state;
 
@@ -798,6 +871,20 @@ class Settings extends React.Component {
             )} :${verifyPersistenceMessage}`}
           />
         )}
+        {verifySecondaryPersistenceSuccess && (
+          <InfoBar
+            type="success"
+            message={t('settings.info.verify_persistence_success')}
+          />
+        )}
+        {verifySecondaryPersistenceError && (
+          <InfoBar
+            type="alert"
+            message={`${t(
+              'settings.info.verify_persistence_error'
+            )} :${verifySecondaryPersistenceMessage}`}
+          />
+        )}
         <div className="stats grid-container --two-columns">
           <div>
             {/* General settings block */}
@@ -2508,6 +2595,140 @@ class Settings extends React.Component {
                 </BlockFooter>
               </Block>
             )}
+
+            {/* Secondary Vault block */}
+            {showPersistenceSection && config.cloud === this.KERBEROS_VAULT && (
+              <Block>
+                <BlockHeader>
+                  <h4>{t('settings.persistence.secondary_persistence')}</h4>
+                </BlockHeader>
+                <BlockBody>
+                  <p>
+                    {t(
+                      'settings.persistence.description_secondary_persistence'
+                    )}
+                  </p>
+                  <Input
+                    noPadding
+                    label={t('settings.persistence.kerberosvault_apiurl')}
+                    placeholder={t(
+                      'settings.persistence.kerberosvault_description_apiurl'
+                    )}
+                    value={
+                      config.kstorage_secondary
+                        ? config.kstorage_secondary.uri
+                        : ''
+                    }
+                    onChange={(value) =>
+                      this.onUpdateField(
+                        'kstorage_secondary',
+                        'uri',
+                        value,
+                        config.kstorage_secondary
+                      )
+                    }
+                  />
+                  <Input
+                    noPadding
+                    label={t('settings.persistence.kerberosvault_provider')}
+                    placeholder={t(
+                      'settings.persistence.kerberosvault_description_provider'
+                    )}
+                    value={
+                      config.kstorage_secondary
+                        ? config.kstorage_secondary.provider
+                        : ''
+                    }
+                    onChange={(value) =>
+                      this.onUpdateField(
+                        'kstorage_secondary',
+                        'provider',
+                        value,
+                        config.kstorage_secondary
+                      )
+                    }
+                  />
+                  <Input
+                    noPadding
+                    label={t('settings.persistence.kerberosvault_directory')}
+                    placeholder={t(
+                      'settings.persistence.kerberosvault_description_directory'
+                    )}
+                    value={
+                      config.kstorage_secondary
+                        ? config.kstorage_secondary.directory
+                        : ''
+                    }
+                    onChange={(value) =>
+                      this.onUpdateField(
+                        'kstorage_secondary',
+                        'directory',
+                        value,
+                        config.kstorage_secondary
+                      )
+                    }
+                  />
+                  <Input
+                    type="password"
+                    iconright="activity"
+                    label={t('settings.persistence.kerberosvault_accesskey')}
+                    placeholder={t(
+                      'settings.persistence.kerberosvault_description_accesskey'
+                    )}
+                    value={
+                      config.kstorage_secondary
+                        ? config.kstorage_secondary.access_key
+                        : ''
+                    }
+                    onChange={(value) =>
+                      this.onUpdateField(
+                        'kstorage_secondary',
+                        'access_key',
+                        value,
+                        config.kstorage_secondary
+                      )
+                    }
+                  />
+                  <Input
+                    type="password"
+                    iconright="activity"
+                    label={t('settings.persistence.kerberosvault_secretkey')}
+                    placeholder={t(
+                      'settings.persistence.kerberosvault_description_secretkey'
+                    )}
+                    value={
+                      config.kstorage_secondary
+                        ? config.kstorage_secondary.secret_access_key
+                        : ''
+                    }
+                    onChange={(value) =>
+                      this.onUpdateField(
+                        'kstorage_secondary',
+                        'secret_access_key',
+                        value,
+                        config.kstorage_secondary
+                      )
+                    }
+                  />
+                </BlockBody>
+                <BlockFooter>
+                  <Button
+                    label={t('settings.persistence.verify_connection')}
+                    disabled={loadingSecondary}
+                    onClick={this.verifySecondaryPersistenceSettings}
+                    type={loadingSecondary ? 'neutral' : 'default'}
+                    icon="verify"
+                  />
+                  <Button
+                    label="Save"
+                    type="submit"
+                    onClick={this.saveConfig}
+                    buttonType="submit"
+                    icon="pencil"
+                  />
+                </BlockFooter>
+              </Block>
+            )}
           </div>
         </div>
       </div>
@@ -2532,6 +2753,8 @@ const mapDispatchToProps = (dispatch /* , ownProps */) => ({
     dispatch(verifyHub(config, success, error)),
   dispatchVerifyPersistence: (config, success, error) =>
     dispatch(verifyPersistence(config, success, error)),
+  dispatchVerifySecondaryPersistence: (config, success, error) =>
+    dispatch(verifySecondaryPersistence(config, success, error)),
   dispatchGetConfig: (callback) => dispatch(getConfig(callback)),
   dispatchUpdateConfig: (field, value) => dispatch(updateConfig(field, value)),
   dispatchSaveConfig: (config, success, error) =>
@@ -2549,6 +2772,7 @@ Settings.propTypes = {
   images: PropTypes.array.isRequired,
   dispatchVerifyHub: PropTypes.func.isRequired,
   dispatchVerifyPersistence: PropTypes.func.isRequired,
+  dispatchVerifySecondaryPersistence: PropTypes.func.isRequired,
   dispatchGetConfig: PropTypes.func.isRequired,
   dispatchUpdateConfig: PropTypes.func.isRequired,
   dispatchSaveConfig: PropTypes.func.isRequired,