Packages

phoenix

1.7.13
1.8.9 1.8.8 1.8.7 1.8.6 1.8.5 1.8.4 1.8.3 1.8.2 1.8.1 1.8.0 1.8.0-rc.4 1.8.0-rc.3 1.8.0-rc.2 1.8.0-rc.1 1.8.0-rc.0 1.7.24 1.7.23 1.7.22 1.7.21 1.7.20 1.7.19 1.7.18 1.7.17 1.7.16 1.7.15 1.7.14 1.7.13 1.7.12 1.7.11 1.7.10 1.7.9 1.7.8 1.7.7 1.7.6 1.7.5 1.7.4 1.7.3 1.7.2 1.7.1 1.7.0 1.7.0-rc.3 1.7.0-rc.2 1.7.0-rc.1 1.7.0-rc.0 1.6.17 1.6.16 1.6.15 1.6.14 1.6.13 1.6.12 1.6.11 1.6.10 1.6.9 1.6.8 1.6.7 1.6.6 1.6.5 1.6.4 1.6.3 1.6.2 1.6.1 1.6.0 1.6.0-rc.1 1.6.0-rc.0 1.5.15 1.5.14 1.5.13 1.5.12 1.5.11 1.5.10 1.5.9 1.5.8 1.5.7 1.5.6 1.5.5 1.5.4 1.5.3 1.5.2 1.5.1 1.5.0 1.5.0-rc.0 1.4.18 1.4.17 1.4.16 1.4.15 1.4.14 1.4.13 1.4.12 1.4.11 1.4.10 1.4.9 1.4.8 1.4.7 1.4.6 1.4.5 1.4.4 1.4.3 1.4.2 1.4.1 1.4.0 1.4.0-rc.3 1.4.0-rc.2 1.4.0-rc.1 1.4.0-rc.0 1.3.5 1.3.4 1.3.3 1.3.2 1.3.1 1.3.0 1.3.0-rc.3 1.3.0-rc.2 1.3.0-rc.1 1.3.0-rc.0 1.2.5 1.2.4 1.2.3 1.2.2 1.2.1 1.2.0 1.2.0-rc.1 1.2.0-rc.0 1.1.9 1.1.8 1.1.7 1.1.6 1.1.5 1.1.4 1.1.3 1.1.2 1.1.1 1.1.0 1.0.6 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.17.1 0.17.0 0.16.1 0.16.0 0.15.0 0.14.0 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.7.2 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.0 0.4.1 0.4.0 0.3.1 0.3.0 0.2.11 0.2.10 0.2.9 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.0

Productive. Reliable. Fast. A productive web framework that does not compromise speed or maintainability.

Security advisory: This version has known vulnerabilities. View advisories
HexDocs

Current section

Files

Jump to
Readme
176 Versions
10 Dependencies
Dependants
5 Advisories
Files
Activity
phoenix assets js phoenix serializer.js
Raw

assets/js/phoenix/serializer.js 

/* The default serializer for encoding and decoding messages */

import {

  CHANNEL_EVENTS

} from "./constants"



export default {

  HEADER_LENGTH: 1,

  META_LENGTH: 4,

  KINDS: {push: 0, reply: 1, broadcast: 2},



  encode(msg, callback){

    if(msg.payload.constructor === ArrayBuffer){

      return callback(this.binaryEncode(msg))

    } else {

      let payload = [msg.join_ref, msg.ref, msg.topic, msg.event, msg.payload]

      return callback(JSON.stringify(payload))

    }

  },



  decode(rawPayload, callback){

    if(rawPayload.constructor === ArrayBuffer){

      return callback(this.binaryDecode(rawPayload))

    } else {

      let [join_ref, ref, topic, event, payload] = JSON.parse(rawPayload)

      return callback({join_ref, ref, topic, event, payload})

    }

  },



  // private



  binaryEncode(message){

    let {join_ref, ref, event, topic, payload} = message

    let metaLength = this.META_LENGTH + join_ref.length + ref.length + topic.length + event.length

    let header = new ArrayBuffer(this.HEADER_LENGTH + metaLength)

    let view = new DataView(header)

    let offset = 0



    view.setUint8(offset++, this.KINDS.push) // kind

    view.setUint8(offset++, join_ref.length)

    view.setUint8(offset++, ref.length)

    view.setUint8(offset++, topic.length)

    view.setUint8(offset++, event.length)

    Array.from(join_ref, char => view.setUint8(offset++, char.charCodeAt(0)))

    Array.from(ref, char => view.setUint8(offset++, char.charCodeAt(0)))

    Array.from(topic, char => view.setUint8(offset++, char.charCodeAt(0)))

    Array.from(event, char => view.setUint8(offset++, char.charCodeAt(0)))



    var combined = new Uint8Array(header.byteLength + payload.byteLength)

    combined.set(new Uint8Array(header), 0)

    combined.set(new Uint8Array(payload), header.byteLength)



    return combined.buffer

  },



  binaryDecode(buffer){

    let view = new DataView(buffer)

    let kind = view.getUint8(0)

    let decoder = new TextDecoder()

    switch(kind){

      case this.KINDS.push: return this.decodePush(buffer, view, decoder)

      case this.KINDS.reply: return this.decodeReply(buffer, view, decoder)

      case this.KINDS.broadcast: return this.decodeBroadcast(buffer, view, decoder)

    }

  },



  decodePush(buffer, view, decoder){

    let joinRefSize = view.getUint8(1)

    let topicSize = view.getUint8(2)

    let eventSize = view.getUint8(3)

    let offset = this.HEADER_LENGTH + this.META_LENGTH - 1 // pushes have no ref

    let joinRef = decoder.decode(buffer.slice(offset, offset + joinRefSize))

    offset = offset + joinRefSize

    let topic = decoder.decode(buffer.slice(offset, offset + topicSize))

    offset = offset + topicSize

    let event = decoder.decode(buffer.slice(offset, offset + eventSize))

    offset = offset + eventSize

    let data = buffer.slice(offset, buffer.byteLength)

    return {join_ref: joinRef, ref: null, topic: topic, event: event, payload: data}

  },



  decodeReply(buffer, view, decoder){

    let joinRefSize = view.getUint8(1)

    let refSize = view.getUint8(2)

    let topicSize = view.getUint8(3)

    let eventSize = view.getUint8(4)

    let offset = this.HEADER_LENGTH + this.META_LENGTH

    let joinRef = decoder.decode(buffer.slice(offset, offset + joinRefSize))

    offset = offset + joinRefSize

    let ref = decoder.decode(buffer.slice(offset, offset + refSize))

    offset = offset + refSize

    let topic = decoder.decode(buffer.slice(offset, offset + topicSize))

    offset = offset + topicSize

    let event = decoder.decode(buffer.slice(offset, offset + eventSize))

    offset = offset + eventSize

    let data = buffer.slice(offset, buffer.byteLength)

    let payload = {status: event, response: data}

    return {join_ref: joinRef, ref: ref, topic: topic, event: CHANNEL_EVENTS.reply, payload: payload}

  },



  decodeBroadcast(buffer, view, decoder){

    let topicSize = view.getUint8(1)

    let eventSize = view.getUint8(2)

    let offset = this.HEADER_LENGTH + 2

    let topic = decoder.decode(buffer.slice(offset, offset + topicSize))

    offset = offset + topicSize

    let event = decoder.decode(buffer.slice(offset, offset + eventSize))

    offset = offset + eventSize

    let data = buffer.slice(offset, buffer.byteLength)



    return {join_ref: null, ref: null, topic: topic, event: event, payload: data}

  }

}