Revert "feat(server): deprecated the subscription module."

This reverts commit 3b79ac66ae.

packages/server/src/loaders/jobs.ts

@@ -2,6 +2,12 @@ import Agenda from 'agenda';
 import ResetPasswordMailJob from 'jobs/ResetPasswordMail';
 import ComputeItemCost from 'jobs/ComputeItemCost';
 import RewriteInvoicesJournalEntries from 'jobs/WriteInvoicesJEntries';
+import SendLicenseViaPhoneJob from 'jobs/SendLicensePhone';
+import SendLicenseViaEmailJob from 'jobs/SendLicenseEmail';
+import SendSMSNotificationSubscribeEnd from 'jobs/SMSNotificationSubscribeEnd';
+import SendSMSNotificationTrialEnd from 'jobs/SMSNotificationTrialEnd';
+import SendMailNotificationSubscribeEnd from 'jobs/MailNotificationSubscribeEnd';
+import SendMailNotificationTrialEnd from 'jobs/MailNotificationTrialEnd';
 import UserInviteMailJob from 'jobs/UserInviteMail';
 import OrganizationSetupJob from 'jobs/OrganizationSetup';
 import OrganizationUpgrade from 'jobs/OrganizationUpgrade';
@@ -16,6 +22,8 @@ import { ImportDeleteExpiredFilesJobs } from '@/services/Import/jobs/ImportDelet
 export default ({ agenda }: { agenda: Agenda }) => {
   new ResetPasswordMailJob(agenda);
   new UserInviteMailJob(agenda);
+  new SendLicenseViaEmailJob(agenda);
+  new SendLicenseViaPhoneJob(agenda);
   new ComputeItemCost(agenda);
   new RewriteInvoicesJournalEntries(agenda);
   new OrganizationSetupJob(agenda);
@@ -31,4 +39,25 @@ export default ({ agenda }: { agenda: Agenda }) => {
   agenda.start().then(() => {
     agenda.every('1 hours', 'delete-expired-imported-files', {});
   });
+  // agenda.define(
+  //   'send-sms-notification-subscribe-end',
+  //   { priority: 'nromal', concurrency: 1, },
+  //   new SendSMSNotificationSubscribeEnd().handler,
+  // );
+  // agenda.define(
+  //   'send-sms-notification-trial-end',
+  //   { priority: 'normal', concurrency: 1, },
+  //   new SendSMSNotificationTrialEnd().handler,
+  // );
+  // agenda.define(
+  //   'send-mail-notification-subscribe-end',
+  //   { priority: 'high', concurrency: 1, },
+  //   new SendMailNotificationSubscribeEnd().handler
+  // );
+  // agenda.define(
+  //   'send-mail-notification-trial-end',
+  //   { priority: 'high', concurrency: 1, },
+  //   new SendMailNotificationTrialEnd().handler
+  // );
+  agenda.start();
 };

packages/server/src/loaders/systemRepositories.ts

@@ -1,6 +1,7 @@
 import Container from 'typedi';
 import {
   SystemUserRepository,
+  SubscriptionRepository,
   TenantRepository,
 } from '@/system/repositories';
 
@@ -10,6 +11,7 @@ export default () => {
 
   return {
     systemUserRepository: new SystemUserRepository(knex, cache),
+    subscriptionRepository: new SubscriptionRepository(knex, cache),
     tenantRepository: new TenantRepository(knex, cache),
   };
 }