/*
NAME
  rtmp.go

DESCRIPTION
  See Readme.md

AUTHORS
  Saxon Nelson-Milton <saxon@ausocean.org>
  Dan Kortschak <dan@ausocean.org>

LICENSE
  rtmp.go is Copyright (C) 2017 the Australian Ocean Lab (AusOcean)

  It is free software: you can redistribute it and/or modify them
  under the terms of the GNU General Public License as published by the
  Free Software Foundation, either version 3 of the License, or (at your
  option) any later version.

  It is distributed in the hope that it will be useful, but WITHOUT
  ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
  for more details.

  You should have received a copy of the GNU General Public License
  along with revid in gpl.txt. If not, see http://www.gnu.org/licenses.

  Derived from librtmp under the GNU Lesser General Public License 2.1
  Copyright (C) 2005-2008 Team XBMC http://www.xbmc.org
  Copyright (C) 2008-2009 Andrej Stepanchuk
  Copyright (C) 2009-2010 Howard Chu
*/

package rtmp

import (
	"errors"
	"fmt"
	"net"
	"time"
)

// int RTMP_Connect(RTMP *r, RTMPPacket* cp);
// rtmp.c +1032
func C_RTMP_Connect(r *C_RTMP, cp *C_RTMPPacket) error {
	if r.Link.host == "" {
		return errors.New("Empty host")
	}

	hostPort := fmt.Sprintf("%s:%d", r.Link.host, r.Link.port)
	addr, err := net.ResolveTCPAddr("tcp4", hostPort)
	if err != nil {
		return err
	}
	r.m_sb.conn, err = net.DialTCP("tcp4", nil, addr)
	if err != nil {
		return err
	}

	r.m_sb.timeout = r.Link.timeout
	if C_RTMP_Connect1(r, cp) {
		return nil
	} else {
		return errors.New("RTMP connection failed")
	}
}

// int SocksNegotiate(RTMP* r);
// rtmp.c +1062
// DELETED

// int RTMPSockBuf_Fill(RTMPSockBuf* sb);
// rtmp.c +4253
func C_RTMPSockBuf_Fill(sb *C_RTMPSockBuf) (int, error) {
	if sb.sb_size == 0 {
		sb.sb_start = 0
	}
	err := sb.conn.SetReadDeadline(time.Now().Add(time.Second * time.Duration(sb.timeout)))
	if err != nil {
		return -1, err
	}
	n, err := sb.conn.Read(sb.sb_buf[sb.sb_start+sb.sb_size:])
	if err != nil {
		return 0, err
	}
	sb.sb_size += n
	return n, nil
}

// int RTMPSockBuf_Send(RTMPSockBuf* sb, const char* buf, int len);
// rtmp.c +4297
// TODO replace send with golang net connection send
func C_RTMPSockBuf_Send(sb *C_RTMPSockBuf, buf []byte) (int, error) {
	err := sb.conn.SetWriteDeadline(time.Now().Add(time.Second * time.Duration(sb.timeout)))
	if err != nil {
		return -1, err
	}
	n, err := sb.conn.Write(buf)
	if err != nil {
		return -1, err
	}
	return n, nil
}

// int
// RTMPSockBuf_Close(RTMPSockBuf *sb)
// rtmp.c +4369
func C_RTMPSockBuf_Close(sb *C_RTMPSockBuf) error {
	if sb.conn != nil {
		err := sb.conn.Close()
		sb.conn = nil
		if err != nil {
			return err
		}
	}
	return nil
}