Quick fix

The incrementing counter and related condition were unnecessary and have been removed. This simplifies the callback function and improves code clarity without altering functionality.

cmd/dev-client/main.go

@@ -116,16 +116,8 @@ func handleLogin(sPack *smart.SmartPackage, pack protocol.Package) (err error) {
 
 	go videoPack.Run()
 
-	i := 0
-
 	videoPack.AddLiveSource(2, func(data []byte) error {
 		fmt.Println("Есть контакт!")
-
-		i++
-
-		if i > 10 {
-			return errors.New("я устал")
-		}
 		return nil
 	})
 

pkg/models/evem.go

@@ -88,3 +88,48 @@ type EventModelGetAlarmingResponse struct {
 	VideoLossAlarmMask   uint `json:"VL_AT"`
 	VideoLossStatusMask  uint `json:"VL_AS"`
 }
+
+// 3.4.1.3
+type EventModelGetAlarmInfoStatusResponse struct {
+	ErrorCode            uint                         `json:"ERRORCODE"`
+	ErrorCause           string                       `json:"ERRORCAUSE"`
+	MotionDetectionAlarm []MotionDetectionAlarmStatus `json:"MD"`
+	IOAlarm              []IOAlarmStatus              `json:"IO"`
+	StorageAlarm         []StorageAlarmStatus         `json:"ST"`
+	CameraCoveredAlarm   []CameraCoveredAlarmStatus   `json:"VS"`
+	VideoLossAlarm       []VideoLossAlarmStatus       `json:"VL"`
+}
+
+// 3.4.1.4.1
+type MotionDetectionAlarmStatus struct {
+	Status uint `json:"ISA"`
+	Mask   uint `json:"LCH"`
+}
+
+// 3.4.1.4.2
+type IOAlarmStatus struct {
+	Status           uint   `json:"ISA"`
+	IONumber         uint   `json:"IONO"`
+	Mask             uint   `json:"LCH"`
+	Name             string `json:"NAME"`
+	NameAbbreviation string `json:"NSER"`
+}
+
+// 3.4.1.4.4
+type CameraCoveredAlarmStatus struct {
+	Status uint `json:"ISA"`
+	Mask   uint `json:"LCH"`
+}
+
+// 3.4.1.4.4
+type VideoLossAlarmStatus struct {
+	Status uint `json:"ISA"`
+	Mask   uint `json:"LCH"`
+}
+
+// 3.4.1.4.21
+type StorageAlarmStatus struct {
+	SID   any  `json:"SID"`
+	Type  uint `json:"ST"`
+	Error uint `json:"E"`
+}

pkg/models/mediastreammodel.go

@@ -51,110 +51,3 @@ type MediaStreamModelControlStreamRequest struct {
 	AudioValid uint       `json:"AUDIOVALID,omitempty"`
 	FrameMode  uint       `json:"FRAMEMODE,omitempty"`
 }
-
-/*
-var ip string = os.Getenv("SERVER_IP")
-
-func (e *Package) MediaRequestDownloadVideo(token int, serial string, session string, camNo int, date string, begin_time string, end_time string, recordID string, serverId int) {
-	e.Payload = map[string]any{
-		"MODULE":    "MEDIASTREAMMODEL",
-		"OPERATION": "REQUESTDOWNLOADVIDEO",
-		"PARAMETER": map[string]any{
-			"PT":         3,
-			"SSRC":       1,
-			"STREAMNAME": "DOWNLOAD" + "_" + serial + "_" + fmt.Sprint(camNo) + "_" + fmt.Sprint(serverId),
-			"STREAMTYPE": 1, // main stream
-			"RECORDID":   recordID,
-			"CHANNEL":    1 << (camNo - 1),
-			"STARTTIME":  date + begin_time,
-			"ENDTIME":    date + end_time,
-			"OFFSETFLAG": 1,
-			"OFFSET":     0,
-			"IPANDPORT":  ip + ":12092",
-			"SERIAL":     token,
-			"DT":         1, // high speed download
-		},
-		"SESSION": session,
-	}
-}
-
-// main server util
-func (e *Package) MediaRequestAliveVideo(token int, camNo int64, Sid string, serial string, quality int64) {
-
-	channel := 0
-
-	if camNo == 1 {
-		channel = 1
-	} else {
-		channel = 1 << (camNo - 1)
-	}
-	e.Payload = map[string]any{
-		"MODULE":    "MEDIASTREAMMODEL",
-		"OPERATION": "REQUESTALIVEVIDEO",
-		"PARAMETER": map[string]any{
-			"AUDIOVALID": 1,
-			"CHANNEL":    channel,
-			"FRAMEMODE":  0,
-			"IPANDPORT":  ip + ":12092",
-			"STREAMNAME": "LIVE" + "_" + serial + "_" + fmt.Sprint(camNo),
-			"STREAMTYPE": quality,
-			"SERIAL":     token,
-		},
-		"SESSION": Sid,
-	}
-}
-
-// main server util
-func (e *Package) MediaRequestRemotePlayback(token int, serial string, session string, camNo int, date string, begin_time string, end_time string, serverId int) {
-	if end_time == "" {
-		e.Payload = map[string]any{
-			"MODULE":    "MEDIASTREAMMODEL",
-			"OPERATION": "REQUESTREMOTEPLAYBACK",
-			"PARAMETER": map[string]any{
-				"STREAMNAME": "PLAYBACK" + "_" + fmt.Sprint(serial) + "_" + fmt.Sprint(camNo) + "_" + fmt.Sprint(serverId),
-				"STREAMTYPE": 1, // main stream
-				"VIDEOTYPE":  2, // common files
-				"CHANNEL":    1 << (camNo - 1),
-				"STARTTIME":  date + begin_time,
-				"IPANDPORT":  ip + ":12092",
-				"SERIAL":     token,
-				"PBST":       0,
-			},
-			"SESSION": session,
-		}
-	} else {
-		e.Payload = map[string]any{
-			"MODULE":    "MEDIASTREAMMODEL",
-			"OPERATION": "REQUESTREMOTEPLAYBACK",
-			"PARAMETER": map[string]any{
-				"STREAMNAME": "PLAYBACK" + "_" + fmt.Sprint(serial) + "_" + fmt.Sprint(camNo) + "_" + fmt.Sprint(serverId),
-				"STREAMTYPE": 1, // main stream
-				"VIDEOTYPE":  2, // common files
-				"CHANNEL":    1 << (camNo - 1),
-				"STARTTIME":  date + begin_time,
-				"ENDTIME":    date + end_time,
-				"IPANDPORT":  ip + ":12092",
-				"SERIAL":     token,
-				"PBST":       0,
-			},
-			"SESSION": session,
-		}
-	}
-}
-
-// main server util
-func (e *Package) ControlRemotePlayback(token int, serial string, session string, camNo int, date string, begin_time string, end_time string, serverId int) {
-	e.Payload = map[string]any{
-		"MODULE":    "MEDIASTREAMMODEL",
-		"OPERATION": "CONTROLREMOTEPLAYBACK",
-		"PARAMETER": map[string]any{
-			"STREAMNAME":  fmt.Sprint(serial) + "_" + fmt.Sprint(camNo) + "_" + fmt.Sprint(serverId),
-			"SERIAL":      token,
-			"PALYBACKCMD": 5,         // main stream
-			"CHANNEL":     268435455, // common files
-		},
-		"SESSION": session,
-	}
-}
-
-*/

pkg/parameters/params.go

@@ -8,6 +8,9 @@ type RIP struct {
 	LN      string // Название линии
 	DID     string // номер водительского удостоверения
 	DNAME   string // ФИО водителя
+	REC     int    // Тип записи видоепотока (0 - беск запись, 1 - запись по событиям, 2 - по расписанию)
+	PREREC  int    // Длительность предтревожной записи
+	POSTREC int    // Длительность послетревожной записи
 }
 
 type VS struct {
@@ -71,9 +74,11 @@ type NEC struct {
 	AEN int // звук (вкл/выкл)
 	VEN int // видео (вкл/выкл)
 	BR  int // битрейт
+	BRM int
 	ECT int // кодировка
 	FR  int // фреймрейт
 	FT  int // тип кадров
+	KFI int
 	QLT int // качество трансляции
 	RST int // разрешение
 }
@@ -95,8 +100,10 @@ type VEC struct {
 	ECT int // кодировка
 	FR  int // фреймрейт
 	QLT int // качество записи
+	RM  int // режим работы
 	AEN int // звук (вкл/выкл)
 	ALT int // качество видео при тревоге
+	BRM int // режим битрейта
 }
 
 type EOSD struct {
@@ -134,6 +141,18 @@ type COSD struct {
 	Y  int
 }
 
+type MAIN struct {
+	VEN uint // 1/0
+	RST uint // разрешение
+	ECT uint // кодировка
+	FR  uint // фреймрейт
+	QLT uint // качество записи
+	RM  uint // режим работы (0 - всегда, 1 - по расписанию, 2 - по тревоге)
+	AEN uint // звук
+	ALT uint // качество видео при тревоге
+	BRM uint // режим битрейта
+}
+
 type IOP struct {
 	EN  int
 	AS  int
@@ -152,6 +171,8 @@ type SAP struct {
 	UN  int
 }
 
+// 7.24.3
+// Alarm processing parameters
 type APR struct {
 	AR ARR
 	SS SS
@@ -167,13 +188,6 @@ type SS struct {
 	EN int
 }
 
-type UAP struct {
-	EN  int
-	AS  int
-	VT  int
-	SDT int
-}
-
 type PVLAS struct {
 	EN  int
 	AS  int
@@ -257,8 +271,10 @@ type MCMS struct {
 	SP []SP // Параметры сервера
 }
 
+// 7.12.1
+// Central server configuration
 type SP struct {
-	EN     int    // Статус сервера
+	EN     int    // Флаг включения
 	CP     int    // Протокол подключения
 	NWT    int    // Способ подключения
 	CS     string // Адрес сервера
@@ -269,7 +285,45 @@ type SP struct {
 	MUPORT int    // UDP-порт медиасервера
 }
 
+// 7.28
+// NVR remote device parameters
+type REDEV struct {
+	EN      int    // Флаг включения
+	LOCK    int    // ???
+	CHL     int    // Номер канала на устройстве
+	RECHL   int    // ???
+	ONLINE  int    // Доступно ли сейчас устройство
+	RETYPE  int    // Тип устройства
+	PROTYPE int    // Тип протокола
+	IPTYPE  int    // Тип IP-адреса (IPv4/IPv6)
+	CONTYPE int    // ???
+	SW      int    // Источник поступаемого сигнала
+	REPORT  int    // Порт камеры
+	REIP    string // IP камеры
+	ID      string // Идентификатор камеры
+	RENAME  string // Название устройства
+	USER    string // Имя пользователя
+	PWD     string // Пароль
+	URL     string // ???
+	CMDPORT uint   // ???
+}
+
+// 7.29
+// Panel emergency alarm
+type UAP struct {
+	EN  int    // Флаг включения
+	AS  int    // Уровень тревоги
+	T   int    // ???
+	VT  int    // ???
+	UN  string // Имя тревоги
+	UO  string // Имя тривоги на экране водителя
+	APR APR    // Параметры обработки тревоги
+	// AP  AP     // Параметры тревоги
+	SDT int // ???
+}
+
 // 7.30
+// Network monitoring status parameters
 type PGDSM struct {
 	PGPS PGPS `json:"PGPS,omitempty"`
 	PDSM PDSM `json:"PDSM,omitempty"`
@@ -286,6 +340,7 @@ type PGPS struct {
 }
 
 // 7.30.2
+// Device status parameter
 type PDSM struct {
 }
 
@@ -304,9 +359,23 @@ type CG struct {
 	AT   uint // Answer automatically when exceed time
 }
 
+type RSI struct {
+	E int64 // End time in seconds
+	S int64 // Start time in seconds
+}
+
+type RCP struct {
+	RSI [][]RSI // Recording type parameters (array for cameras number, 7 for week days)
+}
+
+type RP struct {
+	RCP []RCP // Single channel recording period parameter list
+}
+
 type Setting struct {
 	KEYS      KEYS      `json:"KEYS,omitempty"`
 	RIP       RIP       `json:"RIP,omitempty"`
+	RP        RP        `json:"RP,omitempty"`
 	TIMEP     TIMEP     `json:"TIMEP,omitempty"`
 	ATP       ATP       `json:"ATP,omitempty"`
 	SSP       SSP       `json:"SSP,omitempty"`
@@ -323,6 +392,7 @@ type Setting struct {
 	EOSD      []EOSD    `json:"EOSD,omitempty"`
 	IOP       []IOP     `json:"IOP,omitempty"`
 	SAP       SAP       `json:"SAP,omitempty"`
+	REDEV     []REDEV   `json:"REDEV,omitempty"`
 	UAP       UAP       `json:"UAP,omitempty"`
 	PGDSM     PGDSM     `json:"PGDSM,omitempty"`
 	PVLAS     PVLAS     `json:"PVLAS,omitempty"`

pkg/utils/crypto.go

@@ -6,10 +6,18 @@ import (
 	"encoding/hex"
 )
 
-func GenerateVerifyKey(key string) string {
+func generateHMAC(key string, data string) string {
 	mac := hmac.New(md5.New, []byte(key))
 
-	mac.Write([]byte(key))
+	mac.Write([]byte(data))
 
 	return hex.EncodeToString(mac.Sum(nil))
 }
+
+func GenerateVerifyKey(key string) string {
+	return generateHMAC(key, key)
+}
+
+func GeneratePasswordHash(password string) string {
+	return generateHMAC("streaming", password)
+}