Improve error checking code and fix sql script

changelog/unreleased/notifications-changes.md

@@ -0,0 +1,3 @@
+Change: Clean up notifications error checking code, fix sql creation script
+
+https://github.com/cs3org/reva/pull/????

internal/serverless/services/notifications/notifications.go

@@ -217,14 +217,13 @@ func (s *svc) handleMsgTemplate(msg []byte) {
 
 	name, err := s.templates.Put(msg, s.handlers)
 	if err != nil {
-		s.log.Error().Err(err).Msgf("template registration failed %v", err)
+		s.log.Error().Err(err).Msg("template registration failed")
 
 		// If a template file was not found, delete that template from the registry altogether,
 		// this way we ensure templates that are deleted from the config are deleted from the
 		// store too.
-		wrappedErr := errors.Unwrap(errors.Unwrap(err))
-		_, isFileNotFoundError := wrappedErr.(*template.FileNotFoundError)
-		if isFileNotFoundError && name != "" {
+		var e *template.FileNotFoundError
+		if errors.As(err, &e) && name != "" {
 			err := s.kv.Purge(name)
 			if err != nil {
 				s.log.Error().Err(err).Msgf("deletion of template %s from store failed", name)
@@ -270,8 +269,8 @@ func (s *svc) handleMsgUnregisterNotification(msg *nats.Msg) {
 
 	err := s.nm.DeleteNotification(ref)
 	if err != nil {
-		_, isNotFoundError := err.(*notification.NotFoundError)
-		if isNotFoundError {
+		var e *notification.NotFoundError
+		if errors.As(err, &e) {
 			s.log.Debug().Msgf("a notification with ref %s does not exist", ref)
 		} else {
 			s.log.Error().Err(err).Msgf("notification unregister failed")
@@ -318,8 +317,8 @@ func (s *svc) handleMsgTrigger(msg *nats.Msg) {
 	if notif == nil {
 		notif, err = s.nm.GetNotification(tr.Ref)
 		if err != nil {
-			_, isNotFoundError := err.(*notification.NotFoundError)
-			if isNotFoundError {
+			var e *notification.NotFoundError
+			if errors.As(err, &e) {
 				s.log.Debug().Msgf("trigger %s does not have a notification attached", tr.Ref)
 				return
 			}

pkg/notification/db_changes.sql

@@ -41,11 +41,12 @@ COMMIT;
 CREATE INDEX `cbox_notifications_ix0` ON `cbox_notifications` (`ref`);
 
 CREATE INDEX `cbox_notification_recipients_ix0` ON `cbox_notification_recipients` (`notification_id`);
-CREATE INDEX `cbox_notification_recipients_ix1` ON `cbox_notification_recipients` (`user_name`);
+CREATE INDEX `cbox_notification_recipients_ix1` ON `cbox_notification_recipients` (`recipient`);
 
 -- changes for added notifications on oc shares
 
 ALTER TABLE cernboxngcopy.oc_share ADD notify_uploads BOOL DEFAULT false;
+ALTER TABLE cernboxngcopy.oc_share ADD notify_uploads_extra_recipients VARCHAR(2048);
 
 UPDATE cernboxngcopy.oc_share SET notify_uploads = false;
 

pkg/notification/notification.go

@@ -55,12 +55,12 @@ type InvalidNotificationError struct {
 }
 
 // Error returns the string error msg for NotFoundError.
-func (n *NotFoundError) Error() string {
+func (n NotFoundError) Error() string {
 	return fmt.Sprintf("notification %s not found", n.Ref)
 }
 
 // Error returns the string error msg for InvalidNotificationError.
-func (i *InvalidNotificationError) Error() string {
+func (i InvalidNotificationError) Error() string {
 	return i.Msg
 }
 

pkg/notification/template/template.go

@@ -60,7 +60,7 @@ type FileNotFoundError struct {
 }
 
 // Error returns the string error msg for FileNotFoundError.
-func (t *FileNotFoundError) Error() string {
+func (t FileNotFoundError) Error() string {
 	return fmt.Sprintf("template file %s not found", t.TemplateFileName)
 }