Jan/node-red-contrib-nextcloud
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

use ical.js to parse calendar data

Browse Source
This commit is contained in:
basti76
2018-09-10 16:42:15 +02:00
parent a6c5e2ca21
commit 59ebab8467
1 changed files with 41 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

77
nextcloud.js
View File

@ -1,7 +1,8 @@
module.exports = function(RED) { module.exports = function (RED) {
let dav = require('dav') let dav = require('dav')
let webdav = require('webdav') let webdav = require('webdav')
const fs = require('fs') const fs = require('fs')
const ICAL = require('ical.js');
function NextcloudConfigNode(n) { function NextcloudConfigNode(n) {
RED.nodes.createNode(this, n) RED.nodes.createNode(this, n)
@ -9,8 +10,8 @@ module.exports = function(RED) {
} }
RED.nodes.registerType('nextcloud-credentials', NextcloudConfigNode, { RED.nodes.registerType('nextcloud-credentials', NextcloudConfigNode, {
credentials: { credentials: {
user: {type: 'text'}, user: { type: 'text' },
pass: {type: 'password'} pass: { type: 'password' }
} }
}) })
@ -20,8 +21,8 @@ module.exports = function(RED) {
this.calendar = n.calendar this.calendar = n.calendar
let node = this let node = this
node.on('input', function(msg) { node.on('input', function (msg) {
const xhr = new dav.transport.Basic ( const xhr = new dav.transport.Basic(
new dav.Credentials({ new dav.Credentials({
username: node.server.credentials.user, username: node.server.credentials.user,
password: node.server.credentials.pass password: node.server.credentials.pass
@ -32,35 +33,39 @@ module.exports = function(RED) {
// User // User
calDavUri += node.server.credentials.user + '/' calDavUri += node.server.credentials.user + '/'
dav.createAccount({ server: calDavUri, xhr: xhr }) dav.createAccount({ server: calDavUri, xhr: xhr })
.then(function(account) { .then(function (account) {
if (!account.calendars) { if (!account.calendars) {
node.error('Nextcloud:CalDAV -> no calendars found.') node.error('Nextcloud:CalDAV -> no calendars found.')
return return
} }
// account instanceof dav.Account // account instanceof dav.Account
account.calendars.forEach(function(calendar) { account.calendars.forEach(function (calendar) {
// Wenn Kalender gesetzt ist, dann nur diesen abrufen // Wenn Kalender gesetzt ist, dann nur diesen abrufen
let c = msg.calendar || node.calendar let c = msg.calendar || node.calendar
if (!c || !c.length || (c && c.length && c === calendar.displayName)) { if (!c || !c.length || (c && c.length && c === calendar.displayName)) {
dav.listCalendarObjects(calendar, { xhr: xhr }) dav.listCalendarObjects(calendar, { xhr: xhr })
.then(function(calendarEntries) { .then(function (calendarEntries) {
let icsList = {'payload': {'name': calendar.displayName, 'data': []}} let icsList = { 'payload': { 'name': calendar.displayName, 'data': [] } }
calendarEntries.forEach(function(calendarEntry) { calendarEntries.forEach(function (calendarEntry) {
const keyValue = calendarEntry.calendarData.split('\n') node.warn(calendarEntry.calendarData);
let icsJson = {} node.warn(JSON.stringify(calendarEntry.calendarData.split('\n')));
for (let x = 0; x < keyValue.length; x++) { try {
const temp = keyValue[x].split(':') let jCalData = ICAL.parse(calendarEntry.calendarData);
icsJson[temp[0]] = temp[1] let component = new ICAL.Component(jCalData);
let vevent = component.getFirstSubcomponent('vevent');
var event = new ICAL.Event(vevent);
icsList.payload.data.push(event);
} catch (error) {
node.error("Error parsing calendar data: " + error);
} }
icsList.payload.data.push(icsJson)
}) })
node.send(icsList) node.send(icsList)
}, function(){ }, function () {
node.error('Nextcloud:CalDAV -> get ics went wrong.') node.error('Nextcloud:CalDAV -> get ics went wrong.')
}) })
} }
}) })
}, function(){ }, function () {
node.error('Nextcloud:CalDAV -> get calendars went wrong.') node.error('Nextcloud:CalDAV -> get calendars went wrong.')
}) })
}) })
@ -74,8 +79,8 @@ module.exports = function(RED) {
this.addressBook = n.addressBook this.addressBook = n.addressBook
let node = this let node = this
node.on('input', function(msg) { node.on('input', function (msg) {
const xhr = new dav.transport.Basic ( const xhr = new dav.transport.Basic(
new dav.Credentials({ new dav.Credentials({
username: node.server.credentials.user, username: node.server.credentials.user,
password: node.server.credentials.pass password: node.server.credentials.pass
@ -86,22 +91,22 @@ module.exports = function(RED) {
let cardDavUri = node.server.address + '/remote.php/dav/addressbooks/users/' let cardDavUri = node.server.address + '/remote.php/dav/addressbooks/users/'
// User // User
cardDavUri += node.server.credentials.user + '/' cardDavUri += node.server.credentials.user + '/'
// ToDo Filter ? // ToDo Filter ?
dav.createAccount({ server: cardDavUri, xhr: xhr, accountType: 'carddav' }) dav.createAccount({ server: cardDavUri, xhr: xhr, accountType: 'carddav' })
.then(function(account) { .then(function (account) {
if (!account.addressBooks) { if (!account.addressBooks) {
node.error('Nextcloud:CardDAV -> no addressbooks found.') node.error('Nextcloud:CardDAV -> no addressbooks found.')
return return
} }
// account instanceof dav.Account // account instanceof dav.Account
account.addressBooks.forEach(function(addressBook) { account.addressBooks.forEach(function (addressBook) {
// Wenn Adressbuch gesetzt ist, dann nur diesen abrufen // Wenn Adressbuch gesetzt ist, dann nur diesen abrufen
let c = msg.addressBook || node.addressBook let c = msg.addressBook || node.addressBook
if (!c || !c.length || (c && c.length && c === addressBook.displayName)) { if (!c || !c.length || (c && c.length && c === addressBook.displayName)) {
dav.listVCards(addressBook, { xhr: xhr }) dav.listVCards(addressBook, { xhr: xhr })
.then(function(addressBookEntries) { .then(function (addressBookEntries) {
let vcfList = {'payload': {'name': addressBook.displayName, 'data': []}} let vcfList = { 'payload': { 'name': addressBook.displayName, 'data': [] } }
addressBookEntries.forEach(function(addressBookEntry) { addressBookEntries.forEach(function (addressBookEntry) {
const keyValue = addressBookEntry.addressData.split('\n') const keyValue = addressBookEntry.addressData.split('\n')
let vcfJson = {} let vcfJson = {}
for (let x = 0; x < keyValue.length; x++) { for (let x = 0; x < keyValue.length; x++) {
@ -111,12 +116,12 @@ module.exports = function(RED) {
vcfList.payload.data.push(vcfJson) vcfList.payload.data.push(vcfJson)
}) })
node.send(vcfList) node.send(vcfList)
}, function(){ }, function () {
node.error('Nextcloud:CardDAV -> get cards went wrong.') node.error('Nextcloud:CardDAV -> get cards went wrong.')
}) })
} }
}) })
}, function(){ }, function () {
node.error('Nextcloud:CardDAV -> get addressBooks went wrong.') node.error('Nextcloud:CardDAV -> get addressBooks went wrong.')
}) })
@ -131,7 +136,7 @@ module.exports = function(RED) {
this.directory = n.directory this.directory = n.directory
let node = this let node = this
node.on('input', function(msg) { node.on('input', function (msg) {
const webDavUri = node.server.address + '/remote.php/webdav/' const webDavUri = node.server.address + '/remote.php/webdav/'
const client = webdav(webDavUri, node.server.credentials.user, node.server.credentials.pass) const client = webdav(webDavUri, node.server.credentials.user, node.server.credentials.pass)
let directory = '' let directory = ''
@ -144,7 +149,7 @@ module.exports = function(RED) {
client.getDirectoryContents(directory) client.getDirectoryContents(directory)
.then(function (contents) { .then(function (contents) {
node.send({'payload': contents}) node.send({ 'payload': contents })
}, function (error) { }, function (error) {
node.error('Nextcloud:WebDAV -> get directory content went wrong.' + JSON.stringify(error)) node.error('Nextcloud:WebDAV -> get directory content went wrong.' + JSON.stringify(error))
}) })
@ -159,7 +164,7 @@ module.exports = function(RED) {
this.filename = n.filename this.filename = n.filename
let node = this let node = this
node.on('input', function(msg) { node.on('input', function (msg) {
const webDavUri = node.server.address + '/remote.php/webdav/' const webDavUri = node.server.address + '/remote.php/webdav/'
const client = webdav(webDavUri, node.server.credentials.user, node.server.credentials.pass) const client = webdav(webDavUri, node.server.credentials.user, node.server.credentials.pass)
let filename = '' let filename = ''
@ -175,7 +180,7 @@ module.exports = function(RED) {
node.warn(filename) node.warn(filename)
client.getFileContents(filename) client.getFileContents(filename)
.then(function (contents) { .then(function (contents) {
node.send({'payload': contents}) node.send({ 'payload': contents })
}, function (error) { }, function (error) {
node.error('Nextcloud:WebDAV -> get file went wrong.' + JSON.stringify(error)) node.error('Nextcloud:WebDAV -> get file went wrong.' + JSON.stringify(error))
}) })
@ -191,7 +196,7 @@ module.exports = function(RED) {
this.filename = n.filename this.filename = n.filename
let node = this let node = this
node.on('input', function(msg) { node.on('input', function (msg) {
// Read upload file // Read upload file
let filename = node.filename let filename = node.filename
if (msg.filename) { if (msg.filename) {
@ -212,10 +217,10 @@ module.exports = function(RED) {
const client = webdav(webDavUri, node.server.credentials.user, node.server.credentials.pass) const client = webdav(webDavUri, node.server.credentials.user, node.server.credentials.pass)
client.putFileContents(directory + name, file, { format: 'binary' }) client.putFileContents(directory + name, file, { format: 'binary' })
.then(function(contents) { .then(function (contents) {
console.log(contents) console.log(contents)
node.send({'payload': JSON.parse(contents)}) node.send({ 'payload': JSON.parse(contents) })
}, function() { }, function () {
node.error('Nextcloud:WebDAV -> send file went wrong.') node.error('Nextcloud:WebDAV -> send file went wrong.')
}) })
}) })