handshake_test.go

package gortmp

import (
	"bytes"
	"errors"
	"fmt"
	"testing"
)

const (
	TEST_FMS_URL = "rtmp://192.168.20.111/live"
)

func testC1(c1 []byte, offset1 bool) (uint32, error) {
	var clientDigestOffset uint32
	if offset1 {
		clientDigestOffset = CalcDigestPos(c1, 8, 728, 12)
	} else {
		clientDigestOffset = CalcDigestPos(c1, 772, 728, 776)
	}
	// Create temp buffer
	tmpBuf := new(bytes.Buffer)
	tmpBuf.Write(c1[:clientDigestOffset])
	tmpBuf.Write(c1[clientDigestOffset+SHA256_DIGEST_LENGTH:])
	// Generate the hash
	tempHash, err := HMACsha256(tmpBuf.Bytes(), GENUINE_FP_KEY[:30])
	if err != nil {
		return 0, errors.New(fmt.Sprintf("HMACsha256 err: %s\n", err.Error()))
	}
	expect := c1[clientDigestOffset : clientDigestOffset+SHA256_DIGEST_LENGTH]
	if bytes.Compare(expect, tempHash) != 0 {
		return 0, errors.New(fmt.Sprintf("C1\nExpect % 2x\nGot    % 2x\n",
			expect,
			tempHash))
	}
	return clientDigestOffset, nil
}

func checkC2(s1, c2 []byte) (uint32, error) {
	server_pos := ValidateDigest(s1, 8, GENUINE_FMS_KEY[:36])
	if server_pos == 0 {
		server_pos = ValidateDigest(s1, 772, GENUINE_FMS_KEY[:36])
		if server_pos == 0 {
			return 0, errors.New("Server response validating failed")
		}
	}

	digest, err := HMACsha256(s1[server_pos:server_pos+SHA256_DIGEST_LENGTH], GENUINE_FP_KEY)
	CheckError(err, "Get digest from s1 error")

	signature, err := HMACsha256(c2[:RTMP_SIG_SIZE-SHA256_DIGEST_LENGTH], digest)
	CheckError(err, "Get signature from c2 error")

	if bytes.Compare(signature, c2[RTMP_SIG_SIZE-SHA256_DIGEST_LENGTH:]) != 0 {
		return 0, errors.New("Server signature mismatch")
	}
	return server_pos, nil
}

var (
	testCases = [][]byte{
		vlc_c1, vlc_c2, vlc_s1,
		fp_c1, fp_c2, fp_s1,
		my_c1, my_c2, my_s1,
	}
)

func TestHandshake(t *testing.T) {
	InitTestLogger()
	caseNum := len(testCases) / 3
	for i := 0; i < caseNum; i++ {
		c1 := testCases[i*3]
		c2 := testCases[i*3+1]
		s1 := testCases[i*3+2]

		if _, err := testC1(c1, true); err != nil {
			if _, err = testC1(c1, false); err != nil {
				t.Error(err.Error())
			}
		}

		digestPosServer := CalcDigestPos(s1, 8, 728, 12)
		digestResp, err := HMACsha256(s1[digestPosServer:digestPosServer+SHA256_DIGEST_LENGTH], GENUINE_FP_KEY)
		if err != nil {
			t.Fatalf("Generate C2 HMACsha256 Offset1 err: %s\n", err.Error())
		}
		signatureResp, err := HMACsha256(c2[:RTMP_SIG_SIZE-SHA256_DIGEST_LENGTH], digestResp)
		if err != nil {
			t.Fatalf("Generate C2 HMACsha256 C2 err: %s\n", err.Error())
		}
		expect := c2[RTMP_SIG_SIZE-SHA256_DIGEST_LENGTH:]
		if bytes.Compare(expect, signatureResp) != 0 {
			t.Fatalf("C2\nExpect % 2x\nGot    % 2x\n",
				expect,
				signatureResp)
		}

		if _, err = checkC2(s1, c2); err != nil {
			t.Errorf("checkC2(%d) err: %s\n", i, err.Error())
		}
	}
}