gistfile1.fs

module SocketPolicyServer

type TcpListener = System.Net.Sockets.TcpListener
type IPAddress = System.Net.IPAddress
type HttpListenerRequest = System.Net.HttpListenerRequest

open System.Threading.Tasks
open System.Threading

let StartPolicyServer (gamePort:int) (policyServerPort:int) =
    let PolicyString = 
        [|
            "<?xml version=\"1.0\"?>"
            "<cross-domain-policy>"
            "   <allow-access-from domain=\"*\" to-ports=\"" + (string gamePort) + "\"/>"
            "</cross-domain-policy>"
        |] |> String.concat ""

    let responseBuffer = System.Text.Encoding.UTF8.GetBytes(PolicyString)
    let PolicyRequestString = "<policy-file-request/>"    

    let listener = new TcpListener(IPAddress.Any, policyServerPort)
    let prefix = "http://localhost:" + (string policyServerPort) + "/"

    listener.Start()
    let task = async {
        while true do
            let! client = listener.AcceptTcpClientAsync() |> Async.AwaitTask
            let task = async {
                let stream = client.GetStream()

                use cts = new CancellationTokenSource()
                let timer:(Async<byte[] option>) = async {
                    do! Async.Sleep(5000)
                    return None
                }
                let task = async {
                    let! buffer = stream.AsyncRead PolicyRequestString.Length
                    return Some buffer
                }

                let tasks = ([|task; timer|] |> Seq.map Async.StartAsTask)
                let! maybeBuffer = (Task.WhenAny tasks |> Async.AwaitTask)
              
                match maybeBuffer.Result with
                | Some _ ->
                    printfn "Win"
                    do! stream.AsyncWrite responseBuffer
                | None ->
                    printfn "Lose"

                client.Close()
            }
            Async.Start task
    }

    (listener, task)