{"header":{"message":"Voice call session management done","description":null,"timestamp":"2022-04-23T12:11:27Z","authors":[{"email":"john.razor97@gmail.com","name":"quartz55"}]},"hash":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC","authors":[],"deps":{"hashes":[["VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC","Voice call session management done"],["AA",null],["AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC","Core working"],["P35HCXDOT4NKKPTM6OMKEVKBLB3VLEODS7LNKRG7777RLOFDGU2AC","MVP Voice (#1)"],["WWOXTYSKCYOBP6H7OQNLZJ22O6WVWCHQNJTHBRQ3ZEJH2KSQF3UAC","Remade opus bindings without ppx_cstubs"],["B22T6OTOYMTCUQJGC4DVNB2FNKIYQHLU3I7H2OBWTNLX5WT2Y5RQC","Cleanup + Model types & (de)serialzers"],["SM5TELBWYEM67PHIK2RSGJ3E4TCUT2XLVEZIJGM2GEI45RHSBH6AC","Major project re-architecture"],["G4U6J7TOHDXUL6ECIGJUSTQPURB54PC4VIAW2UGXDJPPFQLR64LQC","working with esy"],["FEHWT3MOW3STJXNBQWXSY6ZDSJIJWVU6EWCXA6KARH7DCYFNM5NQC","MVP with full gateway session protocol + http (voice missing)"],["ITQF7AQWZNN733JQHK3PHYDWDGM4JJZVFBLB7F7XPS56PMHCKTMQC","Ocaml 4.12, Error helpers, Ytdl, Bugfixes"],["HMJFS6WWD2JJZB57HBXRHYS2A2N25YDDAJ443KRMT6K3ALHIBRVQC","Fix mixer yielded events being dropped"]],"deps":["AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC"],"known":["FEHWT3MOW3STJXNBQWXSY6ZDSJIJWVU6EWCXA6KARH7DCYFNM5NQC","P35HCXDOT4NKKPTM6OMKEVKBLB3VLEODS7LNKRG7777RLOFDGU2AC","WWOXTYSKCYOBP6H7OQNLZJ22O6WVWCHQNJTHBRQ3ZEJH2KSQF3UAC","HMJFS6WWD2JJZB57HBXRHYS2A2N25YDDAJ443KRMT6K3ALHIBRVQC","B22T6OTOYMTCUQJGC4DVNB2FNKIYQHLU3I7H2OBWTNLX5WT2Y5RQC","ITQF7AQWZNN733JQHK3PHYDWDGM4JJZVFBLB7F7XPS56PMHCKTMQC","SM5TELBWYEM67PHIK2RSGJ3E4TCUT2XLVEZIJGM2GEI45RHSBH6AC","G4U6J7TOHDXUL6ECIGJUSTQPURB54PC4VIAW2UGXDJPPFQLR64LQC"]},"hunks":[{"Replacement":{"inode":{"change":3,"pos":153},"path":"bin/bot/discopotty.ml","line":4,"ins":{"up_context":[{"change":3,"pos":294}],"down_context":[{"change":3,"pos":340}],"flag":"BLOCK","start":3,"end":49,"inode":{"change":3,"pos":153}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":294},"to":{"change":2,"start":536,"end":561},"introduced_by":2}],"inode":{"change":3,"pos":153}},"ins_contents":[{"Add":{"text":"module Client = D.Client.Make (Voice.Manager)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:48"}}],"del_contents":[{"Del":{"text":"module Client = D.Client","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:560"}}]}},{"Replacement":{"inode":{"change":3,"pos":153},"path":"bin/bot/discopotty.ml","line":39,"ins":{"up_context":[{"change":3,"pos":2212}],"down_context":[{"change":3,"pos":2320}],"flag":"BLOCK","start":50,"end":129,"inode":{"change":3,"pos":153}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2212},"to":{"change":2,"start":985,"end":1072},"introduced_by":2}],"inode":{"change":3,"pos":153}},"ins_contents":[{"Add":{"text":" | Disco_core.Events.Message_create { content; channel_id; guild_id; _ } -> (","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:128"}}],"del_contents":[{"Del":{"text":" | Disco_core.Events.Message_create { content; channel_id; guild_id = _; _ }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1062"}},{"Del":{"text":" -> (","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1071"}}]}},{"Replacement":{"inode":{"change":3,"pos":153},"path":"bin/bot/discopotty.ml","line":67,"ins":{"up_context":[{"change":3,"pos":1217}],"down_context":[{"change":3,"pos":1909}],"flag":"BLOCK","start":130,"end":859,"inode":{"change":3,"pos":153}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1217},"to":{"change":2,"start":1230,"end":2044},"introduced_by":2}],"inode":{"change":3,"pos":153}},"ins_contents":[{"Add":{"text":" | Some (\"join\", vchan) -> (","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:163"}},{"Add":{"text":" let guild_id = Option.get_exn guild_id in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:215"}},{"Add":{"text":" let vchan = M.Snowflake.of_string vchan in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:268"}},{"Add":{"text":" let voice = Client.voice client in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:313"}},{"Add":{"text":" let call = Voice.Manager.get ~guild_id voice in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:371"}},{"Add":{"text":" try Voice.Call.join call ~channel_id:vchan","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:424"}},{"Add":{"text":" with exn ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:446"}},{"Add":{"text":" let msg =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:468"}},{"Add":{"text":" Msg.fmt \"⚠️ Couldn't join voice channel: %s\"","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:531"}},{"Add":{"text":" (Printexc.to_string exn)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:572"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:587"}},{"Add":{"text":" Client.send_message channel_id msg client)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:642"}},{"Add":{"text":" | Some (\"leave\", _) ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:671"}},{"Add":{"text":" let guild_id = Option.get_exn guild_id in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:723"}},{"Add":{"text":" let voice = Client.voice client in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:768"}},{"Add":{"text":" let call = Voice.Manager.get ~guild_id voice in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:826"}},{"Add":{"text":" Voice.Call.leave call","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:858"}}],"del_contents":[{"Del":{"text":" (* | Some (\"join\", vchan) -> (","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1266"}},{"Del":{"text":" let guild_id = Option.get_exn guild_id in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1321"}},{"Del":{"text":" let vchan = M.Snowflake.of_string vchan in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1377"}},{"Del":{"text":" let voice = Client.voice client in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1425"}},{"Del":{"text":" let call = Voice.Manager.get ~guild_id voice in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1486"}},{"Del":{"text":" Voice.Call.join call ~channel_id:vchan >>= function","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1551"}},{"Del":{"text":" | Error e ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1577"}},{"Del":{"text":" let msg =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1604"}},{"Del":{"text":" Msg.fmt \"⚠️ Couldn't join voice channel: %a\" Voice.Error.pp e","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1689"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1709"}},{"Del":{"text":" Client.send_message channel_id msg client","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1768"}},{"Del":{"text":" | Ok () -> Lwt.return_unit)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1809"}},{"Del":{"text":" | Some (\"leave\", _) ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1841"}},{"Del":{"text":" let guild_id = Option.get_exn guild_id in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1896"}},{"Del":{"text":" let voice = Client.voice client in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:1944"}},{"Del":{"text":" let call = Voice.Manager.get ~guild_id voice in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:2005"}},{"Del":{"text":" Voice.Call.leave call *)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:2043"}}]}},{"Replacement":{"inode":{"change":3,"pos":153},"path":"bin/bot/discopotty.ml","line":144,"ins":{"up_context":[{"change":2,"pos":2404}],"down_context":[{"change":2,"pos":2523}],"flag":"BLOCK","start":860,"end":977,"inode":{"change":3,"pos":153}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":2404},"to":{"change":2,"start":2404,"end":2523},"introduced_by":2}],"inode":{"change":3,"pos":153}},"ins_contents":[{"Add":{"text":" let bt, es = Printexc.(get_backtrace (), to_string e) in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:920"}},{"Add":{"text":" L.err (fun m -> m \"fatal exception: %s@.%s\" es bt);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:976"}}],"del_contents":[{"Del":{"text":" L.err (fun m ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:2423"}},{"Del":{"text":" m \"fatal exception: %s@.%s\" (Printexc.to_string e)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:2482"}},{"Del":{"text":" (Printexc.get_backtrace ()));","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:2522"}}]}},{"Replacement":{"inode":{"change":3,"pos":153},"path":"bin/bot/discopotty.ml","line":149,"ins":{"up_context":[{"change":2,"pos":2547}],"down_context":[],"flag":"BLOCK","start":978,"end":1090,"inode":{"change":3,"pos":153}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":2547},"to":{"change":2,"start":2547,"end":2622},"introduced_by":2}],"inode":{"change":3,"pos":153}},"ins_contents":[{"Add":{"text":" Eio_unix.Ctf.with_tracing \"discopotty.ctf\" @@ fun () ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1035"}},{"Add":{"text":" Eio_luv.run (fun env -> main (env :> Eio.Stdenv.t))","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1089"}}],"del_contents":[{"Del":{"text":" Eio_unix.Ctf.with_tracing \"discopotty.ctf\" @@ fun () -> Eio_luv.run main","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:2621"}}]}},{"Replacement":{"inode":{"change":3,"pos":521477},"path":"lib/client.ml","line":9,"ins":{"up_context":[{"change":3,"pos":104706}],"down_context":[{"change":2,"pos":193928}],"flag":"BLOCK","start":1093,"end":1160,"inode":{"change":3,"pos":521477}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":104706},"to":{"change":3,"start":68272,"end":68300},"introduced_by":3}],"inode":{"change":3,"pos":521477}},"ins_contents":[{"Add":{"text":" val make : env:Eio.Stdenv.t -> sw:Eio.Switch.t -> Gateway.t -> t","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1159"}}],"del_contents":[{"Del":{"text":" val make : Gateway.t -> t","pos":"SM5TELBWYEM67PHIK2RSGJ3E4TCUT2XLVEZIJGM2GEI45RHSBH6AC:68299"}}]}},{"Replacement":{"inode":{"change":3,"pos":521477},"path":"lib/client.ml","line":57,"ins":{"up_context":[{"change":3,"pos":69907}],"down_context":[{"change":3,"pos":69940}],"flag":"BLOCK","start":1161,"end":1203,"inode":{"change":3,"pos":521477}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":69907},"to":{"change":3,"start":69907,"end":69940},"introduced_by":3}],"inode":{"change":3,"pos":521477}},"ins_contents":[{"Add":{"text":" let voice = Voice.make ~env ~sw gw in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1202"}}],"del_contents":[{"Del":{"text":" let voice = Voice.make gw in","pos":"SM5TELBWYEM67PHIK2RSGJ3E4TCUT2XLVEZIJGM2GEI45RHSBH6AC:69939"}}]}},{"Replacement":{"inode":{"change":3,"pos":521477},"path":"lib/client.ml","line":60,"ins":{"up_context":[{"change":3,"pos":70034}],"down_context":[{"change":3,"pos":70254}],"flag":"BLOCK","start":1204,"end":1253,"inode":{"change":3,"pos":521477}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":70034},"to":{"change":2,"start":194479,"end":194514},"introduced_by":2}],"inode":{"change":3,"pos":521477}},"ins_contents":[{"Add":{"text":" let fn = handler t in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1229"}},{"Add":{"text":" Gateway.sub ~fn gw","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1252"}}],"del_contents":[{"Del":{"text":" Gateway.sub ~fn:(handler t) gw","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:194513"}}]}},{"Replacement":{"inode":{"change":3,"pos":521477},"path":"lib/client.ml","line":67,"ins":{"up_context":[{"change":3,"pos":70301}],"down_context":[{"change":2,"pos":194515}],"flag":"BLOCK","start":1254,"end":1286,"inode":{"change":3,"pos":521477}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":70301},"to":{"change":3,"start":70301,"end":70320},"introduced_by":3}],"inode":{"change":3,"pos":521477}},"ins_contents":[{"Add":{"text":" let make ~env:_ ~sw:_ _ = Nop","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1285"}}],"del_contents":[{"Del":{"text":" let make _ = Nop","pos":"SM5TELBWYEM67PHIK2RSGJ3E4TCUT2XLVEZIJGM2GEI45RHSBH6AC:70319"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":1,"ins":{"up_context":[{"change":3,"pos":115320}],"down_context":[{"change":3,"pos":115491}],"flag":"BLOCK","start":1289,"end":1499,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":115320},"to":{"change":2,"start":249542,"end":249730},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"open! Disco_core.Globals","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1313"}},{"Add":{"text":"module Snowflake = Disco_models.Snowflake","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1355"}},{"Add":{"text":"module E = Disco_core.Events","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1384"}},{"Add":{"text":"module Gateway = Disco_core.Gateway","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1420"}},{"Add":{"text":"module F = Relog.Field","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1443"}},{"Add":{"text":"module L = (val Relog.logger ~namespace:__MODULE__ ())","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1498"}}],"del_contents":[{"Del":{"text":"(* open! Disco_core.Globals","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:249569"}},{"Del":{"text":" open Lwt.Infix","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:249587"}},{"Del":{"text":" module Snowflake = Disco_models.Snowflake","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:249632"}},{"Del":{"text":" module E = Disco_core.Events","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:249664"}},{"Del":{"text":" module Gateway = Disco_core.Gateway","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:249703"}},{"Del":{"text":" module F = Relog.Field","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:249729"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":8,"ins":{"up_context":[{"change":3,"pos":115492}],"down_context":[{"change":3,"pos":115556}],"flag":"BLOCK","start":1500,"end":1539,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":115492},"to":{"change":2,"start":249731,"end":249798},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"exception Detached","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1518"}},{"Add":{"text":"exception Timed_out","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1538"}}],"del_contents":[{"Del":{"text":" module L = (val Relog.logger ~namespace:\"Disco_voice__Call\" ())","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:249797"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":11,"ins":{"up_context":[{"change":3,"pos":115557}],"down_context":[{"change":3,"pos":115627}],"flag":"BLOCK","start":1540,"end":1659,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":115557},"to":{"change":2,"start":249799,"end":249872},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"type srv_info = { token : string; endpoint : string }","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1593"}},{"Add":{"text":"type sess_info = { channel_id : snowflake; session_id : string }","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1658"}}],"del_contents":[{"Del":{"text":" type 'a req = ('a, Error.t) result Lwt.t * ('a, Error.t) result Lwt.u","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:249871"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":14,"ins":{"up_context":[{"change":3,"pos":115628}],"down_context":[{"change":3,"pos":115682}],"flag":"BLOCK","start":1660,"end":1838,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":115628},"to":{"change":2,"start":249873,"end":249930},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"type t = {","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1670"}},{"Add":{"text":" gw : Gateway.t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1688"}},{"Add":{"text":" guild_id : snowflake;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1712"}},{"Add":{"text":" mixer : Mixer.t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1731"}},{"Add":{"text":" conn : conn Atomic.t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1755"}},{"Add":{"text":" mutable muted : bool;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1779"}},{"Add":{"text":" mutable deafened : bool;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1806"}},{"Add":{"text":" evs : events Eio.Stream.t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1835"}},{"Add":{"text":"}","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1837"}}],"del_contents":[{"Del":{"text":" type srv_info = { token : string; endpoint : string }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:249929"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":24,"ins":{"up_context":[{"change":3,"pos":115683}],"down_context":[{"change":3,"pos":115748}],"flag":"BLOCK","start":1839,"end":1963,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":115683},"to":{"change":2,"start":249931,"end":249999},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"and conn =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1849"}},{"Add":{"text":" | Detached of unit req","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1874"}},{"Add":{"text":" | Init of { cid : snowflake; req : unit req; info : conn_info }","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1940"}},{"Add":{"text":" | Live of Session.t","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:1962"}}],"del_contents":[{"Del":{"text":" type sess_info = { channel_id : snowflake; session_id : string }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:249998"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":29,"ins":{"up_context":[{"change":3,"pos":115749}],"down_context":[{"change":3,"pos":115903}],"flag":"BLOCK","start":1964,"end":2032,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":115749},"to":{"change":2,"start":250000,"end":250178},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"and conn_info = Empty | Got_srv of srv_info | Got_sess of sess_info","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2031"}}],"del_contents":[{"Del":{"text":" type t = {","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250013"}},{"Del":{"text":" gw : Gateway.t;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250034"}},{"Del":{"text":" mixer : Mixer.t;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250056"}},{"Del":{"text":" guild_id : snowflake;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250083"}},{"Del":{"text":" mutable muted : bool;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250110"}},{"Del":{"text":" mutable deafened : bool;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250140"}},{"Del":{"text":" tx : op Lwt_pipe.Writer.t;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250172"}},{"Del":{"text":" }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250177"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":31,"ins":{"up_context":[{"change":3,"pos":115904}],"down_context":[{"change":3,"pos":115945}],"flag":"BLOCK","start":2033,"end":2141,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":115904},"to":{"change":2,"start":250179,"end":250223},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"and events =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2045"}},{"Add":{"text":" | Req_join of snowflake * unit req","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2082"}},{"Add":{"text":" | Gw_srv of srv_info","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2105"}},{"Add":{"text":" | Gw_sess of sess_info","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2130"}},{"Add":{"text":" | Gw_dc","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2140"}}],"del_contents":[{"Del":{"text":" and op = Req of op_req | Gw of gw_update","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250222"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":37,"ins":{"up_context":[{"change":3,"pos":115946}],"down_context":[{"change":3,"pos":115988}],"flag":"BLOCK","start":2142,"end":2180,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":115946},"to":{"change":2,"start":250224,"end":250269},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"and 'a req = ('a, exn) result -> unit","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2179"}}],"del_contents":[{"Del":{"text":" and op_req = Join of snowflake * unit req","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250268"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":39,"ins":{"up_context":[{"change":3,"pos":115989}],"down_context":[{"change":3,"pos":116046}],"flag":"BLOCK","start":2181,"end":3074,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":115989},"to":{"change":2,"start":250270,"end":250330},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"let wait_for_session conn =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2208"}},{"Add":{"text":" let b = Backoff.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2239"}},{"Add":{"text":" let rec loop () =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2259"}},{"Add":{"text":" match Atomic.get conn with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2290"}},{"Add":{"text":" | Live session -> session","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2320"}},{"Add":{"text":" | Init ({ req = o_req; _ } as init) as st ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2369"}},{"Add":{"text":" let p, u = Promise.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2409"}},{"Add":{"text":" if","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2420"}},{"Add":{"text":" Atomic.compare_and_set conn st","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2461"}},{"Add":{"text":" (Init","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2479"}},{"Add":{"text":" {","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2496"}},{"Add":{"text":" init with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2523"}},{"Add":{"text":" req =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2546"}},{"Add":{"text":" (fun res ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2577"}},{"Add":{"text":" o_req res;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2609"}},{"Add":{"text":" Promise.resolve u ());","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2653"}},{"Add":{"text":" })","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2671"}},{"Add":{"text":" then Promise.await p","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2700"}},{"Add":{"text":" else Backoff.once b;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2729"}},{"Add":{"text":" loop ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2745"}},{"Add":{"text":" | Detached o_req as st ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2775"}},{"Add":{"text":" let p, u = Promise.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2815"}},{"Add":{"text":" if","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2826"}},{"Add":{"text":" Atomic.compare_and_set conn st","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2867"}},{"Add":{"text":" (Detached","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2889"}},{"Add":{"text":" (fun res ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2916"}},{"Add":{"text":" o_req res;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2944"}},{"Add":{"text":" Promise.resolve u ()))","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:2984"}},{"Add":{"text":" then Promise.await p","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3013"}},{"Add":{"text":" else Backoff.once b;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3042"}},{"Add":{"text":" loop ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3058"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3063"}},{"Add":{"text":" loop ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3073"}}],"del_contents":[{"Del":{"text":" and gw_update = Srv of srv_info | Sess of sess_info | Dc","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250329"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":73,"ins":{"up_context":[{"change":3,"pos":116047}],"down_context":[{"change":3,"pos":116228}],"flag":"BLOCK","start":3075,"end":3091,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":116047},"to":{"change":2,"start":250331,"end":250527},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"let stub _ = ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3090"}}],"del_contents":[{"Del":{"text":" type conn =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250345"}},{"Del":{"text":" | Detached","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250361"}},{"Del":{"text":" | Init of { channel_id : snowflake; req : unit req; info : conn_info }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250437"}},{"Del":{"text":" | Connecting of { channel_id : snowflake; req : unit req }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250501"}},{"Del":{"text":" | Live of Session.t","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250526"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":75,"ins":{"up_context":[{"change":3,"pos":116229}],"down_context":[{"change":3,"pos":116297}],"flag":"BLOCK","start":3092,"end":7119,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":116229},"to":{"change":2,"start":250528,"end":250599},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"let manage ~net ~dmgr t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3117"}},{"Add":{"text":" Switch.run @@ fun sw ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3143"}},{"Add":{"text":" let user_id = (Gateway.user t.gw).id in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3185"}},{"Add":{"text":" let connect ~srv ~sess =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3212"}},{"Add":{"text":" Session.create ~sw ~net ~guild_id:t.guild_id ~user_id","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3270"}},{"Add":{"text":" ~channel_id:sess.channel_id ~session_id:sess.session_id ~token:srv.token","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3349"}},{"Add":{"text":" srv.endpoint","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3368"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3373"}},{"Add":{"text":" let mixer_thread () =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3397"}},{"Add":{"text":" Switch.on_release sw (fun () -> Mixer.destroy t.mixer);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3457"}},{"Add":{"text":" Eio.Domain_manager.run dmgr @@ fun () ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3502"}},{"Add":{"text":" let play i f =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3521"}},{"Add":{"text":" let s = wait_for_session t.conn in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3562"}},{"Add":{"text":" Session.start_speaking s;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3594"}},{"Add":{"text":" Session.send_rtp s f;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3622"}},{"Add":{"text":" i < 15","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3635"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3642"}},{"Add":{"text":" let stop () = wait_for_session t.conn |> Session.stop_speaking in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3712"}},{"Add":{"text":" Mixer.run ~play ~stop t.mixer","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3746"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3751"}},{"Add":{"text":" let b = Backoff.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3782"}},{"Add":{"text":" let rec main_thread () =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3809"}},{"Add":{"text":" let ev = Eio.Stream.take t.evs in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3847"}},{"Add":{"text":" handle ev","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3861"}},{"Add":{"text":" and cas ~ev ost nst fn =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3888"}},{"Add":{"text":" if Atomic.compare_and_set t.conn ost nst then fn ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3944"}},{"Add":{"text":" else (","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3955"}},{"Add":{"text":" Backoff.once b;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3977"}},{"Add":{"text":" handle ev)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:3994"}},{"Add":{"text":" and handle ev =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4012"}},{"Add":{"text":" match (Atomic.get t.conn, ev) with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4051"}},{"Add":{"text":" | (Detached o_req as st), Req_join (cid, n_req) ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4106"}},{"Add":{"text":" let req res =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4128"}},{"Add":{"text":" o_req res;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4149"}},{"Add":{"text":" n_req res","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4169"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4180"}},{"Add":{"text":" cas ~ev st (Init { cid; req; info = Empty }) @@ fun () ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4246"}},{"Add":{"text":" (* TODO timeout *)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4273"}},{"Add":{"text":" L.info (fun m -> m \"join request while detached\");","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4332"}},{"Add":{"text":" Gateway.send_voice_state_update t.gw ~channel_id:cid ~self_mute:t.muted","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4412"}},{"Add":{"text":" ~self_deaf:t.deafened t.guild_id;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4456"}},{"Add":{"text":" main_thread ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4479"}},{"Add":{"text":" | Detached _, (Gw_dc | Gw_sess _ | Gw_srv _) ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4531"}},{"Add":{"text":" L.warn (fun m -> m \"gateway event on detached call\");","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4593"}},{"Add":{"text":" main_thread ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4616"}},{"Add":{"text":" | Init { info = Got_sess sess; req; _ }, Gw_srv srv","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4672"}},{"Add":{"text":" | Init { info = Got_srv srv; req; _ }, Gw_sess sess ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4731"}},{"Add":{"text":" (* any race conditions with mixer that require a CAS & extra state ? *)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4811"}},{"Add":{"text":" let res =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4829"}},{"Add":{"text":" match connect ~srv ~sess with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4869"}},{"Add":{"text":" | sess ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4889"}},{"Add":{"text":" Atomic.set t.conn @@ Live sess;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4935"}},{"Add":{"text":" Ok ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4955"}},{"Add":{"text":" | exception exn ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:4984"}},{"Add":{"text":" Atomic.set t.conn @@ Detached stub;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5034"}},{"Add":{"text":" Error exn","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5058"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5069"}},{"Add":{"text":" req res;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5086"}},{"Add":{"text":" main_thread ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5109"}},{"Add":{"text":" | (Init ({ info = Got_sess _ | Empty; _ } as init) as st), Gw_sess sess ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5188"}},{"Add":{"text":" cas ~ev st (Init { init with info = Got_sess sess }) @@ main_thread","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5264"}},{"Add":{"text":" | (Init ({ info = Got_srv _ | Empty; _ } as init) as st), Gw_srv srv ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5340"}},{"Add":{"text":" cas ~ev st (Init { init with info = Got_srv srv }) @@ main_thread","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5414"}},{"Add":{"text":" | (Init { req; _ } as st), Gw_dc ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5454"}},{"Add":{"text":" cas ~ev st (Detached stub) @@ fun () -> req @@ Error Detached","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5524"}},{"Add":{"text":" | (Init ({ cid; req = o_req; _ } as init) as st), Req_join (n_cid, n_req)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5602"}},{"Add":{"text":" when Snowflake.(cid = n_cid) ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5640"}},{"Add":{"text":" let req res =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5662"}},{"Add":{"text":" o_req res;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5683"}},{"Add":{"text":" n_req res","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5703"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5714"}},{"Add":{"text":" cas ~ev st (Init { init with req }) @@ main_thread","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5773"}},{"Add":{"text":" | (Init ({ req = o_req; _ } as init) as st), Req_join _ ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5836"}},{"Add":{"text":" let req res =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5858"}},{"Add":{"text":" o_req res;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5879"}},{"Add":{"text":" Eio.Stream.add t.evs ev","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5913"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5924"}},{"Add":{"text":" cas ~ev st (Init { init with req }) @@ main_thread","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:5983"}},{"Add":{"text":" | Live sess, Req_join (cid, req)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6020"}},{"Add":{"text":" when Snowflake.(cid = Session.channel_id sess) ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6076"}},{"Add":{"text":" req @@ Ok ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6097"}},{"Add":{"text":" | (Live sess as st), Req_join _ ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6136"}},{"Add":{"text":" cas ~ev st (Detached stub) @@ fun () ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6184"}},{"Add":{"text":" L.info (fun m -> m \"join request while live, switching channels\");","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6259"}},{"Add":{"text":" Session.disconnect sess;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6292"}},{"Add":{"text":" handle ev","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6310"}},{"Add":{"text":" | (Live sess as st), Gw_sess nsess","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6349"}},{"Add":{"text":" when Snowflake.(Session.channel_id sess <> nsess.channel_id)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6416"}},{"Add":{"text":" || String.(Session.session_id sess <> nsess.session_id) ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6486"}},{"Add":{"text":" let srv = Session.{ token = token sess; endpoint = endpoint sess } in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6564"}},{"Add":{"text":" cas ~ev st","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6583"}},{"Add":{"text":" (Init { req = stub; cid = nsess.channel_id; info = Got_srv srv })","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6659"}},{"Add":{"text":" @@ fun () ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6680"}},{"Add":{"text":" L.warn (fun m -> m \"new voice session info, reconnecting\");","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6748"}},{"Add":{"text":" Session.disconnect sess;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6781"}},{"Add":{"text":" handle ev","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6799"}},{"Add":{"text":" | (Live sess as st), Gw_dc ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6833"}},{"Add":{"text":" cas ~ev st (Detached stub) @@ fun () ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6881"}},{"Add":{"text":" L.info (fun m -> m \"disconnected\");","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6925"}},{"Add":{"text":" Session.disconnect sess;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6958"}},{"Add":{"text":" main_thread ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:6981"}},{"Add":{"text":" | Live _, (Gw_sess _ | Gw_srv _) -> main_thread ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7036"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7041"}},{"Add":{"text":" Fiber.both main_thread mixer_thread;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7080"}},{"Add":{"text":" Mixer.destroy t.mixer;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7105"}},{"Add":{"text":" raise Exit","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7118"}}],"del_contents":[{"Del":{"text":" and conn_info = Empty | Got_srv of srv_info | Got_sess of sess_info","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250598"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":182,"ins":{"up_context":[{"change":3,"pos":116298}],"down_context":[{"change":3,"pos":116593}],"flag":"BLOCK","start":7120,"end":7465,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":116298},"to":{"change":2,"start":250600,"end":250913},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"let make ~sw ~net ~dmgr ?(muted = false) ?(deafened = false) ~guild_id gw =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7195"}},{"Add":{"text":" let t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7205"}},{"Add":{"text":" {","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7211"}},{"Add":{"text":" gw;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7221"}},{"Add":{"text":" guild_id;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7237"}},{"Add":{"text":" mixer = Mixer.create ();","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7268"}},{"Add":{"text":" conn = Atomic.make @@ Detached stub;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7311"}},{"Add":{"text":" muted;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7324"}},{"Add":{"text":" deafened;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7340"}},{"Add":{"text":" evs = Eio.Stream.create max_int;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7379"}},{"Add":{"text":" }","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7385"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7390"}},{"Add":{"text":" Fiber.fork ~sw (fun () -> try manage ~net ~dmgr t with Exit -> ());","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7460"}},{"Add":{"text":" t","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7464"}}],"del_contents":[{"Del":{"text":" let make ?(muted = false) ?(deafened = false) ~guild_id gw =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250663"}},{"Del":{"text":" let ( let+ ) = Result.( let+ ) in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250702"}},{"Del":{"text":" let op_rx = Lwt_pipe.create () in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250741"}},{"Del":{"text":" let mixer_rx = Lwt_pipe.create () in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250783"}},{"Del":{"text":" let+ mixer = Mixer.create (Lwt_pipe.write mixer_rx) in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250843"}},{"Del":{"text":" let t = { gw; guild_id; muted; deafened; tx = op_rx; mixer } in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250912"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":197,"ins":{"up_context":[{"change":3,"pos":116594}],"down_context":[{"change":3,"pos":116815}],"flag":"BLOCK","start":7466,"end":7558,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":116594},"to":{"change":2,"start":250914,"end":251159},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"let update_server ~token ~endpoint t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7504"}},{"Add":{"text":" Eio.Stream.add t.evs @@ Gw_srv { token; endpoint }","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7557"}}],"del_contents":[{"Del":{"text":" let read_op () =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250935"}},{"Del":{"text":" Lwt_pipe.read op_rx >|= Option.get_exn >|= function","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:250994"}},{"Del":{"text":" | Req r -> `Op r","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251018"}},{"Del":{"text":" | Gw g -> `Gw g","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251041"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251049"}},{"Del":{"text":" let _read_mixer () =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251075"}},{"Del":{"text":" Lwt_pipe.read mixer_rx >|= Option.get_exn >|= fun mix -> `Mixer mix","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251150"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251158"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":200,"ins":{"up_context":[{"change":3,"pos":116816}],"down_context":[{"change":3,"pos":117058}],"flag":"BLOCK","start":7559,"end":7754,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":116816},"to":{"change":2,"start":251160,"end":251420},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"let update_session ?channel_id ~session_id t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7605"}},{"Add":{"text":" let ev =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7616"}},{"Add":{"text":" match channel_id with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7642"}},{"Add":{"text":" | None -> Gw_dc","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7662"}},{"Add":{"text":" | Some channel_id -> Gw_sess { channel_id; session_id }","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7722"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7727"}},{"Add":{"text":" Eio.Stream.add t.evs ev","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7753"}}],"del_contents":[{"Del":{"text":" let do_connect ~srv ~sess =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251192"}},{"Del":{"text":" let user_id = (Gateway.user t.gw).id in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251239"}},{"Del":{"text":" let guild_id = t.guild_id in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251275"}},{"Del":{"text":" Session.create ~guild_id ~user_id ~channel_id:sess.channel_id","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251344"}},{"Del":{"text":" ~session_id:sess.session_id ~token:srv.token srv.endpoint","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251411"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251419"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":208,"ins":{"up_context":[{"change":3,"pos":117059}],"down_context":[{"change":3,"pos":123672}],"flag":"BLOCK","start":7755,"end":7904,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":117059},"to":{"change":2,"start":251421,"end":258191},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":258191},"to":{"change":3,"start":123373,"end":123374},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":123373},"to":{"change":3,"start":123373,"end":123374},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":123374},"to":{"change":2,"start":258192,"end":258295},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":258295},"to":{"change":3,"start":123471,"end":123472},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":123471},"to":{"change":3,"start":123471,"end":123472},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":123472},"to":{"change":2,"start":258296,"end":258517},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"let join ~channel_id t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7779"}},{"Add":{"text":" let p, u = Promise.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7813"}},{"Add":{"text":" Eio.Stream.add t.evs @@ Req_join (channel_id, Promise.resolve u);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7881"}},{"Add":{"text":" Promise.await_exn p","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7903"}}],"del_contents":[{"Del":{"text":" let run () =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251438"}},{"Del":{"text":" let conn = ref Detached in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251472"}},{"Del":{"text":" let rec poll q =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251496"}},{"Del":{"text":" Lwt.nchoose_split q >>= function","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251538"}},{"Del":{"text":" | [], [] -> Lwt_result.return ()","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251580"}},{"Del":{"text":" | rs, ps -> (","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251603"}},{"Del":{"text":" match handle ps rs with","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251640"}},{"Del":{"text":" | Ok [] -> Lwt_result.return ()","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251685"}},{"Del":{"text":" | Ok q -> poll q","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251715"}},{"Del":{"text":" | Error _ as err -> Lwt.return err)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251764"}},{"Del":{"text":" and handle out rs =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251791"}},{"Del":{"text":" match (rs, !conn) with","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251823"}},{"Del":{"text":" | [], _ -> Ok out","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251850"}},{"Del":{"text":" | `Noop :: xs, _ -> handle out xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251893"}},{"Del":{"text":" | `Cancel :: xs, Init { req; _ } ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:251938"}},{"Del":{"text":" Lwt.wakeup_later (snd req) @@ Error.msg \"timed out\";","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252004"}},{"Del":{"text":" conn := Detached;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252035"}},{"Del":{"text":" handle out xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252062"}},{"Del":{"text":" | `Cancel :: xs, _ -> handle out xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252107"}},{"Del":{"text":" | `Connected (Ok session) :: xs, (Init { req; _ } | Connecting { req; _ })","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252191"}},{"Del":{"text":" ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252205"}},{"Del":{"text":" conn := Live session;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252240"}},{"Del":{"text":" L.info (fun m -> m \"connected\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252286"}},{"Del":{"text":" Lwt.wakeup_later (snd req) (Ok ());","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252335"}},{"Del":{"text":" handle out xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252362"}},{"Del":{"text":" | ( `Connected (Error _ as err) :: xs,","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252410"}},{"Del":{"text":" (Init { req; _ } | Connecting { req; _ }) ) ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252470"}},{"Del":{"text":" conn := Detached;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252501"}},{"Del":{"text":" L.err (fun m -> m \"error connecting\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252553"}},{"Del":{"text":" Lwt.wakeup_later (snd req) err;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252598"}},{"Del":{"text":" handle out xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252625"}},{"Del":{"text":" | `Connected (Ok session) :: xs, _ ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252672"}},{"Del":{"text":" conn := Live session;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252707"}},{"Del":{"text":" handle out xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252734"}},{"Del":{"text":" | `Connected (Error _) :: xs, _ ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252778"}},{"Del":{"text":" conn := Detached;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252809"}},{"Del":{"text":" handle out xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252836"}},{"Del":{"text":" | ( (`Op (Join (cid, nreq)) as op) :: xs,","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252887"}},{"Del":{"text":" (Init { req; channel_id; _ } | Connecting { req; channel_id; _ }) ) ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:252971"}},{"Del":{"text":" L.info (fun m -> m \"join request while connecting\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253037"}},{"Del":{"text":" if Snowflake.(cid = channel_id) then (","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253089"}},{"Del":{"text":" Lwt.async (fun () ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253125"}},{"Del":{"text":" fst req >|= fun res -> Lwt.wakeup_later (snd nreq) res);","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253201"}},{"Del":{"text":" handle (read_op () :: out) xs)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253247"}},{"Del":{"text":" else handle (Lwt.return op :: read_op () :: out) xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253312"}},{"Del":{"text":" | `Op (Join (channel_id, req)) :: xs, Live session ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253375"}},{"Del":{"text":" L.info (fun m -> m \"join request while connected\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253440"}},{"Del":{"text":" if Snowflake.(channel_id = Session.channel_id session) then (","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253515"}},{"Del":{"text":" Lwt.wakeup_later (snd req) (Ok ());","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253566"}},{"Del":{"text":" handle (read_op () :: out) xs)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253612"}},{"Del":{"text":" else (","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253632"}},{"Del":{"text":" conn := Init { channel_id; req; info = Empty };","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253695"}},{"Del":{"text":" let reconn =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253723"}},{"Del":{"text":" Session.disconnect session >>= fun () ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253781"}},{"Del":{"text":" Gateway.send_voice_state_update t.gw ~channel_id","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253847"}},{"Del":{"text":" ~self_mute:t.muted ~self_deaf:t.deafened t.guild_id","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253918"}},{"Del":{"text":" >|= fun () -> `Noop","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253955"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:253973"}},{"Del":{"text":" handle (reconn :: read_op () :: out) xs)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254029"}},{"Del":{"text":" | `Op (Join (channel_id, req)) :: xs, Detached ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254088"}},{"Del":{"text":" L.info (fun m -> m \"join request while detached\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254152"}},{"Del":{"text":" conn := Init { channel_id; req; info = Empty };","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254213"}},{"Del":{"text":" let send =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254237"}},{"Del":{"text":" Gateway.send_voice_state_update t.gw ~channel_id ~self_mute:t.muted","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254320"}},{"Del":{"text":" ~self_deaf:t.deafened t.guild_id","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254370"}},{"Del":{"text":" >|= fun () -> `Noop","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254405"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254421"}},{"Del":{"text":" let timeout =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254448"}},{"Del":{"text":" Lwt.pick","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254472"}},{"Del":{"text":" [","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254491"}},{"Del":{"text":" (Lwt_unix.sleep 5. >|= fun () -> `Cancel);","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254553"}},{"Del":{"text":" (fst req >|= fun _ -> `Noop);","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254602"}},{"Del":{"text":" ]","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254621"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254637"}},{"Del":{"text":" handle (send :: timeout :: read_op () :: out) xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254699"}},{"Del":{"text":" | `Gw Dc :: xs, Live session ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254740"}},{"Del":{"text":" L.info (fun m -> m \"disconnected\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254789"}},{"Del":{"text":" conn := Detached;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254820"}},{"Del":{"text":" let dc = Session.disconnect session >|= fun () -> `Noop in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254892"}},{"Del":{"text":" handle (dc :: read_op () :: out) xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254941"}},{"Del":{"text":" | `Gw (Srv srv) :: xs, Live s ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254983"}},{"Del":{"text":" if","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:254999"}},{"Del":{"text":" String.(","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255023"}},{"Del":{"text":" Session.endpoint s <> srv.endpoint || Session.token s <> srv.token)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255108"}},{"Del":{"text":" then (","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255128"}},{"Del":{"text":" L.warn (fun m -> m \"new voice server info, reconnecting\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255202"}},{"Del":{"text":" let req = Lwt.wait () in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255242"}},{"Del":{"text":" let sess =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255268"}},{"Del":{"text":" {","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255287"}},{"Del":{"text":" session_id = Session.session_id s;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255341"}},{"Del":{"text":" channel_id = Session.channel_id s;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255395"}},{"Del":{"text":" }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255414"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255432"}},{"Del":{"text":" conn := Connecting { channel_id = sess.channel_id; req };","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255505"}},{"Del":{"text":" let reconn =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255533"}},{"Del":{"text":" Session.disconnect s >>= fun () ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255585"}},{"Del":{"text":" do_connect ~srv ~sess >|= fun res -> `Connected res","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255654"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255672"}},{"Del":{"text":" handle (reconn :: read_op () :: out) xs)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255728"}},{"Del":{"text":" else handle (read_op () :: out) xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255776"}},{"Del":{"text":" | `Gw (Sess sess) :: xs, Live s ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255820"}},{"Del":{"text":" if","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255836"}},{"Del":{"text":" Snowflake.(Session.channel_id s <> sess.channel_id)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255903"}},{"Del":{"text":" || String.(Session.session_id s <> sess.session_id)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255970"}},{"Del":{"text":" then (","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:255990"}},{"Del":{"text":" L.warn (fun m -> m \"new voice session info, reconnecting\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256065"}},{"Del":{"text":" let req = Lwt.wait () in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256105"}},{"Del":{"text":" let srv =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256130"}},{"Del":{"text":" { token = Session.token s; endpoint = Session.endpoint s }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256206"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256224"}},{"Del":{"text":" conn := Connecting { channel_id = sess.channel_id; req };","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256297"}},{"Del":{"text":" let reconn =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256325"}},{"Del":{"text":" Session.disconnect s >>= fun () ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256377"}},{"Del":{"text":" do_connect ~srv ~sess >|= fun res -> `Connected res","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256446"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256464"}},{"Del":{"text":" handle (reconn :: read_op () :: out) xs)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256520"}},{"Del":{"text":" else handle (read_op () :: out) xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256568"}},{"Del":{"text":" | `Gw _ :: xs, Detached ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256604"}},{"Del":{"text":" L.warn (fun m -> m \"gateway event on detached call\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256671"}},{"Del":{"text":" handle (read_op () :: out) xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256714"}},{"Del":{"text":" | (`Gw _ as ev) :: xs, Connecting _ ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256762"}},{"Del":{"text":" L.info (fun m -> m \"buffering gw event while connecting\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256834"}},{"Del":{"text":" handle (Lwt.return ev :: read_op () :: out) xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256894"}},{"Del":{"text":" | `Gw (Srv srv) :: xs, Init { info = Got_sess sess; channel_id; req }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:256973"}},{"Del":{"text":" | `Gw (Sess sess) :: xs, Init { info = Got_srv srv; channel_id; req } ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257055"}},{"Del":{"text":" conn := Connecting { channel_id; req };","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257108"}},{"Del":{"text":" let connect = do_connect ~srv ~sess >|= fun res -> `Connected res in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257190"}},{"Del":{"text":" handle (connect :: read_op () :: out) xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257244"}},{"Del":{"text":" | `Gw (Srv nsrv) :: xs, Init ({ info = Got_srv _ | Empty; _ } as init) ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257327"}},{"Del":{"text":" conn := Init { init with info = Got_srv nsrv };","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257388"}},{"Del":{"text":" handle (read_op () :: out) xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257431"}},{"Del":{"text":" | `Gw (Sess nsess) :: xs, Init ({ info = Got_sess _ | Empty; _ } as init)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257514"}},{"Del":{"text":" ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257528"}},{"Del":{"text":" conn := Init { init with info = Got_sess nsess };","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257591"}},{"Del":{"text":" handle (read_op () :: out) xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257634"}},{"Del":{"text":" | `Gw Dc :: xs, Init { req; _ } ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257678"}},{"Del":{"text":" Lwt.wakeup_later (snd req) (Error.msg \"dc'ed when connecting?\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257756"}},{"Del":{"text":" handle (read_op () :: out) xs","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257799"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257809"}},{"Del":{"text":" poll [ read_op () ]","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257836"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257844"}},{"Del":{"text":" let evloop =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257862"}},{"Del":{"text":" run () >|= function","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257889"}},{"Del":{"text":" | Ok () -> ()","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257910"}},{"Del":{"text":" | Error e -> L.err (fun m -> m \"call evloop crashed: %a\" Error.pp e)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257986"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:257994"}},{"Del":{"text":" Lwt_pipe.keep op_rx evloop;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258027"}},{"Del":{"text":" Lwt.on_termination evloop (fun () ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258069"}},{"Del":{"text":" Lwt_pipe.close_nonblock op_rx;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258109"}},{"Del":{"text":" Mixer.destroy mixer;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258139"}},{"Del":{"text":" Lwt_pipe.close_nonblock mixer_rx);","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258183"}},{"Del":{"text":" t","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258190"}},{"Del":{"text":"","pos":"G4U6J7TOHDXUL6ECIGJUSTQPURB54PC4VIAW2UGXDJPPFQLR64LQC:123373"}},{"Del":{"text":" let update_server ~token ~endpoint t =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258233"}},{"Del":{"text":" Lwt_pipe.write_exn t.tx @@ Gw (Srv { token; endpoint })","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258294"}},{"Del":{"text":"","pos":"G4U6J7TOHDXUL6ECIGJUSTQPURB54PC4VIAW2UGXDJPPFQLR64LQC:123471"}},{"Del":{"text":" let update_session ?channel_id ~session_id t =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258345"}},{"Del":{"text":" let upd =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258360"}},{"Del":{"text":" match channel_id with","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258389"}},{"Del":{"text":" | None -> Dc","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258409"}},{"Del":{"text":" | Some channel_id -> Sess { channel_id; session_id }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258469"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258477"}},{"Del":{"text":" Lwt_pipe.write_exn t.tx @@ Gw upd","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258516"}}]}},{"Replacement":{"inode":{"change":3,"pos":115320},"path":"lib/voice/call.ml","line":213,"ins":{"up_context":[{"change":3,"pos":123673}],"down_context":[],"flag":"BLOCK","start":7905,"end":8044,"inode":{"change":3,"pos":115320}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":123673},"to":{"change":2,"start":258518,"end":258659},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":258659},"to":{"change":3,"start":123805,"end":123806},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":123805},"to":{"change":3,"start":123805,"end":123806},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":123806},"to":{"change":2,"start":258660,"end":258828},"introduced_by":2}],"inode":{"change":3,"pos":115320}},"ins_contents":[{"Add":{"text":"let leave t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7918"}},{"Add":{"text":" Eio.Stream.add t.evs Gw_dc;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:7948"}},{"Add":{"text":" Gateway.send_voice_state_update t.gw ~self_mute:t.muted ~self_deaf:t.deafened","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8028"}},{"Add":{"text":" t.guild_id","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8043"}}],"del_contents":[{"Del":{"text":" let join ~channel_id t =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258545"}},{"Del":{"text":" let req = Lwt.wait () in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258575"}},{"Del":{"text":" Lwt_pipe.write_exn t.tx @@ Req (Join (channel_id, req)) >>= fun () -> fst req","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258658"}},{"Del":{"text":"","pos":"G4U6J7TOHDXUL6ECIGJUSTQPURB54PC4VIAW2UGXDJPPFQLR64LQC:123805"}},{"Del":{"text":" let leave t =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258676"}},{"Del":{"text":" Lwt_pipe.write t.tx @@ Gw Dc >>= fun _ ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258723"}},{"Del":{"text":" Gateway.send_voice_state_update t.gw ~self_mute:t.muted ~self_deaf:t.deafened","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258806"}},{"Del":{"text":" t.guild_id *)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:258827"}}]}},{"Replacement":{"inode":{"change":3,"pos":102610},"path":"lib/voice/manager.ml","line":1,"ins":{"up_context":[{"change":3,"pos":102610}],"down_context":[{"change":3,"pos":102795}],"flag":"BLOCK","start":8046,"end":8293,"inode":{"change":3,"pos":102610}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":102610},"to":{"change":2,"start":266507,"end":266775},"introduced_by":2}],"inode":{"change":3,"pos":102610}},"ins_contents":[{"Add":{"text":"open! Disco_core.Globals","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8070"}},{"Add":{"text":"module Snowflake = Disco_models.Snowflake","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8112"}},{"Add":{"text":"module E = Disco_core.Events","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8141"}},{"Add":{"text":"module Sf_map = Map.Make (Snowflake)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8178"}},{"Add":{"text":"module Gateway = Disco_core.Gateway","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8214"}},{"Add":{"text":"module L = (val Relog.logger ~namespace:__MODULE__ ())","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8269"}},{"Add":{"text":"module F = Relog.Field","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8292"}}],"del_contents":[{"Del":{"text":"(* open! Disco_core.Globals","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266534"}},{"Del":{"text":" module Snowflake = Disco_models.Snowflake","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266579"}},{"Del":{"text":" module E = Disco_core.Events","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266611"}},{"Del":{"text":" module Sf_map = Map.Make (Snowflake)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266651"}},{"Del":{"text":" module Gateway = Disco_core.Gateway","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266690"}},{"Del":{"text":" module L = (val Relog.logger ~namespace:__MODULE__ ())","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266748"}},{"Del":{"text":" module F = Relog.Field","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266774"}}]}},{"Replacement":{"inode":{"change":3,"pos":102610},"path":"lib/voice/manager.ml","line":9,"ins":{"up_context":[{"change":3,"pos":102796}],"down_context":[{"change":3,"pos":102851}],"flag":"BLOCK","start":8294,"end":8460,"inode":{"change":3,"pos":102610}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":102796},"to":{"change":2,"start":266776,"end":266859},"introduced_by":2}],"inode":{"change":3,"pos":102610}},"ins_contents":[{"Add":{"text":"type t = {","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8304"}},{"Add":{"text":" mtx : Eio_mutex.t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8325"}},{"Add":{"text":" gw : Gateway.t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8343"}},{"Add":{"text":" mutable calls : Call.t Sf_map.t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8378"}},{"Add":{"text":" spawn : snowflake -> Call.t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8409"}},{"Add":{"text":" poison : unit -> unit;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8434"}},{"Add":{"text":" mutable dead : bool;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8457"}},{"Add":{"text":"}","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8459"}}],"del_contents":[{"Del":{"text":" type t = { mtx : Eio_mutex.t; gw : Gateway.t; mutable calls : Call.t Sf_map.t }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266858"}}]}},{"Replacement":{"inode":{"change":3,"pos":102610},"path":"lib/voice/manager.ml","line":18,"ins":{"up_context":[{"change":3,"pos":102852}],"down_context":[{"change":3,"pos":108127}],"flag":"BLOCK","start":8461,"end":8527,"inode":{"change":3,"pos":102610}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":102852},"to":{"change":2,"start":266860,"end":266935},"introduced_by":2}],"inode":{"change":3,"pos":102610}},"ins_contents":[{"Add":{"text":"let user_id { gw; _ } =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8484"}},{"Add":{"text":" let user = Gateway.user gw in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8516"}},{"Add":{"text":" user.id","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8526"}}],"del_contents":[{"Del":{"text":" let user_id { gw; _ } =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266886"}},{"Del":{"text":" let user = Gateway.user gw in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266921"}},{"Del":{"text":" user.id","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266934"}}]}},{"Replacement":{"inode":{"change":3,"pos":102610},"path":"lib/voice/manager.ml","line":22,"ins":{"up_context":[{"change":3,"pos":108128}],"down_context":[{"change":3,"pos":109240}],"flag":"BLOCK","start":8528,"end":8787,"inode":{"change":3,"pos":102610}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":108128},"to":{"change":2,"start":266936,"end":267213},"introduced_by":2}],"inode":{"change":3,"pos":102610}},"ins_contents":[{"Add":{"text":"let server_update t srv =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8553"}},{"Add":{"text":" Eio_mutex.with_ t.mtx @@ fun () ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8590"}},{"Add":{"text":" L.info (fun m -> m \"srv update\");","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8626"}},{"Add":{"text":" Sf_map.get srv.E.Voice_server_update.guild_id t.calls","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8682"}},{"Add":{"text":" |> Option.iter (fun call ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8712"}},{"Add":{"text":" Call.update_server ~token:srv.token ~endpoint:srv.endpoint call)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8786"}}],"del_contents":[{"Del":{"text":" let server_update t srv =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:266964"}},{"Del":{"text":" Eio_mutex.with_ t.mtx @@ fun () ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267004"}},{"Del":{"text":" L.info (fun m -> m \"srv update\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267043"}},{"Del":{"text":" Sf_map.get srv.E.Voice_server_update.guild_id t.calls","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267102"}},{"Del":{"text":" |> Option.iter (fun call ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267135"}},{"Del":{"text":" Call.update_server ~token:srv.token ~endpoint:srv.endpoint call)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267212"}}]}},{"Replacement":{"inode":{"change":3,"pos":102610},"path":"lib/voice/manager.ml","line":29,"ins":{"up_context":[{"change":3,"pos":109241}],"down_context":[{"change":3,"pos":109943}],"flag":"BLOCK","start":8788,"end":9178,"inode":{"change":3,"pos":102610}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":109241},"to":{"change":2,"start":267214,"end":267634},"introduced_by":2}],"inode":{"change":3,"pos":102610}},"ins_contents":[{"Add":{"text":"let state_update t vst =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8812"}},{"Add":{"text":" Eio_mutex.with_ t.mtx @@ fun () ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8849"}},{"Add":{"text":" L.info (fun m -> m \"state update\");","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8887"}},{"Add":{"text":" match vst.E.Voice_state.guild_id with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8927"}},{"Add":{"text":" | Some guild_id when Snowflake.(user_id t = vst.user_id) ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:8989"}},{"Add":{"text":" Sf_map.get guild_id t.calls","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9023"}},{"Add":{"text":" |> Option.iter (fun call ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9057"}},{"Add":{"text":" Call.update_session ?channel_id:vst.channel_id","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9117"}},{"Add":{"text":" ~session_id:vst.session_id call)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9165"}},{"Add":{"text":" | _ -> ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9177"}}],"del_contents":[{"Del":{"text":" let state_update t vst =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267241"}},{"Del":{"text":" Eio_mutex.with_ t.mtx @@ fun () ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267281"}},{"Del":{"text":" L.info (fun m -> m \"state update\");","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267322"}},{"Del":{"text":" match vst.E.Voice_state.guild_id with","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267365"}},{"Del":{"text":" | Some guild_id when Snowflake.(user_id t = vst.user_id) ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267430"}},{"Del":{"text":" Sf_map.get guild_id t.calls","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267467"}},{"Del":{"text":" |> Option.iter (fun call ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267504"}},{"Del":{"text":" Call.update_session ?channel_id:vst.channel_id","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267567"}},{"Del":{"text":" ~session_id:vst.session_id call)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267618"}},{"Del":{"text":" | _ -> ()","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267633"}}]}},{"Replacement":{"inode":{"change":3,"pos":102610},"path":"lib/voice/manager.ml","line":40,"ins":{"up_context":[{"change":3,"pos":109944}],"down_context":[{"change":3,"pos":110395}],"flag":"BLOCK","start":9179,"end":10761,"inode":{"change":3,"pos":102610}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":109944},"to":{"change":2,"start":267635,"end":267884},"introduced_by":2}],"inode":{"change":3,"pos":102610}},"ins_contents":[{"Add":{"text":"let make ~env ~sw gw =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9201"}},{"Add":{"text":" let net = Eio.Stdenv.net env in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9235"}},{"Add":{"text":" let dmgr = Eio.Stdenv.domain_mgr env in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9277"}},{"Add":{"text":" let evs = Eio.Stream.create 0 in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9312"}},{"Add":{"text":" let poison () = Eio.Stream.add evs `Poison in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9360"}},{"Add":{"text":" let rec t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9374"}},{"Add":{"text":" {","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9380"}},{"Add":{"text":" mtx = Eio_mutex.make ();","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9411"}},{"Add":{"text":" calls = Sf_map.empty;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9439"}},{"Add":{"text":" gw;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9449"}},{"Add":{"text":" spawn;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9462"}},{"Add":{"text":" poison;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9476"}},{"Add":{"text":" dead = false;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9496"}},{"Add":{"text":" }","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9502"}},{"Add":{"text":" and spawn guild_id =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9525"}},{"Add":{"text":" let p, u = Promise.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9561"}},{"Add":{"text":" Eio.Stream.add evs @@ `Spawn (guild_id, Promise.resolve u);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9625"}},{"Add":{"text":" Promise.await_exn p","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9649"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9654"}},{"Add":{"text":" Gateway.sub gw ~fn:(function","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9685"}},{"Add":{"text":" | E.Voice_server_update v -> server_update t v","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9736"}},{"Add":{"text":" | Voice_state_update v -> state_update t v","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9783"}},{"Add":{"text":" | _ -> ());","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9799"}},{"Add":{"text":" let run () =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9814"}},{"Add":{"text":" Switch.run @@ fun sw ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9842"}},{"Add":{"text":" let rec loop () =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9864"}},{"Add":{"text":" match Eio.Stream.take evs with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9901"}},{"Add":{"text":" | `Poison ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9920"}},{"Add":{"text":" Eio_mutex.with_ t.mtx @@ fun () ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9965"}},{"Add":{"text":" Sf_map.to_seq t.calls","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:9997"}},{"Add":{"text":" |> Seq.map (fun (_, call) () -> Call.leave call)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10056"}},{"Add":{"text":" |> Seq.to_list |> Fiber.all;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10095"}},{"Add":{"text":" t.calls <- Sf_map.empty","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10129"}},{"Add":{"text":" | `Spawn (guild_id, req) ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10163"}},{"Add":{"text":" Eio_mutex.with_ t.mtx (fun () ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10206"}},{"Add":{"text":" match Sf_map.get guild_id t.calls with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10259"}},{"Add":{"text":" | Some call -> req @@ Ok call","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10303"}},{"Add":{"text":" | None ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10327"}},{"Add":{"text":" let res =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10355"}},{"Add":{"text":" Result.guard @@ fun () ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10401"}},{"Add":{"text":" Call.make ~sw ~net ~dmgr ~guild_id gw","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10459"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10480"}},{"Add":{"text":" Result.iter","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10510"}},{"Add":{"text":" (fun call -> t.calls <- Sf_map.add guild_id call t.calls)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10588"}},{"Add":{"text":" res;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10613"}},{"Add":{"text":" req res);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10641"}},{"Add":{"text":" loop ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10659"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10666"}},{"Add":{"text":" loop ();","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10679"}},{"Add":{"text":" raise Exit","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10694"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10699"}},{"Add":{"text":" Fiber.fork ~sw (fun () -> try run () with Exit -> ());","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10756"}},{"Add":{"text":" t","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10760"}}],"del_contents":[{"Del":{"text":" let make gw =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267651"}},{"Del":{"text":" let t = { mtx = Eio_mutex.make (); calls = Sf_map.empty; gw } in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267721"}},{"Del":{"text":" Gateway.sub gw ~fn:(function","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267755"}},{"Del":{"text":" | E.Voice_server_update v -> server_update t v","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267809"}},{"Del":{"text":" | Voice_state_update v -> state_update t","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267857"}},{"Del":{"text":" | _ -> ());","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267876"}},{"Del":{"text":" t","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267883"}}]}},{"Replacement":{"inode":{"change":3,"pos":102610},"path":"lib/voice/manager.ml","line":94,"ins":{"up_context":[{"change":3,"pos":110396}],"down_context":[{"change":3,"pos":110553}],"flag":"BLOCK","start":10762,"end":10841,"inode":{"change":3,"pos":102610}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":110396},"to":{"change":2,"start":267885,"end":268088},"introduced_by":2}],"inode":{"change":3,"pos":102610}},"ins_contents":[{"Add":{"text":"let destroy t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10777"}},{"Add":{"text":" if not @@ t.dead then (","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10803"}},{"Add":{"text":" t.dead <- true;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10823"}},{"Add":{"text":" t.poison ())","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10840"}}],"del_contents":[{"Del":{"text":" let destroy t =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267903"}},{"Del":{"text":" Eio_mutex.with_ t.mtx @@ fun () ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267943"}},{"Del":{"text":" Sf_map.to_seq t.calls","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:267970"}},{"Del":{"text":" |> Seq.map (fun (_, call) () -> Call.leave call)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268024"}},{"Del":{"text":" |> Seq.to_list |> Fiber.all;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268058"}},{"Del":{"text":" t.calls <- Sf_map.empty","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268087"}}]}},{"Replacement":{"inode":{"change":3,"pos":102610},"path":"lib/voice/manager.ml","line":99,"ins":{"up_context":[{"change":3,"pos":110554}],"down_context":[],"flag":"BLOCK","start":10842,"end":11052,"inode":{"change":3,"pos":102610}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":110554},"to":{"change":2,"start":268089,"end":268375},"introduced_by":2}],"inode":{"change":3,"pos":102610}},"ins_contents":[{"Add":{"text":"let get t ~guild_id =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10863"}},{"Add":{"text":" Eio_mutex.lock t.mtx;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10887"}},{"Add":{"text":" match Sf_map.get guild_id t.calls with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10928"}},{"Add":{"text":" | Some call ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10945"}},{"Add":{"text":" Eio_mutex.unlock t.mtx;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10975"}},{"Add":{"text":" call","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10986"}},{"Add":{"text":" | None ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:10998"}},{"Add":{"text":" Eio_mutex.unlock t.mtx;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11028"}},{"Add":{"text":" t.spawn guild_id","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11051"}}],"del_contents":[{"Del":{"text":" let get t ~guild_id =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268113"}},{"Del":{"text":" Eio_mutex.with_ t.mtx @@ fun () ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268153"}},{"Del":{"text":" match Sf_map.get guild_id t.calls with","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268197"}},{"Del":{"text":" | Some call -> call","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268222"}},{"Del":{"text":" | None ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268237"}},{"Del":{"text":" let call = Call.make t.gw ~guild_id |> Result.get_exn in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268303"}},{"Del":{"text":" t.calls <- Sf_map.add guild_id call t.calls;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268357"}},{"Del":{"text":" call *)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268374"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":1,"ins":{"up_context":[{"change":3,"pos":113800}],"down_context":[{"change":3,"pos":113829}],"flag":"BLOCK","start":11054,"end":11171,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":113800},"to":{"change":2,"start":268377,"end":268481},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"open! Disco_core.Globals","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11078"}},{"Add":{"text":"module L = (val Relog.logger ~namespace:__MODULE__ ())","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11133"}},{"Add":{"text":"module Lf_queue = Eio_utils.Lf_queue","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11170"}}],"del_contents":[{"Del":{"text":"(* open! Disco_core.Globals","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268404"}},{"Del":{"text":" open Lwt.Infix","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268422"}},{"Del":{"text":" module L = (val Relog.logger ~namespace:__MODULE__ ())","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268480"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":5,"ins":{"up_context":[{"change":3,"pos":113830}],"down_context":[{"change":3,"pos":113885}],"flag":"BLOCK","start":11172,"end":11192,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":113830},"to":{"change":2,"start":268482,"end":268581},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"exception Destroyed","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11191"}}],"del_contents":[{"Del":{"text":" type pcm_s16_frame =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268505"}},{"Del":{"text":" (int, Bigarray.int16_signed_elt, Bigarray.c_layout) Bigarray.Array1.t","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268580"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":7,"ins":{"up_context":[{"change":3,"pos":113886}],"down_context":[{"change":3,"pos":113979}],"flag":"BLOCK","start":11193,"end":11571,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":113886},"to":{"change":2,"start":268582,"end":268678},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"let spin_sleep ?(acc = 100_000L) dur =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11231"}},{"Add":{"text":" let b = Backoff.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11262"}},{"Add":{"text":" let elapsed =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11278"}},{"Add":{"text":" let start = Mtime_clock.now () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11316"}},{"Add":{"text":" fun () -> Mtime.span start (Mtime_clock.now ()) |> Mtime.Span.to_uint64_ns","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11395"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11400"}},{"Add":{"text":" (if Int64.(dur > acc) then","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11429"}},{"Add":{"text":" let init_s = Int64.(to_float (dur - acc)) /. 1e9 in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11484"}},{"Add":{"text":" Unix.sleepf init_s);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11508"}},{"Add":{"text":" while Int64.(elapsed () < dur) do","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11544"}},{"Add":{"text":" Backoff.once b","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11563"}},{"Add":{"text":" done","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11570"}}],"del_contents":[{"Del":{"text":" type pcm_f32_frame =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268605"}},{"Del":{"text":" (float, Bigarray.float32_elt, Bigarray.c_layout) Bigarray.Array1.t","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268677"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":20,"ins":{"up_context":[{"change":3,"pos":113980}],"down_context":[{"change":3,"pos":114070}],"flag":"BLOCK","start":11572,"end":11745,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":113980},"to":{"change":2,"start":268679,"end":268732},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"type t = {","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11582"}},{"Add":{"text":" reqs : req Lf_queue.t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11607"}},{"Add":{"text":" mutable state : state;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11632"}},{"Add":{"text":" mutable silence : Audio_stream.t option;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11675"}},{"Add":{"text":" dead : bool Atomic.t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11699"}},{"Add":{"text":" wakeup : (unit -> unit) option Atomic.t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11742"}},{"Add":{"text":"}","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11744"}}],"del_contents":[{"Del":{"text":" type silence_stream = bigstring Lwt_pipe.Reader.t","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268731"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":28,"ins":{"up_context":[{"change":3,"pos":114071}],"down_context":[{"change":3,"pos":114121}],"flag":"BLOCK","start":11746,"end":11844,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":114071},"to":{"change":2,"start":268733,"end":268888},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"and req =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11755"}},{"Add":{"text":" | Now_playing of stream option res","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11792"}},{"Add":{"text":" | Play of stream * unit res","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11822"}},{"Add":{"text":" | Stop of unit res","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11843"}}],"del_contents":[{"Del":{"text":" module Driver = struct","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268758"}},{"Del":{"text":" type t = {","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268774"}},{"Del":{"text":" mutable state : state;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268804"}},{"Del":{"text":" mutable silence : silence_stream option;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268852"}},{"Del":{"text":" mutable dead : bool;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268880"}},{"Del":{"text":" }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268887"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":33,"ins":{"up_context":[{"change":3,"pos":114122}],"down_context":[{"change":3,"pos":114259}],"flag":"BLOCK","start":11845,"end":11979,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":114122},"to":{"change":2,"start":268889,"end":269042},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"and 'a res = ('a, exn) result -> unit","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11882"}},{"Add":{"text":"and state = Idle | Playing of stream","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11919"}},{"Add":{"text":"and stream = { waker : bool -> unit; rx : Audio_stream.t }","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:11978"}}],"del_contents":[{"Del":{"text":" and state = Idle | Playing of stream","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:268930"}},{"Del":{"text":" and stream = { waker : waker; rx : bigstring Lwt_pipe.Reader.t }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269000"}},{"Del":{"text":" and waker = bool Lwt.t * bool Lwt.u","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269041"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":37,"ins":{"up_context":[{"change":3,"pos":114260}],"down_context":[{"change":3,"pos":114299}],"flag":"BLOCK","start":11980,"end":12039,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":114260},"to":{"change":2,"start":269043,"end":269407},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"let make_silence ?n () = Audio_stream.silence_frames ?n ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12038"}}],"del_contents":[{"Del":{"text":" let waker : unit -> waker = Lwt.task","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269084"}},{"Del":{"text":" let make_silence ?n () = Audio_stream.n_silence_pipe ?n ()","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269148"}},{"Del":{"text":" let create () = { state = Idle; silence = None; dead = false }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269216"}},{"Del":{"text":" let now () = Mtime_clock.elapsed_ns ()","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269260"}},{"Del":{"text":" let playing t = match t.state with Playing s -> Some s | _ -> None","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269332"}},{"Del":{"text":" let is_playing t = match t.state with Playing _ -> true | _ -> false","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269406"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":39,"ins":{"up_context":[{"change":3,"pos":114300}],"down_context":[{"change":3,"pos":114367}],"flag":"BLOCK","start":12040,"end":12194,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":114300},"to":{"change":2,"start":269408,"end":269580},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"let create () =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12055"}},{"Add":{"text":" {","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12059"}},{"Add":{"text":" reqs = Lf_queue.create ();","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12090"}},{"Add":{"text":" state = Idle;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12108"}},{"Add":{"text":" silence = None;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12128"}},{"Add":{"text":" dead = Atomic.make false;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12158"}},{"Add":{"text":" wakeup = Atomic.make None;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12189"}},{"Add":{"text":" }","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12193"}}],"del_contents":[{"Del":{"text":" let destroy_active t =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269435"}},{"Del":{"text":" match t.state with","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269461"}},{"Del":{"text":" | Playing s ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269483"}},{"Del":{"text":" Lwt.wakeup_later (snd s.waker) false;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269532"}},{"Del":{"text":" t.state <- Idle","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269559"}},{"Del":{"text":" | Idle -> ()","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269579"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":48,"ins":{"up_context":[{"change":3,"pos":114368}],"down_context":[{"change":3,"pos":114406}],"flag":"BLOCK","start":12195,"end":12462,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":114368},"to":{"change":2,"start":269581,"end":269612},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"let wakeup t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12209"}},{"Add":{"text":" let b = Backoff.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12240"}},{"Add":{"text":" let rec loop () =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12260"}},{"Add":{"text":" match Atomic.get t.wakeup with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12295"}},{"Add":{"text":" | None -> ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12312"}},{"Add":{"text":" | Some w as waker when Atomic.compare_and_set t.wakeup waker None -> w ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12390"}},{"Add":{"text":" | Some _ ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12406"}},{"Add":{"text":" Backoff.once b;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12430"}},{"Add":{"text":" loop ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12446"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12451"}},{"Add":{"text":" loop ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12461"}}],"del_contents":[{"Del":{"text":" let stop = destroy_active","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269611"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":60,"ins":{"up_context":[{"change":3,"pos":114407}],"down_context":[{"change":3,"pos":114446}],"flag":"BLOCK","start":12463,"end":12519,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":114407},"to":{"change":2,"start":269613,"end":269884},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"let check t = if Atomic.get t.dead then raise Destroyed","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12518"}}],"del_contents":[{"Del":{"text":" let play ~s t =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269633"}},{"Del":{"text":" match t.state with","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269659"}},{"Del":{"text":" | Playing os ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269682"}},{"Del":{"text":" Lwt.wakeup_later (snd os.waker) false;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269732"}},{"Del":{"text":" if Option.is_none t.silence then t.silence <- Some (make_silence ());","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269813"}},{"Del":{"text":" t.state <- Playing s","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269845"}},{"Del":{"text":" | Idle -> t.state <- Playing s","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269883"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":62,"ins":{"up_context":[{"change":3,"pos":114447}],"down_context":[{"change":3,"pos":114508}],"flag":"BLOCK","start":12520,"end":12586,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":114447},"to":{"change":2,"start":269885,"end":269940},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"let req t req =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12535"}},{"Add":{"text":" check t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12546"}},{"Add":{"text":" Lf_queue.push t.reqs req;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12574"}},{"Add":{"text":" wakeup t","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12585"}}],"del_contents":[{"Del":{"text":" let destroy t = if not t.dead then t.dead <- true","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269939"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":67,"ins":{"up_context":[{"change":3,"pos":114509}],"down_context":[{"change":3,"pos":114602}],"flag":"BLOCK","start":12587,"end":12864,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":114509},"to":{"change":2,"start":269941,"end":272790},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"let now_playing t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12606"}},{"Add":{"text":" let p, u = Promise.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12640"}},{"Add":{"text":" req t (Now_playing (Promise.resolve u));","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12683"}},{"Add":{"text":" Promise.await_exn p","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12705"}},{"Add":{"text":"","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12706"}},{"Add":{"text":"let is_playing t = Option.is_some @@ now_playing t","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12757"}},{"Add":{"text":"","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12758"}},{"Add":{"text":"let stop t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12771"}},{"Add":{"text":" let p, u = Promise.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12805"}},{"Add":{"text":" req t (Stop (Promise.resolve u));","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12841"}},{"Add":{"text":" Promise.await_exn p","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12863"}}],"del_contents":[{"Del":{"text":" let run ~yield ~play ~stop t =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:269976"}},{"Del":{"text":" let rec exhaust ?(i = 0) p =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270012"}},{"Del":{"text":" Lwt_pipe.read p >>= function","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270050"}},{"Del":{"text":" | Some frame ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270075"}},{"Del":{"text":" play (i + 1) frame >>= fun ok ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270121"}},{"Del":{"text":" let i = i + 1 in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270151"}},{"Del":{"text":" if ok then exhaust ~i p else Lwt.return (`Yield i)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270215"}},{"Del":{"text":" | None -> Lwt.return (`Closed i)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270257"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270267"}},{"Del":{"text":" let framelen = float Rtp._FRAME_LEN /. 1e3 in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270320"}},{"Del":{"text":" let schedule_next ?drift ?(frames = 1) () =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270371"}},{"Del":{"text":" let timeout = float frames *. framelen in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270422"}},{"Del":{"text":" let with_drift d =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270450"}},{"Del":{"text":" let delta = Int64.(now () - d |> to_float) /. 1e9 in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270514"}},{"Del":{"text":" timeout -. Float.min delta timeout","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270560"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270572"}},{"Del":{"text":" let timeout =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270595"}},{"Del":{"text":" Option.map with_drift drift |> Option.get_or ~default:timeout","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270668"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270680"}},{"Del":{"text":" L.trace (fun m ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270707"}},{"Del":{"text":" m \"sent %d frames, next tick in %f seconds\" frames timeout);","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270781"}},{"Del":{"text":" Lwt_unix.sleep timeout >|= fun () -> `Tick","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270833"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270843"}},{"Del":{"text":" let last_yield = ref None in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270879"}},{"Del":{"text":" let last_tick = ref (now ()) in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270918"}},{"Del":{"text":" let rec yield_till tick =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270951"}},{"Del":{"text":" let y =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:270968"}},{"Del":{"text":" match !last_yield with","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271002"}},{"Del":{"text":" | Some y -> y","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271027"}},{"Del":{"text":" | None ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271048"}},{"Del":{"text":" let y = yield t in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271082"}},{"Del":{"text":" last_yield := Some y;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271119"}},{"Del":{"text":" y","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271136"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271148"}},{"Del":{"text":" Lwt.choose [ tick; (y >|= fun () -> `Yield) ] >>= function","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271216"}},{"Del":{"text":" | `Yield when t.dead ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271249"}},{"Del":{"text":" Lwt.cancel tick;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271279"}},{"Del":{"text":" Lwt.return_unit","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271308"}},{"Del":{"text":" | `Yield ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271329"}},{"Del":{"text":" last_yield := None;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271362"}},{"Del":{"text":" yield_till tick","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271391"}},{"Del":{"text":" | `Tick ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271411"}},{"Del":{"text":" let t = now () in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271442"}},{"Del":{"text":" L.trace (fun m ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271473"}},{"Del":{"text":" let delta = Int64.(t - !last_tick |> to_float) in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271540"}},{"Del":{"text":" m \"tick +%2fms\" (delta /. 1e6));","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271590"}},{"Del":{"text":" last_tick := t;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271619"}},{"Del":{"text":" Lwt.return_unit","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271648"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271658"}},{"Del":{"text":" let rec f' ?(drift = now ()) ?(i = 0) () =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271708"}},{"Del":{"text":" match (t.silence, t.state) with","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271749"}},{"Del":{"text":" | _ when t.dead ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271777"}},{"Del":{"text":" destroy_active t;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271808"}},{"Del":{"text":" Lwt.return_unit","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271837"}},{"Del":{"text":" | Some s, st -> (","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271864"}},{"Del":{"text":" exhaust ~i s >>= function","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271903"}},{"Del":{"text":" | `Closed i ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271931"}},{"Del":{"text":" t.silence <- None;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:271967"}},{"Del":{"text":" (match st with Idle -> stop () | _ -> Lwt.return_unit)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272039"}},{"Del":{"text":" >>= f' ~drift ~i","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272073"}},{"Del":{"text":" | `Yield frames -> yield_till (schedule_next ~drift ~frames ()) >>= f'","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272157"}},{"Del":{"text":" )","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272172"}},{"Del":{"text":" | None, Idle ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272197"}},{"Del":{"text":" (match !last_yield with","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272234"}},{"Del":{"text":" | Some y ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272259"}},{"Del":{"text":" last_yield := None;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272296"}},{"Del":{"text":" y","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272315"}},{"Del":{"text":" | None -> yield t)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272347"}},{"Del":{"text":" >>= f'","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272367"}},{"Del":{"text":" | None, Playing s -> (","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272399"}},{"Del":{"text":" exhaust ~i s.rx >>= function","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272441"}},{"Del":{"text":" | `Closed i ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272469"}},{"Del":{"text":" t.silence <- Some (make_silence ());","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272523"}},{"Del":{"text":" t.state <- Idle;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272557"}},{"Del":{"text":" Lwt.wakeup_later (snd s.waker) true;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272611"}},{"Del":{"text":" f' ~drift ~i ()","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272644"}},{"Del":{"text":" | `Yield frames ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272676"}},{"Del":{"text":" yield_till (schedule_next ~drift ~frames ()) >>= fun () -> f' ())","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272759"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272769"}},{"Del":{"text":" f' ()","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272782"}},{"Del":{"text":" end","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272789"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":79,"ins":{"up_context":[{"change":3,"pos":114603}],"down_context":[{"change":3,"pos":110946}],"flag":"BLOCK","start":12865,"end":12976,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":114603},"to":{"change":2,"start":272791,"end":272949},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"let play ~s t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12880"}},{"Add":{"text":" let p, u = Promise.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12914"}},{"Add":{"text":" req t (Play (s, Promise.resolve u));","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12953"}},{"Add":{"text":" Promise.await_exn p","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12975"}}],"del_contents":[{"Del":{"text":" type t = { driver : Driver.t; evloop_tx : evloop_msg Lwt_pipe.Writer.t }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272866"}},{"Del":{"text":" and evloop_msg = Stop | Play of pcm_s16_frame Lwt_pipe.Reader.t * Driver.waker","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272948"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":84,"ins":{"up_context":[{"change":3,"pos":110947}],"down_context":[{"change":3,"pos":111016}],"flag":"BLOCK","start":12977,"end":13030,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":110947},"to":{"change":2,"start":272950,"end":273809},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"let destroy t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:12992"}},{"Add":{"text":" Atomic.set t.dead true;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13018"}},{"Add":{"text":" wakeup t","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13029"}}],"del_contents":[{"Del":{"text":" let create ?(burst = 15) out =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:272983"}},{"Del":{"text":" let chan = Lwt_pipe.create () in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273021"}},{"Del":{"text":" let evloop_tx = Lwt_pipe.Writer.map ~f:(fun msg -> `Req msg) chan in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273095"}},{"Del":{"text":" let driver = Driver.create () in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273133"}},{"Del":{"text":" let yield driver =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273157"}},{"Del":{"text":" Lwt_pipe.read chan >|= Option.get_or ~default:`Poison >|= function","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273231"}},{"Del":{"text":" | `Req (Play (s, waker)) ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273266"}},{"Del":{"text":" let s = Lwt_pipe.Reader.filter_map ~f:encode s in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273327"}},{"Del":{"text":" Driver.play driver ~s:{ waker; rx = s }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273378"}},{"Del":{"text":" | `Req Stop -> Driver.stop driver","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273419"}},{"Del":{"text":" | `Poison -> Driver.destroy driver","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273461"}},{"Del":{"text":" in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273469"}},{"Del":{"text":" let play i frame = out (`Play frame) >|= fun r -> r && i < burst in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273542"}},{"Del":{"text":" let stop () = out `Stop >|= ignore in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273585"}},{"Del":{"text":" let f = Driver.run ~yield ~play ~stop driver in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273638"}},{"Del":{"text":" Lwt_pipe.keep chan f;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273665"}},{"Del":{"text":" Lwt_pipe.link_close chan ~after:evloop_tx;","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273713"}},{"Del":{"text":" Lwt.on_termination f (fun () -> Lwt_pipe.close_nonblock chan);","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273781"}},{"Del":{"text":" { driver; evloop_tx }","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273808"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":88,"ins":{"up_context":[{"change":3,"pos":111017}],"down_context":[{"change":3,"pos":114644}],"flag":"BLOCK","start":13031,"end":13150,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":111017},"to":{"change":2,"start":273810,"end":274050},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"let destroy_active t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13053"}},{"Add":{"text":" match t.state with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13074"}},{"Add":{"text":" | Playing s ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13091"}},{"Add":{"text":" s.waker false;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13112"}},{"Add":{"text":" t.state <- Idle","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13134"}},{"Add":{"text":" | Idle -> ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13149"}}],"del_contents":[{"Del":{"text":" let play ?(k = fun ~status:_ s -> Lwt_pipe.close_nonblock s) t stream =","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273884"}},{"Del":{"text":" let ((wp, _) as waker) = Driver.waker () in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273933"}},{"Del":{"text":" Lwt.on_success wp (fun status -> k ~status stream);","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:273990"}},{"Del":{"text":" Lwt_pipe.write_exn t.evloop_tx (Play (stream, waker))","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:274049"}}]}},{"Replacement":{"inode":{"change":3,"pos":113800},"path":"lib/voice/mixer.ml","line":95,"ins":{"up_context":[{"change":3,"pos":114645}],"down_context":[],"flag":"BLOCK","start":13151,"end":15708,"inode":{"change":3,"pos":113800}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":114645},"to":{"change":2,"start":274051,"end":274109},"introduced_by":2}],"inode":{"change":3,"pos":113800}},"ins_contents":[{"Add":{"text":"let run ~play ~stop t =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13174"}},{"Add":{"text":" let now () = Mtime_clock.elapsed_ns () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13218"}},{"Add":{"text":" let rec exhaust ?(i = 0) src =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13251"}},{"Add":{"text":" Audio_stream.read src |> function","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13289"}},{"Add":{"text":" | Some frame ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13309"}},{"Add":{"text":" let i = i + 1 in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13334"}},{"Add":{"text":" if play (i + 1) frame then exhaust ~i src else `Yield i","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13398"}},{"Add":{"text":" | None -> `Closed i","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13422"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13427"}},{"Add":{"text":" let framelen = Int64.(of_int Rtp._FRAME_LEN * 100_000L) in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13488"}},{"Add":{"text":" let schedule_next ?drift ?(frames = 1) () =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13534"}},{"Add":{"text":" let timeout = Int64.(of_int frames * framelen) in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13588"}},{"Add":{"text":" let with_drift d =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13611"}},{"Add":{"text":" let delta = Int64.(now () - d) in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13651"}},{"Add":{"text":" Int64.(timeout - min delta timeout)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13693"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13700"}},{"Add":{"text":" let timeout =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13718"}},{"Add":{"text":" Option.map with_drift drift |> Option.get_or ~default:timeout","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13786"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13793"}},{"Add":{"text":" L.trace (fun m ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13815"}},{"Add":{"text":" m \"sent %d frames, next tick in %Ld ns (%f s)\" frames timeout","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13885"}},{"Add":{"text":" (Int64.to_float timeout /. 1e9));","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13929"}},{"Add":{"text":" spin_sleep timeout","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13952"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:13957"}},{"Add":{"text":" let rec loop ?(drift = now ()) ?(i = 0) () =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14004"}},{"Add":{"text":" if Atomic.get t.dead then (","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14036"}},{"Add":{"text":" destroy_active t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14060"}},{"Add":{"text":" (* TODO @quartz55: cancel/cleanup queued requests (how?) *)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14126"}},{"Add":{"text":" raise Exit);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14145"}},{"Add":{"text":" handle_reqs ();","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14165"}},{"Add":{"text":" process ~drift ~i","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14187"}},{"Add":{"text":" and handle_reqs () =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14210"}},{"Add":{"text":" match Lf_queue.pop t.reqs with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14245"}},{"Add":{"text":" | Some (Play (s, res)) ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14275"}},{"Add":{"text":" (match t.state with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14303"}},{"Add":{"text":" | Playing os ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14327"}},{"Add":{"text":" os.waker false;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14355"}},{"Add":{"text":" if Option.is_none t.silence then t.silence <- Some (make_silence ());","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14437"}},{"Add":{"text":" t.state <- Playing s","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14470"}},{"Add":{"text":" | Idle -> t.state <- Playing s);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14511"}},{"Add":{"text":" res (Ok ());","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14532"}},{"Add":{"text":" handle_reqs ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14555"}},{"Add":{"text":" | Some (Stop res) ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14580"}},{"Add":{"text":" destroy_active t;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14606"}},{"Add":{"text":" res (Ok ());","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14627"}},{"Add":{"text":" handle_reqs ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14650"}},{"Add":{"text":" | Some (Now_playing res) ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14682"}},{"Add":{"text":" res @@ Ok (match t.state with Idle -> None | Playing s -> Some s);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14757"}},{"Add":{"text":" handle_reqs ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14780"}},{"Add":{"text":" | None -> ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14797"}},{"Add":{"text":" and process ~drift ~i =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14823"}},{"Add":{"text":" match (t.silence, t.state) with","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14859"}},{"Add":{"text":" | Some s, st -> (","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14881"}},{"Add":{"text":" exhaust ~i s |> function","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14914"}},{"Add":{"text":" | `Closed i ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14937"}},{"Add":{"text":" t.silence <- None;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:14968"}},{"Add":{"text":" (match st with Idle -> stop () | _ -> ());","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15023"}},{"Add":{"text":" loop ~drift ~i ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15053"}},{"Add":{"text":" | `Yield frames ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15080"}},{"Add":{"text":" schedule_next ~drift ~frames ();","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15125"}},{"Add":{"text":" loop ())","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15146"}},{"Add":{"text":" | None, Playing s -> (","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15173"}},{"Add":{"text":" exhaust ~i s.rx |> function","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15209"}},{"Add":{"text":" | `Closed i ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15232"}},{"Add":{"text":" t.silence <- Some (make_silence ());","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15281"}},{"Add":{"text":" t.state <- Idle;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15310"}},{"Add":{"text":" s.waker true;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15336"}},{"Add":{"text":" loop ~drift ~i ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15366"}},{"Add":{"text":" | `Yield frames ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15393"}},{"Add":{"text":" schedule_next ~drift ~frames ();","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15438"}},{"Add":{"text":" loop ())","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15459"}},{"Add":{"text":" | None, Idle ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15479"}},{"Add":{"text":" assert (Option.is_none @@ Atomic.get t.wakeup);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15535"}},{"Add":{"text":" let p, u = Promise.create () in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15575"}},{"Add":{"text":" Atomic.set t.wakeup (Some (Promise.resolve u));","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15631"}},{"Add":{"text":" Promise.await p;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15656"}},{"Add":{"text":" loop ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15672"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15677"}},{"Add":{"text":" try loop () with Exit -> ()","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15707"}}],"del_contents":[{"Del":{"text":" let destroy t = Lwt_pipe.close_nonblock t.evloop_tx *)","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:274108"}}]}},{"Edit":{"inode":{"change":3,"pos":112242},"path":"lib/voice/session.ml","line":63,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":275558}],"down_context":[{"change":2,"pos":275558}],"flag":"BLOCK","start":15710,"end":15731,"inode":{"change":3,"pos":112242}}},"contents":[{"Add":{"text":" endpoint : string;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15730"}}]}},{"Edit":{"inode":{"change":3,"pos":112242},"path":"lib/voice/session.ml","line":307,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":282088}],"down_context":[{"change":2,"pos":282088}],"flag":"BLOCK","start":15732,"end":15750,"inode":{"change":3,"pos":112242}}},"contents":[{"Add":{"text":" endpoint;","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15749"}}]}},{"Edit":{"inode":{"change":3,"pos":112242},"path":"lib/voice/session.ml","line":320,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":282407}],"down_context":[],"flag":"BLOCK","start":15751,"end":15992,"inode":{"change":3,"pos":112242}}},"contents":[{"Add":{"text":"","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15751"}},{"Add":{"text":"let guild_id { guild_id; _ } = guild_id","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15791"}},{"Add":{"text":"let user_id { user_id; _ } = user_id","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15828"}},{"Add":{"text":"let channel_id { channel_id; _ } = channel_id","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15874"}},{"Add":{"text":"let session_id { session_id; _ } = session_id","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15920"}},{"Add":{"text":"let token { token; _ } = token","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15951"}},{"Add":{"text":"let endpoint { endpoint; _ } = endpoint","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:15991"}}]}},{"Replacement":{"inode":{"change":3,"pos":134668},"path":"lib/voice/udp_connection.ml","line":176,"ins":{"up_context":[{"change":2,"pos":284453}],"down_context":[{"change":2,"pos":284683}],"flag":"BLOCK","start":15994,"end":16344,"inode":{"change":3,"pos":134668}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":284453},"to":{"change":2,"start":284453,"end":284683},"introduced_by":2}],"inode":{"change":3,"pos":134668}},"ins_contents":[{"Add":{"text":" let ipaddr = Eio_unix.Ipaddr.of_unix @@ Unix.inet_addr_of_string ip in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:16068"}},{"Add":{"text":" let discord_addr = `Udp (ipaddr, port) in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:16114"}},{"Add":{"text":" L.dbg (fun m ->","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:16134"}},{"Add":{"text":" m \"discovering external ip using discord's voice server: %a\"","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:16203"}},{"Add":{"text":" Eio.Net.Sockaddr.pp discord_addr);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:16248"}},{"Add":{"text":" let sock =","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:16263"}},{"Add":{"text":" Eio.Net.datagram_socket ~sw net @@ `Udp (Eio.Net.Ipaddr.V4.any, 0)","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:16336"}},{"Add":{"text":" in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:16343"}}],"del_contents":[{"Del":{"text":" let discord_addr = `Udp (Eio.Net.Ipaddr.of_raw ip, port) in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:284516"}},{"Del":{"text":" let sock = Eio.Net.datagram_socket ~sw net discord_addr in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:284579"}},{"Del":{"text":" L.info (fun m ->","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:284600"}},{"Del":{"text":" m \"discovering external ip using discord's voice server: %s:%d\" ip port);","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:284682"}}]}},{"Replacement":{"inode":{"change":3,"pos":134668},"path":"lib/voice/udp_connection.ml","line":187,"ins":{"up_context":[{"change":2,"pos":284780}],"down_context":[{"change":2,"pos":284915}],"flag":"BLOCK","start":16345,"end":16540,"inode":{"change":3,"pos":134668}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":284780},"to":{"change":2,"start":284780,"end":284915},"introduced_by":2}],"inode":{"change":3,"pos":134668}},"ins_contents":[{"Add":{"text":" L.dbg (fun m -> m \"discovered ip and port: %s:%d\" ip_d port_d);","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:16412"}},{"Add":{"text":" let ipaddr_d = Eio_unix.Ipaddr.of_unix @@ Unix.inet_addr_of_string ip_d in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:16491"}},{"Add":{"text":" let local_addr = `Udp (ipaddr_d, port_d) in","pos":"VR6XFOE7TKQQYWIE26QTRB2XWYCZTNBWZ32SB43M2JVOW6EN5KJQC:16539"}}],"del_contents":[{"Del":{"text":" L.info (fun m -> m \"discovered ip and port: %s:%d\" ip_d port_d);","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:284848"}},{"Del":{"text":" let local_addr = `Udp (Eio.Net.Ipaddr.of_raw ip_d, port_d) in","pos":"AW3IHN2SW4JYIT4Y26Q45BLD5RFJ3POVSTECR4GQ3ZQVB463EZVQC:284914"}}]}}],"owner":"quartz55","repo":"discopotty","token":"U4G3xq7qidY3VI3R36CH33cwoeLH9G28+b3N1jZVTvI=","login":null}

…

Dependencies

Change contents

Review