using System;
using System.Windows;
using System.Net.Sockets;
using System.Threading.Tasks;
using System.IO;
using System.Net;
using System.Text;

namespace testEncoderRecieve
{
    public partial class MainWindow : Window
    {
        public MainWindow()
        {
            InitializeComponent();
            this.Loaded += new RoutedEventHandler(MainWindow_Loaded);
        }

        private Task ServerThread;
        private TcpListener server;
        void MainWindow_Loaded(object sender, RoutedEventArgs e)
        {
            ServerThread = new Task(startServerThreaed);
            server = new TcpListener(System.Net.IPAddress.Parse("127.0.0.1"),5555);
            //
            ServerThread.Start();
        }
        void startServerThreaed()
        {
            //서버 스레드가 시작되고 서버가 시작되었다.
            Console.WriteLine("startServerThread");
            server.Start();

            //컨텐츠 버퍼와 헤더버퍼를 생성하였다.
            Byte[] buffer = new Byte[64];
            Byte[] headerBuffer = new Byte[128];
            int testCount = 0;
            while (true)
            {
                TcpClient client = server.AcceptTcpClient();
                NetworkStream netStream = client.GetStream();
                //netStream 에서 지정된 해더 바이트버퍼 만큼읽어서
                //해더정보를 입수한다.
                //그리고 netStream의 포지션은 128 이 되었다.
                netStream.Read(headerBuffer, 0, headerBuffer.Length);
                String rowHeader = Encoding.ASCII.GetString(headerBuffer);

                //String.Trim 을 이용해 불필요한 공백을 
                //제거하고 딱 필요한 헤더만 추출했다.
                string header = rowHeader.Trim();
                FileInfo fInfo = new FileInfo(header);

                //이전과 같이 파일 스트림을 생성하였고,
                //파일경로로는 헤더에서 넘어온 정보를 사용하였다.
                //그리고 여기서 읽을 netStream의 포지션은 129부터 이다.
                FileStream fs = new FileStream(fInfo.FullName, FileMode.OpenOrCreate, FileAccess.Write);
                int i = 0;
                while ((i = netStream.Read(buffer, 0, buffer.Length)) > 0)
                {
                    fs.Write(buffer, 0, i);
                }
                fs.Close();
                netStream.Close();
                client.Close();
                ++testCount;
            }
        }
    }
}

package {
    import flash.events.Event;
    import flash.net.Socket;
    import flash.utils.ByteArray;
    import flash.display.Bitmap;
    import flash.display.BitmapData;
    import flash.display.Sprite;
    import flash.events.MouseEvent;
    import flash.media.Camera;
    import flash.media.Video;
    /**
     * @author superSc_PC
     */
     
    [SWF(width = "1000")]
    public class Main extends Sprite
    {
        private var cam : Camera;
        private var vid : Video;
        private var captureBitmap : Bitmap;
        
        private var socket : Socket;
        private var headerBufferSize : int = 128;
        private var header : ByteArray = new ByteArray();
        private var captureByte : ByteArray;
        public function Main()
        {
            //필요한것들을 생성했다.
            cam = Camera.getCamera();
            vid = new Video();
            vid.attachCamera(cam);
            captureBitmap = new Bitmap(new BitmapData(vid.width, vid.height));
            captureBitmap.x = vid.width;
            addChild(vid);
            addChild(captureBitmap);
            stage.addEventListener(MouseEvent.CLICK    , takePic);
            
            socket = new Socket();
            socket.addEventListener(Event.CONNECT, connectFn);
            
            //header 에 필요한정보를 입력하였다.
            //그리고 바이트의 공백을 매꾸기 위해 while루프로 쓰레기 정보들을
            //입력하였고 마지막 바이트로 줄바꿈"\n"을 입력 하였다.
            header.writeUTFBytes("d:/testAS.png");
            while(header.position < headerBufferSize-1)
            {
                header.writeUTFBytes(" ");
            }
            header.writeUTFBytes("\n");
        }
        
        
        private function connectFn(event : Event) : void {
            if (captureByte != null && captureByte.length > 0)
            {
                //이전과 다르게 소켓에 연달아 2개의 바이트들을 보낸다.
                //처음에는 헤더정보를 다음엔 캡쳐된 png를 보낸다.
                //역시나 보내고 난뒤에 소켓을 죽인다.
                socket.writeBytes(header);
                socket.writeBytes(captureByte);
                socket.flush();
                socket.close();
            }
        }

        private function takePic(event : MouseEvent) : void {
            captureBitmap.bitmapData.draw(vid);
            captureByte = PngEncoder.encode(captureBitmap.bitmapData);
            captureByte.position = 0;
            if(socket.connected == false)
            {
                socket.connect("localhost", 5555);
            }
        }
    }
}