|
5 | 5 | * ------------------------------------------------------------------------------------------- |
6 | 6 | */ |
7 | 7 |
|
8 | | -import { IGraph, Providers, error, log } from '@microsoft/mgt-element'; |
| 8 | +import { BetaGraph, IGraph, Providers, error, log } from '@microsoft/mgt-element'; |
9 | 9 | import * as signalR from '@microsoft/signalr'; |
10 | 10 | import { ThreadEventEmitter } from './ThreadEventEmitter'; |
11 | 11 | import type { Subscription, ChatMessage, Chat, AadUserConversationMember } from '@microsoft/microsoft-graph-types'; |
@@ -43,16 +43,15 @@ export class GraphNotificationClient { |
43 | 43 | private get graph() { |
44 | 44 | return this._graph; |
45 | 45 | } |
| 46 | + private get beta() { |
| 47 | + return BetaGraph.fromGraph(this._graph); |
| 48 | + } |
46 | 49 |
|
47 | 50 | /** |
48 | 51 | * |
49 | 52 | */ |
50 | 53 | constructor(private readonly emitter: ThreadEventEmitter, private readonly _graph: IGraph) {} |
51 | 54 |
|
52 | | - private get _publicKey() { |
53 | | - return 'LS0tLS1CRUdJTiBDRVJUSUZJQ0FURS0tLS0tDQpNSUlGblRDQ0E0V2dBd0lCQWdJVUdJL1N3SDhjMDZ0NzB3VWtrTUxnN2UrN2hha3dEUVlKS29aSWh2Y05BUUVMDQpCUUF3WGpFTE1Ba0dBMVVFQmhNQ2RYTXhDekFKQmdOVkJBZ01BbmRoTVJBd0RnWURWUVFIREFkeVpXUnRiMjVrDQpNUkF3RGdZRFZRUUtEQWRqYjI1MGIzTnZNUXd3Q2dZRFZRUUxEQU5rWlhZeEVEQU9CZ05WQkFNTUIyMW5kQzVrDQpaWFl3SGhjTk1qTXdPREUzTVRnMU5UVTRXaGNOTWpRd09ERTJNVGcxTlRVNFdqQmVNUXN3Q1FZRFZRUUdFd0oxDQpjekVMTUFrR0ExVUVDQXdDZDJFeEVEQU9CZ05WQkFjTUIzSmxaRzF2Ym1ReEVEQU9CZ05WQkFvTUIyTnZiblJ2DQpjMjh4RERBS0JnTlZCQXNNQTJSbGRqRVFNQTRHQTFVRUF3d0hiV2QwTG1SbGRqQ0NBaUl3RFFZSktvWklodmNODQpBUUVCQlFBRGdnSVBBRENDQWdvQ2dnSUJBTFEyQnVKNWdwZ3RjMTYwM0hVMlMrUjBJaFlqOHRNd29UQ1FCc2pVDQpxVW44ZS9GRDduaUQ2ZGRpNWVvRzdXZkdHd2MrUnIzS0tYV3VDemJRQlJnb0xLZk8wbUdtVWFuaEt1a3JKYXBqDQpxYmoycDZReERYMTJCQjlORHVrQ1NEZy9ZdmdjeThTRHBEYTBSL3pyTE9UU2VTb0J1MzhzbGNEbmxBcDVMbTc3DQorTVVqNFV2cG5lWFIrOXRFUjFBQWQySVpZT1RTTFM2bllId2plUndtQ2FhV1VITHYrdnR2emQ3MUdiWmlUenBRDQpDNXNtS1dJUmVzM3VGOGoyb3hXcndJY042WVZuV3lQb3RXT2NNZEhSdmdyVDZSSjdQSCtkYmlMUlJ5OW1ORk94DQptbUJJY2ZxaWRSVHREZlFEYndNeExhNXArRlNvRW92QWhNUi9rUFRMaDkzSkkyZDJxVStEQnJnQkhYZ0dRSHZDDQo4TUZsaVBpVGJwZWJ3R09sbkNHQnZpdWp2cEJ2TUJscUhJU3RlTE0zOGwvUFRna1VsVmtrMURrdjgvRko5TlZHDQpZN2piUmV5ck4wbmlpcXRadHNUOVpNb1FQNnErdWpON0M1clA5NzdVQzlySnZ6TG9TcVhIVVh3SWhRVXUrd3dPDQpnYlBmTVpyZG1aT1NGRzMxSjQvT0tDRW0zMGNtZFR3VmdJeUJOUjNBTlJXUDdtVzdBakFsSmY5ckszVkZMK3FDDQpUM244RXlJcXVQRnVDd05uWGpWbXpQNzJZRU5MWEE4Y0lYczNFVGNDeE1VQjZ1RTlJY2hOK1ROemdpeklsNTVSDQpKa0RETFdoVmFlcHUzOFRpcldWTHI5TG8wZWRwemRMcmZoOHNXU3JJbjRYaVRTWE94d2VEMUNldW42MkRCSFl0DQpGSnMzQWdNQkFBR2pVekJSTUIwR0ExVWREZ1FXQkJScmhPQ0pZNUFUeWNTNkdhT3BwS3NscnlUWW5qQWZCZ05WDQpIU01FR0RBV2dCUnJoT0NKWTVBVHljUzZHYU9wcEtzbHJ5VFluakFQQmdOVkhSTUJBZjhFQlRBREFRSC9NQTBHDQpDU3FHU0liM0RRRUJDd1VBQTRJQ0FRQi8wRTZnd0lpMU1ESHkxc1hISFJQb2tYbVdkeFZ0YmY3YUw3elI3YllkDQpKaUVXRzEzc1J6SElFa3pETTMwUkRJT2xvZnRrbUM1bUM2R09XMmh2WTk4alMzQnM4Z0xIVktwNTU2NVpoT01mDQpheWVId0ZmK1NON1VMRDhMYVNsSTNqVkIydzlkZFFObjhHbm1oejBYckJqektOcEl0NzVyYXFaSGpXRGVwR3lxDQpkS1dsSXJ6RktSOVF6dVV4MzhTeDNxSzlaMWhRdHBQcXJ4U1R6dU92S1RzRDU4TXpMR1JEcUl3NHFmNkRxL2R0DQptTVdnRVEvNXFrMFI5b2pDNnRGYUhjVHFxZGYwSk8xcjNPYUxDTDVFMWtYNGl3WTdPSSs2K3k3NVR4ZjROZ0x1DQpLTGcyUWZrTGRLOXorS1JsQm1tWTI4Y0dOZHV5bmtzVFM3QnpyRHQzMjRSMEV0M0V5QzRzQzRlb2JyTGFTbi9ODQpKcU83S3VIaHdheE8wUmFnN0dPNTdZTWFpNy8yV0kxQ09vTlhFOTJUTEg5NXFuMFBJWWVtSlhEVmdsOE8ybzJBDQplcmU2R1JBQXc3UWFjSERpUjdFd1o5UnVwQldNTkFxbHpiNGRFNk13bzZtWkMwcDQrQng0MHZnb2hKbWtiNXhiDQozclJsME0wM0F6RmQwVWpqNGtLOGkzdy9ic0E4cDdMWUlIS3BjQkVjS3MzbGwvV2Y3UTlhVE1LS3NvTDNTdlpYDQpIT0xrS3pYbGc4K1l4blJKZ3ZoS2I4WmFQV3R1V25ZeG5oaUlYVk4yeVBqdjlzcU56NWVmWDJOTDByczhCV0Z4DQp2T0tUcCt5dnp2aVhDeVVpSW9LMFVacHpNTWlaY05LUEdOTHgxWkM4UDJVSTNENWwwL1IvWHo5UGtSTjVveFFzDQppZz09DQotLS0tLUVORCBDRVJUSUZJQ0FURS0tLS0t'; |
54 | | - } |
55 | | - |
56 | 55 | private readonly getToken = async () => { |
57 | 56 | const token = await Providers.globalProvider.getAccessToken(); |
58 | 57 | if (!token) throw new Error('Could not retrieve token for user'); |
@@ -156,12 +155,12 @@ export class GraphNotificationClient { |
156 | 155 |
|
157 | 156 | log('subscribing to changes for ' + resourcePath); |
158 | 157 | // send subscription POST to Graph |
159 | | - const subscription: Subscription = (await this.graph |
| 158 | + const subscription: Subscription = (await this.beta |
160 | 159 | .api(GraphConfig.subscriptionEndpoint) |
161 | 160 | .post(subscriptionDefinition)) as Subscription; |
162 | 161 | if (!subscription?.notificationUrl) throw new Error('Subscription not created'); |
163 | 162 | log(subscription); |
164 | | - subscription.notificationUrl = GraphConfig.adjustNotificationUrl(subscription.notificationUrl); |
| 163 | + // subscription.notificationUrl = GraphConfig.adjustNotificationUrl(subscription.notificationUrl); |
165 | 164 |
|
166 | 165 | const awaits: Promise<void>[] = []; |
167 | 166 | // Cache the subscription in storage for re-hydration on page refreshes |
@@ -298,7 +297,7 @@ export class GraphNotificationClient { |
298 | 297 | if (someExpired) { |
299 | 298 | await this.removeSubscriptions(cacheData.subscriptions); |
300 | 299 | } else if (webSocketUrl) { |
301 | | - await this.createSignalRConnection(GraphConfig.adjustNotificationUrl(webSocketUrl)); |
| 300 | + await this.createSignalRConnection(webSocketUrl); |
302 | 301 | await this.renewChatSubscriptions(); |
303 | 302 | return; |
304 | 303 | } |
|
0 commit comments