Merge pull request dddwa#20 from dddwa/migrate-to-tito

migrate to tito. Looks fine
vatsalyagoel · Apr 9, 2019 · 229fc72 · 229fc72
2 parents a08e0dc + 63f20f1
commit 229fc72
Show file tree

Hide file tree

Showing 20 changed files with 202 additions and 184 deletions.
diff --git a/DDD.Core/DDD.Core.csproj b/DDD.Core/DDD.Core.csproj
@@ -5,8 +5,8 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="WindowsAzure.Storage" Version="8.6.0" />
-    <PackageReference Include="Polly" Version="5.9.0" />
+    <PackageReference Include="WindowsAzure.Storage" Version="9.3.3" />
+    <PackageReference Include="Polly" Version="7.0.3" />
   </ItemGroup>
 
 </Project>
diff --git a/DDD.Core/Eventbrite/EventbriteOrder.cs b/DDD.Core/Eventbrite/EventbriteOrder.cs
diff --git a/DDD.Core/Tito/TitoOrder.cs b/DDD.Core/Tito/TitoOrder.cs
@@ -0,0 +1,20 @@
+
+using Microsoft.WindowsAzure.Storage.Table;
+
+namespace DDD.Core.Tito
+{
+    public class TitoOrder : TableEntity
+    {
+        public TitoOrder()
+        {
+        }
+
+        public TitoOrder(string conferenceInstance, string orderNumber)
+        {
+            PartitionKey = conferenceInstance;
+            RowKey = orderNumber;
+        }
+
+        public string OrderId => RowKey;
+    }
+}
diff --git a/DDD.Functions.Extensions/DDD.Functions.Extensions.csproj b/DDD.Functions.Extensions/DDD.Functions.Extensions.csproj
@@ -5,7 +5,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="microsoft.net.sdk.functions" Version="1.0.22" />
+    <PackageReference Include="microsoft.net.sdk.functions" Version="1.0.26" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/DDD.Functions.Extensions/KeyDatesConfig.cs b/DDD.Functions.Extensions/KeyDatesConfig.cs
@@ -45,10 +45,10 @@ public class KeyDatesConfig : Attribute
         public string StopSyncingAppInsightsFrom { get; set; }
         public DateTimeOffset StopSyncingAppInsightsFromDate => StopSyncingAppInsightsFrom != null ? DateTimeOffset.Parse(StopSyncingAppInsightsFrom) : DateTimeOffset.MinValue;
 
-        // Eventbrite Sync
-        [AppSetting(Default = "StopSyncingEventbriteFrom")]
-        public string StopSyncingEventbriteFrom { get; set; }
-        public DateTimeOffset StopSyncingEventbriteFromDate => StopSyncingEventbriteFrom != null ? DateTimeOffset.Parse(StopSyncingEventbriteFrom) : DateTimeOffset.MinValue;
+        // Tito Sync
+        [AppSetting(Default = "StopSyncingTitoFrom")]
+        public string StopSyncingTitoFrom { get; set; }
+        public DateTimeOffset StopSyncingTitoFromDate => StopSyncingTitoFrom != null ? DateTimeOffset.Parse(StopSyncingTitoFrom) : DateTimeOffset.MinValue;
 
         public bool Before(Func<KeyDatesConfig, DateTimeOffset> date, TimeSpan? tolerance = null)
         {

diff --git a/DDD.Functions.Extensions/SessionData.cs b/DDD.Functions.Extensions/SessionData.cs
@@ -1,7 +1,7 @@
 using System.Threading.Tasks;
 using DDD.Core.AppInsights;
 using DDD.Core.AzureStorage;
-using DDD.Core.Eventbrite;
+using DDD.Core.Tito;
 using DDD.Core.Voting;
 using Microsoft.WindowsAzure.Storage;
 
@@ -26,9 +26,9 @@ public static async Task<ITableStorageRepository<NotifiedSessionEntity>> GetRepo
             return GetSessionRepositoryAsync(config.ConnectionString, config.SessionsTable, config.PresentersTable);
         }
 
-        public static async Task<ITableStorageRepository<EventbriteOrder>> GetRepositoryAsync(this EventbriteSyncConfig config)
+        public static async Task<ITableStorageRepository<TitoOrder>> GetRepositoryAsync(this TitoSyncConfig config)
         {
-            var repo = new TableStorageRepository<EventbriteOrder>(CloudStorageAccount.Parse(config.ConnectionString), config.Table);
+            var repo = new TableStorageRepository<TitoOrder>(CloudStorageAccount.Parse(config.ConnectionString), config.Table);
             await repo.InitializeAsync();
             return repo;
         }

diff --git a/...ctions.Extensions/EventbriteSyncConfig.cs → DDD.Functions.Extensions/TitoSyncConfig.cs b/...ctions.Extensions/EventbriteSyncConfig.cs → DDD.Functions.Extensions/TitoSyncConfig.cs
@@ -4,32 +4,34 @@
 
 namespace DDD.Functions.Extensions
 {
-    public class EventbriteSyncConfig : Attribute
+    public class TitoSyncConfig : Attribute
     {
         [AppSetting(Default = "VotesConnectionString")]
         public string ConnectionString { get; set; }
-        [AppSetting(Default = "EventbriteTable")]
+        [AppSetting(Default = "TitoTable")]
         public string Table { get; set; }
-        [AppSetting(Default = "EventbriteApiBearerToken")]
+        [AppSetting(Default = "TitoApiBearerToken")]
         public string ApiKey { get; set; }
-        [AppSetting(Default = "EventbriteEventId")]
+        [AppSetting(Default = "TitoEventId")]
         public string EventId { get; set; }
+        [AppSetting(Default = "TitoAccountId")]
+        public string AccountId { get; set; }
     }
 
     [AttributeUsage(AttributeTargets.Parameter | AttributeTargets.ReturnValue)]
     [Binding]
-    public class BindEventbriteSyncConfigAttribute : EventbriteSyncConfig { }
+    public class BindTitoSyncConfigAttribute : TitoSyncConfig { }
 
-    public class BindEventbriteSyncConfigExtension : IExtensionConfigProvider
+    public class BindTitoSyncConfigExtension : IExtensionConfigProvider
     {
         public void Initialize(ExtensionConfigContext context)
         {
-            var rule = context.AddBindingRule<BindEventbriteSyncConfigAttribute>();
+            var rule = context.AddBindingRule<BindTitoSyncConfigAttribute>();
 
             rule.BindToInput(BuildItemFromAttr);
         }
 
-        private EventbriteSyncConfig BuildItemFromAttr(BindEventbriteSyncConfigAttribute attr)
+        private TitoSyncConfig BuildItemFromAttr(BindTitoSyncConfigAttribute attr)
         {
             return attr;
         }

diff --git a/DDD.Functions/DDD.Functions.csproj b/DDD.Functions/DDD.Functions.csproj
@@ -4,7 +4,7 @@
     <AzureFunctionsVersion>v2</AzureFunctionsVersion>
   </PropertyGroup>
   <ItemGroup>    
-    <PackageReference Include="Microsoft.NET.Sdk.Functions" Version="1.0.22" />
+    <PackageReference Include="Microsoft.NET.Sdk.Functions" Version="1.0.26" />
   </ItemGroup>
   <ItemGroup>
     <ProjectReference Include="..\DDD.Functions.Extensions\DDD.Functions.Extensions.csproj" />
@@ -17,10 +17,10 @@
     <None Update="node_modules\**\*.*">
       <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
     </None>
-    <None Update="EventbriteNotification\function.json">
+    <None Update="TitoNotification\function.json">
       <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
     </None>
-    <None Update="EventbriteNotification\index.js">
+    <None Update="TitoNotification\index.js">
       <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
     </None>
     <None Update="host.json">

diff --git a/DDD.Functions/EventbriteSync.cs b/DDD.Functions/EventbriteSync.cs
diff --git a/DDD.Functions/GetVotes.cs b/DDD.Functions/GetVotes.cs
@@ -28,8 +28,8 @@ public static async Task<IActionResult> Run(
             SubmissionsConfig submissions,
             [BindVotingConfig]
             VotingConfig voting,
-            [BindEventbriteSyncConfig]
-            EventbriteSyncConfig eventbrite,
+            [BindTitoSyncConfig]
+            TitoSyncConfig titoSyncConfig,
             [BindAppInsightsSyncConfig]
             AppInsightsSyncConfig appInsights)
         {
@@ -42,17 +42,17 @@ public static async Task<IActionResult> Run(
             var votingRepo = await voting.GetRepositoryAsync();
             var votes = await votingRepo.GetAllAsync(conference.ConferenceInstance);
 
-            // Get Eventbrite ids
-            var ebRepo = await eventbrite.GetRepositoryAsync();
-            var eventbriteOrders = await ebRepo.GetAllAsync(conference.ConferenceInstance);
-            var eventbriteIds = eventbriteOrders.Select(o => o.OrderId).ToArray();
+            // Get Tito ids
+            var titoRebo = await titoSyncConfig.GetRepositoryAsync();
+            var titoOrders = await titoRebo.GetAllAsync(conference.ConferenceInstance);
+            var titoIds = titoOrders.Select(o => o.OrderId).ToArray();
 
             // Get AppInsights sessions
             var aiRepo = await appInsights.GetRepositoryAsync();
             var userSessions = await aiRepo.GetAllAsync(conference.ConferenceInstance);
 
             // Analyse votes
-            var analysedVotes = votes.Select(v => new AnalysedVote(v, votes, eventbriteIds, userSessions)).ToArray();
+            var analysedVotes = votes.Select(v => new AnalysedVote(v, votes, titoIds, userSessions)).ToArray();
 
             // Get summary
             var sessions = receivedSubmissions.Select(x => x.GetSession())

diff --git a/...ions/EventbriteNotification/function.json → DDD.Functions/TitoNotification/function.json b/...ions/EventbriteNotification/function.json → DDD.Functions/TitoNotification/function.json
diff --git a/...Functions/EventbriteNotification/index.js → DDD.Functions/TitoNotification/index.js b/...Functions/EventbriteNotification/index.js → DDD.Functions/TitoNotification/index.js
@@ -22,8 +22,6 @@ function deDupeWebhookRequest(payload, log, successAction, duplicateAction, erro
             errorAction();
         }
     });
-
-
 }
 
 function preventWebhookRequestDuplication(payload, log, successAction, errorAction) {
@@ -57,7 +55,7 @@ module.exports = function (context, req) {
     }
 
     var deDupePayload = {
-        webhook: "eventbrite",
+        webhook: "tito",
         action: req.body.config.action,
         id: req.body.api_url
     };
@@ -68,23 +66,20 @@ module.exports = function (context, req) {
             return;
         }
 
-        var orderUrl = req.body.api_url + "?expand=attendees,event,attendees.ticket_class";
-        var bearer = process.env["EventbriteApiBearerToken"]
-        request.get(orderUrl, {auth: {bearer: bearer}}, function(error, response, body) {
+        var orderUrl = req.body.api_url;
+        var token = process.env["TitoApiBearerToken"]
+        request.get(orderUrl, {auth: {token: `token=${token}`}}, function(error, response, body) {
 
             try {
 
                 var bodyAsJson = JSON.parse(body);
 
                 if (response && response.statusCode && response.statusCode === 200) {
-                    var attendees = bodyAsJson.attendees.map(function(attendee) {
+                    var attendees = bodyAsJson.tickets.map(function(ticket) {
                         return {
-                            name: attendee.profile.name,
+                            name: ticket.name,
                             event: bodyAsJson.event.name.text,
-                            ticketClass: attendee.ticket_class_name,
-                            qtySold: attendee.ticket_class.quantity_sold,
-                            totalQty: attendee.ticket_class.quantity_total,
-                            orderId: attendee.order_id
+                            orderId: tickets.registration_id
                         };
                     });
                     context.log("Attendee(s):", attendees);
@@ -98,7 +93,7 @@ module.exports = function (context, req) {
                     });
 
                 } else {
-                    context.log("ERROR calling EventBrite: (", response.statusCode, ") ", body);
+                    context.log("ERROR calling Tito: (", response.statusCode, ") ", body);
                     end(500);
                 }
             } catch (e) {
@@ -120,9 +115,9 @@ Test using:
     {
         action: 'order.placed',
         user_id: '141671750594',
-        endpoint_url: 'https://dddperth-eventbritewebhook.azurewebsites.net/api/HttpTriggerJS1?code=...',
+        endpoint_url: 'https://dddperth-titowebhook.azurewebsites.net/api/HttpTriggerJS1?code=...',
         webhook_id: '438789'
     },
-    api_url: 'https://www.eventbriteapi.com/v3/orders/650520140/'
+    api_url: 'https://api.tito.io/v3/:account_slug/:event_slug/registrations/:registration_slug'
 }
 */