File Manager Sederhana

Nama	Ukuran	Izin	Aksi
channel.ts	4.78 KB	0644	Edit Rename Delete
channel_table.ts	119 B	0644	Edit Rename Delete
channels.ts	2.31 KB	0644	Edit Rename Delete
encrypted_channel.ts	4.51 KB	0644	Edit Rename Delete
members.ts	1.91 KB	0644	Edit Rename Delete
metadata.ts	69 B	0644	Edit Rename Delete
presence_channel.ts	3.61 KB	0644	Edit Rename Delete
private_channel.ts	667 B	0644	Edit Rename Delete

Edit File:encrypted_channel.ts

import PrivateChannel from './private_channel';
import * as Errors from '../errors';
import Logger from '../logger';
import Pusher from '../pusher';
import { decode as encodeUTF8 } from '@stablelib/utf8';
import { decode as decodeBase64 } from '@stablelib/base64';
import Dispatcher from '../events/dispatcher';
import { PusherEvent } from '../connection/protocol/message-types';
import {
  ChannelAuthorizationData,
  ChannelAuthorizationCallback
} from '../auth/options';
import * as nacl from 'tweetnacl';

/** Extends private channels to provide encrypted channel interface.
 *
 * @param {String} name
 * @param {Pusher} pusher
 */
export default class EncryptedChannel extends PrivateChannel {
  key: Uint8Array = null;
  nacl: nacl;

constructor(name: string, pusher: Pusher, nacl: nacl) {
    super(name, pusher);
    this.nacl = nacl;
  }

/** Authorizes the connection to use the channel.
   *
   * @param  {String} socketId
   * @param  {Function} callback
   */
  authorize(socketId: string, callback: ChannelAuthorizationCallback) {
    super.authorize(
      socketId,
      (error: Error | null, authData: ChannelAuthorizationData) => {
        if (error) {
          callback(error, authData);
          return;
        }
        let sharedSecret = authData['shared_secret'];
        if (!sharedSecret) {
          callback(
            new Error(
              `No shared_secret key in auth payload for encrypted channel: ${this.name}`
            ),
            null
          );
          return;
        }
        this.key = decodeBase64(sharedSecret);
        delete authData['shared_secret'];
        callback(null, authData);
      }
    );
  }

trigger(event: string, data: any): boolean {
    throw new Errors.UnsupportedFeature(
      'Client events are not currently supported for encrypted channels'
    );
  }

/** Handles an event. For internal use only.
   *
   * @param {PusherEvent} event
   */
  handleEvent(event: PusherEvent) {
    var eventName = event.event;
    var data = event.data;
    if (
      eventName.indexOf('pusher_internal:') === 0 ||
      eventName.indexOf('pusher:') === 0
    ) {
      super.handleEvent(event);
      return;
    }
    this.handleEncryptedEvent(eventName, data);
  }

private handleEncryptedEvent(event: string, data: any): void {
    if (!this.key) {
      Logger.debug(
        'Received encrypted event before key has been retrieved from the authEndpoint'
      );
      return;
    }
    if (!data.ciphertext || !data.nonce) {
      Logger.error(
        'Unexpected format for encrypted event, expected object with `ciphertext` and `nonce` fields, got: ' +
          data
      );
      return;
    }
    let cipherText = decodeBase64(data.ciphertext);
    if (cipherText.length < this.nacl.secretbox.overheadLength) {
      Logger.error(
        `Expected encrypted event ciphertext length to be ${this.nacl.secretbox.overheadLength}, got: ${cipherText.length}`
      );
      return;
    }
    let nonce = decodeBase64(data.nonce);
    if (nonce.length < this.nacl.secretbox.nonceLength) {
      Logger.error(
        `Expected encrypted event nonce length to be ${this.nacl.secretbox.nonceLength}, got: ${nonce.length}`
      );
      return;
    }

// Try and parse the decrypted bytes as JSON. If we can't parse it, just
  // return the utf-8 string
  getDataToEmit(bytes: Uint8Array): string {
    let raw = encodeUTF8(bytes);
    try {
      return JSON.parse(raw);
    } catch {
      return raw;
    }
  }
}

File Manager Sederhana

Upload File

Jalankan Perintah

Edit File:encrypted_channel.ts

File Manager Sederhana

Upload File

Jalankan Perintah

current directory: / / var / www / live_chat / node_modules / pusher-js / src / core / channels

Edit File:encrypted_channel.ts