tmm1 / jssocket

generic javascript socket API

This URL has Read+Write access

Ruby License
tmm1 (author)
Sun Jul 26 21:48:10 -0700 2009
commit  6842e31476ec4c51b6cd595058a663207e52a382
tree    289a153e279763538877787342f98064e588d599
parent  c0e8a8794f916cf0a08ccd09061ab2244a580945
jssocket / examples / echo.rb
100644 117 lines (102 sloc) 3.769 kb
raw blame history 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

require 'rubygems'
require 'eventmachine'
require 'thin'
require 'haml'
 
__DIR__ = File.dirname File.expand_path(__FILE__)
 
EM.run{
 
  class FlashServer < EM::Connection
    def self.start host, port
      puts ">> FlashServer started on #{host}:#{port}"
      EM.start_server host, port, self
    end
 
    def post_init
      @buf = BufferedTokenizer.new("\0")
      @ip = Socket.unpack_sockaddr_in(get_peername).last rescue '0.0.0.0'
      puts ">> FlashServer got connection from #{@ip}"
    end
 
    def unbind
      @timer.cancel if @timer
      puts ">> FlashServer got disconnect from #{@ip}"
    end
 
    def receive_data data
      if data.strip == "<policy-file-request/>"
        send %[
          <?xml version="1.0"?>
          <!DOCTYPE cross-domain-policy SYSTEM "http://www.macromedia.com/xml/dtds/cross-domain-policy.dtd">
          <cross-domain-policy>
            <allow-access-from domain="*" to-ports="*" />
          </cross-domain-policy>
        ]
        close_connection_after_writing
        return
      end
 
      @buf.extract(data).each do |packet|
        puts ">> FlashServer got packet from #{@ip}: #{packet}"
        send "you said: '#{packet}' from #{@ip} at #{Time.now}"
      end
    end
 
    def send data
      send_data "#{data}\0"
    end
  end
  
  class StaticApp
    def self.call env
      [ 
        200,
        {'Content-Type' => 'text/html'},
        @page ||= Haml::Engine.new(%[
          %html
            %head
              %title jsSocket example: #{File.basename __FILE__}
              %style{ :type => 'text/css'}
                :sass
                  body
                    margin: 1.5em
                    font-size: 14pt
                    font-family: monospace sans-serif
                  #history
                    height: 200px
                    width: 90%
                    overflow-y: scroll
                    p
                      margin: 0
                      padding: 0
                  form#input
                    input
                      width: 90%
            %body
              %h1 jsSocket example: #{File.basename __FILE__}
 
              #history
              %form#input
                %input{ :type => 'text' }/
 
              %script{ :type => 'text/javascript', :src => '/js/jquery-latest.min.js' }= ''
              %script{ :type => 'text/javascript', :src => '/js/jquery.media.js' }= ''
              %script{ :type => 'text/javascript', :src => '/js/jsonStringify.js' }= ''
              %script{ :type => 'text/javascript', :src => '/js/jsSocket.js' }= ''
 
              :javascript
                $socket = jsSocket({ port: 1234,
                                     debug: true,
                                     logger: console.log,
                                     onData: function(data){
                                       $('#history').append(
                                        $('<p/>').text(data)
                                       ).each(function(){
                                         this.scrollTop = this.scrollHeight
                                       }) 
                                     }
                                  })
                $('form#input').submit(function(){
                  $socket.send($(this).find('input').val())
                  $(this).find('input').val('')
                  return false
                })
        ].gsub(/^          /,'')).render
      ]
    end
  end
  
  map = Rack::URLMap.new '/'      => StaticApp,
                         '/js'    => Rack::File.new(__DIR__ + '/../js'),
                         '/flash' => Rack::File.new(__DIR__ + '/../flash')
  
  http  = Thin::Server.start 'localhost', 1233, map
  flash = FlashServer.start  'localhost', 1234
  
}