Added private data specifier descriptor

astits/main.go

@@ -421,6 +421,8 @@ func descriptorToString(d *astits.Descriptor) string {
 			os = append(os, fmt.Sprintf("country: %s | rating: %d | minimum age: %d", i.CountryCode, i.Rating, i.MinimumAge()))
 		}
 		return "[Parental rating] " + strings.Join(os, " - ")
+	case astits.DescriptorTagPrivateDataSpecifier:
+		return fmt.Sprintf("[Private data specifier] specifier: %d", d.PrivateDataSpecifier.Specifier)
 	case astits.DescriptorTagService:
 		return fmt.Sprintf("[Service] service %s | provider: %s", d.Service.Name, d.Service.Provider)
 	case astits.DescriptorTagShortEvent:

data_psi.go

@@ -243,7 +243,7 @@ func psiTableType(tableID int) string {
 		return PSITableTypeTOT
 	}
 	// TODO Remove this log
-	astilog.Debugf("unlisted PSI table ID %d", tableID)
+	astilog.Debugf("astits: unlisted PSI table ID %d", tableID)
 	return PSITableTypeUnknown
 }
 

descriptor.go

@@ -29,6 +29,7 @@ const (
 	DescriptorTagMaximumBitrate             = 0xe
 	DescriptorTagNetworkName                = 0x40
 	DescriptorTagParentalRating             = 0x55
+	DescriptorTagPrivateDataSpecifier       = 0x5f
 	DescriptorTagService                    = 0x48
 	DescriptorTagShortEvent                 = 0x4d
 	DescriptorTagStreamIdentifier           = 0x52
@@ -88,6 +89,7 @@ type Descriptor struct {
 	MaximumBitrate             *DescriptorMaximumBitrate
 	NetworkName                *DescriptorNetworkName
 	ParentalRating             *DescriptorParentalRating
+	PrivateDataSpecifier       *DescriptorPrivateDataSpecifier
 	Service                    *DescriptorService
 	ShortEvent                 *DescriptorShortEvent
 	StreamIdentifier           *DescriptorStreamIdentifier
@@ -427,7 +429,7 @@ func newDescriptorExtension(i []byte) (d *DescriptorExtension) {
 		d.SupplementaryAudio = newDescriptorExtensionSupplementaryAudio(b)
 	default:
 		// TODO Remove this log
-		astilog.Debugf("unlisted extension tag 0x%x", d.Tag)
+		astilog.Debugf("astits: unlisted extension tag 0x%x", d.Tag)
 	}
 	return
 }
@@ -590,6 +592,15 @@ func newDescriptorParentalRating(i []byte) (d *DescriptorParentalRating) {
 	return
 }
 
+// DescriptorPrivateDataSpecifier represents a private data specifier descriptor
+type DescriptorPrivateDataSpecifier struct {
+	Specifier uint32
+}
+
+func newDescriptorPrivateDataSpecifier(i []byte) *DescriptorPrivateDataSpecifier {
+	return &DescriptorPrivateDataSpecifier{Specifier: uint32(i[0])<<24 | uint32(i[1])<<16 | uint32(i[2])<<8 | uint32(i[3])}
+}
+
 // DescriptorService represents a service descriptor
 // Page: 96 | Chapter: 6.2.33 | Link: https://www.dvb.org/resources/public/standards/a38_dvb-si_specification.pdf
 type DescriptorService struct {
@@ -811,6 +822,8 @@ func parseDescriptors(i []byte, offset *int) (o []*Descriptor) {
 					d.NetworkName = newDescriptorNetworkName(b)
 				case DescriptorTagParentalRating:
 					d.ParentalRating = newDescriptorParentalRating(b)
+				case DescriptorTagPrivateDataSpecifier:
+					d.PrivateDataSpecifier = newDescriptorPrivateDataSpecifier(b)
 				case DescriptorTagService:
 					d.Service = newDescriptorService(b)
 				case DescriptorTagShortEvent:
@@ -827,7 +840,7 @@ func parseDescriptors(i []byte, offset *int) (o []*Descriptor) {
 					d.VBITeletext = newDescriptorTeletext(b)
 				default:
 					// TODO Remove this log
-					astilog.Debugf("unlisted descriptor tag 0x%x", d.Tag)
+					astilog.Debugf("astits: unlisted descriptor tag 0x%x", d.Tag)
 				}
 				*offset += int(d.Length)
 			}

descriptor_test.go

@@ -23,7 +23,7 @@ func descriptorsBytes(w *astibinary.Writer) {
 func TestParseDescriptor(t *testing.T) {
 	// Init
 	w := astibinary.New()
-	w.Write(uint16(211)) // Descriptors length
+	w.Write(uint16(217)) // Descriptors length
 	// AC3
 	w.Write(uint8(DescriptorTagAC3)) // Tag
 	w.Write(uint8(9))                // Length
@@ -191,6 +191,10 @@ func TestParseDescriptor(t *testing.T) {
 	w.Write("1")                          // AVC still present
 	w.Write("1")                          // AVC 24 hour picture flag
 	w.Write("000000")                     // Reserved
+	// Private data specifier
+	w.Write(uint8(DescriptorTagPrivateDataSpecifier)) // Tag
+	w.Write(uint8(4))                                 // Length
+	w.Write(uint32(128))                              // Private data specifier
 
 	// Assert
 	var offset int
@@ -334,4 +338,7 @@ func TestParseDescriptor(t *testing.T) {
 		LevelIDC:             2,
 		ProfileIDC:           1,
 	})
+	assert.Equal(t, *ds[19].PrivateDataSpecifier, DescriptorPrivateDataSpecifier{
+		Specifier: 128,
+	})
 }