-
Notifications
You must be signed in to change notification settings - Fork 2
/
main.js
142 lines (124 loc) · 4.25 KB
/
main.js
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
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
"use strict";
/*
* Created with @iobroker/create-adapter vunknown
*/
// The adapter-core module gives you access to the core ioBroker functions
// you need to create an adapter
const utils = require("@iobroker/adapter-core");
const request = require("request");
// Load your modules here, e.g.:
// const fs = require("fs");
class tunnelbrokerEndpointUpdater extends utils.Adapter {
/**
* @param {Partial<ioBroker.AdapterOptions>} [options={}]
*/
constructor(options) {
super({
...options,
name: "tunnelbroker-endpoint-updater",
});
this.on("ready", this.onReady);
this.on("objectChange", this.onObjectChange);
this.on("stateChange", this.onStateChange);
// this.on("message", this.onMessage);
this.on("unload", this.onUnload);
this.updateIp();
}
/**
* Is called when databases are connected and adapter received configuration.
*/
async onReady() {
// Initialize your adapter here
// The adapters config (in the instance object everything under the attribute "native") is accessible via
// this.config:
this.log.debug("config username: " + this.config.username);
this.log.debug("config updatekey: " + this.config.updatekey);
this.log.debug("config tunnelId: " + this.config.tunnelId);
await this.updateIp();
}
/**
* Is called when adapter shuts down - callback has to be called under any circumstances!
* @param {() => void} callback
*/
onUnload(callback) {
try {
this.log.info("cleaned everything up...");
callback();
} catch (e) {
callback();
}
}
/**
* Is called if a subscribed object changes
* @param {string} id
* @param {ioBroker.Object | null | undefined} obj
*/
onObjectChange(id, obj) {
if (obj) {
// The object was changed
this.log.info(`object ${id} changed: ${JSON.stringify(obj)}`);
} else {
// The object was deleted
this.log.info(`object ${id} deleted`);
}
}
/**
* Is called if a subscribed state changes
* @param {string} id
* @param {ioBroker.State | null | undefined} state
*/
onStateChange(id, state) {
if (state) {
// The state was changed
this.log.info(`state ${id} changed: ${state.val} (ack = ${state.ack})`);
} else {
// The state was deleted
this.log.info(`state ${id} deleted`);
}
}
/**
* Main Function that Updates the IP Address on Tunnelbroker.net
*/
async updateIp() {
try {
const url = "https://" + this.config.username + ":" + this.config.updatekey + "@ipv4.tunnelbroker.net/nic/update?hostname=" + this.config.tunnelId;
this.log.info(url);
const self = this;
request({method: "GET", url}, function (error, response, result) {
self.log.info("update TunnelBroker IP output: " + result);
self.stop();
}).on("error", function (e) {
self.log.info(e);
self.stop();
});
} catch (e) {
this.log.info("Catch Error");
this.log.info(e);
}
}
// /**
// * Some message was sent to this instance over message box. Used by email, pushover, text2speech, ...
// * Using this method requires "common.message" property to be set to true in io-package.json
// * @param {ioBroker.Message} obj
// */
// onMessage(obj) {
// if (typeof obj === "object" && obj.message) {
// if (obj.command === "send") {
// // e.g. send email or pushover or whatever
// this.log.info("send command");
// // Send response in callback if required
// if (obj.callback) this.sendTo(obj.from, obj.command, "Message received", obj.callback);
// }
// }
// }
}
if (module.parent) {
// Export the constructor in compact mode
/**
* @param {Partial<ioBroker.AdapterOptions>} [options={}]
*/
module.exports = (options) => new tunnelbrokerEndpointUpdater(options);
} else {
// otherwise start the instance directly
new tunnelbrokerEndpointUpdater();
}