feat: add timestamp util

opcua/enc/decoder.go

@@ -165,7 +165,7 @@
 		}
 		serviceType, ok := messageBody.TypeId.Identifier.(uint16)
 		if !ok {
-			return errors.New("know type service")
+			return errors.New("unknown type service")
 		}
 
 		switch uamsg.ServiceTypeEnum(serviceType) {
@@ -198,7 +198,7 @@
 			}
 			messageBody.Service = service
 		default:
-			return errors.New("know type service")
+			return errors.New("unknown type service")
 		}
 		msg.MessageBody = messageBody
 	default:

opcua/enc/special_encoder.go

@@ -11,11 +11,11 @@
 )
 
 func StringEncoder(v interface{}) ([]byte, error) {
-	buff := bytes.NewBuffer(nil)
 	value, ok := v.(string)
 	if !ok {
 		return nil, fmt.Errorf("error type of string, %v", reflect.TypeOf(v).Name())
 	}
+	buff := bytes.NewBuffer(nil)
 	length := int32(len(value))
 	if length == 0 {
 		length = -1
@@ -29,11 +29,11 @@
 }
 
 func ByteStringEncoder(v interface{}) ([]byte, error) {
-	buff := bytes.NewBuffer(nil)
 	value, ok := v.([]byte)
 	if !ok {
 		return nil, fmt.Errorf("error type of bytestring, %v", reflect.TypeOf(v).Name())
 	}
+	buff := bytes.NewBuffer(nil)
 	// ByteString's empty and null encodings are inconsistent
 	length := int32(len(value))
 	if length == 0 && value == nil {
@@ -48,7 +48,6 @@
 }
 
 func GuidEncoder(v interface{}) ([]byte, error) {
-	buff := bytes.NewBuffer(nil)
 	var guid uamsg.Guid
 	temp, ok := v.(*uamsg.Guid)
 	if !ok {
@@ -59,6 +58,7 @@
 		temp = &guid
 	}
 	guid = *temp
+	buff := bytes.NewBuffer(nil)
 	err := binary.Write(buff, binary.LittleEndian, guid.Data1)
 	if err != nil {
 		return nil, err
@@ -79,7 +79,6 @@
 }
 
 func QualifiedNameEncoder(v interface{}) ([]byte, error) {
-	buff := bytes.NewBuffer(nil)
 	var qualifiedName uamsg.QualifiedName
 	temp, ok := v.(*uamsg.QualifiedName)
 	if !ok {
@@ -90,6 +89,7 @@
 		temp = &qualifiedName
 	}
 	qualifiedName = *temp
+	buff := bytes.NewBuffer(nil)
 	err := binary.Write(buff, binary.LittleEndian, qualifiedName.NamespaceIndex)
 	if err != nil {
 		return nil, err

opcua/secure_channel.go

@@ -0,0 +1,4 @@
+package opcua
+
+type SecureChannel struct {
+}

opcua/uamsg/generic.go

@@ -1,5 +1,12 @@
 package uamsg
 
+const (
+	MessageSecurityModeInvalid        MessageSecurityModeEnum = 0
+	MessageSecurityModeNone           MessageSecurityModeEnum = 1
+	MessageSecurityModeSign           MessageSecurityModeEnum = 2
+	MessageSecurityModeSignAndEncrypt MessageSecurityModeEnum = 3
+)
+
 type (
 	SecurityTokenRequestType uint32
 	MessageSecurityModeEnum  uint32

opcua/util/timestamp.go

@@ -0,0 +1,17 @@
+package util
+
+import "time"
+
+const (
+	// OpcuaDateTimeTicksToUnixEpoch ((1970 - 1601) * 365 + 3 * 24 + 17) * 86400 * 10 * 1000 * 1000
+	OpcuaDateTimeTicksToUnixEpoch int64 = 116444736000000000
+)
+
+func GetCurrentUaTimestamp() uint64 {
+	ticks := time.Now().UTC().UnixNano()/100 + OpcuaDateTimeTicksToUnixEpoch
+	if ticks < 0 {
+		ticks = 0
+	}
+
+	return uint64(ticks)
+}