@@ -73,7 +73,10 @@ func NewModuleCacheServiceImpl(logger *zap.SugaredLogger, K8sUtil *k8s.K8sServic
73
73
}
74
74
if ! exists {
75
75
// insert cicd module entry
76
- impl .updateModuleToInstalled (ModuleNameCicd )
76
+ err = impl .updateModuleToInstalled (ModuleNameCicd )
77
+ if err != nil {
78
+ return nil , err
79
+ }
77
80
78
81
// if old installation (i.e. project was created more than 1 hour ago then insert rest entries)
79
82
teamId := 1
@@ -86,7 +89,10 @@ func NewModuleCacheServiceImpl(logger *zap.SugaredLogger, K8sUtil *k8s.K8sServic
86
89
// insert first release components if this was old release and user installed full mode at that time
87
90
if time .Now ().After (team .CreatedOn .Add (1 * time .Hour )) {
88
91
for _ , supportedModuleName := range SupportedModuleNamesListFirstReleaseExcludingCicd {
89
- impl .updateModuleToInstalled (supportedModuleName )
92
+ err = impl .updateModuleToInstalled (supportedModuleName )
93
+ if err != nil {
94
+ return nil , err
95
+ }
90
96
}
91
97
}
92
98
}
@@ -102,7 +108,7 @@ func NewModuleCacheServiceImpl(logger *zap.SugaredLogger, K8sUtil *k8s.K8sServic
102
108
return impl , nil
103
109
}
104
110
105
- func (impl * ModuleCacheServiceImpl ) updateModuleToInstalled (moduleName string ) {
111
+ func (impl * ModuleCacheServiceImpl ) updateModuleToInstalled (moduleName string ) error {
106
112
module := & moduleRepo.Module {
107
113
Name : moduleName ,
108
114
Version : impl .serverDataStore .CurrentVersion ,
@@ -112,8 +118,9 @@ func (impl *ModuleCacheServiceImpl) updateModuleToInstalled(moduleName string) {
112
118
err := impl .moduleRepository .Save (module )
113
119
if err != nil {
114
120
log .Println ("Error while saving module." , "moduleName" , moduleName , "error" , err )
115
- return
121
+ return err
116
122
}
123
+ return nil
117
124
}
118
125
119
126
func (impl * ModuleCacheServiceImpl ) buildInformerToListenOnInstallerObject () {
0 commit comments