frodovdr
/
node-red-nodes
mirror of https://github.com/node-red/node-red-nodes.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Update pusher dependencies & code (#974) 

* update pusher dependencies & code

* Update package.json

* update pusher icon

* Reverting some package.json changes

* add contributors

* Add padding to icon

* resize icon

* Updated available clusters

* update broken link to cluster option

* Update clusters for out node
This commit is contained in:
Chad Gregory 2023-02-02 05:57:05 -05:00 committed by GitHub
parent a8edd0cb56
commit 0a0917b67a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 60 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
social/pusher/icons/pusher.png
View File

Binary file not shown.
Side by Side Swipe Overlay

Before

Width:  |  Height:  |  Size: 4.1 KiB

After

Width:  |  Height:  |  Size: 1.3 KiB

14
social/pusher/package.json
View File

@ -1,10 +1,10 @@
{ {
"name": "node-red-node-pusher", "name": "node-red-node-pusher",
"version": "0.1.0", "version": "0.1.1",
"description": "A Node-RED node to send and receive messages using Pusher.com", "description": "A Node-RED node to send and receive messages using Pusher.com",
"dependencies": { "dependencies": {
"pusher": "^1.5.1", "pusher": "^5.1.2",
"pusher-client": "^1.1.0" "pusher-js": "^8.0.1"
}, },
"repository": { "repository": {
"type": "git", "type": "git",
@ -25,5 +25,11 @@
"name": "Dave Conway-Jones", "name": "Dave Conway-Jones",
"email": "ceejay@vnet.ibm.com", "email": "ceejay@vnet.ibm.com",
"url": "http://nodered.org" "url": "http://nodered.org"
} },
"contributors": [
{
"name": "Shaqaruden",
"email": "shaqaruden@gmail.com"
}
]
} }

30
social/pusher/pusher.html
View File

@ -2,11 +2,11 @@
<script type="text/x-red" data-template-name="pusher in"> <script type="text/x-red" data-template-name="pusher in">
<div class="form-row"> <div class="form-row">
<label for="node-input-channel"><i class="fa fa-random"></i> Channel</label> <label for="node-input-channel"><i class="fa fa-random"></i> Channel</label>
<input type="text" id="node-input-channel" placeholder="my_channel"> <input type="text" id="node-input-channel" placeholder="Channel">
</div> </div>
<div class="form-row"> <div class="form-row">
<label for="node-input-eventname"><i class="fa fa-tasks"></i> Event</label> <label for="node-input-eventname"><i class="fa fa-tasks"></i> Event</label>
<input type="text" id="node-input-eventname" placeholder="test_event_name"> <input type="text" id="node-input-eventname" placeholder="Event Name">
</div> </div>
<div class="form-row"> <div class="form-row">
<label for="node-input-pusherappkeysub"><i class="fa fa-lock"></i> App Key</label> <label for="node-input-pusherappkeysub"><i class="fa fa-lock"></i> App Key</label>
@ -15,10 +15,15 @@
<div class="form-row"> <div class="form-row">
<label for="node-input-cluster"><i class="fa fa-server"></i> Cluster</label> <label for="node-input-cluster"><i class="fa fa-server"></i> Cluster</label>
<select type="text" id="node-input-cluster"> <select type="text" id="node-input-cluster">
<option value="mt1">us-east-1 (US - default)</option> <option value="mt1">N. Virginia (US - default)</option>
<option value="eu">eu-west-1 (Europe)</option> <option value="us2">Ohio (US)</option>
<option value="ap1">ap-southeast-1 (Singapore)</option> <option value="us3">Oregon (US)</option>
<option value="ap2">ap-south-1 (Mumbai)</option> <option value="eu">Ireland (Europe)</option>
<option value="ap1">Singapore (Asia)</option>
<option value="ap2">Mumbai (India)</option>
<option value="ap3">Tokyo (Asia)</option>
<option value="ap4">Sydney (Australia)</option>
<option value="sa1">São Paulo (Brazil)</option>
</select> </select>
</div> </div>
<div class="form-row"> <div class="form-row">
@ -87,10 +92,15 @@
<div class="form-row"> <div class="form-row">
<label for="node-input-cluster"><i class="fa fa-server"></i> Cluster</label> <label for="node-input-cluster"><i class="fa fa-server"></i> Cluster</label>
<select type="text" id="node-input-cluster"> <select type="text" id="node-input-cluster">
<option value="mt1">us-east-1 (US - default)</option> <option value="mt1">N. Virginia (US - default)</option>
<option value="eu">eu-west-1 (Europe)</option> <option value="us2">Ohio (US)</option>
<option value="ap1">ap-southeast-1 (Singapore)</option> <option value="us3">Oregon (US)</option>
<option value="ap2">ap-south-1 (Mumbai)</option> <option value="eu">Ireland (Europe)</option>
<option value="ap1">Singapore (Asia)</option>
<option value="ap2">Mumbai (India)</option>
<option value="ap3">Tokyo (Asia)</option>
<option value="ap4">Sydney (Australia)</option>
<option value="sa1">São Paulo (Brazil)</option>
</select> </select>
</div> </div>

56
social/pusher/pusher.js
View File

@ -1,12 +1,12 @@
module.exports = function(RED) { module.exports = function (RED) {
"use strict"; "use strict";
var Pusher = require('pusher'); const Pusher = require("pusher")
var PusherClient = require('pusher-client'); const PusherClient = require('pusher-js');
//node for subscribing to an event/channel //node for subscribing to an event/channel
function PusherNode(n) { function PusherNode(n) {
RED.nodes.createNode(this,n); RED.nodes.createNode(this, n);
this.channel = n.channel; this.channel = n.channel;
this.eventname = n.eventname; this.eventname = n.eventname;
this.cluster = n.cluster || "mt1"; this.cluster = n.cluster || "mt1";
@ -19,19 +19,21 @@ module.exports = function(RED) {
else { this.error("No Pusher app key set for input node"); } else { this.error("No Pusher app key set for input node"); }
//create a subscription to the channel and event defined by user //create a subscription to the channel and event defined by user
var socket = new PusherClient(''+node.appkey, {cluster:node.cluster, encrypted:true}); // var socket = new PusherClient(''+node.appkey, {cluster:node.cluster, encrypted:true});
var chan = socket.subscribe(''+node.channel); const pusher = new PusherClient('' + node.appkey, {
chan.bind(''+node.eventname, cluster: node.cluster
function(data) { });
var msg = {topic:node.eventname, channel:node.channel}; const channel = pusher.subscribe('' + node.channel);
if (data.hasOwnProperty("payload")) { msg.payload = data.payload; }
else { msg.payload = data; }
node.send(msg);
}
);
node.on("close", function() { channel.bind('' + node.eventname, function (data) {
socket.disconnect(); var msg = { topic: node.eventname, channel: node.channel };
if (data.hasOwnProperty("payload")) { msg.payload = data.payload; }
else { msg.payload = data; }
node.send(msg);
});
node.on("close", function () {
pusher.disconnect();
}); });
} }
@ -39,7 +41,7 @@ module.exports = function(RED) {
//Node for sending Pusher events //Node for sending Pusher events
function PusherNodeSend(n) { function PusherNodeSend(n) {
// Create a RED node // Create a RED node
RED.nodes.createNode(this,n); RED.nodes.createNode(this, n);
var node = this; var node = this;
var credentials = this.credentials; var credentials = this.credentials;
@ -56,33 +58,35 @@ module.exports = function(RED) {
this.eventname = n.eventname; this.eventname = n.eventname;
this.cluster = n.cluster || "mt1"; this.cluster = n.cluster || "mt1";
var pusherd = new Pusher({ var pusher = new Pusher({
appId: this.appid, appId: this.appid,
key: this.appkey, key: this.appkey,
secret: this.appsecret, secret: this.appsecret,
cluster: this.cluster cluster: this.cluster
}); });
node.on("input", function(msg) {
pusherd.trigger(this.channel, this.eventname, {
node.on("input", function (msg) {
pusher.trigger(this.channel, this.eventname, {
"payload": msg.payload "payload": msg.payload
}); });
}); });
node.on("close", function() { node.on("close", function () {
}); });
} }
RED.nodes.registerType("pusher in",PusherNode,{ RED.nodes.registerType("pusher in", PusherNode, {
credentials: { credentials: {
pusherappkeysub: "text" pusherappkeysub: "text"
} }
}); });
RED.nodes.registerType("pusher out",PusherNodeSend,{ RED.nodes.registerType("pusher out", PusherNodeSend, {
credentials: { credentials: {
pusherappid: {type:"text"}, pusherappid: { type: "text" },
pusherappkey: {type:"text"}, pusherappkey: { type: "text" },
pusherappsecret: {type:"password"} pusherappsecret: { type: "password" }
}, },
encrypted: true encrypted: true
}); });