Node.js module for querying data and integrating with Tibber Pulse through Tibber API.
| Branch | Status |
|---|---|
| master |      |
This Node.js module is used for communication with Tibber API through GraphQL queries and for retrieving data from Tibber Pulse via websocket. Tibber is a norwegian technology focused power company which is providing tools to get more insight and controll over your home and its power consumption.
Note
Breaking changes!Version 5 introduces breaking changes in TibberFeed. Due to the fact that Tibber also has introduced breaking changes in their API we had to do some small changes.
Instead of changing the whole implementation, the only noticable change is done to the constructor of
TibberFeedwhich takes aTibberQueryinstead of andIConfigobject and uses the config from the providedTibberQuery. See example below.
...
// Instantiate TibberFeed.
const tibberQuery = new TibberQuery(config);
const tibberFeed = new TibberFeed(tibberQuery, 5000);
...Click the link below to sign up, and receive 400 NOK to shop smart home gadgets from Tibber Store:
You will also need an API token from Tibber. Get it here:
npm install tibber-apiRealtime power consuption data from Tibber Pulse. Provide API token, Home ID and select what kind of information you want to retrieve.
Note! There should be only one instance running of TibberFeed per API key. Doing otherwise may return unpredictable result, or even error responses from the API.
/**
* Constructor for creating a new instance if TibberFeed.
* @constructor
* @param {TibberQueryBase} tibberQuery TibberQueryBase object.
* @param {number} timeout Feed idle timeout in milliseconds. The feed will reconnect after being idle for more than the specified number of milliseconds. Min 5000 ms.
* @param {boolean} returnAllFields Specify if you want to return all fields from the data feed.
* @param {number} connectionTimeout Feed connection timeout.
* @see {@linkcode TibberQueryBase}
*/
TibberFeed(tibberQuery: TibberQueryBase, timeout: number = 60000, returnAllFields = false, connectionTimeout: number = 30000)Created a new instance of TibberFeed with with an instance of TibberQuery and timeout. The timeout is used for reconnection when no data is received within the specified time. The config object is described later in this document.
/**
* Connect to Tibber feed.
*/
Connect();Connect to Tibber Pulse realtime data feed. The connect method has a backoff logic with jitter applied to prevent too many reconnection attemts. There is also an idle timeout functionality that ensures that the feed is always connected when it's active.
/**
* Close the Tibber feed.
*/
Close();Disconnect from Tibber Pulse data feed.
/**
* Event: open
* Called when websocket connection is established.
* @message Information message.
*/
connected(message: string)Called when the feed is connected to Tibber.
/**
* Event: connection_ack
* Called when websocket connection is authenticated.
* @message Information message.
*/
connection_ack(message: string)Called when the feed is authenticated.
/**
* Event: disconnected
* Called when websocket connection is disconnected.
* @message Information message.
*/
disconnected(message: string)Called when the feed is disconnected from Tibber.
/**
* Event: data
* Called when data is received through the websocket connection.
* @data Incoming data message from Tibber API {@link https://developer.tibber.com/docs/reference}.
* @see any
*/
data(data: any)Called when new data is available.
/**
* Log function to emit error log data to subscribers.
* @param message Log message
*/
error(error: any)Called when the feed is logging errors.
/**
* Log function to emit warning log data to subscribers.
* @param message Log message
*/
warn(message: string)Called when the feed is logging warnings.
/**
* Log function to emit log data to subscribers.
* @param message Log message
*/
log(message: string)Called when the feed is logging.
Do basic calls to Tibber API using GraphQL queries. To query the Tibber API, simply provide raw GraphQL queries in the payload of the incoming message. See Tibber API documentation and API Explorer for more informations.
/**
* Constructor
* Create an instace of TibberQuery class
* @param {IConfig} config Config object
* @param {number} requestTimeout Request timeout in milliseconds.
* @see IConfig
*/
TibberQuery(config: IConfig, requestTimeout: number = 30000);Created a new instance of TibberQuery with the desired configuration. The config object is described later in this document.
/**
* General GQL query
* @param query GQL query.
* @param variables Variables used by query parameter.
* @return Query result as JSON data
*/
query(query: string, variables?: object): Promise<any>Query Tibber API with GraphQL to retrieve data. See Tibber documentation for more information on QraphQL.
/**
* Get selected home with some selected properties, including address and owner.
* @param homeId Tibber home ID
* @return IHome object
*/
getHome(homeId: string): Promise<IHome>Get home registered to your Tibber account from home ID. This function will return a IHome object including general information. To retrieve complete IHome object, please use the getHomeComplete(homeId: string) function.
/**
* Get homes with all properties, including energy price, consumption and production.
* @param homeId Tibber home ID
* @return IHome object
*/
getHomeComplete(homeId: string): Promise<IHome>Get home registered to your Tibber account from home ID. This function will return a home object including all information.
/**
* Get homes with some selected properties, including address and owner.
* @return Array of IHome.
*/
getHomes(): Promise<IHome[]>Get all homes registered to your Tibber account. This function will return a list of homes including general information. To retrieve complete Home objects, please use the getHomesComplete() function.
/**
* Get homes with all properties, including energy price, consumption and production.
* @return Array of IHome
*/
getHomesComplete(): Promise<IHome[]>Get all homes registered to your Tibber account. This function will return a list of homes including all information.
/**
* Get current energy price for selected home.
* @param homeId Tibber home ID
* @return IPrice object
*/
getCurrentEnergyPrice(homeId: string): Promise<IPrice>Get the current energy price for selected home.
/**
* Get current energy prices from all homes registered to current user
* @return Array of IPrice
*/
getCurrentEnergyPrices(): Promise<IHome[]>Get current energy prices for all your homes.
/**
* Get energy prices for today.
* @param homeId Tibber home ID
* @return Array of IPrice
*/
getTodaysEnergyPrices(homeId: string): Promise<IPrice[]>Get NorPool energy prices for today for selected home.
/**
* Get energy prices for tomorrow. These will only be available between 12:00 and 23:59
* @param homeId Tibber home ID
* @return Array of IPrice
*/
getTomorrowsEnergyPrices(homeId: string): Promise<IPrice[]>Get NorPool energy prices for tomorrow for selected home. This will only return data between 12:00 and 23:59
/**
* Get energy consumption for one or more homes.
* Returns an array of IConsumption
* @param resolution EnergyResolution. Valid values: HOURLY, DAILY, WEEKLY, MONTHLY, ANNUAL
* @param lastCount Return the last number of records
* @param homeId Tibber home ID. Optional parameter. Empty parameter will return all registered homes.
* @return Array of IConsumption
*/
getConsumption(resolution: EnergyResolution, lastCount: number, homeId?: string): Promise<IConsumption[]>Get consumption for selected home, or all homes if homeId is not provided. EnergyResolution describes interval for data and lastCount specifies number of records to retrieve, returning the last number of records in the dataset.
/**
* Sends a push notification to the current user's tibber app.
* Returns a ISendPushNotification Object
* @param title: "The title of your message";
* @param message: "The message you want to send";
* @param screenToOpen: AppScreen Object, example: AppScreen.HOME ;
* @return ISendPushNotification Object
*/Send a notification to the tibber app. You can specify which route shoule be opened in the App when opening the message. The notification will be send to all devices registered for that tibber account. If the send is successful the response will show how many devices the message reached.
TibberFeed: typescript example.
import { TibberFeed, TibberQuery, TibberQueryBase, IConfig } from 'tibber-api';
// Config object needed when instantiating TibberQuery
const config: IConfig = {
// Endpoint configuration.
apiEndpoint: {
apiKey: '5K4MVS-OjfWhK_4yrjOlFe1F6kJXPVf7eQYggo8ebAE', // Demo token
queryUrl: 'https://api.tibber.com/v1-beta/gql',
requestTimeout: 5000,
},
// Query configuration.
homeId: '96a14971-525a-4420-aae9-e5aedaa129ff',
timestamp: true,
power: true,
};
// Instantiate TibberFeed.
const tibberQuery = new TibberQuery(config);
const tibberFeed = new TibberFeed(tibberQuery, 5000);
// Subscribe to "data" event.
tibberFeed.on('data', (data) => {
console.log(data);
});
// Connect to Tibber data feed
tibberFeed.connect();TibberQuery: typescript example.
import { TibberQuery, IConfig } from 'tibber-api';
import http from 'http';
const hostname = '127.0.0.1';
const port = 3000;
// Config object needed when instantiating TibberQuery
const config: IConfig = {
apiEndpoint: {
apiKey: '5K4MVS-OjfWhK_4yrjOlFe1F6kJXPVf7eQYggo8ebAE', // Demo token
queryUrl: 'https://api.tibber.com/v1-beta/gql',
requestTimeout: 5000,
},
};
// GraphQL query
const queryHomes = '{viewer{homes{id size appNickname appAvatar address{address1 address2 address3 postalCode city country latitude longitude}}}}';
// Instance of TibberQuery
const tibberQuery = new TibberQuery(config);
// Simple web server.
const server = http.createServer(async (req, res) => {
// Call the Tibber API and return the result.
const result = await tibberQuery.query(queryHomes);
res.statusCode = 200;
res.setHeader('Content-Type', 'application/json');
res.end(JSON.stringify(result));
});
// Start web server.
server.listen(port, hostname, () => {
console.log(`Server running at http://${hostname}:${port}/`);
});IConfig: typescript example.
// Config object needed when instantiating TibberQuery
const config: IConfig = {
// Endpoint configuration.
apiEndpoint: {
apiKey: '5K4MVS-OjfWhK_4yrjOlFe1F6kJXPVf7eQYggo8ebAE', // Demo token
queryUrl: 'https://api.tibber.com/v1-beta/gql',
requestTimeout: 5000,
},
// Query configuration.
homeId: '96a14971-525a-4420-aae9-e5aedaa129ff',
timestamp: true,
power: true,
lastMeterConsumption: true,
accumulatedConsumption: true,
accumulatedProduction: true,
accumulatedCost: true,
accumulatedReward: true,
currency: true,
minPower: true,
averagePower: true,
maxPower: true,
powerProduction: true,
minPowerProduction: true,
maxPowerProduction: true,
lastMeterProduction: true,
powerFactor: true,
voltagePhase1: true,
voltagePhase2: true,
voltagePhase3: true,
currentL1: true,
currentL2: true,
currentL3: true,
signalStrength: true,
};
![@dependabot[bot]](https://avatars.githubusercontent.com/in/29110?s=64&v=4){kind=small}
