[ID-39] WebTools events handling

.secrets.baseline

@@ -75,6 +75,10 @@
     {
       "path": "detect_secrets.filters.allowlist.is_line_allowlisted"
     },
+    {
+      "path": "detect_secrets.filters.common.is_baseline_file",
+      "filename": ".secrets.baseline"
+    },
     {
       "path": "detect_secrets.filters.common.is_ignored_due_to_verification_policies",
       "min_level": 2
@@ -105,12 +109,6 @@
     },
     {
       "path": "detect_secrets.filters.heuristic.is_templated_secret"
-    },
-    {
-      "path": "detect_secrets.filters.regex.should_exclude_file",
-      "pattern": [
-        "go.sum"
-      ]
     }
   ],
   "results": {
@@ -140,7 +138,39 @@
         "is_verified": false,
         "line_number": 41
       }
+    ],
+    "driver/web/adapter.go": [
+      {
+        "type": "Secret Keyword",
+        "filename": "driver/web/adapter.go",
+        "hashed_secret": "a7d09aaaf55864f7ce39a7715aabed433c3fe661",
+        "is_verified": false,
+        "line_number": 223
+      }
+    ],
+    "driver/web/auth.go": [
+      {
+        "type": "Secret Keyword",
+        "filename": "driver/web/auth.go",
+        "hashed_secret": "8435dc709de99714b7bcb7e6a9c9d4c498d7d38a",
+        "is_verified": false,
+        "line_number": 77
+      },
+      {
+        "type": "Secret Keyword",
+        "filename": "driver/web/auth.go",
+        "hashed_secret": "36c48d6ac9d10902792fa78b9c2d7d535971c2cc",
+        "is_verified": false,
+        "line_number": 199
+      },
+      {
+        "type": "Secret Keyword",
+        "filename": "driver/web/auth.go",
+        "hashed_secret": "fbc6c7d85067efe1a3dcf092a0999044c14b5fa5",
+        "is_verified": false,
+        "line_number": 212
+      }
     ]
   },
-  "generated_at": "2023-07-06T15:24:39Z"
+  "generated_at": "2024-02-02T12:25:52Z"
 }

CHANGELOG.md

@@ -5,6 +5,8 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
+### Added
+- WebTools events handling [#39](https://github.com/rokwire/gateway-building-block/issues/39)
 - added successteam end point
 - added successteam/pcp end point
 - added successteam/adivsors end point

core/app_admin.go → core/apis_admin.go

@@ -15,7 +15,6 @@
 package core
 
 import (
-	"application/core/interfaces"
 	"application/core/model"
 	"time"
 
@@ -53,7 +52,7 @@ func (a appAdmin) UpdateExample(example model.Example) error {
 
 // AppendExample appends to the data in an example - Example of transaction usage
 func (a appAdmin) AppendExample(example model.Example) (*model.Example, error) {
-	now := time.Now()
+	/*now := time.Now()
 	var newExample *model.Example
 	transaction := func(storage interfaces.Storage) error {
 		oldExample, err := storage.FindExample(example.OrgID, example.AppID, example.ID)
@@ -78,7 +77,8 @@ func (a appAdmin) AppendExample(example model.Example) (*model.Example, error) {
 		return nil, errors.WrapErrorAction(logutils.ActionCommit, logutils.TypeTransaction, nil, err)
 	}
 
-	return newExample, nil
+	return newExample, nil */
+	return nil, nil
 }
 
 // DeleteExample deletes an Example by ID

core/app_bbs.go → core/apis_bbs.go

@@ -90,6 +90,16 @@ func (a appBBs) DeleteAppointment(uin string, providerid int, sourceid string, a
 	}
 	return ret, nil
 }
+func (a appBBs) GetLegacyEvents() ([]model.LegacyEvent, error) {
+
+	leEvents, err := a.app.storage.FindAllLegacyEvents()
+	if err != nil {
+		return nil, err
+	}
+
+	return leEvents, nil
+
+}
 
 // newAppBBs creates new appBBs
 func newAppBBs(app *Application) appBBs {

core/app_client.go → core/apis_client.go

@@ -15,21 +15,21 @@
 package core
 
 import (
-	"application/core/interfaces"
 	"application/core/model"
 	"application/driven/uiucadapters"
+
 	"encoding/json"
 	"os"
 )
 
 // appClient contains client implementations
 type appClient struct {
 	app                *Application
-	Courseadapter      interfaces.Courses
-	LocationAdapter    interfaces.WayFinding
-	LaundryAdapter     interfaces.LaundryService
-	ContactAdapter     interfaces.Contact
-	SuccessTeamAdapter interfaces.SuccessTeam
+	Courseadapter      Courses
+	LocationAdapter    WayFinding
+	LaundryAdapter     LaundryService
+	ContactAdapter     Contact
+	SuccessTeamAdapter SuccessTeam
 }
 
 // GetExample gets an Example by ID
@@ -147,7 +147,13 @@ func (a appClient) GetTermSessions() (*[4]model.TermSession, error) {
 
 func (a appClient) GetSuccessTeam(uin string, unitid string, accesstoken string) (*model.SuccessTeam, int, error) {
 	conf, _ := a.app.GetEnvConfigs()
-	retData, status, err := a.SuccessTeamAdapter.GetSuccessTeam(uin, unitid, accesstoken, conf)
+
+	calendars, err := a.app.storage.FindCalendars(unitid)
+	if err != nil {
+		return nil, 500, err
+	}
+
+	retData, status, err := a.SuccessTeamAdapter.GetSuccessTeam(uin, calendars, accesstoken, conf)
 	if err != nil {
 		return nil, status, err
 	}
@@ -166,7 +172,13 @@ func (a appClient) GetPrimaryCareProvider(uin string, accesstoken string) (*[]mo
 
 func (a appClient) GetAcademicAdvisors(uin string, unitid string, accesstoken string) (*[]model.SuccessTeamMember, int, error) {
 	conf, _ := a.app.GetEnvConfigs()
-	retData, status, err := a.SuccessTeamAdapter.GetAcademicAdvisors(uin, unitid, accesstoken, conf)
+
+	calendars, err := a.app.storage.FindCalendars(unitid)
+	if err != nil {
+		return nil, 500, err
+	}
+
+	retData, status, err := a.SuccessTeamAdapter.GetAcademicAdvisors(uin, calendars, accesstoken, conf)
 	if err != nil {
 		return nil, status, err
 	}
@@ -193,6 +205,6 @@ func newAppClient(app *Application) appClient {
 	client.LaundryAdapter = uiucadapters.NewCSCLaundryAdapter(laundryAssets)
 	client.Courseadapter = uiucadapters.NewCourseAdapter()
 	client.LocationAdapter = uiucadapters.NewUIUCWayFinding()
-	client.SuccessTeamAdapter = uiucadapters.NewSuccessTeamAdapter(app.storage)
+	client.SuccessTeamAdapter = uiucadapters.NewSuccessTeamAdapter()
 	return client
 }

core/application.go

@@ -15,7 +15,6 @@
 package core
 
 import (
-	"application/core/interfaces"
 	"application/core/model"
 
 	"github.com/rokwire/core-auth-library-go/v3/authutils"
@@ -41,26 +40,39 @@ type Application struct {
 	version string
 	build   string
 
-	Default interfaces.Default // expose to the drivers adapters
-	Client  interfaces.Client  // expose to the drivers adapters
-	Admin   interfaces.Admin   // expose to the drivers adapters
-	BBs     interfaces.BBs     // expose to the drivers adapters
-	TPS     interfaces.TPS     // expose to the drivers adapters
-	System  interfaces.System  // expose to the drivers adapters
+	Default Default // expose to the drivers adapters
+	Client  Client  // expose to the drivers adapters
+	Admin   Admin   // expose to the drivers adapters
+	BBs     BBs     // expose to the drivers adapters
+	TPS     TPS     // expose to the drivers adapters
+	System  System  // expose to the drivers adapters
 	shared  Shared
 
-	AppointmentAdapters map[string]interfaces.Appointments //expose to the different vendor specific appointment adapters
+	AppointmentAdapters map[string]Appointments //expose to the different vendor specific appointment adapters
 
 	logger *logs.Logger
 
-	storage interfaces.Storage
+	storage Storage
+
+	eventsBBAdapter EventsBBAdapter
+
+	//events logic
+	eventsLogic eventsLogic
 }
 
 // Start starts the core part of the application
-func (a *Application) Start() {
+func (a *Application) Start() error {
 	//set storage listener
 	storageListener := storageListener{app: a}
 	a.storage.RegisterStorageListener(&storageListener)
+
+	err := a.eventsLogic.start()
+	if err != nil {
+		return err
+	}
+
+	//no error
+	return nil
 }
 
 // GetEnvConfigs retrieves the cached database env configs
@@ -77,8 +89,12 @@ func (a *Application) GetEnvConfigs() (*model.EnvConfigData, error) {
 }
 
 // NewApplication creates new Application
-func NewApplication(version string, build string, storage interfaces.Storage, appntAdapters map[string]interfaces.Appointments, logger *logs.Logger) *Application {
-	application := Application{version: version, build: build, storage: storage, logger: logger, AppointmentAdapters: appntAdapters}
+func NewApplication(version string, build string,
+	storage Storage,
+	eventsBBAdapter EventsBBAdapter,
+	appntAdapters map[string]Appointments,
+	logger *logs.Logger) *Application {
+	application := Application{version: version, build: build, storage: storage, eventsBBAdapter: eventsBBAdapter, logger: logger, AppointmentAdapters: appntAdapters}
 
 	//add the drivers ports/interfaces
 	application.Default = newAppDefault(&application)
@@ -88,6 +104,7 @@ func NewApplication(version string, build string, storage interfaces.Storage, ap
 	application.TPS = newAppTPS(&application)
 	application.System = newAppSystem(&application)
 	application.shared = newAppShared(&application)
+	application.eventsLogic = newAppEventsLogic(&application, eventsBBAdapter, *logger)
 
 	return &application
 }