psi: wrote first tests, for simple pat and pmt tables. Pat writing seems to be working

stream/mts/psi/psi.go

@@ -20,7 +20,7 @@ var (
 
 		// syntax section
 		0x00, 0x01, // table id extension
-		0xc1, // reserved bits:3|version:5|use now:1 1100 0001
+		0xc1, // reserved bits:2|version:5|use now:1 1100 0001
 		0x00, // section number
 		0x00, // last section number
 		// table data
@@ -141,12 +141,7 @@ func ReadPSI(data []byte) *PSI {
 	pos := 0
 	psi.Pf = data[pos]
 	if psi.Pf != 0 {
-		psi.Pfb = make([]byte, 0, psi.Pf)
+		panic("No support for pointer filler bytes")
-		pos++
-		for i := 0; i < int(psi.Pf); i++ {
-			psi.Pfb = append(psi.Pfb, data[pos])
-			pos++
-		}
 	}
 	psi.Tid = data[pos]
 	pos++
@@ -242,17 +237,16 @@ func readEssd(data []byte) *ESSD {
 
 // Bytes outputs a byte slice representation of the PSI
 func (p *PSI) Bytes() []byte {
-	l := 1 + len(p.Pfb)
+	out := make([]byte, 4)
-	out := make([]byte, l+PSIDefLen)
 	out[0] = p.Pf
-	for i, b := range p.Pfb {
+	if p.Pf != 0 {
-		out[1+i] = b
+		panic("No support for pointer filler bytes")
 	}
-	out[l] = p.Tid
+	out[1] = p.Tid
-	out[l+1] = 0x80 | 0x40 | 0x30 | (0x03 & byte(p.Sl>>8))
+	out[2] = 0x80 | 0x30 | (0x03 & byte(p.Sl>>8))
-	out[l+2] = byte(p.Sl)
+	out[3] = byte(p.Sl)
 	out = append(out, p.Tss.Bytes()...)
-	crc32 := crc32_Update(0xffffffff, crc32_MakeTable(bits.Reverse32(crc32.IEEE)), out[l:])
+	crc32 := crc32_Update(0xffffffff, crc32_MakeTable(bits.Reverse32(crc32.IEEE)), out[3:])
 	out = append(out, make([]byte, 0, 4)...)
 	out = append(out, byte(crc32>>24))
 	out = append(out, byte(crc32>>16))

stream/mts/psi/psi_test.go

@@ -1,6 +1,7 @@
 package psi
 
 import (
+	"bytes"
 	"testing"
 )
 
@@ -19,7 +20,7 @@ var (
 			Lsn:  0,
 			Sd: &PAT{
 				Pn:    uint16(0x01),
-				Pmpid: 16,
+				Pmpid: uint16(0x1000),
 			},
 		},
 	}
@@ -35,18 +36,32 @@ var (
 			Sn:   0,
 			Lsn:  0,
 			Sd: &PMT{
-				Pcrpid: 16, // wrong
+				Pcrpid: 0x1100, // wrong
 				Pil:    0,
 				Essd: &ESSD{
 					St:   0x1b,
-
+					Epid: 0x0100,
-				}
+					Esil: 0x00,
-			}
+				},
-		}
+			},
-		}
+		},
 	}
 )
 
-func TestReadPSI1(t *testing.T) {
+func TestWritePAT1(t *testing.T) {
-
+	got := patPsi.Bytes()
+	// Remove crc32
+	got = got[:len(got)-4]
+	if !bytes.Equal(StdPat, got[:len(got)-4]) {
+		t.Errorf("Incorrect output, wanted: %v, got: %v", StdPat, got)
+	}
+}
+
+func TestWritePMT1(t *testing.T) {
+	got := pmtPsi.Bytes()
+	// Remove crc32
+	got = got[:len(got)-4]
+	if !bytes.Equal(StdPmt, got[:len(got)-4]) {
+		t.Errorf("Incorrect output, wanted: %v, got: %v", StdPmt, got)
+	}
 }