/* This Source Code Form is subject to the terms of the Mozilla Public * License, v. 2.0. If a copy of the MPL was not distributed with this * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ use dom::bindings::codegen::Bindings::WorkerBinding; use dom::bindings::codegen::Bindings::WorkerBinding::WorkerMethods; use dom::bindings::error::{Fallible, Syntax}; use dom::bindings::global::GlobalRef; use dom::bindings::js::{JSRef, Temporary}; use dom::bindings::trace::Untraceable; use dom::bindings::utils::{Reflectable, Reflector, reflect_dom_object}; use dom::dedicatedworkerglobalscope::DedicatedWorkerGlobalScope; use dom::eventtarget::{EventTarget, WorkerTypeId}; use servo_util::str::DOMString; use url::UrlParser; #[deriving(Encodable)] pub struct Worker { eventtarget: EventTarget, sender: Untraceable>, } impl Worker { pub fn new_inherited(sender: Sender) -> Worker { Worker { eventtarget: EventTarget::new_inherited(WorkerTypeId), sender: Untraceable::new(sender), } } pub fn new(global: &GlobalRef, sender: Sender) -> Temporary { reflect_dom_object(box Worker::new_inherited(sender), global, WorkerBinding::Wrap) } // http://www.whatwg.org/html/#dom-worker pub fn Constructor(global: &GlobalRef, scriptURL: DOMString) -> Fallible> { // Step 2-4. let worker_url = match UrlParser::new().base_url(&global.get_url()) .parse(scriptURL.as_slice()) { Ok(url) => url, Err(_) => return Err(Syntax), }; let (sender, receiver) = channel(); let resource_task = global.resource_task(); DedicatedWorkerGlobalScope::run_worker_scope( worker_url, receiver, resource_task, global.script_chan().clone()); Ok(Worker::new(global, sender)) } } impl<'a> WorkerMethods for JSRef<'a, Worker> { fn PostMessage(&self, message: DOMString) { self.sender.send(message); } } impl Reflectable for Worker { fn reflector<'a>(&'a self) -> &'a Reflector { self.eventtarget.reflector() } }