Add support for access tokens

README.md

@@ -15,7 +15,8 @@ yarn add expo-server-sdk
 import { Expo } from 'expo-server-sdk';
 
 // Create a new Expo SDK client
-let expo = new Expo();
+// optionally providing an access token if you have enabled push security
+let expo = new Expo({ accessToken: process.env.EXPO_ACCESS_TOKEN });
 
 // Create the messages that you want to send to clients
 let messages = [];

package.json

@@ -1,6 +1,6 @@
 {
   "name": "expo-server-sdk",
-  "version": "3.5.1",
+  "version": "3.6.0",
   "description": "Server-side library for working with Expo using Node.js",
   "main": "build/ExpoClient.js",
   "types": "build/ExpoClient.d.ts",

src/ExpoClient.ts

@@ -38,6 +38,7 @@ export class Expo {
 
   private httpAgent: Agent | undefined;
   private limitConcurrentRequests: <T>(thunk: () => Promise<T>) => Promise<T>;
+  private accessToken: string | undefined;
 
   constructor(options: ExpoClientOptions = {}) {
     this.httpAgent = options.httpAgent;
@@ -46,6 +47,7 @@ export class Expo {
         ? options.maxConcurrentRequests
         : DEFAULT_CONCURRENT_REQUEST_LIMIT
     );
+    this.accessToken = options.accessToken;
   }
 
   /**
@@ -194,6 +196,9 @@ export class Expo {
       'Accept-Encoding': 'gzip, deflate',
       'User-Agent': `expo-server-sdk-node/${sdkVersion}`,
     });
+    if (this.accessToken) {
+      requestHeaders.set('Authorization', `Bearer ${this.accessToken}`);
+    }
 
     if (options.body != null) {
       const json = JSON.stringify(options.body);
@@ -328,6 +333,7 @@ function gzipAsync(data: Buffer): Promise<Buffer> {
 export type ExpoClientOptions = {
   httpAgent?: Agent;
   maxConcurrentRequests?: number;
+  accessToken?: string;
 };
 
 export type ExpoPushToken = string;

src/__tests__/ExpoClient-test.ts

@@ -22,7 +22,7 @@ test('limits the number of concurrent requests', async () => {
 });
 
 describe('sending push notification messages', () => {
-  test('sends requests to the Expo API server', async () => {
+  test('sends requests to the Expo API server without a supplied access token', async () => {
     const mockTickets = [
       { status: 'ok', id: 'XXXXXXXX-XXXX-XXXX-XXXX-XXXXXXXXXXXX' },
       { status: 'ok', id: 'YYYYYYYY-YYYY-YYYY-YYYY-YYYYYYYYYYYY' },
@@ -38,6 +38,26 @@ describe('sending push notification messages', () => {
     expect(options.headers.get('accept-encoding')).toContain('gzip');
     expect(options.headers.get('content-type')).toContain('application/json');
     expect(options.headers.get('user-agent')).toMatch(/^expo-server-sdk-node\//);
+    expect(options.headers.get('Authorization')).toBeNull();
+  });
+
+  test('sends requests to the Expo API server with a supplied access token', async () => {
+    const mockTickets = [
+      { status: 'ok', id: 'XXXXXXXX-XXXX-XXXX-XXXX-XXXXXXXXXXXX' },
+      { status: 'ok', id: 'YYYYYYYY-YYYY-YYYY-YYYY-YYYYYYYYYYYY' },
+    ];
+    (fetch as any).mock('https://exp.host/--/api/v2/push/send', { data: mockTickets });
+
+    const client = new ExpoClient({ accessToken: 'foobar' });
+    const tickets = await client.sendPushNotificationsAsync([{ to: 'a' }, { to: 'b' }]);
+    expect(tickets).toEqual(mockTickets);
+
+    const [, options] = (fetch as any).lastCall('https://exp.host/--/api/v2/push/send');
+    expect(options.headers.get('accept')).toContain('application/json');
+    expect(options.headers.get('accept-encoding')).toContain('gzip');
+    expect(options.headers.get('content-type')).toContain('application/json');
+    expect(options.headers.get('user-agent')).toMatch(/^expo-server-sdk-node\//);
+    expect(options.headers.get('Authorization')).toContain('Bearer foobar');
   });
 
   test('compresses request bodies over 1 KiB', async () => {