rtp_server function

void rtp_server(String ip, int port, String filename)

Implementation

void rtp_server(String ip, int port, String filename) {
  RawDatagramSocket.bind(InternetAddress(ip), port)
      .then((RawDatagramSocket socket) {
    print('UDP Echo ready to receive');
    print('${socket.address.address}:${socket.port}');

    List<Uint8List> buffer = [];

    bool timerFlag = false;

    RtpState state = RtpState();

    callback() {
      //if (counter == 0) {
      List<int> record = [];
      if (buffer.isEmpty) {
        return;
      } else {
        print("RTP server state: ${state.state}");
        if (state.state == RTP_STATE.RTP_FINISHED &&
            state.rtpSampleSize == buffer.length) {
          print("RTP server state changed to ${state.state}");
          for (var element in buffer) {
            for (int x = 0; x < element.lengthInBytes; x++) {
              record.add(element[x]);
            }
          }

          var buf = Uint8List.fromList(record);

          print("Writing to file");
          final pcmWave = Pcmtowave.pcmToWav(buf, 8000, 1);

          final f = File("$filename.wav");

          f.writeAsBytesSync(pcmWave);

          //counter--;
          //if (counter == 0) {
          print('Cancel timer');
          //timer.cancel(); // Stops the repeating timer
          socket.close();
          buffer = [];
          record = [];
        }
        if (state.state == RTP_STATE.RTP_RECEIVED &&
            state.rtpSampleSize == buffer.length) {
          state.state = RTP_STATE.RTP_FINISHED;
          state.rtpSampleSize = buffer.length;
          print("RTP server state changed to ${state.state}");
        }
        if (state.state == RTP_STATE.RTP_RECEIVED &&
            state.rtpSampleSize != buffer.length) {
          state.state = RTP_STATE.RTP_RECEIVED;
          state.rtpSampleSize = buffer.length;
          print("RTP server state changed to ${state.state}");
        }
        if (state.state == RTP_STATE.INITIALISED) {
          state.state = RTP_STATE.RTP_RECEIVED;
          state.rtpSampleSize = buffer.length;
          print("RTP server state changed to ${state.state}");
        }
      }

      //}
      //}
    }

    final codec = DartG711Codec.g711a();

    //Timer t = setTimeout(callback, 30);

    const oneSec = Duration(seconds: 30);
    Timer.periodic(oneSec, (Timer t) {
      callback();
    });
    timerFlag = true;

    socket.listen((RawSocketEvent e) {
      Datagram? d = socket.receive();
      if (d != null) {
        //var data = String.fromCharCode(d.data);
        print('Datagram from ${d.address.address}:${d.port}');
        RTPpacket rtPpacket = RTPpacket.fromList(d.data, d.data.lengthInBytes);

        var sample = codec.decode(rtPpacket.payload);
        buffer.add(sample);
        //counter = 1;

        //if (timerFlag) {
        //clearTimeout(t);
        //timerFlag = false;
        // }
      } else {
        //counter = 0;
        //if (!timerFlag) {
        //t = setTimeout(callback, 30);
        // timerFlag = true;
        //}
      }
      //t = setTimeout(callback, 30);
    });
  });

  //wsSipServer ws = wsSipServer("10.100.54.52", 8080);
}