Implement ServiceWorker::postMessage() [Blink]

Source/core/dom/MessagePort.cpp

 /*
  * Copyright (C) 2008 Apple Inc. All Rights Reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2. Redistributions in binary form must reproduce the above copyright
  *    notice, this list of conditions and the following disclaimer in the
@@ skipping 69 matching lines @@
                 exceptionState.throwDOMException(DataCloneError, "Port at index " + String::number(i) + " contains the source port.");
                 return;
             }
         }
         channels = MessagePort::disentanglePorts(ports, exceptionState);
         if (exceptionState.hadException())
             return;
     }
 
     blink::WebString messageString = message->toWireString();
-    blink::WebMessagePortChannelArray* webChannels = 0;
+    OwnPtr<blink::WebMessagePortChannelArray> webChannels = toWebMessagePortChannelArray(channels.get());
+    m_entangledChannel->postMessage(messageString, webChannels.leakPtr());
+}
+
+// static
+PassOwnPtr<blink::WebMessagePortChannelArray> MessagePort::toWebMessagePortChannelArray(MessagePortChannelArray* channels)
+{
+    OwnPtr<blink::WebMessagePortChannelArray> webChannels;
     if (channels && channels->size()) {
-        webChannels = new blink::WebMessagePortChannelArray(channels->size());
+        webChannels = adoptPtr(new blink::WebMessagePortChannelArray(channels->size()));
         for (size_t i = 0; i < channels->size(); ++i)
             (*webChannels)[i] = (*channels)[i].leakPtr();
     }
-    m_entangledChannel->postMessage(messageString, webChannels);
+    return webChannels.release();
+}
+
+// static
+PassOwnPtr<MessagePortArray> MessagePort::toMessagePortArray(ExecutionContext* context, const blink::WebMessagePortChannelArray& webChannels)
+{
+    OwnPtr<MessagePortArray> ports;
+    if (!webChannels.isEmpty()) {
+        OwnPtr<MessagePortChannelArray> channels = adoptPtr(new MessagePortChannelArray(webChannels.size()));
+        for (size_t i = 0; i < webChannels.size(); ++i)
+            (*channels)[i] = adoptPtr(webChannels[i]);
+        ports = MessagePort::entanglePorts(*context, channels.release());
+    }
+    return ports.release();
 }
 
 PassOwnPtr<blink::WebMessagePortChannel> MessagePort::disentangle()
 {
     ASSERT(m_entangledChannel);
     m_entangledChannel->setClient(0);
     return m_entangledChannel.release();
 }
 
 // Invoked to notify us that there are messages available for this port.
@@ skipping 124 matching lines @@
     OwnPtr<MessagePortArray> portArray = adoptPtr(new MessagePortArray(channels->size()));
     for (unsigned int i = 0; i < channels->size(); ++i) {
         RefPtr<MessagePort> port = MessagePort::create(context);
         port->entangle((*channels)[i].release());
         (*portArray)[i] = port.release();
     }
     return portArray.release();
 }
 
 } // namespace WebCore