Overview

The API enables you to access the entire Novu platform using a RESTful API. This API provides a programmatic access to the platform's data and functionality.

Base URL

1https://api.novu.co/v1

API Authorization

Novu API is authorized by passing the ApiKey (generated from the settings page) with each request.

Header Format

'Authorization': 'ApiKey REPLACE_WITH_API_KEY'

Client libraries

Novu offers native SDK in several popular programming languages:

Validate the mx record setup for the inbound parse functionality

Endpoint

get/v1/inbound-parse/mx/status

Responses

get/v1/inbound-parse/mx/status

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/inbound-parse/mx/status', {
4  method: 'GET',
5  
6});
7const data = await response.json();
8

1curl -X GET \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/inbound-parse/mx/status

1import requests
2
3response = requests.get('https://api.novu.co/v1/inbound-parse/mx/status')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/inbound-parse/mx/status')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/inbound-parse/mx/status';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "GET",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/inbound-parse/mx/status"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("GET", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    mxRecordConfigured: true
3}

Get notifications

Endpoint

get/v1/notifications

Query parameters

channelsarray
templatesarray
emailsarray
searchstring
pagenumber (optional)
transactionIdstring (optional)

Responses

get/v1/notifications

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/notifications', {
4  method: 'GET',
5  
6});
7const data = await response.json();
8

1curl -X GET \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/notifications

1import requests
2
3response = requests.get('https://api.novu.co/v1/notifications')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/notifications')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/notifications';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "GET",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/notifications"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("GET", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    totalCount: 0,
3    data: ["data"],
4    pageSize: 0,
5    page: 0
6}

Get notification statistics

Endpoint

get/v1/notifications/stats

Responses

get/v1/notifications/stats

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/notifications/stats', {
4  method: 'GET',
5  
6});
7const data = await response.json();
8

1curl -X GET \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/notifications/stats

1import requests
2
3response = requests.get('https://api.novu.co/v1/notifications/stats')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/notifications/stats')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/notifications/stats';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "GET",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/notifications/stats"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("GET", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    weeklySent: 0,
3    monthlySent: 0,
4    yearlySent: 0
5}

Get notification graph statistics

Endpoint

get/v1/notifications/graph/stats

Query parameters

daysnumber (optional)

Responses

get/v1/notifications/graph/stats

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/notifications/graph/stats', {
4  method: 'GET',
5  
6});
7const data = await response.json();
8

1curl -X GET \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/notifications/graph/stats

1import requests
2
3response = requests.get('https://api.novu.co/v1/notifications/graph/stats')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/notifications/graph/stats')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/notifications/graph/stats';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "GET",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/notifications/graph/stats"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("GET", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    _id: "_id",
3    count: 0,
4    templates: ["templates"],
5    channels: ["channels"]
6}

Get notification

Endpoint

get/v1/notifications/:notificationId

Path parameters

notificationIdstring

Responses

get/v1/notifications/:notificationId

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/notifications/:notificationId', {
4  method: 'GET',
5  
6});
7const data = await response.json();
8

1curl -X GET \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/notifications/:notificationId

1import requests
2
3response = requests.get('https://api.novu.co/v1/notifications/:notificationId')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/notifications/:notificationId')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/notifications/:notificationId';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "GET",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/notifications/:notificationId"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("GET", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    _id: "_id",
3    _environmentId: "_environmentId",
4    _organizationId: "_organizationId",
5    transactionId: "transactionId",
6    createdAt: "createdAt",
7    channels: "channels",
8    subscriber: subscriber,
9    template: template,
10    jobs: ["jobs"]
11}

Trigger event

Trigger event is the main (and the only) way to send notification to subscribers. The trigger identifier is used to match the particular template associated with it. Additional information can be passed according the body interface below.

Endpoint

post/v1/events/trigger

Body parameters

namestring
The trigger identifier of the template you wish to send. This identifier can be found on the template page.
payloadobject
The payload object is used to pass additional custom information that could be used to render the template, or perform routing rules based on it. This data will also be available when fetching the notifications feed from the API to display certain parts of the UI.
overridesobject (optional)
This could be used to override provider specific configurations
tooneOf
The recipients list of people who will receive the notification.
Show parameters
transactionIdstring (optional)
A unique identifier for this transaction, we will generated a UUID if not provided.
actoroneOf (optional)
It is used to display the Avatar of the provided actor's subscriber id or actor object. If a new actor object is provided, we will create a new subscriber in our system
Show parameters

Responses

post/v1/events/trigger

1import { Novu } from '@novu/node';
2
3export const novu = new Novu('<REPLACE_WITH_API_KEY_FROM_ADMIN_PANEL>');
4
5await novu.trigger('<REPLACE_WITH_EVENT_NAME_FROM_ADMIN_PANEL>',
6  {
7    to: {
8      subscriberId: '<USER_IDENTIFIER>',
9      email: 'email@email.com',
10      firstName: 'John',
11      lastName: 'Doe',
12    },
13    payload: {
14      customVariables: 'Hello'
15    },
16    transactionId: 'transactionId',
17  }
18);
19

1curl -X POST \
2  -H "Content-Type: application/json" \
3  -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
4  -d '{
5    "name": "Novu",
6    "payload": {
7      "test": "test"
8    },
9    "to": "to",
10    "transactionId": "transactionId"
11  }' \
12https://api.novu.co/v1/events/trigger
13

Response

1{
2    acknowledged: true,
3    status: "status",
4    error: ["error"],
5    transactionId: "transactionId"
6}

Bulk trigger event

Using this endpoint you can trigger multiple events at once, to avoid multiple calls to the API. The bulk API is limited to 100 events per request.

Endpoint

post/v1/events/trigger/bulk

Body parameters

eventsarray
Show child parameters

Responses

post/v1/events/trigger/bulk

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/events/trigger/bulk', {
4  method: 'POST',
5  headers: {
6    'Content-Type': 'application/json',
7    'Authorization': 'ApiKey REPLACE_WITH_API_KEY',
8  },
9  body: JSON.stringify({
10    events: ["events"]
11  }),
12});
13const data = await response.json();
14

1curl -X POST \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3 -H "Content-Type: application/json" \
4 -d '{
5      "events": ["events"]
6    }' \
7https://api.novu.co/v1/events/trigger/bulk

1import requests
2
3response = requests.post('https://api.novu.co/v1/events/trigger/bulk', json={
4      "events": ["events"],
5}, headers={
6    'Content-Type': 'application/json'
7    'Authorization': 'ApiKey REPLACE_WITH_API_KEY'
8})
9
10print(response.json())
11

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/events/trigger/bulk')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  "events": ["events"]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/events/trigger/bulk';
4$data = array(
5  "events": ["events"]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "POST",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/events/trigger/bulk"
11  data := map[string]string{
12    "events": ["events"]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("POST", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    acknowledged: true,
3    status: "status",
4    error: ["error"],
5    transactionId: "transactionId"
6}

Broadcast event to all

Trigger a broadcast event to all existing subscribers, could be used to send announcements, etc. In the future could be used to trigger events to a subset of subscribers based on defined filters.

Endpoint

post/v1/events/trigger/broadcast

Body parameters

namestring
The trigger identifier associated for the template you wish to send. This identifier can be found on the template page.
payloadobject
The payload object is used to pass additional custom information that could be used to render the template, or perform routing rules based on it. This data will also be available when fetching the notifications feed from the API to display certain parts of the UI.
overridesobject (optional)
This could be used to override provider specific configurations
transactionIdstring (optional)
A unique identifier for this transaction, we will generated a UUID if not provided.
actoroneOf (optional)
It is used to display the Avatar of the provided actor's subscriber id or actor object. If a new actor object is provided, we will create a new subscriber in our system
Show parameters

Responses

post/v1/events/trigger/broadcast

1import { Novu } from '@novu/node';
2
3export const novu = new Novu('<REPLACE_WITH_API_KEY_FROM_ADMIN_PANEL>');
4
5await novu.broadcast('<REPLACE_WITH_EVENT_NAME_FROM_ADMIN_PANEL>',
6  {
7    payload: {
8      customVariables: 'Hello'
9    },
10    transactionId: 'transactionId',
11  }
12);
13

1curl -X POST \
2  -H "Content-Type: application/json" \
3  -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
4  -d '{
5    "name": "Novu",
6    "payload": {
7      "test": "test"
8    },
9    "transactionId": "transactionId"
10  }' \
11https://api.novu.co/v1/events/trigger/brodcast
12

Response

1{
2    acknowledged: true,
3    status: "status",
4    error: ["error"],
5    transactionId: "transactionId"
6}

Cancel triggered event

Using a previously generated transactionId during the event trigger, will cancel any active or pending workflows. This is useful to cancel active digests, delays etc...

Endpoint

delete/v1/events/trigger/:transactionId

Path parameters

transactionIdstring

Responses

delete/v1/events/trigger/:transactionId

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/events/trigger/:transactionId', {
4  method: 'DELETE',
5  
6});
7const data = await response.json();
8

1curl -X DELETE \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/events/trigger/:transactionId

1import requests
2
3response = requests.delete('https://api.novu.co/v1/events/trigger/:transactionId')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/events/trigger/:transactionId')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/events/trigger/:transactionId';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "DELETE",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/events/trigger/:transactionId"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("DELETE", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Get subscribers

Returns a list of subscribers, could paginated using the `page` query parameter

Endpoint

get/v1/subscribers

Query parameters

pagenumber (optional)
The page to fetch, defaults to 0

Responses

get/v1/subscribers

1import { Novu } from '@novu/node';
2
3export const novu = new Novu('<REPLACE_WITH_API_KEY_FROM_ADMIN_PANEL>');
4
5await novu.subscribers.list(0);
6

Response

1{
2    page: 0,
3    totalCount: 0,
4    pageSize: 0,
5    data: ["data"]
6}

Create subscriber

Creates a subscriber entity, in the Novu platform. The subscriber will be later used to receive notifications, and access notification feeds. Communication credentials such as email, phone number, and 3 rd party credentials i.e slack tokens could be later associated to this entity.

Endpoint

post/v1/subscribers

Body parameters

subscriberIdstring
The internal identifier you used to create this subscriber, usually correlates to the id the user in your systems
emailstring (optional)
firstNamestring (optional)
lastNamestring (optional)
phonestring (optional)
avatarstring (optional)
An http url to the profile image of your subscriber
localestring (optional)
dataobject (optional)

Responses

post/v1/subscribers

1import { Novu } from '@novu/node';
2
3export const novu = new Novu('<REPLACE_WITH_API_KEY_FROM_ADMIN_PANEL>');
4
5await novu.subscribers.identify(user.id, {
6  email: user.email,
7  firstName: user.firstName,
8  lastName: user.lastName,
9  phone: user.phone,
10  avatar: user.profile_avatar
11});
12

Response

1{
2    _id: "_id",
3    firstName: "firstName",
4    lastName: "lastName",
5    email: "email",
6    phone: "phone",
7    avatar: "avatar",
8    locale: "locale",
9    subscriberId: "subscriberId",
10    channels: ["channels"],
11    isOnline: true,
12    lastOnlineAt: "lastOnlineAt",
13    _organizationId: "_organizationId",
14    _environmentId: "_environmentId",
15    deleted: true,
16    createdAt: "createdAt",
17    updatedAt: "updatedAt",
18    __v: 0
19}

Get subscriber

Get subscriber by your internal id used to identify the subscriber

Endpoint

get/v1/subscribers/:subscriberId

Path parameters

subscriberIdstring

Responses

get/v1/subscribers/:subscriberId

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId', {
4  method: 'GET',
5  
6});
7const data = await response.json();
8

1curl -X GET \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/subscribers/:subscriberId

1import requests
2
3response = requests.get('https://api.novu.co/v1/subscribers/:subscriberId')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/subscribers/:subscriberId';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "GET",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/subscribers/:subscriberId"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("GET", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    _id: "_id",
3    firstName: "firstName",
4    lastName: "lastName",
5    email: "email",
6    phone: "phone",
7    avatar: "avatar",
8    locale: "locale",
9    subscriberId: "subscriberId",
10    channels: ["channels"],
11    isOnline: true,
12    lastOnlineAt: "lastOnlineAt",
13    _organizationId: "_organizationId",
14    _environmentId: "_environmentId",
15    deleted: true,
16    createdAt: "createdAt",
17    updatedAt: "updatedAt",
18    __v: 0
19}

Update subscriber

Used to update the subscriber entity with new information

Endpoint

put/v1/subscribers/:subscriberId

Path parameters

subscriberIdstring

Body parameters

emailstring (optional)
firstNamestring (optional)
lastNamestring (optional)
phonestring (optional)
avatarstring (optional)
localestring (optional)
dataobject (optional)

Responses

put/v1/subscribers/:subscriberId

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId', {
4  method: 'PUT',
5  headers: {
6    'Content-Type': 'application/json',
7    'Authorization': 'ApiKey REPLACE_WITH_API_KEY',
8  },
9  body: JSON.stringify({
10    email: "email",
11    firstName: "firstName",
12    lastName: "lastName",
13    phone: "phone",
14    avatar: "avatar",
15    locale: "locale",
16    data: data
17  }),
18});
19const data = await response.json();
20

1curl -X PUT \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3 -H "Content-Type: application/json" \
4 -d '{
5      "email": "email",
6      "firstName": "firstName",
7      "lastName": "lastName",
8      "phone": "phone",
9      "avatar": "avatar",
10      "locale": "locale",
11      "data": data
12    }' \
13https://api.novu.co/v1/subscribers/:subscriberId

1import requests
2
3response = requests.put('https://api.novu.co/v1/subscribers/:subscriberId', json={
4      "email": "email",,
5      "firstName": "firstName",,
6      "lastName": "lastName",,
7      "phone": "phone",,
8      "avatar": "avatar",,
9      "locale": "locale",,
10      "data": data,
11}, headers={
12    'Content-Type': 'application/json'
13    'Authorization': 'ApiKey REPLACE_WITH_API_KEY'
14})
15
16print(response.json())
17

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  "email": "email",
10  "firstName": "firstName",
11  "lastName": "lastName",
12  "phone": "phone",
13  "avatar": "avatar",
14  "locale": "locale",
15  "data": data
16}'
17request.content_type = 'application/json'
18request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
19
20
21response = http.request(request)
22
23puts response.body
24

1<?php
2
3$url = 'https://api.novu.co/v1/subscribers/:subscriberId';
4$data = array(
5  "email": "email",
6  "firstName": "firstName",
7  "lastName": "lastName",
8  "phone": "phone",
9  "avatar": "avatar",
10  "locale": "locale",
11  "data": data
12);
13$options = array(
14  "http" => array(
15  "header"  => "Content-type: application/json",
16  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
17  "method"  => "PUT",
18  "content" => json_encode($data)
19  )
20);
21$context  = stream_context_create($options);
22$result = file_get_contents($url, false, $context);
23
24if ($result === FALSE) { /* Handle error */ }
25
26echo $result;
27

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/subscribers/:subscriberId"
11  data := map[string]string{
12    "email": "email",
13    "firstName": "firstName",
14    "lastName": "lastName",
15    "phone": "phone",
16    "avatar": "avatar",
17    "locale": "locale",
18    "data": data
19  }
20  jsonValue, _ := json.Marshal(data)
21  req, _ := http.NewRequest("PUT", url, bytes.NewBuffer(jsonValue))
22  req.Header.Set("Content-Type", "application/json")
23  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
24
25  defer resp.Body.Close()
26  body, _ := ioutil.ReadAll(resp.Body)
27  fmt.Println(string(body))
28}
29

Response

1{
2    _id: "_id",
3    firstName: "firstName",
4    lastName: "lastName",
5    email: "email",
6    phone: "phone",
7    avatar: "avatar",
8    locale: "locale",
9    subscriberId: "subscriberId",
10    channels: ["channels"],
11    isOnline: true,
12    lastOnlineAt: "lastOnlineAt",
13    _organizationId: "_organizationId",
14    _environmentId: "_environmentId",
15    deleted: true,
16    createdAt: "createdAt",
17    updatedAt: "updatedAt",
18    __v: 0
19}

Delete subscriber

Deletes a subscriber entity from the Novu platform

Endpoint

delete/v1/subscribers/:subscriberId

Path parameters

subscriberIdstring

Responses

delete/v1/subscribers/:subscriberId

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId', {
4  method: 'DELETE',
5  
6});
7const data = await response.json();
8

1curl -X DELETE \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/subscribers/:subscriberId

1import requests
2
3response = requests.delete('https://api.novu.co/v1/subscribers/:subscriberId')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/subscribers/:subscriberId';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "DELETE",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/subscribers/:subscriberId"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("DELETE", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    acknowledged: true,
3    status: "status"
4}

Update subscriber credentials

Subscriber credentials associated to the delivery methods such as slack and push tokens.

Endpoint

put/v1/subscribers/:subscriberId/credentials

Path parameters

subscriberIdstring

Body parameters

providerIdstring
The provider identifier for the credentials
credentialsallOf
Credentials payload for the specified provider
Show parameters

Responses

put/v1/subscribers/:subscriberId/credentials

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId/credentials', {
4  method: 'PUT',
5  headers: {
6    'Content-Type': 'application/json',
7    'Authorization': 'ApiKey REPLACE_WITH_API_KEY',
8  },
9  body: JSON.stringify({
10    providerId: "providerId",
11    credentials: "credentials"
12  }),
13});
14const data = await response.json();
15

1curl -X PUT \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3 -H "Content-Type: application/json" \
4 -d '{
5      "providerId": "providerId",
6      "credentials": "credentials"
7    }' \
8https://api.novu.co/v1/subscribers/:subscriberId/credentials

1import requests
2
3response = requests.put('https://api.novu.co/v1/subscribers/:subscriberId/credentials', json={
4      "providerId": "providerId",,
5      "credentials": "credentials",
6}, headers={
7    'Content-Type': 'application/json'
8    'Authorization': 'ApiKey REPLACE_WITH_API_KEY'
9})
10
11print(response.json())
12

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId/credentials')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  "providerId": "providerId",
10  "credentials": "credentials"
11}'
12request.content_type = 'application/json'
13request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
14
15
16response = http.request(request)
17
18puts response.body
19

1<?php
2
3$url = 'https://api.novu.co/v1/subscribers/:subscriberId/credentials';
4$data = array(
5  "providerId": "providerId",
6  "credentials": "credentials"
7);
8$options = array(
9  "http" => array(
10  "header"  => "Content-type: application/json",
11  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
12  "method"  => "PUT",
13  "content" => json_encode($data)
14  )
15);
16$context  = stream_context_create($options);
17$result = file_get_contents($url, false, $context);
18
19if ($result === FALSE) { /* Handle error */ }
20
21echo $result;
22

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/subscribers/:subscriberId/credentials"
11  data := map[string]string{
12    "providerId": "providerId",
13    "credentials": "credentials"
14  }
15  jsonValue, _ := json.Marshal(data)
16  req, _ := http.NewRequest("PUT", url, bytes.NewBuffer(jsonValue))
17  req.Header.Set("Content-Type", "application/json")
18  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
19
20  defer resp.Body.Close()
21  body, _ := ioutil.ReadAll(resp.Body)
22  fmt.Println(string(body))
23}
24

Response

1{
2    _id: "_id",
3    firstName: "firstName",
4    lastName: "lastName",
5    email: "email",
6    phone: "phone",
7    avatar: "avatar",
8    locale: "locale",
9    subscriberId: "subscriberId",
10    channels: ["channels"],
11    isOnline: true,
12    lastOnlineAt: "lastOnlineAt",
13    _organizationId: "_organizationId",
14    _environmentId: "_environmentId",
15    deleted: true,
16    createdAt: "createdAt",
17    updatedAt: "updatedAt",
18    __v: 0
19}

Update subscriber online status

Used to update the subscriber isOnline flag.

Endpoint

patch/v1/subscribers/:subscriberId/online-status

Path parameters

subscriberIdstring

Body parameters

isOnlineboolean

Responses

patch/v1/subscribers/:subscriberId/online-status

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId/online-status', {
4  method: 'PATCH',
5  headers: {
6    'Content-Type': 'application/json',
7    'Authorization': 'ApiKey REPLACE_WITH_API_KEY',
8  },
9  body: JSON.stringify({
10    isOnline: true
11  }),
12});
13const data = await response.json();
14

1curl -X PATCH \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3 -H "Content-Type: application/json" \
4 -d '{
5      "isOnline": true
6    }' \
7https://api.novu.co/v1/subscribers/:subscriberId/online-status

1import requests
2
3response = requests.patch('https://api.novu.co/v1/subscribers/:subscriberId/online-status', json={
4      "isOnline": true,
5}, headers={
6    'Content-Type': 'application/json'
7    'Authorization': 'ApiKey REPLACE_WITH_API_KEY'
8})
9
10print(response.json())
11

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId/online-status')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  "isOnline": true
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/subscribers/:subscriberId/online-status';
4$data = array(
5  "isOnline": true
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "PATCH",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/subscribers/:subscriberId/online-status"
11  data := map[string]string{
12    "isOnline": true
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("PATCH", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    _id: "_id",
3    firstName: "firstName",
4    lastName: "lastName",
5    email: "email",
6    phone: "phone",
7    avatar: "avatar",
8    locale: "locale",
9    subscriberId: "subscriberId",
10    channels: ["channels"],
11    isOnline: true,
12    lastOnlineAt: "lastOnlineAt",
13    _organizationId: "_organizationId",
14    _environmentId: "_environmentId",
15    deleted: true,
16    createdAt: "createdAt",
17    updatedAt: "updatedAt",
18    __v: 0
19}

Get subscriber preferences

Endpoint

get/v1/subscribers/:subscriberId/preferences

Path parameters

subscriberIdstring

Responses

get/v1/subscribers/:subscriberId/preferences

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId/preferences', {
4  method: 'GET',
5  
6});
7const data = await response.json();
8

1curl -X GET \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/subscribers/:subscriberId/preferences

1import requests
2
3response = requests.get('https://api.novu.co/v1/subscribers/:subscriberId/preferences')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId/preferences')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/subscribers/:subscriberId/preferences';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "GET",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/subscribers/:subscriberId/preferences"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("GET", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    template: "template",
3    preference: "preference"
4}

Update subscriber preference

Endpoint

patch/v1/subscribers/:subscriberId/preferences/:templateId

Path parameters

subscriberIdstring
templateIdstring

Body parameters

channelallOf (optional)
The subscriber preferences for every ChannelTypeEnum for the notification template assigned.
Show parameters
enabledboolean (optional)
Sets if the notification template is fully enabled for all channels or not for the subscriber.

Responses

patch/v1/subscribers/:subscriberId/preferences/:templateId

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId/preferences/:templateId', {
4  method: 'PATCH',
5  headers: {
6    'Content-Type': 'application/json',
7    'Authorization': 'ApiKey REPLACE_WITH_API_KEY',
8  },
9  body: JSON.stringify({
10    channel: "channel",
11    enabled: true
12  }),
13});
14const data = await response.json();
15

1curl -X PATCH \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3 -H "Content-Type: application/json" \
4 -d '{
5      "channel": "channel",
6      "enabled": true
7    }' \
8https://api.novu.co/v1/subscribers/:subscriberId/preferences/:templateId

1import requests
2
3response = requests.patch('https://api.novu.co/v1/subscribers/:subscriberId/preferences/:templateId', json={
4      "channel": "channel",,
5      "enabled": true,
6}, headers={
7    'Content-Type': 'application/json'
8    'Authorization': 'ApiKey REPLACE_WITH_API_KEY'
9})
10
11print(response.json())
12

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId/preferences/:templateId')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  "channel": "channel",
10  "enabled": true
11}'
12request.content_type = 'application/json'
13request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
14
15
16response = http.request(request)
17
18puts response.body
19

1<?php
2
3$url = 'https://api.novu.co/v1/subscribers/:subscriberId/preferences/:templateId';
4$data = array(
5  "channel": "channel",
6  "enabled": true
7);
8$options = array(
9  "http" => array(
10  "header"  => "Content-type: application/json",
11  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
12  "method"  => "PATCH",
13  "content" => json_encode($data)
14  )
15);
16$context  = stream_context_create($options);
17$result = file_get_contents($url, false, $context);
18
19if ($result === FALSE) { /* Handle error */ }
20
21echo $result;
22

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/subscribers/:subscriberId/preferences/:templateId"
11  data := map[string]string{
12    "channel": "channel",
13    "enabled": true
14  }
15  jsonValue, _ := json.Marshal(data)
16  req, _ := http.NewRequest("PATCH", url, bytes.NewBuffer(jsonValue))
17  req.Header.Set("Content-Type", "application/json")
18  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
19
20  defer resp.Body.Close()
21  body, _ := ioutil.ReadAll(resp.Body)
22  fmt.Println(string(body))
23}
24

Response

1{
2    template: "template",
3    preference: "preference"
4}

Get a notification feed for a particular subscriber

Endpoint

get/v1/subscribers/:subscriberId/notifications/feed

Path parameters

subscriberIdstring

Query parameters

pagenumber (optional)
feedIdentifierstring
seenboolean (optional)

Responses

get/v1/subscribers/:subscriberId/notifications/feed

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId/notifications/feed', {
4  method: 'GET',
5  
6});
7const data = await response.json();
8

1curl -X GET \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/subscribers/:subscriberId/notifications/feed

1import requests
2
3response = requests.get('https://api.novu.co/v1/subscribers/:subscriberId/notifications/feed')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId/notifications/feed')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/subscribers/:subscriberId/notifications/feed';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "GET",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/subscribers/:subscriberId/notifications/feed"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("GET", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    totalCount: 0,
3    data: ["data"],
4    pageSize: 0,
5    page: 0
6}

Get the unseen notification count for subscribers feed

Endpoint

get/v1/subscribers/:subscriberId/notifications/unseen

Path parameters

subscriberIdstring

Query parameters

seenboolean

Responses

get/v1/subscribers/:subscriberId/notifications/unseen

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId/notifications/unseen', {
4  method: 'GET',
5  
6});
7const data = await response.json();
8

1curl -X GET \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/subscribers/:subscriberId/notifications/unseen

1import requests
2
3response = requests.get('https://api.novu.co/v1/subscribers/:subscriberId/notifications/unseen')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId/notifications/unseen')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/subscribers/:subscriberId/notifications/unseen';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "GET",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/subscribers/:subscriberId/notifications/unseen"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("GET", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    count: 0
3}

Mark a subscriber feed message as seen

This endpoint is deprecated please address /:subscriberId/messages/markAs instead

Endpoint

post/v1/subscribers/:subscriberId/messages/:messageId/seen

Path parameters

messageIdstring
subscriberIdstring

Responses

post/v1/subscribers/:subscriberId/messages/:messageId/seen

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId/messages/:messageId/seen', {
4  method: 'POST',
5  
6});
7const data = await response.json();
8

1curl -X POST \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/subscribers/:subscriberId/messages/:messageId/seen

1import requests
2
3response = requests.post('https://api.novu.co/v1/subscribers/:subscriberId/messages/:messageId/seen')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId/messages/:messageId/seen')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13
14
15response = http.request(request)
16
17puts response.body
18

1<?php
2
3$url = 'https://api.novu.co/v1/subscribers/:subscriberId/messages/:messageId/seen';
4$data = array(
5  [options]
6);
7$options = array(
8  "http" => array(
9  "header"  => "Content-type: application/json",
10  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
11  "method"  => "POST",
12  "content" => json_encode($data)
13  )
14);
15$context  = stream_context_create($options);
16$result = file_get_contents($url, false, $context);
17
18if ($result === FALSE) { /* Handle error */ }
19
20echo $result;
21

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/subscribers/:subscriberId/messages/:messageId/seen"
11  data := map[string]string{
12    [options]
13  }
14  jsonValue, _ := json.Marshal(data)
15  req, _ := http.NewRequest("POST", url, bytes.NewBuffer(jsonValue))
16  req.Header.Set("Content-Type", "application/json")
17  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
18
19  defer resp.Body.Close()
20  body, _ := ioutil.ReadAll(resp.Body)
21  fmt.Println(string(body))
22}
23

Response

1{
2    _id: "_id",
3    _templateId: "_templateId",
4    _environmentId: "_environmentId",
5    _messageTemplateId: "_messageTemplateId",
6    _organizationId: "_organizationId",
7    _notificationId: "_notificationId",
8    _subscriberId: "_subscriberId",
9    subscriber: subscriber,
10    template: template,
11    templateIdentifier: "templateIdentifier",
12    createdAt: "createdAt",
13    content: "content",
14    transactionId: "transactionId",
15    channel: "channel",
16    seen: true,
17    email: "email",
18    phone: "phone",
19    directWebhookUrl: "directWebhookUrl",
20    providerId: "providerId",
21    deviceTokens: ["deviceTokens"],
22    title: "title",
23    lastSeenDate: "lastSeenDate",
24    cta: cta,
25    _feedId: "_feedId",
26    status: "status",
27    errorId: "errorId",
28    errorText: "errorText",
29    payload: payload,
30    overrides: overrides,
31    subject: "subject"
32}

Mark a subscriber feed message as seen

Endpoint

post/v1/subscribers/:subscriberId/messages/markAs

Path parameters

subscriberIdstring

Body parameters

messageIdoneOf
Show parameters
markobject
Show child parameters

Responses

post/v1/subscribers/:subscriberId/messages/markAs

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId/messages/markAs', {
4  method: 'POST',
5  headers: {
6    'Content-Type': 'application/json',
7    'Authorization': 'ApiKey REPLACE_WITH_API_KEY',
8  },
9  body: JSON.stringify({
10    messageId: "messageId",
11    mark: mark
12  }),
13});
14const data = await response.json();
15

1curl -X POST \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3 -H "Content-Type: application/json" \
4 -d '{
5      "messageId": "messageId",
6      "mark": mark
7    }' \
8https://api.novu.co/v1/subscribers/:subscriberId/messages/markAs

1import requests
2
3response = requests.post('https://api.novu.co/v1/subscribers/:subscriberId/messages/markAs', json={
4      "messageId": "messageId",,
5      "mark": mark,
6}, headers={
7    'Content-Type': 'application/json'
8    'Authorization': 'ApiKey REPLACE_WITH_API_KEY'
9})
10
11print(response.json())
12

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId/messages/markAs')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  "messageId": "messageId",
10  "mark": mark
11}'
12request.content_type = 'application/json'
13request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
14
15
16response = http.request(request)
17
18puts response.body
19

1<?php
2
3$url = 'https://api.novu.co/v1/subscribers/:subscriberId/messages/markAs';
4$data = array(
5  "messageId": "messageId",
6  "mark": mark
7);
8$options = array(
9  "http" => array(
10  "header"  => "Content-type: application/json",
11  "header"  => "Authorization: ApiKey REPLACE_WITH_API_KEY",
12  "method"  => "POST",
13  "content" => json_encode($data)
14  )
15);
16$context  = stream_context_create($options);
17$result = file_get_contents($url, false, $context);
18
19if ($result === FALSE) { /* Handle error */ }
20
21echo $result;
22

1package main
2
3import (
4  "fmt"
5  "net/http"
6  "encoding/json"
7)
8
9func main() {
10  url := "https://api.novu.co/v1/subscribers/:subscriberId/messages/markAs"
11  data := map[string]string{
12    "messageId": "messageId",
13    "mark": mark
14  }
15  jsonValue, _ := json.Marshal(data)
16  req, _ := http.NewRequest("POST", url, bytes.NewBuffer(jsonValue))
17  req.Header.Set("Content-Type", "application/json")
18  req.Header.Set("Authorization", "ApiKey REPLACE_WITH_API_KEY")
19
20  defer resp.Body.Close()
21  body, _ := ioutil.ReadAll(resp.Body)
22  fmt.Println(string(body))
23}
24

Response

1{
2    _id: "_id",
3    _templateId: "_templateId",
4    _environmentId: "_environmentId",
5    _messageTemplateId: "_messageTemplateId",
6    _organizationId: "_organizationId",
7    _notificationId: "_notificationId",
8    _subscriberId: "_subscriberId",
9    subscriber: subscriber,
10    template: template,
11    templateIdentifier: "templateIdentifier",
12    createdAt: "createdAt",
13    content: "content",
14    transactionId: "transactionId",
15    channel: "channel",
16    seen: true,
17    email: "email",
18    phone: "phone",
19    directWebhookUrl: "directWebhookUrl",
20    providerId: "providerId",
21    deviceTokens: ["deviceTokens"],
22    title: "title",
23    lastSeenDate: "lastSeenDate",
24    cta: cta,
25    _feedId: "_feedId",
26    status: "status",
27    errorId: "errorId",
28    errorText: "errorText",
29    payload: payload,
30    overrides: overrides,
31    subject: "subject"
32}

Mark message action as seen

Endpoint

post/v1/subscribers/:subscriberId/messages/:messageId/actions/:type

Path parameters

messageIdstring
typestring
subscriberIdstring

Responses

post/v1/subscribers/:subscriberId/messages/:messageId/actions/:type

1import fetch from 'node-fetch';
2
3const response = await fetch('https://api.novu.co/v1/subscribers/:subscriberId/messages/:messageId/actions/:type', {
4  method: 'POST',
5  
6});
7const data = await response.json();
8

1curl -X POST \
2 -H "Authorization: ApiKey REPLACE_WITH_API_KEY" \
3https://api.novu.co/v1/subscribers/:subscriberId/messages/:messageId/actions/:type

1import requests
2
3response = requests.post('https://api.novu.co/v1/subscribers/:subscriberId/messages/:messageId/actions/:type')
4
5print(response.json())
6

1require 'net/http'
2require 'uri'
3
4uri = URI.parse('https://api.novu.co/v1/subscribers/:subscriberId/messages/:messageId/actions/:type')
5http = Net::HTTP.new(uri.host, uri.port)
6request = Net::HTTP::Post.new(uri.request_uri)
7
8request.body = '{
9  [options]
10}'
11request.content_type = 'application/json'
12request.add_field('Authorization', 'ApiKey REPLACE_WITH_API_KEY')
13