cgmartin

<?php
/**
 * Zend Framework (http://framework.zend.com/)
 *
 * @link      http://github.com/zendframework/ZendSkeletonApplication for the canonical source repository
 * @copyright Copyright (c) 2005-2012 Zend Technologies USA Inc. (http://www.zend.com)
 * @license   http://framework.zend.com/license/new-bsd New BSD License
 */

namespace Application\Controller;

cgmartin

    public function transferAction()
    {
        $upload = new \Zend\File\Transfer\Transfer();
        $upload->setDestination('./data/tmpuploads/');
        $upload->addValidator('Extension', false, array('extension' => array('jpg','jpeg','png')));
        $upload->addValidator('Count', false, array('max' => 1));

        $rtn = array('success' => null);

        if ($this->getRequest()->isPost()) {

cgmartin

(ns clj-wamp-example
  (:require [org.httpkit.server :as http-kit]
            [clj-wamp.server :as wamp]))

; Topic URIs
(defn rpc-url [path] (str "http://clj-wamp-example/api#"   path))
(defn evt-url [path] (str "http://clj-wamp-example/event#" path))

(defn wamp-websocket-handler [req]
  (http-kit/with-channel req channel

cgmartin

(defn wamp-handler [req]
  (wamp/with-channel-validation req channel (:ws-origins-re (conf))
    (wamp/http-kit-handler channel
      {:on-open        on-open
       :on-close       on-close
       :on-call        {(rpc-url "echo")  identity                          
                        :on-before        on-before-call}
       :on-subscribe   {(evt-url "chat")  true}
       :on-publish     {(evt-url "chat")  true
                        :on-after         on-publish}})))

cgmartin

var sess;

ab.connect(
  // ...
  function (session) { // Connection callback
    sess = session;
    sess.prefix("event", "http://wamptutorial/event#"); 
    sess.subscribe("event:chat", onChatEvent);
  },
  // ...

cgmartin

(defn evt-url [path] (str "http://wamptutorial/event#" path))

(defn wamp-handler
; ...
  (clj-wamp/http-kit-handler channel
    {:on-subscribe   {(evt-url "chat")  true}
     :on-publish     {(evt-url "chat")  true}})
; ...

cgmartin

var sess;
 
ab.connect(
  // ...
  function (session) { // Connection callback
    sess = session;
    sess.prefix("rpc", "http://wamptutorial/rpc#");    
  },
  // ...
);

cgmartin

(defn rpc-url [path] (str "http://wamptutorial/rpc#" path))
 
(defn wamp-handler
; ...
  (clj-wamp/http-kit-handler channel
    {:on-call  {(rpc-url "echo")  identity}})
; ...

cgmartin

(ns my.server
  (:use org.httpkit.server
        [clojure.string :only [split trim lower-case]])
  (:import [org.httpkit.server AsyncChannel]))


(defn origin-match? [origin-re req]
  (if-let [req-origin (get-in req [:headers "origin"])]
    (re-matches origin-re req-origin)))

cgmartin

(defn rpc-url [path] (str "http://wamptutorial/rpc#" path))
(defn evt-url [path] (str "http://wamptutorial/event#" path))

(defn auth-secret [sess-id auth-key extra]
  "secret-password") ; from database
  
(defn auth-permissions [sess-id auth-key}
  ; get permissions for this user
  {:rpc       {(rpc-url "echo") true}
   :subscribe {(evt-url "chat") true}